commit 088bcf9ca5a00ffb6adfe6a1a0da6a3b3be5e9dc
author Alexandre Julliard <julliard@winehq.org> Fri Apr 04 22:26:34 2003 +0000
committer Alexandre Julliard <julliard@winehq.org> Fri Apr 04 22:26:34 2003 +0000
tree d6f00f943e843b830d709a3de429bdc2cccf2cff
parent c7bebba198bc1466ac3ff7f93b282ccc5961b7ba

Implemented NtQueueApcThread, and changed the server APC interface to
always take 3 parameters.
Implemented a number of other ntdll thread functions, and use them
from the kernel ones.

server/thread.c

diff --git a/server/thread.c b/server/thread.c
index ad310c9..c6ef4ac 100644
--- a/server/thread.c
+++ b/server/thread.c
@@ -67,7 +67,9 @@
     void               *func;     /* function to call in client */
     enum apc_type       type;     /* type of apc function */
     int                 nb_args;  /* number of arguments */
-    void               *args[1];  /* function arguments */
+    void               *arg1;     /* function arguments */
+    void               *arg2;
+    void               *arg3;
 };
 
 
@@ -580,7 +582,7 @@
 
 /* queue an async procedure call */
 int thread_queue_apc( struct thread *thread, struct object *owner, void *func,
-                      enum apc_type type, int system, int nb_args, ... )
+                      enum apc_type type, int system, void *arg1, void *arg2, void *arg3 )
 {
     struct thread_apc *apc;
     struct apc_queue *queue = system ? &thread->system_apc : &thread->user_apc;
@@ -589,21 +591,15 @@
     if (owner) thread_cancel_apc( thread, owner, system );
     if (thread->state == TERMINATED) return 0;
 
-    if (!(apc = mem_alloc( sizeof(*apc) + (nb_args-1)*sizeof(apc->args[0]) ))) return 0;
-    apc->prev    = queue->tail;
-    apc->next    = NULL;
-    apc->owner   = owner;
-    apc->func    = func;
-    apc->type    = type;
-    apc->nb_args = nb_args;
-    if (nb_args)
-    {
-        int i;
-        va_list args;
-        va_start( args, nb_args );
-        for (i = 0; i < nb_args; i++) apc->args[i] = va_arg( args, void * );
-        va_end( args );
-    }
+    if (!(apc = mem_alloc( sizeof(*apc) ))) return 0;
+    apc->prev   = queue->tail;
+    apc->next   = NULL;
+    apc->owner  = owner;
+    apc->func   = func;
+    apc->type   = type;
+    apc->arg1   = arg1;
+    apc->arg2   = arg2;
+    apc->arg3   = arg3;
     queue->tail = apc;
     if (!apc->prev)  /* first one */
     {
@@ -972,7 +968,8 @@
     struct thread *thread;
     if ((thread = get_thread_from_handle( req->handle, THREAD_SET_CONTEXT )))
     {
-        thread_queue_apc( thread, NULL, req->func, APC_USER, !req->user, 1, req->param );
+        thread_queue_apc( thread, NULL, req->func, APC_USER, !req->user,
+                          req->arg1, req->arg2, req->arg3 );
         release_object( thread );
     }
 }
@@ -981,7 +978,6 @@
 DECL_HANDLER(get_apc)
 {
     struct thread_apc *apc;
-    size_t size;
 
     for (;;)
     {
@@ -999,11 +995,11 @@
         if (apc->func || apc->type == APC_ASYNC_IO) break;
         free( apc );
     }
-    size = apc->nb_args * sizeof(apc->args[0]);
-    if (size > get_reply_max_size()) size = get_reply_max_size();
     reply->func = apc->func;
     reply->type = apc->type;
-    set_reply_data( apc->args, size );
+    reply->arg1 = apc->arg1;
+    reply->arg2 = apc->arg2;
+    reply->arg3 = apc->arg3;
     free( apc );
 }