diff options
author | Marko Mäkelä <marko.makela@mariadb.com> | 2021-06-18 09:16:20 +0300 |
---|---|---|
committer | Marko Mäkelä <marko.makela@mariadb.com> | 2021-06-18 09:16:20 +0300 |
commit | b630f0b1b98e462225c13176113946f4580ea8d4 (patch) | |
tree | cb452513c6526a30a2e06d489b5a5d7cf9e69c24 /tpool | |
parent | b7d87bf0a988e6471b793c4c148837a460641102 (diff) | |
parent | 78bd7d86a4a0b3733ba38373213645a6b3a9b9c6 (diff) | |
download | mariadb-git-b630f0b1b98e462225c13176113946f4580ea8d4.tar.gz |
Merge 10.5 into 10.6
Diffstat (limited to 'tpool')
-rw-r--r-- | tpool/aio_simulated.cc | 5 |
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; } |