mirror of
https://github.com/emqx/neuron.git
synced 2026-10-16 20:30:39 +08:00
chore(log): modify log level
This commit is contained in:
@@ -9,5 +9,5 @@ file_format = "%d [%V] %f:%L %m%n"
|
|||||||
|
|
||||||
[rules]
|
[rules]
|
||||||
|
|
||||||
*.* "./logs/%c.log", 10MB * 3 ~ "./logs/%c.#2s.log"; file_format
|
*.* "./logs/%c.log", 100MB * 10 ~ "./logs/%c.#2s.log"; file_format
|
||||||
*.* >stdout; stdout_format
|
*.* >stdout; stdout_format
|
||||||
|
|||||||
@@ -229,7 +229,7 @@ static int ekuiper_plugin_request(neu_plugin_t * plugin,
|
|||||||
{
|
{
|
||||||
bool disconnected = false;
|
bool disconnected = false;
|
||||||
|
|
||||||
plog_info(plugin, "handling request type: %d", header->type);
|
plog_debug(plugin, "handling request type: %d", header->type);
|
||||||
|
|
||||||
nng_mtx_lock(plugin->mtx);
|
nng_mtx_lock(plugin->mtx);
|
||||||
disconnected =
|
disconnected =
|
||||||
|
|||||||
+1
-1
@@ -9,4 +9,4 @@ simple = "%d [%V] %f:%L %m%n"
|
|||||||
|
|
||||||
[rules]
|
[rules]
|
||||||
|
|
||||||
*.INFO "/var/log/neuron/%c.log", 10MB * 3 ~ "/var/log/neuron/%c-%d(%Y%m%d).#2s.log"; simple
|
*.INFO "/var/log/neuron/%c.log", 100MB * 10 ~ "/var/log/neuron/%c-%d(%Y%m%d).#2s.log"; simple
|
||||||
|
|||||||
@@ -371,13 +371,8 @@ static int adapter_loop(enum neu_event_io_type type, int fd, void *usr_data)
|
|||||||
|
|
||||||
nng_recvmsg(adapter->sock, &msg, 0);
|
nng_recvmsg(adapter->sock, &msg, 0);
|
||||||
header = (neu_reqresp_head_t *) nng_msg_body(msg);
|
header = (neu_reqresp_head_t *) nng_msg_body(msg);
|
||||||
if (header->type == NEU_REQRESP_NODES_STATE) {
|
nlog_debug("adapter(%s) recv msg from: %s, type: %s", adapter->name,
|
||||||
nlog_debug("adapter(%s) recv msg from: %s, type: %s", adapter->name,
|
header->sender, neu_reqresp_type_string(header->type));
|
||||||
header->sender, neu_reqresp_type_string(header->type));
|
|
||||||
} else {
|
|
||||||
nlog_info("adapter(%s) recv msg from: %s, type: %s", adapter->name,
|
|
||||||
header->sender, neu_reqresp_type_string(header->type));
|
|
||||||
}
|
|
||||||
|
|
||||||
switch (header->type) {
|
switch (header->type) {
|
||||||
case NEU_RESP_GET_DRIVER_GROUP:
|
case NEU_RESP_GET_DRIVER_GROUP:
|
||||||
|
|||||||
@@ -846,8 +846,8 @@ static int read_callback(void *usr_data)
|
|||||||
group->driver->adapter.plugin, &group->grp);
|
group->driver->adapter.plugin, &group->grp);
|
||||||
|
|
||||||
spend = global_timestamp - spend;
|
spend = global_timestamp - spend;
|
||||||
nlog_info("%s-%s timer: %" PRId64, group->driver->adapter.name,
|
nlog_debug("%s-%s timer: %" PRId64, group->driver->adapter.name,
|
||||||
group->name, spend);
|
group->name, spend);
|
||||||
|
|
||||||
neu_adapter_update_group_metric(&group->driver->adapter, group->name,
|
neu_adapter_update_group_metric(&group->driver->adapter, group->name,
|
||||||
NEU_METRIC_GROUP_LAST_TIMER_MS, spend);
|
NEU_METRIC_GROUP_LAST_TIMER_MS, spend);
|
||||||
|
|||||||
+4
-4
@@ -226,8 +226,8 @@ static int manager_loop(enum neu_event_io_type type, int fd, void *usr_data)
|
|||||||
|
|
||||||
header = (neu_reqresp_head_t *) nng_msg_body(msg);
|
header = (neu_reqresp_head_t *) nng_msg_body(msg);
|
||||||
|
|
||||||
nlog_info("manager recv msg from: %s to %s, type: %s", header->sender,
|
nlog_debug("manager recv msg from: %s to %s, type: %s", header->sender,
|
||||||
header->receiver, neu_reqresp_type_string(header->type));
|
header->receiver, neu_reqresp_type_string(header->type));
|
||||||
switch (header->type) {
|
switch (header->type) {
|
||||||
case NEU_REQRESP_TRANS_DATA: {
|
case NEU_REQRESP_TRANS_DATA: {
|
||||||
neu_reqresp_trans_data_t *cmd = (neu_reqresp_trans_data_t *) &header[1];
|
neu_reqresp_trans_data_t *cmd = (neu_reqresp_trans_data_t *) &header[1];
|
||||||
@@ -658,7 +658,7 @@ inline static void forward_msg_dup(neu_manager_t *manager, nng_msg *msg,
|
|||||||
nng_msg_dup(&out_msg, msg);
|
nng_msg_dup(&out_msg, msg);
|
||||||
nng_msg_set_pipe(out_msg, pipe);
|
nng_msg_set_pipe(out_msg, pipe);
|
||||||
if (nng_sendmsg(manager->socket, out_msg, 0) == 0) {
|
if (nng_sendmsg(manager->socket, out_msg, 0) == 0) {
|
||||||
nlog_info("forward msg to pipe %d", pipe.id);
|
nlog_debug("forward msg to pipe %d", pipe.id);
|
||||||
} else {
|
} else {
|
||||||
nng_msg_free(out_msg);
|
nng_msg_free(out_msg);
|
||||||
}
|
}
|
||||||
@@ -673,7 +673,7 @@ inline static void forward_msg(neu_manager_t *manager, nng_msg *msg,
|
|||||||
nng_msg_dup(&out_msg, msg);
|
nng_msg_dup(&out_msg, msg);
|
||||||
nng_msg_set_pipe(out_msg, pipe);
|
nng_msg_set_pipe(out_msg, pipe);
|
||||||
if (nng_sendmsg(manager->socket, out_msg, 0) == 0) {
|
if (nng_sendmsg(manager->socket, out_msg, 0) == 0) {
|
||||||
nlog_info("forward msg to %s", node);
|
nlog_debug("forward msg to %s", node);
|
||||||
} else {
|
} else {
|
||||||
nng_msg_free(out_msg);
|
nng_msg_free(out_msg);
|
||||||
}
|
}
|
||||||
|
|||||||
+1
-1
@@ -68,7 +68,7 @@ static int neuron_run(const neu_cli_args_t *args)
|
|||||||
rv = neu_persister_create(args->config_dir);
|
rv = neu_persister_create(args->config_dir);
|
||||||
assert(rv == 0);
|
assert(rv == 0);
|
||||||
|
|
||||||
zlog_notice(neuron, "neuron process, daemon: %d, version: %s (%s %s)",
|
zlog_notice(neuron, "neuron start, daemon: %d, version: %s (%s %s)",
|
||||||
args->daemonized, NEURON_VERSION,
|
args->daemonized, NEURON_VERSION,
|
||||||
NEURON_GIT_REV NEURON_GIT_DIFF, NEURON_BUILD_DATE);
|
NEURON_GIT_REV NEURON_GIT_DIFF, NEURON_BUILD_DATE);
|
||||||
g_manager = neu_manager_create();
|
g_manager = neu_manager_create();
|
||||||
|
|||||||
Reference in New Issue
Block a user