aboutsummaryrefslogtreecommitdiff
path: root/src/fs/test_fs_unindex_persistence.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2015-08-03 09:35:48 +0000
committerChristian Grothoff <christian@grothoff.org>2015-08-03 09:35:48 +0000
commitd3e7a5e40dd2d5409009a30e1e41148c4d852673 (patch)
tree21ff19580a99137e9b8aec4393feb67f0f1c7b5a /src/fs/test_fs_unindex_persistence.c
parentec69ceabc67a72373a2579d871c5fe85676a73bd (diff)
downloadgnunet-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.c12
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);