From d41ed82a4ea0cc8e1674b6d5d2c49fd6462610bb Mon Sep 17 00:00:00 2001 From: ng0 Date: Sun, 8 Sep 2019 12:33:09 +0000 Subject: uncrustify as demanded. --- .../test_transport_api_restart_reconnect.c | 182 ++++++++++----------- 1 file changed, 91 insertions(+), 91 deletions(-) (limited to 'src/transport/test_transport_api_restart_reconnect.c') diff --git a/src/transport/test_transport_api_restart_reconnect.c b/src/transport/test_transport_api_restart_reconnect.c index 5a6c10f8a..bf9a7f9a1 100644 --- a/src/transport/test_transport_api_restart_reconnect.c +++ b/src/transport/test_transport_api_restart_reconnect.c @@ -11,12 +11,12 @@ 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 . SPDX-License-Identifier: AGPL3.0-or-later -*/ + */ /** * @file transport/test_transport_api_restart_reconnect.c * @brief base test case for transport implementations @@ -32,7 +32,7 @@ /** * How long until we give up on transmitting the message? */ -#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30) +#define TIMEOUT GNUNET_TIME_relative_multiply(GNUNET_TIME_UNIT_SECONDS, 30) static struct GNUNET_TRANSPORT_TESTING_ConnectCheckContext *ccc; @@ -47,136 +47,136 @@ static int restarted; static void -custom_shutdown (void *cls) +custom_shutdown(void *cls) { if (NULL != ats_sh) - { - GNUNET_ATS_connectivity_suggest_cancel (ats_sh); - ats_sh = NULL; - } + { + GNUNET_ATS_connectivity_suggest_cancel(ats_sh); + ats_sh = NULL; + } } static void -restart_cb (void *cls) +restart_cb(void *cls) { static unsigned int c; struct GNUNET_TRANSPORT_TESTING_PeerContext *p = cls; - + c++; - if ( (2 != c) && - (NULL != strstr (ccc->test_name, - "2peers")) ) + if ((2 != c) && + (NULL != strstr(ccc->test_name, + "2peers"))) return; - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Restarted peer %u (`%s'), issuing reconnect\n", - p->no, - GNUNET_i2s (&p->id)); - ats_sh = GNUNET_ATS_connectivity_suggest (p->ats, - &ccc->p[1]->id, - 1); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Restarted peer %u (`%s'), issuing reconnect\n", + p->no, + GNUNET_i2s(&p->id)); + ats_sh = GNUNET_ATS_connectivity_suggest(p->ats, + &ccc->p[1]->id, + 1); } static void -restart (struct GNUNET_TRANSPORT_TESTING_PeerContext *p) +restart(struct GNUNET_TRANSPORT_TESTING_PeerContext *p) { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Restarting peer %u (`%s')\n", - p->no, - GNUNET_i2s (&p->id)); - GNUNET_assert (GNUNET_OK == - GNUNET_TRANSPORT_TESTING_restart_peer (p, - &restart_cb, - p)); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Restarting peer %u (`%s')\n", + p->no, + GNUNET_i2s(&p->id)); + GNUNET_assert(GNUNET_OK == + GNUNET_TRANSPORT_TESTING_restart_peer(p, + &restart_cb, + p)); } static void -notify_receive (void *cls, - struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, - const struct GNUNET_PeerIdentity *sender, - const struct GNUNET_TRANSPORT_TESTING_TestMessage *message) +notify_receive(void *cls, + struct GNUNET_TRANSPORT_TESTING_PeerContext *receiver, + const struct GNUNET_PeerIdentity *sender, + const struct GNUNET_TRANSPORT_TESTING_TestMessage *message) { { - char *ps = GNUNET_strdup (GNUNET_i2s (&receiver->id)); - - GNUNET_log (GNUNET_ERROR_TYPE_INFO, - "Peer %u (`%s') received message of type %d and size %u size from peer %s!\n", - receiver->no, - ps, - ntohs (message->header.type), - ntohs (message->header.size), - GNUNET_i2s (sender)); - GNUNET_free (ps); + char *ps = GNUNET_strdup(GNUNET_i2s(&receiver->id)); + + GNUNET_log(GNUNET_ERROR_TYPE_INFO, + "Peer %u (`%s') received message of type %d and size %u size from peer %s!\n", + receiver->no, + ps, + ntohs(message->header.type), + ntohs(message->header.size), + GNUNET_i2s(sender)); + GNUNET_free(ps); } - if ( (GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE == ntohs (message->header.type)) && - (sizeof (struct GNUNET_TRANSPORT_TESTING_TestMessage) == ntohs (message->header.size)) ) - { - if (GNUNET_NO == restarted) + if ((GNUNET_TRANSPORT_TESTING_SIMPLE_MTYPE == ntohs(message->header.type)) && + (sizeof(struct GNUNET_TRANSPORT_TESTING_TestMessage) == ntohs(message->header.size))) { - restarted = GNUNET_YES; - fprintf (stderr, "TN: %s\n", ccc->test_name); - restart (ccc->p[0]); - if (NULL != strstr (ccc->test_name, - "2peers")) - restart (ccc->p[1]); - return; + if (GNUNET_NO == restarted) + { + restarted = GNUNET_YES; + fprintf(stderr, "TN: %s\n", ccc->test_name); + restart(ccc->p[0]); + if (NULL != strstr(ccc->test_name, + "2peers")) + restart(ccc->p[1]); + return; + } + else + { + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Restarted peers connected and message was sent, stopping test...\n"); + ccc->global_ret = GNUNET_OK; + GNUNET_SCHEDULER_shutdown(); + } } - else + else { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Restarted peers connected and message was sent, stopping test...\n"); - ccc->global_ret = GNUNET_OK; - GNUNET_SCHEDULER_shutdown (); + GNUNET_break(0); + ccc->global_ret = GNUNET_SYSERR; + GNUNET_SCHEDULER_shutdown(); } - } - else - { - GNUNET_break (0); - ccc->global_ret = GNUNET_SYSERR; - GNUNET_SCHEDULER_shutdown (); - } } static void -notify_connect (void *cls, - struct GNUNET_TRANSPORT_TESTING_PeerContext *me, - const struct GNUNET_PeerIdentity *other) +notify_connect(void *cls, + struct GNUNET_TRANSPORT_TESTING_PeerContext *me, + const struct GNUNET_PeerIdentity *other) { static struct GNUNET_TRANSPORT_TESTING_SendClosure sc = { .num_messages = 1 }; sc.ccc = ccc; - GNUNET_TRANSPORT_TESTING_log_connect (cls, - me, - other); + GNUNET_TRANSPORT_TESTING_log_connect(cls, + me, + other); if (me == ccc->p[0]) p1_connected = GNUNET_YES; if (me == ccc->p[1]) p2_connected = GNUNET_YES; - if ( (GNUNET_YES == restarted) && - (GNUNET_YES == p1_connected) && - (GNUNET_YES == p2_connected) ) - { - /* Peer was restarted and we received 3 connect messages (2 from first connect, 1 from reconnect) */ - GNUNET_SCHEDULER_add_now (&GNUNET_TRANSPORT_TESTING_simple_send, - &sc); - } + if ((GNUNET_YES == restarted) && + (GNUNET_YES == p1_connected) && + (GNUNET_YES == p2_connected)) + { + /* Peer was restarted and we received 3 connect messages (2 from first connect, 1 from reconnect) */ + GNUNET_SCHEDULER_add_now(&GNUNET_TRANSPORT_TESTING_simple_send, + &sc); + } } static void -notify_disconnect (void *cls, - struct GNUNET_TRANSPORT_TESTING_PeerContext *me, - const struct GNUNET_PeerIdentity *other) +notify_disconnect(void *cls, + struct GNUNET_TRANSPORT_TESTING_PeerContext *me, + const struct GNUNET_PeerIdentity *other) { - GNUNET_TRANSPORT_TESTING_log_disconnect (cls, - me, - other); + GNUNET_TRANSPORT_TESTING_log_disconnect(cls, + me, + other); if (me == ccc->p[0]) p1_connected = GNUNET_NO; if (me == ccc->p[1]) @@ -185,8 +185,8 @@ notify_disconnect (void *cls, int -main (int argc, - char *argv[]) +main(int argc, + char *argv[]) { struct GNUNET_TRANSPORT_TESTING_SendClosure sc = { .num_messages = 1 @@ -205,9 +205,9 @@ main (int argc, ccc = &my_ccc; sc.ccc = ccc; if (GNUNET_OK != - GNUNET_TRANSPORT_TESTING_main (2, - &GNUNET_TRANSPORT_TESTING_connect_check, - ccc)) + GNUNET_TRANSPORT_TESTING_main(2, + &GNUNET_TRANSPORT_TESTING_connect_check, + ccc)) return 1; return 0; } -- cgit v1.2.3