logging
authorChristian Grothoff <christian@grothoff.org>
Tue, 25 Oct 2011 12:11:06 +0000 (12:11 +0000)
committerChristian Grothoff <christian@grothoff.org>
Tue, 25 Oct 2011 12:11:06 +0000 (12:11 +0000)
src/dht/dht_api.c
src/dht/gnunet-service-dht_clients.c

index 7674347e4f1689c82adbd4426160a25aac2f9982..e0b97b4577404315749e7ff614f78fd95ba13181 100644 (file)
@@ -277,6 +277,9 @@ try_reconnect (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
 {
   struct GNUNET_DHT_Handle *handle = cls;
 
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+       "Reconnedting with DHT %p\n",
+       handle);
   handle->reconnect_task = GNUNET_SCHEDULER_NO_TASK;
   if (handle->retry_time.rel_value < GNUNET_CONSTANTS_SERVICE_RETRY.rel_value)
     handle->retry_time = GNUNET_CONSTANTS_SERVICE_RETRY;
@@ -513,8 +516,9 @@ service_message_handler (void *cls, const struct GNUNET_MessageHeader *msg)
   }
   dht_msg = (const struct GNUNET_DHT_ClientResultMessage *) msg;
   LOG (GNUNET_ERROR_TYPE_DEBUG, 
-       "Received reply for `%s' from DHT service\n",
-       GNUNET_h2s (&dht_msg->key));
+       "Received reply for `%s' from DHT service %p\n",
+       GNUNET_h2s (&dht_msg->key),
+       handle);
   GNUNET_CONTAINER_multihashmap_get_multiple (handle->active_requests,
                                               &dht_msg->key, &process_reply,
                                               (void *) dht_msg);
@@ -716,6 +720,10 @@ GNUNET_DHT_get_start (struct GNUNET_DHT_Handle *handle,
     GNUNET_break (0);
     return NULL;
   }
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+       "Sending query for %s to DHT %p\n",
+       GNUNET_h2s (key),
+       handle);
   pending = GNUNET_malloc (sizeof (struct PendingMessage) + msize);
   get_msg = (struct GNUNET_DHT_ClientGetMessage *) &pending[1];
   pending->msg = &get_msg->header;
@@ -761,7 +769,10 @@ GNUNET_DHT_get_stop (struct GNUNET_DHT_GetHandle *get_handle)
   handle = get_handle->message->handle;
   get_msg =
       (const struct GNUNET_DHT_ClientGetMessage *) get_handle->message->msg;
-
+  LOG (GNUNET_ERROR_TYPE_DEBUG,
+       "Sending STOP for %s to DHT via %p\n",
+       GNUNET_h2s (&get_msg->key),
+       handle);
   /* generate STOP */
   pending =
       GNUNET_malloc (sizeof (struct PendingMessage) +
index b0641d6b2e93eb909c6c1a10596ef6f13e5c473a..6f7c1daae53a05ce6ddbf2ce312a8763b4d4cdb6 100644 (file)
@@ -411,7 +411,7 @@ handle_dht_local_put (void *cls, struct GNUNET_SERVER_Client *client,
   dht_msg = (const struct GNUNET_DHT_ClientPutMessage *) message;
   /* give to local clients */
   GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
-             "Passing %u-byte reply for query %s to local clients\n",
+             "Handling local PUT of %u-bytes for query %s\n",
              size - sizeof (struct GNUNET_DHT_ClientPutMessage),
              GNUNET_h2s (&dht_msg->key));
   GDS_CLIENTS_handle_reply (GNUNET_TIME_absolute_ntoh (dht_msg->expiration),