{
#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));
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)
{
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);
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)
{
#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)
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)
{
#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;
#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 ));
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)
{
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]);
}