diff options
Diffstat (limited to 'src/cadet/gnunet-cadet-profiler.c')
-rw-r--r-- | src/cadet/gnunet-cadet-profiler.c | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/src/cadet/gnunet-cadet-profiler.c b/src/cadet/gnunet-cadet-profiler.c index e66761e1e..c3a19a399 100644 --- a/src/cadet/gnunet-cadet-profiler.c +++ b/src/cadet/gnunet-cadet-profiler.c | |||
@@ -407,6 +407,7 @@ abort_test (long line) | |||
407 | } | 407 | } |
408 | } | 408 | } |
409 | 409 | ||
410 | |||
410 | /** | 411 | /** |
411 | * Stats callback. Finish the stats testbed operation and when all stats have | 412 | * Stats callback. Finish the stats testbed operation and when all stats have |
412 | * been iterated, shutdown the test. | 413 | * been iterated, shutdown the test. |
@@ -615,7 +616,7 @@ tmt_rdy_pong (void *cls, size_t size, void *buf) | |||
615 | struct CadetPingMessage *ping = cls; | 616 | struct CadetPingMessage *ping = cls; |
616 | struct CadetPingMessage *pong; | 617 | struct CadetPingMessage *pong; |
617 | 618 | ||
618 | if ((0 == size)||(NULL == buf)) | 619 | if ((0 == size) || (NULL == buf)) |
619 | { | 620 | { |
620 | GNUNET_free (ping); | 621 | GNUNET_free (ping); |
621 | return 0; | 622 | return 0; |
@@ -654,6 +655,7 @@ ping (void *cls) | |||
654 | &tmt_rdy_ping, peer); | 655 | &tmt_rdy_ping, peer); |
655 | } | 656 | } |
656 | 657 | ||
658 | |||
657 | /** | 659 | /** |
658 | * @brief Reply with a pong to origin. | 660 | * @brief Reply with a pong to origin. |
659 | * | 661 | * |
@@ -691,7 +693,7 @@ tmt_rdy_ping (void *cls, size_t size, void *buf) | |||
691 | peer->ping_ntr = NULL; | 693 | peer->ping_ntr = NULL; |
692 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 694 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
693 | "tmt_rdy called, filling buffer\n"); | 695 | "tmt_rdy called, filling buffer\n"); |
694 | if ((size < sizeof(struct CadetPingMessage))||(NULL == buf)) | 696 | if ((size < sizeof(struct CadetPingMessage)) || (NULL == buf)) |
695 | { | 697 | { |
696 | GNUNET_break (GNUNET_YES == test_finished); | 698 | GNUNET_break (GNUNET_YES == test_finished); |
697 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 699 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -857,6 +859,7 @@ incoming_channel (void *cls, struct GNUNET_CADET_Channel *channel, | |||
857 | return NULL; | 859 | return NULL; |
858 | } | 860 | } |
859 | 861 | ||
862 | |||
860 | /** | 863 | /** |
861 | * Function called whenever an inbound channel is destroyed. Should clean up | 864 | * Function called whenever an inbound channel is destroyed. Should clean up |
862 | * any associated state. | 865 | * any associated state. |
@@ -903,6 +906,7 @@ select_random_peer (struct CadetPeer *peer) | |||
903 | return &peers[r]; | 906 | return &peers[r]; |
904 | } | 907 | } |
905 | 908 | ||
909 | |||
906 | /** | 910 | /** |
907 | * START THE TEST ITSELF, AS WE ARE CONNECTED TO THE CADET SERVICES. | 911 | * START THE TEST ITSELF, AS WE ARE CONNECTED TO THE CADET SERVICES. |
908 | * | 912 | * |
@@ -999,7 +1003,7 @@ peer_id_cb (void *cls, | |||
999 | { | 1003 | { |
1000 | long n = (long) cls; | 1004 | long n = (long) cls; |
1001 | 1005 | ||
1002 | if ((NULL == pinfo)||(NULL != emsg)) | 1006 | if ((NULL == pinfo) || (NULL != emsg)) |
1003 | { | 1007 | { |
1004 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "pi_cb: %s\n", emsg); | 1008 | GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "pi_cb: %s\n", emsg); |
1005 | abort_test (__LINE__); | 1009 | abort_test (__LINE__); |
@@ -1151,4 +1155,5 @@ main (int argc, char *argv[]) | |||
1151 | return 0; | 1155 | return 0; |
1152 | } | 1156 | } |
1153 | 1157 | ||
1158 | |||
1154 | /* end of gnunet-cadet-profiler.c */ | 1159 | /* end of gnunet-cadet-profiler.c */ |