diff options
author | Christian Grothoff <christian@grothoff.org> | 2018-01-01 15:22:07 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2018-01-01 15:30:04 +0100 |
commit | 4b766fd267ca83a8faa4e22353d5942074d6f2b7 (patch) | |
tree | 8cd218b442028b2c68883667baef2658bccaa49f /src/cadet/test_cadet.c | |
parent | e34b18243af83e8d9ac8da6d96d5b395dae2ced5 (diff) | |
download | gnunet-4b766fd267ca83a8faa4e22353d5942074d6f2b7.tar.gz gnunet-4b766fd267ca83a8faa4e22353d5942074d6f2b7.zip |
remove speed bumps
Diffstat (limited to 'src/cadet/test_cadet.c')
-rw-r--r-- | src/cadet/test_cadet.c | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/src/cadet/test_cadet.c b/src/cadet/test_cadet.c index 6691a0573..bc4414054 100644 --- a/src/cadet/test_cadet.c +++ b/src/cadet/test_cadet.c | |||
@@ -58,6 +58,11 @@ struct CadetTestChannelWrapper | |||
58 | #define SHORT_TIME GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 20) | 58 | #define SHORT_TIME GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 20) |
59 | 59 | ||
60 | /** | 60 | /** |
61 | * How fast do we send messages? | ||
62 | */ | ||
63 | #define SEND_INTERVAL GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, 10) | ||
64 | |||
65 | /** | ||
61 | * DIFFERENT TESTS TO RUN | 66 | * DIFFERENT TESTS TO RUN |
62 | */ | 67 | */ |
63 | #define SETUP 0 | 68 | #define SETUP 0 |
@@ -525,6 +530,7 @@ send_test_message (struct GNUNET_CADET_Channel *channel) | |||
525 | GNUNET_MQ_send (GNUNET_CADET_get_mq (channel), env); | 530 | GNUNET_MQ_send (GNUNET_CADET_get_mq (channel), env); |
526 | } | 531 | } |
527 | 532 | ||
533 | |||
528 | /** | 534 | /** |
529 | * Task to request a new data transmission in a SPEED test, without waiting | 535 | * Task to request a new data transmission in a SPEED test, without waiting |
530 | * for previous messages to be sent/arrrive. | 536 | * for previous messages to be sent/arrrive. |
@@ -537,7 +543,9 @@ send_next_msg (void *cls) | |||
537 | struct GNUNET_CADET_Channel *channel; | 543 | struct GNUNET_CADET_Channel *channel; |
538 | 544 | ||
539 | send_next_msg_task = NULL; | 545 | send_next_msg_task = NULL; |
540 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending next message: %d\n", data_sent); | 546 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
547 | "Sending next message: %d\n", | ||
548 | data_sent); | ||
541 | 549 | ||
542 | channel = GNUNET_YES == test_backwards ? incoming_ch : outgoing_ch; | 550 | channel = GNUNET_YES == test_backwards ? incoming_ch : outgoing_ch; |
543 | GNUNET_assert (NULL != channel); | 551 | GNUNET_assert (NULL != channel); |
@@ -550,9 +558,9 @@ send_next_msg (void *cls) | |||
550 | "Scheduling message %d\n", | 558 | "Scheduling message %d\n", |
551 | data_sent + 1); | 559 | data_sent + 1); |
552 | send_next_msg_task = | 560 | send_next_msg_task = |
553 | GNUNET_SCHEDULER_add_delayed(GNUNET_TIME_UNIT_SECONDS, | 561 | GNUNET_SCHEDULER_add_delayed (SEND_INTERVAL, |
554 | &send_next_msg, | 562 | &send_next_msg, |
555 | NULL); | 563 | NULL); |
556 | } | 564 | } |
557 | } | 565 | } |
558 | 566 | ||