connect.c File Reference

#include "precomp.h"
#include "nddeagnt.h"

Go to the source code of this file.

Classes
struct	tagINIT_ENUM
Defines
#define	ValidateConvList(h)
#define	ValidateAllConvLists()
#define	ORPATH(x)
Typedefs
typedef tagINIT_ENUM	INIT_ENUM
typedef tagINIT_ENUM *	PINIT_ENUM
Functions
BOOL	InitiateEnumerationProc (HWND hwndTarget, PINIT_ENUM pie)
VOID	DisconnectConv (PCONV_INFO pcoi)
HCONV	DdeConnect (DWORD idInst, HSZ hszService, HSZ hszTopic, PCONVCONTEXT pCC)
HCONVLIST	DdeConnectList (DWORD idInst, HSZ hszService, HSZ hszTopic, HCONVLIST hConvList, PCONVCONTEXT pCC)
HCONV	DdeReconnect (HCONV hConv)
BOOL	ValidateConnectParameters (HANDLE hInst, PCL_INSTANCE_INFO *ppcii, HSZ *phszService, HSZ hszTopic, LATOM *plaNormalSvcName, PCONVCONTEXT *ppCC, HWND *phwndTarget, HCONVLIST hConvList)
PCL_CONV_INFO	ConnectConv (PCL_INSTANCE_INFO pcii, LATOM laService, LATOM laTopic, HWND hwndTarget, HWND hwndSkip, PCONVCONTEXT pCC, HCONVLIST hConvList, DWORD clst)
VOID	SetCommonStateFlags (HWND hwndUs, HWND hwndThem, PWORD pwFlags)
HCONV	DdeQueryNextServer (HCONVLIST hConvList, HCONV hConvPrev)
BOOL	DdeDisconnect (HCONV hConv)
BOOL	DdeDisconnectList (HCONVLIST hConvList)
VOID	ShutdownConversation (PCONV_INFO pcoi, BOOL fMakeCallback)
VOID	UnlinkConvFromOthers (PCONV_INFO pcoi, BOOL gGoingZombie)
VOID	FreeConversationResources (PCONV_INFO pcoi)
BOOL	WaitForZombieTerminate (HANDLE hData)
Variables
CONVCONTEXT	TempConvContext
CONVCONTEXT	DefConvContext

---

Define Documentation

#define ORPATH (  x   )

Referenced by UnlinkConvFromOthers().

#define ValidateAllConvLists (   )

Definition at line 103 of file connect.c. Referenced by UnlinkConvFromOthers().

#define ValidateConvList (  h   )

Definition at line 102 of file connect.c. Referenced by DdeConnectList(), DdeDisconnectList(), and UnlinkConvFromOthers().

---

Typedef Documentation

typedef struct tagINIT_ENUM INIT_ENUM

typedef struct tagINIT_ENUM * PINIT_ENUM

---

Function Documentation

PCL_CONV_INFO ConnectConv (  PCL_INSTANCE_INFO  pcii, LATOM  laService, LATOM  laTopic, HWND  hwndTarget, HWND  hwndSkip, PCONVCONTEXT  pCC, HCONVLIST  hConvList, DWORD  clst )

Definition at line 607 of file connect.c. References tagSERVERINFO::atomSysClass, CheckDDECritIn, CheckDDECritOut, tagCL_CONV_INFO::ci, tagINIT_ENUM::clst, CLST_CONNECTED, DWORD, EnterDDECrit, EnumWindows(), Error, tagCL_INSTANCE_INFO::flags, GATOM, GetWindowLongPtr(), gpsi, GWL_CONVSTATE, GWLP_CHINST, GWLP_PCI, GWLP_SHINST, tagINIT_ENUM::hConvList, tagCL_INSTANCE_INFO::hInstClient, tagCL_INSTANCE_INFO::hInstServer, tagINIT_ENUM::hwndClient, tagCL_INSTANCE_INFO::hwndMother, tagCL_CONV_INFO::hwndReconnect, tagINIT_ENUM::hwndSkip, ICLS_DDEMLCLIENTA, ICLS_DDEMLCLIENTW, IIF_UNICODE, IncLocalAtomCount(), InitiateEnumerationProc(), L, tagINIT_ENUM::laServiceRequested, tagCONV_INFO::laServiceRequested, tagINIT_ENUM::laTopic, LeaveDDECrit, LocalToGlobalAtom(), tagINIT_ENUM::lParam, LPVOID, MONCONV, tagCL_INSTANCE_INFO::MonitorFlags, tagCONV_INFO::next, NtUserDdeSetQualityOfService(), NtUserDestroyWindow(), NULL, SendMessage(), SetConvContext(), SetLastDDEMLError(), SetWindowLongPtr(), and TRUE. Referenced by DdeConnect(), DdeConnectList(), and DdeReconnect(). { INIT_ENUM ie; PCL_CONV_INFO pci; PCONV_INFO pcoi; GATOM gaService, gaTopic; CheckDDECritIn; if (hwndTarget && hwndTarget == hwndSkip) { return(NULL); } LeaveDDECrit; CheckDDECritOut; if (pcii->flags & IIF_UNICODE) { ie.hwndClient = CreateWindowW((LPWSTR)(gpsi->atomSysClass[ICLS_DDEMLCLIENTW]), L"", WS_CHILD, 0, 0, 0, 0, pcii->hwndMother, (HMENU)0, (HANDLE)0, (LPVOID)NULL); } else { ie.hwndClient = CreateWindowA((LPSTR)(gpsi->atomSysClass[ICLS_DDEMLCLIENTA]), "", WS_CHILD, 0, 0, 0, 0, pcii->hwndMother, (HMENU)0, (HANDLE)0, (LPVOID)NULL); } EnterDDECrit; if (ie.hwndClient == 0) { return (NULL); } if (pCC != NULL) { if (!NtUserDdeSetQualityOfService(ie.hwndClient, &(pCC->qos), NULL)) { SetLastDDEMLError(pcii, DMLERR_MEMORY_ERROR); goto Error; } } /* * Note that a pci will be created and allocated for each ACK recieved. */ SetConvContext(ie.hwndClient, (LONG *)pCC); SetWindowLong(ie.hwndClient, GWL_CONVSTATE, clst); SetWindowLongPtr(ie.hwndClient, GWLP_SHINST, (LONG_PTR)pcii->hInstServer); SetWindowLongPtr(ie.hwndClient, GWLP_CHINST, (LONG_PTR)pcii->hInstClient); gaService = LocalToGlobalAtom(laService); gaTopic = LocalToGlobalAtom(laTopic); ie.lParam = MAKELONG(gaService, gaTopic); if (!hwndTarget) { ie.hwndSkip = hwndSkip; ie.laServiceRequested = laService; ie.laTopic = laTopic; ie.hConvList = hConvList; ie.clst = clst; } LeaveDDECrit; if (hwndTarget) { SendMessage(hwndTarget, WM_DDE_INITIATE, (WPARAM)ie.hwndClient, ie.lParam); } else { /* * Send this message to the nddeagnt app first so it can start * the netdde services BEFORE we do an enumeration of windows. * This lets things work the first time. NetDDEAgent caches * service status so this is the fastest way to do this. */ HWND hwndAgent = FindWindowW(SZ_NDDEAGNT_CLASS, SZ_NDDEAGNT_TITLE); if (hwndAgent) { SendMessage(hwndAgent, WM_DDE_INITIATE, (WPARAM)ie.hwndClient, ie.lParam); } EnumWindows((WNDENUMPROC)InitiateEnumerationProc, (LPARAM)&ie); } EnterDDECrit; /* * hConvList may have been destroyed during the enumeration but we are * done with it now so no need to revalidate. */ #if DBG { WCHAR sz[10]; if (gaService && GlobalGetAtomName(gaService, sz, 10) == 0) { RIPMSG1(RIP_ERROR, "Bad Service Atom after Initiate phase: %lX", (DWORD)gaService); } if (gaTopic && GlobalGetAtomName(gaTopic, sz, 10) == 0) { RIPMSG1(RIP_ERROR, "Bad Topic Atom after Initiate phase: %lX", (DWORD)gaTopic); } } #endif // DBG GlobalDeleteAtom(gaService); GlobalDeleteAtom(gaTopic); // // Get the first pci allocated when a WM_DDE_ACK was recieved. // pci = (PCL_CONV_INFO)GetWindowLongPtr(ie.hwndClient, GWLP_PCI); if (pci == NULL) { Error: LeaveDDECrit; NtUserDestroyWindow(ie.hwndClient); EnterDDECrit; return (NULL); } SetWindowLong(ie.hwndClient, GWL_CONVSTATE, CLST_CONNECTED); if (hwndTarget) { /* * If hwndTarget was NULL, the enumeration proc took care of this. */ pci->hwndReconnect = hwndTarget; UserAssert(pci->ci.next == NULL); pci->ci.laServiceRequested = laService; IncLocalAtomCount(laService); // pci copy } if (pcii->MonitorFlags & MF_CONV) { for (pcoi = (PCONV_INFO)pci; pcoi; pcoi = pcoi->next) { MONCONV(pcoi, TRUE); } } return (pci); }

HCONV DdeConnect (  DWORD  idInst, HSZ  hszService, HSZ  hszTopic, PCONVCONTEXT  pCC )

Definition at line 146 of file connect.c. References tagCL_INSTANCE_INFO::afCmd, tagCL_CONV_INFO::ci, CLST_SINGLE_INITIALIZING, ConnectConv(), EnterDDECrit, tagCONV_INFO::hConv, tagCL_INSTANCE_INFO::hwndMother, LATOM, LATOM_FROM_HSZ, LeaveDDECrit, NULL, SetLastDDEMLError(), and ValidateConnectParameters(). { PCL_INSTANCE_INFO pcii; PCL_CONV_INFO pci; HCONV hConvRet = 0; HWND hwndTarget = 0; LATOM aNormalSvcName = 0; EnterDDECrit; if (!ValidateConnectParameters((HANDLE)LongToHandle( idInst ), &pcii, &hszService, hszTopic, &aNormalSvcName, &pCC, &hwndTarget, 0)) { goto Exit; } pci = ConnectConv(pcii, LATOM_FROM_HSZ(hszService), LATOM_FROM_HSZ(hszTopic), hwndTarget, (pcii->afCmd & CBF_FAIL_SELFCONNECTIONS) ? pcii->hwndMother : 0, pCC, 0, CLST_SINGLE_INITIALIZING); if (pci == NULL) { SetLastDDEMLError(pcii, DMLERR_NO_CONV_ESTABLISHED); goto Exit; } else { hConvRet = pci->ci.hConv; } Exit: if (aNormalSvcName) { GlobalDeleteAtom(aNormalSvcName); } LeaveDDECrit; return (hConvRet); }

HCONVLIST DdeConnectList (  DWORD  idInst, HSZ  hszService, HSZ  hszTopic, HCONVLIST  hConvList, PCONVCONTEXT  pCC )

Definition at line 195 of file connect.c. References tagCL_INSTANCE_INFO::afCmd, tagCONVLIST::ahwnd, CheckDDECritOut, tagCONVLIST::chwnd, CLST_MULT_INITIALIZING, ConnectConv(), CONVLIST, CreateHandle(), DDEMLAlloc, DDEMLFree, DDEMLReAlloc, DestroyHandle(), DisconnectConv(), EnterDDECrit, FALSE, GetHandleData(), GetWindowLongPtr(), GWLP_PCI, tagCL_INSTANCE_INFO::hInstClient, HTYPE_CONVERSATION_LIST, tagCONV_INFO::hwndConv, tagCL_INSTANCE_INFO::hwndMother, InstFromHandle, LATOM, LATOM_FROM_HSZ, LeaveDDECrit, tagCONV_INFO::next, NULL, SetHandleData(), SetLastDDEMLError(), ShutdownConversation(), tagCONV_INFO::state, ValidateConnectParameters(), and ValidateConvList. { PCL_INSTANCE_INFO pcii; PCONV_INFO pcoi, pcoiNew, pcoiExisting, pcoiNext; HCONVLIST hConvListRet = 0; HWND hwndTarget = 0; LATOM aNormalSvcName = 0; PCONVLIST pcl = NULL; HCONVLIST hConvListOld; int i; CheckDDECritOut; EnterDDECrit; if (!ValidateConnectParameters((HANDLE)LongToHandle( idInst ), &pcii, &hszService, hszTopic, &aNormalSvcName, &pCC, &hwndTarget, hConvList)) { goto Exit; } ValidateConvList(hConvList); hConvListOld = hConvList; pcoi = (PCONV_INFO)ConnectConv(pcii, LATOM_FROM_HSZ(hszService), LATOM_FROM_HSZ(hszTopic), hwndTarget, (pcii->afCmd & (CBF_FAIL_SELFCONNECTIONS | CBF_FAIL_CONNECTIONS)) ? pcii->hwndMother : 0, pCC, hConvListOld, CLST_MULT_INITIALIZING); if (pcoi == NULL) { /* * no new connections made */ SetLastDDEMLError(pcii, DMLERR_NO_CONV_ESTABLISHED); hConvListRet = hConvListOld; goto Exit; } /* * allocate or reallocate the hConvList hwnd list for later addition * If we already have a valid list, reuse the handle so we don't have * to alter the preexisting pcoi->hConvList values. */ if (hConvListOld == 0) { pcl = (PCONVLIST)DDEMLAlloc(sizeof(CONVLIST)); if (pcl == NULL) { SetLastDDEMLError(pcii, DMLERR_MEMORY_ERROR); DisconnectConv(pcoi); goto Exit; } // pcl->chwnd = 0; LPTR zero inits. hConvList = (HCONVLIST)CreateHandle((ULONG_PTR)pcl, HTYPE_CONVERSATION_LIST, InstFromHandle(pcii->hInstClient)); if (hConvList == 0) { DDEMLFree(pcl); SetLastDDEMLError(pcii, DMLERR_MEMORY_ERROR); DisconnectConv(pcoi); goto Exit; } } else { pcl = (PCONVLIST)GetHandleData((HANDLE)hConvList); pcl = DDEMLReAlloc(pcl, sizeof(CONVLIST) + sizeof(HWND) * pcl->chwnd); if (pcl == NULL) { SetLastDDEMLError(pcii, DMLERR_MEMORY_ERROR); hConvListRet = hConvListOld; DisconnectConv(pcoi); goto Exit; } SetHandleData((HANDLE)hConvList, (ULONG_PTR)pcl); } ValidateConvList(hConvListOld); if (hConvListOld) { /* * remove duplicates from new conversations * * Although we tried to prevent duplicates from happening * within the initiate enumeration code, wild initiates or * servers responding with different service names than * requested could cause duplicates. */ /* For each client window... */ for (i = 0; i < pcl->chwnd; i++) { /* For each existing conversation in that window... */ for (pcoiExisting = (PCONV_INFO) GetWindowLongPtr(pcl->ahwnd[i], GWLP_PCI); pcoi != NULL && pcoiExisting != NULL; pcoiExisting = pcoiExisting->next) { if (!(pcoiExisting->state & ST_CONNECTED)) continue; /* For each new conversation... */ for (pcoiNew = pcoi; pcoiNew != NULL; pcoiNew = pcoiNext) { pcoiNext = pcoiNew->next; /* see if the new conversation duplicates the existing one */ if (!(pcoiNew->state & ST_CONNECTED)) continue; UserAssert(((PCL_CONV_INFO)pcoiExisting)->hwndReconnect); UserAssert(((PCL_CONV_INFO)pcoiNew)->hwndReconnect); if (((PCL_CONV_INFO)pcoiExisting)->hwndReconnect == ((PCL_CONV_INFO)pcoiNew)->hwndReconnect && pcoiExisting->laTopic == pcoiNew->laTopic && pcoiExisting->laService == pcoiNew->laService) { /* * duplicate conversation - disconnection causes an unlink */ if (pcoiNew == pcoi) { /* * We are freeing up the head of the list, * Reset the head to the next guy. */ pcoi = pcoiNext; } ValidateConvList(hConvList); ShutdownConversation(pcoiNew, FALSE); ValidateConvList(hConvList); break; } } } } for (pcoiExisting = pcoi; pcoiExisting != NULL; pcoiExisting = pcoiExisting->next) { /* * if these are all zombies - we DONT want to link it in! * This is possible because ShutdownConversation() leaves the critical section * and could allow responding terminates to come through. */ if (pcoiExisting->state & ST_CONNECTED) { goto FoundOne; } } pcoi = NULL; // abandon this guy - he will clean up in time. FoundOne: /* * add new pcoi (if any are left) hwnd to ConvList hwnd list. */ if (pcoi != NULL) { UserAssert(pcoi->hwndConv); pcl->ahwnd[pcl->chwnd] = pcoi->hwndConv; pcl->chwnd++; hConvListRet = hConvList; } else { hConvListRet = hConvListOld; if (!hConvListOld) { DestroyHandle((HANDLE)hConvList); } } } else { // no hConvListOld UserAssert(pcoi->hwndConv); pcl->ahwnd[0] = pcoi->hwndConv; pcl->chwnd = 1; hConvListRet = hConvList; } if (pcoi != NULL) { /* * set hConvList field for all remaining new conversations. */ UserAssert(hConvListRet); for (pcoiNew = pcoi; pcoiNew != NULL; pcoiNew = pcoiNew->next) { if (pcoiNew->state & ST_CONNECTED) { ((PCL_CONV_INFO)pcoiNew)->hConvList = hConvListRet; } } } Exit: if (aNormalSvcName) { DeleteAtom(aNormalSvcName); } ValidateConvList(hConvListRet); LeaveDDECrit; return (hConvListRet); }

BOOL DdeDisconnect (  HCONV  hConv  )

Definition at line 1008 of file connect.c. References BestSetLastDDEMLError(), BOOL, CheckDDECritOut, EnterDDECrit, FALSE, HINST_ANY, HTYPE_CLIENT_CONVERSATION, HTYPE_SERVER_CONVERSATION, LeaveDDECrit, NULL, PciiFromHandle(), ShutdownConversation(), tagCONV_INFO::state, TRUE, and ValidateCHandle(). Referenced by DdeUninitialize(). { BOOL fRet = FALSE; PCONV_INFO pcoi; PCL_INSTANCE_INFO pcii; CheckDDECritOut; EnterDDECrit; pcoi = (PCONV_INFO)ValidateCHandle((HANDLE)hConv, HTYPE_CLIENT_CONVERSATION, HINST_ANY); if (pcoi == NULL) { pcoi = (PCONV_INFO)ValidateCHandle((HANDLE)hConv, HTYPE_SERVER_CONVERSATION, HINST_ANY); } if (pcoi == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } pcii = PciiFromHandle((HANDLE)hConv); if (pcii == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } if (pcoi->state & ST_CONNECTED) { ShutdownConversation(pcoi, FALSE); } fRet = TRUE; Exit: LeaveDDECrit; return (fRet); }

BOOL DdeDisconnectList (  HCONVLIST  hConvList  )

Definition at line 1053 of file connect.c. References tagCONVLIST::ahwnd, BestSetLastDDEMLError(), BOOL, CheckDDECritOut, tagCONVLIST::chwnd, DDEMLFree, DestroyHandle(), EnterDDECrit, FALSE, GetWindowLongPtr(), GWLP_PCI, HINST_ANY, HTYPE_CONVERSATION_LIST, LeaveDDECrit, tagCONV_INFO::next, NULL, PciiFromHandle(), ShutdownConversation(), tagCONV_INFO::state, TRUE, ValidateCHandle(), and ValidateConvList. Referenced by DdeUninitialize(). { BOOL fRet = FALSE; PCL_INSTANCE_INFO pcii; PCONVLIST pcl; PCONV_INFO pcoi, pcoiNext; int i; CheckDDECritOut; EnterDDECrit; pcl = (PCONVLIST)ValidateCHandle((HANDLE)hConvList, HTYPE_CONVERSATION_LIST, HINST_ANY); if (pcl == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } ValidateConvList(hConvList); pcii = PciiFromHandle((HANDLE)hConvList); if (pcii == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } for(i = pcl->chwnd - 1; i >= 0; i--) { pcoi = (PCONV_INFO)GetWindowLongPtr(pcl->ahwnd[i], GWLP_PCI); while (pcoi != NULL && pcoi->state & ST_CONNECTED) { pcoiNext = pcoi->next; ShutdownConversation(pcoi, FALSE); // may unlink pcoi! pcoi = pcoiNext; } } DestroyHandle((HANDLE)hConvList); DDEMLFree(pcl); fRet = TRUE; Exit: LeaveDDECrit; return (fRet); }

HCONV DdeQueryNextServer (  HCONVLIST  hConvList, HCONV  hConvPrev )

Definition at line 906 of file connect.c. References tagCONVLIST::ahwnd, BestSetLastDDEMLError(), tagCONVLIST::chwnd, tagCL_CONV_INFO::ci, EnterDDECrit, GetWindowLongPtr(), GWLP_PCI, tagCONV_INFO::hConv, tagCL_CONV_INFO::hConvList, HINST_ANY, HTYPE_CLIENT_CONVERSATION, HTYPE_CONVERSATION_LIST, HTYPE_ZOMBIE_CONVERSATION, tagCONV_INFO::hwndConv, InstFromHandle, tagCL_INSTANCE_INFO::LastError, LeaveDDECrit, tagCONV_INFO::next, NULL, PciiFromHandle(), SetLastDDEMLError(), TypeFromHandle, and ValidateCHandle(). { HCONV hConvRet = 0; PCONVLIST pcl; HWND *phwnd; int i; PCL_CONV_INFO pci; PCL_INSTANCE_INFO pcii; EnterDDECrit; pcl = (PCONVLIST)ValidateCHandle((HANDLE)hConvList, HTYPE_CONVERSATION_LIST, HINST_ANY); if (pcl == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } if (!pcl->chwnd) { // empty list goto Exit; } pcii = PciiFromHandle((HANDLE)hConvList); if (pcii == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } pcii->LastError = DMLERR_NO_ERROR; do { hConvRet = 0; if (hConvPrev == 0) { pci = (PCL_CONV_INFO)GetWindowLongPtr(pcl->ahwnd[0], GWLP_PCI); if (pci == NULL) { goto Exit; // Must have all conversations zombied. } hConvPrev = hConvRet = pci->ci.hConv; continue; } pci = (PCL_CONV_INFO)ValidateCHandle((HANDLE)hConvPrev, HTYPE_CLIENT_CONVERSATION, InstFromHandle(hConvList)); if (pci == NULL) { pci = (PCL_CONV_INFO)ValidateCHandle((HANDLE)hConvPrev, HTYPE_ZOMBIE_CONVERSATION, InstFromHandle(hConvList)); if (pci == NULL) { SetLastDDEMLError(pcii, DMLERR_INVALIDPARAMETER); break; } else { goto ZombieSkip; } } if (pci->hConvList != hConvList) { SetLastDDEMLError(pcii, DMLERR_INVALIDPARAMETER); break; } ZombieSkip: if (pci->ci.next == NULL) { /* * end of list for this window, go to next window */ for (phwnd = pcl->ahwnd, i = 0; (i + 1) < pcl->chwnd; i++) { if (phwnd[i] == pci->ci.hwndConv) { pci = (PCL_CONV_INFO)GetWindowLongPtr(phwnd[i + 1], GWLP_PCI); if (pci == NULL) { break; } hConvPrev = hConvRet = pci->ci.hConv; break; } } } else { hConvPrev = hConvRet = pci->ci.next->hConv; // next conv for this window. } } while (hConvRet && TypeFromHandle(hConvRet) == HTYPE_ZOMBIE_CONVERSATION); Exit: LeaveDDECrit; return (hConvRet); }

HCONV DdeReconnect (  HCONV  hConv  )

Definition at line 409 of file connect.c. References tagCONV_INFO::aLinks, BestSetLastDDEMLError(), tagCL_CONV_INFO::ci, tagCONV_INFO::cLinks, CLST_SINGLE_INITIALIZING, ClStartAdvise(), ConnectConv(), DDEMLAlloc, DDEMLFree, EnterDDECrit, tagXACT_INFO::flags, tagXACT_INFO::gaItem, GetConvContext(), tagCONV_INFO::hConv, HINST_ANY, HTYPE_CLIENT_CONVERSATION, tagCONV_INFO::hwndConv, tagCL_CONV_INFO::hwndReconnect, tagADVISE_LINK::laItem, tagCONV_INFO::laService, tagCONV_INFO::laTopic, LeaveDDECrit, LocalToGlobalAtom(), NULL, PADVISE_LINK, PciiFromHandle(), tagXACT_INFO::pcoi, SetLastDDEMLError(), tagCONV_INFO::state, ValidateCHandle(), tagADVISE_LINK::wFmt, tagXACT_INFO::wFmt, tagADVISE_LINK::wType, tagXACT_INFO::wType, XACT_INFO, and XIF_ABANDONED. { PCL_INSTANCE_INFO pcii; PCL_CONV_INFO pci, pciNew; HCONV hConvRet = 0; CONVCONTEXT cc; EnterDDECrit; pcii = PciiFromHandle((HANDLE)hConv); if (pcii == NULL) { BestSetLastDDEMLError(DMLERR_INVALIDPARAMETER); goto Exit; } pci = (PCL_CONV_INFO)ValidateCHandle((HANDLE)hConv, HTYPE_CLIENT_CONVERSATION, HINST_ANY); if (pci == NULL) { SetLastDDEMLError(pcii, DMLERR_INVALIDPARAMETER); goto Exit; } if (pci->ci.state & ST_CONNECTED) { goto Exit; } GetConvContext(pci->ci.hwndConv, (LONG *)&cc); pciNew = ConnectConv(pcii, pci->ci.laService, pci->ci.laTopic, pci->hwndReconnect, 0, &cc, 0, CLST_SINGLE_INITIALIZING); if (pciNew == NULL) { SetLastDDEMLError(pcii, DMLERR_NO_CONV_ESTABLISHED); goto Exit; } else { hConvRet = pciNew->ci.hConv; if (pci->ci.cLinks) { PXACT_INFO pxi; int iLink; PADVISE_LINK paLink; /* * reestablish advise links */ for (paLink = pci->ci.aLinks, iLink = pci->ci.cLinks; iLink; paLink++, iLink--) { pxi = (PXACT_INFO)DDEMLAlloc(sizeof(XACT_INFO)); if (pxi == NULL) { break; // abort relinking } pxi->pcoi = (PCONV_INFO)pciNew; pxi->gaItem = LocalToGlobalAtom(paLink->laItem); // pxi copy pxi->wFmt = paLink->wFmt; pxi->wType = (WORD)((paLink->wType >> 12) | XTYP_ADVSTART); if (ClStartAdvise(pxi)) { pxi->flags |= XIF_ABANDONED; } else { GlobalDeleteAtom(pxi->gaItem); DDEMLFree(pxi); } } } } Exit: LeaveDDECrit; return (hConvRet); }

VOID DisconnectConv (  PCONV_INFO  pcoi  )

Definition at line 759 of file connect.c. References FALSE, tagCONV_INFO::next, ShutdownConversation(), and VOID(). Referenced by DdeConnectList(). { PCONV_INFO pcoiNext; for (; pcoi; pcoi = pcoiNext) { pcoiNext = pcoi->next; ShutdownConversation(pcoi, FALSE); } }

VOID FreeConversationResources (  PCONV_INFO  pcoi  )

Definition at line 1354 of file connect.c. References tagCONV_INFO::aLinks, CheckDDECritIn, tagCONV_INFO::cLinks, tagCONV_INFO::cLocks, CreateHandle(), DDEMLFree, DeleteLinkCount(), DestroyHandle(), tagCONV_INFO::dmqIn, tagCONV_INFO::dmqOut, DumpDDEMessage(), FALSE, tagXACT_INFO::flags, tagCONV_INFO::hConv, HTYPE_ZOMBIE_CONVERSATION, tagCONV_INFO::hwndConv, tagCONV_INFO::hwndPartner, InstFromHandle, tagADVISE_LINK::laItem, tagCONV_INFO::laService, tagCONV_INFO::laServiceRequested, tagCONV_INFO::laTopic, LocalToGlobalAtom(), tagDDE_MESSAGE_QUEUE::lParam, MONLINK, tagDDE_MESSAGE_QUEUE::msg, tagXACT_INFO::next, tagDDE_MESSAGE_QUEUE::next, NULL, tagCONV_INFO::pcii, tagXACT_INFO::pfnResponse, tagADVISE_LINK::pLinkCount, PostMessage(), tagCONV_INFO::pxiOut, tagCONV_INFO::state, TID_TIMEOUT, TRUE, UnlinkConvFromOthers(), VOID(), tagADVISE_LINK::wFmt, tagADVISE_LINK::wType, and XIF_SYNCHRONOUS. Referenced by DdeClientTransaction(), DdeEnableCallback(), DdePostAdvise(), EnableEnumProc(), ProcessAsyncDDEMsg(), ProcessSyncDDEMessage(), and ShutdownConversation(). { PADVISE_LINK paLink; PDDE_MESSAGE_QUEUE pdmq; PXACT_INFO pxi; CheckDDECritIn; /* * Don't free resources on locked conversations. */ if (pcoi->cLocks > 0) { pcoi->state |= ST_FREE_CONV_RES_NOW; return; } /* * Don't free resources if a synchronous transaction is in effect! */ pxi = pcoi->pxiOut; while (pxi != NULL) { if (pxi->flags & XIF_SYNCHRONOUS) { /* * This conversation is in a synchronous transaction. * Shutdown the modal loop FIRST, then call this when * the loop exits. */ PostMessage(pcoi->hwndConv, WM_TIMER, TID_TIMEOUT, 0); pcoi->state |= ST_FREE_CONV_RES_NOW; return; } pxi = pxi->next; } /* * If this is an Intra-Process conversation that hasn't yet received * a terminate message, make it a zombie. We will call this routine * again once the terminate arrives or when WaitForZombieTerminate() has * timed out waiting. */ if (pcoi->state & ST_INTRA_PROCESS && !(pcoi->state & ST_TERMINATE_RECEIVED)) { DestroyHandle((HANDLE)pcoi->hConv); pcoi->hConv = (HCONV)CreateHandle((ULONG_PTR)pcoi, HTYPE_ZOMBIE_CONVERSATION, InstFromHandle(pcoi->hConv)); UnlinkConvFromOthers(pcoi, TRUE); return; } /* * remove any transactions left in progress */ while (pcoi->pxiOut != NULL) { (pcoi->pxiOut->pfnResponse)(pcoi->pxiOut, 0, 0); } /* * Throw away any incoming queued DDE messages. */ while (pcoi->dmqOut != NULL) { pdmq = pcoi->dmqOut; DumpDDEMessage(!(pcoi->state & ST_INTRA_PROCESS), pdmq->msg, pdmq->lParam); pcoi->dmqOut = pcoi->dmqOut->next; if (pcoi->dmqOut == NULL) { pcoi->dmqIn = NULL; } DDEMLFree(pdmq); } // // Remove all link info // paLink = pcoi->aLinks; while (pcoi->cLinks) { if (pcoi->state & ST_CLIENT) { MONLINK(pcoi->pcii, FALSE, paLink->wType & XTYPF_NODATA, pcoi->laService, pcoi->laTopic, LocalToGlobalAtom(paLink->laItem), paLink->wFmt, FALSE, (HCONV)pcoi->hwndPartner, (HCONV)pcoi->hwndConv); } else { MONLINK(pcoi->pcii, FALSE, paLink->wType & XTYPF_NODATA, pcoi->laService, pcoi->laTopic, LocalToGlobalAtom(paLink->laItem), paLink->wFmt, TRUE, (HCONV)pcoi->hwndConv, (HCONV)pcoi->hwndPartner); } if (!(pcoi->state & ST_CLIENT)) { DeleteLinkCount(pcoi->pcii, paLink->pLinkCount); } DeleteAtom(paLink->laItem); // link structure copy paLink++; pcoi->cLinks--; } if (pcoi->aLinks) { DDEMLFree(pcoi->aLinks); } // // free atoms associated with this conv // DeleteAtom(pcoi->laService); DeleteAtom(pcoi->laTopic); if (pcoi->laServiceRequested) { DeleteAtom(pcoi->laServiceRequested); } UnlinkConvFromOthers(pcoi, FALSE); /* * invalidate app's conversation handle */ DestroyHandle((HANDLE)pcoi->hConv); DDEMLFree(pcoi); }

BOOL InitiateEnumerationProc (  HWND  hwndTarget, PINIT_ENUM  pie )

Definition at line 784 of file connect.c. References tagCONVLIST::ahwnd, BOOL, CheckDDECritOut, tagCONVLIST::chwnd, tagCL_CONV_INFO::ci, tagINIT_ENUM::clst, CLST_MULT_INITIALIZING, CLST_SINGLE_INITIALIZING, EnterDDECrit, GetWindowLongPtr(), GWLP_PCI, tagINIT_ENUM::hConvList, HINST_ANY, HTYPE_CONVERSATION_LIST, tagINIT_ENUM::hwndClient, tagCL_CONV_INFO::hwndReconnect, tagINIT_ENUM::hwndSkip, IncLocalAtomCount(), tagCONV_INFO::laService, tagCONV_INFO::laServiceRequested, tagINIT_ENUM::laServiceRequested, tagCONV_INFO::laTopic, tagINIT_ENUM::laTopic, LeaveDDECrit, tagINIT_ENUM::lParam, tagCONV_INFO::next, NULL, SendMessage(), tagCONV_INFO::state, TRUE, and ValidateCHandle(). Referenced by ConnectConv(). { PCL_CONV_INFO pci; CheckDDECritOut; if (hwndTarget == pie->hwndSkip) { return (TRUE); } if (pie->hConvList && pie->laTopic && pie->laServiceRequested) { /* * Head off duplicates BEFORE we send the WM_DDE_INITIATE messages! */ PCONVLIST pcl; PCONV_INFO pcoiExisting; int i; EnterDDECrit; /* * We revalidate hConvList here because we left the critical section. */ pcl = (PCONVLIST)ValidateCHandle((HANDLE)pie->hConvList, HTYPE_CONVERSATION_LIST, HINST_ANY); if (pcl != NULL) { for (i = 0; i < pcl->chwnd; i++) { for (pcoiExisting = (PCONV_INFO)GetWindowLongPtr(pcl->ahwnd[i], GWLP_PCI); pcoiExisting != NULL; pcoiExisting = pcoiExisting->next) { if (pcoiExisting->state & ST_CONNECTED && ((PCL_CONV_INFO)pcoiExisting)->hwndReconnect == hwndTarget && pcoiExisting->laTopic == pie->laTopic && pcoiExisting->laService == pie->laServiceRequested) { LeaveDDECrit; return(TRUE); } } } } LeaveDDECrit; } CheckDDECritOut; SendMessage(hwndTarget, WM_DDE_INITIATE, (WPARAM)pie->hwndClient, pie->lParam); EnterDDECrit; // // During the initiate process, any acks received cause more pci's // to become linked together under the same hwndClient. Once // the SendMessage() returns, we set the parts of the new pci's // that hold initiate context information. // pci = (PCL_CONV_INFO)GetWindowLongPtr(pie->hwndClient, GWLP_PCI); if (pci == NULL) { LeaveDDECrit; return (TRUE); } while (pci != NULL) { if (pci->hwndReconnect == 0) { // this one needs updating pci->hwndReconnect = hwndTarget; if (pie->laServiceRequested) { pci->ci.laServiceRequested = pie->laServiceRequested; IncLocalAtomCount(pie->laServiceRequested); // pci copy } } if (pie->clst == CLST_SINGLE_INITIALIZING) { break; } pci = (PCL_CONV_INFO)pci->ci.next; } LeaveDDECrit; return (pie->clst == CLST_MULT_INITIALIZING); }

VOID SetCommonStateFlags (  HWND  hwndUs, HWND  hwndThem, PWORD  pwFlags )

Definition at line 876 of file connect.c. References DWORD, GetWindowThreadProcessId(), IsWindowUnicode(), and VOID(). Referenced by DDEMLClientWndProc(), and ProcessDDEMLInitiate(). { DWORD pidUs, pidThem; GetWindowThreadProcessId(hwndUs, &pidUs); GetWindowThreadProcessId(hwndThem, &pidThem); if (pidUs == pidThem) { *pwFlags |= ST_INTRA_PROCESS; } if (IsWindowUnicode(hwndUs) && IsWindowUnicode(hwndThem)) { *pwFlags |= ST_UNICODE_EXECUTE; } }

VOID ShutdownConversation (  PCONV_INFO  pcoi, BOOL  fMakeCallback )

Definition at line 1109 of file connect.c. References tagCL_INSTANCE_INFO::afCmd, CheckDDECritIn, DoCallback(), FALSE, FreeConversationResources(), tagCONV_INFO::hConv, tagCONV_INFO::hwndConv, tagCONV_INFO::hwndPartner, IsWindow(), L, MONCONV, tagCONV_INFO::pcii, PostMessage(), tagCONV_INFO::state, and VOID(). Referenced by DdeConnectList(), DdeDisconnect(), DdeDisconnectList(), DisconnectConv(), ProcessTerminateMsg(), and SpontaneousClientMessage(). { CheckDDECritIn; if (pcoi->state & ST_CONNECTED) { pcoi->state &= ~ST_CONNECTED; if (IsWindow(pcoi->hwndPartner)) { PostMessage(pcoi->hwndPartner, WM_DDE_TERMINATE, (WPARAM)pcoi->hwndConv, 0); } if (fMakeCallback && !(pcoi->pcii->afCmd & CBF_SKIP_DISCONNECTS)) { DoCallback(pcoi->pcii, (WORD)XTYP_DISCONNECT, 0, pcoi->hConv, 0, 0, 0, 0, (pcoi->state & ST_ISSELF) ? 1L : 0L); } MONCONV(pcoi, FALSE); } FreeConversationResources(pcoi); }

VOID UnlinkConvFromOthers (  PCONV_INFO  pcoi, BOOL  gGoingZombie )

Definition at line 1153 of file connect.c. References tagCONVLIST::ahwnd, tagCL_INSTANCE_INFO::aServerLookup, BOOL, CheckDDECritIn, tagCONVLIST::chwnd, tagCL_INSTANCE_INFO::cServerLookupAlloc, DDEMLFree, DWORD, EnterDDECrit, FALSE, GetAppCompatFlags2(), GetHandleData(), GetWindowLongPtr(), GWLP_PCI, tagCONV_INFO::hConv, HTYPE_ZOMBIE_CONVERSATION, tagCONV_INFO::hwndConv, tagSERVER_LOOKUP::hwndServer, tagSERVER_LOOKUP::laService, tagSERVER_LOOKUP::laTopic, LeaveDDECrit, tagCONV_INFO::next, NtUserDestroyWindow(), NULL, ORPATH, path, tagCONV_INFO::pcii, PCL_CONV_INFO, SetWindowLongPtr(), tagCONV_INFO::state, TRUE, TypeFromHandle, ValidateAllConvLists, ValidateConvList, and VOID(). Referenced by FreeConversationResources(). { PCONV_INFO pcoiPrev, pcoiFirst, pcoiNow; PCONVLIST pcl; int i, cActiveInList = 0; #ifdef TESTING DWORD path = 0; #define ORPATH(x) path |= x; #else #define ORPATH(x) #endif // TESTING CheckDDECritIn; /* * Scan pcoi linked list to get key pointers. */ pcoiPrev = NULL; pcoiFirst = pcoiNow = (PCONV_INFO)GetWindowLongPtr(pcoi->hwndConv, GWLP_PCI); #ifdef TESTING /* * verify that pcoi is in the conv list for this window. */ while (pcoiNow != NULL) { if (pcoiNow == pcoi) { goto FoundIt; } pcoiNow = pcoiNow->next; } DebugBreak(); FoundIt: pcoiNow = pcoiFirst; #endif // TESTING UserAssert(pcoiFirst); while (pcoiNow != NULL) { if (TypeFromHandle(pcoiNow->hConv) != HTYPE_ZOMBIE_CONVERSATION) { ORPATH(1); cActiveInList++; } if (pcoiNow->next == pcoi) { pcoiPrev = pcoiNow; } pcoiNow = pcoiNow->next; } ValidateAllConvLists(); /* * Unlink conversation unless its going Zombie. */ if (!gGoingZombie) { ORPATH(2); if (TypeFromHandle(pcoi->hConv) != HTYPE_ZOMBIE_CONVERSATION) { ORPATH(4); cActiveInList--; } if (pcoiPrev == NULL) { ORPATH(8); pcoiFirst = pcoi->next; SetWindowLongPtr(pcoi->hwndConv, GWLP_PCI, (LONG_PTR)pcoiFirst); } else { pcoiPrev->next = pcoi->next; } } UserAssert(pcoiFirst != NULL || !cActiveInList); if (cActiveInList == 0) { ORPATH(0x10); if (pcoi->state & ST_CLIENT) { ORPATH(0x20); if (((PCL_CONV_INFO)pcoi)->hConvList) { /* * Remove pcoi's hwnd from its hConvList. */ pcl = (PCONVLIST)GetHandleData((HANDLE)((PCL_CONV_INFO)pcoi)->hConvList); for (i = 0; i < pcl->chwnd; i++) { if (pcl->ahwnd[i] == pcoi->hwndConv) { ORPATH(0x40); pcl->chwnd--; UserAssert(pcl->ahwnd[pcl->chwnd]); pcl->ahwnd[i] = pcl->ahwnd[pcl->chwnd]; ValidateConvList(((PCL_CONV_INFO)pcoi)->hConvList); break; } } ORPATH(0x80); } } else { // SERVER /* * remove server window from the service/topic lookup table. */ ORPATH(0x100); for (i = 0; i < pcoi->pcii->cServerLookupAlloc; i++) { if (pcoi->pcii->aServerLookup[i].hwndServer == pcoi->hwndConv) { ORPATH(0x200); /* * Check for appcompat hack */ if (GetAppCompatFlags2(VERMAX) & GACF2_DDE) { DeleteAtom(pcoi->pcii->aServerLookup[i].laService); // delete laService DeleteAtom(pcoi->pcii->aServerLookup[i].laTopic); // delete laTopic } if (--(pcoi->pcii->cServerLookupAlloc)) { ORPATH(0x400); pcoi->pcii->aServerLookup[i] = pcoi->pcii->aServerLookup[pcoi->pcii->cServerLookupAlloc]; } else { DDEMLFree(pcoi->pcii->aServerLookup); pcoi->pcii->aServerLookup = NULL; } break; } } } } #ifdef TESTING else { /* * make sure at this point we have at least one non-zombie */ pcoiNow = pcoiFirst; while (pcoiNow != NULL) { if (TypeFromHandle(pcoiNow->hConv) != HTYPE_ZOMBIE_CONVERSATION) { goto Out; } pcoiNow = pcoiNow->next; } DebugBreak(); Out: ; } #endif // TESTING ValidateAllConvLists(); ORPATH(0x800); /* * In any case remove hConvList references from client conversation. */ if (pcoi->state & ST_CLIENT) { #ifdef TESTING /* * Verify that the hConvList that is being removed, doesn't reference * this window. */ if (((PCL_CONV_INFO)pcoi)->hConvList && !cActiveInList) { BOOL fFound = FALSE; pcl = (PCONVLIST)GetHandleData((HANDLE)((PCL_CONV_INFO)pcoi)->hConvList); for (i = 0; i < pcl->chwnd; i++) { if (pcl->ahwnd[i] == pcoi->hwndConv) { fFound = TRUE; break; } } UserAssert(!fFound); } #endif // TESTING ((PCL_CONV_INFO)pcoi)->hConvList = 0; pcoi->state &= ~ST_INLIST; } /* * last one out turns out the lights. */ if (pcoiFirst == NULL) { /* * If the pcoi list is empty, this window can go away. */ LeaveDDECrit; NtUserDestroyWindow(pcoi->hwndConv); EnterDDECrit; } }

BOOL ValidateConnectParameters (  HANDLE  hInst, PCL_INSTANCE_INFO *  ppcii, HSZ *  phszService, HSZ  hszTopic, LATOM *  plaNormalSvcName, PCONVCONTEXT *  ppCC, HWND *  phwndTarget, HCONVLIST  hConvList )

Definition at line 491 of file connect.c. References BOOL, DefConvContext, DWORD, FALSE, hInst, HSZT_INST_SPECIFIC, HSZT_INVALID, HTYPE_CONVERSATION_LIST, IIF_UNICODE, InstFromHandle, LATOM_FROM_HSZ, NORMAL_HSZ_FROM_LATOM, NULL, ParseInstSpecificAtom(), SetLastDDEMLError(), TempConvContext, TRUE, ValidateCHandle(), ValidateHSZ(), and ValidateInstance(). Referenced by DdeConnect(), and DdeConnectList(). { DWORD hszType; BOOL fError = FALSE; *ppcii = ValidateInstance(hInst); if (*ppcii == NULL) { return (FALSE); } hszType = ValidateHSZ(*phszService); if (hszType == HSZT_INVALID || ValidateHSZ(hszTopic) == HSZT_INVALID) { SetLastDDEMLError(*ppcii, DMLERR_INVALIDPARAMETER); return (FALSE); } if (hszType == HSZT_INST_SPECIFIC) { *phwndTarget = ParseInstSpecificAtom(LATOM_FROM_HSZ(*phszService), plaNormalSvcName); if (*plaNormalSvcName == 0) { SetLastDDEMLError(*ppcii, DMLERR_SYS_ERROR); return (FALSE); } *phszService = NORMAL_HSZ_FROM_LATOM(*plaNormalSvcName); } if (*ppCC == NULL) { *ppCC = &DefConvContext; if ((*ppcii)->flags & IIF_UNICODE) { (*ppCC)->iCodePage = CP_WINUNICODE; } else { (*ppCC)->iCodePage = CP_WINANSI; } } else try { if ((*ppCC)->cb > sizeof(CONVCONTEXT)) { SetLastDDEMLError(*ppcii, DMLERR_INVALIDPARAMETER); fError = TRUE; } else if ((*ppCC)->cb < sizeof(CONVCONTEXT)) { TempConvContext = DefConvContext; /* * we can use this static temp because we are synchronized. */ RtlCopyMemory(&TempConvContext, *ppCC, (*ppCC)->cb); *ppCC = &TempConvContext; } } except(W32ExceptionHandler(FALSE, RIP_WARNING)) { SetLastDDEMLError(*ppcii, DMLERR_INVALIDPARAMETER); fError = TRUE; } if (fError) { return(FALSE); } if (hConvList != 0 && !ValidateCHandle((HANDLE)hConvList, HTYPE_CONVERSATION_LIST, (DWORD)InstFromHandle((*ppcii)->hInstClient))) { return (FALSE); } return (TRUE); }

BOOL WaitForZombieTerminate (  HANDLE  hData  )

Definition at line 1474 of file connect.c. References BOOL, CheckDDECritOut, DispatchMessage(), DWORD, EnterDDECrit, FALSE, HTYPE_ZOMBIE_CONVERSATION, tagCONV_INFO::hwndConv, tagCONV_INFO::hwndPartner, InstFromHandle, LeaveDDECrit, msg, MsgWaitForMultipleObjectsEx(), NULL, PeekMessage(), ProcessTerminateMsg(), tagCONV_INFO::state, TRUE, and ValidateCHandle(). Referenced by DdeUninitialize(). { PCONV_INFO pcoi; MSG msg; HWND hwnd; BOOL fTerminated; DWORD fRet = 0; CheckDDECritOut; EnterDDECrit; fTerminated = FALSE; while ((pcoi = (PCONV_INFO)ValidateCHandle(hData, HTYPE_ZOMBIE_CONVERSATION, InstFromHandle(hData))) != NULL && !(pcoi->state & ST_TERMINATE_RECEIVED)) { hwnd = pcoi->hwndConv; LeaveDDECrit; while (PeekMessage(&msg, hwnd, WM_DDE_FIRST, WM_DDE_LAST, PM_REMOVE)) { DispatchMessage(&msg); if (msg.message == WM_DDE_TERMINATE) { fTerminated = TRUE; } } if (!fTerminated) { fRet = MsgWaitForMultipleObjectsEx(0, NULL, 100, QS_POSTMESSAGE, 0); if (fRet == 0xFFFFFFFF) { RIPMSG0(RIP_WARNING, "WaitForZombieTerminate: I give up - faking terminate."); ProcessTerminateMsg(pcoi, pcoi->hwndPartner); EnterDDECrit; return(FALSE); } } EnterDDECrit; } LeaveDDECrit; return(TRUE); }

---

Variable Documentation

CONVCONTEXT DefConvContext

Initial value: { sizeof(CONVCONTEXT), 0, 0, CP_WINANSI, 0L, 0L, { sizeof(SECURITY_QUALITY_OF_SERVICE), SecurityImpersonation, SECURITY_STATIC_TRACKING, TRUE } } Definition at line 107 of file connect.c. Referenced by DdeQueryConvInfo(), and ValidateConnectParameters().

CONVCONTEXT TempConvContext

Definition at line 106 of file connect.c. Referenced by ValidateConnectParameters().

---