diff options
Diffstat (limited to 'src/trace_output.c')
| -rw-r--r-- | src/trace_output.c | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/trace_output.c b/src/trace_output.c index d3f48a4..19ccf2c 100644 --- a/src/trace_output.c +++ b/src/trace_output.c @@ -123,8 +123,6 @@ void * dp_trace_process_thread(void * arg) marsio_thread_init(mr_instance); - zlog_category_t * kafak_dump_logger = kafka_dump_logger_get(); - unsigned int no_pkt_recv_cnt = 0; for (unsigned int qid_index = 0;; qid_index++) { @@ -182,6 +180,7 @@ void * dp_trace_process_thread(void * arg) if (conf->kafka_dump_to_log) { + zlog_category_t * kafak_dump_logger = kafka_dump_logger_get(); kafka_dump_to_log(kafak_dump_logger, (void *)data, size); } @@ -764,11 +763,11 @@ void arp_pkt_no_ip_verify(marsio_buff_t * mr_mbuf) if (strlen(trace_buff_info.inner_src_addr_str) != 0) { - dzlog_error("arp pkt has inner src ip:", trace_buff_info.inner_src_addr_str); + dzlog_error("arp pkt has inner src ip:%s", trace_buff_info.inner_src_addr_str); } if (strlen(trace_buff_info.inner_dst_addr_str) != 0) { - dzlog_error("arp pkt has inner dst ip:", trace_buff_info.inner_dst_addr_str); + dzlog_error("arp pkt has inner dst ip:%s", trace_buff_info.inner_dst_addr_str); } } |