Ticket #7961: boost-1.53.0b1-asio-epoll-reactor.patch

boost/asio/detail/epoll_reactor.hpp

@@ -62 +62 @@
     int descriptor_;
     boost::uint32_t registered_events_;
     op_queue<reactor_op> op_queue_[max_ops];
+    bool connected_;
     bool shutdown_;
 
     BOOST_ASIO_DECL descriptor_state();

boost/asio/detail/impl/epoll_reactor.ipp

@@ -155 +155 @@
 
     descriptor_data->reactor_ = this;
     descriptor_data->descriptor_ = descriptor;
+    descriptor_data->connected_ = false;
     descriptor_data->shutdown_ = false;
   }
 
@@ -180 +181 @@
 
     descriptor_data->reactor_ = this;
     descriptor_data->descriptor_ = descriptor;
+    descriptor_data->connected_ = false;
     descriptor_data->shutdown_ = false;
     descriptor_data->op_queue_[op_type].push(op);
   }
@@ -615 +617 @@
   static const int flag[max_ops] = { EPOLLIN, EPOLLOUT, EPOLLPRI };
   for (int j = max_ops - 1; j >= 0; --j)
   {
-    if (events & (flag[j] | EPOLLERR | EPOLLHUP))
+    if (events & (flag[j] | EPOLLERR | (connected_ ? EPOLLHUP : 0)))
     {
       while (reactor_op* op = op_queue_[j].front())
       {
+        if (j == connect_op) 
+          connected_ = true;
+
         if (op->perform())
         {
           op_queue_[j].pop();