WiP

[oweals/gnunet.git] / src / dht / gnunet-dht-put.c

diff --git a/src/dht/gnunet-dht-put.c b/src/dht/gnunet-dht-put.c
index 9f7091b849956ba0121222e509c4de20b6f6fbd8..6bd9f90452553e76aeb5cfd7323615f1ea6a857b 100644 (file)
--- a/src/dht/gnunet-dht-put.c
+++ b/src/dht/gnunet-dht-put.c
@@ -56,10 +56,6 @@ static int verbose;
  */
 static struct GNUNET_DHT_Handle *dht_handle;
 
-/**
- * Global handle of the scheduler
- */
-static struct GNUNET_SCHEDULER_Handle *sched;
 
 /**
  * Global handle of the configuration
@@ -95,62 +91,53 @@ shutdown_task (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 void
 message_sent_cont (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
-  if (tc->reason == GNUNET_SCHEDULER_REASON_TIMEOUT)
-    {
-      if (verbose)
-        fprintf (stderr,
-                 "Failed to send put request to service, quitting.\n");
-      ret = 1;
-    }
-  else
-    {
-      if (verbose)
-        fprintf (stderr, "PUT request sent!\n");
-    }
-
-  GNUNET_SCHEDULER_add_now (sched, &shutdown_task, NULL);
+  if (verbose)
+    fprintf (stderr, 
+            _("PUT request sent!\n"));    
+  GNUNET_SCHEDULER_add_now (&shutdown_task, NULL);
 }
 
 /**
  * Main function that will be run by the scheduler.
  *
  * @param cls closure
- * @param s the scheduler to use
  * @param args remaining command-line arguments
  * @param cfgfile name of the configuration file used (for saving, can be NULL!)
  * @param c configuration
  */
 static void
 run (void *cls,
-     struct GNUNET_SCHEDULER_Handle *s,
      char *const *args,
      const char *cfgfile, const struct GNUNET_CONFIGURATION_Handle *c)
 {
   struct GNUNET_TIME_Relative timeout;
   struct GNUNET_TIME_Absolute expiration;
   GNUNET_HashCode key;
-  sched = s;
   cfg = c;
 
-  if ((query_key == NULL) || (data == NULL))
+  if ( (query_key == NULL) || (data == NULL) )
     {
-      if (verbose)
-        fprintf (stderr, "Must provide KEY and DATA for DHT put!\n");
+      fprintf (stderr,
+              _("Must provide KEY and DATA for DHT put!\n"));
       ret = 1;
       return;
     }
 
-  dht_handle = GNUNET_DHT_connect (sched, cfg, 1);
-
+  dht_handle = GNUNET_DHT_connect (cfg, 1);
   if (dht_handle == NULL)
     {
-      if (verbose)
-        fprintf (stderr, "Couldn't connect to DHT service!\n");
+      fprintf (stderr, 
+              _("Could not connect to %s service!\n"),
+              "DHT");
       ret = 1;
       return;
     }
   else if (verbose)
-    fprintf (stderr, "Connected to DHT service!\n");
+    fprintf (stderr,
+            _("Connected to %s service!\n"), "DHT");
+
+  if (query_type == GNUNET_BLOCK_TYPE_ANY) /* Type of data not set */
+    query_type = GNUNET_BLOCK_TYPE_TEST;
 
   GNUNET_CRYPTO_hash (query_key, strlen (query_key), &key);
 
@@ -162,11 +149,12 @@ run (void *cls,
                                        expiration_seconds));
 
   if (verbose)
-    fprintf (stderr, "Issuing put request for `%s' with data `%s'!\n",
+    fprintf (stderr,
+            _("Issuing put request for `%s' with data `%s'!\n"),
              query_key, data);
-
   GNUNET_DHT_put (dht_handle,
                  &key, 
+                 DEFAULT_PUT_REPLICATION,
                  GNUNET_DHT_RO_NONE,
                  query_type, 
                  strlen (data), data,