aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_http_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_http_client.c')
-rw-r--r--src/transport/plugin_transport_http_client.c60
1 files changed, 30 insertions, 30 deletions
diff --git a/src/transport/plugin_transport_http_client.c b/src/transport/plugin_transport_http_client.c
index 4cafaf2c0..cc1f39e9a 100644
--- a/src/transport/plugin_transport_http_client.c
+++ b/src/transport/plugin_transport_http_client.c
@@ -222,17 +222,17 @@ struct Session
222 /** 222 /**
223 * Session timeout task 223 * Session timeout task
224 */ 224 */
225 GNUNET_SCHEDULER_TaskIdentifier put_disconnect_task; 225 struct GNUNET_SCHEDULER_Task * put_disconnect_task;
226 226
227 /** 227 /**
228 * Session timeout task 228 * Session timeout task
229 */ 229 */
230 GNUNET_SCHEDULER_TaskIdentifier timeout_task; 230 struct GNUNET_SCHEDULER_Task * timeout_task;
231 231
232 /** 232 /**
233 * Task to wake up client receive handle when receiving is allowed again 233 * Task to wake up client receive handle when receiving is allowed again
234 */ 234 */
235 GNUNET_SCHEDULER_TaskIdentifier recv_wakeup_task; 235 struct GNUNET_SCHEDULER_Task * recv_wakeup_task;
236 236
237 /** 237 /**
238 * Absolute time when to receive data again. 238 * Absolute time when to receive data again.
@@ -326,7 +326,7 @@ struct HTTP_Client_Plugin
326 /** 326 /**
327 * curl perform task 327 * curl perform task
328 */ 328 */
329 GNUNET_SCHEDULER_TaskIdentifier client_perform_task; 329 struct GNUNET_SCHEDULER_Task * client_perform_task;
330 330
331 /** 331 /**
332 * Type of proxy server: 332 * Type of proxy server:
@@ -440,21 +440,21 @@ client_delete_session (struct Session *s)
440 struct HTTP_Message *next; 440 struct HTTP_Message *next;
441 CURLMcode mret; 441 CURLMcode mret;
442 442
443 if (GNUNET_SCHEDULER_NO_TASK != s->timeout_task) 443 if (NULL != s->timeout_task)
444 { 444 {
445 GNUNET_SCHEDULER_cancel (s->timeout_task); 445 GNUNET_SCHEDULER_cancel (s->timeout_task);
446 s->timeout_task = GNUNET_SCHEDULER_NO_TASK; 446 s->timeout_task = NULL;
447 s->timeout = GNUNET_TIME_UNIT_ZERO_ABS; 447 s->timeout = GNUNET_TIME_UNIT_ZERO_ABS;
448 } 448 }
449 if (GNUNET_SCHEDULER_NO_TASK != s->put_disconnect_task) 449 if (NULL != s->put_disconnect_task)
450 { 450 {
451 GNUNET_SCHEDULER_cancel (s->put_disconnect_task); 451 GNUNET_SCHEDULER_cancel (s->put_disconnect_task);
452 s->put_disconnect_task = GNUNET_SCHEDULER_NO_TASK; 452 s->put_disconnect_task = NULL;
453 } 453 }
454 if (GNUNET_SCHEDULER_NO_TASK != s->recv_wakeup_task) 454 if (NULL != s->recv_wakeup_task)
455 { 455 {
456 GNUNET_SCHEDULER_cancel (s->recv_wakeup_task); 456 GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
457 s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK; 457 s->recv_wakeup_task = NULL;
458 } 458 }
459 GNUNET_assert (GNUNET_OK == 459 GNUNET_assert (GNUNET_OK ==
460 GNUNET_CONTAINER_multipeermap_remove (plugin->sessions, 460 GNUNET_CONTAINER_multipeermap_remove (plugin->sessions,
@@ -541,7 +541,7 @@ client_delete_session (struct Session *s)
541static void 541static void
542client_reschedule_session_timeout (struct Session *s) 542client_reschedule_session_timeout (struct Session *s)
543{ 543{
544 GNUNET_assert (GNUNET_SCHEDULER_NO_TASK != s->timeout_task); 544 GNUNET_assert (NULL != s->timeout_task);
545 s->timeout = GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT); 545 s->timeout = GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT);
546} 546}
547 547
@@ -579,10 +579,10 @@ client_schedule (struct HTTP_Client_Plugin *plugin,
579 struct GNUNET_TIME_Relative timeout; 579 struct GNUNET_TIME_Relative timeout;
580 580
581 /* Cancel previous scheduled task */ 581 /* Cancel previous scheduled task */
582 if (plugin->client_perform_task != GNUNET_SCHEDULER_NO_TASK) 582 if (plugin->client_perform_task != NULL)
583 { 583 {
584 GNUNET_SCHEDULER_cancel (plugin->client_perform_task); 584 GNUNET_SCHEDULER_cancel (plugin->client_perform_task);
585 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK; 585 plugin->client_perform_task = NULL;
586 } 586 }
587 max = -1; 587 max = -1;
588 FD_ZERO (&rs); 588 FD_ZERO (&rs);
@@ -802,9 +802,9 @@ http_client_plugin_send (void *cls,
802 if (H_PAUSED == s->put.state) 802 if (H_PAUSED == s->put.state)
803 { 803 {
804 /* PUT request was paused, unpause */ 804 /* PUT request was paused, unpause */
805 GNUNET_assert (s->put_disconnect_task != GNUNET_SCHEDULER_NO_TASK); 805 GNUNET_assert (s->put_disconnect_task != NULL);
806 GNUNET_SCHEDULER_cancel (s->put_disconnect_task); 806 GNUNET_SCHEDULER_cancel (s->put_disconnect_task);
807 s->put_disconnect_task = GNUNET_SCHEDULER_NO_TASK; 807 s->put_disconnect_task = NULL;
808 LOG (GNUNET_ERROR_TYPE_DEBUG, 808 LOG (GNUNET_ERROR_TYPE_DEBUG,
809 "Session %p/request %p: unpausing request\n", 809 "Session %p/request %p: unpausing request\n",
810 s, s->put.easyhandle); 810 s, s->put.easyhandle);
@@ -851,10 +851,10 @@ http_client_plugin_session_disconnect (void *cls,
851 client_delete_session (s); 851 client_delete_session (s);
852 852
853 /* Re-schedule since handles have changed */ 853 /* Re-schedule since handles have changed */
854 if (plugin->client_perform_task != GNUNET_SCHEDULER_NO_TASK) 854 if (plugin->client_perform_task != NULL)
855 { 855 {
856 GNUNET_SCHEDULER_cancel (plugin->client_perform_task); 856 GNUNET_SCHEDULER_cancel (plugin->client_perform_task);
857 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK; 857 plugin->client_perform_task = NULL;
858 } 858 }
859 client_schedule (plugin, GNUNET_YES); 859 client_schedule (plugin, GNUNET_YES);
860 860
@@ -1001,7 +1001,7 @@ client_put_disconnect (void *cls,
1001{ 1001{
1002 struct Session *s = cls; 1002 struct Session *s = cls;
1003 1003
1004 s->put_disconnect_task = GNUNET_SCHEDULER_NO_TASK; 1004 s->put_disconnect_task = NULL;
1005 LOG (GNUNET_ERROR_TYPE_DEBUG, 1005 LOG (GNUNET_ERROR_TYPE_DEBUG,
1006 "Session %p/request %p: will be disconnected due to no activity\n", 1006 "Session %p/request %p: will be disconnected due to no activity\n",
1007 s, s->put.easyhandle); 1007 s, s->put.easyhandle);
@@ -1132,7 +1132,7 @@ client_wake_up (void *cls,
1132{ 1132{
1133 struct Session *s = cls; 1133 struct Session *s = cls;
1134 1134
1135 s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK; 1135 s->recv_wakeup_task = NULL;
1136 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 1136 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
1137 return; 1137 return;
1138 LOG (GNUNET_ERROR_TYPE_DEBUG, 1138 LOG (GNUNET_ERROR_TYPE_DEBUG,
@@ -1141,9 +1141,9 @@ client_wake_up (void *cls,
1141 if (H_PAUSED == s->put.state) 1141 if (H_PAUSED == s->put.state)
1142 { 1142 {
1143 /* PUT request was paused, unpause */ 1143 /* PUT request was paused, unpause */
1144 GNUNET_assert (s->put_disconnect_task != GNUNET_SCHEDULER_NO_TASK); 1144 GNUNET_assert (s->put_disconnect_task != NULL);
1145 GNUNET_SCHEDULER_cancel (s->put_disconnect_task); 1145 GNUNET_SCHEDULER_cancel (s->put_disconnect_task);
1146 s->put_disconnect_task = GNUNET_SCHEDULER_NO_TASK; 1146 s->put_disconnect_task = NULL;
1147 s->put.state = H_CONNECTED; 1147 s->put.state = H_CONNECTED;
1148 if (NULL != s->put.easyhandle) 1148 if (NULL != s->put.easyhandle)
1149 curl_easy_pause (s->put.easyhandle, CURLPAUSE_CONT); 1149 curl_easy_pause (s->put.easyhandle, CURLPAUSE_CONT);
@@ -1271,10 +1271,10 @@ client_receive (void *stream,
1271 s->get.easyhandle, 1271 s->get.easyhandle,
1272 GNUNET_STRINGS_relative_time_to_string (delta, 1272 GNUNET_STRINGS_relative_time_to_string (delta,
1273 GNUNET_YES)); 1273 GNUNET_YES));
1274 if (s->recv_wakeup_task != GNUNET_SCHEDULER_NO_TASK) 1274 if (s->recv_wakeup_task != NULL)
1275 { 1275 {
1276 GNUNET_SCHEDULER_cancel (s->recv_wakeup_task); 1276 GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
1277 s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK; 1277 s->recv_wakeup_task = NULL;
1278 } 1278 }
1279 s->recv_wakeup_task 1279 s->recv_wakeup_task
1280 = GNUNET_SCHEDULER_add_delayed (delta, 1280 = GNUNET_SCHEDULER_add_delayed (delta,
@@ -1313,7 +1313,7 @@ client_run (void *cls,
1313 int put_request; /* GNUNET_YES if easy handle is put, GNUNET_NO for get */ 1313 int put_request; /* GNUNET_YES if easy handle is put, GNUNET_NO for get */
1314 int msgs_left; 1314 int msgs_left;
1315 1315
1316 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK; 1316 plugin->client_perform_task = NULL;
1317 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) 1317 if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN))
1318 return; 1318 return;
1319 1319
@@ -1918,10 +1918,10 @@ client_connect (struct Session *s)
1918 plugin->cur_requests, 1918 plugin->cur_requests,
1919 GNUNET_NO); 1919 GNUNET_NO);
1920 /* Re-schedule since handles have changed */ 1920 /* Re-schedule since handles have changed */
1921 if (plugin->client_perform_task != GNUNET_SCHEDULER_NO_TASK) 1921 if (plugin->client_perform_task != NULL)
1922 { 1922 {
1923 GNUNET_SCHEDULER_cancel (plugin->client_perform_task); 1923 GNUNET_SCHEDULER_cancel (plugin->client_perform_task);
1924 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK; 1924 plugin->client_perform_task = NULL;
1925 } 1925 }
1926 1926
1927 /* Schedule task to run immediately */ 1927 /* Schedule task to run immediately */
@@ -1958,7 +1958,7 @@ client_session_timeout (void *cls,
1958 struct Session *s = cls; 1958 struct Session *s = cls;
1959 struct GNUNET_TIME_Relative left; 1959 struct GNUNET_TIME_Relative left;
1960 1960
1961 s->timeout_task = GNUNET_SCHEDULER_NO_TASK; 1961 s->timeout_task = NULL;
1962 left = GNUNET_TIME_absolute_get_remaining (s->timeout); 1962 left = GNUNET_TIME_absolute_get_remaining (s->timeout);
1963 if (0 != left.rel_value_us) 1963 if (0 != left.rel_value_us)
1964 { 1964 {
@@ -2166,10 +2166,10 @@ LIBGNUNET_PLUGIN_TRANSPORT_DONE (void *cls)
2166 GNUNET_CONTAINER_multipeermap_iterate (plugin->sessions, 2166 GNUNET_CONTAINER_multipeermap_iterate (plugin->sessions,
2167 &destroy_session_cb, 2167 &destroy_session_cb,
2168 plugin); 2168 plugin);
2169 if (GNUNET_SCHEDULER_NO_TASK != plugin->client_perform_task) 2169 if (NULL != plugin->client_perform_task)
2170 { 2170 {
2171 GNUNET_SCHEDULER_cancel (plugin->client_perform_task); 2171 GNUNET_SCHEDULER_cancel (plugin->client_perform_task);
2172 plugin->client_perform_task = GNUNET_SCHEDULER_NO_TASK; 2172 plugin->client_perform_task = NULL;
2173 } 2173 }
2174 if (NULL != plugin->curl_multi_handle) 2174 if (NULL != plugin->curl_multi_handle)
2175 { 2175 {
@@ -2368,7 +2368,7 @@ http_client_plugin_update_inbound_delay (void *cls,
2368 "New inbound delay %s\n", 2368 "New inbound delay %s\n",
2369 GNUNET_STRINGS_relative_time_to_string (delay, 2369 GNUNET_STRINGS_relative_time_to_string (delay,
2370 GNUNET_NO)); 2370 GNUNET_NO));
2371 if (s->recv_wakeup_task != GNUNET_SCHEDULER_NO_TASK) 2371 if (s->recv_wakeup_task != NULL)
2372 { 2372 {
2373 GNUNET_SCHEDULER_cancel (s->recv_wakeup_task); 2373 GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
2374 s->recv_wakeup_task = GNUNET_SCHEDULER_add_delayed (delay, 2374 s->recv_wakeup_task = GNUNET_SCHEDULER_add_delayed (delay,