aboutsummaryrefslogtreecommitdiff
path: root/src/fs/test_gnunet_service_fs_migration.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_migration.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_migration.c')
-rw-r--r--src/fs/test_gnunet_service_fs_migration.c31
1 files changed, 9 insertions, 22 deletions
diff --git a/src/fs/test_gnunet_service_fs_migration.c b/src/fs/test_gnunet_service_fs_migration.c
index 3d6afbdc2..092cedfc2 100644
--- a/src/fs/test_gnunet_service_fs_migration.c
+++ b/src/fs/test_gnunet_service_fs_migration.c
@@ -48,8 +48,6 @@
48 48
49static struct GNUNET_FS_TestDaemon *daemons[2]; 49static struct GNUNET_FS_TestDaemon *daemons[2];
50 50
51static struct GNUNET_SCHEDULER_Handle *sched;
52
53static int ok; 51static int ok;
54 52
55static struct GNUNET_TIME_Absolute start_time; 53static struct GNUNET_TIME_Absolute start_time;
@@ -61,8 +59,7 @@ do_stop (void *cls,
61 struct GNUNET_TIME_Relative del; 59 struct GNUNET_TIME_Relative del;
62 char *fancy; 60 char *fancy;
63 61
64 GNUNET_FS_TEST_daemons_stop (sched, 62 GNUNET_FS_TEST_daemons_stop (2,
65 2,
66 daemons); 63 daemons);
67 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) 64 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE))
68 { 65 {
@@ -95,8 +92,7 @@ do_download (void *cls,
95 92
96 if (emsg != NULL) 93 if (emsg != NULL)
97 { 94 {
98 GNUNET_FS_TEST_daemons_stop (sched, 95 GNUNET_FS_TEST_daemons_stop (2,
99 2,
100 daemons); 96 daemons);
101 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 97 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
102 "Failed to stop source daemon: %s\n", 98 "Failed to stop source daemon: %s\n",
@@ -109,8 +105,7 @@ do_download (void *cls,
109 "Downloading %llu bytes\n", 105 "Downloading %llu bytes\n",
110 (unsigned long long) FILESIZE); 106 (unsigned long long) FILESIZE);
111 start_time = GNUNET_TIME_absolute_get (); 107 start_time = GNUNET_TIME_absolute_get ();
112 GNUNET_FS_TEST_download (sched, 108 GNUNET_FS_TEST_download (daemons[0],
113 daemons[0],
114 TIMEOUT, 109 TIMEOUT,
115 1, SEED, uri, 110 1, SEED, uri,
116 VERBOSE, 111 VERBOSE,
@@ -143,8 +138,7 @@ do_wait (void *cls,
143 138
144 if (NULL == uri) 139 if (NULL == uri)
145 { 140 {
146 GNUNET_FS_TEST_daemons_stop (sched, 141 GNUNET_FS_TEST_daemons_stop (2,
147 2,
148 daemons); 142 daemons);
149 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 143 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
150 "Timeout during upload attempt, shutting down with error\n"); 144 "Timeout during upload attempt, shutting down with error\n");
@@ -154,8 +148,7 @@ do_wait (void *cls,
154 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 148 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
155 "Waiting to allow content to migrate\n"); 149 "Waiting to allow content to migrate\n");
156 d = GNUNET_FS_uri_dup (uri); 150 d = GNUNET_FS_uri_dup (uri);
157 (void) GNUNET_SCHEDULER_add_delayed (sched, 151 (void) GNUNET_SCHEDULER_add_delayed (MIGRATION_DELAY,
158 MIGRATION_DELAY,
159 &stop_source_peer, 152 &stop_source_peer,
160 d); 153 d);
161} 154}
@@ -167,8 +160,7 @@ do_publish (void *cls,
167{ 160{
168 if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE)) 161 if (0 == (tc->reason & GNUNET_SCHEDULER_REASON_PREREQ_DONE))
169 { 162 {
170 GNUNET_FS_TEST_daemons_stop (sched, 163 GNUNET_FS_TEST_daemons_stop (2,
171 2,
172 daemons); 164 daemons);
173 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 165 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
174 "Timeout during connect attempt, shutting down with error\n"); 166 "Timeout during connect attempt, shutting down with error\n");
@@ -178,8 +170,7 @@ do_publish (void *cls,
178 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 170 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
179 "Publishing %llu bytes\n", 171 "Publishing %llu bytes\n",
180 (unsigned long long) FILESIZE); 172 (unsigned long long) FILESIZE);
181 GNUNET_FS_TEST_publish (sched, 173 GNUNET_FS_TEST_publish (daemons[1],
182 daemons[1],
183 TIMEOUT, 174 TIMEOUT,
184 1, GNUNET_NO, FILESIZE, SEED, 175 1, GNUNET_NO, FILESIZE, SEED,
185 VERBOSE, 176 VERBOSE,
@@ -201,8 +192,7 @@ do_connect (void *cls,
201 } 192 }
202 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 193 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
203 "Daemons started, will now try to connect them\n"); 194 "Daemons started, will now try to connect them\n");
204 GNUNET_FS_TEST_daemons_connect (sched, 195 GNUNET_FS_TEST_daemons_connect (daemons[0],
205 daemons[0],
206 daemons[1], 196 daemons[1],
207 TIMEOUT, 197 TIMEOUT,
208 &do_publish, 198 &do_publish,
@@ -212,14 +202,11 @@ do_connect (void *cls,
212 202
213static void 203static void
214run (void *cls, 204run (void *cls,
215 struct GNUNET_SCHEDULER_Handle *s,
216 char *const *args, 205 char *const *args,
217 const char *cfgfile, 206 const char *cfgfile,
218 const struct GNUNET_CONFIGURATION_Handle *cfg) 207 const struct GNUNET_CONFIGURATION_Handle *cfg)
219{ 208{
220 sched = s; 209 GNUNET_FS_TEST_daemons_start ("test_gnunet_service_fs_migration_data.conf",
221 GNUNET_FS_TEST_daemons_start (sched,
222 "test_gnunet_service_fs_migration_data.conf",
223 TIMEOUT, 210 TIMEOUT,
224 2, 211 2,
225 daemons, 212 daemons,