diff options
Diffstat (limited to 'src/transport')
-rw-r--r-- | src/transport/gnunet-transport-connect-running-peers.c | 4 | ||||
-rw-r--r-- | src/transport/gnunet-transport.c | 28 | ||||
-rw-r--r-- | src/transport/test_quota_compliance.c | 10 | ||||
-rw-r--r-- | src/transport/test_transport_api.c | 2 | ||||
-rw-r--r-- | src/transport/test_transport_api_bidirectional_connect.c | 2 | ||||
-rw-r--r-- | src/transport/test_transport_api_disconnect.c | 2 | ||||
-rw-r--r-- | src/transport/test_transport_api_limited_sockets.c | 2 | ||||
-rw-r--r-- | src/transport/test_transport_api_reliability.c | 8 | ||||
-rw-r--r-- | src/transport/test_transport_api_restart_1peer.c | 2 | ||||
-rw-r--r-- | src/transport/test_transport_api_restart_2peers.c | 2 | ||||
-rw-r--r-- | src/transport/test_transport_api_timeout.c | 6 | ||||
-rw-r--r-- | src/transport/test_transport_api_unreliability.c | 8 | ||||
-rw-r--r-- | src/transport/test_transport_api_unreliability_constant.c | 10 | ||||
-rw-r--r-- | src/transport/test_transport_startonly.c | 6 |
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; | |||
73 | char *cfg_file_p2; | 73 | char *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 | |||
401 | notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) | 401 | notify_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; | |||
81 | char *cfg_file_p2; | 81 | char *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; | |||
80 | char *cfg_file_p2; | 80 | char *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; | |||
80 | char *cfg_file_p2; | 80 | char *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; | |||
84 | char *cfg_file_p2; | 84 | char *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; | |||
80 | static int restarted; | 80 | static 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; | |||
80 | static int restarted; | 80 | static 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 | ||