Skip to content

Commit f4fb6cb

Browse files
committed
MDEV-27900: aio handle partial reads/writes (uring)
MDEV-27900 continued for uring. Also spell synchronously correctly in sql_parse.cc. Reviewed by Wlad.
1 parent bd1ba78 commit f4fb6cb

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

sql/sql_parse.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1190,7 +1190,7 @@ static enum enum_server_command fetch_command(THD *thd, char *packet)
11901190
DISPATCH_COMMAND_CLOSE_CONNECTION request of THD shutdown
11911191
(s. dispatch_command() description)
11921192
@retval
1193-
DISPATCH_COMMAND_WOULDBLOCK - need to wait for asyncronous operations
1193+
DISPATCH_COMMAND_WOULDBLOCK - need to wait for asynchronous operations
11941194
to finish. Only returned if parameter
11951195
'blocking' is false.
11961196
*/

tpool/aio_liburing.cc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -161,6 +161,8 @@ class aio_uring final : public tpool::aio
161161
}
162162

163163
io_uring_cqe_seen(&aio->uring_, cqe);
164+
if (iocb->m_ret_len != iocb->m_len && !iocb->m_err)
165+
finish_synchronous(iocb);
164166

165167
// If we need to resubmit the IO operation, but the ring is full,
166168
// we will follow the same path as for any other error codes.

0 commit comments

Comments
 (0)