aboutsummaryrefslogtreecommitdiff
path: root/src/fs/test_fs_search.c
diff options
context:
space:
mode:
authorNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
committerNathan S. Evans <evans@in.tum.de>2010-11-05 18:21:50 +0000
commit75a33a1499cf60ea4364c9aa673816629a6c1413 (patch)
tree0620da4312bb04de4d7b65074fdd3b0c3dd6cc0e /src/fs/test_fs_search.c
parent7217c601ad30760872823193d62307e7a335d226 (diff)
downloadgnunet-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.c19
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
62static struct GNUNET_TIME_Absolute start; 62static struct GNUNET_TIME_Absolute start;
63 63
64static struct GNUNET_SCHEDULER_Handle *sched;
65
66static struct GNUNET_FS_Handle *fs; 64static struct GNUNET_FS_Handle *fs;
67 65
68static struct GNUNET_FS_SearchContext *search; 66static 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
222static void 216static void
223run (void *cls, 217run (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,