gnunet-svn
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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


From: gnunet
Subject: [GNUnet-SVN] r17015 - gnunet/src/transport
Date: Mon, 26 Sep 2011 16:44:30 +0200

Author: wachs
Date: 2011-09-26 16:44:29 +0200 (Mon, 26 Sep 2011)
New Revision: 17015

Modified:
   gnunet/src/transport/plugin_transport_http_client.c
   gnunet/src/transport/plugin_transport_http_new.c
Log:
fixes


Modified: gnunet/src/transport/plugin_transport_http_client.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_client.c 2011-09-26 14:11:11 UTC 
(rev 17014)
+++ gnunet/src/transport/plugin_transport_http_client.c 2011-09-26 14:44:29 UTC 
(rev 17015)
@@ -189,7 +189,7 @@
        {
 #if DEBUG_HTTP
          GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
-                   "Client: %X connection to '%s'  %s ended\n", s, 
GNUNET_i2s(&s->target), GNUNET_a2s (s->addr, s->addrlen));
+                   "Client: %X connection to '%s'  %s ended\n", 
msg->easy_handle, GNUNET_i2s(&s->target), GNUNET_a2s (s->addr, s->addrlen));
 #endif
          client_disconnect(s);
          //GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,"Notifying 
about ended session to peer `%s' `%s'\n", GNUNET_i2s (&s->target), 
http_plugin_address_to_string (plugin, s->addr, s->addrlen));
@@ -214,15 +214,17 @@
   struct HTTP_Message * msg;
   struct HTTP_Message * t;
 
+
+
+  if (s->client_put != NULL)
+  {
 #if DEBUG_HTTP
   GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
                    "Client: %X Deleting outbound PUT session to peer `%s'\n",
-                   s,
+                   s->client_put,
                    GNUNET_i2s (&s->target));
 #endif
 
-  if (s->client_put != NULL)
-  {
     mret = curl_multi_remove_handle (plugin->client_mh, s->client_put);
     if (mret != CURLM_OK)
     {
@@ -234,12 +236,7 @@
     s->client_put = NULL;
   }
 
-#if DEBUG_HTTP
-  GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
-                   "Client: %X Deleting outbound GET session to peer `%s'\n",
-                   s,
-                   GNUNET_i2s (&s->target));
-#endif
+
   if (s->recv_wakeup_task != GNUNET_SCHEDULER_NO_TASK)
   {
    GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
@@ -248,6 +245,13 @@
 
   if (s->client_get != NULL)
   {
+#if DEBUG_HTTP
+  GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
+                   "Client: %X Deleting outbound GET session to peer `%s'\n",
+                   s->client_get,
+                   GNUNET_i2s (&s->target));
+#endif
+
     mret = curl_multi_remove_handle (plugin->client_mh, s->client_get);
     if (mret != CURLM_OK)
     {
@@ -429,7 +433,7 @@
 #if VERBOSE_CLIENT
     GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
                 "Client: %X Message with %u bytes sent, removing message from 
queue\n",
-                s, msg->size, msg->pos);
+                s->client_put, msg->size, msg->pos);
 #endif
     /* Calling transmit continuation  */
     if (NULL != msg->transmit_cont)

Modified: gnunet/src/transport/plugin_transport_http_new.c
===================================================================
--- gnunet/src/transport/plugin_transport_http_new.c    2011-09-26 14:11:11 UTC 
(rev 17014)
+++ gnunet/src/transport/plugin_transport_http_new.c    2011-09-26 14:44:29 UTC 
(rev 17015)
@@ -494,10 +494,7 @@
   GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, plugin->name,
                    "%s exisiting session\n", (s!=NULL) ? "Found" : "NOT 
Found");
 #endif
-  // FIXME DEBUGGING
-  if (session != NULL)
-     s= session;
-  //FIXME END
+
   /* create new outbound connection */
   if (s == NULL)
   {
@@ -656,7 +653,7 @@
 #if DEBUG_HTTP
     GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
                      "Notifying transport to add IPv6 address `%s'\n",
-                     http_plugin_address_to_string(NULL, &w_t6->addr, sizeof 
(struct sockaddr_in)));
+                     http_plugin_address_to_string(NULL, &w_t6->addr, sizeof 
(struct sockaddr_in6)));
 #endif
     plugin->env->notify_address (plugin->env->cls, add_remove, &w_t6->addr, 
sizeof (struct sockaddr_in6));
     break;
@@ -722,7 +719,7 @@
 #if DEBUG_HTTP
     GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
                      "Notifying transport to remove IPv6 address `%s'\n",
-                     http_plugin_address_to_string(NULL, &w_t4->addr, sizeof 
(struct sockaddr_in)));
+                     http_plugin_address_to_string(NULL, &w_t6->addr, sizeof 
(struct sockaddr_in6)));
 #endif
     plugin->env->notify_address (plugin->env->cls, add_remove, &w_t6->addr,
                                  sizeof (struct sockaddr_in6 ));
@@ -786,6 +783,10 @@
   res =
       GNUNET_SERVICE_get_server_addresses (plugin->name, plugin->env->cfg,
                                            &addrs, &addrlens);
+#if 0
+  GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, plugin->name,
+                   _("FOUND %u addresses\n"),res);
+#endif
 
   if (res != GNUNET_SYSERR)
   {
@@ -798,6 +799,11 @@
     while (res > 0)
     {
       res--;
+#if 0
+      GNUNET_log_from (GNUNET_ERROR_TYPE_ERROR, plugin->name,
+                       _("FREEING %s\n"),
+                       GNUNET_a2s (addrs[res], addrlens[res]));
+#endif
       GNUNET_assert (addrs[res] != NULL);
       GNUNET_free (addrs[res]);
     }




reply via email to

[Prev in Thread] Current Thread [Next in Thread]