4 * Copyright 1997 Alexandre Julliard
5 * Copyright 1997 Len White
6 * Copyright 1999 Keith Matthews
8 * Copyright 2001 Eric Pouech
9 * Copyright 2003, 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
27 #include "wine/port.h"
40 #include "dde_private.h"
41 #include "wine/unicode.h"
42 #include "wine/debug.h"
44 WINE_DEFAULT_DEBUG_CHANNEL(ddeml
);
46 /* convert between ATOM and HSZ avoiding compiler warnings */
47 #define ATOM2HSZ(atom) ((HSZ) (ULONG_PTR)(atom))
48 #define HSZ2ATOM(hsz) ((ATOM) (ULONG_PTR)(hsz))
50 static WDML_INSTANCE
* WDML_InstanceList
= NULL
;
51 static LONG WDML_MaxInstanceID
= 0; /* OK for present, have to worry about wrap-around later */
52 const WCHAR WDML_szEventClass
[] = {'W','i','n','e','D','d','e','E','v','e','n','t','C','l','a','s','s',0};
54 /* protection for instance list */
55 static CRITICAL_SECTION WDML_CritSect
;
56 static CRITICAL_SECTION_DEBUG critsect_debug
=
59 { &critsect_debug
.ProcessLocksList
, &critsect_debug
.ProcessLocksList
},
60 0, 0, { (DWORD_PTR
)(__FILE__
": WDML_CritSect") }
62 static CRITICAL_SECTION WDML_CritSect
= { &critsect_debug
, -1, 0, 0, 0, 0 };
64 /* ================================================================
66 * Pure DDE (non DDEML) management
68 * ================================================================ */
71 /*****************************************************************
72 * PackDDElParam (USER32.@)
77 LPARAM WINAPI
PackDDElParam(UINT msg
, UINT_PTR uiLo
, UINT_PTR uiHi
)
88 if (!(hMem
= GlobalAlloc(GMEM_DDESHARE
, sizeof(UINT_PTR
) * 2)))
90 ERR("GlobalAlloc failed\n");
93 if (!(params
= GlobalLock(hMem
)))
95 ERR("GlobalLock failed (%p)\n", hMem
);
107 return MAKELPARAM(uiLo
, uiHi
);
112 /*****************************************************************
113 * UnpackDDElParam (USER32.@)
119 BOOL WINAPI
UnpackDDElParam(UINT msg
, LPARAM lParam
,
120 PUINT_PTR uiLo
, PUINT_PTR uiHi
)
130 if (!lParam
) return FALSE
;
131 if (!(params
= GlobalLock( (HGLOBAL
)lParam
)))
133 ERR("GlobalLock failed (%lx)\n", lParam
);
136 TRACE("unpacked: low %08x, high %08x\n", params
[0], params
[1]);
137 if (uiLo
) *uiLo
= params
[0];
138 if (uiHi
) *uiHi
= params
[1];
139 GlobalUnlock( (HGLOBAL
)lParam
);
144 if (uiHi
) *uiHi
= lParam
;
148 if (uiLo
) *uiLo
= LOWORD(lParam
);
149 if (uiHi
) *uiHi
= HIWORD(lParam
);
155 /*****************************************************************
156 * FreeDDElParam (USER32.@)
162 BOOL WINAPI
FreeDDElParam(UINT msg
, LPARAM lParam
)
170 /* first check if it's a global handle */
171 if (!GlobalHandle( (LPVOID
)lParam
)) return TRUE
;
172 return !GlobalFree( (HGLOBAL
)lParam
);
180 /*****************************************************************
181 * ReuseDDElParam (USER32.@)
186 LPARAM WINAPI
ReuseDDElParam(LPARAM lParam
, UINT msgIn
, UINT msgOut
,
187 UINT_PTR uiLo
, UINT_PTR uiHi
)
203 if (!lParam
) return 0;
204 if (!(params
= GlobalLock( (HGLOBAL
)lParam
)))
206 ERR("GlobalLock failed\n");
211 TRACE("Reusing pack %08x %08x\n", uiLo
, uiHi
);
212 GlobalUnlock( (HGLOBAL
)lParam
);
216 FreeDDElParam( msgIn
, lParam
);
220 FreeDDElParam( msgIn
, lParam
);
221 return MAKELPARAM(uiLo
, uiHi
);
225 return PackDDElParam( msgOut
, uiLo
, uiHi
);
229 /*****************************************************************
230 * ImpersonateDdeClientWindow (USER32.@)
233 * hWndClient [I] handle to DDE client window
234 * hWndServer [I] handle to DDE server window
236 BOOL WINAPI
ImpersonateDdeClientWindow(HWND hWndClient
, HWND hWndServer
)
238 FIXME("(%p %p): stub\n", hWndClient
, hWndServer
);
242 /*****************************************************************
243 * DdeSetQualityOfService (USER32.@)
246 BOOL WINAPI
DdeSetQualityOfService(HWND hwndClient
, CONST SECURITY_QUALITY_OF_SERVICE
*pqosNew
,
247 PSECURITY_QUALITY_OF_SERVICE pqosPrev
)
249 FIXME("(%p %p %p): stub\n", hwndClient
, pqosNew
, pqosPrev
);
253 /* ================================================================
255 * Instance management
257 * ================================================================ */
259 /******************************************************************************
260 * IncrementInstanceId
262 * generic routine to increment the max instance Id and allocate a new application instance
264 static void WDML_IncrementInstanceId(WDML_INSTANCE
* pInstance
)
266 DWORD id
= InterlockedIncrement(&WDML_MaxInstanceID
);
268 pInstance
->instanceID
= id
;
269 TRACE("New instance id %d allocated\n", id
);
272 /******************************************************************
277 static LRESULT CALLBACK
WDML_EventProc(HWND hwndEvent
, UINT uMsg
, WPARAM wParam
, LPARAM lParam
)
279 WDML_INSTANCE
* pInstance
;
284 case WM_WDML_REGISTER
:
285 pInstance
= WDML_GetInstanceFromWnd(hwndEvent
);
286 /* try calling the Callback */
287 if (pInstance
&& !(pInstance
->CBFflags
& CBF_SKIP_REGISTRATIONS
))
289 hsz1
= WDML_MakeHszFromAtom(pInstance
, wParam
);
290 hsz2
= WDML_MakeHszFromAtom(pInstance
, lParam
);
291 WDML_InvokeCallback(pInstance
, XTYP_REGISTER
, 0, 0, hsz1
, hsz2
, 0, 0, 0);
292 WDML_DecHSZ(pInstance
, hsz1
);
293 WDML_DecHSZ(pInstance
, hsz2
);
297 case WM_WDML_UNREGISTER
:
298 pInstance
= WDML_GetInstanceFromWnd(hwndEvent
);
299 if (pInstance
&& !(pInstance
->CBFflags
& CBF_SKIP_UNREGISTRATIONS
))
301 hsz1
= WDML_MakeHszFromAtom(pInstance
, wParam
);
302 hsz2
= WDML_MakeHszFromAtom(pInstance
, lParam
);
303 WDML_InvokeCallback(pInstance
, XTYP_UNREGISTER
, 0, 0, hsz1
, hsz2
, 0, 0, 0);
304 WDML_DecHSZ(pInstance
, hsz1
);
305 WDML_DecHSZ(pInstance
, hsz2
);
309 case WM_WDML_CONNECT_CONFIRM
:
310 pInstance
= WDML_GetInstanceFromWnd(hwndEvent
);
311 if (pInstance
&& !(pInstance
->CBFflags
& CBF_SKIP_CONNECT_CONFIRMS
))
314 /* confirm connection...
315 * lookup for this conv handle
317 HWND client
= WIN_GetFullHandle( (HWND
)wParam
);
318 HWND server
= WIN_GetFullHandle( (HWND
)lParam
);
319 for (pConv
= pInstance
->convs
[WDML_SERVER_SIDE
]; pConv
!= NULL
; pConv
= pConv
->next
)
321 if (pConv
->hwndClient
== client
&& pConv
->hwndServer
== server
)
326 pConv
->wStatus
|= ST_ISLOCAL
;
328 WDML_InvokeCallback(pInstance
, XTYP_CONNECT_CONFIRM
, 0, (HCONV
)pConv
,
329 pConv
->hszTopic
, pConv
->hszService
, 0, 0,
330 (pConv
->wStatus
& ST_ISSELF
) ? 1 : 0);
335 return DefWindowProcW(hwndEvent
, uMsg
, wParam
, lParam
);
340 /******************************************************************
345 UINT
WDML_Initialize(LPDWORD pidInst
, PFNCALLBACK pfnCallback
,
346 DWORD afCmd
, DWORD ulRes
, BOOL bUnicode
, BOOL b16
)
348 WDML_INSTANCE
* pInstance
;
349 WDML_INSTANCE
* reference_inst
;
351 WNDCLASSEXW wndclass
;
353 TRACE("(%p,%p,0x%x,%d)\n",
354 pidInst
, pfnCallback
, afCmd
, ulRes
);
358 ERR("Reserved value not zero? What does this mean?\n");
359 /* trap this and no more until we know more */
360 return DMLERR_NO_ERROR
;
363 /* grab enough heap for one control struct - not really necessary for re-initialise
364 * but allows us to use same validation routines */
365 pInstance
= HeapAlloc(GetProcessHeap(), 0, sizeof(WDML_INSTANCE
));
366 if (pInstance
== NULL
)
368 /* catastrophe !! warn user & abort */
369 ERR("Instance create failed - out of memory\n");
370 return DMLERR_SYS_ERROR
;
372 pInstance
->next
= NULL
;
373 pInstance
->monitor
= (afCmd
| APPCLASS_MONITOR
);
375 /* messy bit, spec implies that 'Client Only' can be set in 2 different ways, catch 1 here */
377 pInstance
->clientOnly
= afCmd
& APPCMD_CLIENTONLY
;
378 pInstance
->instanceID
= *pidInst
; /* May need to add calling proc Id */
379 pInstance
->threadID
= GetCurrentThreadId();
380 pInstance
->callback
= *pfnCallback
;
381 pInstance
->unicode
= bUnicode
;
382 pInstance
->win16
= b16
;
383 pInstance
->nodeList
= NULL
; /* node will be added later */
384 pInstance
->monitorFlags
= afCmd
& MF_MASK
;
385 pInstance
->wStatus
= 0;
386 pInstance
->servers
= NULL
;
387 pInstance
->convs
[0] = NULL
;
388 pInstance
->convs
[1] = NULL
;
389 pInstance
->links
[0] = NULL
;
390 pInstance
->links
[1] = NULL
;
392 /* isolate CBF flags in one go, expect this will go the way of all attempts to be clever !! */
394 pInstance
->CBFflags
= afCmd
^((afCmd
&MF_MASK
)|((afCmd
&APPCMD_MASK
)|(afCmd
&APPCLASS_MASK
)));
396 if (!pInstance
->clientOnly
)
398 /* Check for other way of setting Client-only !! */
399 pInstance
->clientOnly
=
400 (pInstance
->CBFflags
& CBF_FAIL_ALLSVRXACTIONS
) == CBF_FAIL_ALLSVRXACTIONS
;
403 TRACE("instance created - checking validity\n");
407 /* Initialisation of new Instance Identifier */
408 TRACE("new instance, callback %p flags %X\n",pfnCallback
,afCmd
);
410 EnterCriticalSection(&WDML_CritSect
);
412 if (WDML_InstanceList
== NULL
)
414 /* can't be another instance in this case, assign to the base pointer */
415 WDML_InstanceList
= pInstance
;
417 /* since first must force filter of XTYP_CONNECT and XTYP_WILDCONNECT for
419 * ------------------------------- NOTE NOTE NOTE --------------------------
421 * the manual is not clear if this condition
422 * applies to the first call to DdeInitialize from an application, or the
423 * first call for a given callback !!!
426 pInstance
->CBFflags
= pInstance
->CBFflags
|APPCMD_FILTERINITS
;
427 TRACE("First application instance detected OK\n");
428 /* allocate new instance ID */
429 WDML_IncrementInstanceId(pInstance
);
433 /* really need to chain the new one in to the latest here, but after checking conditions
434 * such as trying to start a conversation from an application trying to monitor */
435 reference_inst
= WDML_InstanceList
;
436 TRACE("Subsequent application instance - starting checks\n");
437 while (reference_inst
->next
!= NULL
)
440 * This set of tests will work if application uses same instance Id
441 * at application level once allocated - which is what manual implies
442 * should happen. If someone tries to be
443 * clever (lazy ?) it will fail to pick up that later calls are for
444 * the same application - should we trust them ?
446 if (pInstance
->instanceID
== reference_inst
->instanceID
)
448 /* Check 1 - must be same Client-only state */
450 if (pInstance
->clientOnly
!= reference_inst
->clientOnly
)
452 ret
= DMLERR_DLL_USAGE
;
456 /* Check 2 - cannot use 'Monitor' with any non-monitor modes */
458 if (pInstance
->monitor
!= reference_inst
->monitor
)
460 ret
= DMLERR_INVALIDPARAMETER
;
464 /* Check 3 - must supply different callback address */
466 if (pInstance
->callback
== reference_inst
->callback
)
468 ret
= DMLERR_DLL_USAGE
;
472 reference_inst
= reference_inst
->next
;
474 /* All cleared, add to chain */
476 TRACE("Application Instance checks finished\n");
477 WDML_IncrementInstanceId(pInstance
);
478 reference_inst
->next
= pInstance
;
480 LeaveCriticalSection(&WDML_CritSect
);
482 *pidInst
= pInstance
->instanceID
;
484 /* for deadlock issues, windows must always be created when outside the critical section */
485 wndclass
.cbSize
= sizeof(wndclass
);
487 wndclass
.lpfnWndProc
= WDML_EventProc
;
488 wndclass
.cbClsExtra
= 0;
489 wndclass
.cbWndExtra
= sizeof(ULONG_PTR
);
490 wndclass
.hInstance
= 0;
492 wndclass
.hCursor
= 0;
493 wndclass
.hbrBackground
= 0;
494 wndclass
.lpszMenuName
= NULL
;
495 wndclass
.lpszClassName
= WDML_szEventClass
;
496 wndclass
.hIconSm
= 0;
498 RegisterClassExW(&wndclass
);
500 pInstance
->hwndEvent
= CreateWindowW(WDML_szEventClass
, NULL
,
501 WS_POPUP
, 0, 0, 0, 0,
504 SetWindowLongPtrW(pInstance
->hwndEvent
, GWL_WDML_INSTANCE
, (ULONG_PTR
)pInstance
);
506 TRACE("New application instance processing finished OK\n");
510 /* Reinitialisation situation --- FIX */
511 TRACE("reinitialisation of (%p,%p,0x%x,%d): stub\n", pidInst
, pfnCallback
, afCmd
, ulRes
);
513 EnterCriticalSection(&WDML_CritSect
);
515 if (WDML_InstanceList
== NULL
)
517 ret
= DMLERR_INVALIDPARAMETER
;
520 HeapFree(GetProcessHeap(), 0, pInstance
); /* finished - release heap space used as work store */
521 /* can't reinitialise if we have initialised nothing !! */
522 reference_inst
= WDML_InstanceList
;
523 /* must first check if we have been given a valid instance to re-initialise !! how do we do that ? */
525 * MS allows initialisation without specifying a callback, should we allow addition of the
526 * callback by a later call to initialise ? - if so this lot will have to change
528 while (reference_inst
->next
!= NULL
)
530 if (*pidInst
== reference_inst
->instanceID
&& pfnCallback
== reference_inst
->callback
)
532 /* Check 1 - cannot change client-only mode if set via APPCMD_CLIENTONLY */
534 if (reference_inst
->clientOnly
)
536 if ((reference_inst
->CBFflags
& CBF_FAIL_ALLSVRXACTIONS
) != CBF_FAIL_ALLSVRXACTIONS
)
538 /* i.e. Was set to Client-only and through APPCMD_CLIENTONLY */
540 if (!(afCmd
& APPCMD_CLIENTONLY
))
542 ret
= DMLERR_INVALIDPARAMETER
;
547 /* Check 2 - cannot change monitor modes */
549 if (pInstance
->monitor
!= reference_inst
->monitor
)
551 ret
= DMLERR_INVALIDPARAMETER
;
555 /* Check 3 - trying to set Client-only via APPCMD when not set so previously */
557 if ((afCmd
&APPCMD_CLIENTONLY
) && !reference_inst
->clientOnly
)
559 ret
= DMLERR_INVALIDPARAMETER
;
564 reference_inst
= reference_inst
->next
;
566 if (reference_inst
->next
== NULL
)
568 ret
= DMLERR_INVALIDPARAMETER
;
571 /* All checked - change relevant flags */
573 reference_inst
->CBFflags
= pInstance
->CBFflags
;
574 reference_inst
->clientOnly
= pInstance
->clientOnly
;
575 reference_inst
->monitorFlags
= pInstance
->monitorFlags
;
576 LeaveCriticalSection(&WDML_CritSect
);
579 return DMLERR_NO_ERROR
;
581 HeapFree(GetProcessHeap(), 0, pInstance
);
582 LeaveCriticalSection(&WDML_CritSect
);
586 /******************************************************************************
587 * DdeInitializeA (USER32.@)
589 * See DdeInitializeW.
591 UINT WINAPI
DdeInitializeA(LPDWORD pidInst
, PFNCALLBACK pfnCallback
,
592 DWORD afCmd
, DWORD ulRes
)
594 return WDML_Initialize(pidInst
, pfnCallback
, afCmd
, ulRes
, FALSE
, FALSE
);
597 /******************************************************************************
598 * DdeInitializeW [USER32.@]
599 * Registers an application with the DDEML
602 * pidInst [I] Pointer to instance identifier
603 * pfnCallback [I] Pointer to callback function
604 * afCmd [I] Set of command and filter flags
608 * Success: DMLERR_NO_ERROR
609 * Failure: DMLERR_DLL_USAGE, DMLERR_INVALIDPARAMETER, DMLERR_SYS_ERROR
611 UINT WINAPI
DdeInitializeW(LPDWORD pidInst
, PFNCALLBACK pfnCallback
,
612 DWORD afCmd
, DWORD ulRes
)
614 return WDML_Initialize(pidInst
, pfnCallback
, afCmd
, ulRes
, TRUE
, FALSE
);
617 /*****************************************************************
618 * DdeUninitialize [USER32.@] Frees DDEML resources
621 * idInst [I] Instance identifier
628 BOOL WINAPI
DdeUninitialize(DWORD idInst
)
630 /* Stage one - check if we have a handle for this instance
632 WDML_INSTANCE
* pInstance
;
634 WDML_CONV
* pConvNext
;
636 TRACE("(%d)\n", idInst
);
638 /* First check instance
640 pInstance
= WDML_GetInstance(idInst
);
641 if (pInstance
== NULL
)
644 * Needs something here to record NOT_INITIALIZED ready for DdeGetLastError
649 /* first terminate all conversations client side
650 * this shall close existing links...
652 for (pConv
= pInstance
->convs
[WDML_CLIENT_SIDE
]; pConv
!= NULL
; pConv
= pConvNext
)
654 pConvNext
= pConv
->next
;
655 DdeDisconnect((HCONV
)pConv
);
657 if (pInstance
->convs
[WDML_CLIENT_SIDE
])
658 FIXME("still pending conversations\n");
660 /* then unregister all known service names */
661 DdeNameService(idInst
, 0, 0, DNS_UNREGISTER
);
663 /* Free the nodes that were not freed by this instance
664 * and remove the nodes from the list of HSZ nodes.
666 WDML_FreeAllHSZ(pInstance
);
668 DestroyWindow(pInstance
->hwndEvent
);
670 /* OK now delete the instance handle itself */
672 if (WDML_InstanceList
== pInstance
)
674 /* special case - the first/only entry */
675 WDML_InstanceList
= pInstance
->next
;
679 /* general case, remove entry */
682 for (inst
= WDML_InstanceList
; inst
->next
!= pInstance
; inst
= inst
->next
);
683 inst
->next
= pInstance
->next
;
685 /* release the heap entry
687 HeapFree(GetProcessHeap(), 0, pInstance
);
692 /******************************************************************
693 * WDML_NotifyThreadExit
697 void WDML_NotifyThreadDetach(void)
699 WDML_INSTANCE
* pInstance
;
701 DWORD tid
= GetCurrentThreadId();
703 EnterCriticalSection(&WDML_CritSect
);
704 for (pInstance
= WDML_InstanceList
; pInstance
!= NULL
; pInstance
= next
)
706 next
= pInstance
->next
;
707 if (pInstance
->threadID
== tid
)
709 LeaveCriticalSection(&WDML_CritSect
);
710 DdeUninitialize(pInstance
->instanceID
);
711 EnterCriticalSection(&WDML_CritSect
);
714 LeaveCriticalSection(&WDML_CritSect
);
717 /******************************************************************
718 * WDML_InvokeCallback
722 HDDEDATA
WDML_InvokeCallback(WDML_INSTANCE
* pInstance
, UINT uType
, UINT uFmt
, HCONV hConv
,
723 HSZ hsz1
, HSZ hsz2
, HDDEDATA hdata
,
724 ULONG_PTR dwData1
, ULONG_PTR dwData2
)
728 if (pInstance
== NULL
)
731 TRACE("invoking CB%d[%p] (%x %x %p %p %p %p %lx %lx)\n",
732 pInstance
->win16
? 16 : 32, pInstance
->callback
, uType
, uFmt
,
733 hConv
, hsz1
, hsz2
, hdata
, dwData1
, dwData2
);
734 if (pInstance
->win16
)
736 ret
= WDML_InvokeCallback16(pInstance
->callback
, uType
, uFmt
, hConv
,
737 hsz1
, hsz2
, hdata
, dwData1
, dwData2
);
741 ret
= pInstance
->callback(uType
, uFmt
, hConv
, hsz1
, hsz2
, hdata
, dwData1
, dwData2
);
743 TRACE("done => %p\n", ret
);
747 /*****************************************************************************
750 * generic routine to return a pointer to the relevant DDE_HANDLE_ENTRY
751 * for an instance Id, or NULL if the entry does not exist
754 WDML_INSTANCE
* WDML_GetInstance(DWORD instId
)
756 WDML_INSTANCE
* pInstance
;
758 EnterCriticalSection(&WDML_CritSect
);
760 for (pInstance
= WDML_InstanceList
; pInstance
!= NULL
; pInstance
= pInstance
->next
)
762 if (pInstance
->instanceID
== instId
)
764 if (GetCurrentThreadId() != pInstance
->threadID
)
766 FIXME("Tried to get instance from wrong thread\n");
773 LeaveCriticalSection(&WDML_CritSect
);
776 WARN("Instance entry missing for id %04x\n", instId
);
780 /******************************************************************
781 * WDML_GetInstanceFromWnd
785 WDML_INSTANCE
* WDML_GetInstanceFromWnd(HWND hWnd
)
787 return (WDML_INSTANCE
*)GetWindowLongPtrW(hWnd
, GWL_WDML_INSTANCE
);
790 /******************************************************************************
791 * DdeGetLastError [USER32.@] Gets most recent error code
794 * idInst [I] Instance identifier
799 UINT WINAPI
DdeGetLastError(DWORD idInst
)
802 WDML_INSTANCE
* pInstance
;
804 /* First check instance
806 pInstance
= WDML_GetInstance(idInst
);
807 if (pInstance
== NULL
)
809 error_code
= DMLERR_INVALIDPARAMETER
;
813 error_code
= pInstance
->lastError
;
814 pInstance
->lastError
= 0;
820 /* ================================================================
824 * ================================================================ */
827 /******************************************************************
832 static HSZNode
* WDML_FindNode(WDML_INSTANCE
* pInstance
, HSZ hsz
)
836 if (pInstance
== NULL
) return NULL
;
838 for (pNode
= pInstance
->nodeList
; pNode
!= NULL
; pNode
= pNode
->next
)
840 if (pNode
->hsz
== hsz
) break;
842 if (!pNode
) WARN("HSZ %p not found\n", hsz
);
846 /******************************************************************
847 * WDML_MakeAtomFromHsz
849 * Creates a global atom from an existing HSZ
850 * Generally used before sending an HSZ as an atom to a remote app
852 ATOM
WDML_MakeAtomFromHsz(HSZ hsz
)
854 WCHAR nameBuffer
[MAX_BUFFER_LEN
];
856 if (GetAtomNameW(HSZ2ATOM(hsz
), nameBuffer
, MAX_BUFFER_LEN
))
857 return GlobalAddAtomW(nameBuffer
);
858 WARN("HSZ %p not found\n", hsz
);
862 /******************************************************************
863 * WDML_MakeHszFromAtom
865 * Creates a HSZ from an existing global atom
866 * Generally used while receiving a global atom and transforming it
869 HSZ
WDML_MakeHszFromAtom(WDML_INSTANCE
* pInstance
, ATOM atom
)
871 WCHAR nameBuffer
[MAX_BUFFER_LEN
];
873 if (!atom
) return NULL
;
875 if (GlobalGetAtomNameW(atom
, nameBuffer
, MAX_BUFFER_LEN
))
877 TRACE("%x => %s\n", atom
, debugstr_w(nameBuffer
));
878 return DdeCreateStringHandleW(pInstance
->instanceID
, nameBuffer
, CP_WINUNICODE
);
880 WARN("ATOM 0x%x not found\n", atom
);
884 /******************************************************************
889 BOOL
WDML_IncHSZ(WDML_INSTANCE
* pInstance
, HSZ hsz
)
893 pNode
= WDML_FindNode(pInstance
, hsz
);
894 if (!pNode
) return FALSE
;
900 /******************************************************************************
901 * WDML_DecHSZ (INTERNAL)
903 * Decrease the ref count of an HSZ. If it reaches 0, the node is removed from the list
905 * Returns -1 is the HSZ isn't found, otherwise it's the current (after --) of the ref count
907 BOOL
WDML_DecHSZ(WDML_INSTANCE
* pInstance
, HSZ hsz
)
909 HSZNode
* pPrev
= NULL
;
912 for (pCurrent
= pInstance
->nodeList
; pCurrent
!= NULL
; pCurrent
= (pPrev
= pCurrent
)->next
)
914 /* If we found the node we were looking for and its ref count is one,
917 if (pCurrent
->hsz
== hsz
)
919 if (--pCurrent
->refCount
== 0)
921 if (pCurrent
== pInstance
->nodeList
)
923 pInstance
->nodeList
= pCurrent
->next
;
927 pPrev
->next
= pCurrent
->next
;
929 HeapFree(GetProcessHeap(), 0, pCurrent
);
930 DeleteAtom(HSZ2ATOM(hsz
));
935 WARN("HSZ %p not found\n", hsz
);
940 /******************************************************************************
941 * WDML_FreeAllHSZ (INTERNAL)
943 * Frees up all the strings still allocated in the list and
944 * remove all the nodes from the list of HSZ nodes.
946 void WDML_FreeAllHSZ(WDML_INSTANCE
* pInstance
)
948 /* Free any strings created in this instance.
950 while (pInstance
->nodeList
!= NULL
)
952 DdeFreeStringHandle(pInstance
->instanceID
, pInstance
->nodeList
->hsz
);
956 /******************************************************************************
957 * InsertHSZNode (INTERNAL)
959 * Insert a node to the head of the list.
961 static void WDML_InsertHSZNode(WDML_INSTANCE
* pInstance
, HSZ hsz
)
965 HSZNode
* pNew
= NULL
;
966 /* Create a new node for this HSZ.
968 pNew
= HeapAlloc(GetProcessHeap(), 0, sizeof(HSZNode
));
972 pNew
->next
= pInstance
->nodeList
;
974 pInstance
->nodeList
= pNew
;
978 ERR("Primary HSZ Node allocation failed - out of memory\n");
983 /******************************************************************
988 static int WDML_QueryString(WDML_INSTANCE
* pInstance
, HSZ hsz
, LPVOID ptr
, DWORD cchMax
,
991 WCHAR pString
[MAX_BUFFER_LEN
];
993 /* If psz is null, we have to return only the length
999 cchMax
= MAX_BUFFER_LEN
;
1005 ret
= GetAtomNameA(HSZ2ATOM(hsz
), ptr
, cchMax
);
1008 ret
= GetAtomNameW(HSZ2ATOM(hsz
), ptr
, cchMax
);
1011 ERR("Unknown code page %d\n", codepage
);
1017 /*****************************************************************
1018 * DdeQueryStringA [USER32.@]
1020 DWORD WINAPI
DdeQueryStringA(DWORD idInst
, HSZ hsz
, LPSTR psz
, DWORD cchMax
, INT iCodePage
)
1023 WDML_INSTANCE
* pInstance
;
1025 TRACE("(%d, %p, %p, %d, %d)\n", idInst
, hsz
, psz
, cchMax
, iCodePage
);
1027 /* First check instance
1029 pInstance
= WDML_GetInstance(idInst
);
1030 if (pInstance
!= NULL
)
1032 if (iCodePage
== 0) iCodePage
= CP_WINANSI
;
1033 ret
= WDML_QueryString(pInstance
, hsz
, psz
, cchMax
, iCodePage
);
1036 TRACE("returning %d (%s)\n", ret
, debugstr_a(psz
));
1040 /*****************************************************************
1041 * DdeQueryStringW [USER32.@]
1044 DWORD WINAPI
DdeQueryStringW(DWORD idInst
, HSZ hsz
, LPWSTR psz
, DWORD cchMax
, INT iCodePage
)
1047 WDML_INSTANCE
* pInstance
;
1049 TRACE("(%d, %p, %p, %d, %d)\n", idInst
, hsz
, psz
, cchMax
, iCodePage
);
1051 /* First check instance
1053 pInstance
= WDML_GetInstance(idInst
);
1054 if (pInstance
!= NULL
)
1056 if (iCodePage
== 0) iCodePage
= CP_WINUNICODE
;
1057 ret
= WDML_QueryString(pInstance
, hsz
, psz
, cchMax
, iCodePage
);
1060 TRACE("returning %d (%s)\n", ret
, debugstr_w(psz
));
1064 /******************************************************************
1069 static HSZ
WDML_CreateString(WDML_INSTANCE
* pInstance
, LPCVOID ptr
, int codepage
)
1076 hsz
= ATOM2HSZ(AddAtomA(ptr
));
1077 TRACE("added atom %s with HSZ %p,\n", debugstr_a(ptr
), hsz
);
1080 hsz
= ATOM2HSZ(AddAtomW(ptr
));
1081 TRACE("added atom %s with HSZ %p,\n", debugstr_w(ptr
), hsz
);
1084 ERR("Unknown code page %d\n", codepage
);
1087 WDML_InsertHSZNode(pInstance
, hsz
);
1091 /*****************************************************************
1092 * DdeCreateStringHandleA [USER32.@]
1094 * See DdeCreateStringHandleW.
1096 HSZ WINAPI
DdeCreateStringHandleA(DWORD idInst
, LPCSTR psz
, INT codepage
)
1099 WDML_INSTANCE
* pInstance
;
1101 TRACE("(%d,%s,%d)\n", idInst
, debugstr_a(psz
), codepage
);
1103 pInstance
= WDML_GetInstance(idInst
);
1106 if (codepage
== 0) codepage
= CP_WINANSI
;
1107 hsz
= WDML_CreateString(pInstance
, psz
, codepage
);
1114 /******************************************************************************
1115 * DdeCreateStringHandleW [USER32.@] Creates handle to identify string
1118 * idInst [I] Instance identifier
1119 * psz [I] Pointer to string
1120 * codepage [I] Code page identifier
1122 * Success: String handle
1125 HSZ WINAPI
DdeCreateStringHandleW(DWORD idInst
, LPCWSTR psz
, INT codepage
)
1127 WDML_INSTANCE
* pInstance
;
1130 TRACE("(%d,%s,%d)\n", idInst
, debugstr_w(psz
), codepage
);
1132 pInstance
= WDML_GetInstance(idInst
);
1135 if (codepage
== 0) codepage
= CP_WINUNICODE
;
1136 hsz
= WDML_CreateString(pInstance
, psz
, codepage
);
1142 /*****************************************************************
1143 * DdeFreeStringHandle (USER32.@)
1148 BOOL WINAPI
DdeFreeStringHandle(DWORD idInst
, HSZ hsz
)
1150 WDML_INSTANCE
* pInstance
;
1153 TRACE("(%d,%p):\n", idInst
, hsz
);
1155 /* First check instance
1157 pInstance
= WDML_GetInstance(idInst
);
1159 ret
= WDML_DecHSZ(pInstance
, hsz
);
1164 /*****************************************************************
1165 * DdeKeepStringHandle (USER32.@)
1171 BOOL WINAPI
DdeKeepStringHandle(DWORD idInst
, HSZ hsz
)
1173 WDML_INSTANCE
* pInstance
;
1176 TRACE("(%d,%p):\n", idInst
, hsz
);
1178 /* First check instance
1180 pInstance
= WDML_GetInstance(idInst
);
1182 ret
= WDML_IncHSZ(pInstance
, hsz
);
1187 /*****************************************************************
1188 * DdeCmpStringHandles (USER32.@)
1190 * Compares the value of two string handles. This comparison is
1191 * not case sensitive.
1194 * hsz1 [I] Handle to the first string
1195 * hsz2 [I] Handle to the second string
1198 * -1 The value of hsz1 is zero or less than hsz2
1199 * 0 The values of hsz 1 and 2 are the same or both zero.
1200 * 1 The value of hsz2 is zero of less than hsz1
1202 INT WINAPI
DdeCmpStringHandles(HSZ hsz1
, HSZ hsz2
)
1204 WCHAR psz1
[MAX_BUFFER_LEN
];
1205 WCHAR psz2
[MAX_BUFFER_LEN
];
1209 ret1
= GetAtomNameW(HSZ2ATOM(hsz1
), psz1
, MAX_BUFFER_LEN
);
1210 ret2
= GetAtomNameW(HSZ2ATOM(hsz2
), psz2
, MAX_BUFFER_LEN
);
1212 TRACE("(%p<%s> %p<%s>);\n", hsz1
, debugstr_w(psz1
), hsz2
, debugstr_w(psz2
));
1214 /* Make sure we found both strings. */
1215 if (ret1
== 0 && ret2
== 0)
1217 /* If both are not found, return both "zero strings". */
1222 /* If hsz1 is a not found, return hsz1 is "zero string". */
1227 /* If hsz2 is a not found, return hsz2 is "zero string". */
1232 /* Compare the two strings we got (case insensitive). */
1233 ret
= lstrcmpiW(psz1
, psz2
);
1234 /* Since strcmp returns any number smaller than
1235 * 0 when the first string is found to be less than
1236 * the second one we must make sure we are returning
1237 * the proper values.
1252 /* ================================================================
1254 * Data handle management
1256 * ================================================================ */
1258 /*****************************************************************
1259 * DdeCreateDataHandle (USER32.@)
1261 HDDEDATA WINAPI
DdeCreateDataHandle(DWORD idInst
, LPBYTE pSrc
, DWORD cb
, DWORD cbOff
,
1262 HSZ hszItem
, UINT wFmt
, UINT afCmd
)
1264 /* For now, we ignore idInst, hszItem.
1265 * The purpose of these arguments still need to be investigated.
1270 DDE_DATAHANDLE_HEAD
* pDdh
;
1271 WCHAR psz
[MAX_BUFFER_LEN
];
1273 if (!GetAtomNameW(HSZ2ATOM(hszItem
), psz
, MAX_BUFFER_LEN
))
1275 psz
[0] = HSZ2ATOM(hszItem
);
1279 TRACE("(%d,%p,cb %d, cbOff %d,%p <%s>,fmt %04x,%x)\n",
1280 idInst
, pSrc
, cb
, cbOff
, hszItem
, debugstr_w(psz
), wFmt
, afCmd
);
1282 if (afCmd
!= 0 && afCmd
!= HDATA_APPOWNED
)
1285 /* we use the first 4 bytes to store the size */
1286 if (!(hMem
= GlobalAlloc(GMEM_MOVEABLE
| GMEM_DDESHARE
, cb
+ cbOff
+ sizeof(DDE_DATAHANDLE_HEAD
))))
1288 ERR("GlobalAlloc failed\n");
1292 pDdh
= (DDE_DATAHANDLE_HEAD
*)GlobalLock(hMem
);
1299 pDdh
->cfFormat
= wFmt
;
1300 pDdh
->bAppOwned
= (afCmd
== HDATA_APPOWNED
);
1302 pByte
= (LPBYTE
)(pDdh
+ 1);
1305 memcpy(pByte
, pSrc
+ cbOff
, cb
);
1309 TRACE("=> %p\n", hMem
);
1310 return (HDDEDATA
)hMem
;
1313 /*****************************************************************
1315 * DdeAddData (USER32.@)
1317 HDDEDATA WINAPI
DdeAddData(HDDEDATA hData
, LPBYTE pSrc
, DWORD cb
, DWORD cbOff
)
1319 DWORD old_sz
, new_sz
;
1322 TRACE("(%p,%p,cb %d, cbOff %d)\n", hData
, pSrc
, cb
, cbOff
);
1324 pDst
= DdeAccessData(hData
, &old_sz
);
1325 if (!pDst
) return 0;
1327 new_sz
= cb
+ cbOff
;
1328 if (new_sz
> old_sz
)
1330 DdeUnaccessData(hData
);
1331 hData
= GlobalReAlloc((HGLOBAL
)hData
, new_sz
+ sizeof(DDE_DATAHANDLE_HEAD
),
1332 GMEM_MOVEABLE
| GMEM_DDESHARE
);
1333 pDst
= DdeAccessData(hData
, &old_sz
);
1336 if (!pDst
) return 0;
1338 memcpy(pDst
+ cbOff
, pSrc
, cb
);
1339 DdeUnaccessData(hData
);
1343 /******************************************************************************
1344 * DdeGetData [USER32.@] Copies data from DDE object to local buffer
1348 * hData [I] Handle to DDE object
1349 * pDst [I] Pointer to destination buffer
1350 * cbMax [I] Amount of data to copy
1351 * cbOff [I] Offset to beginning of data
1354 * Size of memory object associated with handle
1356 DWORD WINAPI
DdeGetData(HDDEDATA hData
, LPBYTE pDst
, DWORD cbMax
, DWORD cbOff
)
1358 DWORD dwSize
, dwRet
;
1361 TRACE("(%p,%p,%d,%d)\n", hData
, pDst
, cbMax
, cbOff
);
1363 pByte
= DdeAccessData(hData
, &dwSize
);
1371 else if (cbOff
+ cbMax
< dwSize
)
1375 else if (cbOff
< dwSize
)
1377 dwRet
= dwSize
- cbOff
;
1383 if (pDst
&& dwRet
!= 0)
1385 memcpy(pDst
, pByte
+ cbOff
, dwRet
);
1387 DdeUnaccessData(hData
);
1396 /*****************************************************************
1397 * DdeAccessData (USER32.@)
1399 LPBYTE WINAPI
DdeAccessData(HDDEDATA hData
, LPDWORD pcbDataSize
)
1401 HGLOBAL hMem
= (HGLOBAL
)hData
;
1402 DDE_DATAHANDLE_HEAD
* pDdh
;
1404 TRACE("(%p,%p)\n", hData
, pcbDataSize
);
1406 pDdh
= (DDE_DATAHANDLE_HEAD
*)GlobalLock(hMem
);
1409 ERR("Failed on GlobalLock(%p)\n", hMem
);
1413 if (pcbDataSize
!= NULL
)
1415 *pcbDataSize
= GlobalSize(hMem
) - sizeof(DDE_DATAHANDLE_HEAD
);
1417 TRACE("=> %p (%lu) fmt %04x\n", pDdh
+ 1, GlobalSize(hMem
) - sizeof(DDE_DATAHANDLE_HEAD
), pDdh
->cfFormat
);
1418 return (LPBYTE
)(pDdh
+ 1);
1421 /*****************************************************************
1422 * DdeUnaccessData (USER32.@)
1424 BOOL WINAPI
DdeUnaccessData(HDDEDATA hData
)
1426 HGLOBAL hMem
= (HGLOBAL
)hData
;
1428 TRACE("(%p)\n", hData
);
1435 /*****************************************************************
1436 * DdeFreeDataHandle (USER32.@)
1438 BOOL WINAPI
DdeFreeDataHandle(HDDEDATA hData
)
1440 TRACE("(%p)\n", hData
);
1441 return GlobalFree((HGLOBAL
)hData
) == 0;
1444 /******************************************************************
1449 BOOL
WDML_IsAppOwned(HDDEDATA hData
)
1451 DDE_DATAHANDLE_HEAD
* pDdh
;
1454 pDdh
= (DDE_DATAHANDLE_HEAD
*)GlobalLock((HGLOBAL
)hData
);
1457 ret
= pDdh
->bAppOwned
;
1458 GlobalUnlock((HGLOBAL
)hData
);
1463 /* ================================================================
1465 * Global <=> Data handle management
1467 * ================================================================ */
1469 /* Note: we use a DDEDATA, but layout of DDEDATA, DDEADVISE and DDEPOKE structures is similar:
1471 * (bytes) (bits) comment
1472 * 0 16 bit fields for options (release, ackreq, response...)
1473 * 2 16 clipboard format
1474 * 4 ? data to be used
1476 HDDEDATA
WDML_Global2DataHandle(HGLOBAL hMem
, WINE_DDEHEAD
* p
)
1484 pDd
= GlobalLock(hMem
);
1485 size
= GlobalSize(hMem
) - sizeof(WINE_DDEHEAD
);
1488 if (p
) memcpy(p
, pDd
, sizeof(WINE_DDEHEAD
));
1489 switch (pDd
->cfFormat
)
1492 FIXME("Unsupported format (%04x) for data %p, passing raw information\n",
1493 pDd
->cfFormat
, hMem
);
1497 ret
= DdeCreateDataHandle(0, pDd
->Value
, size
, 0, 0, pDd
->cfFormat
, 0);
1500 if (size
>= sizeof(BITMAP
))
1502 BITMAP
* bmp
= (BITMAP
*)pDd
->Value
;
1503 int count
= bmp
->bmWidthBytes
* bmp
->bmHeight
* bmp
->bmPlanes
;
1504 if (size
>= sizeof(BITMAP
) + count
)
1508 if ((hbmp
= CreateBitmap(bmp
->bmWidth
, bmp
->bmHeight
,
1509 bmp
->bmPlanes
, bmp
->bmBitsPixel
,
1510 pDd
->Value
+ sizeof(BITMAP
))))
1512 ret
= DdeCreateDataHandle(0, (LPBYTE
)&hbmp
, sizeof(hbmp
),
1513 0, 0, CF_BITMAP
, 0);
1515 else ERR("Can't create bmp\n");
1519 ERR("Wrong count: %u / %d\n", size
, count
);
1521 } else ERR("No bitmap header\n");
1530 /******************************************************************
1531 * WDML_DataHandle2Global
1535 HGLOBAL
WDML_DataHandle2Global(HDDEDATA hDdeData
, BOOL fResponse
, BOOL fRelease
,
1536 BOOL fDeferUpd
, BOOL fAckReq
)
1538 DDE_DATAHANDLE_HEAD
* pDdh
;
1542 dwSize
= GlobalSize((HGLOBAL
)hDdeData
) - sizeof(DDE_DATAHANDLE_HEAD
);
1543 pDdh
= (DDE_DATAHANDLE_HEAD
*)GlobalLock((HGLOBAL
)hDdeData
);
1546 WINE_DDEHEAD
* wdh
= NULL
;
1548 switch (pDdh
->cfFormat
)
1551 FIXME("Unsupported format (%04x) for data %p, passing raw information\n",
1552 pDdh
->cfFormat
, hDdeData
);
1556 hMem
= GlobalAlloc(GMEM_MOVEABLE
| GMEM_DDESHARE
, sizeof(WINE_DDEHEAD
) + dwSize
);
1557 if (hMem
&& (wdh
= GlobalLock(hMem
)))
1559 memcpy(wdh
+ 1, pDdh
+ 1, dwSize
);
1563 if (dwSize
>= sizeof(HBITMAP
))
1567 HBITMAP hbmp
= *(HBITMAP
*)(pDdh
+ 1);
1569 if (GetObjectW(hbmp
, sizeof(bmp
), &bmp
))
1571 count
= bmp
.bmWidthBytes
* bmp
.bmHeight
;
1572 hMem
= GlobalAlloc(GMEM_MOVEABLE
| GMEM_DDESHARE
,
1573 sizeof(WINE_DDEHEAD
) + sizeof(bmp
) + count
);
1574 if (hMem
&& (wdh
= GlobalLock(hMem
)))
1576 memcpy(wdh
+ 1, &bmp
, sizeof(bmp
));
1577 GetBitmapBits(hbmp
, count
, ((char*)(wdh
+ 1)) + sizeof(bmp
));
1586 wdh
->fResponse
= fResponse
;
1587 wdh
->fRelease
= fRelease
;
1588 wdh
->fDeferUpd
= fDeferUpd
;
1589 wdh
->fAckReq
= fAckReq
;
1590 wdh
->cfFormat
= pDdh
->cfFormat
;
1593 GlobalUnlock((HGLOBAL
)hDdeData
);
1599 /* ================================================================
1603 * ================================================================ */
1605 /******************************************************************
1610 WDML_SERVER
* WDML_AddServer(WDML_INSTANCE
* pInstance
, HSZ hszService
, HSZ hszTopic
)
1612 static const WCHAR fmtW
[] = {'%','s','(','0','x','%','0','8','l','x',')',0};
1613 WDML_SERVER
* pServer
;
1617 pServer
= HeapAlloc(GetProcessHeap(), 0, sizeof(WDML_SERVER
));
1618 if (pServer
== NULL
) return NULL
;
1620 pServer
->hszService
= hszService
;
1621 WDML_IncHSZ(pInstance
, hszService
);
1623 DdeQueryStringW(pInstance
->instanceID
, hszService
, buf1
, 256, CP_WINUNICODE
);
1624 snprintfW(buf2
, 256, fmtW
, buf1
, GetCurrentProcessId());
1625 pServer
->hszServiceSpec
= DdeCreateStringHandleW(pInstance
->instanceID
, buf2
, CP_WINUNICODE
);
1627 pServer
->atomService
= WDML_MakeAtomFromHsz(pServer
->hszService
);
1628 pServer
->atomServiceSpec
= WDML_MakeAtomFromHsz(pServer
->hszServiceSpec
);
1630 pServer
->filterOn
= TRUE
;
1632 pServer
->next
= pInstance
->servers
;
1633 pInstance
->servers
= pServer
;
1637 /******************************************************************
1642 void WDML_RemoveServer(WDML_INSTANCE
* pInstance
, HSZ hszService
, HSZ hszTopic
)
1644 WDML_SERVER
* pPrev
= NULL
;
1645 WDML_SERVER
* pServer
= NULL
;
1647 WDML_CONV
* pConvNext
;
1649 pServer
= pInstance
->servers
;
1651 while (pServer
!= NULL
)
1653 if (DdeCmpStringHandles(pServer
->hszService
, hszService
) == 0)
1655 WDML_BroadcastDDEWindows(WDML_szEventClass
, WM_WDML_UNREGISTER
,
1656 pServer
->atomService
, pServer
->atomServiceSpec
);
1657 /* terminate all conversations for given topic */
1658 for (pConv
= pInstance
->convs
[WDML_SERVER_SIDE
]; pConv
!= NULL
; pConv
= pConvNext
)
1660 pConvNext
= pConv
->next
;
1661 if (DdeCmpStringHandles(pConv
->hszService
, hszService
) == 0)
1663 WDML_RemoveConv(pConv
, WDML_SERVER_SIDE
);
1664 /* don't care about return code (whether client window is present or not) */
1665 PostMessageW(pConv
->hwndClient
, WM_DDE_TERMINATE
, (WPARAM
)pConv
->hwndServer
, 0);
1668 if (pServer
== pInstance
->servers
)
1670 pInstance
->servers
= pServer
->next
;
1674 pPrev
->next
= pServer
->next
;
1677 DestroyWindow(pServer
->hwndServer
);
1678 WDML_DecHSZ(pInstance
, pServer
->hszServiceSpec
);
1679 WDML_DecHSZ(pInstance
, pServer
->hszService
);
1681 GlobalDeleteAtom(pServer
->atomService
);
1682 GlobalDeleteAtom(pServer
->atomServiceSpec
);
1684 HeapFree(GetProcessHeap(), 0, pServer
);
1689 pServer
= pServer
->next
;
1693 /*****************************************************************************
1696 * generic routine to return a pointer to the relevant ServiceNode
1697 * for a given service name, or NULL if the entry does not exist
1700 WDML_SERVER
* WDML_FindServer(WDML_INSTANCE
* pInstance
, HSZ hszService
, HSZ hszTopic
)
1702 WDML_SERVER
* pServer
;
1704 for (pServer
= pInstance
->servers
; pServer
!= NULL
; pServer
= pServer
->next
)
1706 if (hszService
== pServer
->hszService
)
1711 TRACE("Service name missing\n");
1715 /* ================================================================
1717 * Conversation management
1719 * ================================================================ */
1721 /******************************************************************
1726 WDML_CONV
* WDML_AddConv(WDML_INSTANCE
* pInstance
, WDML_SIDE side
,
1727 HSZ hszService
, HSZ hszTopic
, HWND hwndClient
, HWND hwndServer
)
1731 /* no converstation yet, add it */
1732 pConv
= HeapAlloc(GetProcessHeap(), 0, sizeof(WDML_CONV
));
1733 if (!pConv
) return NULL
;
1735 pConv
->instance
= pInstance
;
1736 WDML_IncHSZ(pInstance
, pConv
->hszService
= hszService
);
1737 WDML_IncHSZ(pInstance
, pConv
->hszTopic
= hszTopic
);
1738 pConv
->magic
= WDML_CONV_MAGIC
;
1739 pConv
->hwndServer
= hwndServer
;
1740 pConv
->hwndClient
= hwndClient
;
1741 pConv
->transactions
= NULL
;
1743 pConv
->wStatus
= (side
== WDML_CLIENT_SIDE
) ? ST_CLIENT
: 0L;
1744 pConv
->wStatus
|= pInstance
->wStatus
;
1745 /* check if both side of the conversation are of the same instance */
1746 if (GetWindowThreadProcessId(hwndClient
, NULL
) == GetWindowThreadProcessId(hwndServer
, NULL
) &&
1747 WDML_GetInstanceFromWnd(hwndClient
) == WDML_GetInstanceFromWnd(hwndServer
))
1749 pConv
->wStatus
|= ST_ISSELF
;
1751 pConv
->wConvst
= XST_NULL
;
1753 pConv
->next
= pInstance
->convs
[side
];
1754 pInstance
->convs
[side
] = pConv
;
1756 TRACE("pConv->wStatus %04x\n", pConv
->wStatus
);
1761 /******************************************************************
1766 WDML_CONV
* WDML_FindConv(WDML_INSTANCE
* pInstance
, WDML_SIDE side
,
1767 HSZ hszService
, HSZ hszTopic
)
1769 WDML_CONV
* pCurrent
= NULL
;
1771 for (pCurrent
= pInstance
->convs
[side
]; pCurrent
!= NULL
; pCurrent
= pCurrent
->next
)
1773 if (DdeCmpStringHandles(pCurrent
->hszService
, hszService
) == 0 &&
1774 DdeCmpStringHandles(pCurrent
->hszTopic
, hszTopic
) == 0)
1783 /******************************************************************
1788 void WDML_RemoveConv(WDML_CONV
* pRef
, WDML_SIDE side
)
1790 WDML_CONV
* pPrev
= NULL
;
1791 WDML_CONV
* pCurrent
;
1793 WDML_XACT
* pXActNext
;
1799 /* remove any pending transaction */
1800 for (pXAct
= pRef
->transactions
; pXAct
!= NULL
; pXAct
= pXActNext
)
1802 pXActNext
= pXAct
->next
;
1803 WDML_FreeTransaction(pRef
->instance
, pXAct
, TRUE
);
1806 WDML_RemoveAllLinks(pRef
->instance
, pRef
, side
);
1808 /* FIXME: should we keep the window around ? it seems so (at least on client side
1809 * to let QueryConvInfo work after conv termination, but also to implement
1812 /* destroy conversation window, but first remove pConv from hWnd.
1813 * this would help the wndProc do appropriate handling upon a WM_DESTROY message
1815 hWnd
= (side
== WDML_CLIENT_SIDE
) ? pRef
->hwndClient
: pRef
->hwndServer
;
1816 SetWindowLongPtrW(hWnd
, GWL_WDML_CONVERSATION
, 0);
1818 DestroyWindow((side
== WDML_CLIENT_SIDE
) ? pRef
->hwndClient
: pRef
->hwndServer
);
1820 WDML_DecHSZ(pRef
->instance
, pRef
->hszService
);
1821 WDML_DecHSZ(pRef
->instance
, pRef
->hszTopic
);
1823 for (pCurrent
= pRef
->instance
->convs
[side
]; pCurrent
!= NULL
; pCurrent
= (pPrev
= pCurrent
)->next
)
1825 if (pCurrent
== pRef
)
1827 if (pCurrent
== pRef
->instance
->convs
[side
])
1829 pRef
->instance
->convs
[side
] = pCurrent
->next
;
1833 pPrev
->next
= pCurrent
->next
;
1835 pCurrent
->magic
= 0;
1836 HeapFree(GetProcessHeap(), 0, pCurrent
);
1842 /******************************************************************
1843 * WDML_EnableCallback
1845 static BOOL
WDML_EnableCallback(WDML_CONV
*pConv
, UINT wCmd
)
1847 if (wCmd
== EC_DISABLE
)
1849 pConv
->wStatus
|= ST_BLOCKED
;
1850 TRACE("EC_DISABLE: conv %p status flags %04x\n", pConv
, pConv
->wStatus
);
1854 if (wCmd
== EC_QUERYWAITING
)
1855 return pConv
->transactions
? TRUE
: FALSE
;
1857 if (wCmd
!= EC_ENABLEALL
&& wCmd
!= EC_ENABLEONE
)
1859 FIXME("Unknown command code %04x\n", wCmd
);
1863 if (wCmd
== EC_ENABLEALL
)
1865 pConv
->wStatus
&= ~ST_BLOCKED
;
1866 TRACE("EC_ENABLEALL: conv %p status flags %04x\n", pConv
, pConv
->wStatus
);
1869 while (pConv
->transactions
)
1871 WDML_XACT
*pXAct
= pConv
->transactions
;
1873 if (pConv
->wStatus
& ST_CLIENT
)
1875 /* transaction should be in the queue until handled */
1876 WDML_ClientHandle(pConv
, pXAct
, 0, NULL
);
1877 WDML_UnQueueTransaction(pConv
, pXAct
);
1881 /* transaction should be removed from the queue before handling */
1882 WDML_UnQueueTransaction(pConv
, pXAct
);
1883 WDML_ServerHandle(pConv
, pXAct
);
1886 WDML_FreeTransaction(pConv
->instance
, pXAct
, TRUE
);
1888 if (wCmd
== EC_ENABLEONE
) break;
1893 /*****************************************************************
1894 * DdeEnableCallback (USER32.@)
1896 BOOL WINAPI
DdeEnableCallback(DWORD idInst
, HCONV hConv
, UINT wCmd
)
1901 TRACE("(%d, %p, %04x)\n", idInst
, hConv
, wCmd
);
1905 pConv
= WDML_GetConv(hConv
, TRUE
);
1907 if (pConv
&& pConv
->instance
->instanceID
== idInst
)
1908 ret
= WDML_EnableCallback(pConv
, wCmd
);
1912 WDML_INSTANCE
*pInstance
= WDML_GetInstance(idInst
);
1917 TRACE("adding flags %04x to instance %p\n", wCmd
, pInstance
);
1918 pInstance
->wStatus
|= wCmd
;
1920 if (wCmd
== EC_DISABLE
)
1922 pInstance
->wStatus
|= ST_BLOCKED
;
1923 TRACE("EC_DISABLE: inst %p status flags %04x\n", pInstance
, pInstance
->wStatus
);
1925 else if (wCmd
== EC_ENABLEALL
)
1927 pInstance
->wStatus
&= ~ST_BLOCKED
;
1928 TRACE("EC_ENABLEALL: inst %p status flags %04x\n", pInstance
, pInstance
->wStatus
);
1933 for (pConv
= pInstance
->convs
[WDML_CLIENT_SIDE
]; pConv
!= NULL
; pConv
= pConv
->next
)
1935 ret
= WDML_EnableCallback(pConv
, wCmd
);
1936 if (ret
&& wCmd
== EC_QUERYWAITING
) break;
1943 /******************************************************************
1948 WDML_CONV
* WDML_GetConv(HCONV hConv
, BOOL checkConnected
)
1950 WDML_CONV
* pConv
= (WDML_CONV
*)hConv
;
1952 /* FIXME: should do better checking */
1953 if (pConv
== NULL
|| pConv
->magic
!= WDML_CONV_MAGIC
) return NULL
;
1955 if (!pConv
->instance
|| pConv
->instance
->threadID
!= GetCurrentThreadId())
1957 WARN("wrong thread ID\n");
1958 pConv
->instance
->lastError
= DMLERR_INVALIDPARAMETER
; /* FIXME: check */
1962 if (checkConnected
&& !(pConv
->wStatus
& ST_CONNECTED
))
1964 WARN("found conv but ain't connected\n");
1965 pConv
->instance
->lastError
= DMLERR_NO_CONV_ESTABLISHED
;
1972 /******************************************************************
1973 * WDML_GetConvFromWnd
1977 WDML_CONV
* WDML_GetConvFromWnd(HWND hWnd
)
1979 return (WDML_CONV
*)GetWindowLongPtrW(hWnd
, GWL_WDML_CONVERSATION
);
1982 /******************************************************************
1987 BOOL
WDML_PostAck(WDML_CONV
* pConv
, WDML_SIDE side
, WORD appRetCode
,
1988 BOOL fBusy
, BOOL fAck
, UINT pmt
, LPARAM lParam
, UINT oldMsg
)
1993 if (side
== WDML_SERVER_SIDE
)
1995 from
= pConv
->hwndServer
;
1996 to
= pConv
->hwndClient
;
2000 to
= pConv
->hwndServer
;
2001 from
= pConv
->hwndClient
;
2004 ddeAck
.bAppReturnCode
= appRetCode
;
2005 ddeAck
.reserved
= 0;
2006 ddeAck
.fBusy
= fBusy
;
2009 TRACE("Posting a %s ack\n", ddeAck
.fAck
? "positive" : "negative");
2011 lParam
= (lParam
) ? ReuseDDElParam(lParam
, oldMsg
, WM_DDE_ACK
, *(WORD
*)&ddeAck
, pmt
) :
2012 PackDDElParam(WM_DDE_ACK
, *(WORD
*)&ddeAck
, pmt
);
2013 if (!PostMessageW(to
, WM_DDE_ACK
, (WPARAM
)from
, lParam
))
2015 pConv
->wStatus
&= ~ST_CONNECTED
;
2016 pConv
->instance
->lastError
= DMLERR_POSTMSG_FAILED
;
2017 FreeDDElParam(WM_DDE_ACK
, lParam
);
2023 /*****************************************************************
2024 * DdeSetUserHandle (USER32.@)
2026 BOOL WINAPI
DdeSetUserHandle(HCONV hConv
, DWORD id
, DWORD hUser
)
2030 TRACE("(%p,%x,%x)\n", hConv
, id
, hUser
);
2032 pConv
= WDML_GetConv(hConv
, FALSE
);
2038 pConv
->hUser
= hUser
;
2044 pXAct
= WDML_FindTransaction(pConv
, id
);
2047 pXAct
->hUser
= hUser
;
2051 pConv
->instance
->lastError
= DMLERR_UNFOUND_QUEUE_ID
;
2058 /******************************************************************
2059 * WDML_GetLocalConvInfo
2063 static BOOL
WDML_GetLocalConvInfo(WDML_CONV
* pConv
, CONVINFO
* ci
, DWORD id
)
2069 ci
->hConvPartner
= (pConv
->wStatus
& ST_ISLOCAL
) ? (HCONV
)((ULONG_PTR
)pConv
| 1) : 0;
2070 ci
->hszSvcPartner
= pConv
->hszService
;
2071 ci
->hszServiceReq
= pConv
->hszService
; /* FIXME: they shouldn't be the same, should they ? */
2072 ci
->hszTopic
= pConv
->hszTopic
;
2073 ci
->wStatus
= pConv
->wStatus
;
2075 side
= (pConv
->wStatus
& ST_CLIENT
) ? WDML_CLIENT_SIDE
: WDML_SERVER_SIDE
;
2077 for (pLink
= pConv
->instance
->links
[side
]; pLink
!= NULL
; pLink
= pLink
->next
)
2079 if (pLink
->hConv
== (HCONV
)pConv
)
2081 ci
->wStatus
|= ST_ADVISE
;
2086 /* FIXME: non handled status flags:
2092 ci
->wConvst
= pConv
->wConvst
; /* FIXME */
2094 ci
->wLastError
= 0; /* FIXME: note it's not the instance last error */
2096 ci
->ConvCtxt
= pConv
->convContext
;
2097 if (ci
->wStatus
& ST_CLIENT
)
2099 ci
->hwnd
= pConv
->hwndClient
;
2100 ci
->hwndPartner
= pConv
->hwndServer
;
2104 ci
->hwnd
= pConv
->hwndServer
;
2105 ci
->hwndPartner
= pConv
->hwndClient
;
2109 ci
->hUser
= pConv
->hUser
;
2118 pXAct
= WDML_FindTransaction(pConv
, id
);
2121 ci
->hUser
= pXAct
->hUser
;
2122 ci
->hszItem
= pXAct
->hszItem
;
2123 ci
->wFmt
= pXAct
->wFmt
;
2124 ci
->wType
= pXAct
->wType
;
2129 pConv
->instance
->lastError
= DMLERR_UNFOUND_QUEUE_ID
;
2135 /******************************************************************
2136 * DdeQueryConvInfo (USER32.@)
2138 * FIXME: Set last DDE error on failure.
2140 UINT WINAPI
DdeQueryConvInfo(HCONV hConv
, DWORD id
, PCONVINFO lpConvInfo
)
2142 UINT ret
= lpConvInfo
->cb
;
2146 TRACE("(%p,%x,%p)\n", hConv
, id
, lpConvInfo
);
2150 FIXME("hConv is NULL\n");
2154 pConv
= WDML_GetConv(hConv
, FALSE
);
2157 if (!WDML_GetLocalConvInfo(pConv
, &ci
, id
))
2162 if ((ULONG_PTR
)hConv
& 1)
2164 pConv
= WDML_GetConv((HCONV
)((ULONG_PTR
)hConv
& ~1), FALSE
);
2166 FIXME("Request on remote conversation information is not implemented yet\n");
2172 memcpy(lpConvInfo
, &ci
, min((size_t)lpConvInfo
->cb
, sizeof(ci
)));
2176 /* ================================================================
2178 * Link (hot & warm) management
2180 * ================================================================ */
2182 /******************************************************************
2187 void WDML_AddLink(WDML_INSTANCE
* pInstance
, HCONV hConv
, WDML_SIDE side
,
2188 UINT wType
, HSZ hszItem
, UINT wFmt
)
2192 pLink
= HeapAlloc(GetProcessHeap(), 0, sizeof(WDML_LINK
));
2199 pLink
->hConv
= hConv
;
2200 pLink
->transactionType
= wType
;
2201 WDML_IncHSZ(pInstance
, pLink
->hszItem
= hszItem
);
2203 pLink
->next
= pInstance
->links
[side
];
2204 pInstance
->links
[side
] = pLink
;
2207 /******************************************************************
2212 void WDML_RemoveLink(WDML_INSTANCE
* pInstance
, HCONV hConv
, WDML_SIDE side
,
2213 HSZ hszItem
, UINT uFmt
)
2215 WDML_LINK
* pPrev
= NULL
;
2216 WDML_LINK
* pCurrent
= NULL
;
2218 pCurrent
= pInstance
->links
[side
];
2220 while (pCurrent
!= NULL
)
2222 if (pCurrent
->hConv
== hConv
&&
2223 DdeCmpStringHandles(pCurrent
->hszItem
, hszItem
) == 0 &&
2224 pCurrent
->uFmt
== uFmt
)
2226 if (pCurrent
== pInstance
->links
[side
])
2228 pInstance
->links
[side
] = pCurrent
->next
;
2232 pPrev
->next
= pCurrent
->next
;
2235 WDML_DecHSZ(pInstance
, pCurrent
->hszItem
);
2236 HeapFree(GetProcessHeap(), 0, pCurrent
);
2241 pCurrent
= pCurrent
->next
;
2245 /* this function is called to remove all links related to the conv.
2246 It should be called from both client and server when terminating
2249 /******************************************************************
2250 * WDML_RemoveAllLinks
2254 void WDML_RemoveAllLinks(WDML_INSTANCE
* pInstance
, WDML_CONV
* pConv
, WDML_SIDE side
)
2256 WDML_LINK
* pPrev
= NULL
;
2257 WDML_LINK
* pCurrent
= NULL
;
2258 WDML_LINK
* pNext
= NULL
;
2260 pCurrent
= pInstance
->links
[side
];
2262 while (pCurrent
!= NULL
)
2264 if (pCurrent
->hConv
== (HCONV
)pConv
)
2266 if (pCurrent
== pInstance
->links
[side
])
2268 pInstance
->links
[side
] = pCurrent
->next
;
2269 pNext
= pCurrent
->next
;
2273 pPrev
->next
= pCurrent
->next
;
2274 pNext
= pCurrent
->next
;
2277 WDML_DecHSZ(pInstance
, pCurrent
->hszItem
);
2279 HeapFree(GetProcessHeap(), 0, pCurrent
);
2286 pCurrent
= pCurrent
->next
;
2295 /******************************************************************
2300 WDML_LINK
* WDML_FindLink(WDML_INSTANCE
* pInstance
, HCONV hConv
, WDML_SIDE side
,
2301 HSZ hszItem
, BOOL use_fmt
, UINT uFmt
)
2303 WDML_LINK
* pCurrent
= NULL
;
2305 for (pCurrent
= pInstance
->links
[side
]; pCurrent
!= NULL
; pCurrent
= pCurrent
->next
)
2307 /* we don't need to check for transaction type as it can be altered */
2309 if (pCurrent
->hConv
== hConv
&&
2310 DdeCmpStringHandles(pCurrent
->hszItem
, hszItem
) == 0 &&
2311 (!use_fmt
|| pCurrent
->uFmt
== uFmt
))
2321 /* ================================================================
2323 * Transaction management
2325 * ================================================================ */
2327 /******************************************************************
2328 * WDML_AllocTransaction
2330 * Alloc a transaction structure for handling the message ddeMsg
2332 WDML_XACT
* WDML_AllocTransaction(WDML_INSTANCE
* pInstance
, UINT ddeMsg
,
2333 UINT wFmt
, HSZ hszItem
)
2336 static WORD tid
= 1; /* FIXME: wrap around */
2338 pXAct
= HeapAlloc(GetProcessHeap(), 0, sizeof(WDML_XACT
));
2341 pInstance
->lastError
= DMLERR_MEMORY_ERROR
;
2345 pXAct
->xActID
= tid
++;
2346 pXAct
->ddeMsg
= ddeMsg
;
2347 pXAct
->hDdeData
= 0;
2352 if ((pXAct
->hszItem
= hszItem
)) WDML_IncHSZ(pInstance
, pXAct
->hszItem
);
2360 /******************************************************************
2361 * WDML_QueueTransaction
2363 * Adds a transaction to the list of transaction
2365 void WDML_QueueTransaction(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
2369 /* advance to last in queue */
2370 for (pt
= &pConv
->transactions
; *pt
!= NULL
; pt
= &(*pt
)->next
);
2374 /******************************************************************
2375 * WDML_UnQueueTransaction
2379 BOOL
WDML_UnQueueTransaction(WDML_CONV
* pConv
, WDML_XACT
* pXAct
)
2383 for (pt
= &pConv
->transactions
; *pt
; pt
= &(*pt
)->next
)
2394 /******************************************************************
2395 * WDML_FreeTransaction
2399 void WDML_FreeTransaction(WDML_INSTANCE
* pInstance
, WDML_XACT
* pXAct
, BOOL doFreePmt
)
2401 /* free pmt(s) in pXAct too. check against one for not deleting TRUE return values */
2402 if (doFreePmt
&& (ULONG_PTR
)pXAct
->hMem
> 1)
2404 GlobalFree(pXAct
->hMem
);
2406 if (pXAct
->hszItem
) WDML_DecHSZ(pInstance
, pXAct
->hszItem
);
2408 HeapFree(GetProcessHeap(), 0, pXAct
);
2411 /******************************************************************
2412 * WDML_FindTransaction
2416 WDML_XACT
* WDML_FindTransaction(WDML_CONV
* pConv
, DWORD tid
)
2421 for (pXAct
= pConv
->transactions
; pXAct
; pXAct
= pXAct
->next
)
2423 if (pXAct
->xActID
== tid
)
2429 /* ================================================================
2431 * Information broadcast across DDEML implementations
2433 * ================================================================ */
2435 struct tagWDML_BroadcastPmt
2443 /******************************************************************
2444 * WDML_BroadcastEnumProc
2448 static BOOL CALLBACK
WDML_BroadcastEnumProc(HWND hWnd
, LPARAM lParam
)
2450 struct tagWDML_BroadcastPmt
* s
= (struct tagWDML_BroadcastPmt
*)lParam
;
2453 if (GetClassNameW(hWnd
, buffer
, 128) > 0 &&
2454 lstrcmpiW(buffer
, s
->clsName
) == 0)
2456 PostMessageW(hWnd
, s
->uMsg
, s
->wParam
, s
->lParam
);
2461 /******************************************************************
2462 * WDML_BroadcastDDEWindows
2466 void WDML_BroadcastDDEWindows(LPCWSTR clsName
, UINT uMsg
, WPARAM wParam
, LPARAM lParam
)
2468 struct tagWDML_BroadcastPmt s
;
2470 s
.clsName
= clsName
;
2474 EnumWindows(WDML_BroadcastEnumProc
, (LPARAM
)&s
);