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

Merge pull request #383 from fengzeroz/main

Browse Source 
add sender_id in write msg
This commit is contained in:
fengzeroz
2022-03-31 19:17:06 +08:00
committed by GitHub
parent 820d53e453 c02f1532da
commit ab66b4ced9
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/adapter/adapter.c
+2 -1
View File
@@ -1146,7 +1146,7 @@ static void adapter_loop(void *arg)
intf_funs = adapter->plugin_module->intf_funs;
req.req_id = cmd_ptr->req_id;
req.req_type = NEU_REQRESP_WRITE_RESP;
req.sender_id = 0;
req.sender_id = cmd_ptr->sender_id;
req.buf_len = sizeof(neu_reqresp_write_resp_t);
req.buf = (void *) &write_resp;
intf_funs->request(adapter->plugin, &req);
@@ -1727,6 +1727,7 @@ static int adapter_response(neu_adapter_t *adapter, neu_response_t *resp)
write_data_resp->grp_config = write_resp->grp_config;
write_data_resp->recver_id = resp->recver_id;
write_data_resp->req_id = resp->req_id;
write_data_resp->sender_id = to_node_id((adapter), (adapter)->id);
trans_buf = &write_data_resp->trans_buf;
rv = neu_trans_buf_init(trans_buf, adapter->trans_kind,
write_resp->data_val);
src/core/message.h
+1
View File
@@ -182,6 +182,7 @@ typedef struct read_data_resp {
typedef struct write_data_resp {
neu_taggrp_config_t *grp_config;
neu_trans_buf_t trans_buf;
adapter_id_t sender_id;
adapter_id_t recver_id;
uint32_t req_id;
} write_data_resp_t;