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

[gnunet]

Author: wachs
Date: 2010-07-05 17:03:44 +0200 (Mon, 05 Jul 2010)
New Revision: 12165

Modified:
   gnunet/src/transport/plugin_transport_http.c
Log:


Modified: gnunet/src/transport/plugin_transport_http.c
===================================================================
--- gnunet/src/transport/plugin_transport_http.c        2010-07-05 14:57:32 UTC 
(rev 12164)
+++ gnunet/src/transport/plugin_transport_http.c        2010-07-05 15:03:44 UTC 
(rev 12165)
@@ -427,12 +427,12 @@
              ntohs(message->type),
               ntohs(message->size),
              
GNUNET_i2s(&(ps->peercontext)->identity),http_plugin_address_to_string(NULL,ps->addr,ps->addrlen));
-
+/*
   pc->plugin->env->receive (ps->peercontext->plugin->env->cls,
                            &pc->identity,
                            message, 1, ps,
                            ps->addr,
-                           ps->addrlen);
+                           ps->addrlen);*/
 }
 
 static void curl_write_mst_cb  (void *cls,
@@ -449,12 +449,12 @@
               ntohs(message->type),
               ntohs(message->size),
               
GNUNET_i2s(&(pc->identity)),http_plugin_address_to_string(NULL,ps->addr,ps->addrlen));
-
+/*
   pc->plugin->env->receive (pc->plugin->env->cls,
                             &pc->identity,
                             message, 1, ps,
                             ps->addr,
-                            ps->addrlen);
+                            ps->addrlen);*/
 }
 
 
@@ -1070,6 +1070,7 @@
         bytes_sent = msg->size;
     return bytes_sent;
   }
+  return 0;
 }
 
 static void send_execute (void *cls,
@@ -1471,6 +1472,14 @@
     {
 
     }
+    while (ps->pending_msgs_head!=NULL)
+    {
+      remove_http_message(ps, ps->pending_msgs_head);
+    }
+    ps->recv_connected = GNUNET_NO;
+    ps->recv_active = GNUNET_NO;
+    ps->send_connected = GNUNET_NO;
+    ps->send_active = GNUNET_NO;
     ps=ps->next;
   }