From fead72e8a7a1928c8195815d7ec9b33794f28115 Mon Sep 17 00:00:00 2001
From: Huw Davies <huw@codeweavers.com>
Date: Wed, 27 Sep 2006 16:23:42 +0100
Subject: [PATCH] ole32: Don't return from CoRegisterClassObject until we have
 created the named pipe.

Also don't fail if the client connects to the pipe between CreateNamedPipe and ConnectNamedPipe.
---
 dlls/ole32/rpc.c | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/dlls/ole32/rpc.c b/dlls/ole32/rpc.c
index e7266dc1048..7646e1dbf81 100644
--- a/dlls/ole32/rpc.c
+++ b/dlls/ole32/rpc.c
@@ -924,6 +924,7 @@ struct local_server_params
 {
     CLSID clsid;
     IStream *stream;
+    HANDLE ready_event;
 };
 
 /* FIXME: should call to rpcss instead */
@@ -945,12 +946,14 @@ static DWORD WINAPI local_server_thread(LPVOID param)
 
     get_localserver_pipe_name(pipefn, &lsp->clsid);
 
-    HeapFree(GetProcessHeap(), 0, lsp);
-
     hPipe = CreateNamedPipeW( pipefn, PIPE_ACCESS_DUPLEX,
                               PIPE_TYPE_BYTE|PIPE_WAIT, PIPE_UNLIMITED_INSTANCES,
                               4096, 4096, 500 /* 0.5 second timeout */, NULL );
-    
+
+    SetEvent(lsp->ready_event);
+
+    HeapFree(GetProcessHeap(), 0, lsp);
+
     if (hPipe == INVALID_HANDLE_VALUE)
     {
         FIXME("pipe creation failed for %s, le is %ld\n", debugstr_w(pipefn), GetLastError());
@@ -958,7 +961,7 @@ static DWORD WINAPI local_server_thread(LPVOID param)
     }
     
     while (1) {
-        if (!ConnectNamedPipe(hPipe,NULL)) {
+        if (!ConnectNamedPipe(hPipe,NULL) && GetLastError() != ERROR_PIPE_CONNECTED) {
             ERR("Failure during ConnectNamedPipe %ld, ABORT!\n",GetLastError());
             break;
         }
@@ -1002,14 +1005,18 @@ static DWORD WINAPI local_server_thread(LPVOID param)
 void RPC_StartLocalServer(REFCLSID clsid, IStream *stream)
 {
     DWORD tid;
-    HANDLE thread;
+    HANDLE thread, ready_event;
     struct local_server_params *lsp = HeapAlloc(GetProcessHeap(), 0, sizeof(*lsp));
 
     lsp->clsid = *clsid;
     lsp->stream = stream;
     IStream_AddRef(stream);
+    lsp->ready_event = ready_event = CreateEventW(NULL, FALSE, FALSE, NULL);
 
     thread = CreateThread(NULL, 0, local_server_thread, lsp, 0, &tid);
     CloseHandle(thread);
     /* FIXME: failure handling */
+
+    WaitForSingleObject(ready_event, INFINITE);
+    CloseHandle(ready_event);
 }
-- 
2.11.4.GIT