<
classClass>
80 return(ptr?
" ...":
" null");
105 return "CPSGL_BioseqInfo_Processor";
117 constshared_ptr<CPSG_ReplyItem>& item)
119 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
")");
121 autobioseq_info = dynamic_pointer_cast<CPSG_BioseqInfo>(item);
122shared_ptr<SPsgBioseqInfo>
result;
132 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
") info: "<<
m_BioseqInfo.get());
140 constshared_ptr<CPSG_Reply>& reply)
142 _TRACE(
Descr()<<
": ProcessReplyFast("<<
int(status)<<
")");
165 return x_Failed(
"inconsistent reply:"+
187: m_Blob_id(blob_id),
195 const string& blob_id,
212 return "CPSGL_BlobInfo_Processor";
229 constshared_ptr<CPSG_ReplyItem>& item)
232 if(
autoblob_info = dynamic_pointer_cast<CPSG_BlobInfo>(item) ) {
234shared_ptr<SPsgBlobInfo>
result= make_shared<SPsgBlobInfo>(*blob_info);
253 constshared_ptr<CPSG_Reply>& reply)
276 return x_Failed(
"inconsistent reply:"+
298 const string& blob_id,
316 return "CPSGL_Info_Processor";
333 constshared_ptr<CPSG_ReplyItem>& item)
335 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
")");
337 autobioseq_info = dynamic_pointer_cast<CPSG_BioseqInfo>(item);
338shared_ptr<SPsgBioseqInfo>
result;
348 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
") info: "<<
m_BioseqInfo.get());
351 if(
autoblob_info = dynamic_pointer_cast<CPSG_BlobInfo>(item) ) {
353shared_ptr<SPsgBlobInfo>
result= make_shared<SPsgBlobInfo>(*blob_info);
372 constshared_ptr<CPSG_Reply>& reply)
374 _TRACE(
Descr()<<
": ProcessReplyFast("<<
int(status)<<
")");
393 return x_Failed(
"inconsistent reply:"+
423 return x_Failed(
"inconsistent reply:"+
441m_IsWPAcc(is_WP_acc),
455 return "CPSGL_IpgTaxId_Processor";
467 constshared_ptr<CPSG_ReplyItem>& item)
469 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
")");
471 if(
autoipg_info = dynamic_pointer_cast<CPSG_IpgInfo>(item) ) {
476 m_TaxId= tax_id = ipg_info->GetTaxId();
478 else if(ipg_info->GetNucleotide().empty()) {
479 m_TaxId= tax_id = ipg_info->GetTaxId();
481 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
") tax id: "<<
m_TaxId);
488 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
") no tax id");
489 return x_Failed(
"no IPG tax id");
498 constshared_ptr<CPSG_Reply>& reply)
500 _TRACE(
Descr()<<
": ProcessReplyFast("<<
int(status)<<
")");
521m_SeqIdSet(seq_id_set),
522m_DataSource(data_source),
535 return "CPSGL_CDDAnnot_Processor";
547 constshared_ptr<CPSG_ReplyItem>& item)
549 switch( item->GetType() ) {
551 m_AnnotInfo= dynamic_pointer_cast<CPSG_NamedAnnotInfo>(item);
554 m_AnnotStatus= dynamic_pointer_cast<CPSG_NamedAnnotStatus>(item);
556 return x_Failed(
"annot status: failed");
560 m_BlobInfo= dynamic_pointer_cast<CPSG_BlobInfo>(item);
563 m_BlobData= dynamic_pointer_cast<CPSG_BlobData>(item);
574 constshared_ptr<CPSG_Reply>& reply)
595 constshared_ptr<CPSG_Reply>& reply)
644 return x_Failed(
"cannot open CDD data stream for "+
m_SeqIdSet.front().AsString());
653 if( chunk_load_lock.
get() && *chunk_load_lock.
get() ) {
696 return "CPSGL_Get_Processor";
726 constshared_ptr<CPSG_ReplyItem>& item)
729 autobioseq_info = dynamic_pointer_cast<CPSG_BioseqInfo>(item);
730shared_ptr<SPsgBioseqInfo>
result;
742dl_blob_id =
result->GetDLBlobId();
749 _TRACE(
Descr()<<
": ProcessItemFast("<<
int(status)<<
", "<<item.get()<<
") info: "<<
m_BioseqInfo.get());
760 constshared_ptr<CPSG_Reply>& reply)
771 _TRACE(
Descr()<<
": ProcessReplySlow(): processed w/o TSE");
807 if( !psg_blob_id.empty() ) {
816 if( psg_blob_id.empty() ) {
832 constshared_ptr<CPSG_Reply>& reply)
834 _TRACE(
Descr()<<
": ProcessReplyFast("<<(
int)status<<
")");
842 constshared_ptr<CPSG_Reply>& reply)
844 _TRACE(
Descr()<<
": ProcessReplySlow("<<(
int)status<<
")");
883m_Blob_id(dl_blob_id.ToPsgId())
896 return "CPSGL_GetBlob_Processor";
908 constshared_ptr<CPSG_Reply>& reply)
926 constshared_ptr<CPSG_Reply>& reply)
975 return "CPSGL_GetChunk_Processor";
1002 constshared_ptr<CPSG_Reply>& reply)
1021 booladd_wgs_master)
1037 return "CPSGL_NA_Processor";
1048pair<CRef<CTSE_Chunk_Info>,
string>
1054 unsignedmain_count = 0;
1055 unsignedzoom_count = 0;
1075vector<SAnnotTypeSelector>
types;
1083 for(
autofeat_type_info_iter : annot_info.
GetFeat() ) {
1085 intfeat_type = finfo.
GetType();
1086 if( feat_type == 0 ) {
1095 for(
autofeat_subtype : finfo.
GetSubtypes() ) {
1110 if(
names.size() == 1 ) {
1111name = *
names.begin();
1119 " annots: "<<name<<
" "<<main_count<<
"+"<<zoom_count);
1121 returnmake_pair(chunk, name);
1127 constshared_ptr<CPSG_ReplyItem>& item)
1129 switch(item->GetType()) {
1131 if(
autoannot_status = dynamic_pointer_cast<CPSG_NamedAnnotStatus>(item) ) {
1133 return x_Failed(
"annot status: failed");
1135 for(
auto& s : annot_status->GetId2AnnotStatusList() ) {
1142 return x_Failed(
"annot status: absent");
1155 constshared_ptr<CPSG_ReplyItem>& item)
1157 switch(item->GetType()) {
1159 if(
autoannot_info = dynamic_pointer_cast<CPSG_NamedAnnotInfo>(item) ) {
1161 r.m_NA = annot_info->GetName();
1162 r.m_Blob_id = annot_info->GetBlobId().GetId();
1167 if( !name.empty() ) {
1168dl_blob_id->SetTSEName(name);
1177 r.m_TSE_Lock = load_lock;
1185 m_AnnotInfos.push_back(make_pair(status, annot_info));
1198 constshared_ptr<CPSG_Reply>& reply)
1237 booladd_wgs_master)
1241m_CDDChunkInfo(cdd_chunk_info),
1255 return "CPSGL_LocalCDDBlob_Processor";
1274 constshared_ptr<CPSG_ReplyItem>& item)
1276 switch(item->GetType()) {
1278 if(
autoannot_status = dynamic_pointer_cast<CPSG_NamedAnnotStatus>(item) ) {
1280 return x_Failed(
"annot status: failed");
1284 return x_Failed(
"annot status: absent");
1288 if(
autoannot_info = dynamic_pointer_cast<CPSG_NamedAnnotInfo>(item) ) {
1289 stringna = annot_info->GetName();
1318 constshared_ptr<CPSG_Reply>& reply)
1320 _TRACE(
Descr()<<
": ProcessReplySlow("<<
int(status)<<
")");
User-defined methods of the data storage class.
User-defined methods of the data storage class.
User-defined methods of the data storage class.
const string & GetName(void) const
CTSE_LoadLock GetTSE_LoadLock(const TBlobId &blob_id)
CID2S_Feat_type_Info â.
CID2S_Seq_annot_Info â.
mapped_type Add(const key_type &key, const SPsgAnnotInfo::TInfos &infos)
mapped_type Add(const key_type &key, const CPSG_BioseqInfo &info)
void Add(const TKey &key, const TValue &value)
CPSGCache_Base< CPSGBlobInfoCache::key_type, EPSG_Status > m_NoBlobInfoCache
CPSGCache_Base< CPSGBioseqInfoCache::key_type, bool > m_NoBioseqInfoCache
CPSGBlobInfoCache m_BlobInfoCache
CPSGIpgTaxIdCache m_IpgTaxIdCache
CPSGBioseqInfoCache m_BioseqInfoCache
CPSGCache_Base< CPSGAnnotInfoCache::key_type, bool > m_NoAnnotInfoCache
CPSGCache_Base< string, bool > m_NoCDDCache
CPSGAnnotInfoCache m_AnnotInfoCache
shared_ptr< CPSG_BioseqInfo > m_BioseqInfo
const CSeq_id_Handle & GetSeq_id() const
ostream & PrintProcessorArgs(ostream &out) const override
EPSG_Status m_BioseqInfoStatus
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
const char * GetProcessorName() const override
~CPSGL_BioseqInfo_Processor() override
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
CFastMutex m_BioseqInfoMutex
CPSGL_BioseqInfo_Processor(const CSeq_id_Handle &seq_id, CPSGCaches *caches=nullptr)
shared_ptr< SPsgBioseqInfo > m_BioseqInfoResult
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
EPSG_Status m_BlobInfoStatus
shared_ptr< CPSG_BlobInfo > m_BlobInfo
ostream & PrintProcessorArgs(ostream &out) const override
CFastMutex m_BlobInfoMutex
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
~CPSGL_BlobInfo_Processor() override
const char * GetProcessorName() const override
CPSGL_BlobInfo_Processor(const CSeq_id_Handle &seq_id, CPSGCaches *caches=nullptr)
shared_ptr< SPsgBlobInfo > m_BlobInfoResult
void SetDLBlobId(const string &psg_blob_id, const CConstRef< CPsgBlobId > &dl_blob_id)
bool GotUnauthorized() const
void SetLockedDelayedChunkInfo(const string &psg_blob_id, CTSE_Chunk_Info &locked_chunk_info)
EProcessResult ProcessItemSlow(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
EProcessResult ProcessTSE_Lock(const string &blob_id, CTSE_Lock &tse_lock, EWaitForLock wait_for_lock=eNoWaitForLock)
void SetLockedChunkInfo(CTSE_Chunk_Info &locked_chunk_info)
int GetBlobInfoState(const string &psg_blob_id)
CDataSource * m_DataSource
bool GotForbidden() const
CDataSource * m_DataSource
shared_ptr< CPSG_NamedAnnotStatus > m_AnnotStatus
EProcessResult ProcessReplySlow(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
shared_ptr< CPSG_NamedAnnotInfo > m_AnnotInfo
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
CPSGL_CDDAnnot_Processor(const SCDDIds &cdd_ids, const TSeqIdSet &id_set, CDataSource *data_source, CPSGCaches *caches=nullptr)
ostream & PrintProcessorArgs(ostream &out) const override
const char * GetProcessorName() const override
shared_ptr< CPSG_BlobInfo > m_BlobInfo
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
shared_ptr< CPSG_BlobData > m_BlobData
vector< CSeq_id_Handle > TSeqIdSet
~CPSGL_CDDAnnot_Processor() override
EProcessResult ProcessReplyFinal() override
CPSGL_GetBlob_Processor(const CPsgBlobId &dl_blob_id, CDataSource *data_source, CPSGCaches *caches=nullptr, bool add_wgs_master=false)
~CPSGL_GetBlob_Processor() override
ostream & PrintProcessorArgs(ostream &out) const override
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
EProcessResult ProcessReplySlow(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
const char * GetProcessorName() const override
CPSGL_GetChunk_Processor(CTSE_Chunk_Info &chunk, CDataSource *data_source, CPSGCaches *caches=nullptr, bool add_wgs_master=false)
void AddChunk(CTSE_Chunk_Info &chunk)
EProcessResult ProcessReplySlow(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
ostream & PrintProcessorArgs(ostream &out) const override
~CPSGL_GetChunk_Processor() override
const char * GetProcessorName() const override
vector< CTSE_Chunk_Info * > m_Chunks
ostream & PrintChunk(ostream &out, CTSE_Chunk_Info &chunk) const
CPSGL_Get_Processor(const CSeq_id_Handle &seq_id, CDataSource *data_source, CPSGCaches *caches=nullptr, bool add_wgs_master=false)
EProcessResult ProcessReplySlow(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
const string & GetPSGBlobId() const
CConstRef< CPsgBlobId > CreateDLBlobId(STSESlot *tse_slot) override
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
EPSG_Status m_BioseqInfoStatus
EProcessResult x_PreProcessReply(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply)
~CPSGL_Get_Processor() override
shared_ptr< SPsgBioseqInfo > m_BioseqInfoResult
ostream & PrintProcessorArgs(ostream &out) const override
EProcessResult ProcessReplyFinal() override
const char * GetProcessorName() const override
CConstRef< CPsgBlobId > GetDLBlobId() const
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
~CPSGL_Info_Processor() override
ostream & PrintProcessorArgs(ostream &out) const override
const CSeq_id_Handle & GetSeq_id() const
shared_ptr< SPsgBioseqInfo > m_BioseqInfoResult
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
EPSG_Status m_BioseqInfoStatus
EPSG_Status m_BlobInfoStatus
shared_ptr< CPSG_BioseqInfo > m_BioseqInfo
shared_ptr< SPsgBlobInfo > m_BlobInfoResult
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
CPSGL_Info_Processor(const CSeq_id_Handle &seq_id, CPSGCaches *caches=nullptr)
shared_ptr< CPSG_BlobInfo > m_BlobInfo
const char * GetProcessorName() const override
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
CFastMutex m_IpgTaxIdMutex
CPSGL_IpgTaxId_Processor(const CSeq_id_Handle &seq_id, bool is_WP_acc, CPSGCaches *caches=nullptr)
const char * GetProcessorName() const override
EProcessResult ProcessReplyFast(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
~CPSGL_IpgTaxId_Processor() override
ostream & PrintProcessorArgs(ostream &out) const override
EProcessResult ProcessReplySlow(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
CPSGL_LocalCDDBlob_Processor(CTSE_Chunk_Info &cdd_chunk_info, const SCDDIds &cdd_ids, CDataSource *data_source, CPSGCaches *caches=nullptr, bool add_wgs_master=false)
~CPSGL_LocalCDDBlob_Processor() override
CConstRef< CPsgBlobId > CreateDLBlobId(STSESlot *tse_slot) override
ostream & PrintProcessorArgs(ostream &out) const override
CFastMutex m_CDDProcessorMutex
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
CTSE_Chunk_Info & m_CDDChunkInfo
const char * GetProcessorName() const override
EProcessResult ProcessItemSlow(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
const char * GetProcessorName() const override
vector< CSeq_id_Handle > TSeq_ids
CFastMutex m_NAProcessorMutex
ostream & PrintProcessorArgs(ostream &out) const override
~CPSGL_NA_Processor() override
CPSGL_NA_Processor(const TSeq_ids &ids, CDataSource *data_source, CPSGCaches *caches=nullptr, bool add_wgs_master=false)
EProcessResult ProcessReplyFinal() override
EProcessResult ProcessItemFast(EPSG_Status status, const shared_ptr< CPSG_ReplyItem > &item) override
EProcessResult ProcessReplySlow(EPSG_Status status, const shared_ptr< CPSG_Reply > &reply) override
EProcessResult x_Failed(const string &message)
SProcessorDescrPrinter Descr() const
static string x_FormatAndSetError(EPSG_Status &status)
static string x_Format(EPSG_Status status)
const string & GetId() const
Get ID.
Named Annotations (NAs) metainfo â reply to CPSG_Request_NamedAnnotInfo.
CPSG_BlobId GetBlobId() const
Coordinates of the blob that contains the NA data.
TId2AnnotInfoList GetId2AnnotInfoList() const
Named Annotations (NAs) status â reply to CPSG_Request_NamedAnnotInfo.
TId2AnnotStatusList GetId2AnnotStatusList() const
const string & ToPsgId() const
static void x_ParseLocation(TLocationSet &vec, const CID2S_Seq_loc &loc)
TBlobId GetBlobId(void) const
void SetLoaded(CObject *obj=0)
vector< TLocation > TLocationSet
TChunkId GetChunkId(void) const
void x_AddAnnotType(const CAnnotName &annot_name, const SAnnotTypeSelector &annot_type, const TLocationId &location_id)
CInitGuard * GetLoadInitGuard(void)
CTSE_Split_Info & GetSplitInfo(void)
bool x_NeedsDelayedMainChunk(void) const
void SetSeq_entry(CSeq_entry &entry, CTSE_SetObjectInfo *set_info=0)
bool IsLoaded(void) const
CTSE_Chunk_Info & GetChunk(TChunkId chunk_id)
void AddChunk(CTSE_Chunk_Info &chunk_info)
std::ofstream out("events_result.xml")
main entry point for tests
static const struct name_t names[]
static const struct type types[]
#define ITERATE(Type, Var, Cont)
ITERATE macro to sequence through container elements.
element_type * get(void) const
Get pointer.
SStrictId_Tax::TId TTaxId
Taxon id type.
#define LOG_POST(message)
This macro is deprecated and it's strongly recomended to move in all projects (except tests) to macro...
void Info(CExceptionArgs_Base &args)
#define MSerial_AsnText
I/O stream manipulators â.
string ToString(void) const
bool ExtractZoomLevel(const string &full_name, string *acc_ptr, int *zoom_level_ptr)
Extract optional zoom level suffix from named annotation string.
CRef< C > Ref(C *object)
Helper functions to get CRef<> and CConstRef<> objects.
const TSubtypes & GetSubtypes(void) const
Get the Subtypes member data.
const TSeq_loc & GetSeq_loc(void) const
Get the Seq_loc member data.
bool IsSetGraph(void) const
Check if a value has been assigned to Graph data member.
bool IsSetAlign(void) const
Check if a value has been assigned to Align data member.
bool IsSetSubtypes(void) const
Check if a value has been assigned to Subtypes data member.
const TName & GetName(void) const
Get the Name member data.
const TFeat & GetFeat(void) const
Get the Feat member data.
bool IsSetFeat(void) const
Check if a value has been assigned to Feat data member.
TType GetType(void) const
Get the Type member data.
E_Choice
Choice variants.
std::istream & in(std::istream &in_, double &x_)
double r(size_t dimension_, const Int4 *score_, const double *prob_, double theta_)
CTSE_Lock x_CreateLocalCDDEntry(CDataSource *data_source, const SCDDIds &ids)
const char kCDDAnnotName[]
unsigned s_GetDebugLevel()
CObjectIStream * GetBlobDataStream(const CPSG_BlobInfo &blob_info, const CPSG_BlobData &blob_data)
const bool kCreateLocalCDDEntries
void UpdateOMBlobId(CTSE_LoadLock &load_lock, const CConstRef< CPsgBlobId > &dl_blob_id)
string x_MakeLocalCDDEntryId(const SCDDIds &cdd_ids)
void x_CreateEmptyLocalCDDEntry(CDataSource *data_source, CTSE_Chunk_Info *chunk)
bool x_IsEmptyCDD(const CTSE_Info &tse)
EPSG_Status
Retrieval result.
@ eSuccess
Successfully retrieved.
@ eForbidden
User is not authorized for the retrieval.
@ eError
An error was encountered while trying to send request or to read and to process the reply.
static pair< CRef< CTSE_Chunk_Info >, string > s_CreateNAChunk(const CPSG_NamedAnnotInfo &psg_annot_info)
static string x_FormatPtr(const shared_ptr< Class > &ptr)
static bool s_SameId(const CPSG_BlobId *id1, const CPSG_BlobId &id2)
static bool s_HasFailedStatus(const CPSG_NamedAnnotStatus &na_status)
list< shared_ptr< CPSG_NamedAnnotInfo > > TInfos
RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4