Zebediah Figura : server: Use a separate field to track whether an async is blocking.

[Alexandre Julliard]

Module: wine
Branch: master
Commit: 386c4bcf2f0d86a5a19c4836fc4b160c36ccb499
URL:    https://source.winehq.org/git/wine.git/?a=commit;h=386c4bcf2f0d86a5a19c4836fc4b160c36ccb499

Author: Zebediah Figura <zfigura at codeweavers.com>
Date:   Fri Sep  3 23:11:41 2021 -0500

server: Use a separate field to track whether an async is blocking.

Signed-off-by: Zebediah Figura <zfigura at codeweavers.com>
Signed-off-by: Alexandre Julliard <julliard at winehq.org>

---

 server/async.c | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/server/async.c b/server/async.c
index d1627069086..8dba55afb01 100644
--- a/server/async.c
+++ b/server/async.c
@@ -55,6 +55,7 @@ struct async
     unsigned int         terminated :1;   /* async has been terminated */
     unsigned int         canceled :1;     /* have we already queued cancellation for this async? */
     unsigned int         unknown_status :1; /* initial status is not known yet */
+    unsigned int         blocking :1;     /* async is blocking */
     struct completion   *completion;      /* completion associated with fd */
     apc_param_t          comp_key;        /* completion key associated with fd */
     unsigned int         comp_flags;      /* completion flags */
@@ -262,6 +263,7 @@ struct async *create_async( struct fd *fd, struct thread *thread, const async_da
     async->terminated    = 0;
     async->canceled      = 0;
     async->unknown_status = 0;
+    async->blocking      = !is_fd_overlapped( fd );
     async->completion    = fd_get_completion( fd, &async->comp_key );
     async->comp_flags    = 0;
     async->completion_callback = NULL;
@@ -300,6 +302,8 @@ void set_async_pending( struct async *async, int signal )
 /* return async object status and wait handle to client */
 obj_handle_t async_handoff( struct async *async, data_size_t *result, int force_blocking )
 {
+    async->blocking = force_blocking || async->blocking;
+
     if (async->unknown_status)
     {
         /* even the initial status is not known yet */
@@ -338,7 +342,7 @@ obj_handle_t async_handoff( struct async *async, data_size_t *result, int force_
     {
         async->direct_result = 0;
         async->pending = 1;
-        if (!force_blocking && async->fd && is_fd_overlapped( async->fd ))
+        if (!async->blocking)
         {
             close_handle( async->thread->process, async->wait_handle);
             async->wait_handle = 0;