GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-17 04:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1454 from hxy7yx/v2.4

Browse Source 
(file):add error code for reading empty files
This commit is contained in:
fengzeroz
2023-08-15 15:16:13 +08:00
committed by GitHub
parent ccb6a62366 0bf8b7903f
commit 3c7709f4ae
2 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/neuron/errcodes.h
+1
View File
@@ -137,6 +137,7 @@ typedef enum {
NEU_ERR_FILE_OPEN_FAILURE = 4101,
NEU_ERR_FILE_READ_FAILURE = 4102,
NEU_ERR_FILE_WRITE_FAILURE = 4103,
NEU_ERR_FILE_READ_NULL = 4104,
NEU_ERR_PLUGIN_ERROR_START = 10000,
NEU_ERR_PLUGIN_ERROR_END = 20000,
plugins/file/file_req.c
+10 -4
View File
@@ -84,10 +84,16 @@ int file_group_timer(neu_plugin_t *plugin, neu_plugin_group_t *group)
fseek(f, 0, SEEK_SET);
int ret = fread(buf, sizeof(char), length, f);
if (ret == 0) {
nlog_warn("read file failed:%s", tag->address);
dvalue.type = NEU_TYPE_ERROR;
dvalue.value.i32 = NEU_ERR_FILE_READ_FAILURE;
if (feof(f)) {
nlog_warn("file is empty:%s", tag->address);
dvalue.type = NEU_TYPE_ERROR;
dvalue.value.i32 = NEU_ERR_FILE_READ_NULL;
} else if (ferror(f)) {
nlog_warn("read file failed: %s", tag->address);
clearerr(f);
dvalue.type = NEU_TYPE_ERROR;
dvalue.value.i32 = NEU_ERR_FILE_READ_FAILURE;
}
fclose(f);
goto dvalue_result;
} else if (ret >= NEU_VALUE_SIZE) {