aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_lc.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2012-12-10 15:32:30 +0000
committerChristian Grothoff <christian@grothoff.org>2012-12-10 15:32:30 +0000
commit0f292c9b798f4442d2165756e6daf46d84bcb8b9 (patch)
treea128202e59f6a457d69085f52107a164d2511002 /src/fs/gnunet-service-fs_lc.c
parent5d487c87d7c8a51c84ca7c41f08fb3cfc1ed6466 (diff)
downloadgnunet-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.c18
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 {