1 /* -*- tab-width: 8; c-basic-offset: 4 -*- */
6 * Copyright 1997 Alexandre Julliard
7 * Copyright 1997 Len White
8 * Copyright 1999 Keith Matthews
10 * Copyright 2001 Eric Pouech
12 * This library is free software; you can redistribute it and/or
13 * modify it under the terms of the GNU Lesser General Public
14 * License as published by the Free Software Foundation; either
15 * version 2.1 of the License, or (at your option) any later version.
17 * This library is distributed in the hope that it will be useful,
18 * but WITHOUT ANY WARRANTY; without even the implied warranty of
19 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
20 * Lesser General Public License for more details.
22 * You should have received a copy of the GNU Lesser General Public
23 * License along with this library; if not, write to the Free Software
24 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
37 #include "wine/debug.h"
38 #include "dde/dde_private.h"
40 WINE_DEFAULT_DEBUG_CHANNEL(ddeml
);
42 static const char szServerNameClassA
[] = "DdeServerNameAnsi";
43 const char WDML_szServerConvClassA
[] = "DdeServerConvAnsi";
44 const WCHAR WDML_szServerConvClassW
[] = {'D','d','e','S','e','r','v','e','r','C','o','n','v','U','n','i','c','o','d','e',0};
46 static LRESULT CALLBACK
WDML_ServerNameProc(HWND
, UINT
, WPARAM
, LPARAM
);
47 static LRESULT CALLBACK
WDML_ServerConvProc(HWND
, UINT
, WPARAM
, LPARAM
);
49 /******************************************************************************
50 * DdePostAdvise [USER32.@] Send transaction to DDE callback function.
53 * idInst [I] Instance identifier
54 * hszTopic [I] Handle to topic name string
55 * hszItem [I] Handle to item name string
61 BOOL WINAPI
DdePostAdvise(DWORD idInst
, HSZ hszTopic
, HSZ hszItem
)
63 WDML_INSTANCE
* pInstance
= NULL
;
64 WDML_LINK
* pLink
= NULL
;
65 HDDEDATA hDdeData
= 0;
66 HGLOBAL hItemData
= 0;
67 WDML_CONV
* pConv
= NULL
;
71 TRACE("(%ld,%p,%p)\n", idInst
, hszTopic
, hszItem
);
73 EnterCriticalSection(&WDML_CritSect
);
75 pInstance
= WDML_GetInstance(idInst
);
77 if (pInstance
== NULL
|| pInstance
->links
== NULL
)
82 atom
= WDML_MakeAtomFromHsz(hszItem
);
83 if (!atom
) goto theError
;
85 /* first compute the number of links which will trigger a message */
87 for (pLink
= pInstance
->links
[WDML_SERVER_SIDE
]; pLink
!= NULL
; pLink
= pLink
->next
)
89 if (DdeCmpStringHandles(hszItem
, pLink
->hszItem
) == 0)
94 if (count
>= CADV_LATEACK
)
96 FIXME("too high value for count\n");
100 for (pLink
= pInstance
->links
[WDML_SERVER_SIDE
]; pLink
!= NULL
; pLink
= pLink
->next
)
102 if (DdeCmpStringHandles(hszItem
, pLink
->hszItem
) == 0)
104 hDdeData
= WDML_InvokeCallback(pInstance
, XTYP_ADVREQ
, pLink
->uFmt
, pLink
->hConv
,
105 hszTopic
, hszItem
, 0, --count
, 0);
107 if (hDdeData
== (HDDEDATA
)CBR_BLOCK
)
109 /* MS doc is not consistent here */
110 FIXME("CBR_BLOCK returned for ADVREQ\n");
115 if (pLink
->transactionType
& XTYPF_NODATA
)
122 TRACE("with data\n");
124 hItemData
= WDML_DataHandle2Global(hDdeData
, FALSE
, FALSE
, FALSE
, FALSE
);
127 pConv
= WDML_GetConv(pLink
->hConv
, TRUE
);
131 if (!WDML_IsAppOwned(hDdeData
)) DdeFreeDataHandle(hDdeData
);
135 if (!PostMessageA(pConv
->hwndClient
, WM_DDE_DATA
, (WPARAM
)pConv
->hwndServer
,
136 PackDDElParam(WM_DDE_DATA
, (UINT_PTR
)hItemData
, atom
)))
138 ERR("post message failed\n");
139 pConv
->wStatus
&= ~ST_CONNECTED
;
140 if (!WDML_IsAppOwned(hDdeData
)) DdeFreeDataHandle(hDdeData
);
141 GlobalFree(hItemData
);
144 if (!WDML_IsAppOwned(hDdeData
)) DdeFreeDataHandle(hDdeData
);
148 LeaveCriticalSection(&WDML_CritSect
);
151 LeaveCriticalSection(&WDML_CritSect
);
152 if (atom
) GlobalDeleteAtom(atom
);
157 /******************************************************************************
158 * DdeNameService [USER32.@] {Un}registers service name of DDE server
161 * idInst [I] Instance identifier
162 * hsz1 [I] Handle to service name string
164 * afCmd [I] Service name flags
170 HDDEDATA WINAPI
DdeNameService(DWORD idInst
, HSZ hsz1
, HSZ hsz2
, UINT afCmd
)
172 WDML_SERVER
* pServer
;
173 WDML_INSTANCE
* pInstance
;
176 WNDCLASSEXA wndclass
;
180 TRACE("(%ld,%p,%p,%x)\n", idInst
, hsz1
, hsz2
, afCmd
);
182 EnterCriticalSection(&WDML_CritSect
);
184 /* First check instance
186 pInstance
= WDML_GetInstance(idInst
);
187 if (pInstance
== NULL
)
189 TRACE("Instance not found as initialised\n");
190 /* Nothing has been initialised - exit now ! can return TRUE since effect is the same */
196 /* Illegal, reserved parameter
198 pInstance
->lastError
= DMLERR_INVALIDPARAMETER
;
199 WARN("Reserved parameter no-zero !!\n");
202 if (hsz1
== 0 && !(afCmd
& DNS_UNREGISTER
))
204 /* don't know if we should check this but it makes sense
205 * why supply REGISTER or filter flags if de-registering all
207 TRACE("General unregister unexpected flags\n");
208 pInstance
->lastError
= DMLERR_INVALIDPARAMETER
;
212 switch (afCmd
& (DNS_REGISTER
| DNS_UNREGISTER
))
215 pServer
= WDML_FindServer(pInstance
, hsz1
, 0);
218 ERR("Trying to register already registered service!\n");
219 pInstance
->lastError
= DMLERR_DLL_USAGE
;
223 TRACE("Adding service name\n");
225 WDML_IncHSZ(pInstance
, hsz1
);
227 pServer
= WDML_AddServer(pInstance
, hsz1
, 0);
229 WDML_BroadcastDDEWindows(WDML_szEventClass
, WM_WDML_REGISTER
,
230 pServer
->atomService
, pServer
->atomServiceSpec
);
232 wndclass
.cbSize
= sizeof(wndclass
);
234 wndclass
.lpfnWndProc
= WDML_ServerNameProc
;
235 wndclass
.cbClsExtra
= 0;
236 wndclass
.cbWndExtra
= 2 * sizeof(DWORD
);
237 wndclass
.hInstance
= 0;
239 wndclass
.hCursor
= 0;
240 wndclass
.hbrBackground
= 0;
241 wndclass
.lpszMenuName
= NULL
;
242 wndclass
.lpszClassName
= szServerNameClassA
;
243 wndclass
.hIconSm
= 0;
245 RegisterClassExA(&wndclass
);
247 LeaveCriticalSection(&WDML_CritSect
);
248 hwndServer
= CreateWindowA(szServerNameClassA
, NULL
,
249 WS_POPUP
, 0, 0, 0, 0,
251 EnterCriticalSection(&WDML_CritSect
);
253 SetWindowLongA(hwndServer
, GWL_WDML_INSTANCE
, (DWORD
)pInstance
);
254 SetWindowLongA(hwndServer
, GWL_WDML_SERVER
, (DWORD
)pServer
);
255 TRACE("Created nameServer=%p for instance=%08lx\n", hwndServer
, idInst
);
257 pServer
->hwndServer
= hwndServer
;
263 /* General unregister situation
264 * terminate all server side pending conversations
266 while (pInstance
->servers
)
267 WDML_RemoveServer(pInstance
, pInstance
->servers
->hszService
, 0);
268 pInstance
->servers
= NULL
;
269 TRACE("General de-register - finished\n");
273 WDML_RemoveServer(pInstance
, hsz1
, 0L);
278 if (afCmd
& (DNS_FILTERON
| DNS_FILTEROFF
))
280 /* Set filter flags on to hold notifications of connection
282 pServer
= WDML_FindServer(pInstance
, hsz1
, 0);
285 /* trying to filter where no service names !!
287 pInstance
->lastError
= DMLERR_DLL_USAGE
;
292 pServer
->filterOn
= (afCmd
& DNS_FILTERON
) != 0;
295 LeaveCriticalSection(&WDML_CritSect
);
296 return (HDDEDATA
)TRUE
;
299 LeaveCriticalSection(&WDML_CritSect
);
303 /******************************************************************
304 * WDML_CreateServerConv
308 static WDML_CONV
* WDML_CreateServerConv(WDML_INSTANCE
* pInstance
, HWND hwndClient
,
309 HWND hwndServerName
, HSZ hszApp
, HSZ hszTopic
)
314 if (pInstance
->unicode
)
316 WNDCLASSEXW wndclass
;
318 wndclass
.cbSize
= sizeof(wndclass
);
320 wndclass
.lpfnWndProc
= WDML_ServerConvProc
;
321 wndclass
.cbClsExtra
= 0;
322 wndclass
.cbWndExtra
= 2 * sizeof(DWORD
);
323 wndclass
.hInstance
= 0;
325 wndclass
.hCursor
= 0;
326 wndclass
.hbrBackground
= 0;
327 wndclass
.lpszMenuName
= NULL
;
328 wndclass
.lpszClassName
= WDML_szServerConvClassW
;
329 wndclass
.hIconSm
= 0;
331 RegisterClassExW(&wndclass
);
333 hwndServerConv
= CreateWindowW(WDML_szServerConvClassW
, 0,
334 WS_CHILD
, 0, 0, 0, 0,
335 hwndServerName
, 0, 0, 0);
339 WNDCLASSEXA wndclass
;
341 wndclass
.cbSize
= sizeof(wndclass
);
343 wndclass
.lpfnWndProc
= WDML_ServerConvProc
;
344 wndclass
.cbClsExtra
= 0;
345 wndclass
.cbWndExtra
= 2 * sizeof(DWORD
);
346 wndclass
.hInstance
= 0;
348 wndclass
.hCursor
= 0;
349 wndclass
.hbrBackground
= 0;
350 wndclass
.lpszMenuName
= NULL
;
351 wndclass
.lpszClassName
= WDML_szServerConvClassA
;
352 wndclass
.hIconSm
= 0;
354 RegisterClassExA(&wndclass
);
356 hwndServerConv
= CreateWindowA(WDML_szServerConvClassA
, 0,
357 WS_CHILD
, 0, 0, 0, 0,
358 hwndServerName
, 0, 0, 0);
361 TRACE("Created convServer=%p (nameServer=%p) for instance=%08lx\n",
362 hwndServerConv
, hwndServerName
, pInstance
->instanceID
);
364 pConv
= WDML_AddConv(pInstance
, WDML_SERVER_SIDE
, hszApp
, hszTopic
,
365 hwndClient
, hwndServerConv
);
368 SetWindowLongA(hwndServerConv
, GWL_WDML_INSTANCE
, (DWORD
)pInstance
);
369 SetWindowLongA(hwndServerConv
, GWL_WDML_CONVERSATION
, (DWORD
)pConv
);
371 /* this should be the only place using SendMessage for WM_DDE_ACK */
372 /* note: sent messages shall not use packing */
373 SendMessageA(hwndClient
, WM_DDE_ACK
, (WPARAM
)hwndServerConv
,
374 MAKELPARAM(WDML_MakeAtomFromHsz(hszApp
), WDML_MakeAtomFromHsz(hszTopic
)));
375 /* we assume we're connected since we've sent an answer...
376 * I'm not sure what we can do... it doesn't look like the return value
377 * of SendMessage is used... sigh...
379 pConv
->wStatus
|= ST_CONNECTED
;
383 DestroyWindow(hwndServerConv
);
388 /******************************************************************
389 * WDML_ServerNameProc
393 static LRESULT CALLBACK
WDML_ServerNameProc(HWND hwndServer
, UINT iMsg
, WPARAM wParam
, LPARAM lParam
)
397 HDDEDATA hDdeData
= 0;
398 WDML_INSTANCE
* pInstance
;
403 case WM_DDE_INITIATE
:
405 /* wParam -- sending window handle
406 LOWORD(lParam) -- application atom
407 HIWORD(lParam) -- topic atom */
409 TRACE("WM_DDE_INITIATE message received!\n");
410 hwndClient
= (HWND
)wParam
;
412 pInstance
= WDML_GetInstanceFromWnd(hwndServer
);
413 TRACE("idInst=%ld, threadID=0x%lx\n", pInstance
->instanceID
, GetCurrentThreadId());
414 if (!pInstance
) return 0;
416 /* don't free DDEParams, since this is a broadcast */
417 UnpackDDElParam(WM_DDE_INITIATE
, lParam
, &uiLo
, &uiHi
);
419 hszApp
= WDML_MakeHszFromAtom(pInstance
, uiLo
);
420 hszTop
= WDML_MakeHszFromAtom(pInstance
, uiHi
);
422 if (!(pInstance
->CBFflags
& CBF_FAIL_CONNECTIONS
))
426 CONVCONTEXT
* pcc
= NULL
;
430 if (GetWindowThreadProcessId(hwndClient
, NULL
) == GetWindowThreadProcessId(hwndServer
, NULL
) &&
431 WDML_GetInstanceFromWnd(hwndClient
) == WDML_GetInstanceFromWnd(hwndServer
))
435 /* FIXME: so far, we don't grab distant convcontext, so only check if remote is
436 * handled under DDEML, and if so build a default context
438 if ((GetClassNameA(hwndClient
, buf
, sizeof(buf
)) &&
439 strcmp(buf
, WDML_szClientConvClassA
) == 0) ||
440 (GetClassNameW(hwndClient
, (LPWSTR
)buf
, sizeof(buf
)/sizeof(WCHAR
)) &&
441 lstrcmpW((LPWSTR
)buf
, WDML_szClientConvClassW
) == 0))
444 memset(pcc
, 0, sizeof(*pcc
));
445 pcc
->cb
= sizeof(*pcc
);
446 pcc
->iCodePage
= IsWindowUnicode(hwndClient
) ? CP_WINUNICODE
: CP_WINANSI
;
448 if ((pInstance
->CBFflags
& CBF_FAIL_SELFCONNECTIONS
) && self
)
450 TRACE("Don't do self connection as requested\n");
452 else if (hszApp
&& hszTop
)
454 WDML_SERVER
* pServer
= (WDML_SERVER
*)GetWindowLongA(hwndServer
, GWL_WDML_SERVER
);
456 /* check filters for name service */
457 if (!pServer
->filterOn
|| DdeCmpStringHandles(pServer
->hszService
, hszApp
) == 0)
459 /* pass on to the callback */
460 hDdeData
= WDML_InvokeCallback(pInstance
, XTYP_CONNECT
,
461 0, 0, hszTop
, hszApp
, 0, (ULONG_PTR
)pcc
, self
);
464 pConv
= WDML_CreateServerConv(pInstance
, hwndClient
, hwndServer
,
468 if (pcc
) pConv
->wStatus
|= ST_ISLOCAL
;
469 WDML_InvokeCallback(pInstance
, XTYP_CONNECT_CONFIRM
, 0, (HCONV
)pConv
,
470 hszTop
, hszApp
, 0, (ULONG_PTR
)pcc
, self
);
475 else if (pInstance
->servers
)
477 /* pass on to the callback */
478 hDdeData
= WDML_InvokeCallback(pInstance
, XTYP_WILDCONNECT
,
479 0, 0, hszTop
, hszApp
, 0, (ULONG_PTR
)pcc
, self
);
481 if (hDdeData
== (HDDEDATA
)CBR_BLOCK
)
483 /* MS doc is not consistent here */
484 FIXME("CBR_BLOCK returned for WILDCONNECT\n");
486 else if ((UINT
)hDdeData
!= 0)
490 hszp
= (HSZPAIR
*)DdeAccessData(hDdeData
, NULL
);
494 for (i
= 0; hszp
[i
].hszSvc
&& hszp
[i
].hszTopic
; i
++)
496 pConv
= WDML_CreateServerConv(pInstance
, hwndClient
, hwndServer
,
497 hszp
[i
].hszSvc
, hszp
[i
].hszTopic
);
500 if (pcc
) pConv
->wStatus
|= ST_ISLOCAL
;
501 WDML_InvokeCallback(pInstance
, XTYP_CONNECT_CONFIRM
, 0, (HCONV
)pConv
,
502 hszp
[i
].hszTopic
, hszp
[i
].hszSvc
, 0, (ULONG_PTR
)pcc
, self
);
505 DdeUnaccessData(hDdeData
);
507 if (!WDML_IsAppOwned(hDdeData
)) DdeFreeDataHandle(hDdeData
);
516 FIXME("WM_DDE_REQUEST message received!\n");
519 FIXME("WM_DDE_ADVISE message received!\n");
521 case WM_DDE_UNADVISE
:
522 FIXME("WM_DDE_UNADVISE message received!\n");
525 FIXME("WM_DDE_EXECUTE message received!\n");
528 FIXME("WM_DDE_POKE message received!\n");
530 case WM_DDE_TERMINATE
:
531 FIXME("WM_DDE_TERMINATE message received!\n");
536 return DefWindowProcA(hwndServer
, iMsg
, wParam
, lParam
);
539 /******************************************************************
540 * WDML_ServerQueueRequest
544 static WDML_XACT
* WDML_ServerQueueRequest(WDML_CONV
* pConv
, LPARAM lParam
)
549 UnpackDDElParam(WM_DDE_REQUEST
, lParam
, &uiLo
, &uiHi
);
551 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_REQUEST
,
552 uiLo
, WDML_MakeHszFromAtom(pConv
->instance
, uiHi
));
553 if (pXAct
) pXAct
->atom
= uiHi
;
557 /******************************************************************
558 * WDML_ServerHandleRequest
562 static WDML_QUEUE_STATE
WDML_ServerHandleRequest(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
564 HDDEDATA hDdeData
= 0;
567 if (!(pConv
->instance
->CBFflags
& CBF_FAIL_REQUESTS
))
570 hDdeData
= WDML_InvokeCallback(pConv
->instance
, XTYP_REQUEST
, pXAct
->wFmt
, (HCONV
)pConv
,
571 pConv
->hszTopic
, pXAct
->hszItem
, 0, 0, 0);
574 switch ((ULONG_PTR
)hDdeData
)
577 TRACE("No data returned from the Callback\n");
581 case (ULONG_PTR
)CBR_BLOCK
:
582 return WDML_QS_BLOCK
;
586 HGLOBAL hMem
= WDML_DataHandle2Global(hDdeData
, TRUE
, FALSE
, FALSE
, FALSE
);
587 if (!PostMessageA(pConv
->hwndClient
, WM_DDE_DATA
, (WPARAM
)pConv
->hwndServer
,
588 ReuseDDElParam(pXAct
->lParam
, WM_DDE_REQUEST
, WM_DDE_DATA
,
589 (UINT_PTR
)hMem
, (UINT_PTR
)pXAct
->atom
)))
591 DdeFreeDataHandle(hDdeData
);
599 WDML_PostAck(pConv
, WDML_SERVER_SIDE
, 0, FALSE
, fAck
, pXAct
->atom
, pXAct
->lParam
, WM_DDE_REQUEST
);
601 WDML_DecHSZ(pConv
->instance
, pXAct
->hszItem
);
603 return WDML_QS_HANDLED
;
606 /******************************************************************
607 * WDML_ServerQueueAdvise
611 static WDML_XACT
* WDML_ServerQueueAdvise(WDML_CONV
* pConv
, LPARAM lParam
)
616 /* XTYP_ADVSTART transaction:
617 establish link and save link info to InstanceInfoTable */
619 if (!UnpackDDElParam(WM_DDE_ADVISE
, lParam
, &uiLo
, &uiHi
))
622 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_ADVISE
,
623 0, WDML_MakeHszFromAtom(pConv
->instance
, uiHi
));
626 pXAct
->hMem
= (HGLOBAL
)uiLo
;
632 /******************************************************************
633 * WDML_ServerHandleAdvise
637 static WDML_QUEUE_STATE
WDML_ServerHandleAdvise(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
641 DDEADVISE
* pDdeAdvise
;
642 HDDEDATA hDdeData
= 0;
645 pDdeAdvise
= (DDEADVISE
*)GlobalLock(pXAct
->hMem
);
646 uType
= XTYP_ADVSTART
|
647 (pDdeAdvise
->fDeferUpd
? XTYPF_NODATA
: 0) |
648 (pDdeAdvise
->fAckReq
? XTYPF_ACKREQ
: 0);
650 if (!(pConv
->instance
->CBFflags
& CBF_FAIL_ADVISES
))
652 hDdeData
= WDML_InvokeCallback(pConv
->instance
, XTYP_ADVSTART
, pDdeAdvise
->cfFormat
,
653 (HCONV
)pConv
, pConv
->hszTopic
, pXAct
->hszItem
, 0, 0, 0);
656 switch ((ULONG_PTR
)hDdeData
)
659 TRACE("No data returned from the Callback\n");
663 case (ULONG_PTR
)CBR_BLOCK
:
664 return WDML_QS_BLOCK
;
667 /* billx: first to see if the link is already created. */
668 pLink
= WDML_FindLink(pConv
->instance
, (HCONV
)pConv
, WDML_SERVER_SIDE
,
669 pXAct
->hszItem
, TRUE
, pDdeAdvise
->cfFormat
);
673 /* we found a link, and only need to modify it in case it changes */
674 pLink
->transactionType
= uType
;
678 TRACE("Adding Link with hConv %p\n", pConv
);
679 WDML_AddLink(pConv
->instance
, (HCONV
)pConv
, WDML_SERVER_SIDE
,
680 uType
, pXAct
->hszItem
, pDdeAdvise
->cfFormat
);
685 GlobalUnlock(pXAct
->hMem
);
688 GlobalFree(pXAct
->hMem
);
692 WDML_PostAck(pConv
, WDML_SERVER_SIDE
, 0, FALSE
, fAck
, pXAct
->atom
, pXAct
->lParam
, WM_DDE_ADVISE
);
694 WDML_DecHSZ(pConv
->instance
, pXAct
->hszItem
);
696 return WDML_QS_HANDLED
;
699 /******************************************************************
700 * WDML_ServerQueueUnadvise
704 static WDML_XACT
* WDML_ServerQueueUnadvise(WDML_CONV
* pConv
, LPARAM lParam
)
709 UnpackDDElParam(WM_DDE_UNADVISE
, lParam
, &uiLo
, &uiHi
);
711 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_UNADVISE
,
712 uiLo
, WDML_MakeHszFromAtom(pConv
->instance
, uiHi
));
713 if (pXAct
) pXAct
->atom
= uiHi
;
717 /******************************************************************
718 * WDML_ServerHandleUnadvise
722 static WDML_QUEUE_STATE
WDML_ServerHandleUnadvise(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
726 if (pXAct
->hszItem
== NULL
|| pXAct
->wFmt
== 0)
728 ERR("Unsupported yet options (null item or clipboard format)\n");
729 return WDML_QS_ERROR
;
732 pLink
= WDML_FindLink(pConv
->instance
, (HCONV
)pConv
, WDML_SERVER_SIDE
,
733 pXAct
->hszItem
, TRUE
, pXAct
->wFmt
);
736 ERR("Couln'd find link for %p, dropping request\n", pXAct
->hszItem
);
737 FreeDDElParam(WM_DDE_UNADVISE
, pXAct
->lParam
);
738 return WDML_QS_ERROR
;
741 if (!(pConv
->instance
->CBFflags
& CBF_FAIL_ADVISES
))
743 WDML_InvokeCallback(pConv
->instance
, XTYP_ADVSTOP
, pXAct
->wFmt
, (HCONV
)pConv
,
744 pConv
->hszTopic
, pXAct
->hszItem
, 0, 0, 0);
747 WDML_RemoveLink(pConv
->instance
, (HCONV
)pConv
, WDML_SERVER_SIDE
,
748 pXAct
->hszItem
, pXAct
->wFmt
);
751 WDML_PostAck(pConv
, WDML_SERVER_SIDE
, 0, FALSE
, TRUE
, pXAct
->atom
,
752 pXAct
->lParam
, WM_DDE_UNADVISE
);
754 WDML_DecHSZ(pConv
->instance
, pXAct
->hszItem
);
756 return WDML_QS_HANDLED
;
759 /******************************************************************
764 static WDML_XACT
* WDML_ServerQueueExecute(WDML_CONV
* pConv
, LPARAM lParam
)
768 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_EXECUTE
, 0, 0);
771 pXAct
->hMem
= (HGLOBAL
)lParam
;
776 /******************************************************************
777 * WDML_ServerHandleExecute
781 static WDML_QUEUE_STATE
WDML_ServerHandleExecute(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
783 HDDEDATA hDdeData
= DDE_FNOTPROCESSED
;
784 BOOL fAck
= FALSE
, fBusy
= FALSE
;
786 if (!(pConv
->instance
->CBFflags
& CBF_FAIL_EXECUTES
))
788 LPVOID ptr
= GlobalLock(pXAct
->hMem
);
792 hDdeData
= DdeCreateDataHandle(0, ptr
, GlobalSize(pXAct
->hMem
),
794 GlobalUnlock(pXAct
->hMem
);
796 hDdeData
= WDML_InvokeCallback(pConv
->instance
, XTYP_EXECUTE
, 0, (HCONV
)pConv
,
797 pConv
->hszTopic
, 0, hDdeData
, 0L, 0L);
800 switch ((ULONG_PTR
)hDdeData
)
802 case (ULONG_PTR
)CBR_BLOCK
:
803 return WDML_QS_BLOCK
;
812 FIXME("Unsupported returned value %p\n", hDdeData
);
814 case DDE_FNOTPROCESSED
:
817 WDML_PostAck(pConv
, WDML_SERVER_SIDE
, 0, fBusy
, fAck
, (UINT
)pXAct
->hMem
, 0, 0);
819 return WDML_QS_HANDLED
;
822 /******************************************************************
823 * WDML_ServerQueuePoke
827 static WDML_XACT
* WDML_ServerQueuePoke(WDML_CONV
* pConv
, LPARAM lParam
)
832 UnpackDDElParam(WM_DDE_POKE
, lParam
, &uiLo
, &uiHi
);
834 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_POKE
,
835 0, WDML_MakeHszFromAtom(pConv
->instance
, uiHi
));
839 pXAct
->hMem
= (HGLOBAL
)uiLo
;
844 /******************************************************************
845 * WDML_ServerHandlePoke
849 static WDML_QUEUE_STATE
WDML_ServerHandlePoke(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
853 BOOL fBusy
= FALSE
, fAck
= FALSE
;
855 pDdePoke
= (DDEPOKE
*)GlobalLock(pXAct
->hMem
);
858 return WDML_QS_ERROR
;
861 if (!(pConv
->instance
->CBFflags
& CBF_FAIL_POKES
))
863 hDdeData
= DdeCreateDataHandle(pConv
->instance
->instanceID
, pDdePoke
->Value
,
864 GlobalSize(pXAct
->hMem
) - sizeof(DDEPOKE
) + 1,
865 0, 0, pDdePoke
->cfFormat
, 0);
868 HDDEDATA hDdeDataOut
;
870 hDdeDataOut
= WDML_InvokeCallback(pConv
->instance
, XTYP_POKE
, pDdePoke
->cfFormat
,
871 (HCONV
)pConv
, pConv
->hszTopic
, pXAct
->hszItem
,
873 switch ((ULONG_PTR
)hDdeDataOut
)
882 FIXME("Unsupported returned value %p\n", hDdeDataOut
);
884 case DDE_FNOTPROCESSED
:
887 DdeFreeDataHandle(hDdeData
);
890 GlobalUnlock(pXAct
->hMem
);
894 GlobalFree(pXAct
->hMem
);
896 WDML_PostAck(pConv
, WDML_SERVER_SIDE
, 0, fBusy
, fAck
, pXAct
->atom
, pXAct
->lParam
, WM_DDE_POKE
);
898 WDML_DecHSZ(pConv
->instance
, pXAct
->hszItem
);
900 return WDML_QS_HANDLED
;
903 /******************************************************************
904 * WDML_ServerQueueTerminate
908 static WDML_XACT
* WDML_ServerQueueTerminate(WDML_CONV
* pConv
, LPARAM lParam
)
912 pXAct
= WDML_AllocTransaction(pConv
->instance
, WM_DDE_TERMINATE
, 0, 0);
916 /******************************************************************
917 * WDML_ServerHandleTerminate
921 static WDML_QUEUE_STATE
WDML_ServerHandleTerminate(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
923 /* billx: two things to remove: the conv, and associated links.
924 * Respond with another WM_DDE_TERMINATE iMsg.
926 if (!(pConv
->instance
->CBFflags
& CBF_SKIP_DISCONNECTS
))
928 WDML_InvokeCallback(pConv
->instance
, XTYP_DISCONNECT
, 0, (HCONV
)pConv
, 0, 0,
929 0, 0, (pConv
->wStatus
& ST_ISSELF
) ? 1 : 0);
931 PostMessageA(pConv
->hwndClient
, WM_DDE_TERMINATE
, (WPARAM
)pConv
->hwndServer
, 0);
932 WDML_RemoveConv(pConv
, WDML_SERVER_SIDE
);
934 return WDML_QS_HANDLED
;
937 /******************************************************************
942 WDML_QUEUE_STATE
WDML_ServerHandle(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
944 WDML_QUEUE_STATE qs
= WDML_QS_ERROR
;
946 switch (pXAct
->ddeMsg
)
948 case WM_DDE_INITIATE
:
949 FIXME("WM_DDE_INITIATE shouldn't be there!\n");
952 qs
= WDML_ServerHandleRequest(pConv
, pXAct
);
956 qs
= WDML_ServerHandleAdvise(pConv
, pXAct
);
959 case WM_DDE_UNADVISE
:
960 qs
= WDML_ServerHandleUnadvise(pConv
, pXAct
);
964 qs
= WDML_ServerHandleExecute(pConv
, pXAct
);
968 qs
= WDML_ServerHandlePoke(pConv
, pXAct
);
971 case WM_DDE_TERMINATE
:
972 qs
= WDML_ServerHandleTerminate(pConv
, pXAct
);
976 WARN("Shouldn't receive a ACK message (never requests them). Ignoring it\n");
980 FIXME("Unsupported message %d\n", pXAct
->ddeMsg
);
985 /******************************************************************
986 * WDML_ServerConvProc
990 static LRESULT CALLBACK
WDML_ServerConvProc(HWND hwndServer
, UINT iMsg
, WPARAM wParam
, LPARAM lParam
)
992 WDML_INSTANCE
* pInstance
;
994 WDML_XACT
* pXAct
= NULL
;
996 TRACE("%p %04x %08x %08lx\n", hwndServer
, iMsg
, wParam
, lParam
);
998 if (iMsg
== WM_DESTROY
)
1000 EnterCriticalSection(&WDML_CritSect
);
1001 pConv
= WDML_GetConvFromWnd(hwndServer
);
1002 if (pConv
&& !(pConv
->wStatus
& ST_TERMINATED
))
1004 WDML_ServerHandleTerminate(pConv
, NULL
);
1006 LeaveCriticalSection(&WDML_CritSect
);
1008 if (iMsg
< WM_DDE_FIRST
|| iMsg
> WM_DDE_LAST
)
1010 return IsWindowUnicode(hwndServer
) ? DefWindowProcW(hwndServer
, iMsg
, wParam
, lParam
) :
1011 DefWindowProcA(hwndServer
, iMsg
, wParam
, lParam
);
1014 EnterCriticalSection(&WDML_CritSect
);
1016 pInstance
= WDML_GetInstanceFromWnd(hwndServer
);
1017 pConv
= WDML_GetConvFromWnd(hwndServer
);
1021 ERR("Got a message (%x) on a not known conversation, dropping request\n", iMsg
);
1024 if (pConv
->hwndClient
!= WIN_GetFullHandle( (HWND
)wParam
) || pConv
->hwndServer
!= hwndServer
)
1026 ERR("mismatch between C/S windows and converstation\n");
1029 if (pConv
->instance
!= pInstance
|| pConv
->instance
== NULL
)
1031 ERR("mismatch in instances\n");
1037 case WM_DDE_INITIATE
:
1038 FIXME("WM_DDE_INITIATE message received!\n");
1041 case WM_DDE_REQUEST
:
1042 pXAct
= WDML_ServerQueueRequest(pConv
, lParam
);
1046 pXAct
= WDML_ServerQueueAdvise(pConv
, lParam
);
1049 case WM_DDE_UNADVISE
:
1050 pXAct
= WDML_ServerQueueUnadvise(pConv
, lParam
);
1053 case WM_DDE_EXECUTE
:
1054 pXAct
= WDML_ServerQueueExecute(pConv
, lParam
);
1058 pXAct
= WDML_ServerQueuePoke(pConv
, lParam
);
1061 case WM_DDE_TERMINATE
:
1062 pXAct
= WDML_ServerQueueTerminate(pConv
, lParam
);
1066 WARN("Shouldn't receive a ACK message (never requests them). Ignoring it\n");
1070 FIXME("Unsupported message %x\n", iMsg
);
1075 pXAct
->lParam
= lParam
;
1076 if (WDML_ServerHandle(pConv
, pXAct
) == WDML_QS_BLOCK
)
1078 WDML_QueueTransaction(pConv
, pXAct
);
1082 WDML_FreeTransaction(pInstance
, pXAct
, TRUE
);
1086 LeaveCriticalSection(&WDML_CritSect
);