Subversion Repositories funbase_ip_library

/**
 *
 * @file   11_vop_mem.c
 * @author Lasse Lehtonen
 *
 * @brief VOPD - vop_mem node.
 *
 */
 
 
#include "common.h"
 
#include <mcapi.h>
 
#include <stdlib.h>
#include <stdio.h>
#include <signal.h>
#include <getopt.h>
 
const int LOCAL    = 11;
 
const int REMOTE1  = 10;
const int TX_PORT1 = 24;
const int RX_PORT1 = 25;
const int TX_DATA1 = 512;//000;
 
const int REMOTE2  = 9;
const int TX_PORT2 = 26;
const int RX_PORT2 = 27;
const int TX_DATA2 = 512;//000;
 
const int IN_PORT  = 23;
 
 
 
mcapi_pktchan_recv_hndl_t       send_handle1;
mcapi_pktchan_recv_hndl_t       send_handle2;
mcapi_pktchan_recv_hndl_t       recv_handle;
 
static struct sigaction oldactions[32];
 
static void signalled(int signal, siginfo_t *info, void *context)
{
	struct sigaction *action;
 
	action = &oldactions[signal];
 
	if ((action->sa_flags & SA_SIGINFO) && action->sa_sigaction)
		action->sa_sigaction(signal, info, context);
	else if (action->sa_handler)
		action->sa_handler(signal);
 
	exit(signal);
}
 
struct sigaction action = {
	.sa_sigaction = signalled,
	.sa_flags = SA_SIGINFO,
};
 
 
int main(int argc, char* argv[])
{
 
   mcapi_status_t status;
   mcapi_version_t version;
 
   char   outgoing1[TX_DATA1];
   char   outgoing2[TX_DATA2];
   char*  incoming;
   size_t bytes;
   int count = 0;
 
 
   mcapi_initialize(LOCAL, &version, &status);
   mcapi_assert_success(status);
   printf("Node %d: MCAPI Initialized\n", LOCAL);
 
 
   connect_rev(LOCAL, IN_PORT, &recv_handle);
   connect_fwd(LOCAL, TX_PORT1, &send_handle1, REMOTE1, RX_PORT1);
   connect_fwd(LOCAL, TX_PORT2, &send_handle2, REMOTE2, RX_PORT2);
 
 
 
   atexit(cleanup);
   sigaction(SIGQUIT, &action, &oldactions[SIGQUIT]);
   sigaction(SIGABRT, &action, &oldactions[SIGABRT]);
   sigaction(SIGTERM, &action, &oldactions[SIGTERM]);
   sigaction(SIGINT,  &action, &oldactions[SIGINT]);
 
   while(1) {
 
      // Send 1
      count = (count+1) % 10;
      memset(outgoing1, 0, TX_DATA1);
      sprintf(outgoing1, "Node %d: vop_mem (%d)", LOCAL, count);
 
      mcapi_pktchan_send(send_handle1, outgoing1, TX_DATA1,
                         &status);
      mcapi_assert_success(status);      
 
      // Send 2
      memset(outgoing2, 0, TX_DATA2);
      sprintf(outgoing2, "Node %d: vop_mem (%d)", LOCAL, count);
 
      mcapi_pktchan_send(send_handle2, outgoing2, TX_DATA2,
                         &status);
      mcapi_assert_success(status);      
 
      // Receive
      mcapi_pktchan_recv(recv_handle, (void *)&incoming, &bytes,
                        &status);
      printf("Node %d: received %d bytes :%s\n", LOCAL, bytes, incoming);
 
      mcapi_pktchan_free(incoming, &status);
      mcapi_assert_success(status);
 
   }
 
   return 0;
}
 
// Local Variables:
// mode: c++
// c-file-style: "ellemtel"
// c-basic-offset: 3
// End: