diff options
Diffstat (limited to 'src/frag_monitor.c')
| -rw-r--r-- | src/frag_monitor.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/frag_monitor.c b/src/frag_monitor.c index a0ab059..f118b9b 100644 --- a/src/frag_monitor.c +++ b/src/frag_monitor.c @@ -84,7 +84,7 @@ void frag_monitor_history() frag_monitor_runtime_parameter_t g_frag_prog_para; /*sapp threadnum*/ -extern int g_iThreadNum; +static int g_iThreadNum = 1; /*av_master*/ //extern KafkaProducer* g_multi_kafka_producer; extern rd_kafka_t* g_multi_kafka_producer; @@ -1538,7 +1538,8 @@ extern "C" int FRAG_MONITOR_INIT() if(-1==read_main_conf()) { return -1; - } + } + g_iThreadNum = get_thread_count(); /*kafka*/ #if K_PROJECT |