diff options
Diffstat (limited to 'src/transport/plugin_transport_http_server.c')
-rw-r--r-- | src/transport/plugin_transport_http_server.c | 70 |
1 files changed, 35 insertions, 35 deletions
diff --git a/src/transport/plugin_transport_http_server.c b/src/transport/plugin_transport_http_server.c index 31bd7ba4f..aaa17b2cf 100644 --- a/src/transport/plugin_transport_http_server.c +++ b/src/transport/plugin_transport_http_server.c | |||
@@ -232,12 +232,12 @@ struct Session | |||
232 | /** | 232 | /** |
233 | * Session timeout task | 233 | * Session timeout task |
234 | */ | 234 | */ |
235 | GNUNET_SCHEDULER_TaskIdentifier timeout_task; | 235 | struct GNUNET_SCHEDULER_Task * timeout_task; |
236 | 236 | ||
237 | /** | 237 | /** |
238 | * Task to resume MHD handling when receiving is allowed again | 238 | * Task to resume MHD handling when receiving is allowed again |
239 | */ | 239 | */ |
240 | GNUNET_SCHEDULER_TaskIdentifier recv_wakeup_task; | 240 | struct GNUNET_SCHEDULER_Task * recv_wakeup_task; |
241 | 241 | ||
242 | /** | 242 | /** |
243 | * Number of bytes waiting for transmission to this peer. | 243 | * Number of bytes waiting for transmission to this peer. |
@@ -374,17 +374,17 @@ struct HTTP_Server_Plugin | |||
374 | /** | 374 | /** |
375 | * MHD IPv4 task | 375 | * MHD IPv4 task |
376 | */ | 376 | */ |
377 | GNUNET_SCHEDULER_TaskIdentifier server_v4_task; | 377 | struct GNUNET_SCHEDULER_Task * server_v4_task; |
378 | 378 | ||
379 | /** | 379 | /** |
380 | * MHD IPv6 task | 380 | * MHD IPv6 task |
381 | */ | 381 | */ |
382 | GNUNET_SCHEDULER_TaskIdentifier server_v6_task; | 382 | struct GNUNET_SCHEDULER_Task * server_v6_task; |
383 | 383 | ||
384 | /** | 384 | /** |
385 | * Task calling transport service about external address | 385 | * Task calling transport service about external address |
386 | */ | 386 | */ |
387 | GNUNET_SCHEDULER_TaskIdentifier notify_ext_task; | 387 | struct GNUNET_SCHEDULER_Task * notify_ext_task; |
388 | 388 | ||
389 | /** | 389 | /** |
390 | * Notify transport only about external address | 390 | * Notify transport only about external address |
@@ -499,7 +499,7 @@ server_wake_up (void *cls, | |||
499 | { | 499 | { |
500 | struct Session *s = cls; | 500 | struct Session *s = cls; |
501 | 501 | ||
502 | s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK; | 502 | s->recv_wakeup_task = NULL; |
503 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 503 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
504 | return; | 504 | return; |
505 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 505 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
@@ -534,16 +534,16 @@ server_delete_session (struct Session *s) | |||
534 | struct HTTP_Server_Plugin *plugin = s->plugin; | 534 | struct HTTP_Server_Plugin *plugin = s->plugin; |
535 | struct HTTP_Message *msg; | 535 | struct HTTP_Message *msg; |
536 | 536 | ||
537 | if (GNUNET_SCHEDULER_NO_TASK != s->timeout_task) | 537 | if (NULL != s->timeout_task) |
538 | { | 538 | { |
539 | GNUNET_SCHEDULER_cancel (s->timeout_task); | 539 | GNUNET_SCHEDULER_cancel (s->timeout_task); |
540 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 540 | s->timeout_task = NULL; |
541 | s->timeout = GNUNET_TIME_UNIT_ZERO_ABS; | 541 | s->timeout = GNUNET_TIME_UNIT_ZERO_ABS; |
542 | } | 542 | } |
543 | if (GNUNET_SCHEDULER_NO_TASK != s->recv_wakeup_task) | 543 | if (NULL != s->recv_wakeup_task) |
544 | { | 544 | { |
545 | GNUNET_SCHEDULER_cancel (s->recv_wakeup_task); | 545 | GNUNET_SCHEDULER_cancel (s->recv_wakeup_task); |
546 | s->recv_wakeup_task = GNUNET_SCHEDULER_NO_TASK; | 546 | s->recv_wakeup_task = NULL; |
547 | if (NULL != s->server_recv) | 547 | if (NULL != s->server_recv) |
548 | MHD_resume_connection (s->server_recv->mhd_conn); | 548 | MHD_resume_connection (s->server_recv->mhd_conn); |
549 | } | 549 | } |
@@ -649,7 +649,7 @@ server_session_timeout (void *cls, | |||
649 | struct Session *s = cls; | 649 | struct Session *s = cls; |
650 | struct GNUNET_TIME_Relative left; | 650 | struct GNUNET_TIME_Relative left; |
651 | 651 | ||
652 | s->timeout_task = GNUNET_SCHEDULER_NO_TASK; | 652 | s->timeout_task = NULL; |
653 | left = GNUNET_TIME_absolute_get_remaining (s->timeout); | 653 | left = GNUNET_TIME_absolute_get_remaining (s->timeout); |
654 | if (0 != left.rel_value_us) | 654 | if (0 != left.rel_value_us) |
655 | { | 655 | { |
@@ -680,7 +680,7 @@ server_session_timeout (void *cls, | |||
680 | static void | 680 | static void |
681 | server_reschedule_session_timeout (struct Session *s) | 681 | server_reschedule_session_timeout (struct Session *s) |
682 | { | 682 | { |
683 | GNUNET_assert (GNUNET_SCHEDULER_NO_TASK != s->timeout_task); | 683 | GNUNET_assert (NULL != s->timeout_task); |
684 | s->timeout = GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT); | 684 | s->timeout = GNUNET_TIME_relative_to_absolute (GNUNET_CONSTANTS_IDLE_CONNECTION_TIMEOUT); |
685 | } | 685 | } |
686 | 686 | ||
@@ -917,7 +917,7 @@ server_v4_run (void *cls, | |||
917 | { | 917 | { |
918 | struct HTTP_Server_Plugin *plugin = cls; | 918 | struct HTTP_Server_Plugin *plugin = cls; |
919 | 919 | ||
920 | plugin->server_v4_task = GNUNET_SCHEDULER_NO_TASK; | 920 | plugin->server_v4_task = NULL; |
921 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 921 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
922 | return; | 922 | return; |
923 | plugin->server_v4_immediately = GNUNET_NO; | 923 | plugin->server_v4_immediately = GNUNET_NO; |
@@ -939,7 +939,7 @@ server_v6_run (void *cls, | |||
939 | { | 939 | { |
940 | struct HTTP_Server_Plugin *plugin = cls; | 940 | struct HTTP_Server_Plugin *plugin = cls; |
941 | 941 | ||
942 | plugin->server_v6_task = GNUNET_SCHEDULER_NO_TASK; | 942 | plugin->server_v6_task = NULL; |
943 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 943 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
944 | return; | 944 | return; |
945 | plugin->server_v6_immediately = GNUNET_NO; | 945 | plugin->server_v6_immediately = GNUNET_NO; |
@@ -957,12 +957,12 @@ server_v6_run (void *cls, | |||
957 | * @param now schedule now | 957 | * @param now schedule now |
958 | * @return gnunet task identifier | 958 | * @return gnunet task identifier |
959 | */ | 959 | */ |
960 | static GNUNET_SCHEDULER_TaskIdentifier | 960 | static struct GNUNET_SCHEDULER_Task * |
961 | server_schedule (struct HTTP_Server_Plugin *plugin, | 961 | server_schedule (struct HTTP_Server_Plugin *plugin, |
962 | struct MHD_Daemon *daemon_handle, | 962 | struct MHD_Daemon *daemon_handle, |
963 | int now) | 963 | int now) |
964 | { | 964 | { |
965 | GNUNET_SCHEDULER_TaskIdentifier ret; | 965 | struct GNUNET_SCHEDULER_Task * ret; |
966 | fd_set rs; | 966 | fd_set rs; |
967 | fd_set ws; | 967 | fd_set ws; |
968 | fd_set es; | 968 | fd_set es; |
@@ -975,9 +975,9 @@ server_schedule (struct HTTP_Server_Plugin *plugin, | |||
975 | struct GNUNET_TIME_Relative tv; | 975 | struct GNUNET_TIME_Relative tv; |
976 | 976 | ||
977 | if (GNUNET_YES == plugin->in_shutdown) | 977 | if (GNUNET_YES == plugin->in_shutdown) |
978 | return GNUNET_SCHEDULER_NO_TASK; | 978 | return NULL; |
979 | 979 | ||
980 | ret = GNUNET_SCHEDULER_NO_TASK; | 980 | ret = NULL; |
981 | FD_ZERO (&rs); | 981 | FD_ZERO (&rs); |
982 | FD_ZERO (&ws); | 982 | FD_ZERO (&ws); |
983 | FD_ZERO (&es); | 983 | FD_ZERO (&es); |
@@ -1015,10 +1015,10 @@ server_schedule (struct HTTP_Server_Plugin *plugin, | |||
1015 | 1015 | ||
1016 | if (daemon_handle == plugin->server_v4) | 1016 | if (daemon_handle == plugin->server_v4) |
1017 | { | 1017 | { |
1018 | if (plugin->server_v4_task != GNUNET_SCHEDULER_NO_TASK) | 1018 | if (plugin->server_v4_task != NULL) |
1019 | { | 1019 | { |
1020 | GNUNET_SCHEDULER_cancel (plugin->server_v4_task); | 1020 | GNUNET_SCHEDULER_cancel (plugin->server_v4_task); |
1021 | plugin->server_v4_task = GNUNET_SCHEDULER_NO_TASK; | 1021 | plugin->server_v4_task = NULL; |
1022 | } | 1022 | } |
1023 | #if 0 | 1023 | #if 0 |
1024 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1024 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
@@ -1032,10 +1032,10 @@ server_schedule (struct HTTP_Server_Plugin *plugin, | |||
1032 | } | 1032 | } |
1033 | if (daemon_handle == plugin->server_v6) | 1033 | if (daemon_handle == plugin->server_v6) |
1034 | { | 1034 | { |
1035 | if (plugin->server_v6_task != GNUNET_SCHEDULER_NO_TASK) | 1035 | if (plugin->server_v6_task != NULL) |
1036 | { | 1036 | { |
1037 | GNUNET_SCHEDULER_cancel (plugin->server_v6_task); | 1037 | GNUNET_SCHEDULER_cancel (plugin->server_v6_task); |
1038 | plugin->server_v6_task = GNUNET_SCHEDULER_NO_TASK; | 1038 | plugin->server_v6_task = NULL; |
1039 | } | 1039 | } |
1040 | #if 0 | 1040 | #if 0 |
1041 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1041 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
@@ -1073,10 +1073,10 @@ server_reschedule (struct HTTP_Server_Plugin *plugin, | |||
1073 | if (GNUNET_YES == now) | 1073 | if (GNUNET_YES == now) |
1074 | plugin->server_v4_immediately = GNUNET_YES; | 1074 | plugin->server_v4_immediately = GNUNET_YES; |
1075 | 1075 | ||
1076 | if (plugin->server_v4_task != GNUNET_SCHEDULER_NO_TASK) | 1076 | if (plugin->server_v4_task != NULL) |
1077 | { | 1077 | { |
1078 | GNUNET_SCHEDULER_cancel (plugin->server_v4_task); | 1078 | GNUNET_SCHEDULER_cancel (plugin->server_v4_task); |
1079 | plugin->server_v4_task = GNUNET_SCHEDULER_NO_TASK; | 1079 | plugin->server_v4_task = NULL; |
1080 | } | 1080 | } |
1081 | plugin->server_v4_task = server_schedule (plugin, plugin->server_v4, now); | 1081 | plugin->server_v4_task = server_schedule (plugin, plugin->server_v4, now); |
1082 | } | 1082 | } |
@@ -1089,10 +1089,10 @@ server_reschedule (struct HTTP_Server_Plugin *plugin, | |||
1089 | if (GNUNET_YES == now) | 1089 | if (GNUNET_YES == now) |
1090 | plugin->server_v6_immediately = GNUNET_YES; | 1090 | plugin->server_v6_immediately = GNUNET_YES; |
1091 | 1091 | ||
1092 | if (plugin->server_v6_task != GNUNET_SCHEDULER_NO_TASK) | 1092 | if (plugin->server_v6_task != NULL) |
1093 | { | 1093 | { |
1094 | GNUNET_SCHEDULER_cancel (plugin->server_v6_task); | 1094 | GNUNET_SCHEDULER_cancel (plugin->server_v6_task); |
1095 | plugin->server_v6_task = GNUNET_SCHEDULER_NO_TASK; | 1095 | plugin->server_v6_task = NULL; |
1096 | } | 1096 | } |
1097 | plugin->server_v6_task = server_schedule (plugin, plugin->server_v6, now); | 1097 | plugin->server_v6_task = server_schedule (plugin, plugin->server_v6, now); |
1098 | } | 1098 | } |
@@ -1895,7 +1895,7 @@ server_access_cb (void *cls, | |||
1895 | s, sc, GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES)); | 1895 | s, sc, GNUNET_STRINGS_relative_time_to_string (delay, GNUNET_YES)); |
1896 | GNUNET_assert(s->server_recv->mhd_conn == mhd_connection); | 1896 | GNUNET_assert(s->server_recv->mhd_conn == mhd_connection); |
1897 | MHD_suspend_connection (s->server_recv->mhd_conn); | 1897 | MHD_suspend_connection (s->server_recv->mhd_conn); |
1898 | if (GNUNET_SCHEDULER_NO_TASK == s->recv_wakeup_task) | 1898 | if (NULL == s->recv_wakeup_task) |
1899 | s->recv_wakeup_task = GNUNET_SCHEDULER_add_delayed (delay, | 1899 | s->recv_wakeup_task = GNUNET_SCHEDULER_add_delayed (delay, |
1900 | &server_wake_up, s); | 1900 | &server_wake_up, s); |
1901 | } | 1901 | } |
@@ -2881,7 +2881,7 @@ server_notify_external_hostname (void *cls, | |||
2881 | unsigned int urlen; | 2881 | unsigned int urlen; |
2882 | char *url; | 2882 | char *url; |
2883 | 2883 | ||
2884 | plugin->notify_ext_task = GNUNET_SCHEDULER_NO_TASK; | 2884 | plugin->notify_ext_task = NULL; |
2885 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) | 2885 | if (0 != (tc->reason & GNUNET_SCHEDULER_REASON_SHUTDOWN)) |
2886 | return; | 2886 | return; |
2887 | 2887 | ||
@@ -3175,10 +3175,10 @@ LIBGNUNET_PLUGIN_TRANSPORT_DONE (void *cls) | |||
3175 | _("Shutting down plugin `%s'\n"), | 3175 | _("Shutting down plugin `%s'\n"), |
3176 | plugin->name); | 3176 | plugin->name); |
3177 | 3177 | ||
3178 | if (GNUNET_SCHEDULER_NO_TASK != plugin->notify_ext_task) | 3178 | if (NULL != plugin->notify_ext_task) |
3179 | { | 3179 | { |
3180 | GNUNET_SCHEDULER_cancel (plugin->notify_ext_task); | 3180 | GNUNET_SCHEDULER_cancel (plugin->notify_ext_task); |
3181 | plugin->notify_ext_task = GNUNET_SCHEDULER_NO_TASK; | 3181 | plugin->notify_ext_task = NULL; |
3182 | } | 3182 | } |
3183 | 3183 | ||
3184 | if (NULL != plugin->ext_addr) | 3184 | if (NULL != plugin->ext_addr) |
@@ -3213,16 +3213,16 @@ LIBGNUNET_PLUGIN_TRANSPORT_DONE (void *cls) | |||
3213 | MHD_stop_daemon (plugin->server_v6); | 3213 | MHD_stop_daemon (plugin->server_v6); |
3214 | plugin->server_v6 = NULL; | 3214 | plugin->server_v6 = NULL; |
3215 | } | 3215 | } |
3216 | if (GNUNET_SCHEDULER_NO_TASK != plugin->server_v4_task) | 3216 | if (NULL != plugin->server_v4_task) |
3217 | { | 3217 | { |
3218 | GNUNET_SCHEDULER_cancel (plugin->server_v4_task); | 3218 | GNUNET_SCHEDULER_cancel (plugin->server_v4_task); |
3219 | plugin->server_v4_task = GNUNET_SCHEDULER_NO_TASK; | 3219 | plugin->server_v4_task = NULL; |
3220 | } | 3220 | } |
3221 | 3221 | ||
3222 | if (GNUNET_SCHEDULER_NO_TASK != plugin->server_v6_task) | 3222 | if (NULL != plugin->server_v6_task) |
3223 | { | 3223 | { |
3224 | GNUNET_SCHEDULER_cancel (plugin->server_v6_task); | 3224 | GNUNET_SCHEDULER_cancel (plugin->server_v6_task); |
3225 | plugin->server_v6_task = GNUNET_SCHEDULER_NO_TASK; | 3225 | plugin->server_v6_task = NULL; |
3226 | } | 3226 | } |
3227 | #if BUILD_HTTPS | 3227 | #if BUILD_HTTPS |
3228 | GNUNET_free_non_null (plugin->crypto_init); | 3228 | GNUNET_free_non_null (plugin->crypto_init); |
@@ -3309,7 +3309,7 @@ http_server_plugin_update_inbound_delay (void *cls, | |||
3309 | "New inbound delay %s\n", | 3309 | "New inbound delay %s\n", |
3310 | GNUNET_STRINGS_relative_time_to_string (delay, | 3310 | GNUNET_STRINGS_relative_time_to_string (delay, |
3311 | GNUNET_NO)); | 3311 | GNUNET_NO)); |
3312 | if (GNUNET_SCHEDULER_NO_TASK != session->recv_wakeup_task) | 3312 | if (NULL != session->recv_wakeup_task) |
3313 | { | 3313 | { |
3314 | GNUNET_SCHEDULER_cancel (session->recv_wakeup_task); | 3314 | GNUNET_SCHEDULER_cancel (session->recv_wakeup_task); |
3315 | session->recv_wakeup_task | 3315 | session->recv_wakeup_task |