diff options
author | Christian Grothoff <christian@grothoff.org> | 2021-08-27 18:18:32 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2021-08-27 18:18:32 +0200 |
commit | c80eee722ed94e9c40f042f6e6404af059347f97 (patch) | |
tree | f9fe67600cd4fecd78fb0749a6f99eddc40d5a70 /src/backend | |
parent | cd44840c4258a60bd8aa8c6b3d0fa2b6b8920193 (diff) | |
download | anastasis-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.c | 11 |
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); } |