botchain/firmware
1
0
Fork 0
mirror of https://github.com/BotChain-Robots/firmware.git synced 2026-07-08 17:47:21 +02:00
Code Issues Packages Projects Releases Wiki Activity

sendrecv

Browse Source
This commit is contained in:
Johnathon Slightham
2025-10-16 21:46:39 -04:00
parent cfc02dd1d2
commit e226a67303
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
components/rpc/MessagingInterface.cpp
View File

@@ -13,7 +13,7 @@ MessagingInterface::~MessagingInterface() {
vQueueDelete(m_mpi_rx_queue); vQueueDelete(m_mpi_rx_queue);
vSemaphoreDelete(m_map_semaphore); vSemaphoreDelete(m_map_semaphore);
for (const auto [_tag, queue] : m_tag_to_queue) { for (const auto queue: m_tag_to_queue | std::views::values) {
vQueueDelete(queue); vQueueDelete(queue);
} }
} }
@@ -41,7 +41,9 @@ int MessagingInterface::recv(char* buffer, int size, int source, const int tag)
return 0; return 0;
} }
int MessagingInterface::sendrecv(char* send_buffer, int send_size, int dest, int send_tag, char* recv_buffer, int recv_size, int recv_tag) { int MessagingInterface::sendrecv(char* send_buffer, const int send_size, const int dest, const int send_tag, char* recv_buffer, const int recv_size, const int recv_tag, const bool durable) {
send(send_buffer, send_size, dest, send_tag, durable);
recv(recv_buffer, recv_size, dest, recv_tag);
return 0; return 0;
} }

2
components/rpc/include/MessagingInterface.h
View File

@@ -25,7 +25,7 @@ public:
int send(char* buffer, int size, int destination, int tag, bool durable); int send(char* buffer, int size, int destination, int tag, bool durable);
int broadcast(char* buffer, int size, int root, bool durable); int broadcast(char* buffer, int size, int root, bool durable);
int recv(char* buffer, int size, int source, int tag); int recv(char* buffer, int size, int source, int tag);
int sendrecv(char* send_buffer, int send_size, int dest, int send_tag, char* recv_buffer, int recv_size, int recv_tag); int sendrecv(char *send_buffer, int send_size, int dest, int send_tag, char *recv_buffer, int recv_size, int recv_tag, bool durable);
std::pair<std::vector<uint8_t>, std::vector<Orientation>> get_physically_connected_modules() const; std::pair<std::vector<uint8_t>, std::vector<Orientation>> get_physically_connected_modules() const;
Messaging::ConnectionType get_connection_type() const; Messaging::ConnectionType get_connection_type() const;
uint8_t get_leader() const; uint8_t get_leader() const;