aboutsummaryrefslogtreecommitdiff
path: root/src/fs
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs')
-rw-r--r--src/fs/fs_download.c6
-rw-r--r--src/fs/fs_list_indexed.c2
-rw-r--r--src/fs/fs_publish.c4
-rw-r--r--src/fs/fs_search.c9
-rw-r--r--src/fs/fs_unindex.c6
5 files changed, 13 insertions, 14 deletions
diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c
index 8ae4a29fb..e93db4cfd 100644
--- a/src/fs/fs_download.c
+++ b/src/fs/fs_download.c
@@ -1166,7 +1166,7 @@ signal_error:
1166 GNUNET_CLIENT_notify_transmit_ready_cancel (dc->th); 1166 GNUNET_CLIENT_notify_transmit_ready_cancel (dc->th);
1167 dc->th = NULL; 1167 dc->th = NULL;
1168 } 1168 }
1169 GNUNET_CLIENT_disconnect (dc->client, GNUNET_NO); 1169 GNUNET_CLIENT_disconnect (dc->client);
1170 dc->in_receive = GNUNET_NO; 1170 dc->in_receive = GNUNET_NO;
1171 dc->client = NULL; 1171 dc->client = NULL;
1172 GNUNET_FS_free_download_request_ (dc->top_request); 1172 GNUNET_FS_free_download_request_ (dc->top_request);
@@ -1404,7 +1404,7 @@ try_reconnect (struct GNUNET_FS_DownloadContext *dc)
1404 dc->pending_head = NULL; 1404 dc->pending_head = NULL;
1405 dc->pending_tail = NULL; 1405 dc->pending_tail = NULL;
1406 GNUNET_CONTAINER_multihashmap_iterate (dc->active, &retry_entry, dc); 1406 GNUNET_CONTAINER_multihashmap_iterate (dc->active, &retry_entry, dc);
1407 GNUNET_CLIENT_disconnect (dc->client, GNUNET_NO); 1407 GNUNET_CLIENT_disconnect (dc->client);
1408 dc->in_receive = GNUNET_NO; 1408 dc->in_receive = GNUNET_NO;
1409 dc->client = NULL; 1409 dc->client = NULL;
1410 } 1410 }
@@ -1471,7 +1471,7 @@ deactivate_fs_download (void *cls)
1471 } 1471 }
1472 if (NULL != dc->client) 1472 if (NULL != dc->client)
1473 { 1473 {
1474 GNUNET_CLIENT_disconnect (dc->client, GNUNET_NO); 1474 GNUNET_CLIENT_disconnect (dc->client);
1475 dc->in_receive = GNUNET_NO; 1475 dc->in_receive = GNUNET_NO;
1476 dc->client = NULL; 1476 dc->client = NULL;
1477 } 1477 }
diff --git a/src/fs/fs_list_indexed.c b/src/fs/fs_list_indexed.c
index 784c9881a..ef03dee76 100644
--- a/src/fs/fs_list_indexed.c
+++ b/src/fs/fs_list_indexed.c
@@ -176,7 +176,7 @@ GNUNET_FS_get_indexed_files (struct GNUNET_FS_Handle *h,
176void 176void
177GNUNET_FS_get_indexed_files_cancel (struct GNUNET_FS_GetIndexedContext *gic) 177GNUNET_FS_get_indexed_files_cancel (struct GNUNET_FS_GetIndexedContext *gic)
178{ 178{
179 GNUNET_CLIENT_disconnect (gic->client, GNUNET_NO); 179 GNUNET_CLIENT_disconnect (gic->client);
180 GNUNET_free (gic); 180 GNUNET_free (gic);
181} 181}
182 182
diff --git a/src/fs/fs_publish.c b/src/fs/fs_publish.c
index e0a6f046a..3d83beef8 100644
--- a/src/fs/fs_publish.c
+++ b/src/fs/fs_publish.c
@@ -98,7 +98,7 @@ publish_cleanup (struct GNUNET_FS_PublishContext *pc)
98 } 98 }
99 if (pc->client != NULL) 99 if (pc->client != NULL)
100 { 100 {
101 GNUNET_CLIENT_disconnect (pc->client, GNUNET_NO); 101 GNUNET_CLIENT_disconnect (pc->client);
102 pc->client = NULL; 102 pc->client = NULL;
103 } 103 }
104 GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == pc->upload_task); 104 GNUNET_assert (GNUNET_SCHEDULER_NO_TASK == pc->upload_task);
@@ -611,7 +611,7 @@ process_index_start_response (void *cls, const struct GNUNET_MessageHeader *msg)
611 const char *emsg; 611 const char *emsg;
612 uint16_t msize; 612 uint16_t msize;
613 613
614 GNUNET_CLIENT_disconnect (pc->client, GNUNET_NO); 614 GNUNET_CLIENT_disconnect (pc->client);
615 pc->client = NULL; 615 pc->client = NULL;
616 p = pc->fi_pos; 616 p = pc->fi_pos;
617 if (msg == NULL) 617 if (msg == NULL)
diff --git a/src/fs/fs_search.c b/src/fs/fs_search.c
index 94a77e136..ef3e66fbc 100644
--- a/src/fs/fs_search.c
+++ b/src/fs/fs_search.c
@@ -30,7 +30,6 @@
30#include "gnunet_protocols.h" 30#include "gnunet_protocols.h"
31#include "fs_api.h" 31#include "fs_api.h"
32 32
33#define DEBUG_SEARCH GNUNET_EXTRA_LOGGING
34 33
35/** 34/**
36 * Number of availability trials we perform per search result. 35 * Number of availability trials we perform per search result.
@@ -1152,7 +1151,7 @@ try_reconnect (struct GNUNET_FS_SearchContext *sc)
1152{ 1151{
1153 if (NULL != sc->client) 1152 if (NULL != sc->client)
1154 { 1153 {
1155 GNUNET_CLIENT_disconnect (sc->client, GNUNET_NO); 1154 GNUNET_CLIENT_disconnect (sc->client);
1156 sc->client = NULL; 1155 sc->client = NULL;
1157 } 1156 }
1158 sc->task = 1157 sc->task =
@@ -1369,7 +1368,7 @@ GNUNET_FS_search_signal_suspend_ (void *cls)
1369 if (sc->task != GNUNET_SCHEDULER_NO_TASK) 1368 if (sc->task != GNUNET_SCHEDULER_NO_TASK)
1370 GNUNET_SCHEDULER_cancel (sc->task); 1369 GNUNET_SCHEDULER_cancel (sc->task);
1371 if (NULL != sc->client) 1370 if (NULL != sc->client)
1372 GNUNET_CLIENT_disconnect (sc->client, GNUNET_NO); 1371 GNUNET_CLIENT_disconnect (sc->client);
1373 GNUNET_CONTAINER_multihashmap_destroy (sc->master_result_map); 1372 GNUNET_CONTAINER_multihashmap_destroy (sc->master_result_map);
1374 if (sc->requests != NULL) 1373 if (sc->requests != NULL)
1375 { 1374 {
@@ -1425,7 +1424,7 @@ GNUNET_FS_search_pause (struct GNUNET_FS_SearchContext *sc)
1425 GNUNET_SCHEDULER_cancel (sc->task); 1424 GNUNET_SCHEDULER_cancel (sc->task);
1426 sc->task = GNUNET_SCHEDULER_NO_TASK; 1425 sc->task = GNUNET_SCHEDULER_NO_TASK;
1427 if (NULL != sc->client) 1426 if (NULL != sc->client)
1428 GNUNET_CLIENT_disconnect (sc->client, GNUNET_NO); 1427 GNUNET_CLIENT_disconnect (sc->client);
1429 sc->client = NULL; 1428 sc->client = NULL;
1430 GNUNET_FS_search_sync_ (sc); 1429 GNUNET_FS_search_sync_ (sc);
1431 GNUNET_CONTAINER_multihashmap_iterate (sc->master_result_map, 1430 GNUNET_CONTAINER_multihashmap_iterate (sc->master_result_map,
@@ -1569,7 +1568,7 @@ GNUNET_FS_search_stop (struct GNUNET_FS_SearchContext *sc)
1569 if (sc->task != GNUNET_SCHEDULER_NO_TASK) 1568 if (sc->task != GNUNET_SCHEDULER_NO_TASK)
1570 GNUNET_SCHEDULER_cancel (sc->task); 1569 GNUNET_SCHEDULER_cancel (sc->task);
1571 if (NULL != sc->client) 1570 if (NULL != sc->client)
1572 GNUNET_CLIENT_disconnect (sc->client, GNUNET_NO); 1571 GNUNET_CLIENT_disconnect (sc->client);
1573 GNUNET_CONTAINER_multihashmap_iterate (sc->master_result_map, 1572 GNUNET_CONTAINER_multihashmap_iterate (sc->master_result_map,
1574 &search_result_free, sc); 1573 &search_result_free, sc);
1575 GNUNET_CONTAINER_multihashmap_destroy (sc->master_result_map); 1574 GNUNET_CONTAINER_multihashmap_destroy (sc->master_result_map);
diff --git a/src/fs/fs_unindex.c b/src/fs/fs_unindex.c
index bf619b75a..fa71b56bc 100644
--- a/src/fs/fs_unindex.c
+++ b/src/fs/fs_unindex.c
@@ -223,7 +223,7 @@ process_fs_response (void *cls, const struct GNUNET_MessageHeader *msg)
223 223
224 if (uc->client != NULL) 224 if (uc->client != NULL)
225 { 225 {
226 GNUNET_CLIENT_disconnect (uc->client, GNUNET_NO); 226 GNUNET_CLIENT_disconnect (uc->client);
227 uc->client = NULL; 227 uc->client = NULL;
228 } 228 }
229 if (uc->state != UNINDEX_STATE_FS_NOTIFY) 229 if (uc->state != UNINDEX_STATE_FS_NOTIFY)
@@ -708,7 +708,7 @@ GNUNET_FS_unindex_signal_suspend_ (void *cls)
708 } 708 }
709 if (uc->client != NULL) 709 if (uc->client != NULL)
710 { 710 {
711 GNUNET_CLIENT_disconnect (uc->client, GNUNET_NO); 711 GNUNET_CLIENT_disconnect (uc->client);
712 uc->client = NULL; 712 uc->client = NULL;
713 } 713 }
714 if (NULL != uc->dsh) 714 if (NULL != uc->dsh)
@@ -803,7 +803,7 @@ GNUNET_FS_unindex_stop (struct GNUNET_FS_UnindexContext *uc)
803 } 803 }
804 if (uc->client != NULL) 804 if (uc->client != NULL)
805 { 805 {
806 GNUNET_CLIENT_disconnect (uc->client, GNUNET_NO); 806 GNUNET_CLIENT_disconnect (uc->client);
807 uc->client = NULL; 807 uc->client = NULL;
808 } 808 }
809 if (NULL != uc->dsh) 809 if (NULL != uc->dsh)