#include <MultiThreadedVisResampler.h>

Inheritance diagram for casa::MultiThreadedVisibilityResampler:

Public Member Functions
	MultiThreadedVisibilityResampler ()
	enum VBLoader {NOONE=-1, DATATOGRID=0, GRIDTODATA, RESIDUALCALC}; More...

	MultiThreadedVisibilityResampler (const casacore::Bool &doublePrecision, const casacore::Int &n=DEFAULTNOOFCORES)

	MultiThreadedVisibilityResampler (const casacore::Bool &doublePrecision, casacore::CountedPtr< VisibilityResamplerBase > &visResampler, const casacore::Int &n=DEFAULTNOOFCORES)

virtual	~MultiThreadedVisibilityResampler ()

	MultiThreadedVisibilityResampler (const MultiThreadedVisibilityResampler &other)

MultiThreadedVisibilityResampler *	clone ()
	This version will make a clone with shared data buffers (the complex grids and the sum-of-weights arrays). More...

MultiThreadedVisibilityResampler &	operator= (const MultiThreadedVisibilityResampler &other)

void	cleanup ()

void	releaseBuffers ()

void	copy (const MultiThreadedVisibilityResampler &other)

virtual casacore::Int	nelements ()

virtual void	setParams (const casacore::Vector< casacore::Double > &uvwScale, const casacore::Vector< casacore::Double > &offset, const casacore::Vector< casacore::Double > &dphase)

virtual void	setMaps (const casacore::Vector< casacore::Int > &chanMap, const casacore::Vector< casacore::Int > &polMap)

virtual void	setCFMaps (const casacore::Vector< casacore::Int > &cfMap, const casacore::Vector< casacore::Int > &conjCFMap)

virtual void	setFreqMaps (const casacore::Matrix< casacore::Double > &spwChanFreqs, const casacore::Matrix< casacore::Double > &spwChanConjFreqs)

virtual void	setConvFunc (const CFStore &cfs)

virtual void	setPATolerance (const double &dPA)

void	init (const casacore::Bool &doublePrecision)
	Forward looking genealogical baggage – required for the MultiThreadedVisibilityResampler. More...

virtual void	DataToGrid (casacore::Array< casacore::DComplex > &griddedData, VBStore &vbs, casacore::Matrix< casacore::Double > &sumwt, const casacore::Bool &dopsf, casacore::Bool=false)
	More...

virtual void	DataToGrid (casacore::Array< casacore::Complex > &griddedData, VBStore &vbs, casacore::Matrix< casacore::Double > &sumwt, const casacore::Bool &dopsf, casacore::Bool=false)

void	GatherGrids (casacore::Array< casacore::DComplex > &griddedData, casacore::Matrix< casacore::Double > &sumwt)
	This is the gather operation on griddedData for nelements > 1. More...

void	GatherGrids (casacore::Array< casacore::Complex > &griddedData, casacore::Matrix< casacore::Double > &sumwt)

void	initializePutBuffers (const casacore::Array< casacore::DComplex > &griddedData, const casacore::Matrix< casacore::Double > &sumwt)

void	initializePutBuffers (const casacore::Array< casacore::Complex > &griddedData, const casacore::Matrix< casacore::Double > &sumwt)

void	initializeDataBuffers (VBStore &)

virtual void	GridToData (VBStore &vbs, const casacore::Array< casacore::Complex > &griddedData)
	More...

virtual void	ComputeResiduals (VBStore &vbs)
	virtual void GridToData(VBStore& vbs, casacore::Array<casacore::Complex>& griddedData); More...

Public Member Functions inherited from casa::VisibilityResamplerBase
	VisibilityResamplerBase ()

	VisibilityResamplerBase (const VisibilityResamplerBase &other)
	VisibilityResamplerBase(const CFStore& cfs): uvwScale_p(), offset_p(), chanMap_p(), polMap_p(), convFuncStore_p(), inc_p(), cfMap_p(), conjCFMap_p() {setConvFunc(cfs);};. More...

virtual	~VisibilityResamplerBase ()

VisibilityResamplerBase &	operator= (const VisibilityResamplerBase &other)

virtual void	copy (const VisibilityResamplerBase &other)

void	finalizeToSky (casacore::Array< casacore::DComplex > &griddedData, casacore::Matrix< casacore::Double > &sumwt)
	Aliases for more readable code at the FTMachine layer. More...

void	finalizeToSky (casacore::Array< casacore::Complex > &griddedData, casacore::Matrix< casacore::Double > &sumwt)

void	initializeToSky (const casacore::Array< casacore::DComplex > &griddedData, const casacore::Matrix< casacore::Double > &sumwt)

void	initializeToSky (const casacore::Array< casacore::Complex > &griddedData, const casacore::Matrix< casacore::Double > &sumwt)

const casacore::Vector < casacore::Int >	getCFMap ()

const casacore::Vector < casacore::Int >	getConjCFMap ()

VBRow2CFMapType &	getVBRow2CFMap ()

VBRow2CFBMapType &	getVBRow2CFBMap ()

virtual casacore::Int	makeVBRow2CFMap (CFStore2 &cfs, ConvolutionFunction &cf, const VisBuffer &vb, const casacore::Quantity &dPA, const casacore::Vector< casacore::Int > &dataChan2ImChanMap, const casacore::Vector< casacore::Int > &dataPol2ImPolMap, const casacore::Vector< casacore::Double > &pointingOffset)

Private Member Functions
template<class T >
void	DataToGridImpl_p (casacore::Array< T > &griddedData, VBStore &vb, casacore::Matrix< casacore::Double > &sumwt, const casacore::Bool &dopsf, casacore::Bool useConjFreqCF=false)
	-------------------------—Private parts----------------------------------— More...

void	allocateBuffers (casacore::Bool newDataBuffers=true)
	template <class t>=""> void GatherGrids_p(const casacore::Array<T>& griddedData, const casacore::Matrix<casacore::Double>& sumwt); More...

void	makeInfrastructureContainers ()

casacore::Double	allocateDataBuffers ()

void	startThreads ()

void	scatter (casacore::Matrix< VBStore > &vbsStores, const VBStore &vbs)

Private Attributes
casacore::Int	nelements_p

casacore::Bool	doublePrecision_p

casacore::Vector < casacore::CountedPtr < VisibilityResamplerBase > >	resamplers_p

casacore::Vector < casacore::CountedPtr < casacore::Array < casacore::DComplex > > >	doubleGriddedData_p

casacore::Vector < casacore::CountedPtr < casacore::Array < casacore::Complex > > >	singleGriddedData_p

casacore::Vector < casacore::CountedPtr < casacore::Matrix < casacore::Double > > >	sumwt_p

casacore::Vector < casacore::CountedPtr < ResamplerWorklet > >	gridderWorklets_p

casacore::Matrix< VBStore >	vbsVec_p
	casacore::Vector<VBStore> vbsVec_p; More...

casacore::CountedPtr < ThreadCoordinator < casacore::Int > >	threadClerk_p

casacore::Bool	threadStarted_p

casa::utilj::DeltaThreadTimes	tSetupG

casa::utilj::DeltaThreadTimes	tSendDataG

casa::utilj::DeltaThreadTimes	tWaitForWorkG

casa::utilj::DeltaThreadTimes	tOutsideG

casa::utilj::DeltaThreadTimes	tSetupDG

casa::utilj::DeltaThreadTimes	tSendDataDG

casa::utilj::DeltaThreadTimes	tWaitForWorkDG

casa::utilj::DeltaThreadTimes	tOutsideDG

casa::utilj::ThreadTimes	t4G_p

casa::utilj::ThreadTimes	t4DG_p

casacore::CountedPtr < VisibilityResamplerBase >	visResamplerCtor_p
	async::Mutex *mutexForResamplers_p; More...

casacore::Int	whoLoadedVB_p

casacore::Int	currentVBS_p

Additional Inherited Members
Public Attributes inherited from casa::VisibilityResamplerBase
casacore::Double	runTimeG_p

casacore::Double	runTimeDG_p

casacore::Double	runTimeG1_p

casacore::Double	runTimeG2_p

casacore::Double	runTimeG3_p

casacore::Double	runTimeG4_p

casacore::Double	runTimeG5_p

casacore::Double	runTimeG6_p

casacore::Double	runTimeG7_p

casacore::Timer	timer_p

Protected Member Functions inherited from casa::VisibilityResamplerBase
void	sgrid (casacore::Int &ndim, casacore::Double __restrict__ pos, casacore::Int __restrict__ loc, casacore::Int __restrict__ off, casacore::Complex &phasor, const casacore::Int &irow, const casacore::Double __restrict__ uvw, const casacore::Double &dphase, const casacore::Double &freq, const casacore::Double __restrict__ scale, const casacore::Double __restrict__ offset, const casacore::Float *__restrict__ sampling)

casacore::Bool	onGrid (const casacore::Int &nx, const casacore::Int &ny, const casacore::Vector< casacore::Int > &__restrict__ loc, const casacore::Vector< casacore::Int > &__restrict__ support) __restrict__

casacore::Bool	onGrid (const casacore::Int &nx, const casacore::Int &ny, const casacore::Int &loc0, const casacore::Int &loc1, const casacore::Int &support) __restrict__

void	cacheAxisIncrements (const casacore::Int &n0, const casacore::Int &n1, const casacore::Int &n2, const casacore::Int &n3)
	casacore::Array assignment operator in CASACore requires lhs.nelements() == 0 or lhs.nelements()=rhs.nelements() template <class t>=""> inline void SETVEC(casacore::Vector<T>& lhs, const casacore::Vector<T>& rhs) {lhs.resize(rhs.shape()); lhs = rhs;}; More...

void	cacheAxisIncrements (const casacore::Vector< casacore::Int > &n)

void	cacheAxisIncrements (const casacore::Vector< casacore::Int > &n, casacore::Vector< casacore::Int > &inc)

void	cacheAxisIncrements (const casacore::Int n[4], casacore::Int inc[4])

void	addTo4DArray (casacore::DComplex __restrict__ &store, casacore::Int __restrict__ &iPos, casacore::Complex &nvalue, casacore::Double &wt) __restrict__
	Version that use internally cached inc_p template <class t>=""> More...

void	addTo4DArray (casacore::Complex __restrict__ &store, casacore::Int __restrict__ &iPos, casacore::Complex &nvalue, casacore::Double &wt) __restrict__

void	addTo4DArray (casacore::DComplex __restrict__ &store, casacore::Int __restrict__ &iPos, casacore::Int *__restrict__ inc, casacore::Complex &nvalue, casacore::Double &wt) __restrict__
	Version where inc_p is supplied from outside. More...

void	addTo4DArray (casacore::Complex __restrict__ &store, casacore::Int __restrict__ &iPos, casacore::Int *__restrict__ inc, casacore::Complex &nvalue, casacore::Double &wt) __restrict__

casacore::Complex	getFrom4DArray (const casacore::Complex __restrict__ &store, const casacore::Int __restrict__ &iPos, const casacore::Vector< casacore::Int > &inc)
	restrict More...

casacore::Complex	getFrom4DArray (const casacore::Complex *__restrict__ &store, const casacore::Vector< casacore::Int > iPos, const casacore::Vector< casacore::Int > &inc)
	restrict More...

casacore::DComplex	getFrom4DArray (const casacore::DComplex __restrict__ &store, const casacore::Int __restrict__ &iPos, const casacore::Vector< casacore::Int > &inc)
	restrict More...

casacore::DComplex	getFrom4DArray (const casacore::DComplex *__restrict__ &store, const casacore::Vector< casacore::Int > iPos, const casacore::Vector< casacore::Int > &inc)
	restrict More...

casacore::Complex	getFrom4DArray (const casacore::Complex __restrict__ &store, const casacore::Int __restrict__ &iPos)
	The following two methods are called in the innermost loop. More...

casacore::DComplex	getFrom4DArray (const casacore::DComplex __restrict__ &store, const casacore::Int __restrict__ &iPos)
	restrict More...

Protected Attributes inherited from casa::VisibilityResamplerBase
casacore::Vector < casacore::Double >	uvwScale_p
	-------------------------—Private parts----------------------------------— More...

casacore::Vector < casacore::Double >	offset_p

casacore::Vector < casacore::Double >	dphase_p

casacore::Vector< casacore::Int >	chanMap_p

casacore::Vector< casacore::Int >	polMap_p

casacore::Matrix < casacore::Double >	spwChanFreq_p

casacore::Matrix < casacore::Double >	spwChanConjFreq_p

CFStore	convFuncStore_p

casacore::Vector< casacore::Int >	inc_p
	casacore::Int inc0_p, inc1_p, inc2_p, inc3_p; More...

casacore::Int *__restrict__	incPtr_p

casacore::Vector< casacore::Int >	cfMap_p

casacore::Vector< casacore::Int >	conjCFMap_p

VBRow2CFMapType	vbRow2CFMap_p

VBRow2CFBMapType	vbRow2CFBMap_p

double	paTolerance_p

Detailed Description

Definition at line 48 of file MultiThreadedVisResampler.h.

Constructor & Destructor Documentation

casa::MultiThreadedVisibilityResampler::MultiThreadedVisibilityResampler ( )

inline

enum VBLoader {NOONE=-1, DATATOGRID=0, GRIDTODATA, RESIDUALCALC};

nelements_p=DEFAULTNOOFCORES;

Definition at line 52 of file MultiThreadedVisResampler.h.

References FTMachineNumThreadsEnvVar, casa::SynthesisUtils::getenv(), and nelements_p.

Referenced by clone().

casa::MultiThreadedVisibilityResampler::MultiThreadedVisibilityResampler	(	const casacore::Bool &	doublePrecision,
		const casacore::Int &	n = `DEFAULTNOOFCORES`
	)

casa::MultiThreadedVisibilityResampler::MultiThreadedVisibilityResampler	(	const casacore::Bool &	doublePrecision,
		casacore::CountedPtr< VisibilityResamplerBase > &	visResampler,
		const casacore::Int &	n = `DEFAULTNOOFCORES`
	)

virtual casa::MultiThreadedVisibilityResampler::~MultiThreadedVisibilityResampler ( )

inlinevirtual

Definition at line 68 of file MultiThreadedVisResampler.h.

References cleanup(), currentVBS_p, and nelements_p.

casa::MultiThreadedVisibilityResampler::MultiThreadedVisibilityResampler ( const MultiThreadedVisibilityResampler & other )

inline

Definition at line 75 of file MultiThreadedVisResampler.h.

References copy().

Member Function Documentation

void casa::MultiThreadedVisibilityResampler::allocateBuffers ( casacore::Bool newDataBuffers = true )

private

template <class t>=""> void GatherGrids_p(const casacore::Array<T>& griddedData, const casacore::Matrix<casacore::Double>& sumwt);

template <class t>=""> void initializeBuffers(const casacore::Array<T>& griddedData, const casacore::Matrix<casacore::Double>& sumwt);

casacore::Double casa::MultiThreadedVisibilityResampler::allocateDataBuffers ( )

private

Referenced by clone().

void casa::MultiThreadedVisibilityResampler::cleanup ( )

Referenced by ~MultiThreadedVisibilityResampler().

MultiThreadedVisibilityResampler* casa::MultiThreadedVisibilityResampler::clone ( )

inlinevirtual

This version will make a clone with shared data buffers (the complex grids and the sum-of-weights arrays).

Allocate a new instance, and copy the internals.

Now reset the data buffers with independent buffers (arrays of size 0)

Implements casa::VisibilityResamplerBase.

Definition at line 79 of file MultiThreadedVisResampler.h.

References allocateDataBuffers(), and MultiThreadedVisibilityResampler().

virtual void casa::MultiThreadedVisibilityResampler::ComputeResiduals ( VBStore & vbs )

virtual

virtual void GridToData(VBStore& vbs, casacore::Array<casacore::Complex>& griddedData);

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::copy ( const MultiThreadedVisibilityResampler & other )

Referenced by MultiThreadedVisibilityResampler().

virtual void casa::MultiThreadedVisibilityResampler::DataToGrid	(	casacore::Array< casacore::DComplex > &	griddedData,
		VBStore &	vbs,
		casacore::Matrix< casacore::Double > &	sumwt,
		const casacore::Bool &	dopsf,
		casacore::Bool	= `false`
	)

inlinevirtual

Re-sample the griddedData on the VisBuffer (a.k.a gridding).

In this class, these just call the private templated version. The first variant grids onto a double precision grid while the second one does it on a single precision grid.

Implements casa::VisibilityResamplerBase.

Definition at line 116 of file MultiThreadedVisResampler.h.

References DataToGridImpl_p().

virtual void casa::MultiThreadedVisibilityResampler::DataToGrid	(	casacore::Array< casacore::Complex > &	griddedData,
		VBStore &	vbs,
		casacore::Matrix< casacore::Double > &	sumwt,
		const casacore::Bool &	dopsf,
		casacore::Bool	= `false`
	)

inlinevirtual

Implements casa::VisibilityResamplerBase.

Definition at line 122 of file MultiThreadedVisResampler.h.

References DataToGridImpl_p().

template<class T >

void casa::MultiThreadedVisibilityResampler::DataToGridImpl_p	(	casacore::Array< T > &	griddedData,
		VBStore &	vb,
		casacore::Matrix< casacore::Double > &	sumwt,
		const casacore::Bool &	dopsf,
		casacore::Bool	useConjFreqCF = `false`
	)

private

-------------------------—Private parts----------------------------------—

Referenced by DataToGrid().

void casa::MultiThreadedVisibilityResampler::GatherGrids	(	casacore::Array< casacore::DComplex > &	griddedData,
		casacore::Matrix< casacore::Double > &	sumwt
	)

virtual

This is the gather operation on griddedData for nelements > 1.

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::GatherGrids	(	casacore::Array< casacore::Complex > &	griddedData,
		casacore::Matrix< casacore::Double > &	sumwt
	)

virtual

Implements casa::VisibilityResamplerBase.

virtual void casa::MultiThreadedVisibilityResampler::GridToData	(	VBStore &	vbs,
		const casacore::Array< casacore::Complex > &	griddedData
	)

virtual

Re-sample VisBuffer to a regular grid (griddedData) (a.k.a. de-gridding)

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::init ( const casacore::Bool & doublePrecision )

virtual

Forward looking genealogical baggage – required for the MultiThreadedVisibilityResampler.

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::initializeDataBuffers ( VBStore & )

inlinevirtual

Implements casa::VisibilityResamplerBase.

Definition at line 139 of file MultiThreadedVisResampler.h.

void casa::MultiThreadedVisibilityResampler::initializePutBuffers	(	const casacore::Array< casacore::DComplex > &	griddedData,
		const casacore::Matrix< casacore::Double > &	sumwt
	)

virtual

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::initializePutBuffers	(	const casacore::Array< casacore::Complex > &	griddedData,
		const casacore::Matrix< casacore::Double > &	sumwt
	)

virtual

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::makeInfrastructureContainers ( )

private

virtual casacore::Int casa::MultiThreadedVisibilityResampler::nelements ( )

inlinevirtual

Definition at line 96 of file MultiThreadedVisResampler.h.

References nelements_p.

MultiThreadedVisibilityResampler& casa::MultiThreadedVisibilityResampler::operator= ( const MultiThreadedVisibilityResampler & other )

void casa::MultiThreadedVisibilityResampler::releaseBuffers ( )

virtual

Implements casa::VisibilityResamplerBase.

void casa::MultiThreadedVisibilityResampler::scatter	(	casacore::Matrix< VBStore > &	vbsStores,
		const VBStore &	vbs
	)

private

virtual void casa::MultiThreadedVisibilityResampler::setCFMaps	(	const casacore::Vector< casacore::Int > &	cfMap,
		const casacore::Vector< casacore::Int > &	conjCFMap
	)

virtual

Implements casa::VisibilityResamplerBase.

virtual void casa::MultiThreadedVisibilityResampler::setConvFunc ( const CFStore & cfs )

virtual

Implements casa::VisibilityResamplerBase.

virtual void casa::MultiThreadedVisibilityResampler::setFreqMaps	(	const casacore::Matrix< casacore::Double > &	spwChanFreqs,
		const casacore::Matrix< casacore::Double > &	spwChanConjFreqs
	)

virtual

Implements casa::VisibilityResamplerBase.

virtual void casa::MultiThreadedVisibilityResampler::setMaps	(	const casacore::Vector< casacore::Int > &	chanMap,
		const casacore::Vector< casacore::Int > &	polMap
	)

virtual

Implements casa::VisibilityResamplerBase.

virtual void casa::MultiThreadedVisibilityResampler::setParams	(	const casacore::Vector< casacore::Double > &	uvwScale,
		const casacore::Vector< casacore::Double > &	offset,
		const casacore::Vector< casacore::Double > &	dphase
	)