aboutsummaryrefslogtreecommitdiffstats
path: root/src/mds-server/mds-server.h
diff options
context:
space:
mode:
authorMattias Andrée <maandree@operamail.com>2014-05-18 07:08:32 +0200
committerMattias Andrée <maandree@operamail.com>2014-05-18 07:08:32 +0200
commit1936e97603ba95ae2f657208349ef072039aca8c (patch)
tree87c5cfd2ef5e5f77f8d1ba1723013988af9a2b1c /src/mds-server/mds-server.h
parentstyle + reduce code complexity (diff)
downloadmds-1936e97603ba95ae2f657208349ef072039aca8c.tar.gz
mds-1936e97603ba95ae2f657208349ef072039aca8c.tar.bz2
mds-1936e97603ba95ae2f657208349ef072039aca8c.tar.xz
reduce code complexity
Signed-off-by: Mattias Andrée <maandree@operamail.com>
Diffstat (limited to 'src/mds-server/mds-server.h')
-rw-r--r--src/mds-server/mds-server.h24
1 files changed, 23 insertions, 1 deletions
diff --git a/src/mds-server/mds-server.h b/src/mds-server/mds-server.h
index 08f7fd4..9abf095 100644
--- a/src/mds-server/mds-server.h
+++ b/src/mds-server/mds-server.h
@@ -35,11 +35,25 @@
void* slave_loop(void* data);
/**
+ * Send the next message in a clients multicast queue
+ *
+ * @param client The client
+ */
+void send_multicast_queue(client_t* client);
+
+/**
+ * Send the messages that are in a clients reply queue
+ *
+ * @param client The client
+ */
+void send_reply_queue(client_t* client);
+
+/**
* Perform actions that should be taken when
* a message has been received from a client
*
* @param client The client has sent a message
- * @return Normally zero, but 1 if exited because of re-exec
+ * @return Normally zero, but 1 if exited because of re-exec or termination
*/
int message_received(client_t* client);
@@ -64,6 +78,14 @@ void add_intercept_condition(client_t* client, char* condition, int64_t priority
void queue_message_multicast(char* message, size_t length, client_t* sender);
/**
+ * Receive a full message and update open status if the client closes
+ *
+ * @param client The client
+ * @return Zero on success, -2 on failure, otherwise -1
+ */
+int fetch_message(client_t* client);
+
+/**
* Multicast a message
*
* @param multicast The multicast message