aboutsummaryrefslogtreecommitdiff
path: root/src/transport
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport')
-rw-r--r--src/transport/gnunet-transport-connect-running-peers.c4
-rw-r--r--src/transport/gnunet-transport.c28
-rw-r--r--src/transport/test_quota_compliance.c10
-rw-r--r--src/transport/test_transport_api.c2
-rw-r--r--src/transport/test_transport_api_bidirectional_connect.c2
-rw-r--r--src/transport/test_transport_api_disconnect.c2
-rw-r--r--src/transport/test_transport_api_limited_sockets.c2
-rw-r--r--src/transport/test_transport_api_reliability.c8
-rw-r--r--src/transport/test_transport_api_restart_1peer.c2
-rw-r--r--src/transport/test_transport_api_restart_2peers.c2
-rw-r--r--src/transport/test_transport_api_timeout.c6
-rw-r--r--src/transport/test_transport_api_unreliability.c8
-rw-r--r--src/transport/test_transport_api_unreliability_constant.c10
-rw-r--r--src/transport/test_transport_startonly.c6
14 files changed, 46 insertions, 46 deletions
diff --git a/src/transport/gnunet-transport-connect-running-peers.c b/src/transport/gnunet-transport-connect-running-peers.c
index 172f34b27..8ba81891f 100644
--- a/src/transport/gnunet-transport-connect-running-peers.c
+++ b/src/transport/gnunet-transport-connect-running-peers.c
@@ -73,7 +73,7 @@ char *cfg_file_p1;
73char *cfg_file_p2; 73char *cfg_file_p2;
74 74
75#if VERBOSE 75#if VERBOSE
76#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 76#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
77#else 77#else
78#define OKPP do { ok++; } while (0) 78#define OKPP do { ok++; } while (0)
79#endif 79#endif
@@ -368,7 +368,7 @@ main (int argc, char *argv[])
368 368
369 if (argc < 3) 369 if (argc < 3)
370 { 370 {
371 fprintf (stderr, 371 FPRINTF (stderr,
372 "usage gnunet-transport-connect-running-peers <cfg_peer1> <cfg_peer2>\n"); 372 "usage gnunet-transport-connect-running-peers <cfg_peer1> <cfg_peer2>\n");
373 return -1; 373 return -1;
374 } 374 }
diff --git a/src/transport/gnunet-transport.c b/src/transport/gnunet-transport.c
index 02a5ee492..17a21dd28 100644
--- a/src/transport/gnunet-transport.c
+++ b/src/transport/gnunet-transport.c
@@ -167,11 +167,11 @@ display_test_result (struct TestContext *tc, int result)
167{ 167{
168 if (GNUNET_YES != result) 168 if (GNUNET_YES != result)
169 { 169 {
170 fprintf (stderr, "Configuration for plugin `%s' did not work!\n", tc->name); 170 FPRINTF (stderr, "Configuration for plugin `%s' did not work!\n", tc->name);
171 } 171 }
172 else 172 else
173 { 173 {
174 fprintf (stderr, "Configuration for plugin `%s' is working!\n", tc->name); 174 FPRINTF (stderr, "Configuration for plugin `%s' is working!\n", tc->name);
175 } 175 }
176 if (GNUNET_SCHEDULER_NO_TASK != tc->tsk) 176 if (GNUNET_SCHEDULER_NO_TASK != tc->tsk)
177 { 177 {
@@ -245,9 +245,9 @@ do_test_configuration (const struct GNUNET_CONFIGURATION_Handle *cfg)
245 GNUNET_CONFIGURATION_get_value_string (cfg, "transport", "plugins", 245 GNUNET_CONFIGURATION_get_value_string (cfg, "transport", "plugins",
246 &plugins)) 246 &plugins))
247 { 247 {
248 fprintf (stderr, 248 FPRINTF (stderr,
249 _ 249 _
250 ("No transport plugins configured, peer will never communicate\n")); 250 ("No transport plugins configured, peer will never communicate\n"), NULL);
251 ret = 4; 251 ret = 4;
252 return; 252 return;
253 } 253 }
@@ -259,7 +259,7 @@ do_test_configuration (const struct GNUNET_CONFIGURATION_Handle *cfg)
259 if (GNUNET_OK != 259 if (GNUNET_OK !=
260 GNUNET_CONFIGURATION_get_value_number (cfg, section, "PORT", &bnd_port)) 260 GNUNET_CONFIGURATION_get_value_number (cfg, section, "PORT", &bnd_port))
261 { 261 {
262 fprintf (stderr, 262 FPRINTF (stderr,
263 _("No port configured for plugin `%s', cannot test it\n"), tok); 263 _("No port configured for plugin `%s', cannot test it\n"), tok);
264 continue; 264 continue;
265 } 265 }
@@ -310,14 +310,14 @@ do_disconnect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
310 if (benchmark_receive) 310 if (benchmark_receive)
311 { 311 {
312 duration = GNUNET_TIME_absolute_get_duration (start_time); 312 duration = GNUNET_TIME_absolute_get_duration (start_time);
313 fprintf (stdout, _("Received %llu bytes/s (%llu bytes in %llu ms)\n"), 313 FPRINTF (stdout, _("Received %llu bytes/s (%llu bytes in %llu ms)\n"),
314 1000 * traffic_received / (1 + duration.rel_value), 314 1000 * traffic_received / (1 + duration.rel_value),
315 traffic_received, (unsigned long long) duration.rel_value); 315 traffic_received, (unsigned long long) duration.rel_value);
316 } 316 }
317 if (benchmark_send) 317 if (benchmark_send)
318 { 318 {
319 duration = GNUNET_TIME_absolute_get_duration (start_time); 319 duration = GNUNET_TIME_absolute_get_duration (start_time);
320 fprintf (stdout, _("Transmitted %llu bytes/s (%llu bytes in %llu ms)\n"), 320 FPRINTF (stdout, _("Transmitted %llu bytes/s (%llu bytes in %llu ms)\n"),
321 1000 * traffic_sent / (1 + duration.rel_value), traffic_sent, 321 1000 * traffic_sent / (1 + duration.rel_value), traffic_sent,
322 (unsigned long long) duration.rel_value); 322 (unsigned long long) duration.rel_value);
323 } 323 }
@@ -350,7 +350,7 @@ transmit_data (void *cls, size_t size, void *buf)
350 GNUNET_TIME_UNIT_FOREVER_REL, 350 GNUNET_TIME_UNIT_FOREVER_REL,
351 &transmit_data, NULL); 351 &transmit_data, NULL);
352 if (verbosity > 0) 352 if (verbosity > 0)
353 fprintf (stdout, _("Transmitting %u bytes to %s\n"), (unsigned int) size, 353 FPRINTF (stdout, _("Transmitting %u bytes to %s\n"), (unsigned int) size,
354 GNUNET_i2s (&pid)); 354 GNUNET_i2s (&pid));
355 return size; 355 return size;
356} 356}
@@ -370,7 +370,7 @@ notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer,
370 const struct GNUNET_ATS_Information *ats, uint32_t ats_count) 370 const struct GNUNET_ATS_Information *ats, uint32_t ats_count)
371{ 371{
372 if (verbosity > 0) 372 if (verbosity > 0)
373 fprintf (stdout, _("Connected to %s\n"), GNUNET_i2s (peer)); 373 FPRINTF (stdout, _("Connected to %s\n"), GNUNET_i2s (peer));
374 if (0 != memcmp (&pid, peer, sizeof (struct GNUNET_PeerIdentity))) 374 if (0 != memcmp (&pid, peer, sizeof (struct GNUNET_PeerIdentity)))
375 return; 375 return;
376 ret = 0; 376 ret = 0;
@@ -401,7 +401,7 @@ static void
401notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) 401notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer)
402{ 402{
403 if (verbosity > 0) 403 if (verbosity > 0)
404 fprintf (stdout, _("Disconnected from %s\n"), GNUNET_i2s (peer)); 404 FPRINTF (stdout, _("Disconnected from %s\n"), GNUNET_i2s (peer));
405 if ((0 == memcmp (&pid, peer, sizeof (struct GNUNET_PeerIdentity))) && 405 if ((0 == memcmp (&pid, peer, sizeof (struct GNUNET_PeerIdentity))) &&
406 (NULL != th)) 406 (NULL != th))
407 { 407 {
@@ -430,7 +430,7 @@ notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer,
430 if (!benchmark_receive) 430 if (!benchmark_receive)
431 return; 431 return;
432 if (verbosity > 0) 432 if (verbosity > 0)
433 fprintf (stdout, _("Received %u bytes from %s\n"), 433 FPRINTF (stdout, _("Received %u bytes from %s\n"),
434 (unsigned int) ntohs (message->size), GNUNET_i2s (peer)); 434 (unsigned int) ntohs (message->size), GNUNET_i2s (peer));
435 if (traffic_received == 0) 435 if (traffic_received == 0)
436 start_time = GNUNET_TIME_absolute_get (); 436 start_time = GNUNET_TIME_absolute_get ();
@@ -444,7 +444,7 @@ process_string (void *cls, const char *address)
444 444
445 if ((address != NULL)) 445 if ((address != NULL))
446 { 446 {
447 fprintf (stdout, _("Peer `%s': %s %s\n"), GNUNET_i2s (&addrcp->peer), addrcp->transport_name, address); 447 FPRINTF (stdout, _("Peer `%s': %s %s\n"), GNUNET_i2s (&addrcp->peer), addrcp->transport_name, address);
448 } 448 }
449 else 449 else
450 { 450 {
@@ -499,7 +499,7 @@ run (void *cls, char *const *args, const char *cfgfile,
499 } 499 }
500 if (benchmark_send && (NULL == cpid)) 500 if (benchmark_send && (NULL == cpid))
501 { 501 {
502 fprintf (stderr, _("Option `%s' makes no sense without option `%s'.\n"), 502 FPRINTF (stderr, _("Option `%s' makes no sense without option `%s'.\n"),
503 "-s", "-C"); 503 "-s", "-C");
504 return; 504 return;
505 } 505 }
@@ -508,7 +508,7 @@ run (void *cls, char *const *args, const char *cfgfile,
508 ret = 1; 508 ret = 1;
509 if (GNUNET_OK != GNUNET_CRYPTO_hash_from_string (cpid, &pid.hashPubKey)) 509 if (GNUNET_OK != GNUNET_CRYPTO_hash_from_string (cpid, &pid.hashPubKey))
510 { 510 {
511 fprintf (stderr, _("Failed to parse peer identity `%s'\n"), cpid); 511 FPRINTF (stderr, _("Failed to parse peer identity `%s'\n"), cpid);
512 return; 512 return;
513 } 513 }
514 handle = 514 handle =
diff --git a/src/transport/test_quota_compliance.c b/src/transport/test_quota_compliance.c
index 5d9cfff19..0ef708b62 100644
--- a/src/transport/test_quota_compliance.c
+++ b/src/transport/test_quota_compliance.c
@@ -130,7 +130,7 @@ static struct GNUNET_TIME_Absolute start_time;
130 */ 130 */
131 131
132#if VERBOSE 132#if VERBOSE
133#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 133#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
134#else 134#else
135#define OKPP do { ok++; } while (0) 135#define OKPP do { ok++; } while (0)
136#endif 136#endif
@@ -147,7 +147,7 @@ end ()
147 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value; 147 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
148 datarate = (total_bytes_sent * 1000) / delta; 148 datarate = (total_bytes_sent * 1000) / delta;
149 149
150 fprintf (stderr, "Throughput was %llu b/s\n", datarate); 150 FPRINTF (stderr, "Throughput was %llu b/s\n", datarate);
151 151
152 test_failed = GNUNET_NO; 152 test_failed = GNUNET_NO;
153 if (datarate > quota_in_p2) 153 if (datarate > quota_in_p2)
@@ -365,7 +365,7 @@ notify_ready (void *cls, size_t size, void *buf)
365 total_bytes_sent += ret; 365 total_bytes_sent += ret;
366 if (n == TOTAL_MSGS) 366 if (n == TOTAL_MSGS)
367 { 367 {
368 fprintf (stderr, "\n"); 368 FPRINTF (stderr, "%s", "\n");
369 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All messages sent\n"); 369 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All messages sent\n");
370 } 370 }
371 return ret; 371 return ret;
@@ -417,12 +417,12 @@ measure (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
417 counter++; 417 counter++;
418 if ((DURATION.rel_value / 1000) < counter) 418 if ((DURATION.rel_value / 1000) < counter)
419 { 419 {
420 fprintf (stderr, ".\n"); 420 FPRINTF (stderr, "%s", ".\n");
421 GNUNET_SCHEDULER_add_now (&end, NULL); 421 GNUNET_SCHEDULER_add_now (&end, NULL);
422 } 422 }
423 else 423 else
424 { 424 {
425 fprintf (stderr, "."); 425 FPRINTF (stderr, "%s", ".");
426 measure_task = 426 measure_task =
427 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &measure, NULL); 427 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS, &measure, NULL);
428 } 428 }
diff --git a/src/transport/test_transport_api.c b/src/transport/test_transport_api.c
index dd0704231..1058f2b6b 100644
--- a/src/transport/test_transport_api.c
+++ b/src/transport/test_transport_api.c
@@ -81,7 +81,7 @@ char *cfg_file_p1;
81char *cfg_file_p2; 81char *cfg_file_p2;
82 82
83#if VERBOSE 83#if VERBOSE
84#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 84#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
85#else 85#else
86#define OKPP do { ok++; } while (0) 86#define OKPP do { ok++; } while (0)
87#endif 87#endif
diff --git a/src/transport/test_transport_api_bidirectional_connect.c b/src/transport/test_transport_api_bidirectional_connect.c
index 20005deab..b4a3ca41d 100644
--- a/src/transport/test_transport_api_bidirectional_connect.c
+++ b/src/transport/test_transport_api_bidirectional_connect.c
@@ -80,7 +80,7 @@ char *cfg_file_p1;
80char *cfg_file_p2; 80char *cfg_file_p2;
81 81
82#if VERBOSE 82#if VERBOSE
83#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 83#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
84#else 84#else
85#define OKPP do { ok++; } while (0) 85#define OKPP do { ok++; } while (0)
86#endif 86#endif
diff --git a/src/transport/test_transport_api_disconnect.c b/src/transport/test_transport_api_disconnect.c
index 026ed085a..1a73bcb5f 100644
--- a/src/transport/test_transport_api_disconnect.c
+++ b/src/transport/test_transport_api_disconnect.c
@@ -80,7 +80,7 @@ char *cfg_file_p1;
80char *cfg_file_p2; 80char *cfg_file_p2;
81 81
82#if VERBOSE 82#if VERBOSE
83#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 83#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
84#else 84#else
85#define OKPP do { ok++; } while (0) 85#define OKPP do { ok++; } while (0)
86#endif 86#endif
diff --git a/src/transport/test_transport_api_limited_sockets.c b/src/transport/test_transport_api_limited_sockets.c
index 7fb13e261..d1aa6e40d 100644
--- a/src/transport/test_transport_api_limited_sockets.c
+++ b/src/transport/test_transport_api_limited_sockets.c
@@ -84,7 +84,7 @@ char *cfg_file_p1;
84char *cfg_file_p2; 84char *cfg_file_p2;
85 85
86#if VERBOSE 86#if VERBOSE
87#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 87#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
88#else 88#else
89#define OKPP do { ok++; } while (0) 89#define OKPP do { ok++; } while (0)
90#endif 90#endif
diff --git a/src/transport/test_transport_api_reliability.c b/src/transport/test_transport_api_reliability.c
index ac360a3ea..eb03564d5 100644
--- a/src/transport/test_transport_api_reliability.c
+++ b/src/transport/test_transport_api_reliability.c
@@ -123,7 +123,7 @@ static struct GNUNET_TIME_Absolute start_time;
123 */ 123 */
124 124
125#if VERBOSE 125#if VERBOSE
126#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 126#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
127#else 127#else
128#define OKPP do { ok++; } while (0) 128#define OKPP do { ok++; } while (0)
129#endif 129#endif
@@ -139,7 +139,7 @@ end ()
139 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n"); 139 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n");
140 140
141 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value; 141 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
142 fprintf (stderr, "\nThroughput was %llu kb/s\n", 142 FPRINTF (stderr, "\nThroughput was %llu kb/s\n",
143 total_bytes * 1000 / 1024 / delta); 143 total_bytes * 1000 / 1024 / delta);
144 GNUNET_asprintf (&value_name, "reliable_%s", test_plugin); 144 GNUNET_asprintf (&value_name, "reliable_%s", test_plugin);
145 GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta), 145 GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta),
@@ -267,7 +267,7 @@ notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer,
267 n++; 267 n++;
268 if (0 == (n % (TOTAL_MSGS / 100))) 268 if (0 == (n % (TOTAL_MSGS / 100)))
269 { 269 {
270 fprintf (stderr, "."); 270 FPRINTF (stderr, "%s", ".");
271 if (die_task != GNUNET_SCHEDULER_NO_TASK) 271 if (die_task != GNUNET_SCHEDULER_NO_TASK)
272 GNUNET_SCHEDULER_cancel (die_task); 272 GNUNET_SCHEDULER_cancel (die_task);
273 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL); 273 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL);
@@ -353,7 +353,7 @@ notify_ready (void *cls, size_t size, void *buf)
353 total_bytes += ret; 353 total_bytes += ret;
354 if (n == TOTAL_MSGS) 354 if (n == TOTAL_MSGS)
355 { 355 {
356 fprintf (stderr, "\n"); 356 FPRINTF (stderr, "%s", "\n");
357 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All messages sent\n"); 357 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All messages sent\n");
358 } 358 }
359 return ret; 359 return ret;
diff --git a/src/transport/test_transport_api_restart_1peer.c b/src/transport/test_transport_api_restart_1peer.c
index 61423a7ee..22c603565 100644
--- a/src/transport/test_transport_api_restart_1peer.c
+++ b/src/transport/test_transport_api_restart_1peer.c
@@ -80,7 +80,7 @@ char *cfg_file_p2;
80static int restarted; 80static int restarted;
81 81
82#if VERBOSE 82#if VERBOSE
83#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 83#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
84#else 84#else
85#define OKPP do { ok++; } while (0) 85#define OKPP do { ok++; } while (0)
86#endif 86#endif
diff --git a/src/transport/test_transport_api_restart_2peers.c b/src/transport/test_transport_api_restart_2peers.c
index 67cc90f0e..3de91d62a 100644
--- a/src/transport/test_transport_api_restart_2peers.c
+++ b/src/transport/test_transport_api_restart_2peers.c
@@ -80,7 +80,7 @@ char *cfg_file_p2;
80static int restarted; 80static int restarted;
81 81
82#if VERBOSE 82#if VERBOSE
83#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 83#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
84#else 84#else
85#define OKPP do { ok++; } while (0) 85#define OKPP do { ok++; } while (0)
86#endif 86#endif
diff --git a/src/transport/test_transport_api_timeout.c b/src/transport/test_transport_api_timeout.c
index 29f7dd4af..35279ff76 100644
--- a/src/transport/test_transport_api_timeout.c
+++ b/src/transport/test_transport_api_timeout.c
@@ -87,7 +87,7 @@ static int disconnects;
87 87
88 88
89#if VERBOSE 89#if VERBOSE
90#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 90#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
91#else 91#else
92#define OKPP do { ok++; } while (0) 92#define OKPP do { ok++; } while (0)
93#endif 93#endif
@@ -210,13 +210,13 @@ timer (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
210 if (time_running.rel_value == 210 if (time_running.rel_value ==
211 GNUNET_TIME_relative_max (time_running, WAIT).rel_value) 211 GNUNET_TIME_relative_max (time_running, WAIT).rel_value)
212 { 212 {
213 fprintf (stderr, "100%%\n"); 213 FPRINTF (stderr, "%s", "100%%\n");
214 shutdown_flag = GNUNET_YES; 214 shutdown_flag = GNUNET_YES;
215 GNUNET_SCHEDULER_add_now (&end, NULL); 215 GNUNET_SCHEDULER_add_now (&end, NULL);
216 } 216 }
217 else 217 else
218 { 218 {
219 fprintf (stderr, "%u%%..", percentage); 219 FPRINTF (stderr, "%u%%..", percentage);
220 timer_task = 220 timer_task =
221 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_divide (WAIT, 10), 221 GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_divide (WAIT, 10),
222 &timer, NULL); 222 &timer, NULL);
diff --git a/src/transport/test_transport_api_unreliability.c b/src/transport/test_transport_api_unreliability.c
index 2120f7044..413daabc9 100644
--- a/src/transport/test_transport_api_unreliability.c
+++ b/src/transport/test_transport_api_unreliability.c
@@ -126,7 +126,7 @@ static GNUNET_TRANSPORT_TESTING_ConnectRequest cc;
126 */ 126 */
127 127
128#if VERBOSE 128#if VERBOSE
129#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 129#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
130#else 130#else
131#define OKPP do { ok++; } while (0) 131#define OKPP do { ok++; } while (0)
132#endif 132#endif
@@ -144,7 +144,7 @@ end ()
144 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n"); 144 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n");
145 145
146 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value; 146 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
147 fprintf (stderr, "\nThroughput was %llu kb/s\n", 147 FPRINTF (stderr, "\nThroughput was %llu kb/s\n",
148 total_bytes * 1000 / 1024 / delta); 148 total_bytes * 1000 / 1024 / delta);
149 GNUNET_asprintf (&value_name, "unreliable_%s", test_plugin); 149 GNUNET_asprintf (&value_name, "unreliable_%s", test_plugin);
150 GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta), 150 GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta),
@@ -337,7 +337,7 @@ notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer,
337 test_sending = GNUNET_YES; 337 test_sending = GNUNET_YES;
338 if (0 == (n % (TOTAL_MSGS / 100))) 338 if (0 == (n % (TOTAL_MSGS / 100)))
339 { 339 {
340 fprintf (stderr, "."); 340 FPRINTF (stderr, "%s", ".");
341 if (GNUNET_SCHEDULER_NO_TASK != die_task) 341 if (GNUNET_SCHEDULER_NO_TASK != die_task)
342 GNUNET_SCHEDULER_cancel (die_task); 342 GNUNET_SCHEDULER_cancel (die_task);
343 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL); 343 die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL);
@@ -410,7 +410,7 @@ notify_ready (void *cls, size_t size, void *buf)
410 } 410 }
411 else 411 else
412 { 412 {
413 fprintf (stderr, "\n"); 413 FPRINTF (stderr, "%s", "\n");
414 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All messages scheduled to be sent\n"); 414 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "All messages scheduled to be sent\n");
415 if (GNUNET_SCHEDULER_NO_TASK != die_task) 415 if (GNUNET_SCHEDULER_NO_TASK != die_task)
416 GNUNET_SCHEDULER_cancel (die_task); 416 GNUNET_SCHEDULER_cancel (die_task);
diff --git a/src/transport/test_transport_api_unreliability_constant.c b/src/transport/test_transport_api_unreliability_constant.c
index 3770ebfdb..52bf63833 100644
--- a/src/transport/test_transport_api_unreliability_constant.c
+++ b/src/transport/test_transport_api_unreliability_constant.c
@@ -124,7 +124,7 @@ static struct GNUNET_TIME_Absolute start_time;
124 */ 124 */
125 125
126#if VERBOSE 126#if VERBOSE
127#define OKPP do { ok++; fprintf (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) 127#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0)
128#else 128#else
129#define OKPP do { ok++; } while (0) 129#define OKPP do { ok++; } while (0)
130#endif 130#endif
@@ -142,7 +142,7 @@ end ()
142 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n"); 142 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n");
143 143
144 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value; 144 delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
145 fprintf (stderr, "\nThroughput was %llu kb/s\n", 145 FPRINTF (stderr, "\nThroughput was %llu kb/s\n",
146 total_bytes * 1000 / 1024 / delta); 146 total_bytes * 1000 / 1024 / delta);
147 GNUNET_asprintf (&value_name, "unreliable_%s", test_plugin); 147 GNUNET_asprintf (&value_name, "unreliable_%s", test_plugin);
148 GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta), 148 GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta),
@@ -281,7 +281,7 @@ notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer,
281 n++; 281 n++;
282 if (0 == (n % (TOTAL_MSGS / 100))) 282 if (0 == (n % (TOTAL_MSGS / 100)))
283 { 283 {
284 fprintf (stderr, "."); 284 FPRINTF (stderr, "%s", ".");
285 if (GNUNET_SCHEDULER_NO_TASK != die_task) 285 if (GNUNET_SCHEDULER_NO_TASK != die_task)
286 GNUNET_SCHEDULER_cancel (die_task); 286 GNUNET_SCHEDULER_cancel (die_task);
287 test_failed = GNUNET_YES; 287 test_failed = GNUNET_YES;
@@ -291,7 +291,7 @@ notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer,
291 { 291 {
292 /* because of starting with 0 */ 292 /* because of starting with 0 */
293 msg_recv++; 293 msg_recv++;
294 fprintf (stderr, "\n"); 294 FPRINTF (stderr, "%s", "\n");
295 end (); 295 end ();
296 } 296 }
297} 297}
@@ -356,7 +356,7 @@ notify_ready (void *cls, size_t size, void *buf)
356 } 356 }
357 else 357 else
358 { 358 {
359 fprintf (stderr, "\n"); 359 FPRINTF (stderr, "%s", "\n");
360 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 360 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
361 "All messages scheduled to be sent!!\n"); 361 "All messages scheduled to be sent!!\n");
362 if (GNUNET_SCHEDULER_NO_TASK != die_task) 362 if (GNUNET_SCHEDULER_NO_TASK != die_task)
diff --git a/src/transport/test_transport_startonly.c b/src/transport/test_transport_startonly.c
index c6215c9bc..36d9b18d3 100644
--- a/src/transport/test_transport_startonly.c
+++ b/src/transport/test_transport_startonly.c
@@ -124,7 +124,7 @@ run (void *cls, char *const *args, const char *cfgfile,
124 timeout_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL); 124 timeout_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL);
125 125
126 i = 1; 126 i = 1;
127 fprintf (stderr, "%i", i); 127 FPRINTF (stderr, "%i", i);
128 while (i <= ITERATIONS) 128 while (i <= ITERATIONS)
129 { 129 {
130 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Starting peer\n"); 130 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Starting peer\n");
@@ -147,12 +147,12 @@ run (void *cls, char *const *args, const char *cfgfile,
147 147
148 i++; 148 i++;
149 if (i <= ITERATIONS) 149 if (i <= ITERATIONS)
150 fprintf (stderr, "..%i", i); 150 FPRINTF (stderr, "..%i", i);
151 } 151 }
152 152
153 tth = GNUNET_TRANSPORT_TESTING_init (); 153 tth = GNUNET_TRANSPORT_TESTING_init ();
154 154
155 fprintf (stderr, "\n"); 155 FPRINTF (stderr, "%s", "\n");
156 end (); 156 end ();
157} 157}
158 158