commit 93c3faef9415d6c38de896328fe9f546b3f26fb4
author Marcus Meissner <marcus@jet.franken.de> Sat Jan 12 21:16:13 2002 +0000
committer Alexandre Julliard <julliard@winehq.org> Sat Jan 12 21:16:13 2002 +0000
tree 148860ce91dc93d6ffd57f155a238f5fd1fe96cc
parent dea2952242d02937fdd0f5c627b02ca1e15decbb

Add refcounting to the thread member of the pipe user.

server/named_pipe.c

diff --git a/server/named_pipe.c b/server/named_pipe.c
index bce7b23..6bf4dcd 100644
--- a/server/named_pipe.c
+++ b/server/named_pipe.c
@@ -48,7 +48,7 @@
     struct named_pipe  *pipe;
     struct pipe_user   *next;
     struct pipe_user   *prev;
-    void               *thread;
+    struct thread      *thread;
     void               *func;
     void               *overlapped;
 };
@@ -134,6 +134,7 @@
         thread_queue_apc(user->thread,NULL,user->func,
             APC_ASYNC,1,2,user->overlapped,status);
     }
+    if (user->thread) release_object(user->thread);
     user->thread = NULL;
     user->func = NULL;
     user->overlapped=NULL;
@@ -172,6 +173,7 @@
     if (user->next) user->next->prev = user->prev;
     if (user->prev) user->prev->next = user->next;
     else user->pipe->users = user->next;
+    if (user->thread) release_object(user->thread);
     release_object(user->pipe);
 }
 
@@ -361,7 +363,7 @@
     else
     {
         user->state = ps_wait_open;
-        user->thread = current;
+        user->thread = (struct thread *)grab_object(current);
         user->func = req->func;
         user->overlapped = req->overlapped;
 
@@ -405,7 +407,7 @@
                 if( (user = create_pipe_user (pipe, -1)) )
                 {
                     user->state = ps_wait_connect;
-                    user->thread = current;
+                    user->thread = (struct thread *)grab_object(current);
                     user->func = req->func;
                     user->overlapped = req->overlapped;
                     /* don't release it */