fix(event,network):1.11.5, 修复因event中epoll对HUP事件处理的错误引起的BufferedFd多次读0事件的异常

Author: hevake

modules/event/engines/epoll/fd_event.cpp

@@ -165,27 +165,20 @@ void EpollFdEvent::OnEventCallback(uint32_t events, void *obj)
         tbox_events |= kExceptEvent;
     }
 
-    bool is_got_hup = false;
-
     if (events & EPOLLHUP) {
         events &= ~EPOLLHUP;
-        is_got_hup = true;
+        //! 在epoll中，无论有没有监听EPOLLHUP，在对端close了fd时都会触发本端EPOLLHUP事件
+        //! 只要发生了EPOLLHUB事件，只有让上层关闭该事件所有的事件才能停止EPOLLHUP的触发
+        //! 否则它会一直触发事件，导致Loop空跑，CPU占满问题
+        //! 为此，将HUP事件当成可读事件，上层读到0字节则表示对端已关闭
+        tbox_events |= kReadEvent;
     }
 
     //! 要先复制一份，因为在for中很可能会改动到d->fd_events，引起迭代器失效问题
     auto tmp = d->fd_events;
-    for (auto event : tmp) {
+    for (auto event : tmp)
         event->onEvent(tbox_events);
 
-        //! 在epoll中，无论有没有监听EPOLLHUP，在对端close了fd时都会触发本端EPOLLHUP事件
-        //! 只要发生了EPOLLHUB事件，只有让上层关闭该事件所有的事件才能停止EPOLLHUP的触发
-        //! 否则它会一直触发事件，导致Loop空跑，CPU占满问题
-        if (is_got_hup) {
-            //! 将HUP事件当成可读事件，上层读到0字节则表示对端已关闭
-            event->onEvent(kReadEvent);
-        }
-    }
-
     if (events)
         LogWarn("unhandle events:%08X, fd:%d", events, d->fd);
 }

modules/network/buffered_fd.cpp

@@ -228,7 +228,6 @@ void BufferedFd::onReadCallback(short)
         }
 
     } else if (rsize == 0) {    //! 读到0字节数据，说明fd_已不可读了
-        sp_read_event_->disable();
         if (read_zero_cb_) {
             ++cb_level_;
             read_zero_cb_();

modules/network/tcp_connection.cpp

@@ -140,6 +140,8 @@ void TcpConnection::onSocketClosed()
 {
     LogInfo("%s", peer_addr_.toString().c_str());
 
+    sp_buffered_fd_->disable();
+
     BufferedFd *tmp = nullptr;
     std::swap(tmp, sp_buffered_fd_);
 
@@ -157,9 +159,6 @@ void TcpConnection::onSocketClosed()
 
 void TcpConnection::onReadError(int errnum)
 {
-    if (errnum == ECONNRESET)
-        return;
-
     LogNotice("errno:%d, %s", errnum, strerror(errnum));
     onSocketClosed();
 }

version.mk

@@ -21,4 +21,4 @@
 # TBOX版本号
 TBOX_VERSION_MAJOR := 1
 TBOX_VERSION_MINOR := 11
-TBOX_VERSION_REVISION := 4
+TBOX_VERSION_REVISION := 5