diff options
| -rw-r--r-- | sql/sql_parse.cc | 2 | ||||
| -rw-r--r-- | tpool/aio_liburing.cc | 2 |
2 files changed, 3 insertions, 1 deletions
diff --git a/sql/sql_parse.cc b/sql/sql_parse.cc index 0886fc85151..b26320fc098 100644 --- a/sql/sql_parse.cc +++ b/sql/sql_parse.cc @@ -1190,7 +1190,7 @@ static enum enum_server_command fetch_command(THD *thd, char *packet) DISPATCH_COMMAND_CLOSE_CONNECTION request of THD shutdown (s. dispatch_command() description) @retval - DISPATCH_COMMAND_WOULDBLOCK - need to wait for asyncronous operations + DISPATCH_COMMAND_WOULDBLOCK - need to wait for asynchronous operations to finish. Only returned if parameter 'blocking' is false. */ diff --git a/tpool/aio_liburing.cc b/tpool/aio_liburing.cc index cca95bb6d37..b8666482193 100644 --- a/tpool/aio_liburing.cc +++ b/tpool/aio_liburing.cc @@ -161,6 +161,8 @@ private: } io_uring_cqe_seen(&aio->uring_, cqe); + if (iocb->m_ret_len != iocb->m_len && !iocb->m_err) + finish_synchronous(iocb); // If we need to resubmit the IO operation, but the ring is full, // we will follow the same path as for any other error codes. |