WIP: add attach() API to RPC

Author: facchinm

libraries/RPC/RPC.cpp

@@ -44,6 +44,11 @@ int RPC::rpmsg_recv_raw_callback(struct rpmsg_endpoint *ept, void *data,
   for (int i=0; i<len; i++) {
     rpc->rx_buffer.store_char(buf[i]);
   }
+  // call attached function
+  if (rpc->_rx) {
+    rpc->_rx.call();
+  }
+
   return 0;
 }
 

libraries/RPC/RPC_internal.h

@@ -71,6 +71,13 @@ class RPC : public Stream, public rpc::detail::dispatcher {
 			return initialized;
 		}
 
+	    void attach(void (*fptr)(void))
+	    {
+	        if (fptr != NULL) {
+	            _rx = mbed::Callback<void()>(fptr);
+	        }
+	    }
+
 		template <typename... Args>
     	RPCLIB_MSGPACK::object_handle call(std::string const &func_name,
                                        Args... args) {
@@ -112,6 +119,7 @@ class RPC : public Stream, public rpc::detail::dispatcher {
 		rtos::Thread* eventThread;
 		rtos::Thread* dispatcherThread;
 		RPCLIB_MSGPACK::unpacker pac_;
+		mbed::Callback<void()> _rx;
 
 		//rpc::detail::response response;
 		RPCLIB_MSGPACK::object_handle call_result;

libraries/RPC/examples/SerialPassthrough_RPC/SerialPassthrough_RPC.ino

@@ -0,0 +1,24 @@
+#include "Arduino.h"
+#include "RPC_internal.h"
+
+void setup() {
+  Serial.begin(115200);
+  RPC1.begin();
+}
+
+void loop() {
+  String data = "";
+  while (RPC1.available()) {
+    data += (char)RPC1.read();
+  }
+  if (data != "") {
+    Serial.write(data.c_str(), data.length());
+  }
+  data = "";
+  while (Serial.available()) {
+    data += (char)Serial.read();
+  }
+  if (data != "") {
+    RPC1.write(data.c_str(), data.length());
+  }
+}