diff options
Diffstat (limited to 'src/transport/plugin_transport_http_client.c')
-rw-r--r-- | src/transport/plugin_transport_http_client.c | 60 |
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) | |||
541 | static void | 541 | static void |
542 | client_reschedule_session_timeout (struct Session *s) | 542 | client_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, |