NCBI C++ ToolKit
Classes | Public Types | Public Member Functions | Static Public Member Functions | Protected Types | Protected Member Functions | Protected Attributes | Private Types | Private Member Functions | Private Attributes | Friends | List of all members
CReader Class Referenceabstract

Search Toolkit Book for CReader

#include <objtools/data_loaders/genbank/reader.hpp>

+ Inheritance diagram for CReader:
+ Collaboration diagram for CReader:

Classes

class  CDebugPrinter
 
struct  SConnSlot
 

Public Types

typedef unsigned TConn
 
typedef CBlob_id TBlobId
 
typedef int TState
 
typedef int TBlobState
 
typedef int TBlobVersion
 
typedef int TBlobSplitVersion
 
typedef int TChunkId
 
typedef int TContentsMask
 
typedef vector< TChunkId > TChunkIds
 
typedef vector< CSeq_id_Handle > TSeqIds
 
typedef vector< CBlob_Info > TBlobIds
 
typedef vector< CSeq_id_Handle > TIds
 
typedef vector< bool > TLoaded
 
typedef vector< TGi > TGis
 
typedef vector< string > TLabels
 
typedef vector< TTaxId > TTaxIds
 
typedef vector< int > TStates
 
typedef vector< int > THashes
 
typedef vector< bool > TKnown
 
typedef vector< TSeqPos > TLengths
 
typedef vector< CSeq_inst::EMol > TTypes
 
typedef CDataLoader::SAccVerFound TSequenceAcc
 
typedef CDataLoader::SGiFound TSequenceGi
 
typedef CDataLoader::STypeFound TSequenceType
 
typedef CDataLoader::SHashFound TSequenceHash
 
- 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

 CReader (void)
 
virtual ~CReader (void)
 
void InitParams (CConfig &conf, const string &driver_name, int default_max_conn)
 
virtual bool LoadSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel)
 All LoadXxx() methods should return false if there is no requested data in the reader. More...
 
virtual bool LoadSeq_idSeq_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)=0
 
virtual bool LoadSeq_idGi (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadSeq_idAccVer (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadSeq_idLabel (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadSeq_idTaxId (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadSequenceHash (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadSequenceLength (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadSequenceType (CReaderRequestResult &result, const CSeq_id_Handle &seq_id)
 
virtual bool LoadAccVers (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TIds &ret)
 
virtual bool LoadGis (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TGis &ret)
 
virtual bool LoadLabels (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TLabels &ret)
 
virtual bool LoadTaxIds (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TTaxIds &ret)
 
virtual bool LoadHashes (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, THashes &ret, TKnown &known)
 
virtual bool LoadLengths (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TLengths &ret)
 
virtual bool LoadTypes (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TTypes &ret)
 
virtual bool LoadStates (CReaderRequestResult &result, const TIds &ids, TLoaded &loaded, TStates &ret)
 
virtual bool LoadBlobState (CReaderRequestResult &result, const TBlobId &blob_id)=0
 
virtual bool LoadBlobVersion (CReaderRequestResult &result, const TBlobId &blob_id)=0
 
virtual bool LoadBlobs (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, TContentsMask mask, const SAnnotSelector *sel)
 
virtual bool LoadBlobs (CReaderRequestResult &result, const CLoadLockBlobIds &lock, TContentsMask mask, const SAnnotSelector *sel)
 
virtual bool LoadBlob (CReaderRequestResult &result, const CBlob_id &blob_id)=0
 
virtual bool LoadBlob (CReaderRequestResult &result, const CBlob_Info &blob_info)
 
virtual bool LoadChunk (CReaderRequestResult &result, const TBlobId &blob_id, TChunkId chunk_id)
 
virtual bool LoadChunks (CReaderRequestResult &result, const TBlobId &blob_id, const TChunkIds &chunk_ids)
 
virtual bool LoadBlobSet (CReaderRequestResult &result, const TSeqIds &seq_ids)
 
void SetAndSaveSeq_idSeq_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const CFixedSeq_ids &seq_ids) const
 
void SetAndSaveNoSeq_idSeq_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, TState state) const
 
void SetAndSaveSeq_idAccVer (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const TSequenceAcc &acc_id) const
 
void SetAndSaveSeq_idGi (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const TSequenceGi &gi) const
 
void SetAndSaveSeq_idAccFromSeqIds (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const CLoadLockSeqIds &seq_ids) const
 
void SetAndSaveSeq_idGiFromSeqIds (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const CLoadLockSeqIds &seq_ids) const
 
void SetAndSaveSeq_idSeq_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const CLoadLockSeqIds &seq_ids) const
 
void SetAndSaveNoSeq_idSeq_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const CLoadLockGi &gi_lock) const
 
void SetAndSaveSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel, CLoadLockBlobIds &lock, const CLoadLockBlobIds &blob_ids) const
 
void SetAndSaveNoSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel, const CLoadLockGi &gi_lock) const
 
void SetAndSaveSeq_idTaxId (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, TTaxId taxid) const
 
void SetAndSaveSequenceHash (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const TSequenceHash &hash) const
 
void SetAndSaveSequenceLength (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, TSeqPos length) const
 
void SetAndSaveSequenceType (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const TSequenceType &type) const
 
void SetAndSaveSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel, const CFixedBlob_ids &blob_ids) const
 
void SetAndSaveNoSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel, TBlobState state) const
 
void SetAndSaveBlobState (CReaderRequestResult &result, const TBlobId &blob_id, TBlobState blob_state) const
 
void SetAndSaveBlobVersion (CReaderRequestResult &result, const TBlobId &blob_id, TBlobVersion version) const
 
void SetAndSaveNoBlob (CReaderRequestResult &result, const TBlobId &blob_id, TChunkId chunk_id, TBlobState blob_state)
 
void SetAndSaveSeq_idLabelFromSeqIds (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const CLoadLockSeqIds &seq_ids) const
 
void SetAndSaveSeq_idLabel (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const string &label) const
 
void SetAndSaveSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel, CLoadLockBlobIds &lock, const CFixedBlob_ids &blob_ids) const
 
void SetAndSaveNoSeq_idBlob_ids (CReaderRequestResult &result, const CSeq_id_Handle &seq_id, const SAnnotSelector *sel, CLoadLockBlobIds &lock, TBlobState state) const
 
int SetMaximumConnections (int max)
 
void SetMaximumConnections (int max, int default_max)
 
int GetMaximumConnections (void) const
 
virtual int GetMaximumConnectionsLimit (void) const
 
void SetPreopenConnection (bool preopen=true)
 
bool GetPreopenConnection (void) const
 
void OpenInitialConnection (bool force)
 
virtual int GetConst (const string &const_name) const
 
void SetMaximumRetryCount (int retry_count)
 
virtual int GetRetryCount (void) const
 
virtual bool MayBeSkippedOnErrors (void) const
 
virtual void InitializeCache (CReaderCacheManager &cache_manager, const TPluginManagerParamTree *params)
 
virtual void ResetCache (void)
 
virtual void OpenConnection (TConn conn)
 
virtual void WaitBeforeNewConnection (TConn conn)
 
virtual void ConnectSucceeds (TConn conn)
 
virtual void ConnectFailed (TConn conn)
 
virtual void SetNewConnectionDelayMicroSec (unsigned long micro_sec)
 
virtual void SetIncludeHUP (bool include_hup=true, const string &web_cookie=NcbiEmptyString)
 
bool HasHUPIncluded () const
 
virtual void SetParams (const CReaderParams &params)
 
- 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 int ReadInt (CNcbiIstream &stream)
 
- 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)
 

Protected Types

typedef CReaderAllocatedConnection CConn
 

Protected Member Functions

virtual void x_AddConnectionSlot (TConn conn)=0
 
virtual void x_RemoveConnectionSlot (TConn conn)=0
 
virtual void x_DisconnectAtSlot (TConn conn, bool failed)
 
virtual void x_ConnectAtSlot (TConn conn)=0
 
void x_ReportDisconnect (const char *reader, const char *server, TConn conn, bool failed) const
 
void x_SetIncludeHUP (bool include_hup)
 
- Protected Member Functions inherited from CObject
virtual void DeleteThis (void)
 Virtual method "deleting" this object. More...
 

Protected Attributes

CReadDispatcher * m_Dispatcher
 

Private Types

typedef list< SConnSlot > TFreeConnections
 

Private Member Functions

TConn x_AllocConnection (bool oldest=false)
 
void x_ReleaseConnection (TConn conn, double retry_delay=0)
 
void x_ReleaseClosedConnection (TConn conn)
 
void x_AbortConnection (TConn conn, bool failed)
 
void x_AddConnection (void)
 
void x_RemoveConnection (void)
 
 CReader (const CReader &)
 
void operator= (const CReader &)
 

Private Attributes

TConn m_MaxConnections
 
bool m_PreopenConnection
 
bool m_IncludeHUP
 
TConn m_NextNewConnection
 
TFreeConnections m_FreeConnections
 
CMutex m_ConnectionsMutex
 
CSemaphore m_NumFreeConnections
 
int m_MaximumRetryCount
 
atomic< int > m_ConnectFailCount
 
CTime m_LastTimeFailed
 
CTime m_NextConnectTime
 
int m_WaitTimeErrors
 
CIncreasingTime m_WaitTime
 

Friends

class CReadDispatcher
 
class CReaderAllocatedConnection
 

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...
 

Detailed Description

Definition at line 78 of file reader.hpp.

Member Typedef Documentation

◆ CConn

typedef CReaderAllocatedConnection CReader::CConn
protected

Definition at line 346 of file reader.hpp.

◆ TBlobId

typedef CBlob_id CReader::TBlobId

Definition at line 88 of file reader.hpp.

◆ TBlobIds

typedef vector<CBlob_Info> CReader::TBlobIds

Definition at line 97 of file reader.hpp.

◆ TBlobSplitVersion

typedef int CReader::TBlobSplitVersion

Definition at line 92 of file reader.hpp.

◆ TBlobState

typedef int CReader::TBlobState

Definition at line 90 of file reader.hpp.

◆ TBlobVersion

typedef int CReader::TBlobVersion

Definition at line 91 of file reader.hpp.

◆ TChunkId

typedef int CReader::TChunkId

Definition at line 93 of file reader.hpp.

◆ TChunkIds

typedef vector<TChunkId> CReader::TChunkIds

Definition at line 95 of file reader.hpp.

◆ TConn

typedef unsigned CReader::TConn

Definition at line 87 of file reader.hpp.

◆ TContentsMask

typedef int CReader::TContentsMask

Definition at line 94 of file reader.hpp.

◆ TFreeConnections

typedef list<SConnSlot> CReader::TFreeConnections
private

Definition at line 387 of file reader.hpp.

◆ TGis

typedef vector<TGi> CReader::TGis

Definition at line 125 of file reader.hpp.

◆ THashes

typedef vector<int> CReader::THashes

Definition at line 129 of file reader.hpp.

◆ TIds

typedef vector<CSeq_id_Handle> CReader::TIds

Definition at line 123 of file reader.hpp.

◆ TKnown

typedef vector<bool> CReader::TKnown

Definition at line 130 of file reader.hpp.

◆ TLabels

typedef vector<string> CReader::TLabels

Definition at line 126 of file reader.hpp.

◆ TLengths

typedef vector<TSeqPos> CReader::TLengths

Definition at line 131 of file reader.hpp.

◆ TLoaded

typedef vector<bool> CReader::TLoaded

Definition at line 124 of file reader.hpp.

◆ TSeqIds

typedef vector<CSeq_id_Handle> CReader::TSeqIds

Definition at line 96 of file reader.hpp.

◆ TSequenceAcc

typedef CDataLoader::SAccVerFound CReader::TSequenceAcc

Definition at line 183 of file reader.hpp.

◆ TSequenceGi

typedef CDataLoader::SGiFound CReader::TSequenceGi

Definition at line 184 of file reader.hpp.

◆ TSequenceHash

typedef CDataLoader::SHashFound CReader::TSequenceHash

Definition at line 186 of file reader.hpp.

◆ TSequenceType

typedef CDataLoader::STypeFound CReader::TSequenceType

Definition at line 185 of file reader.hpp.

◆ TState

typedef int CReader::TState

Definition at line 89 of file reader.hpp.

◆ TStates

typedef vector<int> CReader::TStates

Definition at line 128 of file reader.hpp.

◆ TTaxIds

typedef vector<TTaxId> CReader::TTaxIds

Definition at line 127 of file reader.hpp.

◆ TTypes

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

Definition at line 132 of file reader.hpp.

Constructor & Destructor Documentation

◆ CReader() [1/2]

CReader::CReader ( void  )

Definition at line 111 of file reader.cpp.

◆ ~CReader()

CReader::~CReader ( void  )
virtual

Definition at line 126 of file reader.cpp.

◆ CReader() [2/2]

CReader::CReader ( const CReader &  )
private

Member Function Documentation

◆ ConnectFailed()

void CReader::ConnectFailed ( TConn  conn)
virtual

Definition at line 310 of file reader.cpp.

References CTime::eCurrent, m_ConnectFailCount, m_ConnectionsMutex, and m_LastTimeFailed.

Referenced by OpenConnection().

◆ ConnectSucceeds()

void CReader::ConnectSucceeds ( TConn  conn)
virtual

Definition at line 304 of file reader.cpp.

References m_ConnectFailCount.

Referenced by OpenConnection().

◆ GetConst()

int CReader::GetConst ( const string &  const_name) const
virtual

Definition at line 466 of file reader.cpp.

◆ GetMaximumConnections()

int CReader::GetMaximumConnections ( void  ) const

Definition at line 260 of file reader.cpp.

References m_MaxConnections.

Referenced by OpenInitialConnection(), SetMaximumConnections(), and x_AllocConnection().

◆ GetMaximumConnectionsLimit()

int CReader::GetMaximumConnectionsLimit ( void  ) const
virtual

Reimplemented in CPubseq2Reader, CPubseqReader, CId2Reader, CId1Reader, CGICacheReader, and CCacheReader.

Definition at line 266 of file reader.cpp.

Referenced by SetMaximumConnections().

◆ GetPreopenConnection()

bool CReader::GetPreopenConnection ( void  ) const

Definition at line 213 of file reader.cpp.

References m_PreopenConnection.

Referenced by OpenInitialConnection().

◆ GetRetryCount()

int CReader::GetRetryCount ( void  ) const
virtual

Reimplemented in CGICacheReader, and CCacheReader.

Definition at line 478 of file reader.cpp.

References m_MaximumRetryCount.

Referenced by OpenInitialConnection(), CReadDispatcher::Process(), and SetMaximumConnections().

◆ HasHUPIncluded()

bool CReader::HasHUPIncluded ( void  ) const
inline

Definition at line 303 of file reader.hpp.

References m_IncludeHUP.

◆ InitializeCache()

void CReader::InitializeCache ( CReaderCacheManager &  cache_manager,
const TPluginManagerParamTree *  params 
)
virtual

Reimplemented in CCacheReader.

Definition at line 1317 of file reader.cpp.

Referenced by CGBDataLoader_Native::x_CreateReader().

◆ InitParams()

void CReader::InitParams ( CConfig &  conf,
const string &  driver_name,
int  default_max_conn 
)

Definition at line 131 of file reader.cpp.

References DEFAULT_PREOPEN, DEFAULT_RETRY_COUNT, DEFAULT_WAIT_TIME_ERRORS, CConfig::eErr_NoThrow, CConfig::GetBool(), CConfig::GetInt(), CIncreasingTime::Init(), m_WaitTime, m_WaitTimeErrors, NCBI_GBLOADER_READER_PARAM2_NUM_CONN, NCBI_GBLOADER_READER_PARAM_NUM_CONN, NCBI_GBLOADER_READER_PARAM_PREOPEN, NCBI_GBLOADER_READER_PARAM_RETRY_COUNT, NCBI_GBLOADER_READER_PARAM_WAIT_TIME_ERRORS, s_WaitTimeParams, SetMaximumConnections(), SetMaximumRetryCount(), and SetPreopenConnection().

Referenced by CId1Reader::CId1Reader(), CId2Reader::CId2Reader(), CPubseq2Reader::CPubseq2Reader(), and CPubseqReader::CPubseqReader().

◆ LoadAccVers()

bool CReader::LoadAccVers ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TIds &  ret 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 661 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockAcc::GetAcc(), CLoadLockAcc::GetAccVer(), i, CLoadLockAcc::IsFound(), CLoadLockAcc::IsLoadedAccVer(), CReadDispatcher::LoadSeq_idAccVer(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadAccVers().

◆ LoadBlob() [1/2]

virtual bool CReader::LoadBlob ( CReaderRequestResult &  result,
const CBlob_id &  blob_id 
)
pure virtual

Implemented in CId2ReaderBase, CId1ReaderBase, CCacheReader, and CGICacheReader.

Referenced by LoadBlob().

◆ LoadBlob() [2/2]

bool CReader::LoadBlob ( CReaderRequestResult &  result,
const CBlob_Info &  blob_info 
)
virtual

Definition at line 942 of file reader.cpp.

References _ASSERT, CBlob_Info::GetBlob_id(), CLoadLockBlob::IsLoadedBlob(), CBlob_Info::IsSetAnnotInfo(), LoadBlob(), CProcessor_AnnotInfo::LoadBlob(), and result.

◆ LoadBlobs() [1/2]

bool CReader::LoadBlobs ( CReaderRequestResult &  result,
const CLoadLockBlobIds &  lock,
TContentsMask  mask,
const SAnnotSelector *  sel 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 898 of file reader.cpp.

References _ASSERT, CLoadLockSetter::AllowIncompleteLoading(), CLoadLockBlobIds::GetBlob_ids(), CLoadLockSetter::GetTSE_LoadLock(), info, CLoadLockBlob::IsLoadedBlob(), ITERATE, CReadDispatcher::LoadBlob(), CProcessor_AnnotInfo::LoadBlob(), m_Dispatcher, mask, names, result, and CTSE_Info::SetName().

◆ LoadBlobs() [2/2]

bool CReader::LoadBlobs ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
TContentsMask  mask,
const SAnnotSelector *  sel 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 879 of file reader.cpp.

References CReadDispatcher::LoadBlobs(), LoadSeq_idBlob_ids(), m_Dispatcher, mask, and result.

Referenced by CId2ReaderBase::LoadBlobs(), and LoadBlobSet().

◆ LoadBlobSet()

bool CReader::LoadBlobSet ( CReaderRequestResult &  result,
const TSeqIds &  seq_ids 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 981 of file reader.cpp.

References fBlobHasCore, ITERATE, LoadBlobs(), and result.

Referenced by CId2ReaderBase::LoadBlobSet().

◆ LoadBlobState()

virtual bool CReader::LoadBlobState ( CReaderRequestResult &  result,
const TBlobId &  blob_id 
)
pure virtual

Implemented in CId2ReaderBase, CId1ReaderBase, CGICacheReader, and CCacheReader.

◆ LoadBlobVersion()

virtual bool CReader::LoadBlobVersion ( CReaderRequestResult &  result,
const TBlobId &  blob_id 
)
pure virtual

Implemented in CId2ReaderBase, CId1ReaderBase, CGICacheReader, and CCacheReader.

◆ LoadChunk()

bool CReader::LoadChunk ( CReaderRequestResult &  result,
const TBlobId &  blob_id,
TChunkId  chunk_id 
)
virtual

Reimplemented in CId2ReaderBase, CId1ReaderBase, and CCacheReader.

Definition at line 961 of file reader.cpp.

Referenced by LoadChunks().

◆ LoadChunks()

bool CReader::LoadChunks ( CReaderRequestResult &  result,
const TBlobId &  blob_id,
const TChunkIds &  chunk_ids 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 969 of file reader.cpp.

References ITERATE, LoadChunk(), and result.

Referenced by CId2ReaderBase::LoadChunks().

◆ LoadGis()

bool CReader::LoadGis ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TGis &  ret 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 685 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockGi::GetGi(), i, CLoadLockGi::IsFound(), CLoadLockGi::IsLoadedGi(), CReadDispatcher::LoadSeq_idGi(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadGis().

◆ LoadHashes()

bool CReader::LoadHashes ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
THashes &  ret,
TKnown &  known 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 751 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockHash::GetHash(), i, CLoadLockHash::IsLoadedHash(), CReadDispatcher::LoadSequenceHash(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadHashes().

◆ LoadLabels()

bool CReader::LoadLabels ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TLabels &  ret 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 709 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockLabel::GetLabel(), i, CLoadLockLabel::IsLoadedLabel(), CReadDispatcher::LoadSeq_idLabel(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadLabels().

◆ LoadLengths()

bool CReader::LoadLengths ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TLengths &  ret 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 777 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockLength::GetLength(), i, CLoadLockLength::IsLoadedLength(), kInvalidSeqPos, CReadDispatcher::LoadSequenceLength(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadLengths().

◆ LoadSeq_idAccVer()

bool CReader::LoadSeq_idAccVer ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CPubseqReader, CId2ReaderBase, CGICacheReader, and CCacheReader.

Definition at line 509 of file reader.cpp.

References CLoadLockAcc::IsLoadedAccVer(), CReadDispatcher::LoadSeq_idSeq_ids(), m_Dispatcher, result, and SetAndSaveSeq_idAccFromSeqIds().

Referenced by CId2ReaderBase::LoadSeq_idAccVer(), and CPubseqReader::LoadSeq_idAccVer().

◆ LoadSeq_idBlob_ids()

bool CReader::LoadSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel 
)
virtual

All LoadXxx() methods should return false if there is no requested data in the reader.

This will notify dispatcher that there is no sense to retry.

Reimplemented in CPubseqReader, CId2ReaderBase, CCacheReader, and CId1Reader.

Definition at line 860 of file reader.cpp.

References SAnnotSelector::IsIncludedAnyNamedAnnotAccession(), CReadDispatcher::LoadSeq_idBlob_ids(), m_Dispatcher, result, and CLoadLockBlobIds::SetLoadedBlob_ids().

Referenced by LoadBlobs(), and CId1Reader::LoadSeq_idBlob_ids().

◆ LoadSeq_idGi()

bool CReader::LoadSeq_idGi ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CPubseqReader, CId2ReaderBase, CId1Reader, and CCacheReader.

Definition at line 490 of file reader.cpp.

References CLoadLockGi::IsLoadedGi(), CReadDispatcher::LoadSeq_idSeq_ids(), m_Dispatcher, result, and SetAndSaveSeq_idGiFromSeqIds().

Referenced by CId2ReaderBase::LoadSeq_idGi().

◆ LoadSeq_idLabel()

bool CReader::LoadSeq_idLabel ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 528 of file reader.cpp.

References CLoadLockLabel::IsLoadedLabel(), CReadDispatcher::LoadSeq_idSeq_ids(), m_Dispatcher, result, and SetAndSaveSeq_idLabelFromSeqIds().

Referenced by CId2ReaderBase::LoadSeq_idLabel().

◆ LoadSeq_idSeq_ids()

virtual bool CReader::LoadSeq_idSeq_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
pure virtual

Implemented in CPubseqReader, CId2ReaderBase, CGICacheReader, CCacheReader, and CId1Reader.

◆ LoadSeq_idTaxId()

bool CReader::LoadSeq_idTaxId ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 547 of file reader.cpp.

References _ASSERT, fBlobHasCore, fBlobHasDescr, CTSE_Info::FindMatchingBioseq(), CLoadLockBlobIds::GetBlob_ids(), CLoadLockBlob::GetTSE_LoadLock(), info, INVALID_TAX_ID, CLoadLockBlob::IsLoadedBlob(), ITERATE, CReadDispatcher::LoadBlobs(), m_Dispatcher, result, and SetAndSaveSeq_idTaxId().

Referenced by CId2ReaderBase::LoadSeq_idTaxId().

◆ LoadSequenceHash()

bool CReader::LoadSequenceHash ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CPubseqReader, CId2ReaderBase, and CCacheReader.

Definition at line 579 of file reader.cpp.

References CLoadLockSeqIds::GetSeq_ids(), CReadDispatcher::LoadSeq_idSeq_ids(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadSequenceHash().

◆ LoadSequenceLength()

bool CReader::LoadSequenceLength ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 596 of file reader.cpp.

References _ASSERT, fBlobHasCore, CTSE_Info::FindMatchingBioseq(), CLoadLockBlobIds::GetBlob_ids(), CLoadLockBlob::GetTSE_LoadLock(), info, CLoadLockBlob::IsLoadedBlob(), ITERATE, kInvalidSeqPos, CReadDispatcher::LoadBlobs(), m_Dispatcher, result, and SetAndSaveSequenceLength().

Referenced by CId2ReaderBase::LoadSequenceLength().

◆ LoadSequenceType()

bool CReader::LoadSequenceType ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 628 of file reader.cpp.

References _ASSERT, fBlobHasCore, CTSE_Info::FindMatchingBioseq(), CLoadLockBlobIds::GetBlob_ids(), CLoadLockBlob::GetTSE_LoadLock(), info, CLoadLockBlob::IsLoadedBlob(), ITERATE, CReadDispatcher::LoadBlobs(), m_Dispatcher, result, SetAndSaveSequenceType(), type, and type::type.

Referenced by CId2ReaderBase::LoadSequenceType().

◆ LoadStates()

bool CReader::LoadStates ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TStates &  ret 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 822 of file reader.cpp.

References CReadDispatcher::CannotProcess(), fBlobHasCore, CBioseq_Handle::fState_not_found, CLoadLockBlobIds::GetBlob_ids(), CLoadLockBlobState::GetBlobState(), i, ITERATE, CReadDispatcher::LoadBlobState(), CReadDispatcher::LoadSeq_idBlob_ids(), m_Dispatcher, result, and CReadDispatcher::SetBlobState().

Referenced by CId2ReaderBase::LoadStates().

◆ LoadTaxIds()

bool CReader::LoadTaxIds ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TTaxIds &  ret 
)
virtual

Reimplemented in CId2ReaderBase, and CCacheReader.

Definition at line 730 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockTaxId::GetTaxId(), i, INVALID_TAX_ID, CLoadLockTaxId::IsLoadedTaxId(), CReadDispatcher::LoadSeq_idTaxId(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadTaxIds().

◆ LoadTypes()

bool CReader::LoadTypes ( CReaderRequestResult &  result,
const TIds &  ids,
TLoaded &  loaded,
TTypes &  ret 
)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 798 of file reader.cpp.

References CReadDispatcher::CannotProcess(), CLoadLockType::GetType(), i, CLoadLockType::IsFound(), CLoadLockType::IsLoadedType(), CReadDispatcher::LoadSequenceType(), m_Dispatcher, and result.

Referenced by CId2ReaderBase::LoadTypes().

◆ MayBeSkippedOnErrors()

bool CReader::MayBeSkippedOnErrors ( void  ) const
virtual

Reimplemented in CGICacheReader, and CCacheReader.

Definition at line 484 of file reader.cpp.

Referenced by CReadDispatcher::Process().

◆ OpenConnection()

void CReader::OpenConnection ( TConn  conn)
virtual

Definition at line 326 of file reader.cpp.

References conn, ConnectFailed(), ConnectSucceeds(), WaitBeforeNewConnection(), and x_ConnectAtSlot().

Referenced by OpenInitialConnection(), CId1Reader::x_GetConnection(), CId2Reader::x_GetConnection(), CPubseqReader::x_GetConnection(), and CPubseq2Reader::x_GetConnection().

◆ OpenInitialConnection()

void CReader::OpenInitialConnection ( bool  force)

Definition at line 168 of file reader.cpp.

References conn, CLoaderException::eNoConnection, CException::GetErrCode(), GetMaximumConnections(), GetPreopenConnection(), GetRetryCount(), LOG_POST_X, NCBI_RETHROW, OpenConnection(), Warning(), CException::what(), x_AllocConnection(), x_ReleaseClosedConnection(), and x_ReleaseConnection().

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

◆ operator=()

void CReader::operator= ( const CReader &  )
private

◆ ReadInt()

int CReader::ReadInt ( CNcbiIstream &  stream)
static

Definition at line 1305 of file reader.cpp.

References NCBI_THROW, and value.

Referenced by CCacheReader::x_ProcessBlob().

◆ ResetCache()

void CReader::ResetCache ( void  )
virtual

Reimplemented in CCacheReader.

Definition at line 1323 of file reader.cpp.

◆ SetAndSaveBlobState()

void CReader::SetAndSaveBlobState ( CReaderRequestResult &  result,
const TBlobId &  blob_id,
TBlobState  blob_state 
) const

Definition at line 1024 of file reader.cpp.

References result.

Referenced by CId1Reader::GetBlobVersion(), and CCacheReader::LoadBlobState().

◆ SetAndSaveBlobVersion()

void CReader::SetAndSaveBlobVersion ( CReaderRequestResult &  result,
const TBlobId &  blob_id,
TBlobVersion  version 
) const

Definition at line 1037 of file reader.cpp.

References result, and version.

Referenced by CId1Reader::GetBlobVersion(), CCacheReader::LoadBlobVersion(), CId2ReaderBase::x_ProcessGetBlob(), CId2ReaderBase::x_ProcessGetBlobId(), and CId2ReaderBase::x_ProcessGetSplitInfo().

◆ SetAndSaveNoBlob()

void CReader::SetAndSaveNoBlob ( CReaderRequestResult &  result,
const TBlobId &  blob_id,
TChunkId  chunk_id,
TBlobState  blob_state 
)

Definition at line 992 of file reader.cpp.

References CBioseq_Handle::fState_no_data, CBioseq_Handle::fState_not_found, and result.

Referenced by CPubseqReader::GetBlob(), CId2ReaderBase::x_ProcessGetBlob(), and CId2ReaderBase::x_ProcessGetSplitInfo().

◆ SetAndSaveNoSeq_idBlob_ids() [1/3]

void CReader::SetAndSaveNoSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel,
CLoadLockBlobIds &  lock,
TBlobState  state 
) const

Definition at line 1285 of file reader.cpp.

References CBioseq_Handle::fState_no_data, CBioseq_Handle::fState_not_found, result, CLoadLockBlobIds::SetNoBlob_ids(), and TRACE_SET.

◆ SetAndSaveNoSeq_idBlob_ids() [2/3]

void CReader::SetAndSaveNoSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel,
const CLoadLockGi &  gi_lock 
) const

Definition at line 1133 of file reader.cpp.

References result, and TRACE_SET.

Referenced by CId1Reader::LoadGiBlob_ids(), CId1Reader::LoadSeq_idBlob_ids(), CPubseqReader::LoadSeq_idBlob_ids(), CPubseqReader::LoadSeq_idInfo(), SetAndSaveNoSeq_idBlob_ids(), SetAndSaveSeq_idSeq_ids(), CId2ReaderBase::x_ProcessEmptyReply(), and CId2ReaderBase::x_ProcessGetBlobId().

◆ SetAndSaveNoSeq_idBlob_ids() [3/3]

void CReader::SetAndSaveNoSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel,
TBlobState  state 
) const

Definition at line 1014 of file reader.cpp.

References result, and SetAndSaveNoSeq_idBlob_ids().

◆ SetAndSaveNoSeq_idSeq_ids() [1/2]

void CReader::SetAndSaveNoSeq_idSeq_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const CLoadLockGi &  gi_lock 
) const

Definition at line 1120 of file reader.cpp.

References result.

◆ SetAndSaveNoSeq_idSeq_ids() [2/2]

void CReader::SetAndSaveNoSeq_idSeq_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
TState  state 
) const

Definition at line 1149 of file reader.cpp.

References CBioseq_Handle::fState_no_data, CBioseq_Handle::fState_not_found, result, and SetAndSaveSeq_idSeq_ids().

Referenced by CId1Reader::LoadGiSeq_ids(), CPubseqReader::LoadGiSeq_ids(), CPubseqReader::LoadSeq_idInfo(), CId1Reader::LoadSeq_idSeq_ids(), CPubseqReader::LoadSeq_idSeq_ids(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSeq_idAccFromSeqIds()

void CReader::SetAndSaveSeq_idAccFromSeqIds ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const CLoadLockSeqIds &  seq_ids 
) const

Definition at line 1081 of file reader.cpp.

References result.

Referenced by LoadSeq_idAccVer().

◆ SetAndSaveSeq_idAccVer()

void CReader::SetAndSaveSeq_idAccVer ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const TSequenceAcc &  acc_id 
) const

Definition at line 1173 of file reader.cpp.

References result.

Referenced by CPubseqReader::LoadSeq_idAccVer(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSeq_idBlob_ids() [1/3]

void CReader::SetAndSaveSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel,
CLoadLockBlobIds &  lock,
const CFixedBlob_ids &  blob_ids 
) const

Definition at line 1251 of file reader.cpp.

References result, CLoadLockBlobIds::SetLoadedBlob_ids(), and TRACE_SET.

◆ SetAndSaveSeq_idBlob_ids() [2/3]

void CReader::SetAndSaveSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel,
CLoadLockBlobIds &  lock,
const CLoadLockBlobIds &  blob_ids 
) const

Definition at line 1268 of file reader.cpp.

References CLoadLockBlobIds::GetBlob_ids(), result, CLoadLockBlobIds::SetLoadedBlob_ids(), and TRACE_SET.

Referenced by CId1Reader::LoadGiBlob_ids(), CId1Reader::LoadSeq_idBlob_ids(), CPubseqReader::LoadSeq_idBlob_ids(), CPubseqReader::LoadSeq_idInfo(), SetAndSaveSeq_idBlob_ids(), and CId2ReaderBase::x_UpdateLoadedSet().

◆ SetAndSaveSeq_idBlob_ids() [3/3]

void CReader::SetAndSaveSeq_idBlob_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const SAnnotSelector *  sel,
const CFixedBlob_ids &  blob_ids 
) const

Definition at line 1004 of file reader.cpp.

References result, and SetAndSaveSeq_idBlob_ids().

◆ SetAndSaveSeq_idGi()

void CReader::SetAndSaveSeq_idGi ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const TSequenceGi &  gi 
) const

Definition at line 1160 of file reader.cpp.

References result.

Referenced by CId1Reader::LoadSeq_idGi(), CPubseqReader::LoadSeq_idInfo(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSeq_idGiFromSeqIds()

void CReader::SetAndSaveSeq_idGiFromSeqIds ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const CLoadLockSeqIds &  seq_ids 
) const

Definition at line 1094 of file reader.cpp.

References result.

Referenced by LoadSeq_idGi().

◆ SetAndSaveSeq_idLabel()

void CReader::SetAndSaveSeq_idLabel ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const string &  label 
) const

Definition at line 1186 of file reader.cpp.

References label, and result.

Referenced by CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSeq_idLabelFromSeqIds()

void CReader::SetAndSaveSeq_idLabelFromSeqIds ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const CLoadLockSeqIds &  seq_ids 
) const

Definition at line 1107 of file reader.cpp.

References result.

Referenced by LoadSeq_idLabel().

◆ SetAndSaveSeq_idSeq_ids() [1/2]

void CReader::SetAndSaveSeq_idSeq_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const CFixedSeq_ids &  seq_ids 
) const

Definition at line 1050 of file reader.cpp.

References CFixedSeq_ids::GetState(), CFixedSeq_ids::IsFound(), result, SetAndSaveNoSeq_idBlob_ids(), and TRACE_SET.

Referenced by CId1Reader::LoadGiSeq_ids(), CPubseqReader::LoadGiSeq_ids(), CId1Reader::LoadSeq_idSeq_ids(), CPubseqReader::LoadSeq_idSeq_ids(), SetAndSaveNoSeq_idSeq_ids(), CId2ReaderBase::x_ProcessGetSeqIdSeqId(), and CId2ReaderBase::x_UpdateLoadedSet().

◆ SetAndSaveSeq_idSeq_ids() [2/2]

void CReader::SetAndSaveSeq_idSeq_ids ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const CLoadLockSeqIds &  seq_ids 
) const

Definition at line 1068 of file reader.cpp.

References result.

◆ SetAndSaveSeq_idTaxId()

void CReader::SetAndSaveSeq_idTaxId ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
TTaxId  taxid 
) const

Definition at line 1199 of file reader.cpp.

References result.

Referenced by LoadSeq_idTaxId(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSequenceHash()

void CReader::SetAndSaveSequenceHash ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const TSequenceHash &  hash 
) const

Definition at line 1212 of file reader.cpp.

References result.

Referenced by CPubseqReader::LoadGiHash(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSequenceLength()

void CReader::SetAndSaveSequenceLength ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
TSeqPos  length 
) const

Definition at line 1225 of file reader.cpp.

References result.

Referenced by LoadSequenceLength(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetAndSaveSequenceType()

void CReader::SetAndSaveSequenceType ( CReaderRequestResult &  result,
const CSeq_id_Handle &  seq_id,
const TSequenceType &  type 
) const

Definition at line 1238 of file reader.cpp.

References result.

Referenced by LoadSequenceType(), and CId2ReaderBase::x_ProcessGetSeqIdSeqId().

◆ SetIncludeHUP()

void CReader::SetIncludeHUP ( bool  include_hup = true,
const string &  web_cookie = NcbiEmptyString 
)
virtual

Reimplemented in CPubseq2Reader, and CPubseqReader.

Definition at line 1328 of file reader.cpp.

References NCBI_THROW.

Referenced by CGBDataLoader_Native::x_CreateReaders().

◆ SetMaximumConnections() [1/2]

int CReader::SetMaximumConnections ( int  max)

Definition at line 228 of file reader.cpp.

References error_count, GetMaximumConnections(), GetMaximumConnectionsLimit(), GetRetryCount(), LOG_POST_X, max(), Warning(), x_AddConnection(), and x_RemoveConnection().

Referenced by CCacheReader::CCacheReader(), CId1Reader::CId1Reader(), CId2Reader::CId2Reader(), CPubseqReader::CPubseqReader(), InitParams(), and SetMaximumConnections().

◆ SetMaximumConnections() [2/2]

void CReader::SetMaximumConnections ( int  max,
int  default_max 
)

Definition at line 219 of file reader.cpp.

References max(), and SetMaximumConnections().

◆ SetMaximumRetryCount()

void CReader::SetMaximumRetryCount ( int  retry_count)

Definition at line 472 of file reader.cpp.

References m_MaximumRetryCount.

Referenced by InitParams().

◆ SetNewConnectionDelayMicroSec()

void CReader::SetNewConnectionDelayMicroSec ( unsigned long  micro_sec)
virtual

Definition at line 318 of file reader.cpp.

References CTime::AddTimeSpan(), CTime::eCurrent, m_ConnectionsMutex, and m_NextConnectTime.

◆ SetParams()

void CReader::SetParams ( const CReaderParams &  params)
virtual

Reimplemented in CId2ReaderBase.

Definition at line 1335 of file reader.cpp.

Referenced by CGBDataLoader_Native::x_CreateReader().

◆ SetPreopenConnection()

void CReader::SetPreopenConnection ( bool  preopen = true)

Definition at line 207 of file reader.cpp.

References m_PreopenConnection.

Referenced by InitParams(), s_InitializeSubject(), CBlastScopeSource::x_InitGenbankDataLoader(), and TestUtil::CBlastOM::x_InitGenbankDataLoader().

◆ WaitBeforeNewConnection()

void CReader::WaitBeforeNewConnection ( TConn  conn)
virtual

Definition at line 272 of file reader.cpp.

References _TRACE, CTime::Clear(), CTime::DiffNanoSecond(), CTime::eCurrent, CIncreasingTime::GetTime(), CTime::IsEmpty(), LOG_POST_X, m_ConnectFailCount, m_ConnectionsMutex, m_NextConnectTime, m_WaitTime, SleepMicroSec(), and Warning().

Referenced by OpenConnection().

◆ x_AbortConnection()

void CReader::x_AbortConnection ( TConn  conn,
bool  failed 
)
private

Definition at line 419 of file reader.cpp.

References _ASSERT, conn, ERR_POST_X, failed, m_ConnectionsMutex, m_MaxConnections, x_AddConnection(), x_DisconnectAtSlot(), x_ReleaseClosedConnection(), and x_RemoveConnectionSlot().

Referenced by CReaderAllocatedConnection::~CReaderAllocatedConnection().

◆ x_AddConnection()

void CReader::x_AddConnection ( void  )
private

Definition at line 340 of file reader.cpp.

References _ASSERT, conn, m_ConnectionsMutex, m_MaxConnections, m_NextNewConnection, x_AddConnectionSlot(), and x_ReleaseClosedConnection().

Referenced by SetMaximumConnections(), and x_AbortConnection().

◆ x_AddConnectionSlot()

virtual void CReader::x_AddConnectionSlot ( TConn  conn)
protectedpure virtual

Implemented in CPubseq2Reader, CPubseqReader, CId2Reader, CId1Reader, CGICacheReader, and CCacheReader.

Referenced by x_AddConnection(), and x_DisconnectAtSlot().

◆ x_AllocConnection()

CReader::TConn CReader::x_AllocConnection ( bool  oldest = false)
private

Definition at line 361 of file reader.cpp.

References _TRACE, CTime::DiffNanoSecond(), CTime::eCurrent, GetMaximumConnections(), CTime::IsEmpty(), LOG_POST_X, CReader::SConnSlot::m_Conn, m_ConnectionsMutex, m_FreeConnections, CReader::SConnSlot::m_LastUseTime, m_NumFreeConnections, CReader::SConnSlot::m_RetryDelay, NCBI_THROW, SleepMicroSec(), CSemaphore::Wait(), Warning(), and x_DisconnectAtSlot().

Referenced by CReaderAllocatedConnection::CReaderAllocatedConnection(), OpenInitialConnection(), and x_RemoveConnection().

◆ x_ConnectAtSlot()

virtual void CReader::x_ConnectAtSlot ( TConn  conn)
protectedpure virtual

Implemented in CPubseq2Reader, CPubseqReader, CId2Reader, CId1Reader, CGICacheReader, and CCacheReader.

Referenced by OpenConnection().

◆ x_DisconnectAtSlot()

void CReader::x_DisconnectAtSlot ( TConn  conn,
bool  failed 
)
protectedvirtual

Reimplemented in CPubseq2Reader, CPubseqReader, CId2Reader, CId1Reader, CGICacheReader, and CCacheReader.

Definition at line 458 of file reader.cpp.

References conn, failed, x_AddConnectionSlot(), x_RemoveConnectionSlot(), and x_ReportDisconnect().

Referenced by x_AbortConnection(), and x_AllocConnection().

◆ x_ReleaseClosedConnection()

void CReader::x_ReleaseClosedConnection ( TConn  conn)
private

Definition at line 396 of file reader.cpp.

References conn, CReader::SConnSlot::m_Conn, m_ConnectionsMutex, m_FreeConnections, m_NumFreeConnections, CReader::SConnSlot::m_RetryDelay, and CSemaphore::Post().

Referenced by OpenInitialConnection(), x_AbortConnection(), and x_AddConnection().

◆ x_ReleaseConnection()

void CReader::x_ReleaseConnection ( TConn  conn,
double  retry_delay = 0 
)
private

Definition at line 407 of file reader.cpp.

References conn, CTime::eCurrent, CReader::SConnSlot::m_Conn, m_ConnectionsMutex, m_FreeConnections, CReader::SConnSlot::m_LastUseTime, m_NumFreeConnections, CReader::SConnSlot::m_RetryDelay, and CSemaphore::Post().

Referenced by OpenInitialConnection(), and CReaderAllocatedConnection::Release().

◆ x_RemoveConnection()

void CReader::x_RemoveConnection ( void  )
private

Definition at line 351 of file reader.cpp.

References _ASSERT, conn, m_ConnectionsMutex, m_MaxConnections, x_AllocConnection(), and x_RemoveConnectionSlot().

Referenced by SetMaximumConnections().

◆ x_RemoveConnectionSlot()

virtual void CReader::x_RemoveConnectionSlot ( TConn  conn)
protectedpure virtual

Implemented in CPubseq2Reader, CPubseqReader, CId2Reader, CId1Reader, CGICacheReader, and CCacheReader.

Referenced by x_AbortConnection(), x_DisconnectAtSlot(), and x_RemoveConnection().

◆ x_ReportDisconnect()

void CReader::x_ReportDisconnect ( const char *  reader,
const char *  server,
TConn  conn,
bool  failed 
) const
protected

Definition at line 444 of file reader.cpp.

References conn, failed, Info(), LOG_POST_X, and Warning().

Referenced by CId1Reader::x_DisconnectAtSlot(), CId2Reader::x_DisconnectAtSlot(), x_DisconnectAtSlot(), CPubseqReader::x_DisconnectAtSlot(), and CPubseq2Reader::x_DisconnectAtSlot().

◆ x_SetIncludeHUP()

void CReader::x_SetIncludeHUP ( bool  include_hup)
inlineprotected

Definition at line 359 of file reader.hpp.

References m_IncludeHUP.

Referenced by CPubseqReader::SetIncludeHUP(), and CPubseq2Reader::SetIncludeHUP().

Friends And Related Function Documentation

◆ CReadDispatcher

friend class CReadDispatcher
friend

Definition at line 287 of file reader.hpp.

◆ CReaderAllocatedConnection

friend class CReaderAllocatedConnection
friend

Definition at line 365 of file reader.hpp.

Member Data Documentation

◆ m_ConnectFailCount

atomic<int> CReader::m_ConnectFailCount
private

Definition at line 392 of file reader.hpp.

Referenced by ConnectFailed(), ConnectSucceeds(), and WaitBeforeNewConnection().

◆ m_ConnectionsMutex

CMutex CReader::m_ConnectionsMutex
private

Definition at line 389 of file reader.hpp.

Referenced by ConnectFailed(), SetNewConnectionDelayMicroSec(), WaitBeforeNewConnection(), x_AbortConnection(), x_AddConnection(), x_AllocConnection(), x_ReleaseClosedConnection(), x_ReleaseConnection(), and x_RemoveConnection().

◆ m_Dispatcher

CReadDispatcher* CReader::m_Dispatcher
protected

Definition at line 344 of file reader.hpp.

Referenced by CId1Reader::GetBlob(), CPubseqReader::GetBlob(), CReadDispatcher::InsertReader(), LoadAccVers(), CId1ReaderBase::LoadBlob(), CId2ReaderBase::LoadBlob(), CId2ReaderBase::LoadBlobs(), LoadBlobs(), CCacheReader::LoadChunk(), LoadGis(), LoadHashes(), LoadLabels(), LoadLengths(), LoadSeq_idAccVer(), CId1Reader::LoadSeq_idBlob_ids(), LoadSeq_idBlob_ids(), LoadSeq_idGi(), LoadSeq_idLabel(), CId1Reader::LoadSeq_idSeq_ids(), CPubseqReader::LoadSeq_idSeq_ids(), LoadSeq_idTaxId(), LoadSequenceHash(), CPubseqReader::LoadSequenceHash(), LoadSequenceLength(), LoadSequenceType(), LoadStates(), LoadTaxIds(), LoadTypes(), CCacheReader::x_ProcessBlob(), CId2ReaderBase::x_ProcessGetBlob(), CId2ReaderBase::x_ProcessGetChunk(), and CId2ReaderBase::x_ProcessGetSplitInfo().

◆ m_FreeConnections

TFreeConnections CReader::m_FreeConnections
private

Definition at line 388 of file reader.hpp.

Referenced by x_AllocConnection(), x_ReleaseClosedConnection(), and x_ReleaseConnection().

◆ m_IncludeHUP

bool CReader::m_IncludeHUP
private

Definition at line 378 of file reader.hpp.

Referenced by HasHUPIncluded(), and x_SetIncludeHUP().

◆ m_LastTimeFailed

CTime CReader::m_LastTimeFailed
private

Definition at line 393 of file reader.hpp.

Referenced by ConnectFailed().

◆ m_MaxConnections

TConn CReader::m_MaxConnections
private

Definition at line 376 of file reader.hpp.

Referenced by GetMaximumConnections(), x_AbortConnection(), x_AddConnection(), and x_RemoveConnection().

◆ m_MaximumRetryCount

int CReader::m_MaximumRetryCount
private

Definition at line 391 of file reader.hpp.

Referenced by GetRetryCount(), and SetMaximumRetryCount().

◆ m_NextConnectTime

CTime CReader::m_NextConnectTime
private

Definition at line 394 of file reader.hpp.

Referenced by SetNewConnectionDelayMicroSec(), and WaitBeforeNewConnection().

◆ m_NextNewConnection

TConn CReader::m_NextNewConnection
private

Definition at line 381 of file reader.hpp.

Referenced by x_AddConnection().

◆ m_NumFreeConnections

CSemaphore CReader::m_NumFreeConnections
private

Definition at line 390 of file reader.hpp.

Referenced by x_AllocConnection(), x_ReleaseClosedConnection(), and x_ReleaseConnection().

◆ m_PreopenConnection

bool CReader::m_PreopenConnection
private

Definition at line 377 of file reader.hpp.

Referenced by GetPreopenConnection(), and SetPreopenConnection().

◆ m_WaitTime

CIncreasingTime CReader::m_WaitTime
private

Definition at line 396 of file reader.hpp.

Referenced by InitParams(), and WaitBeforeNewConnection().

◆ m_WaitTimeErrors

int CReader::m_WaitTimeErrors
private

Definition at line 395 of file reader.hpp.

Referenced by InitParams().

The documentation for this class was generated from the following files:
Generated by doxygen 1.9.0
Modified on Wed Dec 06 07:15:36 2023 by modify_doxy.py rev. 669887