NCBI C++ ToolKit
|
Search Toolkit Book for CProcessor
#include <objtools/data_loaders/genbank/impl/processor.hpp>
Public Types | |
enum | EType { eType_ID1 , eType_ID1_SNP , eType_Seq_entry , eType_Seq_entry_SNP , eType_St_Seq_entry , eType_St_Seq_entry_SNPT , eType_ID2 , eType_ID2AndSkel , eType_ID2_SE , eType_ID2_Split , eType_ID2_Chunk , eType_ID2_SNP , eType_ExtAnnot , eType_AnnotInfo } |
typedef CBlob_id | TBlobId |
typedef int | TBlobState |
typedef int | TBlobVersion |
typedef int | TChunkId |
typedef unsigned | TMagic |
![]() | |
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 | |
virtual | ~CProcessor (void) |
virtual EType | GetType (void) const =0 |
virtual TMagic | GetMagic (void) const =0 |
virtual void | ProcessStream (CReaderRequestResult &result, const TBlobId &blob_id, TChunkId chunk_id, CNcbiIstream &stream) const |
virtual void | ProcessObjStream (CReaderRequestResult &result, const TBlobId &blob_id, TChunkId chunk_id, CObjectIStream &obj_stream) const |
void | ProcessBlobFromID2Data (CReaderRequestResult &result, const TBlobId &blob_id, TChunkId chunk_id, const CID2_Reply_Data &data) const |
![]() | |
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... | |
![]() | |
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 |
Protected Member Functions | |
CProcessor (CReadDispatcher &dispatcher) | |
CWriter * | GetWriter (const CReaderRequestResult &result) const |
![]() | |
virtual void | DeleteThis (void) |
Virtual method "deleting" this object. More... | |
Protected Attributes | |
CReadDispatcher * | m_Dispatcher |
Additional Inherited Members | |
![]() | |
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... | |
Definition at line 61 of file processor.hpp.
typedef CBlob_id CProcessor::TBlobId |
Definition at line 64 of file processor.hpp.
typedef int CProcessor::TBlobState |
Definition at line 65 of file processor.hpp.
typedef int CProcessor::TBlobVersion |
Definition at line 66 of file processor.hpp.
typedef int CProcessor::TChunkId |
Definition at line 67 of file processor.hpp.
typedef unsigned CProcessor::TMagic |
Definition at line 84 of file processor.hpp.
enum CProcessor::EType | ( | void | ) |
Definition at line 68 of file processor.hpp.
|
virtual |
Definition at line 232 of file processors.cpp.
|
protected |
Definition at line 226 of file processors.cpp.
|
inlinestaticprotected |
Definition at line 219 of file processors.cpp.
References NCBI_PARAM_TYPE, and ncbi::grid::netcache::search::s_Value().
Definition at line 139 of file processor.hpp.
References GetGiOffset(), and OffsetGi().
Referenced by CId1Reader::LoadGiBlob_ids(), CPubseqReader::LoadGiHash(), CPubseqReader::LoadGiSeq_ids(), CPubseqReader::LoadSeq_idAccVer(), CId1Reader::LoadSeq_idBlob_ids(), and CPubseqReader::LoadSeq_idInfo().
Definition at line 144 of file processor.hpp.
References GetGiOffset(), and OffsetGi().
Referenced by CProcessor_ExtAnnot::Process().
|
inlinestatic |
Definition at line 149 of file processor.hpp.
References GetGiOffset(), and OffsetId().
Referenced by CPubseqReader::LoadSeq_idInfo().
|
static |
Definition at line 417 of file processors.cpp.
References NCBI_PARAM_TYPE.
Referenced by ConvertGiFromOM(), ConvertGiToOM(), ConvertIdFromOM(), OffsetAllGisFromOM(), OffsetAllGisToOM(), OffsetGiToOM(), and OffsetIdToOM().
|
pure virtual |
Implemented in CProcessor_AnnotInfo, CProcessor_ExtAnnot, CProcessor_ID2AndSkel, CProcessor_ID2_Split, CProcessor_ID2, CProcessor_St_SE_SNPT, CProcessor_St_SE, CProcessor_SE_SNP, CProcessor_SE, CProcessor_ID1_SNP, and CProcessor_ID1.
Referenced by CWriter::WriteProcessorTag(), and CCacheReader::x_ProcessBlob().
|
pure virtual |
Implemented in CProcessor_AnnotInfo, CProcessor_ExtAnnot, CProcessor_ID2AndSkel, CProcessor_ID2_Split, CProcessor_ID2, CProcessor_St_SE_SNPT, CProcessor_St_SE, CProcessor_SE_SNP, CProcessor_SE, CProcessor_ID1_SNP, and CProcessor_ID1.
Referenced by CReadDispatcher::InsertProcessor(), CWriter::WriteProcessorTag(), and CCacheReader::x_ProcessBlob().
|
inlineprotected |
Definition at line 407 of file processors.cpp.
References CWriter::eBlobWriter, CReadDispatcher::GetWriter(), m_Dispatcher, and result.
Referenced by CProcessor_ExtAnnot::Process(), CProcessor_ID2::ProcessData(), CProcessor_ID1::ProcessObjStream(), CProcessor_ID1_SNP::ProcessObjStream(), CProcessor_St_SE::ProcessObjStream(), CProcessor_St_SE_SNPT::ProcessStream(), and CProcessor_SE::x_GetWriterToSaveBlob().
|
inlinestaticprotected |
Definition at line 184 of file processor.hpp.
References LogStat(), and ncbi::grid::netcache::search::fields::size.
|
staticprotected |
Definition at line 2479 of file processors.cpp.
References cmd, CReaderRequestResultRecursion::GetResult(), CReadDispatcher::LogStat(), and ncbi::grid::netcache::search::fields::size.
Referenced by LogStat(), CProcessor_ID2::ProcessData(), CProcessor_ID1::ProcessObjStream(), CProcessor_ID1_SNP::ProcessObjStream(), CProcessor_SE::ProcessObjStream(), CProcessor_SE_SNP::ProcessObjStream(), CProcessor_St_SE::ProcessObjStream(), CProcessor_ID2::ProcessObjStream(), CProcessor_ID2_Split::ProcessObjStream(), CProcessor_ID2AndSkel::ProcessObjStream(), and CProcessor_St_SE_SNPT::ProcessStream().
|
inlinestaticprotected |
Definition at line 201 of file processor.hpp.
References LogStat(), and ncbi::grid::netcache::search::fields::size.
|
inlinestaticprotected |
Definition at line 192 of file processor.hpp.
References LogStat(), and ncbi::grid::netcache::search::fields::size.
|
staticprotected |
Definition at line 2491 of file processors.cpp.
References cmd, CReaderRequestResultRecursion::GetResult(), CReadDispatcher::LogStat(), and ncbi::grid::netcache::search::fields::size.
|
inlinestaticprotected |
Definition at line 209 of file processor.hpp.
References LogStat(), and ncbi::grid::netcache::search::fields::size.
|
static |
Definition at line 499 of file processors.cpp.
References CID1server_request_Base::e_Getgihist, CID1server_request_Base::e_Getgirev, CID1server_request_Base::e_Getgistate, CID1server_request_Base::e_Getseqidsfromgi, CID1server_back_Base::IsGotgi(), CID2S_Seq_loc_Base::IsWhole_gi(), NON_CONST_ITERATE, OffsetGi(), OffsetId(), CID1server_request_Base::SetGetgihist(), CID1server_request_Base::SetGetgirev(), CID1server_request_Base::SetGetgistate(), CID1server_request_Base::SetGetseqidsfromgi(), CID1server_back_Base::SetGotgi(), CID2S_Seq_loc_Base::SetWhole_gi(), and CID1server_request_Base::Which().
Referenced by OffsetAllGisFromOM(), and OffsetAllGisToOM().
|
static |
Definition at line 572 of file processors.cpp.
References CTSE_SetObjectInfo::m_Seq_annot_InfoMap, and NON_CONST_ITERATE.
|
static |
Definition at line 584 of file processors.cpp.
References GetGiOffset(), and OffsetAllGis().
Referenced by CId2ReaderBase::x_SendID2Packet(), CId1Reader::x_SendRequest(), and CId2ReaderBase::x_SendToConnection().
|
static |
Definition at line 590 of file processors.cpp.
References GetGiOffset(), and OffsetAllGis().
Referenced by CProcessor_ID2::ProcessData(), CProcessor_ID1::ProcessObjStream(), CProcessor_ID1_SNP::ProcessObjStream(), CProcessor_SE::ProcessObjStream(), CProcessor_SE_SNP::ProcessObjStream(), CProcessor_St_SE_SNPT::ProcessStream(), CId2ReaderBase::x_ReceiveFromConnection(), CId2ReaderBase::x_ReceiveID2Reply(), and CId1Reader::x_ReceiveReply().
Definition at line 120 of file processor.hpp.
References GI_FROM, and ZERO_GI.
Referenced by ConvertGiFromOM(), ConvertGiToOM(), OffsetAllGis(), and OffsetGiToOM().
Definition at line 127 of file processor.hpp.
Definition at line 154 of file processor.hpp.
References GetGiOffset(), and OffsetGi().
Referenced by CPubseqReader::LoadSeq_idInfo().
Definition at line 429 of file processors.cpp.
References NStr::eNocase, NStr::EqualNocase(), NStr::fConvErr_NoThrow, CDbtag_Base::GetDb(), GI_FROM, NPOS, NStr::NumericToString(), CDbtag_Base::SetTag(), NStr::StartsWith(), NStr::StringToNumeric(), tag, and ZERO_GI.
Referenced by ConvertIdFromOM(), OffsetAllGis(), OffsetId(), and OffsetIdToOM().
|
static |
Definition at line 476 of file processors.cpp.
References CSeq_id_Base::e_General, CSeq_id_Handle::GetGiHandle(), CSeq_id_Handle::GetHandle(), GetSeqId(), GI_FROM, OffsetId(), SerialClone(), and ZERO_GI.
Definition at line 158 of file processor.hpp.
References GetGiOffset(), and OffsetId().
Referenced by CPubseqReader::LoadGiSeq_ids().
void CProcessor::ProcessBlobFromID2Data | ( | CReaderRequestResult & | result, |
const TBlobId & | blob_id, | ||
TChunkId | chunk_id, | ||
const CID2_Reply_Data & | data | ||
) | const |
Definition at line 262 of file processors.cpp.
References CID2_Reply_Data_Base::eData_compression_gzip, CID2_Reply_Data_Base::eData_compression_none, CID2_Reply_Data_Base::eData_format_asn_binary, CRWStreambuf::fOwnAll, CCompressionStream::fOwnProcessor, CID2_Reply_Data_Base::GetData(), CID2_Reply_Data_Base::GetData_compression(), CID2_Reply_Data_Base::GetData_format(), CID2_Reply_Data_Base::IsSetData(), NCBI_THROW, ProcessStream(), and result.
Referenced by CId2ReaderBase::x_ProcessGetBlob().
|
virtual |
Reimplemented in CProcessor_ID2AndSkel, CProcessor_ID2_Split, CProcessor_ID2, CProcessor_St_SE, CProcessor_SE_SNP, CProcessor_SE, CProcessor_ID1_SNP, and CProcessor_ID1.
Definition at line 252 of file processors.cpp.
References NCBI_THROW.
Referenced by ProcessStream().
|
virtual |
Reimplemented in CProcessor_ExtAnnot, and CProcessor_St_SE_SNPT.
Definition at line 237 of file processors.cpp.
References ProcessObjStream(), and result.
Referenced by CId1Reader::GetBlob(), CPubseqReader::GetBlob(), ProcessBlobFromID2Data(), and CCacheReader::x_ProcessBlob().
|
static |
Definition at line 299 of file processors.cpp.
References CReadDispatcher::InsertProcessor().
Referenced by CReadDispatcher::CReadDispatcher().
|
static |
|
static |
Definition at line 356 of file processors.cpp.
References in(), s_UseMemoryPool(), TryStringPack(), and type.
Referenced by CProcessor_ID1::ProcessObjStream(), CProcessor_SE::ProcessObjStream(), and CProcessor_ID2::x_ReadData().
|
static |
Definition at line 380 of file processors.cpp.
References in(), TryStringPack(), and type.
Referenced by CSeq_annot_SNP_Info_Reader::Parse(), and CSeq_annot_SNP_Info_Reader::Read().
|
static |
Definition at line 328 of file processors.cpp.
References NCBI_PARAM_TYPE, and ncbi::grid::netcache::search::s_Value().
Referenced by CId1Reader::LoadGiBlob_ids(), and CPubseqReader::LoadSeq_idInfo().
|
static |
Definition at line 335 of file processors.cpp.
References NCBI_PARAM_TYPE, and ncbi::grid::netcache::search::s_Value().
Referenced by CSeq_annot_SNP_Info_Reader::Parse().
|
static |
Definition at line 314 of file processors.cpp.
References NCBI_PARAM_TYPE, and CPackString::TryStringPack().
Referenced by SetSeqEntryReadHooks(), and SetSNPReadHooks().
|
protected |
Definition at line 168 of file processor.hpp.
Referenced by GetWriter(), CProcessor_ID2::ProcessData(), CProcessor_ID1_SNP::ProcessObjStream(), CProcessor_SE::ProcessObjStream(), CProcessor_SE_SNP::ProcessObjStream(), and CProcessor_St_SE::ProcessObjStream().