Changeset 1397:239ba25870d8 in freeDiameter for libfdcore/fdd.y

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/fdd.y (modified) (3 diffs)

libfdcore/fdd.y

@@ -108 +108 @@
 %token          SCTPSTREAMS
 %token          APPSERVTHREADS
+%token          ROUTINGINTHREADS
+%token          ROUTINGOUTTHREADS
+%token          QINLIMIT
+%token          QOUTLIMIT
+%token          QLOCALLIMIT
 %token          LISTENON
 %token          THRPERSRV
@@ -148 +153 @@
                         | conffile norelay
                         | conffile appservthreads
+                        | conffile routinginthreads
+                        | conffile routingoutthreads
+                        | conffile qinlimit
+                        | conffile qoutlimit
+                        | conffile qlocallimit
                         | conffile noip
                         | conffile noip6
@@ -307 +317 @@
                                         { yyerror (&yylloc, conf, "Invalid value"); YYERROR; } );
                                 conf->cnf_dispthr = (uint16_t)$3;
+                        }
+                        ;
+
+routinginthreads:               ROUTINGINTHREADS '=' INTEGER ';'
+                        {
+                                CHECK_PARAMS_DO( ($3 > 0) && ($3 < 256),
+                                        { yyerror (&yylloc, conf, "Invalid value"); YYERROR; } );
+                                conf->cnf_rtinthr = (uint16_t)$3;
+                        }
+                        ;
+
+routingoutthreads:              ROUTINGOUTTHREADS '=' INTEGER ';'
+                        {
+                                CHECK_PARAMS_DO( ($3 > 0) && ($3 < 256),
+                                        { yyerror (&yylloc, conf, "Invalid value"); YYERROR; } );
+                                conf->cnf_rtoutthr = (uint16_t)$3;
+                        }
+                        ;
+
+qinlimit:               QINLIMIT '=' INTEGER ';'
+                        {
+                                CHECK_PARAMS_DO( ($3 >= 0),
+                                        { yyerror (&yylloc, conf, "Invalid value"); YYERROR; } );
+                                conf->cnf_qin_limit = $3;
+                        }
+                        ;
+
+qoutlimit:              QOUTLIMIT '=' INTEGER ';'
+                        {
+                                CHECK_PARAMS_DO( ($3 >= 0),
+                                        { yyerror (&yylloc, conf, "Invalid value"); YYERROR; } );
+                                conf->cnf_qout_limit = $3;
+                        }
+                        ;
+
+qlocallimit:            QLOCALLIMIT '=' INTEGER ';'
+                        {
+                                CHECK_PARAMS_DO( ($3 >= 0),
+                                        { yyerror (&yylloc, conf, "Invalid value"); YYERROR; } );
+                                conf->cnf_qlocal_limit = $3;
                         }
                         ;