[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r15216 - gnunet/src/dht
From: |
gnunet |
Subject: |
[GNUnet-SVN] r15216 - gnunet/src/dht |
Date: |
Thu, 12 May 2011 15:46:15 +0200 |
Author: grothoff
Date: 2011-05-12 15:46:15 +0200 (Thu, 12 May 2011)
New Revision: 15216
Modified:
gnunet/src/dht/dht_api.c
Log:
simplify
Modified: gnunet/src/dht/dht_api.c
===================================================================
--- gnunet/src/dht/dht_api.c 2011-05-12 13:10:20 UTC (rev 15215)
+++ gnunet/src/dht/dht_api.c 2011-05-12 13:46:15 UTC (rev 15216)
@@ -279,6 +279,14 @@
/**
+ * Try to send messages from list of messages to send
+ * @param handle DHT_Handle
+ */
+static void
+process_pending_messages (struct GNUNET_DHT_Handle *handle);
+
+
+/**
* Try reconnecting to the dht service.
*
* @param cls GNUNET_DHT_Handle
@@ -289,6 +297,7 @@
const struct GNUNET_SCHEDULER_TaskContext *tc)
{
struct GNUNET_DHT_Handle *handle = cls;
+
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;
@@ -304,19 +313,10 @@
"dht reconnect failed(!)\n");
return;
}
-
GNUNET_CONTAINER_multihashmap_iterate (handle->active_requests,
&add_request_to_pending,
handle);
- if (handle->pending_head == NULL)
- return;
-
- GNUNET_CLIENT_notify_transmit_ready (handle->client,
- ntohs(handle->pending_head->msg->size),
- GNUNET_TIME_UNIT_FOREVER_REL,
- GNUNET_NO,
- &transmit_pending,
- handle);
+ process_pending_messages (handle);
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r15216 - gnunet/src/dht,
gnunet <=