#include "gnunet_util.h"
#include "gnunet_fsui_lib.h"
-#define DEBUG_VERBOSE GNUNET_NO
+#define DEBUG_VERBOSE GNUNET_EXTRA_LOGGING
#define CHECK(a) if (!(a)) { ok = GNUNET_NO; GNUNET_GE_BREAK(NULL, 0); goto FAILURE; }
{
char *fn;
- fn =
- GNUNET_malloc (strlen ("/tmp/gnunet-basic_fsui_test/BASIC_FSUI_TEST") +
- 14);
+ fn = GNUNET_malloc (strlen ("/tmp/gnunet-basic_fsui_test/BASIC_FSUI_TEST") +
+ 14);
GNUNET_snprintf (fn,
- strlen ("/tmp/gnunet-basic_fsui_test/BASIC_FSUI_TEST") +
- 14, "/tmp/gnunet-basic_fsui_test/BASIC_FSUI_TEST%u", i);
+ strlen ("/tmp/gnunet-basic_fsui_test/BASIC_FSUI_TEST") + 14,
+ "/tmp/gnunet-basic_fsui_test/BASIC_FSUI_TEST%u", i);
GNUNET_disk_directory_create_for_file (NULL, fn);
return fn;
}
static char unused;
switch (event->type)
- {
- case GNUNET_FSUI_search_resumed:
- case GNUNET_FSUI_download_resumed:
- case GNUNET_FSUI_upload_resumed:
- case GNUNET_FSUI_unindex_resumed:
- return &unused;
- case GNUNET_FSUI_search_result:
+ {
+ case GNUNET_FSUI_search_resumed:
+ case GNUNET_FSUI_download_resumed:
+ case GNUNET_FSUI_upload_resumed:
+ case GNUNET_FSUI_unindex_resumed:
+ return &unused;
+ case GNUNET_FSUI_search_result:
#if DEBUG_VERBOSE
- printf ("Received search result\n");
+ printf ("Received search result\n");
#endif
- search_uri =
- GNUNET_ECRS_uri_duplicate (event->data.SearchResult.fi.uri);
- search_meta =
- GNUNET_meta_data_duplicate (event->data.SearchResult.fi.meta);
- break;
- case GNUNET_FSUI_upload_completed:
+ search_uri = GNUNET_ECRS_uri_duplicate (event->data.SearchResult.fi.uri);
+ search_meta = GNUNET_meta_data_duplicate (event->data.SearchResult.fi.meta);
+ break;
+ case GNUNET_FSUI_upload_completed:
#if DEBUG_VERBOSE
- printf ("Upload complete.\n");
+ printf ("Upload complete.\n");
#endif
- break;
- case GNUNET_FSUI_download_completed:
+ break;
+ case GNUNET_FSUI_download_completed:
#if DEBUG_VERBOSE
- printf ("Download complete.\n");
+ printf ("Download complete.\n");
#endif
- break;
- case GNUNET_FSUI_unindex_completed:
+ break;
+ case GNUNET_FSUI_unindex_completed:
#if DEBUG_VERBOSE
- printf ("Unindex complete.\n");
+ printf ("Unindex complete.\n");
#endif
- break;
- default:
- break;
- }
+ break;
+ default:
+ break;
+ }
lastEvent = event->type;
return NULL;
}
main (int argc, char *argv[])
{
#if START_DAEMON
- pid_t daemon;
+ struct GNUNET_OS_Process *daemon;
#endif
int ok;
struct GNUNET_ECRS_URI *uri;
char *filename = NULL;
+
char *keywords[] = {
"fsui_foo",
"fsui_bar",
cfg = GNUNET_GC_create ();
if (-1 == GNUNET_GC_parse_configuration (cfg, "check.conf"))
- {
- GNUNET_GC_free (cfg);
- return -1;
- }
+ {
+ GNUNET_GC_free (cfg);
+ return -1;
+ }
#if START_DAEMON
daemon = GNUNET_daemon_start (NULL, cfg, "peer.conf", GNUNET_NO);
- GNUNET_GE_ASSERT (NULL, daemon > 0);
+ GNUNET_GE_ASSERT (NULL, daemon != NULL);
CHECK (GNUNET_OK ==
- GNUNET_wait_for_daemon_running (NULL, cfg,
- 60 * GNUNET_CRON_SECONDS));
+ GNUNET_wait_for_daemon_running (NULL, cfg, 60 * GNUNET_CRON_SECONDS));
#endif
GNUNET_thread_sleep (5 * GNUNET_CRON_SECONDS); /* give apps time to start */
ok = GNUNET_YES;
&eventCallback, NULL);
CHECK (ctx != NULL);
filename = makeName (42);
- GNUNET_disk_file_write (NULL,
- filename,
- "foo bar test!", strlen ("foo bar test!"), "600");
+ GNUNET_disk_file_write (NULL, filename, "foo bar test!",
+ strlen ("foo bar test!"), "600");
meta = GNUNET_meta_data_create ();
kuri =
- GNUNET_ECRS_keyword_command_line_to_uri (NULL, 2,
- (const char **) keywords);
+ GNUNET_ECRS_keyword_command_line_to_uri (NULL, 2,
+ (const char **) keywords);
/* upload */
upload = GNUNET_FSUI_upload_start (ctx, filename, (GNUNET_FSUI_DirectoryScanCallback) & GNUNET_disk_directory_scan, NULL, 0, /* anonymity */
0, /* priority */
- GNUNET_YES,
- GNUNET_NO,
- GNUNET_NO,
- GNUNET_get_time () +
- 5 * GNUNET_CRON_HOURS, meta, kuri, kuri);
+ GNUNET_YES, GNUNET_NO, GNUNET_NO,
+ GNUNET_get_time () + 5 * GNUNET_CRON_HOURS,
+ meta, kuri, kuri);
CHECK (upload != NULL);
GNUNET_ECRS_uri_destroy (kuri);
GNUNET_meta_data_destroy (meta);
prog = 0;
while (lastEvent != GNUNET_FSUI_upload_completed)
- {
- prog++;
- CHECK (prog <
- 10000) GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
- if (GNUNET_shutdown_test () == GNUNET_YES)
- break;
- }
+ {
+ prog++;
+ CHECK (prog < 10000) GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
+ if (GNUNET_shutdown_test () == GNUNET_YES)
+ break;
+ }
/* search */
GNUNET_snprintf (keyword, 40, "+%s +%s", keywords[0], keywords[1]);
CHECK (search != NULL);
prog = 0;
while (lastEvent != GNUNET_FSUI_search_result)
- {
- prog++;
- CHECK (prog < 10000);
- GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
- if (GNUNET_shutdown_test () == GNUNET_YES)
- break;
- }
+ {
+ prog++;
+ CHECK (prog < 10000);
+ GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
+ if (GNUNET_shutdown_test () == GNUNET_YES)
+ break;
+ }
GNUNET_FSUI_search_abort (search);
GNUNET_FSUI_search_stop (search);
/* download */
fn = makeName (43);
- download = GNUNET_FSUI_download_start (ctx,
- 0,
- GNUNET_NO,
- search_uri,
- search_meta, fn, NULL, NULL);
+ download =
+ GNUNET_FSUI_download_start (ctx, 0, GNUNET_NO, search_uri, search_meta,
+ fn, NULL, NULL);
GNUNET_free (fn);
prog = 0;
while (lastEvent != GNUNET_FSUI_download_completed)
- {
- prog++;
- CHECK (prog < 10000);
- GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
- if (GNUNET_shutdown_test () == GNUNET_YES)
- break;
- }
+ {
+ prog++;
+ CHECK (prog < 10000);
+ GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
+ if (GNUNET_shutdown_test () == GNUNET_YES)
+ break;
+ }
GNUNET_FSUI_download_stop (download);
download = NULL;
GNUNET_ECRS_uri_destroy (search_uri);
unindex = GNUNET_FSUI_unindex_start (ctx, filename);
prog = 0;
while (lastEvent != GNUNET_FSUI_unindex_completed)
- {
- prog++;
- CHECK (prog < 10000);
- GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
- if (GNUNET_shutdown_test () == GNUNET_YES)
- break;
- }
+ {
+ prog++;
+ CHECK (prog < 10000);
+ GNUNET_thread_sleep (50 * GNUNET_CRON_MILLISECONDS);
+ if (GNUNET_shutdown_test () == GNUNET_YES)
+ break;
+ }
if (lastEvent != GNUNET_FSUI_unindex_completed)
GNUNET_FSUI_unindex_abort (unindex);
GNUNET_FSUI_unindex_stop (unindex);
if (ctx != NULL)
GNUNET_FSUI_stop (ctx);
if (filename != NULL)
- {
- UNLINK (filename);
- GNUNET_free (filename);
- }
+ {
+ UNLINK (filename);
+ GNUNET_free (filename);
+ }
if (download != NULL)
- {
- GNUNET_FSUI_download_abort (download);
- GNUNET_FSUI_download_stop (download);
- }
+ {
+ GNUNET_FSUI_download_abort (download);
+ GNUNET_FSUI_download_stop (download);
+ }
filename = makeName (43);
/* TODO: verify file 'filename(42)' == file 'filename(43)' */
UNLINK (filename);
#if START_DAEMON
GNUNET_GE_ASSERT (NULL, GNUNET_OK == GNUNET_daemon_stop (NULL, daemon));
+ GNUNET_OS_process_close (daemon);
#endif
GNUNET_GC_free (cfg);
projects / oweals / gnunet.git / blobdiff