aboutsummaryrefslogtreecommitdiff
path: root/src/core/gnunet-service-core_clients.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2016-07-26 21:12:56 +0000
committerChristian Grothoff <christian@grothoff.org>2016-07-26 21:12:56 +0000
commit8c2dc7d19810d58f23c43bf900e2fb3eebe06fed (patch)
tree9173a966e2f51a34d9259a0126484e05d44dcaac /src/core/gnunet-service-core_clients.c
parenta89ea716333ad5ad43757a946efc01cb5e95a0c0 (diff)
downloadgnunet-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.c26
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,