Fix avrorouter client notifications

The notifications that tell clients about new data weren't using the correct mechanism.
mariadb-corporation · May 10, 2019 · 1efe3e0 · 1efe3e0
1 parent 37bfe1c
commit 1efe3e0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/server/modules/routing/avrorouter/avro_file.cc b/server/modules/routing/avrorouter/avro_file.cc
@@ -377,7 +377,8 @@ bool notify_cb(DCB* dcb, void* data)
 
     if (dcb->service == service && dcb->dcb_role == DCB_ROLE_CLIENT_HANDLER)
     {
-        poll_fake_write_event(dcb);
+        auto session = (AvroSession*)dcb->session->router_session;
+        session->queue_client_callback();
     }
 
     return true;

diff --git a/server/modules/routing/avrorouter/avrorouter.hh b/server/modules/routing/avrorouter/avrorouter.hh
@@ -170,6 +170,8 @@ public:
      */
     int routeQuery(GWBUF* buffer);
 
+    void queue_client_callback();
+
 private:
     AvroSession(Avro* instance, MXS_SESSION* session);
 
@@ -183,7 +185,6 @@ private:
     bool stream_data();
     void rotate_avro_file(std::string fullname);
     void client_callback();
-    void queue_client_callback();
 };
 
 void read_table_info(uint8_t* ptr,