aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/mds-server/client.c23
-rw-r--r--src/mds-server/client.h8
-rw-r--r--src/mds-server/mds-server.c71
3 files changed, 66 insertions, 36 deletions
diff --git a/src/mds-server/client.c b/src/mds-server/client.c
index 08205b2..0e8e0b5 100644
--- a/src/mds-server/client.c
+++ b/src/mds-server/client.c
@@ -21,10 +21,33 @@
#include <stdlib.h>
#include <string.h>
+#include <pthread.h>
/**
+ * Release all resources assoicated with a client
+ *
+ * @param this The client information
+ */
+void client_destroy(client_t* restrict this)
+{
+ if (this->interception_conditions != NULL)
+ {
+ size_t i;
+ for (i = 0; i < this->interception_conditions_count; i++)
+ free(this->interception_conditions[i].condition);
+ free(this->interception_conditions);
+ }
+ if (this->mutex_created)
+ pthread_mutex_destroy(&(this->mutex));
+ mds_message_destroy(&(this->message));
+ free(this->send_pending);
+ free(this);
+}
+
+
+/**
* Calculate the buffer size need to marshal client information
*
* @param this The client information
diff --git a/src/mds-server/client.h b/src/mds-server/client.h
index fee5eba..6b98ade 100644
--- a/src/mds-server/client.h
+++ b/src/mds-server/client.h
@@ -99,6 +99,14 @@ typedef struct client
} client_t;
+
+/**
+ * Release all resources assoicated with a client
+ *
+ * @param this The client information
+ */
+void client_destroy(client_t* restrict this);
+
/**
* Calculate the buffer size need to marshal client information
*
diff --git a/src/mds-server/mds-server.c b/src/mds-server/mds-server.c
index 24ec7ac..00f8ceb 100644
--- a/src/mds-server/mds-server.c
+++ b/src/mds-server/mds-server.c
@@ -365,6 +365,7 @@ int main(int argc_, char** argv_)
pid_t pid = getpid();
int reexec_fd;
char shm_path[NAME_MAX + 1];
+ ssize_t node;
/* Join with all slaves threads. */
with_mutex(slave_mutex,
@@ -388,8 +389,17 @@ int main(int argc_, char** argv_)
close(reexec_fd);
reexec_fd = -1;
+ /* Release resources. */
+ foreach_linked_list_node (client_list, node)
+ {
+ client_t* client = (client_t*)(void*)(client_list.values[node]);
+ client_destroy(client);
+ }
+
/* Re-exec the server. */
reexec_server(argc, argv, reexec);
+ fd_table_destroy(&client_map, NULL, NULL);
+ linked_list_destroy(&client_list);
reexec_fail:
perror(*argv);
@@ -570,20 +580,7 @@ void* slave_loop(void* data)
close(socket_fd);
free(msgbuf);
if (information != NULL)
- {
- if (information->interception_conditions != NULL)
- {
- size_t i;
- for (i = 0; i < information->interception_conditions_count; i++)
- free(information->interception_conditions[i].condition);
- free(information->interception_conditions);
- }
- if (information->mutex_created)
- pthread_mutex_destroy(&(information->mutex));
- mds_message_destroy(&(information->message));
- free(information->send_pending);
- free(information);
- }
+ client_destroy(information);
/* Unlist client and decrease the slave count. */
with_mutex(slave_mutex,
@@ -1013,29 +1010,31 @@ void multicast_message(char* message, size_t length)
n = client->interception_conditions_count;
errno = 0;
if (client->open)
- with_mutex(mutex,
- if (errno || (client->open == 0))
- n == 0;
- for (i = 0; i < n; i++)
- {
- interception_condition_t* cond = conds + i;
- for (j = 0; j < header_count; j++)
- {
- if (*(cond->condition) == '\0')
- break;
- if (cond->header_hash == hashes[j])
- if (strequals(cond->condition, headers[j]) ||
- strequals(cond->condition, header_values[j]))
+ {
+ with_mutex(mutex,
+ if (errno || (client->open == 0))
+ n = 0;
+ for (i = 0; i < n; i++)
+ {
+ interception_condition_t* cond = conds + i;
+ for (j = 0; j < header_count; j++)
+ {
+ if (*(cond->condition) == '\0')
break;
- }
- if (j < header_count)
- {
- priority = cond->priority;
- modifying = cond->modifying;
- break;
- }
- }
- );
+ if (cond->header_hash == hashes[j])
+ if (strequals(cond->condition, headers[j]) ||
+ strequals(cond->condition, header_values[j]))
+ break;
+ }
+ if (j < header_count)
+ {
+ priority = cond->priority;
+ modifying = cond->modifying;
+ break;
+ }
+ }
+ );
+ }
else
n = 0;