Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/classIPSGS__Processor.html below:

NCBI C++ ToolKit: IPSGS_Processor Class Reference

Search Toolkit Book for IPSGS_Processor

Interface class (and self-factory) for request processor objects that can retrieve data from a given data source. More...

#include "ipsgs_processor.hpp"
(Private to src/app/pubseq_gateway/server.)

Interface class (and self-factory) for request processor objects that can retrieve data from a given data source.

The overal life cycle of the processors is as follows. There is a one-time processors registration stage. On this stage a default processor constructor will be used. Then at the time when a request comes, all the registred processors will receive the CreateProcessor(...) call. All not NULL processors will be considered as those which are able to process the request. Later the infrastructure will call the created processors Process() method in parallel and periodically will call GetStatus() method. When all processors finished it is considered as the end of the request processing.

There are a few agreements for the processors.

• The server replies use PSG protocol. When something is needed to be sent to the client then m_Reply method should be used.
• When a processor is finished it should call the SignalProcessorFinished() method.
• If a processor needs to do any logging then two thing need to be done:
  • Set request context fot the current thread.
  • Use one of the macro PSG_TRACE, PSG_INFO, PSG_WARNING, PSG_ERROR, PSG_CRITICAL, PSG_MESSAGE (pubseq_gateway_logging.hpp)
  • Reset request context E.g.: { CRequestContextResetter context_resetter; m_Request->SetRequestContext(); ... PSG_WARNING("Something"); }
• The ProcessEvents() method can be called periodically (in addition to some events like Cassandra data ready)

Definition at line 72 of file ipsgs_processor.hpp.

The GetStatus() method returns a processor current status.

The order is important: basing on it a worst (max) and best (min) status is calculated for a group of processors.

Definition at line 78 of file ipsgs_processor.hpp.

Definition at line 104 of file ipsgs_processor.hpp.

Tells if processor can process the given request.

Parameters

request PSG request to retrieve the data for. It is guaranteed to be not null. reply The way to send reply chunks to the client. It is guaranteed to be not null.

Returns

true if the processor can process the request

Reimplemented in CPSGS_WGSProcessor, CPSGS_SNPProcessor, CPSGS_DummyProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, CPSGS_GetProcessor, CPSGS_AnnotProcessor, and CPSGS_AccessionVersionHistoryProcessor.

Definition at line 116 of file ipsgs_processor.hpp.

Create processor to fulfil PSG request using the data source.

Parameters

request PSG request to retrieve the data for. It is guaranteed to be not null. reply The way to send reply chunks to the client. It is guaranteed to be not null.

Returns

New processor object if this processor can theoretically fulfill (all or a part of) the request; else NULL.

Implemented in CPSGS_WGSProcessor, CPSGS_SNPProcessor, CPSGS_DummyProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, CPSGS_GetProcessor, CPSGS_AnnotProcessor, and CPSGS_AccessionVersionHistoryProcessor.

Tells the processor group name.

For example, all the processors which retrieve data from Cassandra should return the same name in response to this call. This name is used to control the total number of simultaneously working processors retrieving from the same backend.

Returns

the processor group name

Implemented in CPSGS_WGSProcessor, CPSGS_SNPProcessor, CPSGS_DummyProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, CPSGS_GetProcessor, CPSGS_AnnotProcessor, and CPSGS_AccessionVersionHistoryProcessor.

Referenced by CPSGSCounters::Increment(), COperationTiming::Register(), COperationTiming::RegisterProcessorDone(), and COperationTiming::RegisterProcessorPerformance().

Tells the processor name (used in logging and tracing)

Returns

the processor name

Implemented in CPSGS_WGSProcessor, CPSGS_SNPProcessor, CPSGS_DummyProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, CPSGS_GetProcessor, CPSGS_AnnotProcessor, and CPSGS_AccessionVersionHistoryProcessor.

Referenced by PostponeInvoke(), CPSGS_CassProcessorBase::ReportExplicitIncludeHUPSetToNo(), CPSGS_CassProcessorBase::ReportFailureToGetCassConnection(), CPSGS_CassProcessorBase::ReportMyNCBIError(), CPSGS_CassProcessorBase::ReportMyNCBINotFound(), CPSGS_CassProcessorBase::ReportNoWebCubbyUser(), CPSGS_CassProcessorBase::ReportSecureSatUnauthorized(), SetSocketCallback(), CPSGS_Dispatcher::SignalFinishProcessing(), CPSGS_Dispatcher::SignalStartProcessing(), CPSGS_CassProcessorBase::TranslateSatToKeyspace(), and CPSGS_Dispatcher::x_SendProgressMessage().

Provides the reply wrapper.

Returns

Reply wrapper which lets to send reply chunks to the user

Definition at line 200 of file ipsgs_processor.hpp.

References m_Reply.

Referenced by CPSGS_SNPProcessor::GetAnnotation(), CPSGS_CDDProcessor::GetBlobByBlobId(), CPSGS_SNPProcessor::GetBlobByBlobId(), CPSGS_WGSProcessor::GetBlobByBlobId(), CPSGS_CDDProcessor::GetBlobBySeqId(), CPSGS_WGSProcessor::GetBlobBySeqId(), CPSGS_CDDProcessor::GetBlobId(), CPSGS_SNPProcessor::GetChunk(), CPSGS_WGSProcessor::GetChunk(), CPSGS_Dispatcher::NotifyRequestFinished(), CPSGS_SNPProcessor::OnGotAnnotation(), CPSGS_CDDProcessor::OnGotBlobByBlobId(), CPSGS_SNPProcessor::OnGotBlobByBlobId(), CPSGS_WGSProcessor::OnGotBlobByBlobId(), CPSGS_CDDProcessor::OnGotBlobBySeqId(), CPSGS_WGSProcessor::OnGotBlobBySeqId(), CPSGS_CDDProcessor::OnGotBlobId(), CPSGS_SNPProcessor::OnGotChunk(), CPSGS_WGSProcessor::OnGotChunk(), CPSGS_WGSProcessor::OnResolvedSeqId(), CMyNCBIDataCallback::operator()(), CMyNCBIErrorCallback::operator()(), CPSGS_WGSProcessor::ResolveSeqId(), CPSGS_Dispatcher::SignalFinishProcessing(), CPSGS_Dispatcher::SignalStartProcessing(), CPSGS_SNPProcessor::x_OnSeqIdResolveError(), CPSGS_SNPProcessor::x_OnSeqIdResolveFinished(), CPSGS_SNPProcessor::x_Peek(), CPSGS_SNPProcessor::x_ProcessAnnotationRequest(), CPSGS_WGSProcessor::x_ProcessBlobBySatSatKeyRequest(), CPSGS_WGSProcessor::x_ProcessBlobBySeqIdRequest(), CPSGS_WGSProcessor::x_ProcessResolveRequest(), CPSGS_WGSProcessor::x_ProcessTSEChunkRequest(), CPSGS_CDDProcessor::x_SendAnnot(), CPSGS_CDDProcessor::x_SendAnnotInfo(), CPSGS_SNPProcessor::x_SendAnnotInfo(), CPSGS_WGSProcessor::x_SendBlob(), CPSGS_SNPProcessor::x_SendBlobData(), CPSGS_WGSProcessor::x_SendBlobData(), CPSGS_WGSProcessor::x_SendBlobForbidden(), CPSGS_SNPProcessor::x_SendBlobProps(), CPSGS_WGSProcessor::x_SendBlobProps(), CPSGS_SNPProcessor::x_SendChunkBlobData(), CPSGS_WGSProcessor::x_SendChunkBlobData(), CPSGS_SNPProcessor::x_SendChunkBlobProps(), CPSGS_WGSProcessor::x_SendChunkBlobProps(), CPSGS_CDDProcessor::x_SendError(), CPSGS_SNPProcessor::x_SendError(), CPSGS_WGSProcessor::x_SendResult(), and CPSGS_CDDProcessor::x_SignalStartProcessing().

Provides the user request.

Returns

User request

Definition at line 192 of file ipsgs_processor.hpp.

References m_Request.

Referenced by CPSGS_GetBlobProcessor::CreateProcessor(), CPSGS_TSEChunkProcessor::CreateProcessor(), CPSGS_SNPProcessor::GetAnnotation(), CPSGS_CDDProcessor::GetBlobByBlobId(), CPSGS_SNPProcessor::GetBlobByBlobId(), CPSGS_WGSProcessor::GetBlobByBlobId(), CPSGS_CDDProcessor::GetBlobBySeqId(), CPSGS_WGSProcessor::GetBlobBySeqId(), CPSGS_CDDProcessor::GetBlobId(), CPSGS_SNPProcessor::GetChunk(), CPSGS_WGSProcessor::GetChunk(), CPSGS_Dispatcher::NotifyRequestFinished(), CPSGS_SNPProcessor::OnGotAnnotation(), CPSGS_CDDProcessor::OnGotBlobByBlobId(), CPSGS_SNPProcessor::OnGotBlobByBlobId(), CPSGS_WGSProcessor::OnGotBlobByBlobId(), CPSGS_CDDProcessor::OnGotBlobBySeqId(), CPSGS_WGSProcessor::OnGotBlobBySeqId(), CPSGS_CDDProcessor::OnGotBlobId(), CPSGS_SNPProcessor::OnGotChunk(), CPSGS_WGSProcessor::OnGotChunk(), CPSGS_WGSProcessor::OnResolvedSeqId(), CMyNCBIDataCallback::operator()(), CMyNCBIErrorCallback::operator()(), CPSGS_Dispatcher::PopulateStatus(), CPSGS_CDDProcessor::Process(), CPSGS_SNPProcessor::Process(), CPSGS_WGSProcessor::Process(), COperationTiming::Register(), COperationTiming::RegisterProcessorPerformance(), CPSGS_WGSProcessor::ResolveSeqId(), CPSGS_Dispatcher::SignalFinishProcessing(), CPSGS_Dispatcher::SignalStartProcessing(), CPSGS_SNPProcessor::x_OnResolutionGoodData(), CPSGS_SNPProcessor::x_OnSeqIdResolveError(), CPSGS_SNPProcessor::x_OnSeqIdResolveFinished(), CPSGS_SNPProcessor::x_ProcessAnnotationRequest(), CPSGS_SNPProcessor::x_ProcessBlobBySatSatKeyRequest(), CPSGS_WGSProcessor::x_ProcessBlobBySatSatKeyRequest(), CPSGS_WGSProcessor::x_ProcessBlobBySeqIdRequest(), CPSGS_CDDProcessor::x_ProcessGetBlobRequest(), CPSGS_CDDProcessor::x_ProcessResolveRequest(), CPSGS_WGSProcessor::x_ProcessResolveRequest(), CPSGS_SNPProcessor::x_ProcessTSEChunkRequest(), CPSGS_WGSProcessor::x_ProcessTSEChunkRequest(), CPSGS_CDDProcessor::x_ReportResultStatus(), CPSGS_SNPProcessor::x_ReportResultStatusForAllNA(), CPSGS_CDDProcessor::x_SendAnnotInfo(), CPSGS_SNPProcessor::x_SendAnnotInfo(), CPSGS_CDDProcessor::x_SignalStartProcessing(), CPSGS_SNPProcessor::x_SignalStartProcessing(), CPSGS_CDDProcessor::x_UnlockRequest(), CPSGS_SNPProcessor::x_UnlockRequest(), and CPSGS_WGSProcessor::x_WaitForOtherProcessors().

Tells the processor status (if it has finished or in progress)

Returns

the current processor status

Implemented in CPSGS_WGSProcessor, CPSGS_SNPProcessor, CPSGS_DummyProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, CPSGS_CassProcessorBase, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, CPSGS_GetProcessor, CPSGS_AnnotProcessor, and CPSGS_AccessionVersionHistoryProcessor.

Referenced by CPSGS_Dispatcher::SignalFinishProcessing().

Parse seq-id from a string and type representation.

Parameters

seq_id Destination seq-id to place parsed value into. request_seq_id Input string containing seq-id to parse. request_seq_id_type Input seq-id type err_msg Optional string to receive error message if any.

Returns

ePSGS_ParsedOK on success, ePSGS_ParseFailed otherwise.

Definition at line 252 of file ipsgs_processor.cpp.

References CSeq_id::eFasta_AsTypeAndContent, ePSGS_ParsedOK, ePSGS_ParseFailed, GetEffectiveSeqIdType(), IsINSDCSeqIdType(), m_Reply, m_Request, CSeq_id::Set(), StripTrailingVerticalBars(), and CSeq_id_Base::Which().

Referenced by PSGSortSeqIds(), CPSGS_ResolveBase::ResolveTestInputSeqId(), CPSGS_SNPProcessor::x_OnSeqIdResolveFinished(), CPSGS_WGSProcessor::x_ProcessBlobBySeqIdRequest(), CPSGS_WGSProcessor::x_ProcessResolveRequest(), and CPSGS_ResolveBase::x_ResolveSeqId().

The provided callback will be called from the libuv loop assigned to the processor.

Parameters

cb The callback to be called from the libuv loop user_data The data to be passed to the callback

Definition at line 126 of file ipsgs_processor.cpp.

References CPubseqGatewayApp::GetInstance(), GetName(), GetUVThreadId(), m_Request, msg(), NCBI_THROW, and PSG_ERROR.

Referenced by CPSGS_CassProcessorBase::CancelLoaders(), CPSGS_SNPProcessor::GetAnnotation(), CPSGS_CDDProcessor::GetBlobByBlobId(), CPSGS_SNPProcessor::GetBlobByBlobId(), CPSGS_WGSProcessor::GetBlobByBlobId(), CPSGS_CDDProcessor::GetBlobBySeqId(), CPSGS_WGSProcessor::GetBlobBySeqId(), CPSGS_CDDProcessor::GetBlobId(), CPSGS_SNPProcessor::GetChunk(), CPSGS_WGSProcessor::GetChunk(), and CPSGS_WGSProcessor::ResolveSeqId().

Main processing function.

It should avoid throwing exceptions. In case of errors it must make sure that:

• the consequent GetStatus() calls return appropriate status
• call SignalFinishProcessing() if there in no more processor activity If an exception is generated it is still a must for a processor to fulfill the obligations above. The dispatching code will log the message (and possibly trace) and continue in this case.

Implemented in CPSGS_WGSProcessor, CPSGS_SNPProcessor, CPSGS_DummyProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, CPSGS_GetProcessor, CPSGS_AnnotProcessor, and CPSGS_AccessionVersionHistoryProcessor.

Referenced by CPSGS_ResolveBase::x_ResolveSeqId().

The provided callbacks will be called from the libuv loop assigned to the processor when the corresponding event appeared on the provided socket.

Parameters

fd The socket to poll event The event to wait for timeout_millisec The timeout of waiting for the event user_data The data to be passed to the callback event_cb The event callback timeout_cb The timeout callback error_cb The error callback

Note

The processor must make sure the socket is valid

Definition at line 160 of file ipsgs_processor.cpp.

References CPubseqGatewayApp::GetInstance(), GetName(), GetUVThreadId(), m_Request, msg(), NCBI_THROW, and PSG_ERROR.

Saves the libuv worker thread id which runs the processor.

To be used by the server framework only.

Parameters

uv_thread_id The libuv worker thread id which runs the processor

Definition at line 253 of file ipsgs_processor.hpp.

References m_UVThreadId.

A processor should call the method when it decides that it successfully started processing the request.

The other processors which are handling this request in parallel will be cancelled.

Returns

The flag to continue or to stop further activity

Definition at line 94 of file ipsgs_processor.cpp.

References g_AllowProcessorTiming, CPubseqGatewayApp::GetInstance(), m_SignalStartTimestamp, m_SignalStartTimestampInitialized, and CPubseqGatewayApp::SignalStartProcessing().

Referenced by CPSGS_GetBlobProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), CPSGS_AccessionVersionHistoryProcessor::x_OnResolutionGoodData(), CPSGS_GetProcessor::x_OnResolutionGoodData(), CPSGS_ResolveProcessor::x_OnResolutionGoodData(), CPSGS_CDDProcessor::x_SignalStartProcessing(), CPSGS_SNPProcessor::x_SignalStartProcessing(), and CPSGS_WGSProcessor::x_SignalStartProcessing().

Needs to be implemented only for the ID/get_na requests.

It returns a list of named annotations which a processor recognizes as suitable for processing.

Parameters

request PSG request to retrieve the data for. It is guaranteed to be not null. reply The way to send reply chunks to the client. It is guaranteed to be not null.

Returns

a list of annotations which can be processed

Reimplemented in CPSGS_SNPProcessor, CPSGS_CDDProcessor, CPSGS_CassProcessorDispatcher, and CPSGS_AnnotProcessor.

Definition at line 132 of file ipsgs_processor.hpp.

Definition at line 355 of file ipsgs_processor.hpp.

Referenced by CPSGS_CassProcessorBase::CPSGS_CassProcessorBase(), CPSGS_DummyProcessor::CPSGS_DummyProcessor(), CPSGS_WGSProcessor::CPSGS_WGSProcessor(), CPSGS_SNPProcessor::CreateProcessor(), GetPriority(), CPSGS_AnnotProcessor::OnGetBlobError(), CPSGS_AnnotProcessor::Process(), CPSGS_CDDProcessor::x_ProcessResolveRequest(), CPSGS_AnnotProcessor::x_RequestBlobProp(), CPSGS_AnnotProcessor::x_SendAnnotDataToClient(), and CPSGS_AnnotProcessor::x_SendBioseqInfo().

Definition at line 354 of file ipsgs_processor.hpp.

Referenced by CPSGS_AsyncResolveBase::AdjustBioseqAccession(), CPSGS_CassProcessorBase::CallOnData(), CPSGS_CassProcessorBase::CountError(), CPSGS_CassProcessorBase::CPSGS_CassProcessorBase(), CPSGS_DummyProcessor::CPSGS_DummyProcessor(), CPSGS_SNPProcessor::CPSGS_SNPProcessor(), CPSGS_WGSProcessor::CPSGS_WGSProcessor(), GetEffectiveSeqIdType(), GetReply(), CPSGS_AsyncResolveBase::GetSeqIdResolve(), CPSGS_AsyncResolveBase::MoveToNextSeqId(), CPSGS_AnnotProcessor::OnAnnotBlobProp(), CPSGS_CassBlobBase::OnGetBlobChunk(), CPSGS_AnnotProcessor::OnGetBlobChunk(), CPSGS_GetProcessor::OnGetBlobChunk(), CPSGS_GetBlobProcessor::OnGetBlobChunk(), CPSGS_TSEChunkProcessor::OnGetBlobChunk(), CPSGS_AnnotProcessor::OnGetBlobError(), CPSGS_GetProcessor::OnGetBlobError(), CPSGS_GetBlobProcessor::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetBlobError(), CPSGS_AnnotProcessor::OnGetBlobProp(), CPSGS_CassBlobBase::OnGetBlobProp(), CPSGS_GetProcessor::OnGetBlobProp(), CPSGS_GetBlobProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), CPSGS_TSEChunkProcessor::OnGetSplitHistoryError(), CPSGS_CassBlobBase::OnPublicComment(), CPSGS_CassBlobBase::OnPublicCommentError(), ParseInputSeqId(), CPSGS_CassProcessorBase::PopulateMyNCBIUser(), CPSGS_GetBlobProcessor::Process(), CPSGS_CassProcessorBase::ReportExplicitIncludeHUPSetToNo(), CPSGS_CassProcessorBase::ReportFailureToGetCassConnection(), CPSGS_CassProcessorBase::ReportMyNCBIError(), CPSGS_CassProcessorBase::ReportMyNCBINotFound(), CPSGS_CassProcessorBase::ReportNoWebCubbyUser(), CPSGS_CassProcessorBase::ReportSecureSatUnauthorized(), CPSGS_AsyncResolveBase::SetupSeqIdToResolve(), CPSGS_CassProcessorBase::TranslateSatToKeyspace(), CPSGS_CassBlobBase::x_BlobChunkCallback(), CPSGS_CassBlobBase::x_BlobErrorCallback(), CPSGS_CassBlobBase::x_BlobPropsCallback(), CPSGS_CassBlobBase::x_CheckId2Info(), CPSGS_ResolveBase::x_ComposeOSLT(), CPSGS_CassBlobBase::x_DecideToRequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_DeserializeSplitInfo(), CPSGS_IPGResolveProcessor::x_DetectSeqIdTypes(), CPSGS_IPGResolveProcessor::x_FormSeqId(), CPSGS_GetProcessor::x_GetBlob(), CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_TSEChunkProcessor::x_GetMyNCBIUser(), CPSGS_IPGResolveProcessor::x_InitiateIPGFetch(), CPSGS_IPGResolveProcessor::x_InitiateResolve(), CPSGS_CassBlobBase::x_IsAuthorized(), CPSGS_AsyncBioseqInfoBase::x_MakeRequest(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistData(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistError(), CPSGS_AsyncBioseqInfoBase::x_OnBioseqInfo(), CPSGS_AsyncResolveBase::x_OnBioseqInfo(), CPSGS_AsyncBioseqInfoBase::x_OnBioseqInfoWithoutSeqIdType(), CPSGS_AsyncResolveBase::x_OnBioseqInfoWithoutSeqIdType(), CPSGS_IPGResolveProcessor::x_OnIPGResolveData(), CPSGS_IPGResolveProcessor::x_OnIPGResolveError(), CPSGS_GetProcessor::x_OnMyNCBIError(), CPSGS_GetBlobProcessor::x_OnMyNCBIError(), CPSGS_TSEChunkProcessor::x_OnMyNCBIError(), CPSGS_AnnotProcessor::x_OnNamedAnnotData(), CPSGS_AnnotProcessor::x_OnNamedAnnotError(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveError(), CPSGS_AnnotProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveError(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveError(), CPSGS_ResolveProcessor::x_OnSeqIdResolveError(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveFinished(), CPSGS_AnnotProcessor::x_OnSeqIdResolveFinished(), CPSGS_ResolveBase::x_OnSeqIdResolveFinished(), CPSGS_AsyncResolveBase::x_OnSi2csiRecord(), CPSGS_ResolveBase::x_OptimizedNotFound(), CPSGS_AccessionVersionHistoryProcessor::x_Peek(), CPSGS_AnnotProcessor::x_Peek(), CPSGS_GetProcessor::x_Peek(), CPSGS_GetBlobProcessor::x_Peek(), CPSGS_IPGResolveProcessor::x_Peek(), CPSGS_ResolveProcessor::x_Peek(), CPSGS_TSEChunkProcessor::x_Peek(), CPSGS_CassBlobBase::x_PrepareBlobCompletion(), CPSGS_CassBlobBase::x_PrepareBlobData(), CPSGS_CassBlobBase::x_PrepareBlobExcluded(), CPSGS_CassBlobBase::x_PrepareBlobMessage(), CPSGS_CassBlobBase::x_PrepareBlobPropCompletion(), CPSGS_CassBlobBase::x_PrepareBlobPropData(), CPSGS_CassBlobBase::x_PrepareBlobPropMessage(), CPSGS_AsyncResolveBase::x_PreparePrimaryBioseqInfoQuery(), CPSGS_IPGResolveProcessor::x_PrepareRequestOnOriginalValues(), CPSGS_IPGResolveProcessor::x_PrepareRequestOnResolvedlValues(), CPSGS_AsyncResolveBase::x_PrepareSi2csiQuery(), CPSGS_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2Info(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage(), CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage(), CPSGS_AnnotProcessor::x_RequestBlobProp(), CPSGS_CassBlobBase::x_RequestID2BlobChunks(), CPSGS_CassBlobBase::x_RequestId2SplitBlobs(), CPSGS_CassBlobBase::x_RequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_RequestOriginalBlobChunks(), CPSGS_TSEChunkProcessor::x_RequestTSEChunk(), CPSGS_ResolveBase::x_ResolvePrimaryOSLTInCache(), CPSGS_ResolveBase::x_ResolveSecondaryOSLTInCache(), CPSGS_ResolveBase::x_ResolveSeqId(), CPSGS_AnnotProcessor::x_SendAnnotDataToClient(), CPSGS_AccessionVersionHistoryProcessor::x_SendBioseqInfo(), CPSGS_AnnotProcessor::x_SendBioseqInfo(), CPSGS_GetProcessor::x_SendBioseqInfo(), CPSGS_ResolveProcessor::x_SendBioseqInfo(), CPSGS_WGSProcessor::x_SendError(), and CPSGS_TSEChunkProcessor::x_SendProcessorError().

Definition at line 353 of file ipsgs_processor.hpp.

Referenced by CPSGS_AsyncResolveBase::AdjustBioseqAccession(), CPSGS_AsyncResolveBase::CanSkipBioseqInfoRetrieval(), CPSGS_CassProcessorBase::CountError(), CPSGS_CassProcessorBase::CPSGS_CassProcessorBase(), CPSGS_DummyProcessor::CPSGS_DummyProcessor(), CPSGS_SNPProcessor::CPSGS_SNPProcessor(), CPSGS_WGSProcessor::CPSGS_WGSProcessor(), CPSGS_AsyncResolveBase::GetAccessionSubstitutionOption(), CPSGS_AsyncResolveBase::GetBioseqInfoFields(), GetEffectiveSeqIdType(), GetRequest(), CPSGS_AsyncResolveBase::GetSeqIdResolve(), CPSGS_AsyncResolveBase::MoveToNextSeqId(), CPSGS_CassBlobBase::NeedToAddId2CunkId2Info(), CPSGS_AnnotProcessor::OnAnnotBlobProp(), CPSGS_CassBlobBase::OnGetBlobChunk(), CPSGS_TSEChunkProcessor::OnGetBlobChunk(), CPSGS_CassBlobBase::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetBlobError(), CPSGS_CassBlobBase::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), CPSGS_TSEChunkProcessor::OnGetSplitHistoryError(), CPSGS_CassBlobBase::OnPublicComment(), CPSGS_CassBlobBase::OnPublicCommentError(), ParseInputSeqId(), CPSGS_CassProcessorBase::PopulateMyNCBIUser(), PostponeInvoke(), CPSGS_AccessionVersionHistoryProcessor::Process(), CPSGS_AnnotProcessor::Process(), CPSGS_GetProcessor::Process(), CPSGS_GetBlobProcessor::Process(), CPSGS_ResolveProcessor::Process(), CPSGS_TSEChunkProcessor::Process(), CPSGS_WGSProcessor::Process(), CPSGS_CassProcessorBase::ReportExplicitIncludeHUPSetToNo(), CPSGS_CassProcessorBase::ReportNoWebCubbyUser(), SetSocketCallback(), CPSGS_AsyncResolveBase::SetupSeqIdToResolve(), CPSGS_CassProcessorBase::UnlockWaitingProcessor(), CPSGS_CassBlobBase::x_BlobChunkCallback(), CPSGS_CassBlobBase::x_BlobErrorCallback(), CPSGS_CassBlobBase::x_BlobPropsCallback(), CPSGS_CassBlobBase::x_CheckExcludeBlobCache(), CPSGS_ResolveBase::x_ComposeOSLT(), CPSGS_CassBlobBase::x_DecideToRequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_DeserializeSplitInfo(), CPSGS_IPGResolveProcessor::x_DetectSeqIdTypes(), CPSGS_IPGResolveProcessor::x_FormSeqId(), CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_AsyncResolveBase::x_GetRequestSeqId(), CPSGS_AsyncResolveBase::x_GetRequestSeqIdType(), CPSGS_ResolveBase::x_GetRequestUseCache(), CPSGS_IPGResolveProcessor::x_InitiateIPGFetch(), CPSGS_IPGResolveProcessor::x_InitiateResolve(), CPSGS_CassBlobBase::x_IsAuthorized(), CPSGS_AsyncBioseqInfoBase::x_MakeRequest(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistData(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistError(), CPSGS_AsyncBioseqInfoBase::x_OnBioseqInfo(), CPSGS_AsyncResolveBase::x_OnBioseqInfo(), CPSGS_AsyncBioseqInfoBase::x_OnBioseqInfoWithoutSeqIdType(), CPSGS_AsyncResolveBase::x_OnBioseqInfoWithoutSeqIdType(), CPSGS_CassBlobBase::x_OnBlobPropSlimTSE(), CPSGS_CassBlobBase::x_OnBlobPropSmartTSE(), CPSGS_IPGResolveProcessor::x_OnIPGResolveData(), CPSGS_IPGResolveProcessor::x_OnIPGResolveError(), CPSGS_AnnotProcessor::x_OnNamedAnnotData(), CPSGS_AnnotProcessor::x_OnNamedAnnotError(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveError(), CPSGS_AnnotProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveError(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveError(), CPSGS_ResolveProcessor::x_OnSeqIdResolveError(), CPSGS_ResolveBase::x_OnSeqIdResolveError(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveFinished(), CPSGS_AnnotProcessor::x_OnSeqIdResolveFinished(), CPSGS_GetProcessor::x_OnSeqIdResolveFinished(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveFinished(), CPSGS_ResolveBase::x_OnSeqIdResolveFinished(), CPSGS_ResolveProcessor::x_OnSeqIdResolveFinished(), CPSGS_AsyncResolveBase::x_OnSi2csiRecord(), CPSGS_ResolveBase::x_OptimizedNotFound(), CPSGS_CassBlobBase::x_PrepareBlobPropData(), CPSGS_AsyncResolveBase::x_PreparePrimaryBioseqInfoQuery(), CPSGS_IPGResolveProcessor::x_PrepareRequestOnOriginalValues(), CPSGS_IPGResolveProcessor::x_PrepareRequestOnResolvedlValues(), CPSGS_AsyncResolveBase::x_PrepareSi2csiQuery(), CPSGS_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2Info(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage(), CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage(), CPSGS_ResolveBase::x_RegisterSuccessTiming(), CPSGS_AnnotProcessor::x_RequestBlobProp(), CPSGS_CassBlobBase::x_RequestID2BlobChunks(), CPSGS_CassBlobBase::x_RequestId2SplitBlobs(), CPSGS_CassBlobBase::x_RequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_RequestOriginalBlobChunks(), CPSGS_TSEChunkProcessor::x_RequestTSEChunk(), CPSGS_ResolveBase::x_ResolvePrimaryOSLTInCache(), CPSGS_ResolveBase::x_ResolveSecondaryOSLTInCache(), CPSGS_ResolveBase::x_ResolveSeqId(), CPSGS_AnnotProcessor::x_SendAnnotDataToClient(), CPSGS_AccessionVersionHistoryProcessor::x_SendBioseqInfo(), CPSGS_AnnotProcessor::x_SendBioseqInfo(), CPSGS_GetProcessor::x_SendBioseqInfo(), CPSGS_ResolveProcessor::x_SendBioseqInfo(), CPSGS_TSEChunkProcessor::x_SendProcessorError(), and CPSGS_WGSProcessor::x_UnlockRequest().

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

• src/app/pubseq_gateway/server/ipsgs_processor.hpp
• src/app/pubseq_gateway/server/ipsgs_processor.cpp

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