aboutsummaryrefslogtreecommitdiff
path: root/src/fs/test_fs_search_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_search_persistence.c
parentec69ceabc67a72373a2579d871c5fe85676a73bd (diff)
downloadgnunet-d3e7a5e40dd2d5409009a30e1e41148c4d852673.tar.gz
gnunet-d3e7a5e40dd2d5409009a30e1e41148c4d852673.zip
-use simpler, modern scheduler API
Diffstat (limited to 'src/fs/test_fs_search_persistence.c')
-rw-r--r--src/fs/test_fs_search_persistence.c12
1 files changed, 4 insertions, 8 deletions
diff --git a/src/fs/test_fs_search_persistence.c b/src/fs/test_fs_search_persistence.c
index 43275fb8d..7c84c24c9 100644
--- a/src/fs/test_fs_search_persistence.c
+++ b/src/fs/test_fs_search_persistence.c
@@ -183,21 +183,18 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event)
183 * search result since we exit here after the first one... */ 183 * search result since we exit here after the first one... */
184 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, 184 GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
185 "Search complete.\n"); 185 "Search complete.\n");
186 GNUNET_SCHEDULER_add_continuation (&abort_search_task, NULL, 186 GNUNET_SCHEDULER_add_now (&abort_search_task, NULL);
187 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
188 break; 187 break;
189 case GNUNET_FS_STATUS_PUBLISH_ERROR: 188 case GNUNET_FS_STATUS_PUBLISH_ERROR:
190 FPRINTF (stderr, "Error publishing file: %s\n", 189 FPRINTF (stderr, "Error publishing file: %s\n",
191 event->value.publish.specifics.error.message); 190 event->value.publish.specifics.error.message);
192 GNUNET_break (0); 191 GNUNET_break (0);
193 GNUNET_SCHEDULER_add_continuation (&abort_publish_task, NULL, 192 GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL);
194 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
195 break; 193 break;
196 case GNUNET_FS_STATUS_SEARCH_ERROR: 194 case GNUNET_FS_STATUS_SEARCH_ERROR:
197 FPRINTF (stderr, "Error searching file: %s\n", 195 FPRINTF (stderr, "Error searching file: %s\n",
198 event->value.search.specifics.error.message); 196 event->value.search.specifics.error.message);
199 GNUNET_SCHEDULER_add_continuation (&abort_search_task, NULL, 197 GNUNET_SCHEDULER_add_now (&abort_search_task, NULL);
200 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
201 break; 198 break;
202 case GNUNET_FS_STATUS_SEARCH_SUSPEND: 199 case GNUNET_FS_STATUS_SEARCH_SUSPEND:
203 if (event->value.search.sc == search) 200 if (event->value.search.sc == search)
@@ -235,8 +232,7 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event)
235 break; 232 break;
236 case GNUNET_FS_STATUS_SEARCH_STOPPED: 233 case GNUNET_FS_STATUS_SEARCH_STOPPED:
237 GNUNET_assert (search == event->value.search.sc); 234 GNUNET_assert (search == event->value.search.sc);
238 GNUNET_SCHEDULER_add_continuation (&abort_publish_task, NULL, 235 GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL);
239 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
240 search = NULL; 236 search = NULL;
241 break; 237 break;
242 default: 238 default: