aboutsummaryrefslogtreecommitdiff
path: root/src/fs/test_fs_search_probes.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_probes.c
parentec69ceabc67a72373a2579d871c5fe85676a73bd (diff)
downloadgnunet-d3e7a5e40dd2d5409009a30e1e41148c4d852673.tar.gz
gnunet-d3e7a5e40dd2d5409009a30e1e41148c4d852673.zip
-use simpler, modern scheduler API
Diffstat (limited to 'src/fs/test_fs_search_probes.c')
-rw-r--r--src/fs/test_fs_search_probes.c13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/fs/test_fs_search_probes.c b/src/fs/test_fs_search_probes.c
index 203d3fa36..218951509 100644
--- a/src/fs/test_fs_search_probes.c
+++ b/src/fs/test_fs_search_probes.c
@@ -140,14 +140,12 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event)
140 FPRINTF (stderr, "Error publishing file: %s\n", 140 FPRINTF (stderr, "Error publishing file: %s\n",
141 event->value.publish.specifics.error.message); 141 event->value.publish.specifics.error.message);
142 GNUNET_break (0); 142 GNUNET_break (0);
143 GNUNET_SCHEDULER_add_continuation (&abort_publish_task, NULL, 143 GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL);
144 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
145 break; 144 break;
146 case GNUNET_FS_STATUS_SEARCH_ERROR: 145 case GNUNET_FS_STATUS_SEARCH_ERROR:
147 FPRINTF (stderr, "Error searching file: %s\n", 146 FPRINTF (stderr, "Error searching file: %s\n",
148 event->value.search.specifics.error.message); 147 event->value.search.specifics.error.message);
149 GNUNET_SCHEDULER_add_continuation (&abort_search_task, NULL, 148 GNUNET_SCHEDULER_add_now (&abort_search_task, NULL);
150 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
151 break; 149 break;
152 case GNUNET_FS_STATUS_PUBLISH_START: 150 case GNUNET_FS_STATUS_PUBLISH_START:
153 GNUNET_assert (0 == strcmp ("publish-context", event->value.publish.cctx)); 151 GNUNET_assert (0 == strcmp ("publish-context", event->value.publish.cctx));
@@ -177,11 +175,12 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event)
177 break; 175 break;
178 case GNUNET_FS_STATUS_SEARCH_STOPPED: 176 case GNUNET_FS_STATUS_SEARCH_STOPPED:
179 GNUNET_assert (search == event->value.search.sc); 177 GNUNET_assert (search == event->value.search.sc);
180 GNUNET_SCHEDULER_add_continuation (&abort_publish_task, NULL, 178 GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL);
181 GNUNET_SCHEDULER_REASON_PREREQ_DONE);
182 break; 179 break;
183 default: 180 default:
184 FPRINTF (stderr, "Unexpected event: %d\n", event->status); 181 FPRINTF (stderr,
182 "Unexpected event: %d\n",
183 event->status);
185 break; 184 break;
186 } 185 }
187 return NULL; 186 return NULL;