GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-28 14:07:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

modify metrics log level

Browse Source
This commit is contained in:
fengzero
2022-10-21 01:47:33 +00:00
parent 0b44bc56d1
commit 495a5ef3e0
2 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+6 -2
View File
@@ -333,12 +333,16 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
nng_recvmsg(adapter->sock, &msg, 0);
header = (neu_reqresp_head_t *) nng_msg_body(msg);
if (header->type == NEU_REQRESP_NODES_STATE) {
switch (header->type) {
case NEU_REQRESP_NODES_STATE:
case NEU_REQRESP_METRICS:
nlog_debug("adapter(%s) recv msg from: %s, type: %s", adapter->name,
header->sender, neu_reqresp_type_string(header->type));
} else {
break;
default:
nlog_info("adapter(%s) recv msg from: %s, type: %s", adapter->name,
header->sender, neu_reqresp_type_string(header->type));
break;
}
switch (header->type) {
src/core/manager.c
+10 -2
View File
@@ -190,8 +190,16 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
header = (neu_reqresp_head_t *) nng_msg_body(msg);
nlog_info("manager recv msg from: %s to %s, type: %s", header->sender,
header->receiver, neu_reqresp_type_string(header->type));
switch (header->type) {
case NEU_REQRESP_METRICS:
nlog_debug("manager recv msg from: %s to %s, type: %s", header->sender,
header->receiver, neu_reqresp_type_string(header->type));
break;
default:
nlog_info("manager recv msg from: %s to %s, type: %s", header->sender,
header->receiver, neu_reqresp_type_string(header->type));
break;
}
switch (header->type) {
case NEU_REQRESP_TRANS_DATA: {
neu_reqresp_trans_data_t *cmd = (neu_reqresp_trans_data_t *) &header[1];