GithubStar/neuron
1
0
Fork 0
mirror of https://github.com/emqx/neuron.git synced 2026-10-28 05:56:39 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #423 from fengzeroz/main

Browse Source 
fix(adapter): update value based on name
This commit is contained in:
fengzeroz
2022-04-14 14:03:18 +08:00
committed by GitHub
parent d227377b79 47a31a691c
commit 0e6f4fdf1e
3 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/neuron/adapter.h
+1 -1
View File
@@ -87,7 +87,7 @@ typedef struct adapter_callbacks {
union {
struct {
int (*update)(neu_adapter_t *adapter, const char *address,
int (*update)(neu_adapter_t *adapter, const char *name,
neu_dvalue_t value);
} driver;
};
include/neuron/neu_tag.h
+3
View File
@@ -25,6 +25,9 @@ config_ **/
#include "data_expr.h"
#define NEU_TAG_NAME_SIZE 128
#define NEU_TAG_ADDRESS_SIZE 128
typedef uint32_t neu_datatag_id_t;
typedef char * neu_addr_str_t;
typedef char * neu_tag_name;
src/adapter/driver.c
+4 -5
View File
@@ -64,8 +64,7 @@ static void load_tags(neu_adapter_driver_t *driver, neu_taggrp_config_t *group,
UT_array **tags);
static void free_tags(UT_array *tags);
static int update(neu_adapter_t *adapter, const char *address,
neu_dvalue_t value)
static int update(neu_adapter_t *adapter, const char *name, neu_dvalue_t value)
{
neu_adapter_driver_t *driver = (neu_adapter_driver_t *) adapter;
uint16_t n_byte = 0;
@@ -101,9 +100,9 @@ static int update(neu_adapter_t *adapter, const char *address,
}
if (value.type == NEU_TYPE_ERROR) {
neu_driver_cache_error(driver->cache, address, 0, value.value.i32);
neu_driver_cache_error(driver->cache, name, 0, value.value.i32);
} else {
neu_driver_cache_update(driver->cache, address, 0, n_byte,
neu_driver_cache_update(driver->cache, name, 0, n_byte,
value.value.bytes);
}
return 0;
@@ -375,7 +374,7 @@ static neu_data_val_t *read_group(neu_adapter_driver_t *driver,
continue;
}
if (neu_driver_cache_get(driver->cache, tag->addr_str, &value) != 0) {
if (neu_driver_cache_get(driver->cache, tag->name, &value) != 0) {
error = NEU_ERR_TAG_NOT_EXIST;
neu_datatag_pack_add(val, index, NEU_DTYPE_ERRORCODE, *id,
(void *) &error);