diff options
author | Christian Grothoff <christian@grothoff.org> | 2012-12-10 15:32:30 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2012-12-10 15:32:30 +0000 |
commit | 0f292c9b798f4442d2165756e6daf46d84bcb8b9 (patch) | |
tree | a128202e59f6a457d69085f52107a164d2511002 /src/fs/gnunet-service-fs_lc.c | |
parent | 5d487c87d7c8a51c84ca7c41f08fb3cfc1ed6466 (diff) | |
download | gnunet-0f292c9b798f4442d2165756e6daf46d84bcb8b9.tar.gz gnunet-0f292c9b798f4442d2165756e6daf46d84bcb8b9.zip |
-fix
Diffstat (limited to 'src/fs/gnunet-service-fs_lc.c')
-rw-r--r-- | src/fs/gnunet-service-fs_lc.c | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/fs/gnunet-service-fs_lc.c b/src/fs/gnunet-service-fs_lc.c index fd29c81f9..c3b6f40b0 100644 --- a/src/fs/gnunet-service-fs_lc.c +++ b/src/fs/gnunet-service-fs_lc.c | |||
@@ -275,9 +275,14 @@ client_response_handler (void *cls, enum GNUNET_BLOCK_EvaluationResult eval, | |||
275 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 275 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
276 | "Queued reply to query `%s' for local client\n", | 276 | "Queued reply to query `%s' for local client\n", |
277 | GNUNET_h2s (&prd->query), (unsigned int) prd->type); | 277 | GNUNET_h2s (&prd->query), (unsigned int) prd->type); |
278 | if (eval != GNUNET_BLOCK_EVALUATION_OK_LAST) | 278 | if (GNUNET_BLOCK_EVALUATION_OK_LAST != eval) |
279 | { | ||
280 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
281 | "Evaluation %d - keeping query alive\n", | ||
282 | (int) eval); | ||
279 | return; | 283 | return; |
280 | if (GNUNET_SCHEDULER_NO_TASK != cr->kill_task) | 284 | } |
285 | if (GNUNET_SCHEDULER_NO_TASK == cr->kill_task) | ||
281 | cr->kill_task = GNUNET_SCHEDULER_add_now (&client_request_destroy, cr); | 286 | cr->kill_task = GNUNET_SCHEDULER_add_now (&client_request_destroy, cr); |
282 | } | 287 | } |
283 | 288 | ||
@@ -480,18 +485,13 @@ GSF_client_disconnect_handler_ (void *cls, struct GNUNET_SERVER_Client *client) | |||
480 | pos = client_head; | 485 | pos = client_head; |
481 | while ((pos != NULL) && (pos->client != client)) | 486 | while ((pos != NULL) && (pos->client != client)) |
482 | pos = pos->next; | 487 | pos = pos->next; |
483 | if (pos == NULL) | 488 | if (NULL == pos) |
484 | return; | 489 | return; |
485 | while (NULL != (cr = pos->cr_head)) | 490 | while (NULL != (cr = pos->cr_head)) |
486 | { | 491 | { |
487 | GNUNET_CONTAINER_DLL_remove (pos->cr_head, pos->cr_tail, cr); | ||
488 | GSF_pending_request_cancel_ (cr->pr, GNUNET_YES); | ||
489 | GNUNET_STATISTICS_update (GSF_stats, | ||
490 | gettext_noop ("# client searches active"), -1, | ||
491 | GNUNET_NO); | ||
492 | if (GNUNET_SCHEDULER_NO_TASK != cr->kill_task) | 492 | if (GNUNET_SCHEDULER_NO_TASK != cr->kill_task) |
493 | GNUNET_SCHEDULER_cancel (cr->kill_task); | 493 | GNUNET_SCHEDULER_cancel (cr->kill_task); |
494 | GNUNET_free (cr); | 494 | client_request_destroy (cr, NULL); |
495 | } | 495 | } |
496 | while (NULL != (res = pos->res_head)) | 496 | while (NULL != (res = pos->res_head)) |
497 | { | 497 | { |