diff options
Diffstat (limited to 'src/cadet/test_cadet_flow.c')
-rw-r--r-- | src/cadet/test_cadet_flow.c | 15 |
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 */ |