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_fs_unindex_persistence.c | |
parent | 7217c601ad30760872823193d62307e7a335d226 (diff) | |
download | gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.tar.gz gnunet-75a33a1499cf60ea4364c9aa673816629a6c1413.zip |
big scheduler refactoring, expect some issues
Diffstat (limited to 'src/fs/test_fs_unindex_persistence.c')
-rw-r--r-- | src/fs/test_fs_unindex_persistence.c | 25 |
1 files changed, 7 insertions, 18 deletions
diff --git a/src/fs/test_fs_unindex_persistence.c b/src/fs/test_fs_unindex_persistence.c index 42f047b70..eec181544 100644 --- a/src/fs/test_fs_unindex_persistence.c +++ b/src/fs/test_fs_unindex_persistence.c | |||
@@ -59,8 +59,6 @@ static struct PeerContext p1; | |||
59 | 59 | ||
60 | static struct GNUNET_TIME_Absolute start; | 60 | static struct GNUNET_TIME_Absolute start; |
61 | 61 | ||
62 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
63 | |||
64 | static struct GNUNET_FS_Handle *fs; | 62 | static struct GNUNET_FS_Handle *fs; |
65 | 63 | ||
66 | static struct GNUNET_FS_UnindexContext *unindex; | 64 | static struct GNUNET_FS_UnindexContext *unindex; |
@@ -108,8 +106,7 @@ restart_fs_task (void *cls, | |||
108 | const struct GNUNET_SCHEDULER_TaskContext *tc) | 106 | const struct GNUNET_SCHEDULER_TaskContext *tc) |
109 | { | 107 | { |
110 | GNUNET_FS_stop (fs); | 108 | GNUNET_FS_stop (fs); |
111 | fs = GNUNET_FS_start (sched, | 109 | fs = GNUNET_FS_start (cfg, |
112 | cfg, | ||
113 | "test-fs-unindex-persistence", | 110 | "test-fs-unindex-persistence", |
114 | &progress_cb, | 111 | &progress_cb, |
115 | NULL, | 112 | NULL, |
@@ -135,8 +132,7 @@ consider_restart (int ev) | |||
135 | if (prev[i] == ev) | 132 | if (prev[i] == ev) |
136 | return; | 133 | return; |
137 | prev[off++] = ev; | 134 | prev[off++] = ev; |
138 | GNUNET_SCHEDULER_add_with_priority (sched, | 135 | GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_URGENT, |
139 | GNUNET_SCHEDULER_PRIORITY_URGENT, | ||
140 | &restart_fs_task, | 136 | &restart_fs_task, |
141 | NULL); | 137 | NULL); |
142 | } | 138 | } |
@@ -169,8 +165,7 @@ progress_cb (void *cls, | |||
169 | case GNUNET_FS_STATUS_UNINDEX_COMPLETED: | 165 | case GNUNET_FS_STATUS_UNINDEX_COMPLETED: |
170 | printf ("Unindex complete, %llu kbps.\n", | 166 | printf ("Unindex complete, %llu kbps.\n", |
171 | (unsigned long long) (FILESIZE * 1000 / (1+GNUNET_TIME_absolute_get_duration (start).rel_value) / 1024)); | 167 | (unsigned long long) (FILESIZE * 1000 / (1+GNUNET_TIME_absolute_get_duration (start).rel_value) / 1024)); |
172 | GNUNET_SCHEDULER_add_continuation (sched, | 168 | GNUNET_SCHEDULER_add_continuation (&abort_unindex_task, |
173 | &abort_unindex_task, | ||
174 | NULL, | 169 | NULL, |
175 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 170 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
176 | break; | 171 | break; |
@@ -209,8 +204,7 @@ progress_cb (void *cls, | |||
209 | "Error publishing file: %s\n", | 204 | "Error publishing file: %s\n", |
210 | event->value.publish.specifics.error.message); | 205 | event->value.publish.specifics.error.message); |
211 | GNUNET_break (0); | 206 | GNUNET_break (0); |
212 | GNUNET_SCHEDULER_add_continuation (sched, | 207 | GNUNET_SCHEDULER_add_continuation (&abort_publish_task, |
213 | &abort_publish_task, | ||
214 | NULL, | 208 | NULL, |
215 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 209 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
216 | break; | 210 | break; |
@@ -218,8 +212,7 @@ progress_cb (void *cls, | |||
218 | fprintf (stderr, | 212 | fprintf (stderr, |
219 | "Error unindexing file: %s\n", | 213 | "Error unindexing file: %s\n", |
220 | event->value.unindex.specifics.error.message); | 214 | event->value.unindex.specifics.error.message); |
221 | GNUNET_SCHEDULER_add_continuation (sched, | 215 | GNUNET_SCHEDULER_add_continuation (&abort_unindex_task, |
222 | &abort_unindex_task, | ||
223 | NULL, | 216 | NULL, |
224 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 217 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
225 | break; | 218 | break; |
@@ -247,8 +240,7 @@ progress_cb (void *cls, | |||
247 | break; | 240 | break; |
248 | case GNUNET_FS_STATUS_UNINDEX_STOPPED: | 241 | case GNUNET_FS_STATUS_UNINDEX_STOPPED: |
249 | GNUNET_assert (unindex == event->value.unindex.uc); | 242 | GNUNET_assert (unindex == event->value.unindex.uc); |
250 | GNUNET_SCHEDULER_add_continuation (sched, | 243 | GNUNET_SCHEDULER_add_continuation (&abort_publish_task, |
251 | &abort_publish_task, | ||
252 | NULL, | 244 | NULL, |
253 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 245 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
254 | break; | 246 | break; |
@@ -296,7 +288,6 @@ stop_arm (struct PeerContext *p) | |||
296 | 288 | ||
297 | static void | 289 | static void |
298 | run (void *cls, | 290 | run (void *cls, |
299 | struct GNUNET_SCHEDULER_Handle *s, | ||
300 | char *const *args, | 291 | char *const *args, |
301 | const char *cfgfile, | 292 | const char *cfgfile, |
302 | const struct GNUNET_CONFIGURATION_Handle *c) | 293 | const struct GNUNET_CONFIGURATION_Handle *c) |
@@ -311,12 +302,10 @@ run (void *cls, | |||
311 | struct GNUNET_FS_FileInformation *fi; | 302 | struct GNUNET_FS_FileInformation *fi; |
312 | size_t i; | 303 | size_t i; |
313 | 304 | ||
314 | sched = s; | ||
315 | cfg = c; | 305 | cfg = c; |
316 | setup_peer (&p1, "test_fs_unindex_data.conf"); | 306 | setup_peer (&p1, "test_fs_unindex_data.conf"); |
317 | fn = GNUNET_DISK_mktemp ("gnunet-unindex-test-dst"); | 307 | fn = GNUNET_DISK_mktemp ("gnunet-unindex-test-dst"); |
318 | fs = GNUNET_FS_start (sched, | 308 | fs = GNUNET_FS_start (cfg, |
319 | cfg, | ||
320 | "test-fs-unindex-persistence", | 309 | "test-fs-unindex-persistence", |
321 | &progress_cb, | 310 | &progress_cb, |
322 | NULL, | 311 | NULL, |