gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[GNUnet-SVN] r17740 - gnunet/src/dht


From: gnunet
Subject: [GNUnet-SVN] r17740 - gnunet/src/dht
Date: Tue, 25 Oct 2011 14:11:06 +0200

Author: grothoff
Date: 2011-10-25 14:11:06 +0200 (Tue, 25 Oct 2011)
New Revision: 17740

Modified:
   gnunet/src/dht/dht_api.c
   gnunet/src/dht/gnunet-service-dht_clients.c
Log:
logging

Modified: gnunet/src/dht/dht_api.c
===================================================================
--- gnunet/src/dht/dht_api.c    2011-10-25 08:47:28 UTC (rev 17739)
+++ gnunet/src/dht/dht_api.c    2011-10-25 12:11:06 UTC (rev 17740)
@@ -277,6 +277,9 @@
 {
   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 @@
   }
   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_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 @@
   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) +

Modified: gnunet/src/dht/gnunet-service-dht_clients.c
===================================================================
--- gnunet/src/dht/gnunet-service-dht_clients.c 2011-10-25 08:47:28 UTC (rev 
17739)
+++ gnunet/src/dht/gnunet-service-dht_clients.c 2011-10-25 12:11:06 UTC (rev 
17740)
@@ -411,7 +411,7 @@
   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),




reply via email to

[Prev in Thread] Current Thread [Next in Thread]