X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Futil%2Ftest_server_with_client_unix.c;h=4f80f188cc17f5fa59945c365abc9e9ced21da9e;hb=e62ce5b19244ae28472bf0e02b19c3f905f1ee0a;hp=98a530a1935a9c9da19b6bfd42b70966cb456d01;hpb=0d43d44a39a7cee4bc1a84ab5eb36ac8eb05e2a2;p=oweals%2Fgnunet.git diff --git a/src/util/test_server_with_client_unix.c b/src/util/test_server_with_client_unix.c index 98a530a19..4f80f188c 100644 --- a/src/util/test_server_with_client_unix.c +++ b/src/util/test_server_with_client_unix.c @@ -30,7 +30,7 @@ #include "gnunet_server_lib.h" #include "gnunet_time_lib.h" -#define VERBOSE GNUNET_NO +#define VERBOSE GNUNET_EXTRA_LOGGING #define MY_TYPE 128 @@ -47,6 +47,7 @@ static void send_done (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) { struct GNUNET_SERVER_Client *argclient = cls; + GNUNET_assert (ok == 3); ok++; GNUNET_SERVER_receive_done (argclient, GNUNET_OK); @@ -54,26 +55,25 @@ send_done (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) static void -recv_cb (void *cls, - struct GNUNET_SERVER_Client *argclient, +recv_cb (void *cls, struct GNUNET_SERVER_Client *argclient, const struct GNUNET_MessageHeader *message) { switch (ok) - { - case 2: - ok++; - GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply - (GNUNET_TIME_UNIT_MILLISECONDS, 50), - &send_done, argclient); - break; - case 4: - ok++; - GNUNET_CLIENT_disconnect (client, GNUNET_YES); - GNUNET_SERVER_receive_done (argclient, GNUNET_OK); - break; - default: - GNUNET_assert (0); - } + { + case 2: + ok++; + GNUNET_SCHEDULER_add_delayed (GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_MILLISECONDS, 50), + &send_done, argclient); + break; + case 4: + ok++; + GNUNET_CLIENT_disconnect (client, GNUNET_YES); + GNUNET_SERVER_receive_done (argclient, GNUNET_OK); + break; + default: + GNUNET_assert (0); + } } @@ -133,53 +133,45 @@ static struct GNUNET_SERVER_MessageHandler handlers[] = { static void task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) { - char * unixpath = "/tmp/testsock"; - int slen = strlen (unixpath) + 1; - struct sockaddr_un un; + const char *unixpath = "/tmp/testsock"; + size_t slen = strlen (unixpath); + struct sockaddr *sap[2]; + socklen_t slens[2]; - memset(&un, 0, sizeof(un)); + memset (&un, 0, sizeof (un)); un.sun_family = AF_UNIX; memcpy (un.sun_path, unixpath, slen); un.sun_path[slen] = '\0'; #if HAVE_SOCKADDR_IN_SIN_LEN - un.sun_len = (u_char) SUN_LEN (&un); + un.sun_len = (u_char) sizeof (un); #endif #if LINUX un.sun_path[0] = '\0'; #endif - struct sockaddr * sap[2]; - socklen_t slens[2]; - sap[0] = (struct sockaddr*) &un; + sap[0] = (struct sockaddr *) &un; slens[0] = sizeof (un); - sap[1] = NULL; slens[1] = 0; - - server = GNUNET_SERVER_create (NULL, - NULL, - sap, - slens, - GNUNET_TIME_relative_multiply - (GNUNET_TIME_UNIT_MILLISECONDS, 250), - GNUNET_NO); + server = + GNUNET_SERVER_create (NULL, NULL, sap, slens, + GNUNET_TIME_relative_multiply + (GNUNET_TIME_UNIT_MILLISECONDS, 250), GNUNET_NO); GNUNET_assert (server != NULL); handlers[0].callback_cls = cls; GNUNET_SERVER_add_handlers (server, handlers); GNUNET_SERVER_disconnect_notify (server, ¬ify_disconnect, cls); cfg = GNUNET_CONFIGURATION_create (); - GNUNET_CONFIGURATION_set_value_string (cfg, "test", "UNIXPATH", - unixpath); + GNUNET_CONFIGURATION_set_value_string (cfg, "test", "UNIXPATH", unixpath); GNUNET_CONFIGURATION_set_value_string (cfg, "resolver", "HOSTNAME", "localhost"); client = GNUNET_CLIENT_connect ("test", cfg); GNUNET_assert (client != NULL); - GNUNET_CLIENT_notify_transmit_ready (client, - 256, + GNUNET_CLIENT_notify_transmit_ready (client, 256, GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MILLISECONDS, 250), GNUNET_NO, ¬ify_ready, NULL);