aboutsummaryrefslogtreecommitdiff
path: root/src/dht/gnunet-service-dht_clients.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/dht/gnunet-service-dht_clients.c')
-rw-r--r--src/dht/gnunet-service-dht_clients.c14
1 files changed, 7 insertions, 7 deletions
diff --git a/src/dht/gnunet-service-dht_clients.c b/src/dht/gnunet-service-dht_clients.c
index 20fbba789..f91311cf3 100644
--- a/src/dht/gnunet-service-dht_clients.c
+++ b/src/dht/gnunet-service-dht_clients.c
@@ -199,7 +199,7 @@ struct ClientMonitorRecord
199 * Previous element in DLL. 199 * Previous element in DLL.
200 */ 200 */
201 struct ClientMonitorRecord *prev; 201 struct ClientMonitorRecord *prev;
202 202
203 /** 203 /**
204 * Type of blocks that are of interest 204 * Type of blocks that are of interest
205 */ 205 */
@@ -367,7 +367,7 @@ handle_client_disconnect (void *cls,
367 struct ClientMonitorRecord *monitor; 367 struct ClientMonitorRecord *monitor;
368 368
369 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 369 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
370 "Local client %p disconnects\n", 370 "Local client %p disconnects\n",
371 client); 371 client);
372 pos = find_active_client (client); 372 pos = find_active_client (client);
373 GNUNET_CONTAINER_DLL_remove (client_head, client_tail, pos); 373 GNUNET_CONTAINER_DLL_remove (client_head, client_tail, pos);
@@ -384,7 +384,7 @@ handle_client_disconnect (void *cls,
384 if (monitor->client == pos) 384 if (monitor->client == pos)
385 { 385 {
386 struct ClientMonitorRecord *next; 386 struct ClientMonitorRecord *next;
387 387
388 GNUNET_free_non_null (monitor->key); 388 GNUNET_free_non_null (monitor->key);
389 next = monitor->next; 389 next = monitor->next;
390 GNUNET_CONTAINER_DLL_remove (monitor_head, monitor_tail, monitor); 390 GNUNET_CONTAINER_DLL_remove (monitor_head, monitor_tail, monitor);
@@ -550,7 +550,7 @@ handle_dht_local_put (void *cls, struct GNUNET_SERVER_Client *client,
550 &dht_msg[1], 550 &dht_msg[1],
551 size - sizeof (struct GNUNET_DHT_ClientPutMessage)); 551 size - sizeof (struct GNUNET_DHT_ClientPutMessage));
552 GNUNET_CONTAINER_bloomfilter_free (peer_bf); 552 GNUNET_CONTAINER_bloomfilter_free (peer_bf);
553 pm = GNUNET_malloc (sizeof (struct PendingMessage) + 553 pm = GNUNET_malloc (sizeof (struct PendingMessage) +
554 sizeof (struct GNUNET_DHT_ClientPutConfirmationMessage)); 554 sizeof (struct GNUNET_DHT_ClientPutConfirmationMessage));
555 conf = (struct GNUNET_DHT_ClientPutConfirmationMessage *) &pm[1]; 555 conf = (struct GNUNET_DHT_ClientPutConfirmationMessage *) &pm[1];
556 conf->header.size = htons (sizeof (struct GNUNET_DHT_ClientPutConfirmationMessage)); 556 conf->header.size = htons (sizeof (struct GNUNET_DHT_ClientPutConfirmationMessage));
@@ -884,7 +884,7 @@ handle_dht_local_monitor_stop (void *cls, struct GNUNET_SERVER_Client *client,
884 } 884 }
885 r = r->next; 885 r = r->next;
886 } 886 }
887 887
888 GNUNET_SERVER_receive_done (client, GNUNET_OK); 888 GNUNET_SERVER_receive_done (client, GNUNET_OK);
889} 889}
890 890
@@ -1226,7 +1226,7 @@ void
1226GDS_CLIENTS_process_get (uint32_t options, 1226GDS_CLIENTS_process_get (uint32_t options,
1227 enum GNUNET_BLOCK_Type type, 1227 enum GNUNET_BLOCK_Type type,
1228 uint32_t hop_count, 1228 uint32_t hop_count,
1229 uint32_t desired_replication_level, 1229 uint32_t desired_replication_level,
1230 unsigned int path_length, 1230 unsigned int path_length,
1231 const struct GNUNET_PeerIdentity *path, 1231 const struct GNUNET_PeerIdentity *path,
1232 const struct GNUNET_HashCode * key) 1232 const struct GNUNET_HashCode * key)
@@ -1386,7 +1386,7 @@ void
1386GDS_CLIENTS_process_put (uint32_t options, 1386GDS_CLIENTS_process_put (uint32_t options,
1387 enum GNUNET_BLOCK_Type type, 1387 enum GNUNET_BLOCK_Type type,
1388 uint32_t hop_count, 1388 uint32_t hop_count,
1389 uint32_t desired_replication_level, 1389 uint32_t desired_replication_level,
1390 unsigned int path_length, 1390 unsigned int path_length,
1391 const struct GNUNET_PeerIdentity *path, 1391 const struct GNUNET_PeerIdentity *path,
1392 struct GNUNET_TIME_Absolute exp, 1392 struct GNUNET_TIME_Absolute exp,