mirror of
https://github.com/emqx/neuron.git
synced 2026-10-18 13:41:22 +08:00
add sender_id in read msg
This commit is contained in:
Vendored
@@ -1692,6 +1692,7 @@ static int adapter_response(neu_adapter_t *adapter, neu_response_t *resp)
|
||||
read_data_resp->grp_config = read_resp->grp_config;
|
||||
read_data_resp->recver_id = resp->recver_id;
|
||||
read_data_resp->req_id = resp->req_id;
|
||||
read_data_resp->sender_id = to_node_id((adapter), (adapter)->id);
|
||||
trans_buf = &read_data_resp->trans_buf;
|
||||
rv = neu_trans_buf_init(trans_buf, adapter->trans_kind,
|
||||
read_resp->data_val);
|
||||
|
||||
@@ -173,6 +173,7 @@ typedef struct neuron_trans_data {
|
||||
typedef struct read_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;
|
||||
} read_data_resp_t;
|
||||
|
||||
Reference in New Issue
Block a user