[taler-exchange] branch master updated: fix bug where suspended /keys requests eat up all sockets

[gnunet]

This is an automated email from the git hooks/post-receive script.

grothoff pushed a commit to branch master
in repository exchange.

The following commit(s) were added to refs/heads/master by this push:
     new 3721780f fix bug where suspended /keys requests eat up all sockets
3721780f is described below

commit 3721780f16f61727e0f29505a32c4aa43b53ed51
Author: Christian Grothoff <christian@grothoff.org>
AuthorDate: Wed Jul 21 16:08:50 2021 +0200

    fix bug where suspended /keys requests eat up all sockets
---
 src/exchange/taler-exchange-httpd_keys.c | 43 ++++++++++++++++++++++++++++++++
 1 file changed, 43 insertions(+)

diff --git a/src/exchange/taler-exchange-httpd_keys.c 
b/src/exchange/taler-exchange-httpd_keys.c
index fc38c7ac..b703b220 100644
--- a/src/exchange/taler-exchange-httpd_keys.c
+++ b/src/exchange/taler-exchange-httpd_keys.c
@@ -28,6 +28,13 @@
 #include "taler_exchangedb_plugin.h"
 
 
+/**
+ * How many /keys request do we hold in suspension at
+ * most at any time?
+ */
+#define SKR_LIMIT 32
+
+
 /**
  * Taler protocol version in the format CURRENT:REVISION:AGE
  * as used by GNU libtool.  See
@@ -356,6 +363,18 @@ static struct SuspendedKeysRequests *skr_head;
  */
 static struct SuspendedKeysRequests *skr_tail;
 
+/**
+ * Number of entries in the @e skr_head DLL.
+ */
+static unsigned int skr_size;
+
+/**
+ * Handle to a connection that should be force-resumed
+ * with a hard error due to @a skr_size hitting
+ * #SKR_LIMIT.
+ */
+static struct MHD_Connection *skr_connection;
+
 /**
  * For how long should a signing key be legally retained?
  * Configuration value.
@@ -423,6 +442,18 @@ suspend_request (struct MHD_Connection *connection)
   GNUNET_CONTAINER_DLL_insert (skr_head,
                                skr_tail,
                                skr);
+  skr_size++;
+  if (skr_size > SKR_LIMIT)
+  {
+    skr = skr_tail;
+    GNUNET_CONTAINER_DLL_remove (skr_head,
+                                 skr_tail,
+                                 skr);
+    skr_size--;
+    skr_connection = skr->connection;
+    MHD_resume_connection (skr->connection);
+    GNUNET_free (skr);
+  }
   GNUNET_assert (0 == pthread_mutex_unlock (&skr_mutex));
   return MHD_YES;
 }
@@ -441,6 +472,7 @@ TEH_resume_keys_requests (bool do_shutdown)
     GNUNET_CONTAINER_DLL_remove (skr_head,
                                  skr_tail,
                                  skr);
+    skr_size--;
     MHD_resume_connection (skr->connection);
     GNUNET_free (skr);
   }
@@ -2058,6 +2090,17 @@ TEH_keys_get_handler (const struct TEH_RequestHandler 
*rh,
     ksh = TEH_keys_get_state ();
     if (NULL == ksh)
     {
+      GNUNET_assert (0 == pthread_mutex_lock (&skr_mutex));
+      if ( (SKR_LIMIT == skr_size) &&
+           (connection == skr_connection) )
+      {
+        GNUNET_assert (0 == pthread_mutex_unlock (&skr_mutex));
+        return TALER_MHD_reply_with_error (connection,
+                                           MHD_HTTP_INTERNAL_SERVER_ERROR,
+                                           
TALER_EC_EXCHANGE_GENERIC_KEYS_MISSING,
+                                           "too many connections suspended on 
/keys");
+      }
+      GNUNET_assert (0 == pthread_mutex_unlock (&skr_mutex));
       return suspend_request (connection);
     }
     krd = bsearch (&last_issue_date,

-- 
To stop receiving notification emails like this one, please contact
gnunet@gnunet.org.