tc = lookup_client (client);
if (NULL == tc)
- {
- /* client asked for transmission before 'START' */
- GNUNET_break (0);
- GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
- return;
- }
+ {
+ /* client asked for transmission before 'START' */
+ GNUNET_break (0);
+ GNUNET_SERVER_receive_done (client, GNUNET_SYSERR);
+ return;
+ }
size = ntohs (message->size);
if (size <
tc = lookup_client (client);
if (NULL == tc)
- return; /* client got disconnected in the meantime, drop message */
+ return; /* client got disconnected in the meantime, drop message */
unicast (tc, msg, may_drop);
}
GNUNET_asprintf (&cfg_file_p2, "%s_peer2.conf", filename);
GNUNET_free (backup);
- if ((strstr (argv[0], "tcp_nat") != NULL) || (strstr (argv[0], "udp_nat") != NULL))
+ if ((strstr (argv[0], "tcp_nat") != NULL) ||
+ (strstr (argv[0], "udp_nat") != NULL))
{
nat_res = GNUNET_OS_check_helper_binary ("gnunet-nat-server");
if (GNUNET_NO == nat_res)
{
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Cannot run NAT test: `%s' %s \n",
- "gnunet-nat-server",
- "SUID not set");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Cannot run NAT test: `%s' %s \n",
+ "gnunet-nat-server", "SUID not set");
return 0;
}
- if (GNUNET_SYSERR == nat_res)
+ if (GNUNET_SYSERR == nat_res)
{
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Cannot run NAT test: `%s' %s \n",
- "gnunet-nat-server",
- "file not found");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Cannot run NAT test: `%s' %s \n",
+ "gnunet-nat-server", "file not found");
return 0;
}
while (peers_connected > 0) ;
if (counter < ITERATIONS)
+ {
+ if ((counter % (ITERATIONS / 10)) == 0)
+ fprintf (stderr, "%u%%..", (counter / (ITERATIONS / 10)) * 10);
peers_connect ();
+ }
else
+ {
+ fprintf (stderr, "100%%\n");
end ();
+ }
}
static void
delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
fprintf (stderr, "\nThroughput was %llu kb/s\n",
total_bytes * 1000 / 1024 / delta);
- GNUNET_asprintf(&value_name, "reliable_%s", test_name);
- GAUGER ("TRANSPORT", value_name, (int)(total_bytes * 1000 / 1024 /delta), "kb/s");
- GNUNET_free(value_name);
+ GNUNET_asprintf (&value_name, "reliable_%s", test_name);
+ GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta),
+ "kb/s");
+ GNUNET_free (value_name);
if (die_task != GNUNET_SCHEDULER_NO_TASK)
GNUNET_SCHEDULER_cancel (die_task);
#endif
ok = 1;
GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1, argv,
- "test-transport-api-reliability", "nohelp", options, &run, &ok);
+ "test-transport-api-reliability", "nohelp", options, &run,
+ &ok);
return ok;
}
char *backup = pch;
char *filename = NULL;
char *dotexe;
- char *src_name = strdup (__FILE__);
+ char *src_name = strdup (__FILE__);
char *split = NULL;
/* get executable filename */
if (split != NULL)
{
split[0] = '\0';
- test_name = strdup(&filename[strlen(src_name)+1]);
+ test_name = strdup (&filename[strlen (src_name) + 1]);
}
else
test_name = NULL;
GNUNET_free (src_name);
GNUNET_free (backup);
- if ((strstr (argv[0], "tcp_nat") != NULL) || (strstr (argv[0], "udp_nat") != NULL))
+ if ((strstr (argv[0], "tcp_nat") != NULL) ||
+ (strstr (argv[0], "udp_nat") != NULL))
{
nat_res = GNUNET_OS_check_helper_binary ("gnunet-nat-server");
if (GNUNET_NO == nat_res)
{
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Cannot run NAT test: `%s' %s \n",
- "gnunet-nat-server",
- "SUID not set");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Cannot run NAT test: `%s' %s \n",
+ "gnunet-nat-server", "SUID not set");
return 0;
}
- if (GNUNET_SYSERR == nat_res)
+ if (GNUNET_SYSERR == nat_res)
{
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Cannot run NAT test: `%s' %s \n",
- "gnunet-nat-server",
- "file not found");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Cannot run NAT test: `%s' %s \n",
+ "gnunet-nat-server", "file not found");
return 0;
}
}
delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value;
fprintf (stderr, "\nThroughput was %llu kb/s\n",
total_bytes * 1000 / 1024 / delta);
- GNUNET_asprintf(&value_name, "unreliable_%s", test_name);
- GAUGER ("TRANSPORT", value_name, (int)(total_bytes * 1000 / 1024 /delta), "kb/s");
- GNUNET_free(value_name);
+ GNUNET_asprintf (&value_name, "unreliable_%s", test_name);
+ GAUGER ("TRANSPORT", value_name, (int) (total_bytes * 1000 / 1024 / delta),
+ "kb/s");
+ GNUNET_free (value_name);
if (die_task != GNUNET_SCHEDULER_NO_TASK)
GNUNET_SCHEDULER_cancel (die_task);
ok = 0;
int i;
+
for (i = 0; i < TOTAL_MSGS; i++)
{
if (get_bit (bitmap, i) == 0)
while (size - ret >= s);
if (n < TOTAL_MSGS)
{
- th =
- GNUNET_TRANSPORT_notify_transmit_ready (p2->th, &p1->id, s, 0, TIMEOUT,
- ¬ify_ready, NULL);
+ th = GNUNET_TRANSPORT_notify_transmit_ready (p2->th, &p1->id, s, 0, TIMEOUT,
+ ¬ify_ready, NULL);
msg_scheduled = n;
}
else
"All messages scheduled to be sent!!\n");
if (GNUNET_SCHEDULER_NO_TASK != die_task)
GNUNET_SCHEDULER_cancel (die_task);
- die_task =
- GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly,
- NULL);
+ die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL);
}
if (n % 5000 == 0)
{
ok = GNUNET_SYSERR;
GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1, argv,
- "test-transport-api-unreliability", "nohelp", options, &run, &ok);
+ "test-transport-api-unreliability", "nohelp", options,
+ &run, &ok);
return ok;
}
char *backup = pch;
char *filename = NULL;
char *dotexe;
- char *src_name = strdup (__FILE__);
+ char *src_name = strdup (__FILE__);
char *split = NULL;
/* get executable filename */
if (split != NULL)
{
split[0] = '\0';
- test_name = strdup(&filename[strlen(src_name)+1]);
+ test_name = strdup (&filename[strlen (src_name) + 1]);
}
else
test_name = NULL;
GNUNET_free (src_name);
GNUNET_free (backup);
- if ((strstr (argv[0], "tcp_nat") != NULL) || (strstr (argv[0], "udp_nat") != NULL))
+ if ((strstr (argv[0], "tcp_nat") != NULL) ||
+ (strstr (argv[0], "udp_nat") != NULL))
{
nat_res = GNUNET_OS_check_helper_binary ("gnunet-nat-server");
if (GNUNET_NO == nat_res)
{
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Cannot run NAT test: `%s' %s \n",
- "gnunet-nat-server",
- "SUID not set");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Cannot run NAT test: `%s' %s \n",
+ "gnunet-nat-server", "SUID not set");
return 0;
}
- if (GNUNET_SYSERR == nat_res)
+ if (GNUNET_SYSERR == nat_res)
{
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Cannot run NAT test: `%s' %s \n",
- "gnunet-nat-server",
- "file not found");
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Cannot run NAT test: `%s' %s \n",
+ "gnunet-nat-server", "file not found");
return 0;
}
}