aboutsummaryrefslogtreecommitdiff
path: root/src/cadet/test_cadet_flow.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/cadet/test_cadet_flow.c')
-rw-r--r--src/cadet/test_cadet_flow.c15
1 files changed, 8 insertions, 7 deletions
diff --git a/src/cadet/test_cadet_flow.c b/src/cadet/test_cadet_flow.c
index 94e1f1c85..2fbdd8d50 100644
--- a/src/cadet/test_cadet_flow.c
+++ b/src/cadet/test_cadet_flow.c
@@ -333,10 +333,10 @@ stats_iterator (void *cls,
333 i = GNUNET_TESTBED_get_index (peer); 333 i = GNUNET_TESTBED_get_index (peer);
334 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "STATS PEER %u - %s [%s]: %llu\n", i, 334 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "STATS PEER %u - %s [%s]: %llu\n", i,
335 subsystem, name, (unsigned long long) value); 335 subsystem, name, (unsigned long long) value);
336 if ((0 == strncmp (s_sent, name, strlen (s_sent)))&&(0 == i)) 336 if ((0 == strncmp (s_sent, name, strlen (s_sent))) && (0 == i))
337 ka_sent = value; 337 ka_sent = value;
338 if ((0 == strncmp (s_recv, name, strlen (s_recv)))&&(peers_requested - 1 == 338 if ((0 == strncmp (s_recv, name, strlen (s_recv))) && (peers_requested - 1 ==
339 i) ) 339 i) )
340 ka_received = value; 340 ka_received = value;
341 if (0 == strncmp (rdrops, name, strlen (rdrops))) 341 if (0 == strncmp (rdrops, name, strlen (rdrops)))
342 msg_dropped += value; 342 msg_dropped += value;
@@ -425,7 +425,7 @@ send_test_message (struct GNUNET_CADET_Channel *channel)
425 if (SPEED_ACK == test) // FIXME unify SPEED_ACK with an initializer 425 if (SPEED_ACK == test) // FIXME unify SPEED_ACK with an initializer
426 data_sent++; 426 data_sent++;
427 } 427 }
428 else if ((SPEED == test)||(SPEED_ACK == test)) 428 else if ((SPEED == test) || (SPEED_ACK == test))
429 { 429 {
430 if (get_target_channel () == channel) 430 if (get_target_channel () == channel)
431 { 431 {
@@ -577,14 +577,14 @@ handle_data (void *cls,
577 } 577 }
578 else /* Got "ack" */ 578 else /* Got "ack" */
579 { 579 {
580 if ((SPEED_ACK == test) ||(SPEED == test) ) 580 if ((SPEED_ACK == test) || (SPEED == test) )
581 { 581 {
582 GNUNET_log (GNUNET_ERROR_TYPE_INFO, " received ack %u\n", ack_received); 582 GNUNET_log (GNUNET_ERROR_TYPE_INFO, " received ack %u\n", ack_received);
583 /* Send more data */ 583 /* Send more data */
584 send_test_message (channel); 584 send_test_message (channel);
585 if ((ack_received < total_packets) &&(SPEED != test) ) 585 if ((ack_received < total_packets) && (SPEED != test) )
586 return; 586 return;
587 if ((ok == 2) &&(SPEED == test) ) 587 if ((ok == 2) && (SPEED == test) )
588 return; 588 return;
589 show_end_data (); 589 show_end_data ();
590 } 590 }
@@ -887,4 +887,5 @@ main (int argc,
887 return 0; 887 return 0;
888} 888}
889 889
890
890/* end of test_cadet_flow.c */ 891/* end of test_cadet_flow.c */