#include <VisibilityIteratorImplAsync.h>

Inheritance diagram for casa::ViReadImplAsync:

Public Types
typedef casa::asyncio::PrefetchColumns	PrefetchColumns
Public Member Functions
	ViReadImplAsync (const Block< MeasurementSet > &mss, const PrefetchColumns &prefetchColumns, const Block< Int > &sortColumns, const Bool addDefaultSortCols, Double timeInterval, Bool writable)
	static VisibilityIteratorReadImpl * create (const ROVisibilityIterator &, const PrefetchColumns & prefetchColumns, Int nReadAheadBuffers = -1);
	ViReadImplAsync (const PrefetchColumns &prefetchColumns, const VisibilityIteratorReadImpl &other, Bool writable)
	~ViReadImplAsync ()
VisibilityIteratorReadImpl *	clone () const
void	attachVisBuffer (VisBuffer &vb)
	Attach a VisBuffer object.
void	detachVisBuffer (VisBuffer &vb)
	Detach a VisBuffer object.
void	getChannelSelection (Block< Vector< Int > > &, Block< Vector< Int > > &, Block< Vector< Int > > &, Block< Vector< Int > > &, Block< Vector< Int > > &)
	get the channel selection ...the block over the number of ms's associated with this iterator
PrefetchColumns	getPrefetchColumns () const
VisBuffer *	getVisBuffer ()
MEpoch	getEpoch () const
	Int getDataDescriptionId () const; const MeasurementSet & getMeasurementSet(); const Int getMeasurementSetId (); Int getNAntennas () const;.
bool	more () const
	Vector<Float> getReceptor0Angle ();.
bool	moreChunks () const
	Return False if no more 'Chunks' of data left.
ViReadImplAsync &	nextChunk ()
	Advance to the next Chunk of data.
void	origin ()
	Reset iterator to origin/start of data (of current chunk)
void	originChunks ()
	Reset iterator to true start of data (first chunk)
virtual void	advance ()
	advance the iteration
void	setPrefetchColumns (const PrefetchColumns &prefetchColumns)
VisibilityIteratorReadImpl &	selectChannel (Int nGroup=1, Int start=0, Int width=0, Int increment=1, Int spectralWindow=-1)
	Channel selection - only the selected channels will be returned by the access functions.
VisibilityIteratorReadImpl &	selectChannel (const Block< Vector< Int > > &blockNGroup, const Block< Vector< Int > > &blockStart, const Block< Vector< Int > > &blockWidth, const Block< Vector< Int > > &blockIncr, const Block< Vector< Int > > &blockSpw)
	Same as above except when multiple ms's are to be accessed.
VisibilityIteratorReadImpl &	selectVelocity (Int, const MVRadialVelocity &, const MVRadialVelocity &, MRadialVelocity::Types, MDoppler::Types, Bool)
	Velocity selection - specify the output channels in velocity: nChan - number of output channels, vStart - start velocity, vInc - velocity increment.
void	setInterval (Double timeInterval)
	Set or reset the time interval (in seconds) to use for iteration.
void	setRowBlocking (Int nRow)
	Set the 'blocking' size for returning data.
Bool	allBeamOffsetsZero () const
	The functions below make no sense (at first glance) for asynchronous operation and are implemented to throw an AipsError if called.
void	allSelectedSpectralWindows (Vector< Int > &, Vector< Int > &)
	get back the selected spectral windows and spectral channels for current ms
Vector< Int > &	antenna1 (Vector< Int > &) const
	Return antenna1.
Vector< Int > &	antenna2 (Vector< Int > &) const
	Return antenna2.
const Vector< String > &	antennaMounts () const
	return a string mount identifier for each antenna
Vector< MDirection >	azel (Double) const
MDirection	azel0 (Double) const
	Return the antenna AZ/EL Vector (nant)
Vector< Int > &	channel (Vector< Int > &) const
	Return channel numbers in selected VisSet spectrum (i.e.
Int	channelGroupSize () const
	Return the width of the current group of channels, i.e., the number of channels returned by visibility () and frequency ().
Int	channelIndex () const
	Return the index of the first channel of the current channel group in the total (selected) spectrum.
Vector< SquareMatrix< Complex, 2 > > &	CJones (Vector< SquareMatrix< Complex, 2 > > &) const
	Return feed configuration matrix for specified antenna.
Vector< Int > &	corrType (Vector< Int > &) const
	Return the correlation type (returns Stokes enums)
Int	dataDescriptionId () const
	Return current DataDescription Id.
Bool	existsWeightSpectrum () const
	Determine whether WEIGHT_SPECTRUM exists.
Vector< Double > &	exposure (Vector< Double > &) const
	Return actual time interval.
Vector< Int > &	feed1 (Vector< Int > &) const
	Return feed1.
Vector< Int > &	feed2 (Vector< Int > &) const
	Return feed2.
Int	fieldId () const
	Vector<Float> feed_pa(Double ) const { NotImplementedROVIA; }.
Array< Bool > &	flagCategory (Array< Bool > &) const
	Return flags for each polarization, channel, category, and row.
Cube< Float > &	floatData (Cube< Float > &) const
	Return FLOAT_DATA as a Cube (npol, nchan, nrow) if found in the MS.
void	getFloatDataColumn (Cube< Float > &) const
void	getFloatDataColumn (const Slicer &, Cube< Float > &) const
	get FLOAT_DATA as real Floats.
void	getInterpolatedFloatDataFlagWeight () const
void	getInterpolatedVisFlagWeight (DataColumn) const
Int	arrayId () const
	Return the current ArrayId.
String	fieldName () const
	Return the current Field Name.
String	sourceName () const
	Return the current Source Name.
Cube< Bool > &	flag (Cube< Bool > &) const
	Return flag for each polarization, channel and row.
Matrix< Bool > &	flag (Matrix< Bool > &) const
	Return flag for each channel & row.
Vector< Bool > &	flagRow (Vector< Bool > &) const
	Return row flag.
Vector< Double > &	frequency (Vector< Double > &) const
	Return current frequencies (in Hz, acc.
const Cube< RigidVector < Double, 2 > > &	getBeamOffsets () const
	Return a cube containing pairs of coordinate offsets for each receptor of each feed (values are in radians, coordinate system is fixed with antenna and is the same one as used to define the BEAM_OFFSET parameter in the feed table).
Int	getDataDescriptionId () const
MEpoch	getMEpoch () const
const MeasurementSet &	getMeasurementSet () const
Int	getMeasurementSetId () const
Int	getNAntennas () const
Vector< Float >	getReceptor0Angle ()
Vector< uInt >	getRowIds () const
Double	hourang (Double) const
	Return the hour angle for the specified time.
Vector< Double > &	lsrFrequency (Vector< Double > &) const
	Return frequencies (in Hz, acc.
void	lsrFrequency (const Int &, Vector< Double > &, Bool &)
const MeasurementSet &	ms () const
	reference to actual ms in interator
const ROMSColumns &	msColumns () const
	Access the current ROMSColumns object in MSIter.
Int	msId () const
Int	nCorr () const
	Return the number of correlations in the current iteration.
Int	nRow () const
	Return the number of rows in the current iteration.
Int	nRowChunk () const
	Return the numbers of rows in the current chunk.
Int	nSubInterval () const
	Return the number of sub-intervals in the current chunk.
Bool	newArrayId () const
	Return True if arrayID has changed since last iteration.
Bool	newFieldId () const
	Return True if FieldId/Source has changed since last iteration.
Bool	newMS () const
	Check if ms has change since last iteration.
Bool	newSpectralWindow () const
	Return True if SpectralWindow has changed since last iteration.
Int	numberCoh ()
	Return number of rows in all selected ms's.
Int	numberDDId ()
Int	numberPol ()
Int	numberSpw ()
	Return number of spws, polids, ddids.
Vector< Int > &	observationId (Vector< Int > &) const
	Return the OBSERVATION_IDs.
Vector< Float >	parang (Double) const
	Per antenna:
const Float &	parang0 (Double) const
	Return nominal parallactic angle at specified time (does not include feed position angle offset--see feed_pa) A global value for all antennas (e.g., small array)
const MDirection &	phaseCenter () const
	Return the current phase center as an MDirection.
Int	polFrame () const
	Return frame for polarization (returns PolFrame enum)
Vector< Int > &	processorId (Vector< Int > &) const
	Return the PROCESSOR_IDs.
Int	polarizationId () const
	Return current Polarization Id.
const Cube< Double > &	receptorAngles () const
	Return receptor angles for all antennae and feeds First axis of the cube is a receptor number, 2nd is antennaId, 3rd is feedId Note: the method is intended to provide an access to MSIter::receptorAngles for VisBuffer in the multi-feed case.
Vector< uInt > &	rowIds (Vector< uInt > &) const
	Return the row ids as from the original root table.
Vector< Int > &	scan (Vector< Int > &) const
	Return scan number.
Vector< Float > &	sigma (Vector< Float > &) const
	Return sigma.
Matrix< Float > &	sigmaMat (Matrix< Float > &) const
	Return sigma matrix (pol-dep)
void	slurp () const
	Call to use the slurp i/o method for all scalar columns.
Int	spectralWindow () const
	Return current SpectralWindow.
Vector< Int > &	stateId (Vector< Int > &) const
	Return the STATE_IDs.
Vector< Double > &	time (Vector< Double > &) const
	Return MJD midpoint of interval.
Vector< Double > &	timeCentroid (Vector< Double > &) const
	Return MJD centroid of interval.
Vector< Double > &	timeInterval (Vector< Double > &) const
	Return nominal time interval.
Vector< RigidVector< Double, 3 > > &	uvw (Vector< RigidVector< Double, 3 > > &) const
	Return u,v and w (in meters)
Matrix< Double > &	uvwMat (Matrix< Double > &) const
VisibilityIteratorReadImpl &	velInterpolation (const String &)
	Select the velocity interpolation scheme.
Cube< Complex > &	visibility (Cube< Complex > &, DataColumn) const
	Return the visibilities as found in the MS, Cube (npol,nchan,nrow).
Matrix< CStokesVector > &	visibility (Matrix< CStokesVector > &, DataColumn) const
	Return the visibility 4-vector of polarizations for each channel.
IPosition	visibilityShape () const
	Return the shape of the visibility Cube.
Vector< Float > &	weight (Vector< Float > &) const
	Return weight.
Matrix< Float > &	weightMat (Matrix< Float > &) const
	Returns the nPol_p x curNumRow_p weight matrix.
Cube< Float > &	weightSpectrum (Cube< Float > &) const
	Return weightspectrum (a weight for each channel)
Static Public Member Functions
static int	getDefaultNBuffers ()
	These functions generate a list of the IDs (from PrefetchColumnIDs enum) of the columns to prefetch.
static String	prefetchColumnName (Int id)
Protected Member Functions
	ViReadImplAsync (const ROVisibilityIterator &rovi, const PrefetchColumns &prefetchColumns, Int nReadAheadBuffers=-1)
	Use the factory method "create" instead of calling the constructor directly.
PrefetchColumns	augmentPrefetchColumns (const PrefetchColumns &prefetchColumnsBase)
void	construct (const Block< MeasurementSet > &mss, const PrefetchColumns &prefetchColumns, const Block< Int > &sortColumns, const Bool addDefaultSortCols, Double timeInterval, Bool writable)
void	fillVisBuffer ()
const MeasurementSet &	getMs () const
void	readComplete ()
void	saveMss (const Block< MeasurementSet > &mss)
void	saveMss (const MeasurementSet &ms)
Private Member Functions
void	dumpPrefetchColumns () const
void	updateMsd ()
	ViReadImplAsync (const ViReadImplAsync &MSI)
ViReadImplAsync &	operator= (const ViReadImplAsync &MSI)
Private Attributes
asyncio::AsynchronousInterface *	interface_p
	void startVlat ();
Int	msId_p
PrefetchColumns	prefetchColumns_p
Stack< VisBufferAsyncWrapper * >	vbaWrapperStack_p
VisBufferAsync *	visBufferAsync_p
asyncio::VlaData *	vlaData_p
asyncio::VLAT *	vlat_p
Friends
class	Rovia_Test
	This needs to be changed back to ROVisibilityIterator at some point after feasibility testing.
class	ROVisIterator
class	VisIterator
class	ViWriteImplAsync

Detailed Description

Definition at line 36 of file VisibilityIteratorImplAsync.h.

Member Typedef Documentation

typedef casa::asyncio::PrefetchColumns casa::ViReadImplAsync::PrefetchColumns

Definition at line 47 of file VisibilityIteratorImplAsync.h.

Constructor & Destructor Documentation

casa::ViReadImplAsync::ViReadImplAsync	(	const Block< MeasurementSet > &	mss,
		const PrefetchColumns &	prefetchColumns,
		const Block< Int > &	sortColumns,
		const Bool	addDefaultSortCols,
		Double	timeInterval,
		Bool	writable
	)

static VisibilityIteratorReadImpl * create (const ROVisibilityIterator &, const PrefetchColumns & prefetchColumns, Int nReadAheadBuffers = -1);

casa::ViReadImplAsync::ViReadImplAsync	(	const PrefetchColumns &	prefetchColumns,
		const VisibilityIteratorReadImpl &	other,
		Bool	writable
	)

casa::ViReadImplAsync::~ViReadImplAsync ( )

casa::ViReadImplAsync::ViReadImplAsync	(	const ROVisibilityIterator &	rovi,
		const PrefetchColumns &	prefetchColumns,
		Int	nReadAheadBuffers = `-1`
	)		`[protected]`

Use the factory method "create" instead of calling the constructor directly.

This allows disabling the feature.

 ViReadImplAsync (const MeasurementSet & ms,
                  const PrefetchColumns & prefetchColumns,
                  const Block<Int> & sortColumns,
                  Double timeInterval=0,
                  Int nReadAheadBuffers = 2);
 ViReadImplAsync (const MeasurementSet & ms,
                  const PrefetchColumns & prefetchColumns,
                  const Block<Int> & sortColumns,
                  const Bool addDefaultSortCols,
                  Double timeInterval=0,
                  Int nReadAheadBuffers = 2);

Same as previous constructor, but with multiple MSs to iterate over.

   ViReadImplAsync (const Block<MeasurementSet> & mss,
                    const PrefetchColumns & prefetchColumns,
                    const Block<Int> & sortColumns,
                    Double timeInterval=0,
                    Int nReadAheadBuffers = 2);

casa::ViReadImplAsync::ViReadImplAsync ( const ViReadImplAsync & MSI ) [private]

Member Function Documentation

virtual void casa::ViReadImplAsync::advance ( ) [virtual]

advance the iteration

Reimplemented from casa::VisibilityIteratorReadImpl.

Bool casa::ViReadImplAsync::allBeamOffsetsZero ( ) const [virtual]

The functions below make no sense (at first glance) for asynchronous operation and are implemented to throw an AipsError if called.

ROVIA is designed to have all the data accessed through the associated VisBufferAsync. Any method which tries to access data through the ROVIA makes no sense. Also anything that tries to change the characteristics of underlying ROVI is not currently permitted. During integration some methods may be found to be more important to the use of ROVIA and a way may be found to implement them in ROVIA.

Reimplemented from casa::VisibilityIteratorReadImpl.

void casa::ViReadImplAsync::allSelectedSpectralWindows	(	Vector< Int > &	spws,
		Vector< Int > &	nvischan
	)		`[inline, virtual]`

get back the selected spectral windows and spectral channels for current ms

Reimplemented from casa::VisibilityIteratorReadImpl.

Definition at line 135 of file VisibilityIteratorImplAsync.h.

void casa::ViReadImplAsync::construct	(	const Block< MeasurementSet > &	mss,
		const PrefetchColumns &	prefetchColumns,
		const Block< Int > &	sortColumns,
		const Bool	addDefaultSortCols,
		Double	timeInterval,
		Bool	writable
	)		`[protected]`

void casa::ViReadImplAsync::getChannelSelection	(	Block< Vector< Int > > &	blockNGroup,
		Block< Vector< Int > > &	blockStart,
		Block< Vector< Int > > &	blockWidth,
		Block< Vector< Int > > &	blockIncr,
		Block< Vector< Int > > &	blockSpw
	)		`[virtual]`

void casa::ViReadImplAsync::getFloatDataColumn	(	const Slicer &	slicer,
		Cube< Float > &	data
	)		const `[inline, virtual]`

void casa::ViReadImplAsync::lsrFrequency	(	const Int &	,
		Vector< Double > &	,
		Bool &
	)		`[inline]`

VisibilityIteratorReadImpl& casa::ViReadImplAsync::selectChannel	(	Int	nGroup = `1`,
		Int	start = `0`,
		Int	width = `0`,
		Int	increment = `1`,
		Int	spectralWindow = `-1`
	)		`[virtual]`

VisibilityIteratorReadImpl& casa::ViReadImplAsync::selectChannel	(	const Block< Vector< Int > > &	blockNGroup,
		const Block< Vector< Int > > &	blockStart,
		const Block< Vector< Int > > &	blockWidth,
		const Block< Vector< Int > > &	blockIncr,
		const Block< Vector< Int > > &	blockSpw
	)		`[virtual]`

VisibilityIteratorReadImpl& casa::ViReadImplAsync::selectVelocity	(	Int	nChan,
		const MVRadialVelocity &	vStart,
		const MVRadialVelocity &	vInc,
		MRadialVelocity::Types	rvType,
		MDoppler::Types	dType,
		Bool	precise
	)		`[virtual]`

Cube<Complex>& casa::ViReadImplAsync::visibility	(	Cube< Complex > &	vis,
		DataColumn	whichOne
	)		const `[inline, virtual]`

Matrix<CStokesVector>& casa::ViReadImplAsync::visibility	(	Matrix< CStokesVector > &	vis,
		DataColumn	whichOne
	)		const `[inline, virtual]`

Public Types

Public Member Functions

Static Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Friends And Related Function Documentation

Member Data Documentation