diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-03-25 08:18:47 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-03-25 08:18:47 +0000 |
commit | 2574474f98d5a4feefab2bbd7092c9d0ff9d64e8 (patch) | |
tree | bb769a4ade0c1017940a557faf8611aaf043bc64 /src/fs/gnunet-service-fs_lc.c | |
parent | f094448e150652facb82024f45dea7193650c2bc (diff) | |
download | gnunet-2574474f98d5a4feefab2bbd7092c9d0ff9d64e8.tar.gz gnunet-2574474f98d5a4feefab2bbd7092c9d0ff9d64e8.zip |
fixes
Diffstat (limited to 'src/fs/gnunet-service-fs_lc.c')
-rw-r--r-- | src/fs/gnunet-service-fs_lc.c | 17 |
1 files changed, 16 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_lc.c b/src/fs/gnunet-service-fs_lc.c index 2b069d9ca..8727670e8 100644 --- a/src/fs/gnunet-service-fs_lc.c +++ b/src/fs/gnunet-service-fs_lc.c | |||
@@ -232,12 +232,23 @@ client_response_handler (void *cls, | |||
232 | pm->expiration = GNUNET_TIME_absolute_hton (expiration); | 232 | pm->expiration = GNUNET_TIME_absolute_hton (expiration); |
233 | memcpy (&pm[1], data, data_len); | 233 | memcpy (&pm[1], data, data_len); |
234 | GSF_local_client_transmit_ (lc, &pm->header); | 234 | GSF_local_client_transmit_ (lc, &pm->header); |
235 | 235 | #if DEBUG_FS | |
236 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
237 | "Queued reply to query `%s' for local client\n", | ||
238 | GNUNET_h2s (&prd->query), | ||
239 | (unsigned int) prd->type); | ||
240 | #endif | ||
236 | if (GNUNET_NO == more) | 241 | if (GNUNET_NO == more) |
237 | { | 242 | { |
238 | GNUNET_CONTAINER_DLL_remove (lc->cr_head, | 243 | GNUNET_CONTAINER_DLL_remove (lc->cr_head, |
239 | lc->cr_tail, | 244 | lc->cr_tail, |
240 | cr); | 245 | cr); |
246 | GNUNET_SERVER_receive_done (lc->client, | ||
247 | GNUNET_OK); | ||
248 | GNUNET_STATISTICS_update (GSF_stats, | ||
249 | gettext_noop ("# client searches active"), | ||
250 | - 1, | ||
251 | GNUNET_NO); | ||
241 | GNUNET_free (cr); | 252 | GNUNET_free (cr); |
242 | } | 253 | } |
243 | } | 254 | } |
@@ -469,6 +480,10 @@ GSF_client_disconnect_handler_ (void *cls, | |||
469 | pos->cr_tail, | 480 | pos->cr_tail, |
470 | cr); | 481 | cr); |
471 | GSF_pending_request_cancel_ (cr->pr); | 482 | GSF_pending_request_cancel_ (cr->pr); |
483 | GNUNET_STATISTICS_update (GSF_stats, | ||
484 | gettext_noop ("# client searches active"), | ||
485 | - 1, | ||
486 | GNUNET_NO); | ||
472 | GNUNET_free (cr); | 487 | GNUNET_free (cr); |
473 | } | 488 | } |
474 | while (NULL != (res = pos->res_head)) | 489 | while (NULL != (res = pos->res_head)) |