aboutsummaryrefslogtreecommitdiff
path: root/src/fs/test_gnunet_service_fs_p2p.c
diff options
context:
space:
mode:
authorNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
committerNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
commit75a33a1499cf60ea4364c9aa673816629a6c1413 (patch)
tree0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/fs/test_gnunet_service_fs_p2p.c
parent7217c601ad30760872823193d62307e7a335d226 (diff)
downloadgnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.tar.gz
gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.zip
big scheduler refactoring, expect some issues
Diffstat (limited to 'src/fs/test_gnunet_service_fs_p2p.c')
-rw-r--r--src/fs/test_gnunet_service_fs_p2p.c25
1 files changed, 7 insertions, 18 deletions
diff --git a/src/fs/test_gnunet_service_fs_p2p.c b/src/fs/test_gnunet_service_fs_p2p.c
index f026baf6b..3bb808c48 100644
--- a/src/fs/test_gnunet_service_fs_p2p.c
+++ b/src/fs/test_gnunet_service_fs_p2p.c
@@ -44,8 +44,6 @@
44 44
45static struct GNUNET_FS_TestDaemon *daemons[NUM_DAEMONS]; 45static struct GNUNET_FS_TestDaemon *daemons[NUM_DAEMONS];
46 46
47static struct GNUNET_SCHEDULER_Handle *sched;
48
49static int ok; 47static int ok;
50 48
51static struct GNUNET_TIME_Absolute start_time; 49static struct GNUNET_TIME_Absolute start_time;
@@ -57,8 +55,7 @@ do_stop (void *cls,
57 struct GNUNET_TIME_Relative del; 55 struct GNUNET_TIME_Relative del;
58 char *fancy; 56 char *fancy;
59 57
60 GNUNET_FS_TEST_daemons_stop (sched, 58 GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS,
61 NUM_DAEMONS,
62 daemons); 59 daemons);
63 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) 60 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE))
64 { 61 {
@@ -89,8 +86,7 @@ do_download (void *cls,
89{ 86{
90 if (NULL == uri) 87 if (NULL == uri)
91 { 88 {
92 GNUNET_FS_TEST_daemons_stop (sched, 89 GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS,
93 NUM_DAEMONS,
94 daemons); 90 daemons);
95 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 91 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
96 "Timeout during upload attempt, shutting down with error\n"); 92 "Timeout during upload attempt, shutting down with error\n");
@@ -101,8 +97,7 @@ do_download (void *cls,
101 "Downloading %llu bytes\n", 97 "Downloading %llu bytes\n",
102 (unsigned long long) FILESIZE); 98 (unsigned long long) FILESIZE);
103 start_time = GNUNET_TIME_absolute_get (); 99 start_time = GNUNET_TIME_absolute_get ();
104 GNUNET_FS_TEST_download (sched, 100 GNUNET_FS_TEST_download (daemons[0],
105 daemons[0],
106 TIMEOUT, 101 TIMEOUT,
107 1, SEED, uri, 102 1, SEED, uri,
108 VERBOSE, 103 VERBOSE,
@@ -116,8 +111,7 @@ do_publish (void *cls,
116{ 111{
117 if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) 112 if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE))
118 { 113 {
119 GNUNET_FS_TEST_daemons_stop (sched, 114 GNUNET_FS_TEST_daemons_stop (NUM_DAEMONS,
120 NUM_DAEMONS,
121 daemons); 115 daemons);
122 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 116 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
123 "Timeout during connect attempt, shutting down with error\n"); 117 "Timeout during connect attempt, shutting down with error\n");
@@ -127,8 +121,7 @@ do_publish (void *cls,
127 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 121 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
128 "Publishing %llu bytes\n", 122 "Publishing %llu bytes\n",
129 (unsigned long long) FILESIZE); 123 (unsigned long long) FILESIZE);
130 GNUNET_FS_TEST_publish (sched, 124 GNUNET_FS_TEST_publish (daemons[1],
131 daemons[1],
132 TIMEOUT, 125 TIMEOUT,
133 1, GNUNET_NO, FILESIZE, SEED, 126 1, GNUNET_NO, FILESIZE, SEED,
134 VERBOSE, 127 VERBOSE,
@@ -143,8 +136,7 @@ do_connect (void *cls,
143 GNUNET_assert (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)); 136 GNUNET_assert (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE));
144 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 137 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
145 "Daemons started, will now try to connect them\n"); 138 "Daemons started, will now try to connect them\n");
146 GNUNET_FS_TEST_daemons_connect (sched, 139 GNUNET_FS_TEST_daemons_connect (daemons[0],
147 daemons[0],
148 daemons[1], 140 daemons[1],
149 TIMEOUT, 141 TIMEOUT,
150 &do_publish, 142 &do_publish,
@@ -154,14 +146,11 @@ do_connect (void *cls,
154 146
155static void 147static void
156run (void *cls, 148run (void *cls,
157 struct GNUNET_SCHEDULER_Handle *s,
158 char *const *args, 149 char *const *args,
159 const char *cfgfile, 150 const char *cfgfile,
160 const struct GNUNET_CONFIGURATION_Handle *cfg) 151 const struct GNUNET_CONFIGURATION_Handle *cfg)
161{ 152{
162 sched = s; 153 GNUNET_FS_TEST_daemons_start ("fs_test_lib_data.conf",
163 GNUNET_FS_TEST_daemons_start (sched,
164 "fs_test_lib_data.conf",
165 TIMEOUT, 154 TIMEOUT,
166 NUM_DAEMONS, 155 NUM_DAEMONS,
167 daemons, 156 daemons,