Subversion Repositories funbase_ip_library

/**
 *
 * @file   common.c
 * @author Lasse Lehtonen
 *
 * @brief VOPD - Common stuff for all nodes.
 *
 */
 
 
#include "common.h"
 
#include <assert.h>
#include <limits.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <fcntl.h>
#include <errno.h>
#include <time.h> 
 
void connect_fwd(int local, int tx_port, mcapi_pktchan_recv_hndl_t* send_hndl,
                 int remote, int rx_port)
{
   mcapi_endpoint_t local_send_endpoint; 
 
   mcapi_endpoint_t remote_recv_endpoint;
   mcapi_request_t  request;
   mcapi_request_t  send_request;
 
   mcapi_status_t   status;
   size_t           size;
 
 
   printf("Node %d: Creating tx port %d\n", local, tx_port);
   local_send_endpoint = mcapi_create_endpoint(tx_port, &status);
   mcapi_assert_success(status);
 
   printf("Node %d: Creating remote rx port %d\n", local, rx_port);
   remote_recv_endpoint = mcapi_get_endpoint(remote, rx_port, &status);
   mcapi_assert_success(status);
 
   printf("Node %d: Connecting %d:%d to %d:%d\n",local, local, tx_port,
          remote, rx_port);
   mcapi_connect_pktchan_i(local_send_endpoint, remote_recv_endpoint,
                           &request, &status);
   mcapi_assert_success(status);
 
   mcapi_wait(&request, &size, &status, WAIT_TIMEOUT);     
   mcapi_assert_success(status);
 
   printf("Node %d: Connection complete\n", local);
 
   printf("Node %d: Opening send endpoint\n", local);
   mcapi_open_pktchan_send_i(send_hndl, local_send_endpoint, &send_request,
                             &status);
 
   mcapi_wait(&send_request, &size, &status, WAIT_TIMEOUT);        
   mcapi_assert_success(status);
 
   printf("Node %d: MCAPI forward connection complete! \n", local);
 
}
 
 
 
void connect_rev(int local, int rx_port, mcapi_pktchan_recv_hndl_t* recv_hndl)
{
   mcapi_endpoint_t local_recv_endpoint;
   mcapi_request_t  recv_request;
   mcapi_status_t   status;
   size_t           size;
 
   printf("Node %d: Creating local rx port %d\n", local, rx_port);
   local_recv_endpoint = mcapi_create_endpoint(rx_port, &status);
   mcapi_assert_success(status);
 
   printf("Node %d: Opening receive endpoint\n", local);
   mcapi_open_pktchan_recv_i(recv_hndl, local_recv_endpoint, &recv_request,
                             &status);
 
   mcapi_wait(&recv_request, &size, &status, WAIT_TIMEOUT);        
   mcapi_assert_success(status);
 
   printf("Node %d: MCAPI reverse connection complete! \n", local);
 
}
 
 
void cleanup()
{
   mcapi_status_t status;
   mcapi_finalize(&status);
}
 
// Local Variables:
// mode: c++
// c-file-style: "ellemtel"
// c-basic-offset: 3
// End: