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

Merge pull request #487 from fengzeroz/main

Browse Source 
adapter(driver): implement the write api
This commit is contained in:
fengzeroz
2022-05-16 11:24:50 +08:00
committed by GitHub
parent db31cee551 d39e222679
commit d88cb8911b
3 changed files with 56 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
include/neuron/type.h
+2
View File
@@ -26,6 +26,7 @@ extern "C" {
#include <assert.h>
#include <netinet/in.h>
#include <stdbool.h>
#include <stdint.h>
typedef enum {
@@ -48,6 +49,7 @@ typedef enum {
#define NEU_VALUE_SIZE 128
typedef union {
bool boolean;
int8_t i8;
uint8_t u8;
int16_t i16;
include/neuron/utils/protocol_buf.h
+5
View File
@@ -46,6 +46,11 @@ inline static void neu_protocol_unpack_buf_init(neu_protocol_unpack_buf_t *buf,
buf->offset = 0;
}
inline static uint16_t neu_protocol_buf_size(neu_protocol_buf_t *buf)
{
return buf->size;
}
inline static neu_protocol_unpack_buf_t *
neu_protocol_unpack_buf_new(uint16_t size)
{
src/adapter/driver/driver.c
+49 -1
View File
@@ -244,6 +244,54 @@ void neu_adapter_driver_process_msg(neu_adapter_driver_t *driver,
int_val->key, (void *) &error);
driver->adapter.cb_funs.response(&driver->adapter, &resp);
} else {
neu_dtype_e type =
neu_value_type_in_dtype(neu_dvalue_get_type(int_val->val));
switch (type) {
case NEU_DTYPE_INT8:
neu_dvalue_get_int8(int_val->val, &value.i8);
break;
case NEU_DTYPE_UINT8:
neu_dvalue_get_uint8(int_val->val, &value.u8);
break;
case NEU_DTYPE_INT16:
neu_dvalue_get_int16(int_val->val, &value.i16);
break;
case NEU_DTYPE_UINT16:
neu_dvalue_get_uint16(int_val->val, &value.u16);
break;
case NEU_DTYPE_UINT32:
neu_dvalue_get_uint32(int_val->val, &value.u32);
break;
case NEU_DTYPE_INT32:
neu_dvalue_get_int32(int_val->val, &value.i32);
break;
case NEU_DTYPE_INT64:
neu_dvalue_get_int64(int_val->val, &value.i64);
break;
case NEU_DTYPE_UINT64:
neu_dvalue_get_uint64(int_val->val, &value.u64);
break;
case NEU_DTYPE_FLOAT:
neu_dvalue_get_float(int_val->val, &value.f32);
break;
case NEU_DTYPE_DOUBLE:
neu_dvalue_get_double(int_val->val, &value.d64);
break;
case NEU_DTYPE_BIT:
neu_dvalue_get_bit(int_val->val, &value.u8);
break;
case NEU_DTYPE_BOOL:
neu_dvalue_get_bool(int_val->val, &value.boolean);
break;
case NEU_DTYPE_CSTR:
neu_dvalue_get_ref_cstr(int_val->val, (char **) &value.str);
break;
default:
assert(1 == 0);
break;
}
driver->adapter.plugin_info.module->intf_funs->driver.write_tag(
driver->adapter.plugin_info.plugin, (void *) req, tag, value);
}
@@ -407,7 +455,7 @@ static neu_data_val_t *read_group(neu_adapter_driver_t *driver,
}
if (neu_driver_cache_get(driver->cache, tag->name, &value) != 0) {
error = NEU_ERR_TAG_NOT_EXIST;
error = NEU_ERR_PLUGIN_READ_FAILURE;
neu_datatag_pack_add(val, index, NEU_DTYPE_ERRORCODE, *id,
(void *) &error);
continue;