+server_delete_session (struct GNUNET_ATS_Session *s)
+{
+ struct HTTP_Server_Plugin *plugin = s->plugin;
+ struct HTTP_Message *msg;
+
+ if (NULL != s->timeout_task)
+ {
+ GNUNET_SCHEDULER_cancel (s->timeout_task);
+ s->timeout_task = NULL;
+ s->timeout = GNUNET_TIME_UNIT_ZERO_ABS;
+ }
+ if (NULL != s->recv_wakeup_task)
+ {
+ GNUNET_SCHEDULER_cancel (s->recv_wakeup_task);
+ s->recv_wakeup_task = NULL;
+ if (NULL != s->server_recv)
+ {
+ GNUNET_assert (s->server_recv->suspended);
+ s->server_recv->suspended = false;
+ MHD_resume_connection (s->server_recv->mhd_conn);
+ }
+ }
+ GNUNET_assert (GNUNET_OK ==
+ GNUNET_CONTAINER_multipeermap_remove (plugin->sessions,
+ &s->target,
+ s));
+ while (NULL != (msg = s->msg_head))
+ {
+ GNUNET_CONTAINER_DLL_remove (s->msg_head,
+ s->msg_tail,
+ msg);
+ if (NULL != msg->transmit_cont)
+ msg->transmit_cont (msg->transmit_cont_cls,
+ &s->target,
+ GNUNET_SYSERR,
+ msg->size,
+ msg->pos + msg->overhead);
+ GNUNET_assert (s->msgs_in_queue > 0);
+ s->msgs_in_queue--;
+ GNUNET_assert (s->bytes_in_queue >= msg->size);
+ s->bytes_in_queue -= msg->size;
+ GNUNET_free (msg);
+ }
+
+ GNUNET_assert (0 == s->msgs_in_queue);
+ GNUNET_assert (0 == s->bytes_in_queue);
+
+ if (NULL != s->server_send)
+ {
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Server: %p / %p Terminating inbound PUT session to peer `%s'\n",
+ s, s->server_send,
+ GNUNET_i2s (&s->target));
+ s->server_send->session = NULL;
+ MHD_set_connection_option (s->server_send->mhd_conn,
+ MHD_CONNECTION_OPTION_TIMEOUT,
+ 1 /* 0 = no timeout, so this is MIN */);
+ if (s->server_send->suspended)
+ {
+ s->server_send->suspended = false;
+ MHD_resume_connection (s->server_send->mhd_conn);
+ }
+ server_reschedule (plugin,
+ s->server_send->mhd_daemon,
+ GNUNET_YES);
+ }
+
+ if (NULL != s->server_recv)
+ {
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Server: %p / %p Terminating inbound GET session to peer `%s'\n",
+ s, s->server_recv, GNUNET_i2s (&s->target));
+ s->server_recv->session = NULL;
+ MHD_set_connection_option (s->server_recv->mhd_conn,
+ MHD_CONNECTION_OPTION_TIMEOUT,
+ 1 /* 0 = no timeout, so this is MIN */);
+ server_reschedule (plugin,
+ s->server_recv->mhd_daemon,
+ GNUNET_YES);
+ }
+ notify_session_monitor (plugin,
+ s,
+ GNUNET_TRANSPORT_SS_DONE);
+ if (GNUNET_YES == s->known_to_service)
+ {
+ plugin->env->session_end (plugin->env->cls,
+ s->address,
+ s);
+ s->known_to_service = GNUNET_NO;
+ }
+ if (NULL != s->msg_tk)
+ {
+ GNUNET_MST_destroy (s->msg_tk);
+ s->msg_tk = NULL;
+ }
+ GNUNET_HELLO_address_free (s->address);
+ LOG (GNUNET_ERROR_TYPE_DEBUG,
+ "Session %p destroyed\n",
+ s);
+ GNUNET_free (s);
+}