prepare for handling client closed messages

Signed-off-by: Mattias Andrée <maandree@operamail.com>

1 files changed, 34 insertions, 3 deletions

diff --git a/src/mds-registry.c b/src/mds-registry.c
index a438c1b..ec1e186 100644
--- a/src/mds-registry.c
+++ b/src/mds-registry.c
@@ -139,7 +139,7 @@ int initialise_server(void)
     "Length: 32\n"
     "\n"
     "Command: register\n"
-    "Client closed\n" /* FIXME support not implemented yet */
+    "Client closed\n"
     /* -- NEXT MESSAGE -- */
     "Command: reregister\n"
     "Message ID: 1\n"
@@ -391,12 +391,12 @@ int master_loop(void)
 
 
 /**
- * Handle the received message
+ * Handle the received message containing ‘Command: register’-header–value
  * 
  * @return  Zero on success -1 on error or interruption,
  *          errno will be set accordingly
  */
-int handle_message(void)
+static int handle_register_message(void)
 {
   const char* recv_client_id = NULL;
   const char* recv_message_id = NULL;
@@ -467,6 +467,37 @@ int handle_message(void)
 
 
 /**
+ * Handle the received message containing a ‘Client closed’-header
+ * 
+ * @return  Zero on success -1 on error or interruption,
+ *          errno will be set accordingly
+ */
+static int handle_close_message(void)
+{
+  /* FIXME */
+  return 0;
+}
+
+
+/**
+ * Handle the received message
+ * 
+ * @return  Zero on success -1 on error or interruption,
+ *          errno will be set accordingly
+ */
+int handle_message(void)
+{
+  size_t i;
+  for (i = 0; i < received.header_count; i++)
+    {
+      if (strequals(received.headers[i], "Command: register"))
+	return handle_register_message();
+    }
+  return handle_close_message();
+}
+
+
+/**
  * Convert a client ID string into a client ID integer
  * 
  * @param   str  The client ID string