summaryrefslogtreecommitdiff
path: root/src/backend
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2021-08-27 18:18:32 +0200
committerChristian Grothoff <christian@grothoff.org>2021-08-27 18:18:32 +0200
commitc80eee722ed94e9c40f042f6e6404af059347f97 (patch)
treef9fe67600cd4fecd78fb0749a6f99eddc40d5a70 /src/backend
parentcd44840c4258a60bd8aa8c6b3d0fa2b6b8920193 (diff)
downloadanastasis-c80eee722ed94e9c40f042f6e6404af059347f97.tar.gz
anastasis-c80eee722ed94e9c40f042f6e6404af059347f97.tar.bz2
anastasis-c80eee722ed94e9c40f042f6e6404af059347f97.zip
-fix IBAN notification logic
Diffstat (limited to 'src/backend')
-rw-r--r--src/backend/anastasis-httpd_truth.c11
1 files changed, 7 insertions, 4 deletions
diff --git a/src/backend/anastasis-httpd_truth.c b/src/backend/anastasis-httpd_truth.c
index 613e27f..4853e15 100644
--- a/src/backend/anastasis-httpd_truth.c
+++ b/src/backend/anastasis-httpd_truth.c
@@ -316,8 +316,8 @@ AH_truth_shutdown (void)
}
if (gc->suspended)
{
- MHD_resume_connection (gc->connection);
gc->suspended = false;
+ MHD_resume_connection (gc->connection);
}
if (NULL != gc->as)
{
@@ -576,8 +576,8 @@ proposal_cb (void *cls,
gc);
gc->in_list = false;
GNUNET_assert (gc->suspended);
- MHD_resume_connection (gc->connection);
gc->suspended = false;
+ MHD_resume_connection (gc->connection);
AH_trigger_daemon (NULL);
if (MHD_HTTP_OK != por->hr.http_status)
{
@@ -641,8 +641,8 @@ check_payment_cb (void *cls,
gc);
gc->in_list = false;
GNUNET_assert (gc->suspended);
- MHD_resume_connection (gc->connection);
gc->suspended = false;
+ MHD_resume_connection (gc->connection);
AH_trigger_daemon (NULL);
switch (hr->http_status)
@@ -895,6 +895,7 @@ run_authorization_process (struct MHD_Connection *connection,
enum ANASTASIS_AUTHORIZATION_Result ret;
enum GNUNET_DB_QueryStatus qs;
+ GNUNET_assert (! gc->suspended);
ret = gc->authorization->process (gc->as,
gc->timeout,
connection);
@@ -922,13 +923,13 @@ run_authorization_process (struct MHD_Connection *connection,
return MHD_YES;
case ANASTASIS_AUTHORIZATION_RES_SUSPENDED:
/* connection was suspended */
+ gc->suspended = true;
if (NULL == AH_to_heap)
AH_to_heap = GNUNET_CONTAINER_heap_create (
GNUNET_CONTAINER_HEAP_ORDER_MIN);
gc->hn = GNUNET_CONTAINER_heap_insert (AH_to_heap,
gc,
gc->timeout.abs_value_us);
- gc->suspended = true;
if (NULL != to_task)
{
GNUNET_SCHEDULER_cancel (to_task);
@@ -1135,6 +1136,7 @@ AH_handler_truth_get (
GNUNET_assert (NULL != gc->authorization);
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"Continuing with running the authorization process\n");
+ GNUNET_assert (! gc->suspended);
return run_authorization_process (connection,
gc);
@@ -1547,6 +1549,7 @@ AH_handler_truth_get (
GNUNET_CONTAINER_DLL_insert (gc_head,
gc_tail,
gc);
+ GNUNET_assert (! gc->suspended);
return run_authorization_process (connection,
gc);
}