2 This file is part of GNUnet.
3 Copyright (C) 2009, 2010, 2016 GNUnet e.V.
5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details.
15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>.
19 * @file transport/test_transport_api_manipulation_cfg.c
20 * @brief base test case for transport traffic manipulation implementation
23 * Peer 1 has inbound and outbound delay of 100ms
24 * Peer 2 has no inbound and outbound delay
26 * We send a request from P1 to P2 and expect delay of >= TEST_DELAY us
27 * Then we send response from P2 to P1 and expect delay of >= TEST_DELAY us
30 #include "gnunet_transport_service.h"
31 #include "transport-testing.h"
34 * How long until we give up on transmitting the message?
36 #define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 120)
39 #define TEST_MESSAGE_SIZE 2600
41 #define TEST_RESPONSE_MESSAGE_TYPE
44 * Test delay, in microseconds.
46 #define TEST_DELAY 100 * 1000LL
49 static struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc;
51 static struct GNUNET_TIME_Absolute start_request;
53 static struct GNUNET_TIME_Absolute start_response;
57 sendtask_response_task (void *cls)
61 start_response = GNUNET_TIME_absolute_get();
62 ret = GNUNET_TRANSPORT_TESTING_send (ccc->p[1],
64 GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2,
72 GNUNET_SCHEDULER_shutdown ();
75 GNUNET_assert (GNUNET_SYSERR != ret);
80 notify_receive (void *cls,
81 struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver,
82 const struct GNUNET_PeerIdentity *sender,
83 const struct GNUNET_TRANSPORT_TESTING_TestMessage *message)
85 struct GNUNET_TIME_Relative duration;
88 char *ps = GNUNET_strdup (GNUNET_i2s (&receiver->id));
90 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
91 "Peer %u (`%s') received message of type %d and size %u size from peer %s)!\n",
94 ntohs (message->header.type),
95 ntohs (message->header.size),
100 switch (ntohs (message->header.type)) {
101 case GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE:
102 duration = GNUNET_TIME_absolute_get_difference (start_request,
103 GNUNET_TIME_absolute_get());
104 if (duration.rel_value_us >= TEST_DELAY)
106 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
107 "Request message was delayed for %s\n",
108 GNUNET_STRINGS_relative_time_to_string (duration,
113 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
114 "Request message was delayed for unexpected duration %s\n",
115 GNUNET_STRINGS_relative_time_to_string (duration,
117 ccc->global_ret = GNUNET_SYSERR;
118 GNUNET_SCHEDULER_shutdown ();
121 GNUNET_SCHEDULER_add_now (&sendtask_response_task,
124 case GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE2:
125 duration = GNUNET_TIME_absolute_get_difference(start_response,
126 GNUNET_TIME_absolute_get());
127 if (duration.rel_value_us >= TEST_DELAY)
129 GNUNET_log (GNUNET_ERROR_TYPE_INFO,
130 "Response message was delayed for %s\n",
131 GNUNET_STRINGS_relative_time_to_string (duration,
133 ccc->global_ret = GNUNET_OK;
137 GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
138 "Response message was delayed for unexpected duration %s\n",
139 GNUNET_STRINGS_relative_time_to_string (duration,
141 ccc->global_ret = GNUNET_SYSERR;
143 GNUNET_SCHEDULER_shutdown ();
156 struct GNUNET_TRANSPORT_TESTING_SendClosure sc = {
159 struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext my_ccc = {
160 .connect_continuation = &GNUNET_TRANSPORT_TESTING_large_send,
161 .connect_continuation_cls = &sc,
162 .config_file = "test_transport_api_data.conf",
163 .rec = ¬ify_receive,
164 .nc = &GNUNET_TRANSPORT_TESTING_log_connect,
165 .nd = &GNUNET_TRANSPORT_TESTING_log_disconnect,
171 start_request = GNUNET_TIME_absolute_get ();
173 GNUNET_TRANSPORT_TESTING_main (2,
174 &GNUNET_TRANSPORT_TESTING_connect_check,
181 /* end of test_transport_api_manipulation_cfg.c */