update

Author: treefrogframework

src/turingcoroutine_linux.cpp

@@ -105,7 +105,24 @@ class AsyncSendFile : public TAwaitBase {
     bool completed() const override
     {
         //tSystemInfo("AsyncSendFile::completed : _offset:{} _cqeflags:{} _cqeres:{}", _offset, _cqeflags, _cqeres);
-        return (_cqeres < 0) || (_offset + _cqeres >= _fileSize);
+        switch (_state) {
+        case State::WaitForPollOut:
+            if (_cqeres == POLLOUT) {
+                return (_offset + _cqeres >= _fileSize);
+            } else {
+                // POLLERR or POLLHUP
+                return true;
+            }
+            break;
+
+        case State::Sending:
+            return (_cqeres <= 0);
+
+        case State::Idle:
+        default:
+            tSystemError("Bad status  [{}:{}]", __FILE__, __LINE__);
+            return true;
+        }
     }
 
     void iterate() override
@@ -116,7 +133,6 @@ class AsyncSendFile : public TAwaitBase {
         switch (_state) {
         case State::WaitForPollOut:
             if (_cqeres < 0) {
-                // error
                 return;
             }
             _state = State::Idle;
@@ -144,7 +160,7 @@ class AsyncSendFile : public TAwaitBase {
                 }
             }
 
-            int res = TUringServer::instance()->addPoll(_sd, POLLOUT, this);
+            int res = TUringServer::instance()->addPoll(_sd, (POLLOUT | POLLERR | POLLHUP), this);
             if (res < 0) {
                 tSystemError("addPoll error: {}", strerror(errno));
                 _cqeres = -1;

src/turingserver_linux.cpp

@@ -80,7 +80,7 @@ TUringServer::TUringServer(int listeningSocket, QObject *parent) :
     TApplicationServerBase(),
     _listenSocket(listeningSocket)
 {
-    io_uring_queue_init(8192 * 2, &_ring, 0);
+    io_uring_queue_init(8192, &_ring, 0);
 
     // Event fd
     _notifyFd = eventfd(0, (EFD_NONBLOCK | EFD_CLOEXEC));
@@ -229,7 +229,7 @@ void TUringServer::run()
                     }
                 }
             } else {
-                tSystemDebug("cqe->res:{}  cqe->flags: {}", await->_cqeres, cqe->flags);
+                tSystemDebug("cqe->res:{}  cqe->flags: {}", cqe->res, cqe->flags);
                 if (cqe->flags != IORING_CQE_F_MORE) [[likely]] {
                     if (!await->_cqeres && !await->_cqeflags) {
                         await->_cqeres = cqe->res;