diff --git a/dev.conf b/dev.conf index c627f81e..117e18fd 100644 --- a/dev.conf +++ b/dev.conf @@ -9,5 +9,5 @@ file_format = "%d [%V] %f:%L %m%n" [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 diff --git a/plugins/ekuiper/plugin_ekuiper.c b/plugins/ekuiper/plugin_ekuiper.c index a505e09e..93592be1 100644 --- a/plugins/ekuiper/plugin_ekuiper.c +++ b/plugins/ekuiper/plugin_ekuiper.c @@ -229,7 +229,7 @@ static int ekuiper_plugin_request(neu_plugin_t * plugin, { 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); disconnected = diff --git a/sdk-zlog.conf b/sdk-zlog.conf index 933e90fe..8c7441ec 100644 --- a/sdk-zlog.conf +++ b/sdk-zlog.conf @@ -9,4 +9,4 @@ simple = "%d [%V] %f:%L %m%n" [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 diff --git a/src/adapter/adapter.c b/src/adapter/adapter.c index 4bd97951..fcf88ae0 100644 --- a/src/adapter/adapter.c +++ b/src/adapter/adapter.c @@ -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); 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, - 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)); - } + nlog_debug("adapter(%s) recv msg from: %s, type: %s", adapter->name, + header->sender, neu_reqresp_type_string(header->type)); switch (header->type) { case NEU_RESP_GET_DRIVER_GROUP: diff --git a/src/adapter/driver/driver.c b/src/adapter/driver/driver.c index 620526ca..39c45546 100644 --- a/src/adapter/driver/driver.c +++ b/src/adapter/driver/driver.c @@ -846,8 +846,8 @@ static int read_callback(void *usr_data) group->driver->adapter.plugin, &group->grp); spend = global_timestamp - spend; - nlog_info("%s-%s timer: %" PRId64, group->driver->adapter.name, - group->name, spend); + nlog_debug("%s-%s timer: %" PRId64, group->driver->adapter.name, + group->name, spend); neu_adapter_update_group_metric(&group->driver->adapter, group->name, NEU_METRIC_GROUP_LAST_TIMER_MS, spend); diff --git a/src/core/manager.c b/src/core/manager.c index e61f3c8c..3e2710c8 100644 --- a/src/core/manager.c +++ b/src/core/manager.c @@ -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); - nlog_info("manager recv msg from: %s to %s, type: %s", header->sender, - header->receiver, neu_reqresp_type_string(header->type)); + nlog_debug("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_TRANS_DATA: { 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_set_pipe(out_msg, pipe); 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 { 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_set_pipe(out_msg, pipe); if (nng_sendmsg(manager->socket, out_msg, 0) == 0) { - nlog_info("forward msg to %s", node); + nlog_debug("forward msg to %s", node); } else { nng_msg_free(out_msg); } diff --git a/src/main.c b/src/main.c index 5d323536..4ec7ef3d 100644 --- a/src/main.c +++ b/src/main.c @@ -68,7 +68,7 @@ static int neuron_run(const neu_cli_args_t *args) rv = neu_persister_create(args->config_dir); 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, NEURON_GIT_REV NEURON_GIT_DIFF, NEURON_BUILD_DATE); g_manager = neu_manager_create(); diff --git a/zlog.conf b/zlog.conf index 13e1a261..97b556a4 100644 --- a/zlog.conf +++ b/zlog.conf @@ -8,4 +8,4 @@ simple = "%d [%V] %f:%L %m%n" [rules] -*.* "./logs/%c.log", 10MB * 3 ~ "./logs/%c.#2s.log"; simple +*.* "./logs/%c.log", 100MB * 10 ~ "./logs/%c.#2s.log"; simple