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_search.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_search.c')
-rw-r--r-- | src/fs/test_fs_search.c | 19 |
1 files changed, 5 insertions, 14 deletions
diff --git a/src/fs/test_fs_search.c b/src/fs/test_fs_search.c index 1609cd8e3..b003b75e1 100644 --- a/src/fs/test_fs_search.c +++ b/src/fs/test_fs_search.c | |||
@@ -61,8 +61,6 @@ static struct PeerContext p1; | |||
61 | 61 | ||
62 | static struct GNUNET_TIME_Absolute start; | 62 | static struct GNUNET_TIME_Absolute start; |
63 | 63 | ||
64 | static struct GNUNET_SCHEDULER_Handle *sched; | ||
65 | |||
66 | static struct GNUNET_FS_Handle *fs; | 64 | static struct GNUNET_FS_Handle *fs; |
67 | 65 | ||
68 | static struct GNUNET_FS_SearchContext *search; | 66 | static struct GNUNET_FS_SearchContext *search; |
@@ -124,8 +122,7 @@ progress_cb (void *cls, | |||
124 | #if VERBOSE | 122 | #if VERBOSE |
125 | printf ("Search complete.\n"); | 123 | printf ("Search complete.\n"); |
126 | #endif | 124 | #endif |
127 | GNUNET_SCHEDULER_add_continuation (sched, | 125 | GNUNET_SCHEDULER_add_continuation (&abort_search_task, |
128 | &abort_search_task, | ||
129 | NULL, | 126 | NULL, |
130 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 127 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
131 | break; | 128 | break; |
@@ -134,8 +131,7 @@ progress_cb (void *cls, | |||
134 | "Error publishing file: %s\n", | 131 | "Error publishing file: %s\n", |
135 | event->value.publish.specifics.error.message); | 132 | event->value.publish.specifics.error.message); |
136 | GNUNET_break (0); | 133 | GNUNET_break (0); |
137 | GNUNET_SCHEDULER_add_continuation (sched, | 134 | GNUNET_SCHEDULER_add_continuation (&abort_publish_task, |
138 | &abort_publish_task, | ||
139 | NULL, | 135 | NULL, |
140 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 136 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
141 | break; | 137 | break; |
@@ -143,8 +139,7 @@ progress_cb (void *cls, | |||
143 | fprintf (stderr, | 139 | fprintf (stderr, |
144 | "Error searching file: %s\n", | 140 | "Error searching file: %s\n", |
145 | event->value.search.specifics.error.message); | 141 | event->value.search.specifics.error.message); |
146 | GNUNET_SCHEDULER_add_continuation (sched, | 142 | GNUNET_SCHEDULER_add_continuation (&abort_search_task, |
147 | &abort_search_task, | ||
148 | NULL, | 143 | NULL, |
149 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 144 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
150 | break; | 145 | break; |
@@ -171,8 +166,7 @@ progress_cb (void *cls, | |||
171 | break; | 166 | break; |
172 | case GNUNET_FS_STATUS_SEARCH_STOPPED: | 167 | case GNUNET_FS_STATUS_SEARCH_STOPPED: |
173 | GNUNET_assert (search == event->value.search.sc); | 168 | GNUNET_assert (search == event->value.search.sc); |
174 | GNUNET_SCHEDULER_add_continuation (sched, | 169 | GNUNET_SCHEDULER_add_continuation (&abort_publish_task, |
175 | &abort_publish_task, | ||
176 | NULL, | 170 | NULL, |
177 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | 171 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); |
178 | break; | 172 | break; |
@@ -221,7 +215,6 @@ stop_arm (struct PeerContext *p) | |||
221 | 215 | ||
222 | static void | 216 | static void |
223 | run (void *cls, | 217 | run (void *cls, |
224 | struct GNUNET_SCHEDULER_Handle *s, | ||
225 | char *const *args, | 218 | char *const *args, |
226 | const char *cfgfile, | 219 | const char *cfgfile, |
227 | const struct GNUNET_CONFIGURATION_Handle *cfg) | 220 | const struct GNUNET_CONFIGURATION_Handle *cfg) |
@@ -236,10 +229,8 @@ run (void *cls, | |||
236 | struct GNUNET_FS_FileInformation *fi; | 229 | struct GNUNET_FS_FileInformation *fi; |
237 | size_t i; | 230 | size_t i; |
238 | 231 | ||
239 | sched = s; | ||
240 | setup_peer (&p1, "test_fs_search_data.conf"); | 232 | setup_peer (&p1, "test_fs_search_data.conf"); |
241 | fs = GNUNET_FS_start (sched, | 233 | fs = GNUNET_FS_start (cfg, |
242 | cfg, | ||
243 | "test-fs-search", | 234 | "test-fs-search", |
244 | &progress_cb, | 235 | &progress_cb, |
245 | NULL, | 236 | NULL, |