aboutsummaryrefslogtreecommitdiff
path: root/src/transport/plugin_transport_http_server.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/transport/plugin_transport_http_server.c')
-rw-r--r--src/transport/plugin_transport_http_server.c70
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,
680static void 680static void
681server_reschedule_session_timeout (struct Session *s) 681server_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 */
960static GNUNET_SCHEDULER_TaskIdentifier 960static struct GNUNET_SCHEDULER_Task *
961server_schedule (struct HTTP_Server_Plugin *plugin, 961server_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