diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c index 7acd7026..fec35a96 100644 --- a/src/adapter/adapter.c +++ b/src/adapter/adapter.c @@ -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) { diff --git a/src/core/manager.c b/src/core/manager.c index b2270fbe..c7e1b686 100644 --- a/src/core/manager.c +++ b/src/core/manager.c @@ -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];