From 8f62c823dfb8150c3bc970932d042be2feb83e25 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 10 Jul 2016 17:22:37 +0000 Subject: removing dead test --- .../test_transport_api_unreliability_constant.c | 496 --------------------- 1 file changed, 496 deletions(-) delete mode 100644 src/transport/test_transport_api_unreliability_constant.c (limited to 'src') diff --git a/src/transport/test_transport_api_unreliability_constant.c b/src/transport/test_transport_api_unreliability_constant.c deleted file mode 100644 index c0fd91816..000000000 --- a/src/transport/test_transport_api_unreliability_constant.c +++ /dev/null @@ -1,496 +0,0 @@ -/* - This file is part of GNUnet. - Copyright (C) 2009, 2010 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 - by the Free Software Foundation; either version 3, or (at your - option) any later version. - - GNUnet is distributed in the hope that it will be useful, but - WITHOUT ANY WARRANTY; without even the implied warranty of - MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU - General Public License for more details. - - You should have received a copy of the GNU General Public License - along with GNUnet; see the file COPYING. If not, write to the - Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, - Boston, MA 02110-1301, USA. -*/ -/** - * @file transport/test_transport_api_unreliability_constant.c - * @brief test case for transports; ensures messages get - * through, regardless of order, constant packet size - * - * This test case serves as a base for unreliable - * transport test cases to check that the transports - * achieve reliable message delivery. - */ -#include "platform.h" -#include "gnunet_transport_service.h" -#include "gauger.h" -#include "transport-testing.h" - -/** - * Testcase timeout - */ -#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 900) - -/** - * How long until we give up on transmitting the message? - */ -#define TIMEOUT_TRANSMIT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 60) - -static char *test_source; - -static char *test_plugin; - -static char *test_name; - -static int ok; - -static struct GNUNET_SCHEDULER_Task * die_task; - -struct GNUNET_TRANSPORT_TESTING_PeerContext *p1; - -struct GNUNET_TRANSPORT_TESTING_PeerContext *p2; - -struct GNUNET_TRANSPORT_TransmitHandle *th; - -struct GNUNET_TRANSPORT_TESTING_Handle *tth; - -char *cfg_file_p1; - -char *cfg_file_p2; - -uint32_t max_bps_p1; -uint32_t max_bps_p2; - -static struct GNUNET_TRANSPORT_TESTING_ConnectRequest * cc; - -/* - * Testcase specific declarations - */ - -/** - * Note that this value must not significantly exceed - * 'MAX_PENDING' in 'gnunet-service-transport.c', otherwise - * messages may be dropped even for a reliable transport. - */ -#define TOTAL_MSGS (1024 * 3) - -#define MTYPE 12345 - -#define MSG_SIZE 10000 - -GNUNET_NETWORK_STRUCT_BEGIN - -struct TestMessage -{ - struct GNUNET_MessageHeader header; - uint32_t num; -}; -GNUNET_NETWORK_STRUCT_END - -static char *test_name; - -static int msg_scheduled; -static int msg_sent; -static int msg_recv_expected; -static int msg_recv; - -static int test_failed; - -static unsigned long long total_bytes; - -static struct GNUNET_TIME_Absolute start_time; - -/* - * END Testcase specific declarations - */ - -#if VERBOSE -#define OKPP do { ok++; FPRINTF (stderr, "Now at stage %u at %s:%u\n", ok, __FILE__, __LINE__); } while (0) -#else -#define OKPP do { ok++; } while (0) -#endif - -int -get_bit (const char *map, unsigned int bit); - -static void -end () -{ - unsigned long long delta; - char *value_name; - - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Stopping peers\n"); - - delta = GNUNET_TIME_absolute_get_duration (start_time).rel_value_us / (1000 * 1000); - FPRINTF (stderr, "\nThroughput was %llu kb/s total_bytes\n", - (total_bytes / 1024) / delta); - GNUNET_asprintf (&value_name, "unreliable_%s", test_plugin); - GAUGER ("TRANSPORT", value_name, (int) (total_bytes / 1024 / delta), - "kb/s"); - GNUNET_free (value_name); - - if (die_task != NULL) - GNUNET_SCHEDULER_cancel (die_task); - - if (th != NULL) - GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); - th = NULL; - - if (cc != NULL) - GNUNET_TRANSPORT_TESTING_connect_peers_cancel (tth, cc); - cc = NULL; - - GNUNET_TRANSPORT_TESTING_stop_peer (tth, p1); - GNUNET_TRANSPORT_TESTING_stop_peer (tth, p2); - - GNUNET_TRANSPORT_TESTING_done (tth); - - ok = 0; - if (test_failed == GNUNET_NO) - ok = GNUNET_SYSERR; - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "GOT %u of %u messages\n", msg_recv, - TOTAL_MSGS); -} - -static void -end_badly () -{ - die_task = NULL; - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Fail! Stopping peers\n"); - - if (test_failed == GNUNET_NO) - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Testcase timeout\n"); - else - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Reliability failed: Last message sent %u, Next message scheduled %u, Last message received %u, Message expected %u\n", - msg_sent, msg_scheduled, msg_recv, msg_recv_expected); - - if (th != NULL) - GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); - th = NULL; - - if (cc != NULL) - GNUNET_TRANSPORT_TESTING_connect_peers_cancel (tth, cc); - cc = NULL; - - if (p1 != NULL) - GNUNET_TRANSPORT_TESTING_stop_peer (tth, p1); - if (p2 != NULL) - GNUNET_TRANSPORT_TESTING_stop_peer (tth, p2); - - GNUNET_TRANSPORT_TESTING_done (tth); - - ok = GNUNET_SYSERR; -} - - -static unsigned int -get_size (unsigned int iter) -{ -/* - unsigned int ret; - ret = (iter * iter * iter); - return sizeof (struct TestMessage) + (ret % 60000); - */ - return MSG_SIZE; -} - - - - -static void -notify_receive (void *cls, const struct GNUNET_PeerIdentity *peer, - const struct GNUNET_MessageHeader *message) -{ - static int n; - - unsigned int s; - char cbuf[GNUNET_SERVER_MAX_MESSAGE_SIZE - 1]; - const struct TestMessage *hdr; - - hdr = (const struct TestMessage *) message; - - if (MTYPE != ntohs (message->type)) - return; - msg_recv_expected = n; - msg_recv = ntohl (hdr->num); - if (msg_recv_expected != msg_recv) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Expected message no %u, got %u\n", - msg_recv_expected, msg_recv); - if (NULL != die_task) - GNUNET_SCHEDULER_cancel (die_task); - test_failed = GNUNET_YES; - die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); - return; - } - - s = get_size (ntohl (hdr->num)); - if (ntohs (message->size) != s) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Expected message %u of size %u, got %u bytes of message %u\n", - ntohl (hdr->num), s, ntohs (message->size), ntohl (hdr->num)); - if (NULL != die_task) - GNUNET_SCHEDULER_cancel (die_task); - test_failed = GNUNET_YES; - die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); - return; - } - - memset (cbuf, ntohl (hdr->num), s - sizeof (struct TestMessage)); - if (0 != memcmp (cbuf, &hdr[1], s - sizeof (struct TestMessage))) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Expected message %u with bits %u, but body did not match\n", - ntohl (hdr->num), (unsigned char) n); - if (NULL != die_task) - GNUNET_SCHEDULER_cancel (die_task); - test_failed = GNUNET_YES; - die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); - return; - } -#if VERBOSE - if (ntohl (hdr->num) % 5 == 0) - { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Got message %u of size %u\n", - ntohl (hdr->num), ntohs (message->size)); - } -#endif - n++; - if (0 == (n % (TOTAL_MSGS / 100))) - { - FPRINTF (stderr, "%s", "."); - if (NULL != die_task) - GNUNET_SCHEDULER_cancel (die_task); - test_failed = GNUNET_YES; - die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL); - } - if (n == TOTAL_MSGS) - { - /* because of starting with 0 */ - msg_recv++; - FPRINTF (stderr, "%s", "\n"); - end (); - } -} - - -static size_t -notify_ready (void *cls, size_t size, void *buf) -{ - static int n; - char *cbuf = buf; - struct TestMessage hdr; - unsigned int s; - unsigned int ret; - - th = NULL; - - if (buf == NULL) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, - "Timeout occurred while waiting for transmit_ready\n"); - if (NULL != die_task) - GNUNET_SCHEDULER_cancel (die_task); - die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); - ok = 42; - return 0; - } - ret = 0; - s = get_size (n); - GNUNET_assert (size >= s); - GNUNET_assert (buf != NULL); - cbuf = buf; - do - { - hdr.header.size = htons (s); - hdr.header.type = htons (MTYPE); - hdr.num = htonl (n); - msg_sent = n; - GNUNET_memcpy (&cbuf[ret], &hdr, sizeof (struct TestMessage)); - ret += sizeof (struct TestMessage); - memset (&cbuf[ret], n, s - sizeof (struct TestMessage)); - ret += s - sizeof (struct TestMessage); -#if VERBOSE - if (n % 1 == 0) - { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Sending message %u of size %u\n", n, - s); - } - -#endif - n++; - s = get_size (n); - if (0 == GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 16)) - break; /* sometimes pack buffer full, sometimes not */ - } - while (size - ret >= s); - if (n < TOTAL_MSGS) - { - th = GNUNET_TRANSPORT_notify_transmit_ready (p2->th, &p1->id, s, - TIMEOUT_TRANSMIT, - ¬ify_ready, NULL); - msg_scheduled = n; - } - else - { - FPRINTF (stderr, "%s", "\n"); - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "All messages scheduled to be sent!!\n"); - if (NULL != die_task) - GNUNET_SCHEDULER_cancel (die_task); - die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL); - } - if (n % 5000 == 0) - { - GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, - "Returning total message block of size %u\n", ret); - } - total_bytes += ret; - return ret; -} - - -static void -notify_connect (void *cls, const struct GNUNET_PeerIdentity *peer) -{ - - GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Peer `%4s' connected to us (%p)!\n", - GNUNET_i2s (peer), cls); -} - - -static void -notify_disconnect (void *cls, const struct GNUNET_PeerIdentity *peer) -{ - GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Peer `%4s' disconnected (%p)!\n", - GNUNET_i2s (peer), cls); - if (th != NULL) - GNUNET_TRANSPORT_notify_transmit_ready_cancel (th); - th = NULL; -} - -static void -sendtask () -{ - start_time = GNUNET_TIME_absolute_get (); - th = GNUNET_TRANSPORT_notify_transmit_ready (p2->th, &p1->id, get_size (0), - TIMEOUT_TRANSMIT, ¬ify_ready, - NULL); -} - -static void -testing_connect_cb (struct GNUNET_TRANSPORT_TESTING_PeerContext *p1, struct GNUNET_TRANSPORT_TESTING_PeerContext *p2, void *cls) -{ - char *p1_c = GNUNET_strdup (GNUNET_i2s (&p1->id)); - - GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Peers connected: %s <-> %s\n", p1_c, - GNUNET_i2s (&p2->id)); - GNUNET_free (p1_c); - - cc = NULL; - - GNUNET_SCHEDULER_add_now (&sendtask, NULL); -} - -void -start_cb (struct GNUNET_TRANSPORT_TESTING_PeerContext *p, void *cls) -{ - static int started; - - started++; - - GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Peer %u (`%s') started\n", p->no, - GNUNET_i2s (&p->id)); - - if (started != 2) - return; - - cc = GNUNET_TRANSPORT_TESTING_connect_peers (tth, p1, p2, &testing_connect_cb, - NULL); -} - -static void -run (void *cls, char *const *args, const char *cfgfile, - const struct GNUNET_CONFIGURATION_Handle *cfg) -{ - die_task = GNUNET_SCHEDULER_add_delayed (TIMEOUT, &end_badly, NULL); - - p1 = GNUNET_TRANSPORT_TESTING_start_peer (tth, cfg_file_p1, 1, - ¬ify_receive, ¬ify_connect, - ¬ify_disconnect, &start_cb, - NULL); - p2 = GNUNET_TRANSPORT_TESTING_start_peer (tth, cfg_file_p2, 2, - ¬ify_receive, ¬ify_connect, - ¬ify_disconnect, &start_cb, - NULL); - - if ((p1 == NULL) || (p2 == NULL)) - { - GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Fail! Could not start peers!\n"); - if (die_task != NULL) - GNUNET_SCHEDULER_cancel (die_task); - die_task = GNUNET_SCHEDULER_add_now (&end_badly, NULL); - return; - } -} - -static int -check () -{ - static char *const argv[] = { "test-transport-api-unreliability-constant", - "-c", - "test_transport_api_data.conf", - NULL - }; - static struct GNUNET_GETOPT_CommandLineOption options[] = { - GNUNET_GETOPT_OPTION_END - }; - - ok = GNUNET_SYSERR; - - GNUNET_PROGRAM_run ((sizeof (argv) / sizeof (char *)) - 1, argv, test_name, - "nohelp", options, &run, &ok); - - return ok; -} - -int -main (int argc, char *argv[]) -{ - int ret; - - GNUNET_TRANSPORT_TESTING_get_test_name (argv[0], &test_name); - - GNUNET_log_setup (test_name, - "WARNING", - NULL); - - GNUNET_TRANSPORT_TESTING_get_test_source_name (__FILE__, &test_source); - GNUNET_TRANSPORT_TESTING_get_test_plugin_name (argv[0], test_source, - &test_plugin); - - tth = GNUNET_TRANSPORT_TESTING_init (); - - GNUNET_TRANSPORT_TESTING_get_config_name (argv[0], &cfg_file_p1, 1); - GNUNET_TRANSPORT_TESTING_get_config_name (argv[0], &cfg_file_p2, 2); - - ret = check (); - - GNUNET_free (cfg_file_p1); - GNUNET_free (cfg_file_p2); - - GNUNET_free (test_source); - GNUNET_free (test_plugin); - GNUNET_free (test_name); - - return ret; -} - -/* end of test_transport_api_unreliability_constant.c */ -- cgit v1.2.3