[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r17052 - gnunet/src/transport
From: |
gnunet |
Subject: |
[GNUnet-SVN] r17052 - gnunet/src/transport |
Date: |
Tue, 27 Sep 2011 15:06:14 +0200 |
Author: wachs
Date: 2011-09-27 15:06:14 +0200 (Tue, 27 Sep 2011)
New Revision: 17052
Modified:
gnunet/src/transport/plugin_transport_http_client.c
Log:
client bw throttling
Modified: gnunet/src/transport/plugin_transport_http_client.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_client.c 2011-09-27 12:50:55 UTC
(rev 17051)
+++ gnunet/src/transport/plugin_transport_http_client.c 2011-09-27 13:06:14 UTC
(rev 17052)
@@ -326,11 +326,17 @@
struct Session *s = cls;
s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK;
+
if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
return;
+ GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, s->plugin->name,
+ "Client: %X Waking up receive handle\n",
+ s->client_get);
+
if (s->client_get != NULL)
curl_easy_pause(s->client_get, CURLPAUSE_CONT);
+
}
/**
@@ -360,20 +366,20 @@
now = GNUNET_TIME_absolute_get();
if (now.abs_value < s->next_receive.abs_value)
{
+ struct GNUNET_TIME_Absolute now = GNUNET_TIME_absolute_get();
+ struct GNUNET_TIME_Relative delta =
GNUNET_TIME_absolute_get_difference(now, s->next_receive);
#if DEBUG_CLIENT
- GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
- "No inbound bandwidth available! Next read was delayed for
%llu ms\n",
- s, GNUNET_TIME_absolute_get_difference(s->next_receive,
GNUNET_TIME_absolute_get()).rel_value);
+ GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
+ "Client: %X No inbound bandwidth available! Next read was delayed for
%llu ms\n",
+ s->client_get, delta.rel_value);
#endif
-#if 0
if (s->recv_wakeup_task != GNUNET_SCHEDULER_NO_TASK)
{
GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK;
}
- s->recv_wakeup_task = GNUNET_SCHEDULER_add_delayed(
GNUNET_TIME_absolute_get_difference(s->next_receive, now), &client_wake_up, s);
+ s->recv_wakeup_task = GNUNET_SCHEDULER_add_delayed (delta,
&client_wake_up, s);
return CURLPAUSE_ALL;
-#endif
}
@@ -384,8 +390,7 @@
GNUNET_NO);
return len;
-
- client_wake_up (NULL, NULL);
+ client_wake_up(NULL,NULL);
}
/**
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r17052 - gnunet/src/transport,
gnunet <=