Copyright (C) 2009, 2010, 2011, 2016 GNUnet e.V.
GNUnet is free software: you can redistribute it and/or modify it
- under the terms of the GNU General Public License as published
+ under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License,
or (at your option) any later version.
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Affero General Public License for more details.
+
+ You should have received a copy of the GNU Affero General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+
+ SPDX-License-Identifier: AGPL3.0-or-later
*/
/**
* @file transport/test_transport_address_switch.c
struct PeerStats *stat = cls;
stat->switch_attempts++;
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "Switch attempted (%p)",
- stat);
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Switch attempted (%p)", stat);
bytes_recv_after_switch = 0;
bytes_sent_after_switch = 0;
struct PeerStats *stat = cls;
stat->switch_success++;
- GNUNET_log (GNUNET_ERROR_TYPE_INFO,
- "Switch succeeded (%p)",
- stat);
+ GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Switch succeeded (%p)", stat);
return GNUNET_OK;
}
return GNUNET_OK;
stat->switch_fail++;
- GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
- "Switch failed (%p)",
- stat);
+ GNUNET_log (GNUNET_ERROR_TYPE_WARNING, "Switch failed (%p)", stat);
return GNUNET_OK;
}
/**
* List of statistics entries we care about.
*/
-static struct WatchEntry {
+static struct WatchEntry
+{
/**
* Name of the statistic we watch.
* Handler to register;
*/
GNUNET_STATISTICS_Iterator stat_handler;
-} watches[] = {
- { "# Attempts to switch addresses", &stat_start_attempt_cb },
- { "# Successful attempts to switch addresses", &stat_success_attempt_cb },
- { "# Failed attempts to switch addresses (failed to send CONNECT CONT)", &stat_fail_attempt_cb },
- { "# Failed attempts to switch addresses (failed to send CONNECT)", &stat_fail_attempt_cb },
- { "# Failed attempts to switch addresses (no response)", &stat_fail_attempt_cb },
- { "# transport addresses", &stat_addresses_available },
- { NULL, NULL }
-};
+} watches[] =
+ {{"# Attempts to switch addresses", &stat_start_attempt_cb},
+ {"# Successful attempts to switch addresses", &stat_success_attempt_cb},
+ {"# Failed attempts to switch addresses (failed to send CONNECT CONT)",
+ &stat_fail_attempt_cb},
+ {"# Failed attempts to switch addresses (failed to send CONNECT)",
+ &stat_fail_attempt_cb},
+ {"# Failed attempts to switch addresses (no response)",
+ &stat_fail_attempt_cb},
+ {"# transport addresses", &stat_addresses_available},
+ {NULL, NULL}};
static void
}
/* stop statistics */
- for (unsigned int i=0;i<2;i++)
+ for (unsigned int i = 0; i < 2; i++)
{
if (NULL != stats[i].stat)
{
- for (unsigned int j=0;NULL != watches[j].stat_name; j++)
- GNUNET_STATISTICS_watch_cancel (stats[i].stat,
- "transport",
- watches[j].stat_name,
- watches[j].stat_handler,
- &stats[i]);
-
- GNUNET_STATISTICS_destroy (stats[i].stat,
- GNUNET_NO);
+ for (unsigned int j = 0; NULL != watches[j].stat_name; j++)
+ GNUNET_assert (GNUNET_OK ==
+ GNUNET_STATISTICS_watch_cancel (stats[i].stat,
+ "transport",
+ watches[j].stat_name,
+ watches[j].stat_handler,
+ &stats[i]));
+ GNUNET_STATISTICS_destroy (stats[i].stat, GNUNET_NO);
stats[i].stat = NULL;
}
}
result = 0;
- FPRINTF (stderr, "\n");
+ fprintf (stderr, "\n");
if (stats[0].switch_attempts > 0)
{
- FPRINTF (stderr,
- "Peer 1 tried %u times to switch and succeeded %u times, failed %u times\n",
- stats[0].switch_attempts,
- stats[0].switch_success,
- stats[0].switch_fail);
+ fprintf (
+ stderr,
+ "Peer 1 tried %u times to switch and succeeded %u times, failed %u times\n",
+ stats[0].switch_attempts,
+ stats[0].switch_success,
+ stats[0].switch_fail);
if (stats[0].switch_success != stats[0].switch_attempts)
{
GNUNET_break (0);
- result ++;
+ result++;
}
}
else if (stats[0].addresses_avail > 1)
{
- FPRINTF (stderr,
+ fprintf (stderr,
"Peer 1 had %u addresses available, but did not try to switch\n",
stats[0].addresses_avail);
}
if (stats[1].switch_attempts > 0)
{
- FPRINTF (stderr,
- "Peer 2 tried %u times to switch and succeeded %u times, failed %u times\n",
- stats[1].switch_attempts,
- stats[1].switch_success,
- stats[1].switch_fail);
+ fprintf (
+ stderr,
+ "Peer 2 tried %u times to switch and succeeded %u times, failed %u times\n",
+ stats[1].switch_attempts,
+ stats[1].switch_success,
+ stats[1].switch_fail);
if (stats[1].switch_success != stats[1].switch_attempts)
{
GNUNET_break (0);
}
else if (stats[1].addresses_avail > 1)
{
- FPRINTF (stderr,
+ fprintf (stderr,
"Peer 2 had %u addresses available, but did not try to switch\n",
stats[1].addresses_avail);
}
- if ( ((stats[0].switch_attempts > 0) || (stats[1].switch_attempts > 0)) &&
- (bytes_sent_after_switch == 0) )
+ if (((stats[0].switch_attempts > 0) || (stats[1].switch_attempts > 0)) &&
+ (bytes_sent_after_switch == 0))
{
- FPRINTF (stderr,
- "No data sent after switching!\n");
+ fprintf (stderr, "No data sent after switching!\n");
GNUNET_break (0);
result++;
}
- if ( ((stats[0].switch_attempts > 0) || (stats[1].switch_attempts > 0)) &&
- (bytes_recv_after_switch == 0) )
+ if (((stats[0].switch_attempts > 0) || (stats[1].switch_attempts > 0)) &&
+ (bytes_recv_after_switch == 0))
{
- FPRINTF (stderr,
- "No data received after switching!\n");
+ fprintf (stderr, "No data received after switching!\n");
GNUNET_break (0);
result++;
}
GNUNET_i2s (sender));
GNUNET_free (ps);
}
- if ( ((stats[0].switch_attempts >= 1) || (stats[1].switch_attempts >= 1)) &&
- (stats[0].switch_attempts == stats[0].switch_fail + stats[0].switch_success) &&
- (stats[1].switch_attempts == stats[1].switch_fail + stats[1].switch_success) )
+ if (((stats[0].switch_attempts >= 1) || (stats[1].switch_attempts >= 1)) &&
+ (stats[0].switch_attempts ==
+ stats[0].switch_fail + stats[0].switch_success) &&
+ (stats[1].switch_attempts ==
+ stats[1].switch_fail + stats[1].switch_success))
{
- bytes_recv_after_switch += ntohs(hdr->header.size);
- if ( (bytes_sent_after_switch > 0) &&
- (bytes_recv_after_switch > 0) )
+ bytes_recv_after_switch += ntohs (hdr->header.size);
+ if ((bytes_sent_after_switch > 0) && (bytes_recv_after_switch > 0))
{
/* A peer switched addresses and sent and received data after the
* switch operations */
{
static uint32_t cnt;
- GNUNET_assert (GNUNET_OK ==
- GNUNET_TRANSPORT_TESTING_send (ccc->p[1],
- ccc->p[0],
- GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE,
- GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE,
- ++cnt,
- ¬ify_send,
- NULL));
- if ( ( (stats[0].switch_attempts >= 1) ||
- (stats[1].switch_attempts >= 1) ) &&
- (stats[0].switch_attempts == stats[0].switch_fail + stats[0].switch_success) &&
- (stats[1].switch_attempts == stats[1].switch_fail + stats[1].switch_success) )
+ GNUNET_assert (
+ GNUNET_OK ==
+ GNUNET_TRANSPORT_TESTING_send (ccc->p[1],
+ ccc->p[0],
+ GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE,
+ GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE,
+ ++cnt,
+ ¬ify_send,
+ NULL));
+ if (((stats[0].switch_attempts >= 1) || (stats[1].switch_attempts >= 1)) &&
+ (stats[0].switch_attempts ==
+ stats[0].switch_fail + stats[0].switch_success) &&
+ (stats[1].switch_attempts ==
+ stats[1].switch_fail + stats[1].switch_success))
{
- bytes_sent_after_switch
- += GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE;
+ bytes_sent_after_switch += GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE;
}
}
counter++;
if ((TIMEOUT.rel_value_us / 1000 / 1000LL) < counter)
{
- FPRINTF (stderr, "%s", ".\n");
+ fprintf (stderr, "%s", ".\n");
}
else
{
- FPRINTF (stderr, "%s", ".");
+ fprintf (stderr, "%s", ".");
measure_task = GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_UNIT_SECONDS,
&progress_indicator,
NULL);
static void
connected_cb (void *cls)
{
- for (unsigned int i=0;i<2;i++)
+ for (unsigned int i = 0; i < 2; i++)
{
- stats[i].stat = GNUNET_STATISTICS_create ("transport",
- ccc->p[i]->cfg);
+ stats[i].stat = GNUNET_STATISTICS_create ("transport", ccc->p[i]->cfg);
if (NULL == stats[i].stat)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
GNUNET_SCHEDULER_shutdown ();
return;
}
- for (unsigned int j=0;NULL != watches[j].stat_name; j++)
+ for (unsigned int j = 0; NULL != watches[j].stat_name; j++)
{
GNUNET_STATISTICS_watch (stats[i].stat,
"transport",
&progress_indicator,
NULL);
/* Peers are connected, start transmit test messages */
- GNUNET_assert (GNUNET_OK ==
- GNUNET_TRANSPORT_TESTING_send (ccc->p[1],
- ccc->p[0],
- GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE,
- GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE,
- 0,
- ¬ify_send,
- NULL));
+ GNUNET_assert (
+ GNUNET_OK ==
+ GNUNET_TRANSPORT_TESTING_send (ccc->p[1],
+ ccc->p[0],
+ GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE,
+ GNUNET_TRANSPORT_TESTING_LARGE_MESSAGE_SIZE,
+ 0,
+ ¬ify_send,
+ NULL));
}
int
-main (int argc,
- char *argv[])
+main (int argc, char *argv[])
{
- struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext my_ccc = {
- .connect_continuation = &connected_cb,
- .config_file = "test_transport_api_data.conf",
- .rec = ¬ify_receive,
- .nc = &GNUNET_TRANSPORT_TESTING_log_connect,
- .shutdown_task = &custom_shutdown,
- .timeout = TIMEOUT
- };
+ struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext my_ccc =
+ {.connect_continuation = &connected_cb,
+ .config_file = "test_transport_api_data.conf",
+ .rec = ¬ify_receive,
+ .nc = &GNUNET_TRANSPORT_TESTING_log_connect,
+ .shutdown_task = &custom_shutdown,
+ .timeout = TIMEOUT};
ccc = &my_ccc;
int ret;
projects / oweals / gnunet.git / blobdiff