From ca5776f40e60f5bf5c0bf19c242492c2082d3dfc Mon Sep 17 00:00:00 2001
From: Alon Levy <alevy@redhat.com>
Date: Mon, 7 Nov 2011 12:01:26 +0200
Subject: server/dispatcher: add dispatcher_register_async_done_callback

---
 server/dispatcher.h | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)

(limited to 'server/dispatcher.h')

diff --git a/server/dispatcher.h b/server/dispatcher.h
index 95b6bfc6..a468c58f 100644
--- a/server/dispatcher.h
+++ b/server/dispatcher.h
@@ -8,6 +8,11 @@ typedef struct Dispatcher Dispatcher;
 typedef void (*dispatcher_handle_message)(void *opaque,
                                           void *payload);
 
+typedef void (*dispatcher_handle_async_done)(void *opaque,
+                                             uint32_t message_type,
+                                             void *payload);
+
+
 typedef struct DispatcherMessage {
     size_t size;
     int ack;
@@ -26,6 +31,7 @@ struct Dispatcher {
     void *payload; /* allocated as max of message sizes */
     size_t payload_size; /* used to track realloc calls */
     void *opaque;
+    dispatcher_handle_async_done handle_async_done;
 };
 
 /*
@@ -68,6 +74,16 @@ void dispatcher_register_handler(Dispatcher *dispatcher, uint32_t message_type,
                                  dispatcher_handle_message handler, size_t size,
                                  int ack);
 
+/*
+ * dispatcher_register_async_done_callback
+ * @dispatcher:     dispatcher
+ * @handler:        callback on the receiver side called *after* the
+ *                  message callback in case ack == DISPATCHER_ASYNC.
+ */
+void dispatcher_register_async_done_callback(
+                                    Dispatcher *dispatcher,
+                                    dispatcher_handle_async_done handler);
+
 /*
  *  dispatcher_handle_recv_read
  *  @dispatcher: Dispatcher instance
-- 
cgit