[Top][All Lists]
[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]);
}
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r17015 - gnunet/src/transport,
gnunet <=