{
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;
}
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);
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;
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) +
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),