4 * Copyright 1997 Alexandre Julliard
5 * Copyright 1997 Len White
6 * Copyright 1999 Keith Matthews
8 * Copyright 2001 Eric Pouech
9 * Copyright 2004, 2005 Dmitry Timoshkov
11 * This library is free software; you can redistribute it and/or
12 * modify it under the terms of the GNU Lesser General Public
13 * License as published by the Free Software Foundation; either
14 * version 2.1 of the License, or (at your option) any later version.
16 * This library is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
19 * Lesser General Public License for more details.
21 * You should have received a copy of the GNU Lesser General Public
22 * License along with this library; if not, write to the Free Software
23 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
37 #include "wine/debug.h"
38 #include "dde_private.h"
40 WINE_DEFAULT_DEBUG_CHANNEL(ddeml
);
42 static LRESULT CALLBACK
WDML_ClientProc(HWND
, UINT
, WPARAM
, LPARAM
); /* only for one client, not conv list */
43 const char WDML_szClientConvClassA
[] = "WineDdeClientA";
44 const WCHAR WDML_szClientConvClassW
[] = {'W','i','n','e','D','d','e','C','l','i','e','n','t','W',0};
46 /******************************************************************************
47 * DdeConnectList [USER32.@] Establishes conversation with DDE servers
50 * idInst [I] Instance identifier
51 * hszService [I] Handle to service name string
52 * hszTopic [I] Handle to topic name string
53 * hConvList [I] Handle to conversation list
54 * pCC [I] Pointer to structure with context data
57 * Success: Handle to new conversation list
60 HCONVLIST WINAPI
DdeConnectList(DWORD idInst
, HSZ hszService
, HSZ hszTopic
,
61 HCONVLIST hConvList
, PCONVCONTEXT pCC
)
63 FIXME("(%d,%p,%p,%p,%p): stub\n", idInst
, hszService
, hszTopic
, hConvList
, pCC
);
67 /*****************************************************************
68 * DdeQueryNextServer [USER32.@]
70 HCONV WINAPI
DdeQueryNextServer(HCONVLIST hConvList
, HCONV hConvPrev
)
72 FIXME("(%p,%p): stub\n", hConvList
, hConvPrev
);
76 /******************************************************************************
77 * DdeDisconnectList [USER32.@] Destroys list and terminates conversations
81 * hConvList [I] Handle to conversation list
87 BOOL WINAPI
DdeDisconnectList(HCONVLIST hConvList
)
89 FIXME("(%p): stub\n", hConvList
);
93 /*****************************************************************
94 * DdeConnect (USER32.@)
96 HCONV WINAPI
DdeConnect(DWORD idInst
, HSZ hszService
, HSZ hszTopic
,
100 WDML_INSTANCE
* pInstance
;
101 WDML_CONV
* pConv
= NULL
;
102 ATOM aSrv
= 0, aTpc
= 0;
104 TRACE("(0x%x,%p,%p,%p)\n", idInst
, hszService
, hszTopic
, pCC
);
106 EnterCriticalSection(&WDML_CritSect
);
108 pInstance
= WDML_GetInstance(idInst
);
114 /* make sure this conv is never created */
115 pConv
= WDML_FindConv(pInstance
, WDML_CLIENT_SIDE
, hszService
, hszTopic
);
118 ERR("This Conv already exists: (%p)\n", pConv
);
122 /* we need to establish a conversation with
123 server, so create a window for it */
125 if (pInstance
->unicode
)
127 WNDCLASSEXW wndclass
;
129 wndclass
.cbSize
= sizeof(wndclass
);
131 wndclass
.lpfnWndProc
= WDML_ClientProc
;
132 wndclass
.cbClsExtra
= 0;
133 wndclass
.cbWndExtra
= 2 * sizeof(ULONG_PTR
);
134 wndclass
.hInstance
= 0;
136 wndclass
.hCursor
= 0;
137 wndclass
.hbrBackground
= 0;
138 wndclass
.lpszMenuName
= NULL
;
139 wndclass
.lpszClassName
= WDML_szClientConvClassW
;
140 wndclass
.hIconSm
= 0;
142 RegisterClassExW(&wndclass
);
144 hwndClient
= CreateWindowW(WDML_szClientConvClassW
, NULL
, WS_POPUP
, 0, 0, 0, 0, 0, 0, 0, 0);
148 WNDCLASSEXA wndclass
;
150 wndclass
.cbSize
= sizeof(wndclass
);
152 wndclass
.lpfnWndProc
= WDML_ClientProc
;
153 wndclass
.cbClsExtra
= 0;
154 wndclass
.cbWndExtra
= 2 * sizeof(ULONG_PTR
);
155 wndclass
.hInstance
= 0;
157 wndclass
.hCursor
= 0;
158 wndclass
.hbrBackground
= 0;
159 wndclass
.lpszMenuName
= NULL
;
160 wndclass
.lpszClassName
= WDML_szClientConvClassA
;
161 wndclass
.hIconSm
= 0;
163 RegisterClassExA(&wndclass
);
165 hwndClient
= CreateWindowA(WDML_szClientConvClassA
, NULL
, WS_POPUP
, 0, 0, 0, 0, 0, 0, 0, 0);
168 SetWindowLongPtrW(hwndClient
, GWL_WDML_INSTANCE
, (ULONG_PTR
)pInstance
);
172 aSrv
= WDML_MakeAtomFromHsz(hszService
);
173 if (!aSrv
) goto theEnd
;
177 aTpc
= WDML_MakeAtomFromHsz(hszTopic
);
178 if (!aTpc
) goto theEnd
;
181 LeaveCriticalSection(&WDML_CritSect
);
183 /* note: sent messages shall not use packing */
184 SendMessageTimeoutW( HWND_BROADCAST
, WM_DDE_INITIATE
, (WPARAM
)hwndClient
, MAKELPARAM(aSrv
, aTpc
),
185 SMTO_ABORTIFHUNG
, 2000, NULL
);
187 EnterCriticalSection(&WDML_CritSect
);
189 pInstance
= WDML_GetInstance(idInst
);
195 /* At this point, Client WM_DDE_ACK should have saved hwndServer
196 for this instance id and hwndClient if server responds.
197 So get HCONV and return it. And add it to conv list */
198 pConv
= WDML_GetConvFromWnd(hwndClient
);
199 if (pConv
== NULL
|| pConv
->hwndServer
== 0)
201 WARN("Done with INITIATE, but no Server window available\n");
205 TRACE("Connected to Server window (%p)\n", pConv
->hwndServer
);
206 pConv
->wConvst
= XST_CONNECTED
;
208 /* finish init of pConv */
211 pConv
->convContext
= *pCC
;
215 memset(&pConv
->convContext
, 0, sizeof(pConv
->convContext
));
216 pConv
->convContext
.cb
= sizeof(pConv
->convContext
);
217 pConv
->convContext
.iCodePage
= (pInstance
->unicode
) ? CP_WINUNICODE
: CP_WINANSI
;
221 LeaveCriticalSection(&WDML_CritSect
);
223 if (aSrv
) GlobalDeleteAtom(aSrv
);
224 if (aTpc
) GlobalDeleteAtom(aTpc
);
228 /*****************************************************************
229 * DdeReconnect (DDEML.37)
230 * DdeReconnect (USER32.@)
232 HCONV WINAPI
DdeReconnect(HCONV hConv
)
235 WDML_CONV
* pNewConv
= NULL
;
236 ATOM aSrv
= 0, aTpc
= 0;
238 TRACE("(%p)\n", hConv
);
240 EnterCriticalSection(&WDML_CritSect
);
241 pConv
= WDML_GetConv(hConv
, FALSE
);
242 if (pConv
!= NULL
&& (pConv
->wStatus
& ST_CLIENT
))
246 /* to reestablist a connection, we have to make sure that:
247 * 1/ pConv is the converstation attached to the client window (it wouldn't be
248 * if a call to DdeReconnect would have already been done...)
249 * FIXME: is this really an error ???
250 * 2/ the pConv conversation had really been deconnected
252 if (pConv
== WDML_GetConvFromWnd(pConv
->hwndClient
) &&
253 (pConv
->wStatus
& ST_TERMINATED
) && !(pConv
->wStatus
& ST_CONNECTED
))
255 HWND hwndClient
= pConv
->hwndClient
;
256 HWND hwndServer
= pConv
->hwndServer
;
258 SetWindowLongPtrW(pConv
->hwndClient
, GWL_WDML_CONVERSATION
, 0);
260 aSrv
= WDML_MakeAtomFromHsz(pConv
->hszService
);
261 aTpc
= WDML_MakeAtomFromHsz(pConv
->hszTopic
);
262 if (!aSrv
|| !aTpc
) goto theEnd
;
264 LeaveCriticalSection(&WDML_CritSect
);
266 /* note: sent messages shall not use packing */
267 ret
= SendMessageW(hwndServer
, WM_DDE_INITIATE
, (WPARAM
)hwndClient
,
268 MAKELPARAM(aSrv
, aTpc
));
270 EnterCriticalSection(&WDML_CritSect
);
272 pConv
= WDML_GetConv(hConv
, FALSE
);
275 FIXME("Should fail reconnection\n");
279 if (ret
&& (pNewConv
= WDML_GetConvFromWnd(pConv
->hwndClient
)) != NULL
)
281 /* re-establish all links... */
284 for (pLink
= pConv
->instance
->links
[WDML_CLIENT_SIDE
]; pLink
; pLink
= pLink
->next
)
286 if (pLink
->hConv
== hConv
)
288 /* try to reestablish the links... */
289 DdeClientTransaction(NULL
, 0, (HCONV
)pNewConv
, pLink
->hszItem
, pLink
->uFmt
,
290 pLink
->transactionType
, 1000, NULL
);
296 /* reset the conversation as it was */
297 SetWindowLongPtrW(pConv
->hwndClient
, GWL_WDML_CONVERSATION
, (ULONG_PTR
)pConv
);
303 LeaveCriticalSection(&WDML_CritSect
);
305 if (aSrv
) GlobalDeleteAtom(aSrv
);
306 if (aTpc
) GlobalDeleteAtom(aTpc
);
307 return (HCONV
)pNewConv
;
310 /******************************************************************
311 * WDML_ClientQueueAdvise
313 * Creates and queue an WM_DDE_ADVISE transaction
315 static WDML_XACT
* WDML_ClientQueueAdvise(WDML_CONV
* pConv
, UINT wType
, UINT wFmt
, HSZ hszItem
)
317 DDEADVISE
* pDdeAdvise
;
321 TRACE("XTYP_ADVSTART (with%s data) transaction\n", (wType
& XTYPF_NODATA
) ? "out" : "");
323 atom
= WDML_MakeAtomFromHsz(hszItem
);
324 if (!atom
) return NULL
;
326 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_ADVISE
, wFmt
, hszItem
);
329 GlobalDeleteAtom(atom
);
333 pXAct
->wType
= wType
& ~0x0F;
334 pXAct
->hMem
= GlobalAlloc(GHND
| GMEM_DDESHARE
, sizeof(DDEADVISE
));
335 /* FIXME: hMem is unfreed for now... should be deleted in server */
338 pDdeAdvise
= (DDEADVISE
*)GlobalLock(pXAct
->hMem
);
339 pDdeAdvise
->fAckReq
= (wType
& XTYPF_ACKREQ
) ? TRUE
: FALSE
;
340 pDdeAdvise
->fDeferUpd
= (wType
& XTYPF_NODATA
) ? TRUE
: FALSE
;
341 pDdeAdvise
->cfFormat
= wFmt
;
342 GlobalUnlock(pXAct
->hMem
);
344 pXAct
->lParam
= PackDDElParam(WM_DDE_ADVISE
, (UINT_PTR
)pXAct
->hMem
, atom
);
349 /******************************************************************
350 * WDML_HandleAdviseReply
352 * handles the reply to an advise request
354 static WDML_QUEUE_STATE
WDML_HandleAdviseReply(WDML_CONV
* pConv
, MSG
* msg
, WDML_XACT
* pXAct
, DWORD
*ack
)
360 if (msg
->message
!= WM_DDE_ACK
|| WIN_GetFullHandle((HWND
)msg
->wParam
) != pConv
->hwndServer
)
365 UnpackDDElParam(WM_DDE_ACK
, msg
->lParam
, &uiLo
, &uiHi
);
366 hsz
= WDML_MakeHszFromAtom(pConv
->instance
, uiHi
);
368 if (DdeCmpStringHandles(hsz
, pXAct
->hszItem
) != 0)
371 GlobalDeleteAtom(uiHi
);
372 FreeDDElParam(WM_DDE_ACK
, msg
->lParam
);
374 if (ack
) *ack
= uiLo
;
375 WDML_ExtractAck(uiLo
, &ddeAck
);
381 /* billx: first to see if the link is already created. */
382 pLink
= WDML_FindLink(pConv
->instance
, (HCONV
)pConv
, WDML_CLIENT_SIDE
,
383 pXAct
->hszItem
, TRUE
, pXAct
->wFmt
);
386 /* we found a link, and only need to modify it in case it changes */
387 pLink
->transactionType
= pXAct
->wType
;
391 WDML_AddLink(pConv
->instance
, (HCONV
)pConv
, WDML_CLIENT_SIDE
,
392 pXAct
->wType
, pXAct
->hszItem
, pXAct
->wFmt
);
394 pXAct
->hDdeData
= (HDDEDATA
)1;
398 TRACE("Returning FALSE on XTYP_ADVSTART - fAck was FALSE\n");
399 GlobalFree(pXAct
->hMem
);
400 pXAct
->hDdeData
= NULL
;
403 return WDML_QS_HANDLED
;
406 /******************************************************************
407 * WDML_ClientQueueUnadvise
409 * queues an unadvise transaction
411 static WDML_XACT
* WDML_ClientQueueUnadvise(WDML_CONV
* pConv
, UINT wFmt
, HSZ hszItem
)
416 TRACE("XTYP_ADVSTOP transaction\n");
418 atom
= WDML_MakeAtomFromHsz(hszItem
);
419 if (!atom
) return NULL
;
421 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_UNADVISE
, wFmt
, hszItem
);
424 GlobalDeleteAtom(atom
);
428 /* end advise loop: post WM_DDE_UNADVISE to server to terminate link
429 * on the specified item.
431 pXAct
->lParam
= PackDDElParam(WM_DDE_UNADVISE
, wFmt
, atom
);
435 /******************************************************************
436 * WDML_HandleUnadviseReply
440 static WDML_QUEUE_STATE
WDML_HandleUnadviseReply(WDML_CONV
* pConv
, MSG
* msg
, WDML_XACT
* pXAct
, DWORD
*ack
)
446 if (msg
->message
!= WM_DDE_ACK
|| WIN_GetFullHandle((HWND
)msg
->wParam
) != pConv
->hwndServer
)
451 UnpackDDElParam(WM_DDE_ACK
, msg
->lParam
, &uiLo
, &uiHi
);
452 hsz
= WDML_MakeHszFromAtom(pConv
->instance
, uiHi
);
454 if (DdeCmpStringHandles(hsz
, pXAct
->hszItem
) != 0)
457 FreeDDElParam(WM_DDE_ACK
, msg
->lParam
);
458 GlobalDeleteAtom(uiHi
);
460 if (ack
) *ack
= uiLo
;
461 WDML_ExtractAck(uiLo
, &ddeAck
);
463 TRACE("WM_DDE_ACK received while waiting for a timeout\n");
467 TRACE("Returning FALSE on XTYP_ADVSTOP - fAck was FALSE\n");
468 pXAct
->hDdeData
= NULL
;
472 /* billx: remove the link */
473 WDML_RemoveLink(pConv
->instance
, (HCONV
)pConv
, WDML_CLIENT_SIDE
,
474 pXAct
->hszItem
, pXAct
->wFmt
);
475 pXAct
->hDdeData
= (HDDEDATA
)1;
477 return WDML_QS_HANDLED
;
480 /******************************************************************
481 * WDML_ClientQueueRequest
485 static WDML_XACT
* WDML_ClientQueueRequest(WDML_CONV
* pConv
, UINT wFmt
, HSZ hszItem
)
490 TRACE("XTYP_REQUEST transaction\n");
492 atom
= WDML_MakeAtomFromHsz(hszItem
);
493 if (!atom
) return NULL
;
495 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_REQUEST
, wFmt
, hszItem
);
498 GlobalDeleteAtom(atom
);
502 pXAct
->lParam
= PackDDElParam(WM_DDE_REQUEST
, wFmt
, atom
);
507 /******************************************************************
508 * WDML_HandleRequestReply
512 static WDML_QUEUE_STATE
WDML_HandleRequestReply(WDML_CONV
* pConv
, MSG
* msg
, WDML_XACT
* pXAct
, DWORD
*ack
)
519 if (WIN_GetFullHandle((HWND
)msg
->wParam
) != pConv
->hwndServer
)
522 switch (msg
->message
)
525 UnpackDDElParam(WM_DDE_ACK
, msg
->lParam
, &uiLo
, &uiHi
);
526 FreeDDElParam(WM_DDE_ACK
, msg
->lParam
);
527 GlobalDeleteAtom(uiHi
);
528 if (ack
) *ack
= uiLo
;
529 WDML_ExtractAck(uiLo
, &ddeAck
);
532 ERR("Positive answer should appear in NACK for a request, assuming negative\n");
533 TRACE("Negative answer...\n");
537 UnpackDDElParam(WM_DDE_DATA
, msg
->lParam
, &uiLo
, &uiHi
);
538 TRACE("Got the result (%08x)\n", uiLo
);
540 hsz
= WDML_MakeHszFromAtom(pConv
->instance
, uiHi
);
542 if (DdeCmpStringHandles(hsz
, pXAct
->hszItem
) != 0)
545 pXAct
->hDdeData
= WDML_Global2DataHandle((HGLOBAL
)uiLo
, &wdh
);
548 GlobalFree((HGLOBAL
)uiLo
);
552 WDML_PostAck(pConv
, WDML_CLIENT_SIDE
, 0, FALSE
, TRUE
, uiHi
, msg
->lParam
, WM_DDE_DATA
);
556 GlobalDeleteAtom(uiHi
);
557 FreeDDElParam(WM_DDE_ACK
, msg
->lParam
);
562 FreeDDElParam(msg
->message
, msg
->lParam
);
566 return WDML_QS_HANDLED
;
569 /******************************************************************
570 * WDML_BuildExecuteCommand
572 * Creates a DDE block suitable for sending in WM_DDE_COMMAND
573 * It also takes care of string conversion between the two window procedures
575 static HGLOBAL
WDML_BuildExecuteCommand(WDML_CONV
* pConv
, LPCVOID pData
, DWORD cbData
)
578 BOOL clientUnicode
, serverUnicode
;
581 clientUnicode
= pConv
->instance
->unicode
;
582 TRACE("client %p uses unicode = %d\n", pConv
->hwndClient
, clientUnicode
);
583 /* FIXME: how exactly Windows determines what to use for the server side? */
584 serverUnicode
= IsWindowUnicode(pConv
->hwndServer
) && IsWindowUnicode(pConv
->hwndClient
);
585 TRACE("server %p uses unicode = %d\n", pConv
->hwndServer
, serverUnicode
);
587 if (clientUnicode
== serverUnicode
)
595 memSize
= WideCharToMultiByte( CP_ACP
, 0, pData
, cbData
, NULL
, 0, NULL
, NULL
);
599 memSize
= MultiByteToWideChar( CP_ACP
, 0, pData
, cbData
, NULL
, 0) * sizeof(WCHAR
);
603 hMem
= GlobalAlloc(GMEM_MOVEABLE
| GMEM_DDESHARE
, memSize
);
609 pDst
= GlobalLock(hMem
);
612 if (clientUnicode
== serverUnicode
)
614 memcpy(pDst
, pData
, cbData
);
620 WideCharToMultiByte( CP_ACP
, 0, pData
, cbData
, pDst
, memSize
, NULL
, NULL
);
624 MultiByteToWideChar( CP_ACP
, 0, pData
, cbData
, (LPWSTR
)pDst
, memSize
/sizeof(WCHAR
));
639 /******************************************************************
640 * WDML_ClientQueueExecute
644 static WDML_XACT
* WDML_ClientQueueExecute(WDML_CONV
* pConv
, LPCVOID pData
, DWORD cbData
)
648 TRACE("XTYP_EXECUTE transaction\n");
650 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_EXECUTE
, 0, 0);
654 if (cbData
== (DWORD
)-1)
656 HDDEDATA hDdeData
= (HDDEDATA
)pData
;
658 pData
= DdeAccessData(hDdeData
, &cbData
);
661 pXAct
->hMem
= WDML_BuildExecuteCommand(pConv
, pData
, cbData
);
662 DdeUnaccessData(hDdeData
);
667 pXAct
->hMem
= WDML_BuildExecuteCommand(pConv
, pData
, cbData
);
670 pXAct
->lParam
= (LPARAM
)pXAct
->hMem
;
675 /******************************************************************
676 * WDML_HandleExecuteReply
680 static WDML_QUEUE_STATE
WDML_HandleExecuteReply(WDML_CONV
* pConv
, MSG
* msg
, WDML_XACT
* pXAct
, DWORD
*ack
)
685 if (msg
->message
!= WM_DDE_ACK
|| WIN_GetFullHandle((HWND
)msg
->wParam
) != pConv
->hwndServer
)
690 UnpackDDElParam(WM_DDE_ACK
, msg
->lParam
, &uiLo
, &uiHi
);
691 FreeDDElParam(WM_DDE_ACK
, msg
->lParam
);
693 if ((HANDLE
)uiHi
!= pXAct
->hMem
)
698 if (ack
) *ack
= uiLo
;
699 WDML_ExtractAck(uiLo
, &ddeAck
);
700 pXAct
->hDdeData
= (HDDEDATA
)(UINT_PTR
)ddeAck
.fAck
;
702 TRACE("hDdeData = %p\n", pXAct
->hDdeData
);
703 pConv
->instance
->lastError
= (pXAct
->hDdeData
!= 0) ? DMLERR_NO_ERROR
: DMLERR_NOTPROCESSED
;
705 return WDML_QS_HANDLED
;
708 /******************************************************************
709 * WDML_ClientQueuePoke
713 static WDML_XACT
* WDML_ClientQueuePoke(WDML_CONV
* pConv
, LPCVOID pData
, DWORD cbData
,
714 UINT wFmt
, HSZ hszItem
)
719 TRACE("XTYP_POKE transaction\n");
721 atom
= WDML_MakeAtomFromHsz(hszItem
);
722 if (!atom
) return NULL
;
724 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_POKE
, wFmt
, hszItem
);
727 GlobalDeleteAtom(atom
);
731 if (cbData
== (DWORD
)-1)
733 pXAct
->hMem
= (HDDEDATA
)pData
;
739 pXAct
->hMem
= GlobalAlloc(GHND
| GMEM_DDESHARE
, sizeof(DDEPOKE
) + cbData
);
740 ddePoke
= GlobalLock(pXAct
->hMem
);
743 memcpy(ddePoke
->Value
, pData
, cbData
);
744 ddePoke
->fRelease
= FALSE
; /* FIXME: app owned ? */
745 ddePoke
->cfFormat
= wFmt
;
746 GlobalUnlock(pXAct
->hMem
);
750 pXAct
->lParam
= PackDDElParam(WM_DDE_POKE
, (UINT_PTR
)pXAct
->hMem
, atom
);
755 /******************************************************************
756 * WDML_HandlePokeReply
760 static WDML_QUEUE_STATE
WDML_HandlePokeReply(WDML_CONV
* pConv
, MSG
* msg
, WDML_XACT
* pXAct
, DWORD
*ack
)
765 if (msg
->message
!= WM_DDE_ACK
&& WIN_GetFullHandle((HWND
)msg
->wParam
) != pConv
->hwndServer
)
770 UnpackDDElParam(WM_DDE_ACK
, msg
->lParam
, &uiLo
, &uiHi
);
771 hsz
= WDML_MakeHszFromAtom(pConv
->instance
, uiHi
);
772 if (DdeCmpStringHandles(hsz
, pXAct
->hszItem
) != 0)
776 FreeDDElParam(WM_DDE_ACK
, msg
->lParam
);
777 GlobalDeleteAtom(uiHi
);
779 if (ack
) *ack
= uiLo
;
780 GlobalFree(pXAct
->hMem
);
782 pXAct
->hDdeData
= (HDDEDATA
)TRUE
;
786 /******************************************************************
787 * WDML_ClientQueueTerminate
789 * Creates and queue an WM_DDE_TERMINATE transaction
791 static WDML_XACT
* WDML_ClientQueueTerminate(WDML_CONV
* pConv
)
795 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_TERMINATE
, 0, 0);
800 pConv
->wStatus
&= ~ST_CONNECTED
;
805 /******************************************************************
806 * WDML_HandleTerminateReply
808 * handles the reply to a terminate request
810 static WDML_QUEUE_STATE
WDML_HandleTerminateReply(WDML_CONV
* pConv
, MSG
* msg
, WDML_XACT
* pXAct
)
812 if (msg
->message
!= WM_DDE_TERMINATE
)
814 /* FIXME: should delete data passed here */
815 return WDML_QS_SWALLOWED
;
818 if (WIN_GetFullHandle((HWND
)msg
->wParam
) != pConv
->hwndServer
)
820 FIXME("hmmm shouldn't happen\n");
823 if (!pConv
->instance
->CBFflags
& CBF_SKIP_DISCONNECTS
)
825 WDML_InvokeCallback(pConv
->instance
, XTYP_DISCONNECT
, 0, (HCONV
)pConv
,
826 0, 0, 0, 0, (pConv
->wStatus
& ST_ISSELF
) ? 1 : 0);
828 WDML_RemoveConv(pConv
, WDML_CLIENT_SIDE
);
829 return WDML_QS_HANDLED
;
832 /******************************************************************
833 * WDML_HandleReplyData
837 static WDML_QUEUE_STATE
WDML_HandleIncomingData(WDML_CONV
* pConv
, MSG
* msg
, HDDEDATA
* hdd
)
840 HDDEDATA hDdeDataIn
, hDdeDataOut
;
845 TRACE("WM_DDE_DATA message received in the Client Proc!\n");
846 /* wParam -- sending window handle */
847 /* lParam -- hDdeData & item HSZ */
849 UnpackDDElParam(WM_DDE_DATA
, msg
->lParam
, &uiLo
, &uiHi
);
850 hsz
= WDML_MakeHszFromAtom(pConv
->instance
, uiHi
);
852 hDdeDataIn
= WDML_Global2DataHandle((HGLOBAL
)uiLo
, &wdh
);
855 * For hot link, data should be passed to its callback with
856 * XTYP_ADVDATA and callback should return the proper status.
858 pLink
= WDML_FindLink(pConv
->instance
, (HCONV
)pConv
, WDML_CLIENT_SIDE
, hsz
,
859 uiLo
? TRUE
: FALSE
, wdh
.cfFormat
);
862 WDML_DecHSZ(pConv
->instance
, hsz
);
863 DdeFreeDataHandle(hDdeDataIn
);
867 if (hDdeDataIn
!= 0 && wdh
.fAckReq
)
869 WDML_PostAck(pConv
, WDML_CLIENT_SIDE
, 0, FALSE
, TRUE
, uiHi
, msg
->lParam
, WM_DDE_DATA
);
875 GlobalDeleteAtom(uiHi
);
878 hDdeDataOut
= WDML_InvokeCallback(pConv
->instance
, XTYP_ADVDATA
, pLink
->uFmt
, pLink
->hConv
,
879 pConv
->hszTopic
, pLink
->hszItem
, hDdeDataIn
, 0, 0);
881 if (hDdeDataOut
!= (HDDEDATA
)DDE_FACK
|| wdh
.fRelease
)
883 if (uiLo
) GlobalFree((HANDLE
)uiLo
);
886 DdeFreeDataHandle(hDdeDataIn
);
888 WDML_DecHSZ(pConv
->instance
, hsz
);
890 FreeDDElParam(WM_DDE_DATA
, msg
->lParam
);
892 return WDML_QS_HANDLED
;
895 /******************************************************************
896 * WDML_HandleIncomingTerminate
900 static WDML_QUEUE_STATE
WDML_HandleIncomingTerminate(WDML_CONV
* pConv
, MSG
* msg
, HDDEDATA
* hdd
)
902 if (pConv
->hwndServer
!= WIN_GetFullHandle((HWND
)msg
->wParam
))
905 pConv
->wStatus
|= ST_TERMINATED
;
906 if (!pConv
->instance
->CBFflags
& CBF_SKIP_DISCONNECTS
)
908 WDML_InvokeCallback(pConv
->instance
, XTYP_DISCONNECT
, 0, (HCONV
)pConv
,
909 0, 0, 0, 0, (pConv
->wStatus
& ST_ISSELF
) ? 1 : 0);
911 if (pConv
->wStatus
& ST_CONNECTED
)
913 /* don't care about result code (if server exists or not) */
914 PostMessageW(pConv
->hwndServer
, WM_DDE_TERMINATE
, (WPARAM
)pConv
->hwndClient
, 0L);
915 pConv
->wStatus
&= ~ST_CONNECTED
;
917 /* have to keep connection around to allow reconnection */
918 return WDML_QS_HANDLED
;
921 /******************************************************************
924 * handles any incoming reply, and try to match to an already sent request
926 static WDML_QUEUE_STATE
WDML_HandleReply(WDML_CONV
* pConv
, MSG
* msg
, HDDEDATA
* hdd
, DWORD
*ack
)
928 WDML_XACT
* pXAct
= pConv
->transactions
;
931 if (pConv
->transactions
)
933 /* first check message against a pending transaction, if any */
934 switch (pXAct
->ddeMsg
)
937 qs
= WDML_HandleAdviseReply(pConv
, msg
, pXAct
, ack
);
939 case WM_DDE_UNADVISE
:
940 qs
= WDML_HandleUnadviseReply(pConv
, msg
, pXAct
, ack
);
943 qs
= WDML_HandleExecuteReply(pConv
, msg
, pXAct
, ack
);
946 qs
= WDML_HandleRequestReply(pConv
, msg
, pXAct
, ack
);
949 qs
= WDML_HandlePokeReply(pConv
, msg
, pXAct
, ack
);
951 case WM_DDE_TERMINATE
:
952 qs
= WDML_HandleTerminateReply(pConv
, msg
, pXAct
);
964 /* now check the results */
968 case WDML_QS_SWALLOWED
:
971 case WDML_QS_HANDLED
:
972 /* ok, we have resolved a pending transaction
973 * notify callback if asynchronous, and remove it in any case
975 WDML_UnQueueTransaction(pConv
, pXAct
);
976 if (pXAct
->dwTimeout
== TIMEOUT_ASYNC
&& pXAct
->ddeMsg
!= WM_DDE_TERMINATE
)
978 WDML_InvokeCallback(pConv
->instance
, XTYP_XACT_COMPLETE
, pXAct
->wFmt
,
979 (HCONV
)pConv
, pConv
->hszTopic
, pXAct
->hszItem
,
980 pXAct
->hDdeData
, MAKELONG(0, pXAct
->xActID
), 0 /* FIXME */);
985 *hdd
= pXAct
->hDdeData
;
987 WDML_FreeTransaction(pConv
->instance
, pXAct
, TRUE
);
990 /* no pending transaction found, try a warm/hot link or a termination request */
991 switch (msg
->message
)
994 qs
= WDML_HandleIncomingData(pConv
, msg
, hdd
);
996 case WM_DDE_TERMINATE
:
997 qs
= WDML_HandleIncomingTerminate(pConv
, msg
, hdd
);
1002 FIXME("shouldn't be used on client side\n");
1009 /******************************************************************
1010 * WDML_SyncWaitTransactionReply
1012 * waits until an answer for a sent request is received
1013 * time out is also handled. only used for synchronous transactions
1015 static HDDEDATA
WDML_SyncWaitTransactionReply(HCONV hConv
, DWORD dwTimeout
, WDML_XACT
* pXAct
, DWORD
*ack
)
1021 TRACE("Starting wait for a timeout of %d ms\n", dwTimeout
);
1023 /* FIXME: time 32 bit wrap around */
1024 dwTimeout
+= GetCurrentTime();
1026 while ((dwTime
= GetCurrentTime()) < dwTimeout
)
1028 /* we cannot be in the crit sect all the time because when client and server run in a
1029 * single process they need to share the access to the internal data
1031 if (MsgWaitForMultipleObjects(0, NULL
, FALSE
,
1032 dwTimeout
- dwTime
, QS_POSTMESSAGE
) == WAIT_OBJECT_0
)
1036 while (PeekMessageW(&msg
, 0, WM_DDE_FIRST
, WM_DDE_LAST
, PM_REMOVE
))
1040 EnterCriticalSection(&WDML_CritSect
);
1042 pConv
= WDML_GetConv(hConv
, FALSE
);
1045 LeaveCriticalSection(&WDML_CritSect
);
1046 /* conversation no longer available... return failure */
1049 if (msg
.hwnd
== pConv
->hwndClient
)
1051 /* check that either pXAct has been processed or no more xActions are pending */
1052 BOOL ret
= (pConv
->transactions
== pXAct
);
1053 if (WDML_HandleReply(pConv
, &msg
, &hdd
, ack
) == WDML_QS_HANDLED
)
1055 TRACE("WDML_HandleReply returned WDML_QS_HANDLED\n");
1059 ret
= (pConv
->transactions
== NULL
|| ret
);
1063 pConv
->instance
->lastError
= hdd
? DMLERR_NO_ERROR
: DMLERR_NOTPROCESSED
;
1064 LeaveCriticalSection(&WDML_CritSect
);
1070 LeaveCriticalSection(&WDML_CritSect
);
1071 DispatchMessageW(&msg
);
1077 TRACE("Timeout !!\n");
1079 EnterCriticalSection(&WDML_CritSect
);
1081 pConv
= WDML_GetConv(hConv
, FALSE
);
1084 if (pConv
->transactions
)
1086 switch (pConv
->transactions
->ddeMsg
)
1088 case WM_DDE_ADVISE
: err
= DMLERR_ADVACKTIMEOUT
; break;
1089 case WM_DDE_REQUEST
: err
= DMLERR_DATAACKTIMEOUT
; break;
1090 case WM_DDE_EXECUTE
: err
= DMLERR_EXECACKTIMEOUT
; break;
1091 case WM_DDE_POKE
: err
= DMLERR_POKEACKTIMEOUT
; break;
1092 case WM_DDE_UNADVISE
: err
= DMLERR_UNADVACKTIMEOUT
; break;
1093 default: err
= DMLERR_INVALIDPARAMETER
; break;
1096 pConv
->instance
->lastError
= err
;
1099 LeaveCriticalSection(&WDML_CritSect
);
1104 /*****************************************************************
1105 * DdeClientTransaction (USER32.@)
1107 HDDEDATA WINAPI
DdeClientTransaction(LPBYTE pData
, DWORD cbData
, HCONV hConv
, HSZ hszItem
, UINT wFmt
,
1108 UINT wType
, DWORD dwTimeout
, LPDWORD pdwResult
)
1112 HDDEDATA hDdeData
= 0;
1114 TRACE("(%p,%d,%p,%p,%x,%x,%d,%p)\n",
1115 pData
, cbData
, hConv
, hszItem
, wFmt
, wType
, dwTimeout
, pdwResult
);
1119 WARN("Invalid conversation handle NULL\n");
1123 EnterCriticalSection(&WDML_CritSect
);
1125 pConv
= WDML_GetConv(hConv
, TRUE
);
1128 /* cannot set error... cannot get back to DDE instance */
1135 /* Windows simply ignores hszItem and wFmt in this case */
1136 pXAct
= WDML_ClientQueueExecute(pConv
, pData
, cbData
);
1139 pXAct
= WDML_ClientQueuePoke(pConv
, pData
, cbData
, wFmt
, hszItem
);
1141 case XTYP_ADVSTART
|XTYPF_NODATA
:
1142 case XTYP_ADVSTART
|XTYPF_NODATA
|XTYPF_ACKREQ
:
1144 case XTYP_ADVSTART
|XTYPF_ACKREQ
:
1147 pConv
->instance
->lastError
= DMLERR_INVALIDPARAMETER
;
1150 pXAct
= WDML_ClientQueueAdvise(pConv
, wType
, wFmt
, hszItem
);
1155 pConv
->instance
->lastError
= DMLERR_INVALIDPARAMETER
;
1158 pXAct
= WDML_ClientQueueUnadvise(pConv
, wFmt
, hszItem
);
1163 pConv
->instance
->lastError
= DMLERR_INVALIDPARAMETER
;
1166 pXAct
= WDML_ClientQueueRequest(pConv
, wFmt
, hszItem
);
1169 FIXME("Unknown transation\n");
1170 /* unknown transaction type */
1171 pConv
->instance
->lastError
= DMLERR_INVALIDPARAMETER
;
1177 pConv
->instance
->lastError
= DMLERR_MEMORY_ERROR
;
1181 WDML_QueueTransaction(pConv
, pXAct
);
1183 if (!PostMessageW(pConv
->hwndServer
, pXAct
->ddeMsg
, (WPARAM
)pConv
->hwndClient
, pXAct
->lParam
))
1185 WARN("Failed posting message %x to %p (error=0x%x)\n",
1186 pXAct
->ddeMsg
, pConv
->hwndServer
, GetLastError());
1187 pConv
->wStatus
&= ~ST_CONNECTED
;
1188 WDML_UnQueueTransaction(pConv
, pXAct
);
1189 WDML_FreeTransaction(pConv
->instance
, pXAct
, TRUE
);
1192 pXAct
->dwTimeout
= dwTimeout
;
1193 /* FIXME: should set the app bits on *pdwResult */
1195 if (dwTimeout
== TIMEOUT_ASYNC
)
1199 *pdwResult
= MAKELONG(0, pXAct
->xActID
);
1201 hDdeData
= (HDDEDATA
)1;
1207 count
= WDML_CritSect
.RecursionCount
;
1208 for (i
= 0; i
< count
; i
++)
1209 LeaveCriticalSection(&WDML_CritSect
);
1210 hDdeData
= WDML_SyncWaitTransactionReply((HCONV
)pConv
, dwTimeout
, pXAct
, pdwResult
);
1211 for (i
= 0; i
< count
; i
++)
1212 EnterCriticalSection(&WDML_CritSect
);
1214 LeaveCriticalSection(&WDML_CritSect
);
1218 LeaveCriticalSection(&WDML_CritSect
);
1222 /*****************************************************************
1223 * DdeAbandonTransaction (USER32.@)
1225 BOOL WINAPI
DdeAbandonTransaction(DWORD idInst
, HCONV hConv
, DWORD idTransaction
)
1227 WDML_INSTANCE
* pInstance
;
1231 TRACE("(%08x,%p,%08x);\n", idInst
, hConv
, idTransaction
);
1233 EnterCriticalSection(&WDML_CritSect
);
1234 if ((pInstance
= WDML_GetInstance(idInst
)))
1238 if ((pConv
= WDML_GetConv(hConv
, TRUE
)) && pConv
->instance
== pInstance
)
1240 for (pXAct
= pConv
->transactions
; pXAct
; pXAct
= pXAct
->next
)
1242 if (pXAct
->dwTimeout
== TIMEOUT_ASYNC
&&
1243 (idTransaction
== 0 || pXAct
->xActID
== idTransaction
))
1245 WDML_UnQueueTransaction(pConv
, pXAct
);
1246 WDML_FreeTransaction(pInstance
, pXAct
, TRUE
);
1253 for (pConv
= pInstance
->convs
[WDML_CLIENT_SIDE
]; pConv
; pConv
= pConv
->next
)
1255 if (!(pConv
->wStatus
& ST_CONNECTED
)) continue;
1256 for (pXAct
= pConv
->transactions
; pXAct
; pXAct
= pXAct
->next
)
1258 if (pXAct
->dwTimeout
== TIMEOUT_ASYNC
)
1260 WDML_UnQueueTransaction(pConv
, pXAct
);
1261 WDML_FreeTransaction(pInstance
, pXAct
, TRUE
);
1267 LeaveCriticalSection(&WDML_CritSect
);
1272 /******************************************************************
1275 * Window Proc created on client side for each conversation
1277 static LRESULT CALLBACK
WDML_ClientProc(HWND hwnd
, UINT iMsg
, WPARAM wParam
, LPARAM lParam
)
1280 WDML_CONV
* pConv
= NULL
;
1283 TRACE("%p %04x %08x %08lx\n", hwnd
, iMsg
, wParam
, lParam
);
1285 if (iMsg
== WM_DDE_ACK
&&
1286 /* in the initial WM_INITIATE sendmessage */
1287 ((pConv
= WDML_GetConvFromWnd(hwnd
)) == NULL
|| pConv
->wStatus
== XST_INIT1
))
1289 /* In response to WM_DDE_INITIATE, save server window */
1291 WDML_INSTANCE
* pInstance
;
1293 /* note: sent messages do not need packing */
1294 uiLo
= LOWORD(lParam
);
1295 uiHi
= HIWORD(lParam
);
1297 /* FIXME: convlist should be handled here */
1300 /* we already have started the conv with a server, drop other replies */
1301 GlobalDeleteAtom(uiLo
);
1302 GlobalDeleteAtom(uiHi
);
1303 PostMessageW((HWND
)wParam
, WM_DDE_TERMINATE
, (WPARAM
)hwnd
, 0);
1307 pInstance
= WDML_GetInstanceFromWnd(hwnd
);
1309 hszSrv
= WDML_MakeHszFromAtom(pInstance
, uiLo
);
1310 hszTpc
= WDML_MakeHszFromAtom(pInstance
, uiHi
);
1312 pConv
= WDML_AddConv(pInstance
, WDML_CLIENT_SIDE
, hszSrv
, hszTpc
, hwnd
, (HWND
)wParam
);
1314 SetWindowLongPtrW(hwnd
, GWL_WDML_CONVERSATION
, (ULONG_PTR
)pConv
);
1315 pConv
->wStatus
|= ST_CONNECTED
;
1316 pConv
->wConvst
= XST_INIT1
;
1318 /* check if server is handled by DDEML */
1319 if ((GetClassNameA((HWND
)wParam
, buf
, sizeof(buf
)) &&
1320 lstrcmpiA(buf
, WDML_szServerConvClassA
) == 0) ||
1321 (GetClassNameW((HWND
)wParam
, (LPWSTR
)buf
, sizeof(buf
)/sizeof(WCHAR
)) &&
1322 lstrcmpiW((LPWSTR
)buf
, WDML_szServerConvClassW
) == 0))
1324 pConv
->wStatus
|= ST_ISLOCAL
;
1327 WDML_BroadcastDDEWindows(WDML_szEventClass
, WM_WDML_CONNECT_CONFIRM
, (WPARAM
)hwnd
, wParam
);
1329 GlobalDeleteAtom(uiLo
);
1330 GlobalDeleteAtom(uiHi
);
1332 /* accept conversation */
1336 if (iMsg
>= WM_DDE_FIRST
&& iMsg
<= WM_DDE_LAST
)
1338 EnterCriticalSection(&WDML_CritSect
);
1340 pConv
= WDML_GetConvFromWnd(hwnd
);
1349 msg
.wParam
= wParam
;
1350 msg
.lParam
= lParam
;
1352 WDML_HandleReply(pConv
, &msg
, &hdd
, NULL
);
1355 LeaveCriticalSection(&WDML_CritSect
);
1359 return IsWindowUnicode(hwnd
) ? DefWindowProcW(hwnd
, iMsg
, wParam
, lParam
) :
1360 DefWindowProcA(hwnd
, iMsg
, wParam
, lParam
);
1363 /*****************************************************************
1364 * DdeDisconnect (USER32.@)
1366 BOOL WINAPI
DdeDisconnect(HCONV hConv
)
1368 WDML_CONV
* pConv
= NULL
;
1373 TRACE("(%p)\n", hConv
);
1377 WARN("DdeDisconnect(): hConv = 0\n");
1381 EnterCriticalSection(&WDML_CritSect
);
1382 pConv
= WDML_GetConv(hConv
, TRUE
);
1385 if (pConv
->wStatus
& ST_CLIENT
)
1387 /* FIXME: should abandon all pending transactions */
1388 pXAct
= WDML_ClientQueueTerminate(pConv
);
1391 count
= WDML_CritSect
.RecursionCount
;
1392 for (i
= 0; i
< count
; i
++)
1393 LeaveCriticalSection(&WDML_CritSect
);
1394 if (PostMessageW(pConv
->hwndServer
, pXAct
->ddeMsg
,
1395 (WPARAM
)pConv
->hwndClient
, pXAct
->lParam
))
1396 WDML_SyncWaitTransactionReply(hConv
, 10000, pXAct
, NULL
);
1397 for (i
= 0; i
< count
; i
++)
1398 EnterCriticalSection(&WDML_CritSect
);
1400 WDML_FreeTransaction(pConv
->instance
, pXAct
, TRUE
);
1401 /* still have to destroy data assosiated with conversation */
1402 WDML_RemoveConv(pConv
, WDML_CLIENT_SIDE
);
1406 FIXME("Not implemented yet for a server side conversation\n");
1410 LeaveCriticalSection(&WDML_CritSect
);
1415 /*****************************************************************
1416 * DdeImpersonateClient (USER32.@)
1418 BOOL WINAPI
DdeImpersonateClient(HCONV hConv
)
1423 TRACE("(%p)\n", hConv
);
1425 EnterCriticalSection(&WDML_CritSect
);
1426 pConv
= WDML_GetConv(hConv
, TRUE
);
1429 ret
= ImpersonateDdeClientWindow(pConv
->hwndClient
, pConv
->hwndServer
);
1431 LeaveCriticalSection(&WDML_CritSect
);