summaryrefslogtreecommitdiff
path: root/tpool
diff options
context:
space:
mode:
authorMarko Mäkelä <marko.makela@mariadb.com>2021-06-18 09:16:20 +0300
committerMarko Mäkelä <marko.makela@mariadb.com>2021-06-18 09:16:20 +0300
commitb630f0b1b98e462225c13176113946f4580ea8d4 (patch)
treecb452513c6526a30a2e06d489b5a5d7cf9e69c24 /tpool
parentb7d87bf0a988e6471b793c4c148837a460641102 (diff)
parent78bd7d86a4a0b3733ba38373213645a6b3a9b9c6 (diff)
downloadmariadb-git-b630f0b1b98e462225c13176113946f4580ea8d4.tar.gz
Merge 10.5 into 10.6
Diffstat (limited to 'tpool')
-rw-r--r--tpool/aio_simulated.cc5
1 files changed, 4 insertions, 1 deletions
diff --git a/tpool/aio_simulated.cc b/tpool/aio_simulated.cc
index 4811797a75e..93b2ae134b2 100644
--- a/tpool/aio_simulated.cc
+++ b/tpool/aio_simulated.cc
@@ -159,7 +159,9 @@ public:
#endif
cb->m_ret_len = ret_len;
cb->m_err = err;
- cb->m_callback(cb);
+ cb->m_internal_task.m_func= cb->m_callback;
+ thread_pool *pool= (thread_pool *)cb->m_internal;
+ pool->submit_task(&cb->m_internal_task);
}
virtual int submit_io(aiocb *aiocb) override
@@ -167,6 +169,7 @@ public:
aiocb->m_internal_task.m_func = simulated_aio_callback;
aiocb->m_internal_task.m_arg = aiocb;
aiocb->m_internal_task.m_group = aiocb->m_group;
+ aiocb->m_internal = m_pool;
m_pool->submit_task(&aiocb->m_internal_task);
return 0;
}