22
33using namespace Canard ;
44
5- void TestNetwork::route_msg (CoreTestInterface *send_iface, uint8_t source_node_id, uint8_t destination_node_id, Transfer transfer) {
5+ void TestNetwork::route_msg (CoreTestInterface *send_iface, uint8_t source_node_id, uint8_t destination_node_id,
6+ Transfer transfer, CanardTransferType transfer_type) {
67 (void )destination_node_id;
78 // prepare CanardRxTransfer
89 CanardRxTransfer rx_transfer {};
@@ -20,7 +21,7 @@ void TestNetwork::route_msg(CoreTestInterface *send_iface, uint8_t source_node_i
2021 // send to all interfaces
2122 for (auto iface : ifaces) {
2223 if (iface != send_iface && iface != nullptr ) {
23- iface->handle_transfer (rx_transfer);
24+ iface->handle_transfer (rx_transfer, transfer_type );
2425 }
2526 }
2627}
@@ -30,7 +31,7 @@ void TestNetwork::route_msg(CoreTestInterface *send_iface, uint8_t source_node_i
3031// / @return true if message was added to the queue
3132bool CoreTestInterface::broadcast (const Transfer &bcast_transfer) {
3233 // call network router
33- TestNetwork::get_network ().route_msg (this , node_id, 255 , bcast_transfer);
34+ TestNetwork::get_network ().route_msg (this , node_id, 255 , bcast_transfer, CanardTransferTypeBroadcast );
3435 return true ;
3536}
3637
@@ -40,7 +41,7 @@ bool CoreTestInterface::broadcast(const Transfer &bcast_transfer) {
4041// / @return true if request was added to the queue
4142bool CoreTestInterface::request (uint8_t destination_node_id, const Transfer &req_transfer) {
4243 // call network router
43- TestNetwork::get_network ().route_msg (this , node_id, destination_node_id, req_transfer);
44+ TestNetwork::get_network ().route_msg (this , node_id, destination_node_id, req_transfer, CanardTransferTypeRequest );
4445 return true ;
4546}
4647
@@ -50,7 +51,7 @@ bool CoreTestInterface::request(uint8_t destination_node_id, const Transfer &req
5051// / @return true if response was added to the queue
5152bool CoreTestInterface::respond (uint8_t destination_node_id, const Transfer &res_transfer) {
5253 // call network router
53- TestNetwork::get_network ().route_msg (this , node_id, destination_node_id, res_transfer);
54+ TestNetwork::get_network ().route_msg (this , node_id, destination_node_id, res_transfer, CanardTransferTypeResponse );
5455 return true ;
5556}
5657
@@ -60,10 +61,10 @@ void CoreTestInterface::set_node_id(uint8_t _node_id) {
6061 node_id = _node_id;
6162}
6263
63- void CoreTestInterface::handle_transfer (CanardRxTransfer &transfer) {
64+ void CoreTestInterface::handle_transfer (CanardRxTransfer &transfer, CanardTransferType transfer_type ) {
6465 uint64_t signature = 0 ;
6566 // check if message should be accepted
66- if (accept_message (transfer.data_type_id , signature)) {
67+ if (accept_message (transfer.data_type_id , transfer_type, signature)) {
6768 // call message handler
6869 handle_message (transfer);
6970 }
0 commit comments