Changeset 1397:239ba25870d8 in freeDiameter for libfdcore/queues.c

Timestamp:

Nov 15, 2019, 7:40:37 PM (4 years ago)

Author:

Thomas Klausner <tk@giga.or.at>

Branch:

default

Phase:

public

Message:

Allow parametrizing the number of threads for routing in/out.

This is for high-load situations where freeDiameter was limited
by the corresponding queues.

File:

• libfdcore/queues.c (modified) (1 diff)

libfdcore/queues.c

@@ -45 +45 @@
 {
         TRACE_ENTRY();
-        CHECK_FCT( fd_fifo_new ( &fd_g_incoming, 20 ) );
-        CHECK_FCT( fd_fifo_new ( &fd_g_outgoing, 30 ) );
-        CHECK_FCT( fd_fifo_new ( &fd_g_local, 25 ) );
+        CHECK_FCT( fd_fifo_new ( &fd_g_incoming, fd_g_config->cnf_qin_limit ) );
+        CHECK_FCT( fd_fifo_new ( &fd_g_outgoing, fd_g_config->cnf_qout_limit ) );
+        CHECK_FCT( fd_fifo_new ( &fd_g_local,    fd_g_config->cnf_qlocal_limit ) );
+        return 0;
+}
+
+/* Resize according to values given in configuration file */
+int fd_queues_init_after_conf(void)
+{
+        TRACE_ENTRY();
+        CHECK_FCT( fd_fifo_set_max ( fd_g_incoming, fd_g_config->cnf_qin_limit ) );
+        CHECK_FCT( fd_fifo_set_max ( fd_g_outgoing, fd_g_config->cnf_qout_limit ) );
+        CHECK_FCT( fd_fifo_set_max ( fd_g_local,    fd_g_config->cnf_qlocal_limit ) );
         return 0;
 }