diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-08-15 21:54:06 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-08-15 21:54:06 +0000 |
commit | 5746309cb4be2073d550ad7a6885e918631dbc38 (patch) | |
tree | 89455bc4aadf977816b38df13f990372cd81d71a /src/fs/test_fs_publish_persistence.c | |
parent | 6fd3e715cae09fa6e657c96f1c6f9711ee51f42f (diff) | |
download | gnunet-5746309cb4be2073d550ad7a6885e918631dbc38.tar.gz gnunet-5746309cb4be2073d550ad7a6885e918631dbc38.zip |
indentation
Diffstat (limited to 'src/fs/test_fs_publish_persistence.c')
-rw-r--r-- | src/fs/test_fs_publish_persistence.c | 96 |
1 files changed, 40 insertions, 56 deletions
diff --git a/src/fs/test_fs_publish_persistence.c b/src/fs/test_fs_publish_persistence.c index 4dcf10965..f69ac5d9a 100644 --- a/src/fs/test_fs_publish_persistence.c +++ b/src/fs/test_fs_publish_persistence.c | |||
@@ -106,10 +106,7 @@ restart_fs_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) | |||
106 | { | 106 | { |
107 | rtask = GNUNET_SCHEDULER_NO_TASK; | 107 | rtask = GNUNET_SCHEDULER_NO_TASK; |
108 | GNUNET_FS_stop (fs); | 108 | GNUNET_FS_stop (fs); |
109 | fs = GNUNET_FS_start (cfg, | 109 | fs = GNUNET_FS_start (cfg, "test-fs-publish-persistence", &progress_cb, NULL, |
110 | "test-fs-publish-persistence", | ||
111 | &progress_cb, | ||
112 | NULL, | ||
113 | GNUNET_FS_FLAGS_PERSISTENCE, GNUNET_FS_OPTIONS_END); | 110 | GNUNET_FS_FLAGS_PERSISTENCE, GNUNET_FS_OPTIONS_END); |
114 | } | 111 | } |
115 | 112 | ||
@@ -132,8 +129,9 @@ consider_restart (int ev) | |||
132 | if (prev[i] == ev) | 129 | if (prev[i] == ev) |
133 | return; | 130 | return; |
134 | prev[off++] = ev; | 131 | prev[off++] = ev; |
135 | rtask = GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_URGENT, | 132 | rtask = |
136 | &restart_fs_task, NULL); | 133 | GNUNET_SCHEDULER_add_with_priority (GNUNET_SCHEDULER_PRIORITY_URGENT, |
134 | &restart_fs_task, NULL); | ||
137 | } | 135 | } |
138 | 136 | ||
139 | 137 | ||
@@ -151,8 +149,8 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
151 | printf ("Publish complete, %llu kbps.\n", | 149 | printf ("Publish complete, %llu kbps.\n", |
152 | (unsigned long long) (FILESIZE * 1000LL / | 150 | (unsigned long long) (FILESIZE * 1000LL / |
153 | (1 + | 151 | (1 + |
154 | GNUNET_TIME_absolute_get_duration | 152 | GNUNET_TIME_absolute_get_duration (start). |
155 | (start).rel_value) / 1024)); | 153 | rel_value) / 1024)); |
156 | if (0 == strcmp ("publish-context-dir", event->value.publish.cctx)) | 154 | if (0 == strcmp ("publish-context-dir", event->value.publish.cctx)) |
157 | GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); | 155 | GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); |
158 | break; | 156 | break; |
@@ -165,8 +163,8 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
165 | (unsigned long long) event->value.publish.completed, | 163 | (unsigned long long) event->value.publish.completed, |
166 | (unsigned long long) event->value.publish.size, | 164 | (unsigned long long) event->value.publish.size, |
167 | event->value.publish.specifics.progress.depth, | 165 | event->value.publish.specifics.progress.depth, |
168 | (unsigned long long) event->value.publish.specifics. | 166 | (unsigned long long) event->value.publish.specifics.progress. |
169 | progress.offset); | 167 | offset); |
170 | #endif | 168 | #endif |
171 | break; | 169 | break; |
172 | case GNUNET_FS_STATUS_PUBLISH_SUSPEND: | 170 | case GNUNET_FS_STATUS_PUBLISH_SUSPEND: |
@@ -177,17 +175,15 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
177 | if (NULL == publish) | 175 | if (NULL == publish) |
178 | { | 176 | { |
179 | GNUNET_assert (GNUNET_YES == | 177 | GNUNET_assert (GNUNET_YES == |
180 | GNUNET_FS_file_information_is_directory (event-> | 178 | GNUNET_FS_file_information_is_directory (event->value. |
181 | value.publish. | 179 | publish.fi)); |
182 | fi)); | ||
183 | publish = event->value.publish.pc; | 180 | publish = event->value.publish.pc; |
184 | return "publish-context-dir"; | 181 | return "publish-context-dir"; |
185 | } | 182 | } |
186 | break; | 183 | break; |
187 | case GNUNET_FS_STATUS_PUBLISH_ERROR: | 184 | case GNUNET_FS_STATUS_PUBLISH_ERROR: |
188 | ret = event->value.publish.cctx; | 185 | ret = event->value.publish.cctx; |
189 | fprintf (stderr, | 186 | fprintf (stderr, "Error publishing file: %s\n", |
190 | "Error publishing file: %s\n", | ||
191 | event->value.publish.specifics.error.message); | 187 | event->value.publish.specifics.error.message); |
192 | err = 1; | 188 | err = 1; |
193 | GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); | 189 | GNUNET_SCHEDULER_add_now (&abort_publish_task, NULL); |
@@ -198,16 +194,16 @@ progress_cb (void *cls, const struct GNUNET_FS_ProgressInfo *event) | |||
198 | ret = event->value.publish.cctx; | 194 | ret = event->value.publish.cctx; |
199 | if (0 == strcmp ("publish-context1", event->value.publish.cctx)) | 195 | if (0 == strcmp ("publish-context1", event->value.publish.cctx)) |
200 | { | 196 | { |
201 | GNUNET_assert (0 == strcmp ("publish-context-dir", | 197 | GNUNET_assert (0 == |
202 | event->value.publish.pctx)); | 198 | strcmp ("publish-context-dir", event->value.publish.pctx)); |
203 | GNUNET_assert (FILESIZE == event->value.publish.size); | 199 | GNUNET_assert (FILESIZE == event->value.publish.size); |
204 | GNUNET_assert (0 == event->value.publish.completed); | 200 | GNUNET_assert (0 == event->value.publish.completed); |
205 | GNUNET_assert (1 == event->value.publish.anonymity); | 201 | GNUNET_assert (1 == event->value.publish.anonymity); |
206 | } | 202 | } |
207 | else if (0 == strcmp ("publish-context2", event->value.publish.cctx)) | 203 | else if (0 == strcmp ("publish-context2", event->value.publish.cctx)) |
208 | { | 204 | { |
209 | GNUNET_assert (0 == strcmp ("publish-context-dir", | 205 | GNUNET_assert (0 == |
210 | event->value.publish.pctx)); | 206 | strcmp ("publish-context-dir", event->value.publish.pctx)); |
211 | GNUNET_assert (FILESIZE == event->value.publish.size); | 207 | GNUNET_assert (FILESIZE == event->value.publish.size); |
212 | GNUNET_assert (0 == event->value.publish.completed); | 208 | GNUNET_assert (0 == event->value.publish.completed); |
213 | GNUNET_assert (2 == event->value.publish.anonymity); | 209 | GNUNET_assert (2 == event->value.publish.anonymity); |
@@ -238,12 +234,13 @@ setup_peer (struct PeerContext *p, const char *cfgname) | |||
238 | { | 234 | { |
239 | p->cfg = GNUNET_CONFIGURATION_create (); | 235 | p->cfg = GNUNET_CONFIGURATION_create (); |
240 | #if START_ARM | 236 | #if START_ARM |
241 | p->arm_proc = GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm", | 237 | p->arm_proc = |
242 | "gnunet-service-arm", | 238 | GNUNET_OS_start_process (NULL, NULL, "gnunet-service-arm", |
239 | "gnunet-service-arm", | ||
243 | #if VERBOSE | 240 | #if VERBOSE |
244 | "-L", "DEBUG", | 241 | "-L", "DEBUG", |
245 | #endif | 242 | #endif |
246 | "-c", cfgname, NULL); | 243 | "-c", cfgname, NULL); |
247 | #endif | 244 | #endif |
248 | GNUNET_assert (GNUNET_OK == GNUNET_CONFIGURATION_load (p->cfg, cfgname)); | 245 | GNUNET_assert (GNUNET_OK == GNUNET_CONFIGURATION_load (p->cfg, cfgname)); |
249 | } | 246 | } |
@@ -259,8 +256,7 @@ stop_arm (struct PeerContext *p) | |||
259 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); | 256 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "kill"); |
260 | if (GNUNET_OS_process_wait (p->arm_proc) != GNUNET_OK) | 257 | if (GNUNET_OS_process_wait (p->arm_proc) != GNUNET_OK) |
261 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); | 258 | GNUNET_log_strerror (GNUNET_ERROR_TYPE_WARNING, "waitpid"); |
262 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 259 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, "ARM process %u stopped\n", |
263 | "ARM process %u stopped\n", | ||
264 | GNUNET_OS_process_get_pid (p->arm_proc)); | 260 | GNUNET_OS_process_get_pid (p->arm_proc)); |
265 | GNUNET_OS_process_close (p->arm_proc); | 261 | GNUNET_OS_process_close (p->arm_proc); |
266 | p->arm_proc = NULL; | 262 | p->arm_proc = NULL; |
@@ -271,9 +267,8 @@ stop_arm (struct PeerContext *p) | |||
271 | 267 | ||
272 | 268 | ||
273 | static void | 269 | static void |
274 | run (void *cls, | 270 | run (void *cls, char *const *args, const char *cfgfile, |
275 | char *const *args, | 271 | const struct GNUNET_CONFIGURATION_Handle *c) |
276 | const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *c) | ||
277 | { | 272 | { |
278 | const char *keywords[] = { | 273 | const char *keywords[] = { |
279 | "down_foo", | 274 | "down_foo", |
@@ -290,10 +285,7 @@ run (void *cls, | |||
290 | 285 | ||
291 | cfg = c; | 286 | cfg = c; |
292 | setup_peer (&p1, "test_fs_publish_data.conf"); | 287 | setup_peer (&p1, "test_fs_publish_data.conf"); |
293 | fs = GNUNET_FS_start (cfg, | 288 | fs = GNUNET_FS_start (cfg, "test-fs-publish-persistence", &progress_cb, NULL, |
294 | "test-fs-publish-persistence", | ||
295 | &progress_cb, | ||
296 | NULL, | ||
297 | GNUNET_FS_FLAGS_PERSISTENCE, GNUNET_FS_OPTIONS_END); | 289 | GNUNET_FS_FLAGS_PERSISTENCE, GNUNET_FS_OPTIONS_END); |
298 | GNUNET_assert (NULL != fs); | 290 | GNUNET_assert (NULL != fs); |
299 | fn1 = GNUNET_DISK_mktemp ("gnunet-publish-test-dst"); | 291 | fn1 = GNUNET_DISK_mktemp ("gnunet-publish-test-dst"); |
@@ -301,9 +293,7 @@ run (void *cls, | |||
301 | for (i = 0; i < FILESIZE; i++) | 293 | for (i = 0; i < FILESIZE; i++) |
302 | buf[i] = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 256); | 294 | buf[i] = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 256); |
303 | GNUNET_assert (FILESIZE == | 295 | GNUNET_assert (FILESIZE == |
304 | GNUNET_DISK_fn_write (fn1, | 296 | GNUNET_DISK_fn_write (fn1, buf, FILESIZE, |
305 | buf, | ||
306 | FILESIZE, | ||
307 | GNUNET_DISK_PERM_USER_READ | | 297 | GNUNET_DISK_PERM_USER_READ | |
308 | GNUNET_DISK_PERM_USER_WRITE)); | 298 | GNUNET_DISK_PERM_USER_WRITE)); |
309 | GNUNET_free (buf); | 299 | GNUNET_free (buf); |
@@ -313,9 +303,7 @@ run (void *cls, | |||
313 | for (i = 0; i < FILESIZE; i++) | 303 | for (i = 0; i < FILESIZE; i++) |
314 | buf[i] = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 256); | 304 | buf[i] = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 256); |
315 | GNUNET_assert (FILESIZE == | 305 | GNUNET_assert (FILESIZE == |
316 | GNUNET_DISK_fn_write (fn2, | 306 | GNUNET_DISK_fn_write (fn2, buf, FILESIZE, |
317 | buf, | ||
318 | FILESIZE, | ||
319 | GNUNET_DISK_PERM_USER_READ | | 307 | GNUNET_DISK_PERM_USER_READ | |
320 | GNUNET_DISK_PERM_USER_WRITE)); | 308 | GNUNET_DISK_PERM_USER_WRITE)); |
321 | GNUNET_free (buf); | 309 | GNUNET_free (buf); |
@@ -326,32 +314,28 @@ run (void *cls, | |||
326 | bo.anonymity_level = 1; | 314 | bo.anonymity_level = 1; |
327 | bo.replication_level = 0; | 315 | bo.replication_level = 0; |
328 | bo.expiration_time = GNUNET_TIME_relative_to_absolute (LIFETIME); | 316 | bo.expiration_time = GNUNET_TIME_relative_to_absolute (LIFETIME); |
329 | fi1 = GNUNET_FS_file_information_create_from_file (fs, | 317 | fi1 = |
330 | "publish-context1", | 318 | GNUNET_FS_file_information_create_from_file (fs, "publish-context1", fn1, |
331 | fn1, | 319 | kuri, meta, GNUNET_YES, &bo); |
332 | kuri, | ||
333 | meta, GNUNET_YES, &bo); | ||
334 | GNUNET_assert (NULL != fi1); | 320 | GNUNET_assert (NULL != fi1); |
335 | bo.anonymity_level = 2; | 321 | bo.anonymity_level = 2; |
336 | fi2 = GNUNET_FS_file_information_create_from_file (fs, | 322 | fi2 = |
337 | "publish-context2", | 323 | GNUNET_FS_file_information_create_from_file (fs, "publish-context2", fn2, |
338 | fn2, | 324 | kuri, meta, GNUNET_YES, &bo); |
339 | kuri, | ||
340 | meta, GNUNET_YES, &bo); | ||
341 | GNUNET_assert (NULL != fi2); | 325 | GNUNET_assert (NULL != fi2); |
342 | bo.anonymity_level = 3; | 326 | bo.anonymity_level = 3; |
343 | fidir = GNUNET_FS_file_information_create_empty_directory (fs, | 327 | fidir = |
344 | "publish-context-dir", | 328 | GNUNET_FS_file_information_create_empty_directory (fs, |
345 | kuri, meta, &bo); | 329 | "publish-context-dir", |
330 | kuri, meta, &bo); | ||
346 | GNUNET_assert (GNUNET_OK == GNUNET_FS_file_information_add (fidir, fi1)); | 331 | GNUNET_assert (GNUNET_OK == GNUNET_FS_file_information_add (fidir, fi1)); |
347 | GNUNET_assert (GNUNET_OK == GNUNET_FS_file_information_add (fidir, fi2)); | 332 | GNUNET_assert (GNUNET_OK == GNUNET_FS_file_information_add (fidir, fi2)); |
348 | GNUNET_FS_uri_destroy (kuri); | 333 | GNUNET_FS_uri_destroy (kuri); |
349 | GNUNET_CONTAINER_meta_data_destroy (meta); | 334 | GNUNET_CONTAINER_meta_data_destroy (meta); |
350 | GNUNET_assert (NULL != fidir); | 335 | GNUNET_assert (NULL != fidir); |
351 | start = GNUNET_TIME_absolute_get (); | 336 | start = GNUNET_TIME_absolute_get (); |
352 | GNUNET_FS_publish_start (fs, | 337 | GNUNET_FS_publish_start (fs, fidir, NULL, NULL, NULL, |
353 | fidir, | 338 | GNUNET_FS_PUBLISH_OPTION_NONE); |
354 | NULL, NULL, NULL, GNUNET_FS_PUBLISH_OPTION_NONE); | ||
355 | GNUNET_assert (publish != NULL); | 339 | GNUNET_assert (publish != NULL); |
356 | } | 340 | } |
357 | 341 | ||
@@ -379,8 +363,8 @@ main (int argc, char *argv[]) | |||
379 | "WARNING", | 363 | "WARNING", |
380 | #endif | 364 | #endif |
381 | NULL); | 365 | NULL); |
382 | GNUNET_PROGRAM_run ((sizeof (argvx) / sizeof (char *)) - 1, | 366 | GNUNET_PROGRAM_run ((sizeof (argvx) / sizeof (char *)) - 1, argvx, |
383 | argvx, "test-fs-publish", "nohelp", options, &run, NULL); | 367 | "test-fs-publish", "nohelp", options, &run, NULL); |
384 | stop_arm (&p1); | 368 | stop_arm (&p1); |
385 | GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-publish/"); | 369 | GNUNET_DISK_directory_remove ("/tmp/gnunet-test-fs-publish/"); |
386 | if (fn1 != NULL) | 370 | if (fn1 != NULL) |