feat: udp and tcp read_timeout

Author: eigen-value

src/tcp_client.h

@@ -32,6 +32,7 @@ class BridgeTCPClient : public Client {
 
     BridgeClass* bridge;
     uint32_t connection_id{};
+    uint32_t read_timeout = 0;
     RingBufferN<BufferSize> temp_buffer;
     struct k_mutex client_mutex{};
     bool _connected = false;
@@ -49,6 +50,12 @@ class BridgeTCPClient : public Client {
         return true;
     }
 
+    void setTimeout(const uint32_t ms) {
+        k_mutex_lock(&client_mutex, K_FOREVER);
+        read_timeout = ms;
+        k_mutex_unlock(&client_mutex);
+    }
+
     int connect(IPAddress ip, uint16_t port) override {
         return connect(ip.toString().c_str(), port);
     }
@@ -198,7 +205,7 @@ class BridgeTCPClient : public Client {
         k_mutex_lock(&client_mutex, K_FOREVER);
 
         MsgPack::arr_t<uint8_t> message;
-        RpcResult async_rpc = bridge->call(TCP_READ_METHOD, connection_id, size);
+        RpcResult async_rpc = bridge->call(TCP_READ_METHOD, connection_id, size, read_timeout);
 
         const bool ret = async_rpc.result(message);
 

src/udp_bridge.h

@@ -30,6 +30,7 @@ class BridgeUDP final: public UDP {
 
     BridgeClass* bridge;
     uint32_t connection_id{};
+    uint32_t read_timeout = 0;
     RingBufferN<BufferSize> temp_buffer;
     struct k_mutex udp_mutex{};
     bool _connected = false;
@@ -67,6 +68,12 @@ class BridgeUDP final: public UDP {
         return ok? 1 : 0;
     }
 
+    void setTimeout(const uint32_t ms) {
+        k_mutex_lock(&udp_mutex, K_FOREVER);
+        read_timeout = ms;
+        k_mutex_unlock(&udp_mutex);
+    }
+
     uint8_t beginMulticast(IPAddress ip, uint16_t port) override {
 
         if (!init()) {
@@ -257,7 +264,7 @@ class BridgeUDP final: public UDP {
         k_mutex_lock(&udp_mutex, K_FOREVER);
 
         MsgPack::arr_t<uint8_t> message;
-        RpcResult async_res = bridge->call(UDP_READ_METHOD, connection_id, size);
+        RpcResult async_res = bridge->call(UDP_READ_METHOD, connection_id, size, read_timeout);
         const bool ret = _connected && async_res.result(message);
 
         if (ret) {