diff options
Diffstat (limited to 'src/transport/test_transport_api_manipulation_recv_tcp.c')
-rw-r--r-- | src/transport/test_transport_api_manipulation_recv_tcp.c | 16 |
1 files changed, 15 insertions, 1 deletions
diff --git a/src/transport/test_transport_api_manipulation_recv_tcp.c b/src/transport/test_transport_api_manipulation_recv_tcp.c index 3014715b1..69ccf5763 100644 --- a/src/transport/test_transport_api_manipulation_recv_tcp.c +++ b/src/transport/test_transport_api_manipulation_recv_tcp.c | |||
@@ -60,6 +60,16 @@ do_free (void *cls) | |||
60 | 60 | ||
61 | 61 | ||
62 | static void | 62 | static void |
63 | delayed_transmit (void *cls) | ||
64 | { | ||
65 | struct GNUNET_TRANSPORT_TESTING_SendClosure *sc = cls; | ||
66 | |||
67 | start_delayed = GNUNET_TIME_absolute_get (); | ||
68 | GNUNET_TRANSPORT_TESTING_large_send (sc); | ||
69 | } | ||
70 | |||
71 | |||
72 | static void | ||
63 | sendtask (void *cls) | 73 | sendtask (void *cls) |
64 | { | 74 | { |
65 | struct GNUNET_TRANSPORT_TESTING_SendClosure *sc; | 75 | struct GNUNET_TRANSPORT_TESTING_SendClosure *sc; |
@@ -84,7 +94,11 @@ sendtask (void *cls) | |||
84 | &prop, | 94 | &prop, |
85 | delay, | 95 | delay, |
86 | GNUNET_TIME_UNIT_ZERO); | 96 | GNUNET_TIME_UNIT_ZERO); |
87 | start_delayed = GNUNET_TIME_absolute_get(); | 97 | /* wait 1s to allow manipulation to go into effect */ |
98 | GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, | ||
99 | &delayed_transmit, | ||
100 | sc); | ||
101 | return; | ||
88 | } | 102 | } |
89 | GNUNET_TRANSPORT_TESTING_large_send (sc); | 103 | GNUNET_TRANSPORT_TESTING_large_send (sc); |
90 | } | 104 | } |