diff options
author | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
---|---|---|
committer | Nathan S. Evans <evans@in.tum.de> | 2010-11-05 18:21:50 +0000 |
commit | 75a33a1499cf60ea4364c9aa673816629a6c1413 (patch) | |
tree | 0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/fs/test_gnunet_service_fs_migration.c | |
parent | 7217c601ad30760872823193d62307e7a335d226 (diff) | |
download | gnunet-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.c | 31 |
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 | ||
49 | static struct GNUNET_FS_TestDaemon *daemons[2]; | 49 | static struct GNUNET_FS_TestDaemon *daemons[2]; |
50 | 50 | ||
51 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
52 | |||
53 | static int ok; | 51 | static int ok; |
54 | 52 | ||
55 | static struct GNUNET_TIME_Absolute start_time; | 53 | static 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 | ||
213 | static void | 203 | static void |
214 | run (void *cls, | 204 | run (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, |