aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_http_client.c
diff options
context:
space:
mode:
authorMatthias Wachs <wachs@net.in.tum.de>2011-09-16 13:22:46 +0000
committerMatthias Wachs <wachs@net.in.tum.de>2011-09-16 13:22:46 +0000
commitcdc7de2be41b4d68f92a6af6e66e7a6503f268e1 (patch)
tree09a9eec79ddaeb6b1ab204ae54c4319a7051b7b8 /src/transport/plugin_transport_http_client.c
parent5d4256d1235061a1382764a425b9372376f64450 (diff)
downloadgnunet-cdc7de2be41b4d68f92a6af6e66e7a6503f268e1.tar.gz
gnunet-cdc7de2be41b4d68f92a6af6e66e7a6503f268e1.zip
Diffstat (limited to 'src/transport/plugin_transport_http_client.c')
-rw-r--r--src/transport/plugin_transport_http_client.c9
1 files changed, 5 insertions, 4 deletions
diff --git a/src/transport/plugin_transport_http_client.c b/src/transport/plugin_transport_http_client.c
index f62f7b2dd..c2962394f 100644
--- a/src/transport/plugin_transport_http_client.c
+++ b/src/transport/plugin_transport_http_client.c
@@ -183,6 +183,7 @@ client_run (void *cls, const struct GNUNET_SCHEDULER_TaskContext *tc)
183 "Connection to '%s' %s ended\n", GNUNET_i2s(&s->target), http_plugin_address_to_string(plugin, s->addr, s->addrlen)); 183 "Connection to '%s' %s ended\n", GNUNET_i2s(&s->target), http_plugin_address_to_string(plugin, s->addr, s->addrlen));
184#endif 184#endif
185 client_disconnect(s); 185 client_disconnect(s);
186 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,"Notifying about ended session to peer `%s' `%s'\n", GNUNET_i2s (&s->target), GNUNET_a2s (s->addr, s->addrlen));
186 notify_session_end (plugin, &s->target, s); 187 notify_session_end (plugin, &s->target, s);
187 } 188 }
188 } 189 }
@@ -198,9 +199,9 @@ client_disconnect (struct Session *s)
198{ 199{
199 int res = GNUNET_OK; 200 int res = GNUNET_OK;
200 CURLMcode mret; 201 CURLMcode mret;
201 struct Plugin *plugin = plugin; 202 struct Plugin *plugin = s->plugin;
202 203
203#if DEBUG_HTTP 204#if 0
204 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name, 205 GNUNET_log_from (GNUNET_ERROR_TYPE_DEBUG, plugin->name,
205 "Deleting outbound PUT session to peer `%s'\n", 206 "Deleting outbound PUT session to peer `%s'\n",
206 GNUNET_i2s (&s->target)); 207 GNUNET_i2s (&s->target));
@@ -239,13 +240,13 @@ client_disconnect (struct Session *s)
239 } 240 }
240 241
241 plugin->cur_connections -= 2; 242 plugin->cur_connections -= 2;
242
243 /* Re-schedule since handles have changed */ 243 /* Re-schedule since handles have changed */
244 if (plugin->client_perform_task!= GNUNET_SCHEDULER_NO_TASK) 244 if (plugin->client_perform_task != GNUNET_SCHEDULER_NO_TASK)
245 { 245 {
246 GNUNET_SCHEDULER_cancel (plugin->client_perform_task); 246 GNUNET_SCHEDULER_cancel (plugin->client_perform_task);
247 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK; 247 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK;
248 } 248 }
249
249 plugin->client_perform_task = GNUNET_SCHEDULER_add_now(client_run, plugin); 250 plugin->client_perform_task = GNUNET_SCHEDULER_add_now(client_run, plugin);
250 251
251 return res; 252 return res;