bgpdma.cpp File Reference

#include <structpool.h>

Include dependency graph for bgpdma.cpp:

Classes
class	BGP_ReceiveBuffer
class	BGP_DMASend
Defines
#define	BGP_RECEIVEBUFFER_SIZE   10000
#define	NSEND   10
#define	NSEND2   5
Functions
void	nrnmpi_int_allgatherv (int *, int *, int *, int *)
void	nrnmpi_int_alltoallv (int *, int *, int *, int *, int *, int *)
void	nrnmpi_int_gather (int *, int *, int, int)
void	nrnmpi_int_gatherv (int *, int, int *, int *, int *, int)
void	nrnmpi_barrier ()
	declareStructPool (SpkPool, NRNMPI_Spike) implementStructPool(SpkPool
void	nrnmpi_bgp_comm ()
void	nrnmpi_bgp_multisend (NRNMPI_Spike *, int, int *)
int	nrnmpi_bgp_single_advance (NRNMPI_Spike *)
int	nrnmpi_bgp_conserve (int nsend, int nrecv)
void	bgp_dma_receive ()
void	bgp_dma_send (PreSyn *ps, double t)
void	bgpdma_send_init (PreSyn *ps)
void	bgpdma_cleanup_presyn (PreSyn *ps)
void	bgp_dma_setup ()
	NrnHashIterate (Gid2PreSyn, gid2out_, PreSyn *, ps)
	for (i=0;i< nrnmpi_numprocs;++i)
	if (gids) delete[] gids
	NrnHashIterate (Gid2PreSyn, gid2in_, PreSyn *, ps)
	determine_targid_count_on_srchost (srchost_count, tarcounts)
	determine_targids_on_srchost (targid_on_tar, srchost_count, srchost_displ, targid_on_src, tarcounts, tardispl)
	if (gid2out_) for(i=0
i< n;++i){assert(gid2out_->	find (targid_on_src[i], ps))
	if (i==nrnmpi_myid)
	if (targid_on_src) delete[] targid_on_src
	if (targid_on_tar) delete[] targid_on_tar
Variables
	nsrcgid = 0
int *	gids = nsrcgid ? new int[nsrcgid] : 0
	i = 0
int *	host_nsrcgid = new int[nrnmpi_numprocs]
long	totalngid = 0
int	maxngid = 0
int	bufsize = 10000
int *	n = new int[nrnmpi_numprocs]
int *	displ = new int[nrnmpi_numprocs+1]
int *	buf = new int[bufsize]
int *	srchost_displ = new int[nrnmpi_numprocs + 1]
int *	targid_on_tar = ntargid ? new int[ntargid] : 0
int *	tarcounts = new int[nrnmpi_numprocs]
int *	tardispl = new int[nrnmpi_numprocs+1]
int *	targid_on_src = n ? new int[n] : 0
ps bgp dma_send_	ntarget_hosts_
i< nrnmpi_numprocs;++i){for(int j=tardispl[i];j< tardispl[i+1];++j){assert(gid2out_-> find(targid_on_src[j], ps));BGP_DMASend *s=ps-> bgp	dma_send_
s	target_hosts_ [s->ntarget_hosts_++] = i
delete[]	srchost_count

---

Define Documentation

#define BGP_RECEIVEBUFFER_SIZE   10000

Referenced by BGP_ReceiveBuffer::BGP_ReceiveBuffer().

#define NSEND   10

Referenced by BGP_DMASend::send().

#define NSEND2   5

Referenced by bgp_dma_setup(), and BGP_DMASend::send().

---

Function Documentation

void bgp_dma_receive

(

)

References BGP_ReceiveBuffer::enqueue(), BGP_ReceiveBuffer::nrecv_, nrnmpi_bgp_conserve(), nrnmpi_wtime(), BGP_ReceiveBuffer::nsend_, and s.

Referenced by BBS::netpar_solve().

Here is the call graph for this function:

void bgp_dma_send	(	PreSyn *	ps,
		double	t
	)

void bgp_dma_setup

(

)

References assert, nrnmpi_bgp_comm(), nrnmpi_numprocs, nrnmpi_wtime(), and NSEND2.

Referenced by nrn_spike_exchange_init().

Here is the call graph for this function:

void bgpdma_cleanup_presyn

(

PreSyn *

ps

)

Referenced by nrn_cleanup_presyn().

void bgpdma_send_init

(

PreSyn *

ps

)

declareStructPool	(	SpkPool	,
		NRNMPI_Spike
	)

determine_targid_count_on_srchost	(	srchost_count	,
		tarcounts
	)

determine_targids_on_srchost	(	targid_on_tar	,
		srchost_count	,
		srchost_displ	,
		targid_on_src	,
		tarcounts	,
		tardispl
	)

i< n; ++i) { assert(gid2out_-> find	(	targid_on_src	[i],
		ps
	)

for

(

)

if

(

targid_on_tar

)

if

(

targid_on_src

)

if

(

i

= = nrnmpi_myid

)

References BGP_DMASend::ntarget_hosts_, and BGP_DMASend::send2self_.

if

(

gid2out_

)

[pure virtual]

if

(

gids

)

NrnHashIterate	(	Gid2PreSyn	,
		gid2in_	,
		PreSyn *	,
		ps
	)

NrnHashIterate	(	Gid2PreSyn	,
		gid2out_	,
		PreSyn *	,
		ps
	)

References ntarget_hosts_, BGP_DMASend::ntarget_hosts_, s, and BGP_DMASend::target_hosts_.

void nrnmpi_barrier

(

)

Referenced by nrnmpi_setup_transfer(), and MultiSplitControl::prstruct().

void nrnmpi_bgp_comm

(

)

Referenced by bgp_dma_setup().

int nrnmpi_bgp_conserve	(	int	nsend,
		int	nrecv
	)

Referenced by bgp_dma_receive().

void nrnmpi_bgp_multisend	(	NRNMPI_Spike *	,
		int	,
		int *
	)

Referenced by BGP_DMASend::send().

int nrnmpi_bgp_single_advance

(

NRNMPI_Spike *

)

void nrnmpi_int_allgatherv	(	int *	,
		int *	,
		int *	,
		int *
	)

Referenced by MultiSplitControl::exchange_setup(), and nrnmpi_setup_transfer().

void nrnmpi_int_alltoallv	(	int *	,
		int *	,
		int *	,
		int *	,
		int *	,
		int *
	)

Referenced by nrnmpi_setup_transfer().

void nrnmpi_int_gather	(	int *	,
		int *	,
		int	,
		int
	)

void nrnmpi_int_gatherv	(	int *	,
		int	,
		int *	,
		int *	,
		int *	,
		int
	)

---

Variable Documentation

delete [] buf = new int[bufsize]

Referenced by HocCommand::audit(), KSChan::build(), check_obj_type(), HocCommand::execute(), expand_env_var(), for(), forall_section(), Fprint(), getenv(), HocCommand::help(), hoc_araystr(), hoc_audit_from_hoc_main1(), hoc_constobject(), hoc_exec_cmd(), hoc_final_exit(), hoc_Getstr(), hoc_ifsec(), hoc_name2obj(), hoc_name2sym(), hoc_parallel_begin(), hoc_saveaudit(), hoc_secname(), hoc_Sprint(), hoc_val_pointer(), hoc_win32_cleanup(), if(), inithoc(), ion_reg(), ion_register(), ivoc_list_look(), ivocmain(), java2nrn_class(), KSChan::KSChan(), SymDirectoryImpl::load_section(), make_mechanism(), SymDirectoryImpl::make_pathname(), make_pointprocess(), neuronhome_forward(), nrn_cache_prop_realloc(), nrn_thread_stat(), nrn_user_partition(), nrn_version(), nrnglobalmechmenu(), nrnmpi_splitcell_connect(), nrnpy_augment_path(), nrnpy_dprop(), StmtInfo::parse(), pathprepend(), plprint(), print(), PRintf(), SaveState::read(), SaveState::readnet(), register_mech(), HocDataPathImpl::search(), HocDataPathImpl::search_vectors(), sec_and_position(), section_exists(), sectionname(), KSChan::setion(), KSChan::setligand(), setneuronhome(), KSChan::setstructure(), KSChan::settype(), KSChan::sname_install(), SymbolItem::SymbolItem(), system(), and SymDirectory::variable().

bufsize = 10000

delete [] displ = new int[nrnmpi_numprocs+1]

Referenced by MultiSplitControl::exchange_setup().

i< nrnmpi_numprocs; ++i) { for (int j = tardispl[i] ; j < tardispl[i+1]; ++j) { assert(gid2out_->find(targid_on_src[j], ps)); BGP_DMASend* s = ps-> bgp dma_send_

int* gids = nsrcgid ? new int[nsrcgid] : 0

delete [] host_nsrcgid = new int[nrnmpi_numprocs]

i = 0

int maxngid = 0

int n = new int[nrnmpi_numprocs]

nrnmpi_int_allgather & nsrcgid = 0

ps bgp dma_send_ ntarget_hosts_

Referenced by NrnHashIterate().

delete [] srchost_count

delete [] srchost_displ = new int[nrnmpi_numprocs + 1]

delete [] tarcounts = new int[nrnmpi_numprocs]

delete [] tardispl = new int[nrnmpi_numprocs+1]

s target_hosts_[s->ntarget_hosts_++] = i

int* targid_on_src = n ? new int[n] : 0

int* targid_on_tar = ntargid ? new int[ntargid] : 0

long totalngid = 0