diff options
author | Christian Grothoff <christian@grothoff.org> | 2016-07-26 21:12:56 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2016-07-26 21:12:56 +0000 |
commit | 8c2dc7d19810d58f23c43bf900e2fb3eebe06fed (patch) | |
tree | 9173a966e2f51a34d9259a0126484e05d44dcaac /src/core/gnunet-service-core_clients.c | |
parent | a89ea716333ad5ad43757a946efc01cb5e95a0c0 (diff) | |
download | gnunet-8c2dc7d19810d58f23c43bf900e2fb3eebe06fed.tar.gz gnunet-8c2dc7d19810d58f23c43bf900e2fb3eebe06fed.zip |
-converting CORE service to new transport MQ API
Diffstat (limited to 'src/core/gnunet-service-core_clients.c')
-rw-r--r-- | src/core/gnunet-service-core_clients.c | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/src/core/gnunet-service-core_clients.c b/src/core/gnunet-service-core_clients.c index 3030eb701..2f042dfbf 100644 --- a/src/core/gnunet-service-core_clients.c +++ b/src/core/gnunet-service-core_clients.c | |||
@@ -29,7 +29,6 @@ | |||
29 | #include "gnunet_transport_service.h" | 29 | #include "gnunet_transport_service.h" |
30 | #include "gnunet-service-core.h" | 30 | #include "gnunet-service-core.h" |
31 | #include "gnunet-service-core_clients.h" | 31 | #include "gnunet-service-core_clients.h" |
32 | #include "gnunet-service-core_neighbours.h" | ||
33 | #include "gnunet-service-core_sessions.h" | 32 | #include "gnunet-service-core_sessions.h" |
34 | #include "gnunet-service-core_typemap.h" | 33 | #include "gnunet-service-core_typemap.h" |
35 | #include "core.h" | 34 | #include "core.h" |
@@ -402,8 +401,8 @@ handle_client_send_request (void *cls, | |||
402 | /* dequeue and recycle memory from pending request, there can only | 401 | /* dequeue and recycle memory from pending request, there can only |
403 | be at most one per client and peer */ | 402 | be at most one per client and peer */ |
404 | GNUNET_STATISTICS_update (GSC_stats, | 403 | GNUNET_STATISTICS_update (GSC_stats, |
405 | gettext_noop | 404 | gettext_noop ("# dequeuing CAR (duplicate request)"), |
406 | ("# dequeuing CAR (duplicate request)"), 1, | 405 | 1, |
407 | GNUNET_NO); | 406 | GNUNET_NO); |
408 | GSC_SESSIONS_dequeue_request (car); | 407 | GSC_SESSIONS_dequeue_request (car); |
409 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 408 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -476,7 +475,8 @@ handle_client_send (void *cls, | |||
476 | if (msize < sizeof (struct SendMessage)) | 475 | if (msize < sizeof (struct SendMessage)) |
477 | { | 476 | { |
478 | GNUNET_break (0); | 477 | GNUNET_break (0); |
479 | GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); | 478 | GNUNET_SERVER_receive_done (client, |
479 | GNUNET_SYSERR); | ||
480 | return; | 480 | return; |
481 | } | 481 | } |
482 | sm = (const struct SendMessage *) message; | 482 | sm = (const struct SendMessage *) message; |
@@ -487,12 +487,12 @@ handle_client_send (void *cls, | |||
487 | { | 487 | { |
488 | /* client did not send INIT first! */ | 488 | /* client did not send INIT first! */ |
489 | GNUNET_break (0); | 489 | GNUNET_break (0); |
490 | GNUNET_SERVER_receive_done (client, GNUNET_SYSERR); | 490 | GNUNET_SERVER_receive_done (client, |
491 | GNUNET_SYSERR); | ||
491 | return; | 492 | return; |
492 | } | 493 | } |
493 | tc.car | 494 | tc.car = GNUNET_CONTAINER_multipeermap_get (c->requests, |
494 | = GNUNET_CONTAINER_multipeermap_get (c->requests, | 495 | &sm->peer); |
495 | &sm->peer); | ||
496 | if (NULL == tc.car) | 496 | if (NULL == tc.car) |
497 | { | 497 | { |
498 | /* Must have been that we first approved the request, then got disconnected | 498 | /* Must have been that we first approved the request, then got disconnected |
@@ -501,9 +501,9 @@ handle_client_send (void *cls, | |||
501 | * might also now be *again* connected. So this can happen (but should be | 501 | * might also now be *again* connected. So this can happen (but should be |
502 | * rare). If it does happen, the message is discarded. */ | 502 | * rare). If it does happen, the message is discarded. */ |
503 | GNUNET_STATISTICS_update (GSC_stats, | 503 | GNUNET_STATISTICS_update (GSC_stats, |
504 | gettext_noop | 504 | gettext_noop ("# messages discarded (session disconnected)"), |
505 | ("# messages discarded (session disconnected)"), | 505 | 1, |
506 | 1, GNUNET_NO); | 506 | GNUNET_NO); |
507 | GNUNET_SERVER_receive_done (client, | 507 | GNUNET_SERVER_receive_done (client, |
508 | GNUNET_OK); | 508 | GNUNET_OK); |
509 | return; | 509 | return; |
@@ -519,7 +519,7 @@ handle_client_send (void *cls, | |||
519 | GNUNET_YES), | 519 | GNUNET_YES), |
520 | msize, | 520 | msize, |
521 | GNUNET_i2s (&sm->peer), | 521 | GNUNET_i2s (&sm->peer), |
522 | tc.cork ? "" : " (corked)"); | 522 | tc.cork ? " (cork)" : " (uncorked)"); |
523 | else | 523 | else |
524 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 524 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
525 | "Client waited %s for transmission of %u bytes to `%s'%s\n", | 525 | "Client waited %s for transmission of %u bytes to `%s'%s\n", |
@@ -527,7 +527,7 @@ handle_client_send (void *cls, | |||
527 | GNUNET_YES), | 527 | GNUNET_YES), |
528 | msize, | 528 | msize, |
529 | GNUNET_i2s (&sm->peer), | 529 | GNUNET_i2s (&sm->peer), |
530 | tc.cork ? "" : " (corked)"); | 530 | tc.cork ? " (cork)" : " (uncorked)"); |
531 | 531 | ||
532 | GNUNET_assert (GNUNET_YES == | 532 | GNUNET_assert (GNUNET_YES == |
533 | GNUNET_CONTAINER_multipeermap_remove (c->requests, | 533 | GNUNET_CONTAINER_multipeermap_remove (c->requests, |