X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=citadel%2Fmodules%2Fnetwork%2Fserv_network.c;h=55d8fd370312ef79c4df83e18bddc76730a66a84;hb=0ca1d79e24b57ed59ab3c2e81f04c9463c3a1c5b;hp=6c8db4bf65a73be29e1cd83042c8229bf2ccd189;hpb=2dff3764daf64c3ad1cabd92da2385331e05db3a;p=citadel.git

diff --git a/citadel/modules/network/serv_network.c b/citadel/modules/network/serv_network.c
index 6c8db4bf6..55d8fd370 100644
--- a/citadel/modules/network/serv_network.c
+++ b/citadel/modules/network/serv_network.c
@@ -261,7 +261,6 @@ void network_queue_room(struct ctdlroom *qrbuf, void *data) {
 void destroy_network_queue_room(void)
 {
 	struct RoomProcList *cur, *p;
-	NetMap *nmcur, *nmp;
 
 	cur = rplist;
 	begin_critical_section(S_RPLIST);
@@ -273,18 +272,6 @@ void destroy_network_queue_room(void)
 	}
 	rplist = NULL;
 	end_critical_section(S_RPLIST);
-
-	nmcur = the_netmap;
-	while (nmcur != NULL)
-	{
-		nmp = nmcur->next;
-		free (nmcur);
-		nmcur = nmp;		
-	}
-	the_netmap = NULL;
-	if (working_ignetcfg != NULL)
-		free (working_ignetcfg);
-	working_ignetcfg = NULL;
 }
 
 
@@ -407,6 +394,9 @@ void network_do_queue(void) {
 	static time_t last_run = 0L;
 	struct RoomProcList *ptr;
 	int full_processing = 1;
+	char *working_ignetcfg;
+	NetMap *the_netmap = NULL;
+	int netmap_changed = 0;
 
 	/*
 	 * Run the full set of processing tasks no more frequently
@@ -431,12 +421,12 @@ void network_do_queue(void) {
 	doing_queue = 1;
 
 	/* Load the IGnet Configuration into memory */
-	load_working_ignetcfg();
+	working_ignetcfg = load_working_ignetcfg();
 
 	/*
 	 * Load the network map and filter list into memory.
 	 */
-	read_network_map();
+	the_netmap = read_network_map();
 	load_network_filter_list();
 
 	/* 
@@ -475,16 +465,19 @@ void network_do_queue(void) {
 
 	/* If there is anything in the inbound queue, process it */
 	if (!server_shutting_down) {
-		network_do_spoolin();
+		network_do_spoolin(working_ignetcfg, 
+				   the_netmap,
+				   &netmap_changed);
 	}
 
 	/* Save the network map back to disk */
-	write_network_map();
+	write_network_map(the_netmap, netmap_changed);
 
 	/* Free the filter list in memory */
 	free_netfilter_list();
 
-	network_consolidate_spoolout();
+	network_consolidate_spoolout(working_ignetcfg, the_netmap);
+	free(working_ignetcfg);
 
 	syslog(LOG_DEBUG, "network: queue run completed\n");