Commit 414020f6 authored by yoogx's avatar yoogx

* Minor reformatting

parent ede84b0d
...@@ -8,7 +8,6 @@ ...@@ -8,7 +8,6 @@
#include <po_hi_transport.h> #include <po_hi_transport.h>
#include <po_hi_gqueue.h> #include <po_hi_gqueue.h>
/******************************************************************************/ /******************************************************************************/
/* In the case of the client-side of the RPC: the corresponding AADL /* In the case of the client-side of the RPC: the corresponding AADL
* subprogram is *NOT* connected to AADL thread ports. We interact * subprogram is *NOT* connected to AADL thread ports. We interact
...@@ -34,18 +33,17 @@ void rpc_client (__po_hi_task_id self) { ...@@ -34,18 +33,17 @@ void rpc_client (__po_hi_task_id self) {
&req); &req);
__po_hi_send_output (self,REQUEST_PORT(client_t, out_parameter)); __po_hi_send_output (self,REQUEST_PORT(client_t, out_parameter));
printf ("Client thread: sending parameter %d\n", i); printf ("Client thread: sending parameter %d\n", i);
__po_hi_gqueue_wait_for_incoming_event(self, &return_value_port); __po_hi_gqueue_wait_for_incoming_event(self, &return_value_port);
__po_hi_gqueue_get_value(self,return_value_port,&req); __po_hi_gqueue_get_value(self,return_value_port,&req);
__po_hi_gqueue_next_value(self,return_value_port); __po_hi_gqueue_next_value(self,return_value_port);
printf ("Client received: %d\n", printf ("Client received: %d\n",
req.PORT_VARIABLE(client_t,return_value)); req.PORT_VARIABLE(client_t,return_value));
i++;
printf ("[END of RPC]\n\n");
i++;
printf ("[END of RPC]\n\n");
} }
/******************************************************************************/ /******************************************************************************/
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment