shared_ptr<CPSGS_Reply> reply)
const override;
68 bool CanProcess(shared_ptr<CPSGS_Request> request,
69shared_ptr<CPSGS_Reply> reply)
const override;
71shared_ptr<CPSGS_Reply> reply,
73 void Process(
void)
override;
74 void Cancel(
void)
override;
76 string GetName(
void)
const override;
90shared_ptr<ncbi::CThreadPool> thread_pool,
91shared_ptr<CPSGS_Request> request,
92shared_ptr<CPSGS_Reply> reply,
105 void x_SendAnnotInfo(
constobjects::CCDD_Reply_Get_Blob_Id& blob_info);
111 static void x_SendError(shared_ptr<CPSGS_Reply> reply,
112 const string&
msg);
113 static void x_SendError(shared_ptr<CPSGS_Reply> reply,
114 const string&
msg,
constexception& exc);
const string kCDDProcessorEvent
CCDD_Reply_Get_Blob_Id â.
void x_UnlockRequest(void)
void x_SendAnnotInfo(const objects::CCDD_Reply_Get_Blob_Id &blob_info)
vector< objects::CSeq_id_Handle > m_SeqIds
void x_SendAnnot(const objects::CID2_Blob_Id &id2_blob_id, CRef< objects::CSeq_annot > &annot)
bool x_CanProcessAnnotRequestIds(SPSGS_AnnotRequest &annot_request) const
vector< string > WhatCanProcess(shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply) const override
Needs to be implemented only for the ID/get_na requests.
bool x_SignalStartProcessing()
void GetBlobByBlobId(void)
void OnGotBlobByBlobId(void)
void x_Finish(EPSGS_Status status)
objects::CCDDClientPool::SCDDBlob m_CDDBlob
void x_ProcessGetBlobRequest(void)
string GetGroupName(void) const override
Tells the processor group name.
bool x_CanProcessSeq_id(const string &psg_id) const
void x_RegisterTimingNotFound(EPSGOperation operation)
void Process(void) override
Main processing function.
~CPSGS_CDDProcessor(void) override
void GetBlobBySeqId(void)
bool x_NameIncluded(const vector< string > &names) const
IPSGS_Processor * CreateProcessor(shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority) const override
Create processor to fulfil PSG request using the data source.
bool x_IsEnabled(CPSGS_Request &request) const
void Cancel(void) override
The infrastructure request to cancel processing.
bool x_CanProcessAnnotRequest(SPSGS_AnnotRequest &annot_request, TProcessorPriority priority) const
void x_ReportResultStatus(SPSGS_AnnotRequest::EPSGS_ResultStatus status)
CPSGS_CDDProcessor(shared_ptr< objects::CCDDClientPool > client_pool, shared_ptr< ncbi::CThreadPool > thread_pool, shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority)
void OnGotBlobBySeqId(void)
string GetName(void) const override
Tells the processor name (used in logging and tracing)
bool CanProcess(shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply) const override
Tells if processor can process the given request.
EPSGS_Status GetStatus(void) override
Tells the processor status (if it has finished or in progress)
shared_ptr< ncbi::CThreadPool > m_ThreadPool
CRef< objects::CCDDClientPool::TBlobId > m_BlobId
static void x_SendError(shared_ptr< CPSGS_Reply > reply, const string &msg)
void x_RegisterTiming(EPSGOperation operation, EPSGOperationStatus status, size_t size)
bool x_CanProcessBlobRequest(SPSGS_BlobBySatSatKeyRequest &blob_request) const
shared_ptr< objects::CCDDClientPool > m_ClientPool
void x_ProcessResolveRequest(void)
Main class implementing functionality of pool of threads.
Interface class (and self-factory) for request processor objects that can retrieve data from a given ...
EPSGS_Status
The GetStatus() method returns a processor current status.
static const struct name_t names[]
operation
Bit operations.
const struct ncbi::grid::netcache::search::fields::SIZE size
psg_clock_t::time_point psg_time_point_t
static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)
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