[GNUnet-SVN] r23969 - gnunet/src/transport

[gnunet]

Author: wachs
Date: 2012-09-24 10:43:14 +0200 (Mon, 24 Sep 2012)
New Revision: 23969

Modified:
   gnunet/src/transport/plugin_transport_http_client.c
Log:
- fix disconnect problem in put connection

Modified: gnunet/src/transport/plugin_transport_http_client.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_client.c 2012-09-24 08:31:55 UTC 
(rev 23968)
+++ gnunet/src/transport/plugin_transport_http_client.c 2012-09-24 08:43:14 UTC 
(rev 23969)
@@ -880,8 +880,9 @@
   struct HTTP_Client_Plugin *plugin = s->plugin;
 
   GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
-                   "Received %u bytes from peer `%s'\n", len,
-                   GNUNET_i2s (&s->target));
+                   "Session %p / connection %p: Received %u bytes from peer 
`%s'\n",
+                   s, s->client_get,
+                   len, GNUNET_i2s (&s->target));
   now = GNUNET_TIME_absolute_get ();
   if (now.abs_value < s->next_receive.abs_value)
   {
@@ -889,8 +890,8 @@
     struct GNUNET_TIME_Relative delta =
         GNUNET_TIME_absolute_get_difference (now, s->next_receive);
     GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
-                     "No inbound bandwidth for session %p available! Next read 
was delayed for %llu ms\n",
-                     s, delta.rel_value);
+                     "Session %p / connection %p: No inbound bandwidth 
available! Next read was delayed for %llu ms\n",
+                     s, s->client_get, delta.rel_value);
     if (s->recv_wakeup_task != GNUNET_SCHEDULER_NO_TASK)
     {
       GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
@@ -898,7 +899,7 @@
     }
     s->recv_wakeup_task =
         GNUNET_SCHEDULER_add_delayed (delta, &client_wake_up, s);
-    return CURLPAUSE_ALL;
+    return CURL_WRITEFUNC_PAUSE;
   }
   if (NULL == s->msg_tk)
     s->msg_tk = GNUNET_SERVER_mst_create (&client_receive_mst_cb, s);