From 7778ab95935b7466177c4ba644ec1f04228df0ca Mon Sep 17 00:00:00 2001 From: fengzero Date: Mon, 19 Jan 2026 06:23:28 +0000 Subject: [PATCH] write tag log --- src/adapter/driver/driver.c | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/src/adapter/driver/driver.c b/src/adapter/driver/driver.c index 9c0e8a59..7b8a94d1 100644 --- a/src/adapter/driver/driver.c +++ b/src/adapter/driver/driver.c @@ -1255,6 +1255,8 @@ int neu_adapter_driver_write_tags(neu_adapter_driver_t *driver, group_t *g = find_group(driver, cmd->group); if (g == NULL) { + nlog_warn("driver write tags group not exist, driver: %s, group: %s", + driver->adapter.name, cmd->group); driver->adapter.cb_funs.driver.write_response(&driver->adapter, req, NEU_ERR_GROUP_NOT_EXIST); return NEU_ERR_GROUP_NOT_EXIST; @@ -1275,6 +1277,9 @@ int neu_adapter_driver_write_tags(neu_adapter_driver_t *driver, cmd->tags[i].value.value.d64, cmd->tags[i].value.type, tag->decimal); } else { + nlog_warn("driver write tags not exist, driver: %s, group: %s, " + "tag: %s", + driver->adapter.name, cmd->group, cmd->tags[i].tag); value_check = NEU_ERR_TAG_NOT_EXIST; } @@ -1308,6 +1313,8 @@ int neu_adapter_driver_write_tags(neu_adapter_driver_t *driver, } if (value_err != NEU_ERR_SUCCESS) { + nlog_warn("driver write tags value error(%d), driver: %s, group: %s", + value_err, driver->adapter.name, cmd->group); driver->adapter.cb_funs.driver.write_response(&driver->adapter, req, value_err); utarray_foreach(tags, neu_plugin_tag_value_t *, tv) @@ -1321,6 +1328,9 @@ int neu_adapter_driver_write_tags(neu_adapter_driver_t *driver, } if (utarray_len(tags) != (unsigned int) cmd->n_tag) { + nlog_warn("driver write tags some tag not exist, driver: %s, group: " + "%s", + driver->adapter.name, cmd->group); driver->adapter.cb_funs.driver.write_response(&driver->adapter, req, NEU_ERR_TAG_NOT_EXIST); utarray_foreach(tags, neu_plugin_tag_value_t *, tv) @@ -1480,6 +1490,8 @@ int neu_adapter_driver_write_tag(neu_adapter_driver_t *driver, group_t * g = find_group(driver, cmd->group); if (g == NULL) { + nlog_warn("driver write tag group not exist, driver: %s, group: %s", + driver->adapter.name, cmd->group); driver->adapter.cb_funs.driver.write_response(&driver->adapter, req, NEU_ERR_GROUP_NOT_EXIST); return NEU_ERR_GROUP_NOT_EXIST; @@ -1487,11 +1499,16 @@ int neu_adapter_driver_write_tag(neu_adapter_driver_t *driver, neu_datatag_t *tag = neu_group_find_tag(g->group, cmd->tag); if (tag == NULL) { + nlog_warn("driver write tag not exist, driver: %s, group: %s, tag: %s", + driver->adapter.name, cmd->group, cmd->tag); driver->adapter.cb_funs.driver.write_response(&driver->adapter, req, NEU_ERR_TAG_NOT_EXIST); return NEU_ERR_TAG_NOT_EXIST; } else { if ((tag->attribute & NEU_ATTRIBUTE_WRITE) != NEU_ATTRIBUTE_WRITE) { + nlog_warn("driver write tag not allow write, driver: %s, group: " + "%s, tag: %s", + driver->adapter.name, cmd->group, cmd->tag); driver->adapter.cb_funs.driver.write_response( &driver->adapter, req, NEU_ERR_PLUGIN_TAG_NOT_ALLOW_WRITE); neu_tag_free(tag); @@ -1503,6 +1520,9 @@ int neu_adapter_driver_write_tag(neu_adapter_driver_t *driver, cmd->value.type, tag->decimal); if (value_check != NEU_ERR_SUCCESS) { + nlog_warn("driver write tag value error(%d), driver: %s, group: " + "%s, tag: %s", + value_check, driver->adapter.name, cmd->group, cmd->tag); driver->adapter.cb_funs.driver.write_response(&driver->adapter, req, value_check); neu_tag_free(tag);