comparison libfdcore/config.c @ 1397:239ba25870d8

Allow parametrizing the number of threads for routing in/out. This is for high-load situations where freeDiameter was limited by the corresponding queues.
author Thomas Klausner <tk@giga.or.at>
date Fri, 15 Nov 2019 11:40:37 +0100
parents 188c82b6690b
children 6cc290653ef6
comparison
equal deleted inserted replaced
1396:188c82b6690b 1397:239ba25870d8
59 fd_g_config->cnf_port_tls = DIAMETER_SECURE_PORT; 59 fd_g_config->cnf_port_tls = DIAMETER_SECURE_PORT;
60 fd_g_config->cnf_sctp_str = 30; 60 fd_g_config->cnf_sctp_str = 30;
61 fd_g_config->cnf_thr_srv = 5; 61 fd_g_config->cnf_thr_srv = 5;
62 fd_g_config->cnf_processing_peers_minimum = 0; 62 fd_g_config->cnf_processing_peers_minimum = 0;
63 fd_g_config->cnf_dispthr = 4; 63 fd_g_config->cnf_dispthr = 4;
64 fd_g_config->cnf_rtinthr = 1;
65 fd_g_config->cnf_rtoutthr = 1;
66 fd_g_config->cnf_qin_limit = 20;
67 fd_g_config->cnf_qout_limit = 30;
68 fd_g_config->cnf_qlocal_limit = 25;
64 fd_list_init(&fd_g_config->cnf_endpoints, NULL); 69 fd_list_init(&fd_g_config->cnf_endpoints, NULL);
65 fd_list_init(&fd_g_config->cnf_apps, NULL); 70 fd_list_init(&fd_g_config->cnf_apps, NULL);
66 #ifdef DISABLE_SCTP 71 #ifdef DISABLE_SCTP
67 fd_g_config->cnf_flags.no_sctp = 1; 72 fd_g_config->cnf_flags.no_sctp = 1;
68 #endif /* DISABLE_SCTP */ 73 #endif /* DISABLE_SCTP */
101 } 106 }
102 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of SCTP streams . : %hu\n", fd_g_config->cnf_sctp_str), return NULL); 107 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of SCTP streams . : %hu\n", fd_g_config->cnf_sctp_str), return NULL);
103 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of clients thr .. : %d\n", fd_g_config->cnf_thr_srv), return NULL); 108 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of clients thr .. : %d\n", fd_g_config->cnf_thr_srv), return NULL);
104 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of app threads .. : %hu\n", fd_g_config->cnf_dispthr), return NULL); 109 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of app threads .. : %hu\n", fd_g_config->cnf_dispthr), return NULL);
105 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Minimal processing peers : %hu\n", fd_g_config->cnf_processing_peers_minimum), return NULL); 110 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Minimal processing peers : %hu\n", fd_g_config->cnf_processing_peers_minimum), return NULL);
111 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of rtin threads . : %hu\n", fd_g_config->cnf_rtinthr), return NULL);
112 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Number of rtout threads : %hu\n", fd_g_config->cnf_rtoutthr), return NULL);
113 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Incoming queue limit : %hu\n", fd_g_config->cnf_qin_limit), return NULL);
114 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Outgoing queue limit : %hu\n", fd_g_config->cnf_qout_limit), return NULL);
115 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Local queue limit : %hu\n", fd_g_config->cnf_qlocal_limit), return NULL);
106 if (FD_IS_LIST_EMPTY(&fd_g_config->cnf_endpoints)) { 116 if (FD_IS_LIST_EMPTY(&fd_g_config->cnf_endpoints)) {
107 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Local endpoints ........ : Default (use all available)\n"), return NULL); 117 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Local endpoints ........ : Default (use all available)\n"), return NULL);
108 } else { 118 } else {
109 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Local endpoints ........ : "), return NULL); 119 CHECK_MALLOC_DO( fd_dump_extend( FD_DUMP_STD_PARAMS, " Local endpoints ........ : "), return NULL);
110 CHECK_MALLOC_DO( fd_ep_dump( FD_DUMP_STD_PARAMS, 0, 0, &fd_g_config->cnf_endpoints ), return NULL); 120 CHECK_MALLOC_DO( fd_ep_dump( FD_DUMP_STD_PARAMS, 0, 0, &fd_g_config->cnf_endpoints ), return NULL);
"Welcome to our mercurial repository"