aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/gnunet-cadet-profiler.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/cadet/gnunet-cadet-profiler.c')
-rw-r--r--src/cadet/gnunet-cadet-profiler.c11
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 */