[GNUnet-SVN] [libmicrohttpd] branch master updated: Better check for pending outgoing data for "upgraded" connections

[gnunet]

This is an automated email from the git hooks/post-receive script.

karlson2k pushed a commit to branch master
in repository libmicrohttpd.

The following commit(s) were added to refs/heads/master by this push:
     new bd3a8f5e Better check for pending outgoing data for "upgraded" 
connections
bd3a8f5e is described below

commit bd3a8f5e00bccf6b25c1956d7c3456309d16ce96
Author: Evgeny Grin (Karlson2k) <address@hidden>
AuthorDate: Mon Dec 19 00:01:58 2016 +0300

    Better check for pending outgoing data for "upgraded" connections
---
 src/microhttpd/daemon.c | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/microhttpd/daemon.c b/src/microhttpd/daemon.c
index 664bb90d..e7f712df 100644
--- a/src/microhttpd/daemon.c
+++ b/src/microhttpd/daemon.c
@@ -685,7 +685,7 @@ urh_to_fdset (struct MHD_UpgradeResponseHandle *urh,
                               max_fd,
                               fd_setsize)) )
     return MHD_NO;
-  if ( (0 == (MHD_EPOLL_STATE_WRITE_READY & urh->mhd.celi)) &&
+  if ( (0 != urh->in_buffer_used) &&
        (MHD_NO == urh->was_closed) &&
        (MHD_INVALID_SOCKET != urh->mhd.socket) &&
        (! MHD_add_to_fd_set_ (urh->mhd.socket,
@@ -701,7 +701,7 @@ urh_to_fdset (struct MHD_UpgradeResponseHandle *urh,
                               max_fd,
                               fd_setsize)) )
     return MHD_NO;
-  if ( (0 == (MHD_EPOLL_STATE_WRITE_READY & urh->app.celi)) &&
+  if ( (0 != urh->out_buffer_used) &&
        (MHD_INVALID_SOCKET != urh->connection->socket_fd) &&
        (! MHD_add_to_fd_set_ (urh->connection->socket_fd,
                               ws,
@@ -1339,11 +1339,11 @@ thread_main_connection_upgrade (struct MHD_Connection 
*con)
           p[1].fd = urh->mhd.socket;
           if (urh->in_buffer_used < urh->in_buffer_size)
             p[0].events |= POLLIN;
-          if (0 == (MHD_EPOLL_STATE_WRITE_READY & urh->app.celi))
+          if (0 != urh->out_buffer_used)
             p[0].events |= POLLOUT;
           if (urh->out_buffer_used < urh->out_buffer_size)
             p[1].events |= POLLIN;
-          if (0 == (MHD_EPOLL_STATE_WRITE_READY & urh->mhd.celi))
+          if (0 != urh->in_buffer_used)
             p[1].events |= POLLOUT;
 
           if ( (0 != (p[0].events | p[1].events)) &&
@@ -3333,13 +3333,13 @@ MHD_poll_all (struct MHD_Daemon *daemon,
         p[poll_server+i].fd = urh->connection->socket_fd;
         if (urh->in_buffer_used < urh->in_buffer_size)
           p[poll_server+i].events |= POLLIN;
-        if (0 == (MHD_EPOLL_STATE_WRITE_READY & urh->app.celi))
+        if (0 != urh->out_buffer_used)
           p[poll_server+i].events |= POLLOUT;
         i++;
         p[poll_server+i].fd = urh->mhd.socket;
         if (urh->out_buffer_used < urh->out_buffer_size)
           p[poll_server+i].events |= POLLIN;
-        if (0 == (MHD_EPOLL_STATE_WRITE_READY & urh->mhd.celi))
+        if (0 != urh->in_buffer_used)
           p[poll_server+i].events |= POLLOUT;
         i++;
       }

-- 
To stop receiving notification emails like this one, please contact
address@hidden