xmp_onesided_tca.c File Reference

#include "xmp_internal.h"
#include "tca-api.h"
#include "pthread.h"
#include <time.h>
#include <sys/time.h>

Include dependency graph for xmp_onesided_tca.c:

Data Structures
struct	packet_t
struct	tca_ring_buf_t

Macros
#define	RING_SIZE   (8)

Typedefs
typedef struct packet_t	packet_t
typedef unsigned long long	psn_t
typedef struct tca_ring_buf_t	tca_ring_buf_t

Functions
void	_XMP_tca_comm_init ()
void	_XMP_tca_comm_finalize ()
void	_XMP_tca_initialize ()
	Initialize TCA. More...
void	_XMP_tca_finalize ()
	Finalize TCA. More...
void	_XMP_tca_comm_send (const int rank, const int tag, const int data)
bool	_XMP_tca_comm_recv_nowait (const int rank, packet_t *packet)
void	_XMP_tca_comm_recv (const int rank, int *tag, int *data)
double	getElapsedTime_ (struct timespec *begin, struct timespec *end)
void	_XMP_tca_lock ()
void	_XMP_tca_unlock ()

Variables
const int	_wait_slot_offset = 16
const int	_dmac_channel = 0
const int	_handle_sendrecv_tag = 123
const int	_packet_wait_tag = 31
const int	_psn_wait_tag = 32
tca_ring_buf_t *	_ring_bufs
struct timespec begin_ts	end_ts

Macro Definition Documentation

RING_SIZE

#define RING_SIZE   (8)

Typedef Documentation

packet_t

typedef struct packet_t packet_t

psn_t

typedef unsigned long long psn_t

tca_ring_buf_t

typedef struct tca_ring_buf_t tca_ring_buf_t

Function Documentation

_XMP_tca_comm_finalize()

void _XMP_tca_comm_finalize

(

)

{
  for(int i = 0; i < _XMP_world_size; i++){
    if(i == _XMP_world_rank) continue;
    _XMP_tca_ring_buf_finalize(&_ring_bufs[i]);
  }
  _XMP_free(_ring_bufs);
  //fprintf(stderr, "spin_wait_count=%llu\n", spin_wait_count);
}

_XMP_tca_comm_init()

void _XMP_tca_comm_init

(

)

{
  _ring_bufs = _XMP_alloc(sizeof(tca_ring_buf_t) * _XMP_world_size);
  for(int i = 0; i < _XMP_world_size; i++){
    if(i == _XMP_world_rank) continue;
    _XMP_tca_ring_buf_init(&_ring_bufs[i], i);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

_XMP_tca_comm_recv()

void _XMP_tca_comm_recv	(	const int	rank,
		int *	tag,
		int *	data
	)

{
  if(rank == _XMP_world_rank){
    _XMP_fatal("recv from self is not supported");
  }
  _XMP_tca_ring_buf_recv(&_ring_bufs[rank], tag, data);
}

Here is the call graph for this function:

_XMP_tca_comm_recv_nowait()

bool _XMP_tca_comm_recv_nowait	(	const int	rank,
		packet_t *	packet
	)

                                                                {
  if(rank == _XMP_world_rank){
    _XMP_fatal("recv from self is not supported");
    return false;
  }
  return _XMP_tca_ring_buf_recv_nowait(&_ring_bufs[rank], packet);
}

Here is the call graph for this function:

_XMP_tca_comm_send()

void _XMP_tca_comm_send	(	const int	rank,
		const int	tag,
		const int	data
	)

{
  if(rank == _XMP_world_rank){
    _XMP_fatal("send to self is not supported");
  }
  _XMP_tca_ring_buf_send(&_ring_bufs[rank], tag, data);
}

Here is the call graph for this function:

_XMP_tca_finalize()

void _XMP_tca_finalize

(

)

Finalize TCA.

{
  _XMP_tca_lock();
  destroy_comm_thread();
  _XMP_tca_comm_finalize();
  _XMP_tca_unlock();
}

Here is the call graph for this function:

Here is the caller graph for this function:

_XMP_tca_initialize()

void _XMP_tca_initialize

(

)

Initialize TCA.

{
  if(_XMP_world_rank == 0){
    fprintf(stderr, "TCA Library Version = %s\n", TCA_LIB_VERSION);
  }
 
  if(_XMP_world_size > 16)
    _XMP_fatal("TCA reflect has been not implemented in 16 more than nodes.");
 
  _XMP_tca_lock();
  /* TCA_CHECK(tcaInit()); */
 
  //this is probably unnecessary
  TCA_CHECK(tcaDMADescInt_Init()); // Initialize Descriptor (Internal Memory) Mode
  
  _XMP_tca_comm_init();
  create_comm_thread();
  _XMP_tca_unlock();
}

Here is the call graph for this function:

Here is the caller graph for this function:

_XMP_tca_lock()

void _XMP_tca_lock

(

)

{
  int ret = pthread_mutex_lock(&_XMP_tca_mutex);
  if(ret == 0) return;
 
  _XMP_fatal("tca lock failed");
}

Here is the caller graph for this function:

_XMP_tca_unlock()

void _XMP_tca_unlock

(

)

{
  int ret = pthread_mutex_unlock(&_XMP_tca_mutex);
  if(ret == 0) return;
  _XMP_fatal("tca unlock failed");
}

Here is the caller graph for this function:

getElapsedTime_()

double getElapsedTime_	(	struct timespec *	begin,
		struct timespec *	end
	)

                                                                    {
  return (end->tv_sec - begin->tv_sec) + (end->tv_nsec - begin->tv_nsec) * 1e-9;
}

Variable Documentation

_dmac_channel

const int _dmac_channel = 0

_handle_sendrecv_tag

const int _handle_sendrecv_tag = 123

_packet_wait_tag

const int _packet_wait_tag = 31

_psn_wait_tag

const int _psn_wait_tag = 32

_ring_bufs

tca_ring_buf_t* _ring_bufs

_wait_slot_offset

const int _wait_slot_offset = 16

end_ts

struct timespec begin_ts end_ts