diff options
Diffstat (limited to 'src/fs')
-rw-r--r-- | src/fs/fs_download.c | 6 | ||||
-rw-r--r-- | src/fs/fs_list_indexed.c | 2 | ||||
-rw-r--r-- | src/fs/fs_publish.c | 4 | ||||
-rw-r--r-- | src/fs/fs_search.c | 9 | ||||
-rw-r--r-- | src/fs/fs_unindex.c | 6 |
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, | |||
176 | void | 176 | void |
177 | GNUNET_FS_get_indexed_files_cancel (struct GNUNET_FS_GetIndexedContext *gic) | 177 | GNUNET_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) |