diff options
author | Christian Grothoff <christian@grothoff.org> | 2015-08-03 09:35:48 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2015-08-03 09:35:48 +0000 |
commit | d3e7a5e40dd2d5409009a30e1e41148c4d852673 (patch) | |
tree | 21ff19580a99137e9b8aec4393feb67f0f1c7b5a /src/fs/test_fs_unindex_persistence.c | |
parent | ec69ceabc67a72373a2579d871c5fe85676a73bd (diff) | |
download | gnunet-d3e7a5e40dd2d5409009a30e1e41148c4d852673.tar.gz gnunet-d3e7a5e40dd2d5409009a30e1e41148c4d852673.zip |
-use simpler, modern scheduler API
Diffstat (limited to 'src/fs/test_fs_unindex_persistence.c')
-rw-r--r-- | src/fs/test_fs_unindex_persistence.c | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/fs/test_fs_unindex_persistence.c b/src/fs/test_fs_unindex_persistence.c index 628bc85d2..ccb628a63 100644 --- a/src/fs/test_fs_unindex_persistence.c +++ b/src/fs/test_fs_unindex_persistence.c | |||
@@ -150,8 +150,7 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
150 | (1 + | 150 | (1 + |
151 | GNUNET_TIME_absolute_get_duration | 151 | GNUNET_TIME_absolute_get_duration |
152 | (start).rel_value_us) / 1024)); | 152 | (start).rel_value_us) / 1024)); |
153 | GNUNET_SCHEDULER_add_continuation (&abort_unindex_task, NULL, | 153 | GNUNET_SCHEDULER_add_now (&abort_unindex_task, NULL); |
154 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | ||
155 | break; | 154 | break; |
156 | case GNUNET_FS_STATUS_UNINDEX_PROGRESS: | 155 | case GNUNET_FS_STATUS_UNINDEX_PROGRESS: |
157 | consider_restart (event->status); | 156 | consider_restart (event->status); |
@@ -187,15 +186,13 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
187 | FPRINTF (stderr, "Error publishing file: %s\n", | 186 | FPRINTF (stderr, "Error publishing file: %s\n", |
188 | event->value.publish.specifics.error.message); | 187 | event->value.publish.specifics.error.message); |
189 | GNUNET_break (0); | 188 | GNUNET_break (0); |
190 | GNUNET_SCHEDULER_add_continuation (&abort_publish_task, NULL, | 189 | GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); |
191 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | ||
192 | break; | 190 | break; |
193 | case GNUNET_FS_STATUS_UNINDEX_ERROR: | 191 | case GNUNET_FS_STATUS_UNINDEX_ERROR: |
194 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 192 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
195 | "Error unindexing file: %s\n", | 193 | "Error unindexing file: %s\n", |
196 | event->value.unindex.specifics.error.message); | 194 | event->value.unindex.specifics.error.message); |
197 | GNUNET_SCHEDULER_add_continuation (&abort_unindex_task, NULL, | 195 | GNUNET_SCHEDULER_add_now (&abort_unindex_task, NULL); |
198 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | ||
199 | break; | 196 | break; |
200 | case GNUNET_FS_STATUS_PUBLISH_START: | 197 | case GNUNET_FS_STATUS_PUBLISH_START: |
201 | GNUNET_assert (0 == strcmp ("publish-context", event->value.publish.cctx)); | 198 | GNUNET_assert (0 == strcmp ("publish-context", event->value.publish.cctx)); |
@@ -221,8 +218,7 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
221 | break; | 218 | break; |
222 | case GNUNET_FS_STATUS_UNINDEX_STOPPED: | 219 | case GNUNET_FS_STATUS_UNINDEX_STOPPED: |
223 | GNUNET_assert (unindex == event->value.unindex.uc); | 220 | GNUNET_assert (unindex == event->value.unindex.uc); |
224 | GNUNET_SCHEDULER_add_continuation (&abort_publish_task, NULL, | 221 | GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); |
225 | GNUNET_SCHEDULER_REASON_PREREQ_DONE); | ||
226 | break; | 222 | break; |
227 | default: | 223 | default: |
228 | printf ("Unexpected event: %d\n", event->status); | 224 | printf ("Unexpected event: %d\n", event->status); |