RPC: check for messages in IRQ

Author: facchinm

libraries/RPC/RPC.cpp

@@ -107,9 +107,9 @@ int RPC::begin() {
     return 0;
   }
 
-  eventThread = new rtos::Thread(osPriorityNormal);
-  eventThread->start(callback(&eventQueue, &events::EventQueue::dispatch_forever));
-  ticker.attach(eventQueue.event(&OPENAMP_check_for_message), 0.02f);
+  //eventThread = new rtos::Thread(osPriorityNormal);
+  //eventThread->start(callback(&eventQueue, &events::EventQueue::dispatch_forever));
+  //ticker.attach(eventQueue.event(&OPENAMP_check_for_message), 0.01f);
 
   dispatcherThread = new rtos::Thread(osPriorityNormal);
   dispatcherThread->start(mbed::callback(this, &RPC::dispatch));
@@ -191,9 +191,9 @@ int RPC::begin() {
 	OPENAMP_send(&rp_endpoints[1], &message, sizeof(message));
 	OPENAMP_send(&rp_endpoints[2], &message, sizeof(message));
 
-	eventThread = new rtos::Thread(osPriorityNormal);
-	eventThread->start(callback(&eventQueue, &events::EventQueue::dispatch_forever));
-	ticker.attach(eventQueue.event(&OPENAMP_check_for_message), 0.005f);
+	//eventThread = new rtos::Thread(osPriorityNormal);
+	//eventThread->start(callback(&eventQueue, &events::EventQueue::dispatch_forever));
+	//ticker.attach(eventQueue.event(&OPENAMP_check_for_message), 0.01f);
 
 	dispatcherThread = new rtos::Thread(osPriorityNormal);
 	dispatcherThread->start(mbed::callback(this, &RPC::dispatch));

libraries/openamp_arduino/src/mailbox_hsem_if.c

@@ -67,6 +67,8 @@
 /* Private variables ---------------------------------------------------------*/
 static uint32_t msg_received = RX_NO_MSG;
 
+void OPENAMP_check_for_message(void);
+
 /* Private functions ---------------------------------------------------------*/
 void HAL_HSEM_FreeCallback(uint32_t SemMask)
 {
@@ -79,7 +81,9 @@ void HAL_HSEM_FreeCallback(uint32_t SemMask)
 #endif
 #ifdef CORE_CM4
   HAL_HSEM_ActivateNotification(__HAL_HSEM_SEMID_TO_MASK(HSEM_ID_0));   
-#endif  
+#endif
+
+  OPENAMP_check_for_message();
 }
 
 /**