CReadDispatcher Class Reference

Search Toolkit Book for CReadDispatcher

#include <objtools/data_loaders/genbank/impl/dispatcher.hpp>

Inheritance diagram for CReadDispatcher:

Collaboration diagram for CReadDispatcher:

Public Types
typedef CReader::TContentsMask	TContentsMask
typedef CReader::TBlobState	TBlobState
typedef CReader::TBlobVersion	TBlobVersion
typedef CReader::TBlobId	TBlobId
typedef CReader::TChunkId	TChunkId
typedef CReader::TChunkIds	TChunkIds
typedef size_t	TLevel
typedef vector< CSeq_id_Handle >	TIds
typedef vector< bool >	TLoaded
typedef vector< bool >	TKnown
typedef vector< TIds >	TBulkIds
typedef vector< TGi >	TGis
typedef vector< string >	TLabels
typedef vector< TTaxId >	TTaxIds
typedef vector< int >	THashes
typedef vector< TSeqPos >	TLengths
typedef vector< CSeq_inst::EMol >	TTypes
typedef vector< TBlobState >	TStates
typedef vector< CBlob_id >	TBlobIds
typedef vector< CBlob_Info >	TBlobInfos
typedef vector< pair< CBlob_id, TChunkIds > >	TBlobChunkIds
Public Types inherited from CObject
enum	EAllocFillMode { eAllocFillNone = 1 , eAllocFillZero , eAllocFillPattern }
	Control filling of newly allocated memory. More...
typedef CObjectCounterLocker	TLockerType
	Default locker type for CRef. More...
typedef atomic< Uint8 >	TCounter
	Counter type is CAtomiCounter. More...
typedef Uint8	TCount
	Alias for value type of counter. More...

Public Member Functions
	CReadDispatcher (void)
	~CReadDispatcher (void)
void	InsertReader (TLevel level, CRef< CReader > reader)
void	InsertWriter (TLevel level, CRef< CWriter > writer)
void	InsertProcessor (CRef< CProcessor > processor)
bool	HasReaderWithHUPIncluded () const
CWriter *	GetWriter (const CReaderRequestResult &result, CWriter::EType type) const
const CProcessor &	GetProcessor (CProcessor::EType type) const
void	LoadSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel)
void	LoadSeq_idSeq_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSeq_idGi (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSeq_idAccVer (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSeq_idLabel (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSeq_idTaxId (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSequenceHash (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSequenceLength (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadSequenceType (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
void	LoadBulkIds (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TBulkIds &ret)
void	LoadAccVers (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TIds &ret)
void	LoadGis (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TGis &ret)
void	LoadLabels (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TLabels &ret)
void	LoadTaxIds (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TTaxIds &ret)
void	LoadHashes (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, THashes &ret, TKnown &known)
void	LoadLengths (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TLengths &ret)
void	LoadTypes (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TTypes &ret)
void	LoadStates (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TStates &ret)
void	LoadBlobState (CReaderRequestResult &result, const TBlobId &blob_id)
void	LoadBlobVersion (CReaderRequestResult &result, const TBlobId &blob_id, const CReader *asking_reader=0)
void	LoadBlobs (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, TContentsMask mask, const SAnnotSelector *sel)
void	LoadBlobs (CReaderRequestResult &result, const CLoadLockBlobIds &blobs, TContentsMask mask, const SAnnotSelector *sel)
void	LoadBlob (CReaderRequestResult &result, const CBlob_id &blob_id)
void	LoadBlob (CReaderRequestResult &result, const CBlob_Info &blob_info)
void	LoadChunk (CReaderRequestResult &result, const TBlobId &blob_id, TChunkId chunk_id)
void	LoadChunks (CReaderRequestResult &result, const TBlobId &blob_id, const TChunkIds &chunk_ids)
void	LoadChunks (CReaderRequestResult &result, const TBlobChunkIds &chunk_ids)
void	LoadBlobSet (CReaderRequestResult &result, const TIds &seq_ids)
void	LoadBlobs (CReaderRequestResult &result, const TBlobInfos &blob_infos)
void	CheckReaders (void) const
void	Process (CReadDispatcherCommand &command, const CReader *asking_reader=0)
void	ResetCaches (void)
Public Member Functions inherited from CObject
	CObject (void)
	Constructor. More...
	CObject (const CObject &src)
	Copy constructor. More...
virtual	~CObject (void)
	Destructor. More...
CObject &	operator= (const CObject &src) THROWS_NONE
	Assignment operator. More...
bool	CanBeDeleted (void) const THROWS_NONE
	Check if object can be deleted. More...
bool	IsAllocatedInPool (void) const THROWS_NONE
	Check if object is allocated in memory pool (not system heap) More...
bool	Referenced (void) const THROWS_NONE
	Check if object is referenced. More...
bool	ReferencedOnlyOnce (void) const THROWS_NONE
	Check if object is referenced only once. More...
void	AddReference (void) const
	Add reference to object. More...
void	RemoveReference (void) const
	Remove reference to object. More...
void	ReleaseReference (void) const
	Remove reference without deleting object. More...
virtual void	DoNotDeleteThisObject (void)
	Mark this object as not allocated in heap – do not delete this object. More...
virtual void	DoDeleteThisObject (void)
	Mark this object as allocated in heap – object can be deleted. More...
void *	operator new (size_t size)
	Define new operator for memory allocation. More...
void *	operator new[] (size_t size)
	Define new[] operator for 'array' memory allocation. More...
void	operator delete (void *ptr)
	Define delete operator for memory deallocation. More...
void	operator delete[] (void *ptr)
	Define delete[] operator for memory deallocation. More...
void *	operator new (size_t size, void *place)
	Define new operator. More...
void	operator delete (void *ptr, void *place)
	Define delete operator. More...
void *	operator new (size_t size, CObjectMemoryPool *place)
	Define new operator using memory pool. More...
void	operator delete (void *ptr, CObjectMemoryPool *place)
	Define delete operator. More...
virtual void	DebugDump (CDebugDumpContext ddc, unsigned int depth) const
	Define method for dumping debug information. More...
Public Member Functions inherited from CDebugDumpable
	CDebugDumpable (void)
virtual	~CDebugDumpable (void)
void	DebugDumpText (ostream &out, const string &bundle, unsigned int depth) const
void	DebugDumpFormat (CDebugDumpFormatter &ddf, const string &bundle, unsigned int depth) const
void	DumpToConsole (void) const

Static Public Member Functions
static bool	CannotProcess (const CSeq_id_Handle &sih)
static bool	SetBlobState (size_t i, CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TStates &ret)
static int	CollectStatistics (void)
static void	LogStat (CReadDispatcherCommand &command, CReaderRequestResultRecursion &recursion)
static void	LogStat (CReadDispatcherCommand &command, CReaderRequestResultRecursion &recursion, double size)
Static Public Member Functions inherited from CObject
static NCBI_XNCBI_EXPORT void	ThrowNullPointerException (void)
	Define method to throw null pointer exception. More...
static NCBI_XNCBI_EXPORT void	ThrowNullPointerException (const type_info &type)
static EAllocFillMode	GetAllocFillMode (void)
static void	SetAllocFillMode (EAllocFillMode mode)
static void	SetAllocFillMode (const string &value)
	Set mode from configuration parameter value. More...
Static Public Member Functions inherited from CDebugDumpable
static void	EnableDebugDump (bool on)

Private Types
typedef map< TLevel, CRef< CReader > >	TReaders
typedef map< TLevel, CRef< CWriter > >	TWriters
typedef map< CProcessor::EType, CRef< CProcessor > >	TProcessors

Private Attributes
TReaders	m_Readers
TWriters	m_Writers
TProcessors	m_Processors

Additional Inherited Members
Static Public Attributes inherited from CObject
static const TCount	eCounterBitsCanBeDeleted = 1 << 0
	Define possible object states. More...
static const TCount	eCounterBitsInPlainHeap = 1 << 1
	Heap signature was found. More...
static const TCount	eCounterBitsPlaceMask
	Mask for 'in heap' state flags. More...
static const int	eCounterStep = 1 << 2
	Skip over the "in heap" bits. More...
static const TCount	eCounterValid = TCount(1) << (sizeof(TCount) * 8 - 2)
	Minimal value for valid objects (reference counter is zero) Must be a single bit value. More...
static const TCount	eCounterStateMask
	Valid object, and object in heap. More...
Protected Member Functions inherited from CObject
virtual void	DeleteThis (void)
	Virtual method "deleting" this object. More...

Detailed Description

Definition at line 59 of file dispatcher.hpp.

Member Typedef Documentation

TBlobChunkIds

typedef vector<pair<CBlob_id, TChunkIds> > CReadDispatcher::TBlobChunkIds

Definition at line 119 of file dispatcher.hpp.

TBlobId

typedef CReader::TBlobId CReadDispatcher::TBlobId

Definition at line 65 of file dispatcher.hpp.

TBlobIds

typedef vector<CBlob_id> CReadDispatcher::TBlobIds

Definition at line 117 of file dispatcher.hpp.

TBlobInfos

typedef vector<CBlob_Info> CReadDispatcher::TBlobInfos

Definition at line 118 of file dispatcher.hpp.

TBlobState

typedef CReader::TBlobState CReadDispatcher::TBlobState

Definition at line 63 of file dispatcher.hpp.

TBlobVersion

typedef CReader::TBlobVersion CReadDispatcher::TBlobVersion

Definition at line 64 of file dispatcher.hpp.

TBulkIds

typedef vector<TIds> CReadDispatcher::TBulkIds

Definition at line 109 of file dispatcher.hpp.

TChunkId

typedef CReader::TChunkId CReadDispatcher::TChunkId

Definition at line 66 of file dispatcher.hpp.

TChunkIds

typedef CReader::TChunkIds CReadDispatcher::TChunkIds

Definition at line 67 of file dispatcher.hpp.

TContentsMask

typedef CReader::TContentsMask CReadDispatcher::TContentsMask

Definition at line 62 of file dispatcher.hpp.

TGis

typedef vector<TGi> CReadDispatcher::TGis

Definition at line 110 of file dispatcher.hpp.

THashes

typedef vector<int> CReadDispatcher::THashes

Definition at line 113 of file dispatcher.hpp.

TIds

typedef vector<CSeq_id_Handle> CReadDispatcher::TIds

Definition at line 69 of file dispatcher.hpp.

TKnown

typedef vector<bool> CReadDispatcher::TKnown

Definition at line 108 of file dispatcher.hpp.

TLabels

typedef vector<string> CReadDispatcher::TLabels

Definition at line 111 of file dispatcher.hpp.

TLengths

typedef vector<TSeqPos> CReadDispatcher::TLengths

Definition at line 114 of file dispatcher.hpp.

TLevel

typedef size_t CReadDispatcher::TLevel

Definition at line 68 of file dispatcher.hpp.

TLoaded

typedef vector<bool> CReadDispatcher::TLoaded

Definition at line 107 of file dispatcher.hpp.

TProcessors

typedef map< CProcessor::EType, CRef<CProcessor> > CReadDispatcher::TProcessors

private

Definition at line 189 of file dispatcher.hpp.

TReaders

typedef map< TLevel, CRef<CReader> > CReadDispatcher::TReaders

private

Definition at line 187 of file dispatcher.hpp.

TStates

typedef vector<TBlobState> CReadDispatcher::TStates

Definition at line 116 of file dispatcher.hpp.

TTaxIds

typedef vector<TTaxId> CReadDispatcher::TTaxIds

Definition at line 112 of file dispatcher.hpp.

TTypes

typedef vector<CSeq_inst::EMol> CReadDispatcher::TTypes

Definition at line 115 of file dispatcher.hpp.

TWriters

typedef map< TLevel, CRef<CWriter> > CReadDispatcher::TWriters

private

Definition at line 188 of file dispatcher.hpp.

Constructor & Destructor Documentation

CReadDispatcher()

CReadDispatcher::CReadDispatcher

(

void

)

Definition at line 158 of file dispatcher.cpp.

References CollectStatistics(), and CProcessor::RegisterAllProcessors().

~CReadDispatcher()

CReadDispatcher::~CReadDispatcher

(

void

)

Definition at line 165 of file dispatcher.cpp.

References CollectStatistics(), and CGBRequestStatistics::PrintStatistics().

Member Function Documentation

CannotProcess()

bool CReadDispatcher::CannotProcess ( const CSeq_id_Handle &  sih )

static

Definition at line 261 of file dispatcher.cpp.

References CSeq_id_Base::e_General, CSeq_id_Base::e_Local, NStr::EqualNocase(), CDbtag_Base::GetDb(), CSeq_id_Base::GetGeneral(), CSeq_id_Handle::GetSeqId(), and CSeq_id_Handle::Which().

Referenced by CGBDataLoader_Native::GetAccVerFound(), CGBDataLoader_Native::GetAccVers(), CGBDataLoader_Native::GetBlobId(), CGBDataLoader_Native::GetBlobs(), CGBDataLoader_Native::GetBulkIds(), CGBDataLoader_Native::GetCDDAnnots(), CGBDataLoader_Native::GetGiFound(), CGBDataLoader_Native::GetGis(), CGBDataLoader_Native::GetIds(), CGBDataLoader_Native::GetLabel(), CGBDataLoader_Native::GetLabels(), CGBDataLoader_Native::GetSequenceHashes(), CGBDataLoader_Native::GetSequenceHashFound(), CGBDataLoader_Native::GetSequenceLength(), CGBDataLoader_Native::GetSequenceLengths(), CGBDataLoader_Native::GetSequenceState(), CGBDataLoader_Native::GetSequenceStates(), CGBDataLoader_Native::GetSequenceTypeFound(), CGBDataLoader_Native::GetSequenceTypes(), CGBDataLoader_Native::GetTaxId(), CGBDataLoader_Native::GetTaxIds(), CCacheReader::LoadAccVers(), CId2ReaderBase::LoadAccVers(), CReader::LoadAccVers(), CId2ReaderBase::LoadBulkIds(), CReader::LoadBulkIds(), CCacheReader::LoadGis(), CId2ReaderBase::LoadGis(), CReader::LoadGis(), CId2ReaderBase::LoadHashes(), CReader::LoadHashes(), CCacheReader::LoadLabels(), CId2ReaderBase::LoadLabels(), CReader::LoadLabels(), CId2ReaderBase::LoadLengths(), CReader::LoadLengths(), CReader::LoadStates(), CCacheReader::LoadTaxIds(), CId2ReaderBase::LoadTaxIds(), CReader::LoadTaxIds(), CId2ReaderBase::LoadTypes(), CReader::LoadTypes(), SetBlobState(), and CGBDataLoader_Native::x_GetRecords().

CheckReaders()

void CReadDispatcher::CheckReaders

(

void

)

const

Definition at line 231 of file dispatcher.cpp.

References map_checker< Container >::empty(), m_Readers, and NCBI_THROW.

Referenced by Process().

CollectStatistics()

int CReadDispatcher::CollectStatistics ( void  )

inlinestatic

Definition at line 151 of file dispatcher.cpp.

References NCBI_PARAM_TYPE, and ncbi::grid::netcache::search::s_Value().

Referenced by CReadDispatcher(), LogStat(), and ~CReadDispatcher().

GetProcessor()

const CProcessor & CReadDispatcher::GetProcessor

(

CProcessor::EType

type

)

const

Definition at line 219 of file dispatcher.cpp.

References map_checker< Container >::end(), map_checker< Container >::find(), m_Processors, and NCBI_THROW_FMT.

Referenced by CId1Reader::GetBlob(), CPubseqReader::GetBlob(), CId1ReaderBase::LoadBlob(), CId2ReaderBase::LoadBlob(), CId2ReaderBase::LoadBlobs(), CSplitCacheApp::ProcessBlob(), CProcessor_ID2::ProcessData(), CSplitCacheApp::ProcessEntry(), CProcessor_ID1_SNP::ProcessObjStream(), CProcessor_SE::ProcessObjStream(), CProcessor_SE_SNP::ProcessObjStream(), CProcessor_St_SE::ProcessObjStream(), CCacheReader::x_ProcessBlob(), CId2ReaderBase::x_ProcessGetBlob(), CId2ReaderBase::x_ProcessGetChunk(), and CId2ReaderBase::x_ProcessGetSplitInfo().

GetWriter()

CWriter * CReadDispatcher::GetWriter	(	const CReaderRequestResult &	result,
		CWriter::EType	type
	)		const

Definition at line 204 of file dispatcher.cpp.

References i, ITERATE, m_Writers, and result.

Referenced by CReaderRequestResult::GetBlobWriter(), CReaderRequestResult::GetIdWriter(), CProcessor::GetWriter(), CId2ReaderBase::LoadBlobs(), CSplitCacheApp::ProcessBlob(), CSplitCacheApp::ProcessEntry(), and CSplitCacheApp::SetupCache().

HasReaderWithHUPIncluded()

bool CReadDispatcher::HasReaderWithHUPIncluded

(

)

const

Definition at line 239 of file dispatcher.cpp.

References m_Readers.

Referenced by CGBDataLoader_Native::x_CreateWriters().

InsertProcessor()

void CReadDispatcher::InsertProcessor

(

CRef< CProcessor >

processor

)

Definition at line 194 of file dispatcher.cpp.

References CProcessor::GetType(), and m_Processors.

Referenced by CProcessor::RegisterAllProcessors().

InsertReader()

void CReadDispatcher::InsertReader	(	TLevel	level,
		CRef< CReader >	reader
	)

Definition at line 173 of file dispatcher.cpp.

References CReader::m_Dispatcher, and m_Readers.

Referenced by CGBDataLoader_Native::x_CreateDriver(), and CGBDataLoader_Native::x_CreateReaders().

InsertWriter()

void CReadDispatcher::InsertWriter	(	TLevel	level,
		CRef< CWriter >	writer
	)

Definition at line 184 of file dispatcher.cpp.

References m_Writers.

Referenced by CGBDataLoader_Native::x_CreateWriters().

LoadAccVers()

void CReadDispatcher::LoadAccVers	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TIds &	ret
	)

Definition at line 2003 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetAccVers().

LoadBlob() [1/2]

void CReadDispatcher::LoadBlob	(	CReaderRequestResult &	result,
		const CBlob_id &	blob_id
	)

Definition at line 2120 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetBlobById(), and CReader::LoadBlobs().

LoadBlob() [2/2]

void CReadDispatcher::LoadBlob	(	CReaderRequestResult &	result,
		const CBlob_Info &	blob_info
	)

Definition at line 2128 of file dispatcher.cpp.

References command, CBlob_Info::GetBlob_id(), Process(), and result.

LoadBlobs() [1/3]

void CReadDispatcher::LoadBlobs	(	CReaderRequestResult &	result,
		const CLoadLockBlobIds &	blobs,
		TContentsMask	mask,
		const SAnnotSelector *	sel
	)

Definition at line 2102 of file dispatcher.cpp.

References command, mask, Process(), and result.

LoadBlobs() [2/3]

void CReadDispatcher::LoadBlobs	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id,
		TContentsMask	mask,
		const SAnnotSelector *	sel
	)

Definition at line 2092 of file dispatcher.cpp.

References command, mask, Process(), and result.

Referenced by CGBDataLoader_Native::GetCDDAnnots(), CReader::LoadBlobs(), CReader::LoadSeq_idTaxId(), CReader::LoadSequenceLength(), CReader::LoadSequenceType(), and CGBDataLoader_Native::x_GetRecords().

LoadBlobs() [3/3]

void CReadDispatcher::LoadBlobs	(	CReaderRequestResult &	result,
		const TBlobInfos &	blob_infos
	)

Definition at line 2112 of file dispatcher.cpp.

References command, Process(), and result.

LoadBlobSet()

void CReadDispatcher::LoadBlobSet	(	CReaderRequestResult &	result,
		const TIds &	seq_ids
	)

Definition at line 2161 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetBlobs(), and CGBDataLoader_Native::GetCDDAnnots().

LoadBlobState()

void CReadDispatcher::LoadBlobState	(	CReaderRequestResult &	result,
		const TBlobId &	blob_id
	)

Definition at line 2077 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CReader::LoadStates().

LoadBlobVersion()

void CReadDispatcher::LoadBlobVersion	(	CReaderRequestResult &	result,
		const TBlobId &	blob_id,
		const CReader *	asking_reader = 0
	)

Definition at line 2084 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetBlobVersion(), and CCacheReader::LoadChunk().

LoadBulkIds()

void CReadDispatcher::LoadBulkIds	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TBulkIds &	ret
	)

Definition at line 1995 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetBulkIds().

LoadChunk()

void CReadDispatcher::LoadChunk	(	CReaderRequestResult &	result,
		const TBlobId &	blob_id,
		TChunkId	chunk_id
	)

Definition at line 2136 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetChunk().

LoadChunks() [1/2]

void CReadDispatcher::LoadChunks	(	CReaderRequestResult &	result,
		const TBlobChunkIds &	chunk_ids
	)

Definition at line 2153 of file dispatcher.cpp.

References command, Process(), and result.

LoadChunks() [2/2]

void CReadDispatcher::LoadChunks	(	CReaderRequestResult &	result,
		const TBlobId &	blob_id,
		const TChunkIds &	chunk_ids
	)

Definition at line 2144 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetCDDAnnots(), and CGBDataLoader_Native::GetChunks().

LoadGis()

void CReadDispatcher::LoadGis	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TGis &	ret
	)

Definition at line 2011 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetGis().

LoadHashes()

void CReadDispatcher::LoadHashes	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		THashes &	ret,
		TKnown &	known
	)

Definition at line 2035 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceHashes().

LoadLabels()

void CReadDispatcher::LoadLabels	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TLabels &	ret
	)

Definition at line 2019 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetLabels().

LoadLengths()

void CReadDispatcher::LoadLengths	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TLengths &	ret
	)

Definition at line 2044 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceLengths().

LoadSeq_idAccVer()

void CReadDispatcher::LoadSeq_idAccVer	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1947 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetAccVerFound(), and CReader::LoadAccVers().

LoadSeq_idBlob_ids()

void CReadDispatcher::LoadSeq_idBlob_ids	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id,
		const SAnnotSelector *	sel
	)

Definition at line 2068 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetBlobId(), CGBDataLoader_Native::GetNamedAnnotAccessions(), CId1Reader::LoadSeq_idBlob_ids(), CReader::LoadSeq_idBlob_ids(), and CReader::LoadStates().

LoadSeq_idGi()

void CReadDispatcher::LoadSeq_idGi	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1939 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetGiFound(), CReader::LoadGis(), CId1Reader::LoadSeq_idBlob_ids(), CId1Reader::LoadSeq_idSeq_ids(), CPubseqReader::LoadSeq_idSeq_ids(), and CPubseqReader::LoadSequenceHash().

LoadSeq_idLabel()

void CReadDispatcher::LoadSeq_idLabel	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1955 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetLabel(), and CReader::LoadLabels().

LoadSeq_idSeq_ids()

void CReadDispatcher::LoadSeq_idSeq_ids	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1931 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetIds(), CReader::LoadBulkIds(), CReader::LoadSeq_idAccVer(), CReader::LoadSeq_idGi(), CReader::LoadSeq_idLabel(), CId1Reader::LoadSeq_idSeq_ids(), CPubseqReader::LoadSeq_idSeq_ids(), and CReader::LoadSequenceHash().

LoadSeq_idTaxId()

void CReadDispatcher::LoadSeq_idTaxId	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1963 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetTaxId(), and CReader::LoadTaxIds().

LoadSequenceHash()

void CReadDispatcher::LoadSequenceHash	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1971 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceHashFound(), CReader::LoadHashes(), and CPubseqReader::LoadSequenceHash().

LoadSequenceLength()

void CReadDispatcher::LoadSequenceLength	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1979 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceLength(), and CReader::LoadLengths().

LoadSequenceType()

void CReadDispatcher::LoadSequenceType	(	CReaderRequestResult &	result,
		const CSeq_id_Handle &	seq_id
	)

Definition at line 1987 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceTypeFound(), and CReader::LoadTypes().

LoadStates()

void CReadDispatcher::LoadStates	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TStates &	ret
	)

Definition at line 2060 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceStates().

LoadTaxIds()

void CReadDispatcher::LoadTaxIds	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TTaxIds &	ret
	)

Definition at line 2027 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetTaxIds().

LoadTypes()

void CReadDispatcher::LoadTypes	(	CReaderRequestResult &	result,
		const TIds &	ids,
		TLoaded &	loaded,
		TTypes &	ret
	)

Definition at line 2052 of file dispatcher.cpp.

References command, Process(), and result.

Referenced by CGBDataLoader_Native::GetSequenceTypes().

LogStat() [1/2]

void CReadDispatcher::LogStat ( CReadDispatcherCommand &  command, CReaderRequestResultRecursion &  recursion  )

static

Definition at line 2213 of file dispatcher.cpp.

References CGBRequestStatistics::AddTime(), CSeq_id_Handle::AsString(), CollectStatistics(), command, count, CReaderRequestResultRecursion::GetCurrentRequestTime(), CReaderRequestResultRecursion::GetRecursionLevel(), LOG_POST_X, result, and sx_Statistics.

Referenced by CProcessor::LogStat(), and Process().

LogStat() [2/2]

void CReadDispatcher::LogStat ( CReadDispatcherCommand &  command, CReaderRequestResultRecursion &  recursion, double  size  )

static

Definition at line 2236 of file dispatcher.cpp.

References CGBRequestStatistics::AddTimeSize(), CSeq_id_Handle::AsString(), CollectStatistics(), command, CReaderRequestResultRecursion::GetCurrentRequestTime(), CReaderRequestResultRecursion::GetRecursionLevel(), LOG_POST_X, result, ncbi::grid::netcache::search::fields::size, and sx_Statistics.

Process()

void CReadDispatcher::Process	(	CReadDispatcherCommand &	command,
		const CReader *	asking_reader = 0
	)

Definition at line 1838 of file dispatcher.cpp.

References CheckReaders(), command, CLoaderException::eNoConnection, CLoaderException::eRepeatAgain, CException::GetErrCode(), CReader::GetRetryCount(), Info(), kMax_Int, LOG_POST_X, LogStat(), m_Readers, CReader::MayBeSkippedOnErrors(), NCBI_THROW, NON_CONST_ITERATE, r(), s_AllowIncompleteCommands(), Warning(), and CException::what().

Referenced by LoadAccVers(), LoadBlob(), LoadBlobs(), LoadBlobSet(), LoadBlobState(), LoadBlobVersion(), LoadBulkIds(), LoadChunk(), LoadChunks(), LoadGis(), LoadHashes(), LoadLabels(), LoadLengths(), LoadSeq_idAccVer(), LoadSeq_idBlob_ids(), LoadSeq_idGi(), LoadSeq_idLabel(), LoadSeq_idSeq_ids(), LoadSeq_idTaxId(), LoadSequenceHash(), LoadSequenceLength(), LoadSequenceType(), LoadStates(), LoadTaxIds(), and LoadTypes().

ResetCaches()

void CReadDispatcher::ResetCaches

(

void

)

Definition at line 250 of file dispatcher.cpp.

References m_Readers, m_Writers, and NON_CONST_ITERATE.

Referenced by CGBDataLoader_Native::CloseCache().

SetBlobState()

bool CReadDispatcher::SetBlobState ( size_t  i, CReaderRequestResult &  result, const TIds &  ids, TLoaded &  loaded, TStates &  ret  )

static

Definition at line 2169 of file dispatcher.cpp.

References CannotProcess(), eAlreadyLoaded, fBlobHasCore, CLoadLockBlobIds::GetBlob_ids(), CLoadLockBlobState::GetBlobState(), CLoadLockSeqIds::GetState(), CLoadLockBlobIds::GetState(), i, CLoadLockSeqIds::IsFound(), CFixedBlob_ids::IsFound(), CLoadLockBlobState::IsLoadedBlobState(), ITERATE, CFixedBlob_ids::kUnknownState, and result.

Referenced by CId2ReaderBase::LoadStates(), and CReader::LoadStates().

Member Data Documentation

m_Processors

TProcessors CReadDispatcher::m_Processors

private

Definition at line 193 of file dispatcher.hpp.

Referenced by GetProcessor(), and InsertProcessor().

m_Readers

TReaders CReadDispatcher::m_Readers

private

Definition at line 191 of file dispatcher.hpp.

Referenced by CheckReaders(), HasReaderWithHUPIncluded(), InsertReader(), Process(), and ResetCaches().

m_Writers

TWriters CReadDispatcher::m_Writers

private

Definition at line 192 of file dispatcher.hpp.

Referenced by GetWriter(), InsertWriter(), and ResetCaches().

---

The documentation for this class was generated from the following files:

• include/objtools/data_loaders/genbank/impl/dispatcher.hpp
• src/objtools/data_loaders/genbank/dispatcher.cpp