X-Git-Url: https://git.librecmc.org/?a=blobdiff_plain;f=src%2Fdht%2Fgnunet-dht-put.c;h=1f3df1d351856fa173254024772bef88f754cc9a;hb=5b32752cd7b02adcb8e6fec7798637638c6f63a0;hp=c58311876d73dc715553b449acc4f4c81dba4177;hpb=bb5fe91d23b0938baa3c4f0e92a83df659df216a;p=oweals%2Fgnunet.git diff --git a/src/dht/gnunet-dht-put.c b/src/dht/gnunet-dht-put.c index c58311876..1f3df1d35 100644 --- a/src/dht/gnunet-dht-put.c +++ b/src/dht/gnunet-dht-put.c @@ -41,11 +41,6 @@ struct GNUNET_HashCode key; */ static char *query_key; -/** - * User supplied timeout value - */ -static unsigned long long timeout_request = 5; - /** * User supplied expiration value */ @@ -87,8 +82,9 @@ static int ret; */ static char *data; + static void -shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) +shutdown_task (void *cls) { if (NULL != dht_handle) { @@ -97,13 +93,14 @@ shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc) } } + /** * Signature of the main function of a task. * * @param cls closure - * @param success GNUNET_OK if the PUT was transmitted, - * GNUNET_NO on timeout, - * GNUNET_SYSERR on disconnect from service + * @param success #GNUNET_OK if the PUT was transmitted, + * #GNUNET_NO on timeout, + * #GNUNET_SYSERR on disconnect from service * after the PUT message was transmitted * (so we don't know if it was received or not) */ @@ -131,6 +128,7 @@ message_sent_cont (void *cls, int success) GNUNET_SCHEDULER_add_now (&shutdown_task, NULL); } + /** * Main function that will be run by the scheduler. * @@ -140,14 +138,14 @@ message_sent_cont (void *cls, int success) * @param c configuration */ static void -run (void *cls, char *const *args, const char *cfgfile, +run (void *cls, + char *const *args, + const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *c) { - struct GNUNET_TIME_Relative timeout; struct GNUNET_TIME_Absolute expiration; cfg = c; - if ((NULL == query_key) || (NULL == data)) { FPRINTF (stderr, "%s", _("Must provide KEY and DATA for DHT put!\n")); @@ -166,8 +164,6 @@ run (void *cls, char *const *args, const char *cfgfile, GNUNET_CRYPTO_hash (query_key, strlen (query_key), &key); - timeout = - GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, timeout_request); expiration = GNUNET_TIME_relative_to_absolute (GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, @@ -175,12 +171,16 @@ run (void *cls, char *const *args, const char *cfgfile, if (verbose) FPRINTF (stderr, _("Issuing put request for `%s' with data `%s'!\n"), query_key, data); - GNUNET_DHT_put (dht_handle, &key, replication, + GNUNET_DHT_put (dht_handle, + &key, + replication, (demultixplex_everywhere) ? GNUNET_DHT_RO_DEMULTIPLEX_EVERYWHERE : GNUNET_DHT_RO_NONE, query_type, - strlen (data), data, expiration, timeout, &message_sent_cont, + strlen (data), + data, + expiration, + &message_sent_cont, NULL); - } @@ -206,9 +206,6 @@ static struct GNUNET_GETOPT_CommandLineOption options[] = { {'t', "type", "TYPE", gettext_noop ("the type to insert data as"), 1, &GNUNET_GETOPT_set_uint, &query_type}, - {'T', "timeout", "TIMEOUT", - gettext_noop ("how long to execute this query before giving up?"), - 1, &GNUNET_GETOPT_set_ulong, &timeout_request}, {'V', "verbose", NULL, gettext_noop ("be verbose (print progress information)"), 0, &GNUNET_GETOPT_set_one, &verbose}, @@ -226,10 +223,9 @@ static struct GNUNET_GETOPT_CommandLineOption options[] = { int main (int argc, char *const *argv) { - if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, &argc, &argv)) + if (GNUNET_OK != GNUNET_STRINGS_get_utf8_args (argc, argv, + &argc, &argv)) return 2; - - return (GNUNET_OK == GNUNET_PROGRAM_run (argc, argv, "gnunet-dht-put", gettext_noop