Fix: Did not return when receiving EAGAIN

Signed-off-by: gxu <georgexu420@163.com>

Author: gxuu

scaler/io/ymq/examples/automated_echo_client.cpp

@@ -34,7 +34,8 @@ int main() {
     std::vector<std::promise<Message>> recvPromises;
     recvPromises.reserve(msgCnt + 10);
 
-    syncConnectSocket(clientSocket, "tcp://51.15.214.200:32912");
+    // syncConnectSocket(clientSocket, "tcp://51.15.214.200:32912");
+    syncConnectSocket(clientSocket, "tcp://127.0.0.1:8080");
     printf("Connected to server.\n");
 
     const std::string_view line = longStr;

scaler/io/ymq/tcp_server.cpp

@@ -97,7 +97,7 @@ void TcpServer::onRead() {
                 // Not an error
                 // case EWOULDBLOCK: // same as EAGAIN
                 case EAGAIN:
-                case ECONNABORTED: break;
+                case ECONNABORTED: return;
 
                 case ENOTSOCK:
                 case EOPNOTSUPP: