diff options
| author | lishu <[email protected]> | 2019-12-19 15:32:08 +0800 |
|---|---|---|
| committer | lishu <[email protected]> | 2019-12-19 15:32:08 +0800 |
| commit | 6b6d519715a8cf397bec259f7dbebb3744a1e530 (patch) | |
| tree | b221d8edfae99661c94a54f2fe554475731bcc05 | |
| parent | 68fe0ff1780191b345581c30be8d5b1465ae6d04 (diff) | |
| -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 |