[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r22220 - gnunet/src/fs
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] r22220 - gnunet/src/fs |
|
Date: |
Sat, 23 Jun 2012 10:36:58 +0200 |
Author: grothoff
Date: 2012-06-23 10:36:58 +0200 (Sat, 23 Jun 2012)
New Revision: 22220
Added:
gnunet/src/fs/perf_gnunet_service_fs_p2p_respect.c
Removed:
gnunet/src/fs/perf_gnunet_service_fs_p2p_trust.c
Modified:
gnunet/src/fs/Makefile.am
Log:
-renaming for consistency
Modified: gnunet/src/fs/Makefile.am
===================================================================
--- gnunet/src/fs/Makefile.am 2012-06-23 08:35:49 UTC (rev 22219)
+++ gnunet/src/fs/Makefile.am 2012-06-23 08:36:58 UTC (rev 22220)
@@ -201,7 +201,7 @@
perf_gnunet_service_fs_p2p \
perf_gnunet_service_fs_p2p_dht \
perf_gnunet_service_fs_p2p_index \
- perf_gnunet_service_fs_p2p_trust
+ perf_gnunet_service_fs_p2p_respect
endif
check_PROGRAMS = \
Copied: gnunet/src/fs/perf_gnunet_service_fs_p2p_respect.c (from rev 22214,
gnunet/src/fs/perf_gnunet_service_fs_p2p_trust.c)
===================================================================
--- gnunet/src/fs/perf_gnunet_service_fs_p2p_respect.c
(rev 0)
+++ gnunet/src/fs/perf_gnunet_service_fs_p2p_respect.c 2012-06-23 08:36:58 UTC
(rev 22220)
@@ -0,0 +1,418 @@
+/*
+ This file is part of GNUnet.
+ (C) 2010, 2011 Christian Grothoff (and other contributing authors)
+
+ 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., 59 Temple Place - Suite 330,
+ Boston, MA 02111-1307, USA.
+*/
+
+/**
+ * @file fs/perf_gnunet_service_fs_p2p_respect.c
+ * @brief profile P2P routing respect mechanism. Creates
+ * a clique of NUM_DAEMONS (i.e. 3) where two
+ * peers share (seed) different files and download
+ * them from each other while all the other peers
+ * just "leach" those files. Ideally, the seeders
+ * "learn" that they contribute (to each other),
+ * and give the other seeder higher priority;
+ * naturally, this only happens nicely for larger
+ * files; finally, once the seeders are done, the
+ * leachers should see fast download rates as well.
+ * @author Christian Grothoff
+ *
+ * Sample output:
+ * - 10 MB, 3 peers, with delays:
+ * Download speed of type `seeder 1' was 757 KiB/s
+ * Download speed of type `seeder 2' was 613 KiB/s
+ * Download speed of type `leach` was 539 KiB/s
+ *
+ * - 10 MB, 3 peers, without delays:
+ * Download speed of type `seeder 1' was 1784 KiB/s
+ * Download speed of type `seeder 2' was 1604 KiB/s
+ * Download speed of type `leach` was 1384 KiB/s
+ */
+#include "platform.h"
+#include "fs_test_lib.h"
+#include "gnunet_testing_lib.h"
+
+#define VERBOSE GNUNET_NO
+
+/**
+ * File-size we use for testing.
+ */
+#define FILESIZE (1024 * 1024 * 1)
+
+/**
+ * How long until we give up on transmitting the message?
+ */
+#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 30)
+
+/**
+ * Number of daemons in clique, must be at least 3 (!).
+ */
+#define NUM_DAEMONS 3
+
+/**
+ * Seed for first file on offer.
+ */
+#define SEED1 42
+
+/**
+ * Seed for second file on offer.
+ */
+#define SEED2 43
+
+static struct GNUNET_FS_TestDaemon *daemons[NUM_DAEMONS];
+
+static int ok;
+
+static struct GNUNET_TIME_Absolute start_time;
+
+static const char *progname;
+
+static struct GNUNET_FS_Uri *uri1;
+
+static struct GNUNET_FS_Uri *uri2;
+
+static void
+do_stop (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+ GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
+}
+
+
+/**
+ * Master context for 'stat_run'.
+ */
+struct StatMaster
+{
+ struct GNUNET_STATISTICS_Handle *stat;
+ unsigned int daemon;
+ unsigned int value;
+};
+
+struct StatValues
+{
+ const char *subsystem;
+ const char *name;
+};
+
+/**
+ * Statistics we print out.
+ */
+static struct StatValues stats[] = {
+ {"fs", "# artificial delays introduced (ms)"},
+ {"fs", "# queries forwarded"},
+ {"fs", "# replies received and matched"},
+ {"fs", "# results found locally"},
+ {"fs", "# requests forwarded due to high load"},
+ {"fs", "# requests done for free (low load)"},
+ {"fs", "# requests dropped, priority insufficient"},
+ {"fs", "# requests done for a price (normal load)"},
+ {"fs", "# requests dropped by datastore (queue length limit)"},
+ {"fs", "# P2P searches received"},
+ {"fs", "# P2P searches discarded (queue length bound)"},
+ {"fs", "# replies received for local clients"},
+ {"fs", "# queries retransmitted to same target"},
+ {"core", "# bytes decrypted"},
+ {"core", "# bytes encrypted"},
+ {"core", "# discarded CORE_SEND requests"},
+ {"core", "# discarded lower priority CORE_SEND requests"},
+ {"transport", "# bytes received via TCP"},
+ {"transport", "# bytes transmitted via TCP"},
+ {"datacache", "# bytes stored"},
+ {NULL, NULL}
+};
+
+
+/**
+ * Callback function to process statistic values.
+ *
+ * @param cls closure
+ * @param subsystem name of subsystem that created the statistic
+ * @param name the name of the datum
+ * @param value the current value
+ * @param is_persistent GNUNET_YES if the value is persistent, GNUNET_NO if not
+ * @return GNUNET_OK to continue, GNUNET_SYSERR to abort iteration
+ */
+static int
+print_stat (void *cls, const char *subsystem, const char *name, uint64_t value,
+ int is_persistent)
+{
+ struct StatMaster *sm = cls;
+
+ FPRINTF (stderr, "Peer %2u: %12s/%50s = %12llu\n", sm->daemon, subsystem,
+ name, (unsigned long long) value);
+ return GNUNET_OK;
+}
+
+
+/**
+ * Function that gathers stats from all daemons.
+ */
+static void
+stat_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc);
+
+
+/**
+ * Function called when GET operation on stats is done.
+ */
+static void
+get_done (void *cls, int success)
+{
+ struct StatMaster *sm = cls;
+
+ GNUNET_break (GNUNET_OK == success);
+ sm->value++;
+ GNUNET_SCHEDULER_add_now (&stat_run, sm);
+}
+
+
+/**
+ * Function that gathers stats from all daemons.
+ */
+static void
+stat_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+ struct StatMaster *sm = cls;
+
+ if (stats[sm->value].name != NULL)
+ {
+ GNUNET_STATISTICS_get (sm->stat,
+#if 0
+ NULL, NULL,
+#else
+ stats[sm->value].subsystem, stats[sm->value].name,
+#endif
+ GNUNET_TIME_UNIT_FOREVER_REL, &get_done,
&print_stat,
+ sm);
+ return;
+ }
+ GNUNET_STATISTICS_destroy (sm->stat, GNUNET_NO);
+ sm->value = 0;
+ sm->daemon++;
+ if (sm->daemon == NUM_DAEMONS)
+ {
+ GNUNET_free (sm);
+ GNUNET_SCHEDULER_add_now (&do_stop, NULL);
+ return;
+ }
+ sm->stat =
+ GNUNET_STATISTICS_create ("<driver>",
+ GNUNET_FS_TEST_get_configuration (daemons,
+ sm->daemon));
+ GNUNET_SCHEDULER_add_now (&stat_run, sm);
+}
+
+
+static void
+do_report (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+ static int download_counter;
+ const char *type = cls;
+ struct GNUNET_TIME_Relative del;
+ char *fancy;
+ struct StatMaster *sm;
+
+ if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE))
+ {
+ del = GNUNET_TIME_absolute_get_duration (start_time);
+ if (del.rel_value == 0)
+ del.rel_value = 1;
+ fancy =
+ GNUNET_STRINGS_byte_size_fancy (((unsigned long long) FILESIZE) *
+ 1000LL / del.rel_value);
+ FPRINTF (stderr, "Download speed of type `%s' was %s/s\n", type, fancy);
+ GNUNET_free (fancy);
+ if (NUM_DAEMONS != ++download_counter)
+ return; /* more downloads to come */
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Finished all downloads, shutting down\n",
+ (unsigned long long) FILESIZE);
+ sm = GNUNET_malloc (sizeof (struct StatMaster));
+ sm->stat =
+ GNUNET_STATISTICS_create ("<driver>",
+ GNUNET_FS_TEST_get_configuration (daemons,
+
sm->daemon));
+ GNUNET_SCHEDULER_add_now (&stat_run, sm);
+ }
+ else
+ {
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Timeout during download for type `%s', shutting down with
error\n",
+ type);
+ ok = 1;
+ GNUNET_SCHEDULER_add_now (&do_stop, NULL);
+ }
+}
+
+
+static void
+do_downloads (void *cls, const struct GNUNET_FS_Uri *u2)
+{
+ int anonymity;
+ unsigned int i;
+
+ if (NULL == u2)
+ {
+ GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Timeout during upload attempt, shutting down with error\n");
+ ok = 1;
+ return;
+ }
+ uri2 = GNUNET_FS_uri_dup (u2);
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Downloading %llu bytes\n",
+ (unsigned long long) FILESIZE);
+ start_time = GNUNET_TIME_absolute_get ();
+ if (NULL != strstr (progname, "dht"))
+ anonymity = 0;
+ else
+ anonymity = 1;
+ /* (semi) leach-download(s); not true leaches since
+ * these peers do participate in sharing, they just
+ * don't have to offer anything *initially*. */
+ for (i = 0; i < NUM_DAEMONS - 2; i++)
+ GNUNET_FS_TEST_download (daemons[i], TIMEOUT, anonymity,
+ 0 == (i % 2) ? SEED1 : SEED2,
+ 0 == (i % 2) ? uri1 : uri2, VERBOSE, &do_report,
+ "leach");
+ /* mutual downloads of (primary) sharing peers */
+ GNUNET_FS_TEST_download (daemons[NUM_DAEMONS - 2], TIMEOUT, anonymity, SEED1,
+ uri1, VERBOSE, &do_report, "seeder 2");
+ GNUNET_FS_TEST_download (daemons[NUM_DAEMONS - 1], TIMEOUT, anonymity, SEED2,
+ uri2, VERBOSE, &do_report, "seeder 1");
+}
+
+
+static void
+do_publish2 (void *cls, const struct GNUNET_FS_Uri *u1)
+{
+ int do_index;
+ int anonymity;
+
+ if (NULL == u1)
+ {
+ GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
+ "Timeout during upload attempt, shutting down with error\n");
+ ok = 1;
+ return;
+ }
+ uri1 = GNUNET_FS_uri_dup (u1);
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Publishing %llu bytes\n",
+ (unsigned long long) FILESIZE);
+ if (NULL != strstr (progname, "index"))
+ do_index = GNUNET_YES;
+ else
+ do_index = GNUNET_NO;
+ if (NULL != strstr (progname, "dht"))
+ anonymity = 0;
+ else
+ anonymity = 1;
+
+ GNUNET_FS_TEST_publish (daemons[NUM_DAEMONS - 2], TIMEOUT, anonymity,
+ do_index, FILESIZE, SEED2, VERBOSE, &do_downloads,
+ NULL);
+}
+
+static void
+do_publish1 (void *cls, const char *emsg)
+{
+ int do_index;
+ int anonymity;
+
+ if (NULL != emsg)
+ {
+ GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
+ GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Error trying to connect: %s\n",
emsg);
+ ok = 1;
+ return;
+ }
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Publishing %llu bytes\n",
+ (unsigned long long) FILESIZE);
+ if (NULL != strstr (progname, "index"))
+ do_index = GNUNET_YES;
+ else
+ do_index = GNUNET_NO;
+ if (NULL != strstr (progname, "dht"))
+ anonymity = 0;
+ else
+ anonymity = 1;
+
+ GNUNET_FS_TEST_publish (daemons[NUM_DAEMONS - 1], TIMEOUT, anonymity,
+ do_index, FILESIZE, SEED1, VERBOSE, &do_publish2,
+ NULL);
+}
+
+
+static void
+do_connect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
+{
+ struct GNUNET_TESTING_PeerGroup *pg;
+
+ GNUNET_assert (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE));
+ GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
+ "Daemons started, will now try to connect them\n");
+ pg = GNUNET_FS_TEST_get_group (daemons);
+ GNUNET_TESTING_create_topology (pg, GNUNET_TESTING_TOPOLOGY_CLIQUE,
+ GNUNET_TESTING_TOPOLOGY_NONE, NULL);
+ GNUNET_TESTING_connect_topology (pg, GNUNET_TESTING_TOPOLOGY_CLIQUE,
+ GNUNET_TESTING_TOPOLOGY_OPTION_NONE, 0.0,
+ TIMEOUT, NUM_DAEMONS, &do_publish1, NULL);
+}
+
+
+static void
+run (void *cls, char *const *args, const char *cfgfile,
+ const struct GNUNET_CONFIGURATION_Handle *cfg)
+{
+ GNUNET_FS_TEST_daemons_start ("fs_test_lib_data.conf", TIMEOUT, NUM_DAEMONS,
+ daemons, &do_connect, NULL);
+}
+
+
+int
+main (int argc, char *argv[])
+{
+ char *const argvx[] = {
+ "perf-gnunet-service-fs-p2p",
+ "-c",
+ "fs_test_lib_data.conf",
+#if VERBOSE
+ "-L", "DEBUG",
+#endif
+ NULL
+ };
+ struct GNUNET_GETOPT_CommandLineOption options[] = {
+ GNUNET_GETOPT_OPTION_END
+ };
+ progname = argv[0];
+ GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-lib/");
+ GNUNET_log_setup ("perf_gnunet_service_fs_p2p_respect",
+#if VERBOSE
+ "DEBUG",
+#else
+ "WARNING",
+#endif
+ NULL);
+ GNUNET_PROGRAM_run ((sizeof (argvx) / sizeof (char *)) - 1, argvx,
+ "perf-gnunet-service-fs-p2p-respect", "nohelp", options,
+ &run, NULL);
+ GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-lib/");
+ return ok;
+}
+
+/* end of perf_gnunet_service_fs_p2p_respect.c */
Deleted: gnunet/src/fs/perf_gnunet_service_fs_p2p_trust.c
===================================================================
--- gnunet/src/fs/perf_gnunet_service_fs_p2p_trust.c 2012-06-23 08:35:49 UTC
(rev 22219)
+++ gnunet/src/fs/perf_gnunet_service_fs_p2p_trust.c 2012-06-23 08:36:58 UTC
(rev 22220)
@@ -1,418 +0,0 @@
-/*
- This file is part of GNUnet.
- (C) 2010, 2011 Christian Grothoff (and other contributing authors)
-
- 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., 59 Temple Place - Suite 330,
- Boston, MA 02111-1307, USA.
-*/
-
-/**
- * @file fs/perf_gnunet_service_fs_p2p_trust.c
- * @brief profile P2P routing trust mechanism. Creates
- * a clique of NUM_DAEMONS (i.e. 3) where two
- * peers share (seed) different files and download
- * them from each other while all the other peers
- * just "leach" those files. Ideally, the seeders
- * "learn" that they contribute (to each other),
- * and give the other seeder higher priority;
- * naturally, this only happens nicely for larger
- * files; finally, once the seeders are done, the
- * leachers should see fast download rates as well.
- * @author Christian Grothoff
- *
- * Sample output:
- * - 10 MB, 3 peers, with delays:
- * Download speed of type `seeder 1' was 757 KiB/s
- * Download speed of type `seeder 2' was 613 KiB/s
- * Download speed of type `leach` was 539 KiB/s
- *
- * - 10 MB, 3 peers, without delays:
- * Download speed of type `seeder 1' was 1784 KiB/s
- * Download speed of type `seeder 2' was 1604 KiB/s
- * Download speed of type `leach` was 1384 KiB/s
- */
-#include "platform.h"
-#include "fs_test_lib.h"
-#include "gnunet_testing_lib.h"
-
-#define VERBOSE GNUNET_NO
-
-/**
- * File-size we use for testing.
- */
-#define FILESIZE (1024 * 1024 * 1)
-
-/**
- * How long until we give up on transmitting the message?
- */
-#define TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_MINUTES, 30)
-
-/**
- * Number of daemons in clique, must be at least 3 (!).
- */
-#define NUM_DAEMONS 3
-
-/**
- * Seed for first file on offer.
- */
-#define SEED1 42
-
-/**
- * Seed for second file on offer.
- */
-#define SEED2 43
-
-static struct GNUNET_FS_TestDaemon *daemons[NUM_DAEMONS];
-
-static int ok;
-
-static struct GNUNET_TIME_Absolute start_time;
-
-static const char *progname;
-
-static struct GNUNET_FS_Uri *uri1;
-
-static struct GNUNET_FS_Uri *uri2;
-
-static void
-do_stop (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
-{
- GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
-}
-
-
-/**
- * Master context for 'stat_run'.
- */
-struct StatMaster
-{
- struct GNUNET_STATISTICS_Handle *stat;
- unsigned int daemon;
- unsigned int value;
-};
-
-struct StatValues
-{
- const char *subsystem;
- const char *name;
-};
-
-/**
- * Statistics we print out.
- */
-static struct StatValues stats[] = {
- {"fs", "# artificial delays introduced (ms)"},
- {"fs", "# queries forwarded"},
- {"fs", "# replies received and matched"},
- {"fs", "# results found locally"},
- {"fs", "# requests forwarded due to high load"},
- {"fs", "# requests done for free (low load)"},
- {"fs", "# requests dropped, priority insufficient"},
- {"fs", "# requests done for a price (normal load)"},
- {"fs", "# requests dropped by datastore (queue length limit)"},
- {"fs", "# P2P searches received"},
- {"fs", "# P2P searches discarded (queue length bound)"},
- {"fs", "# replies received for local clients"},
- {"fs", "# queries retransmitted to same target"},
- {"core", "# bytes decrypted"},
- {"core", "# bytes encrypted"},
- {"core", "# discarded CORE_SEND requests"},
- {"core", "# discarded lower priority CORE_SEND requests"},
- {"transport", "# bytes received via TCP"},
- {"transport", "# bytes transmitted via TCP"},
- {"datacache", "# bytes stored"},
- {NULL, NULL}
-};
-
-
-/**
- * Callback function to process statistic values.
- *
- * @param cls closure
- * @param subsystem name of subsystem that created the statistic
- * @param name the name of the datum
- * @param value the current value
- * @param is_persistent GNUNET_YES if the value is persistent, GNUNET_NO if not
- * @return GNUNET_OK to continue, GNUNET_SYSERR to abort iteration
- */
-static int
-print_stat (void *cls, const char *subsystem, const char *name, uint64_t value,
- int is_persistent)
-{
- struct StatMaster *sm = cls;
-
- FPRINTF (stderr, "Peer %2u: %12s/%50s = %12llu\n", sm->daemon, subsystem,
- name, (unsigned long long) value);
- return GNUNET_OK;
-}
-
-
-/**
- * Function that gathers stats from all daemons.
- */
-static void
-stat_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc);
-
-
-/**
- * Function called when GET operation on stats is done.
- */
-static void
-get_done (void *cls, int success)
-{
- struct StatMaster *sm = cls;
-
- GNUNET_break (GNUNET_OK == success);
- sm->value++;
- GNUNET_SCHEDULER_add_now (&stat_run, sm);
-}
-
-
-/**
- * Function that gathers stats from all daemons.
- */
-static void
-stat_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
-{
- struct StatMaster *sm = cls;
-
- if (stats[sm->value].name != NULL)
- {
- GNUNET_STATISTICS_get (sm->stat,
-#if 0
- NULL, NULL,
-#else
- stats[sm->value].subsystem, stats[sm->value].name,
-#endif
- GNUNET_TIME_UNIT_FOREVER_REL, &get_done,
&print_stat,
- sm);
- return;
- }
- GNUNET_STATISTICS_destroy (sm->stat, GNUNET_NO);
- sm->value = 0;
- sm->daemon++;
- if (sm->daemon == NUM_DAEMONS)
- {
- GNUNET_free (sm);
- GNUNET_SCHEDULER_add_now (&do_stop, NULL);
- return;
- }
- sm->stat =
- GNUNET_STATISTICS_create ("<driver>",
- GNUNET_FS_TEST_get_configuration (daemons,
- sm->daemon));
- GNUNET_SCHEDULER_add_now (&stat_run, sm);
-}
-
-
-static void
-do_report (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
-{
- static int download_counter;
- const char *type = cls;
- struct GNUNET_TIME_Relative del;
- char *fancy;
- struct StatMaster *sm;
-
- if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE))
- {
- del = GNUNET_TIME_absolute_get_duration (start_time);
- if (del.rel_value == 0)
- del.rel_value = 1;
- fancy =
- GNUNET_STRINGS_byte_size_fancy (((unsigned long long) FILESIZE) *
- 1000LL / del.rel_value);
- FPRINTF (stderr, "Download speed of type `%s' was %s/s\n", type, fancy);
- GNUNET_free (fancy);
- if (NUM_DAEMONS != ++download_counter)
- return; /* more downloads to come */
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Finished all downloads, shutting down\n",
- (unsigned long long) FILESIZE);
- sm = GNUNET_malloc (sizeof (struct StatMaster));
- sm->stat =
- GNUNET_STATISTICS_create ("<driver>",
- GNUNET_FS_TEST_get_configuration (daemons,
-
sm->daemon));
- GNUNET_SCHEDULER_add_now (&stat_run, sm);
- }
- else
- {
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- "Timeout during download for type `%s', shutting down with
error\n",
- type);
- ok = 1;
- GNUNET_SCHEDULER_add_now (&do_stop, NULL);
- }
-}
-
-
-static void
-do_downloads (void *cls, const struct GNUNET_FS_Uri *u2)
-{
- int anonymity;
- unsigned int i;
-
- if (NULL == u2)
- {
- GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- "Timeout during upload attempt, shutting down with error\n");
- ok = 1;
- return;
- }
- uri2 = GNUNET_FS_uri_dup (u2);
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Downloading %llu bytes\n",
- (unsigned long long) FILESIZE);
- start_time = GNUNET_TIME_absolute_get ();
- if (NULL != strstr (progname, "dht"))
- anonymity = 0;
- else
- anonymity = 1;
- /* (semi) leach-download(s); not true leaches since
- * these peers do participate in sharing, they just
- * don't have to offer anything *initially*. */
- for (i = 0; i < NUM_DAEMONS - 2; i++)
- GNUNET_FS_TEST_download (daemons[i], TIMEOUT, anonymity,
- 0 == (i % 2) ? SEED1 : SEED2,
- 0 == (i % 2) ? uri1 : uri2, VERBOSE, &do_report,
- "leach");
- /* mutual downloads of (primary) sharing peers */
- GNUNET_FS_TEST_download (daemons[NUM_DAEMONS - 2], TIMEOUT, anonymity, SEED1,
- uri1, VERBOSE, &do_report, "seeder 2");
- GNUNET_FS_TEST_download (daemons[NUM_DAEMONS - 1], TIMEOUT, anonymity, SEED2,
- uri2, VERBOSE, &do_report, "seeder 1");
-}
-
-
-static void
-do_publish2 (void *cls, const struct GNUNET_FS_Uri *u1)
-{
- int do_index;
- int anonymity;
-
- if (NULL == u1)
- {
- GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
- "Timeout during upload attempt, shutting down with error\n");
- ok = 1;
- return;
- }
- uri1 = GNUNET_FS_uri_dup (u1);
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Publishing %llu bytes\n",
- (unsigned long long) FILESIZE);
- if (NULL != strstr (progname, "index"))
- do_index = GNUNET_YES;
- else
- do_index = GNUNET_NO;
- if (NULL != strstr (progname, "dht"))
- anonymity = 0;
- else
- anonymity = 1;
-
- GNUNET_FS_TEST_publish (daemons[NUM_DAEMONS - 2], TIMEOUT, anonymity,
- do_index, FILESIZE, SEED2, VERBOSE, &do_downloads,
- NULL);
-}
-
-static void
-do_publish1 (void *cls, const char *emsg)
-{
- int do_index;
- int anonymity;
-
- if (NULL != emsg)
- {
- GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS, daemons);
- GNUNET_log (GNUNET_ERROR_TYPE_ERROR, "Error trying to connect: %s\n",
emsg);
- ok = 1;
- return;
- }
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "Publishing %llu bytes\n",
- (unsigned long long) FILESIZE);
- if (NULL != strstr (progname, "index"))
- do_index = GNUNET_YES;
- else
- do_index = GNUNET_NO;
- if (NULL != strstr (progname, "dht"))
- anonymity = 0;
- else
- anonymity = 1;
-
- GNUNET_FS_TEST_publish (daemons[NUM_DAEMONS - 1], TIMEOUT, anonymity,
- do_index, FILESIZE, SEED1, VERBOSE, &do_publish2,
- NULL);
-}
-
-
-static void
-do_connect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
-{
- struct GNUNET_TESTING_PeerGroup *pg;
-
- GNUNET_assert (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE));
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "Daemons started, will now try to connect them\n");
- pg = GNUNET_FS_TEST_get_group (daemons);
- GNUNET_TESTING_create_topology (pg, GNUNET_TESTING_TOPOLOGY_CLIQUE,
- GNUNET_TESTING_TOPOLOGY_NONE, NULL);
- GNUNET_TESTING_connect_topology (pg, GNUNET_TESTING_TOPOLOGY_CLIQUE,
- GNUNET_TESTING_TOPOLOGY_OPTION_NONE, 0.0,
- TIMEOUT, NUM_DAEMONS, &do_publish1, NULL);
-}
-
-
-static void
-run (void *cls, char *const *args, const char *cfgfile,
- const struct GNUNET_CONFIGURATION_Handle *cfg)
-{
- GNUNET_FS_TEST_daemons_start ("fs_test_lib_data.conf", TIMEOUT, NUM_DAEMONS,
- daemons, &do_connect, NULL);
-}
-
-
-int
-main (int argc, char *argv[])
-{
- char *const argvx[] = {
- "perf-gnunet-service-fs-p2p",
- "-c",
- "fs_test_lib_data.conf",
-#if VERBOSE
- "-L", "DEBUG",
-#endif
- NULL
- };
- struct GNUNET_GETOPT_CommandLineOption options[] = {
- GNUNET_GETOPT_OPTION_END
- };
- progname = argv[0];
- GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-lib/");
- GNUNET_log_setup ("perf_gnunet_service_fs_p2p_trust",
-#if VERBOSE
- "DEBUG",
-#else
- "WARNING",
-#endif
- NULL);
- GNUNET_PROGRAM_run ((sizeof (argvx) / sizeof (char *)) - 1, argvx,
- "perf-gnunet-service-fs-p2p-trust", "nohelp", options,
- &run, NULL);
- GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-lib/");
- return ok;
-}
-
-/* end of perf_gnunet_service_fs_p2p_trust.c */
| [Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r22220 - gnunet/src/fs,
gnunet <=