From 788dc429f82fd4be296e86a293cd2a9f3f98e7c0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Markus=20M=C3=A4kel=C3=A4?= Date: Thu, 9 May 2019 10:05:40 +0300 Subject: [PATCH] Do client callback on owning worker The callback should've been done on the worker that owns the DCB instead of the main worker. --- server/modules/routing/avrorouter/avro_client.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/modules/routing/avrorouter/avro_client.cc b/server/modules/routing/avrorouter/avro_client.cc index 566b7b571..1ff7a2515 100644 --- a/server/modules/routing/avrorouter/avro_client.cc +++ b/server/modules/routing/avrorouter/avro_client.cc @@ -244,7 +244,7 @@ bool file_in_dir(const char* dir, const char* file) */ void AvroSession::queue_client_callback() { - auto worker = mxs::RoutingWorker::get(mxs::RoutingWorker::MAIN); + auto worker = static_cast(dcb->poll.owner); worker->execute([this]() { client_callback(); }, mxs::RoutingWorker::EXECUTE_QUEUED);