A RetroSearch Logo

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

Search Query:

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

NCBI C++ ToolKit: CPSGS_CassProcessorBase Class Reference

Search Toolkit Book for CPSGS_CassProcessorBase

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

  CPSGS_CassProcessorBase ()     CPSGS_CassProcessorBase (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority)   virtual  ~CPSGS_CassProcessorBase ()   virtual void  Cancel (void) override   The infrastructure request to cancel processing. More...
  void  SignalFinishProcessing (void)   void  UnlockWaitingProcessor (void)   void  CallOnData (void)   string  GetVerboseFetches (void) const   void  EnforceWait (void) const     IPSGS_Processor ()   virtual  ~IPSGS_Processor ()   virtual bool  CanProcess (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply) const   Tells if processor can process the given request. More...
  virtual vector< string >  WhatCanProcess (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply) const   Needs to be implemented only for the ID/get_na requests. More...
  virtual IPSGS_Processor *  CreateProcessor (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority) const =0   Create processor to fulfil PSG request using the data source. More...
  virtual void  Process (void)=0   Main processing function. More...
  virtual string  GetName (void) const =0   Tells the processor name (used in logging and tracing) More...
  virtual string  GetGroupName (void) const =0   Tells the processor group name. More...
  virtual void  ProcessEvent (void)   Called when an event happened which may require to have some processing. More...
  shared_ptr< CPSGS_Request >  GetRequest (void) const   Provides the user request. More...
  shared_ptr< CPSGS_Reply >  GetReply (void) const   Provides the reply wrapper. More...
  TProcessorPriority  GetPriority (void) const   Provides the processor priority. More...
  void  PostponeInvoke (CPSGS_UvLoopBinder::TProcessorCB cb, void *user_data)   The provided callback will be called from the libuv loop assigned to the processor. More...
  void  SetSocketCallback (int fd, CPSGS_SocketIOCallback::EPSGS_Event event, uint64_t timeout_millisec, void *user_data, CPSGS_SocketIOCallback::TEventCB event_cb, CPSGS_SocketIOCallback::TTimeoutCB timeout_cb, CPSGS_SocketIOCallback::TErrorCB error_cb)   The provided callbacks will be called from the libuv loop assigned to the processor when the corresponding event appeared on the provided socket. More...
  void  SetUVThreadId (uv_thread_t uv_thread_id)   Saves the libuv worker thread id which runs the processor. More...
  uv_thread_t  GetUVThreadId (void) const   Provides the libuv thread id which runs the processor. More...
  bool  IsUVThreadAssigned (void) const   Tells if a libuv thread id has been assigned to the processor. More...
  psg_time_point_t  GetProcessInvokeTimestamp (bool &is_valid) const   Provides the timestamp of when the Process() method was called. More...
  psg_time_point_t  GetSignalStartTimestamp (bool &is_valid) const   Provides the timestamp of when the processor called SignalStartProcessing() method. More...
  psg_time_point_t  GetSignalFinishTimestamp (bool &is_valid) const   Provides the timestamp of when the processor called SignalFinishProcessing() method. More...
  void  OnBeforeProcess (void)   Called just before the virtual Process() method is called. More...
  EPSGS_StartProcessing  SignalStartProcessing (void)   A processor should call the method when it decides that it successfully started processing the request. More...
  void  SignalFinishProcessing (void)   A processor should call this method when it decides that there is nothing else to be done. More...
  EPSGS_SeqIdParsingResult  ParseInputSeqId (objects::CSeq_id &seq_id, const string &request_seq_id, int request_seq_id_type, string *err_msg=nullptr)   Parse seq-id from a string and type representation. More...
  IPSGS_Processor::EPSGS_Status  GetStatus (void) override   Tells the processor status (if it has finished or in progress) More...
  bool  AreAllFinishedRead (void) const   bool  IsMyNCBIFinished (void) const   void  UpdateOverallStatus (CRequestStatus::ECode status)   bool  IsCassandraProcessorEnabled (shared_ptr< CPSGS_Request > request) const   void  CancelLoaders (void)   SCass_BlobId  TranslateSatToKeyspace (CBioseqInfoRecord::TSat sat, CBioseqInfoRecord::TSatKey sat_key, const string &seq_id)   bool  IsTimeoutError (const string &msg) const   bool  IsTimeoutError (int code) const   bool  IsError (EDiagSev severity) const   CRequestStatus::ECode  CountError (CCassFetch *fetch_details, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message, EPSGS_LoggingFlag logging_flag, EPSGS_StatusUpdateFlag status_update_flag)   EPSGS_MyNCBILookupResult  PopulateMyNCBIUser (TMyNCBIDataCB data_cb, TMyNCBIErrorCB error_cb)   void  ReportNoWebCubbyUser (void)   void  ReportExplicitIncludeHUPSetToNo (void)   void  ReportMyNCBIError (CRequestStatus::ECode status, const string &my_ncbi_message)   void  ReportMyNCBINotFound (void)   void  ReportSecureSatUnauthorized (const string &user_name)   void  ReportFailureToGetCassConnection (const string &message)   void  ReportFailureToGetCassConnection (void)   void  CleanupMyNCBICache (void)   bool  GetEffectiveSeqIdType (const objects::CSeq_id &parsed_seq_id, int request_seq_id_type, int16_t &eff_seq_id_type, bool need_trace)  

Definition at line 54 of file cass_processor_base.hpp.

◆ EPSGS_MyNCBILookupResult Enumerator ePSGS_IncludeHUPSetToNo  ePSGS_FoundInOKCache  ePSGS_FoundInErrorCache  ePSGS_FoundInNotFoundCache  ePSGS_CookieNotPresent  ePSGS_RequestInitiated  ePSGS_AddedToWaitlist 

Definition at line 91 of file cass_processor_base.hpp.

◆ CPSGS_CassProcessorBase() [1/2] ◆ CPSGS_CassProcessorBase() [2/2] ◆ ~CPSGS_CassProcessorBase() CPSGS_CassProcessorBase::~CPSGS_CassProcessorBase ( ) virtual ◆ AreAllFinishedRead() bool CPSGS_CassProcessorBase::AreAllFinishedRead ( void  ) const protected

Definition at line 202 of file cass_processor_base.cpp.

References m_FetchDetails.

Referenced by CPSGS_AnnotProcessor::OnAnnotBlobProp(), SignalFinishProcessing(), CPSGS_AnnotProcessor::x_OnNamedAnnotData(), CPSGS_AnnotProcessor::x_OnNamedAnnotError(), 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_SNPProcessor::x_Peek(), and CPSGS_TSEChunkProcessor::x_Peek().

◆ CallOnData() void CPSGS_CassProcessorBase::CallOnData ( void  ) ◆ Cancel() void CPSGS_CassProcessorBase::Cancel ( void  ) overridevirtual ◆ CancelLoaders() void CPSGS_CassProcessorBase::CancelLoaders ( void  ) protected ◆ CleanupMyNCBICache() void CPSGS_CassProcessorBase::CleanupMyNCBICache ( void  ) protected ◆ CountError()

Definition at line 377 of file cass_processor_base.cpp.

References CRequestStatus::e404_NotFound, CRequestStatus::e504_GatewayTimeout, ePSGS_AccVerHistoryFetch, CPSGSCounters::ePSGS_AccVerHistoryNotFound, ePSGS_AnnotationBlobFetch, CPSGSCounters::ePSGS_AnnotationBlobNotFound, ePSGS_AnnotationFetch, CPSGSCounters::ePSGS_AnnotationNotFound, ePSGS_BioseqInfoFetch, CPSGSCounters::ePSGS_BioseqInfoNotFound, ePSGS_BlobBySatSatKeyFetch, ePSGS_BlobBySeqIdFetch, CPSGSCounters::ePSGS_CassQueryTimeoutError, CPSGSCounters::ePSGS_GetBlobNotFound, ePSGS_IPGResolveFetch, CPSGSCounters::ePSGS_IPGResolveNotFound, ePSGS_NeedLogging, ePSGS_NeedStatusUpdate, CPSGSCounters::ePSGS_ProcUnknownError, ePSGS_PublicCommentFetch, CPSGSCounters::ePSGS_PublicCommentNotFound, ePSGS_Si2csiFetch, CPSGSCounters::ePSGS_Si2csiNotFound, ePSGS_SplitHistoryFetch, CPSGSCounters::ePSGS_SplitHistoryNotFound, ePSGS_TSEChunkFetch, CPSGSCounters::ePSGS_TSEChunkNotFound, ePSGS_UnknownFetch, CCassFetch::GetFetchType(), CPubseqGatewayApp::GetInstance(), IsError(), IsTimeoutError(), IPSGS_Processor::m_Reply, IPSGS_Processor::m_Request, PSG_ERROR, PSG_WARNING, CCassFetch::Serialize(), CNcbiDiag::SeverityName(), and UpdateOverallStatus().

Referenced by CPSGS_CassBlobBase::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetSplitHistoryError(), CPSGS_CassBlobBase::OnPublicCommentError(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistError(), CPSGS_IPGResolveProcessor::x_OnIPGResolveError(), CPSGS_AnnotProcessor::x_OnNamedAnnotError(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveError(), CPSGS_AnnotProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveError(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveError(), and CPSGS_ResolveProcessor::x_OnSeqIdResolveError().

◆ EnforceWait() void CPSGS_CassProcessorBase::EnforceWait ( void  ) const ◆ GetStatus()

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

Returns
the current processor status

Implements IPSGS_Processor.

Reimplemented in CPSGS_SNPProcessor, CPSGS_TSEChunkProcessor, CPSGS_ResolveProcessor, CPSGS_IPGResolveProcessor, CPSGS_GetBlobProcessor, and CPSGS_GetProcessor.

Definition at line 132 of file cass_processor_base.cpp.

References CRequestStatus::e100_Continue, CRequestStatus::e401_Unauthorized, CRequestStatus::e504_GatewayTimeout, IPSGS_Processor::ePSGS_Canceled, IPSGS_Processor::ePSGS_Done, IPSGS_Processor::ePSGS_Error, IPSGS_Processor::ePSGS_InProgress, IPSGS_Processor::ePSGS_NotFound, IPSGS_Processor::ePSGS_Timeout, IPSGS_Processor::ePSGS_Unauthorized, m_Canceled, and m_Status.

Referenced by CPSGS_AccessionVersionHistoryProcessor::GetStatus(), CPSGS_AnnotProcessor::GetStatus(), CPSGS_GetProcessor::GetStatus(), CPSGS_GetBlobProcessor::GetStatus(), CPSGS_IPGResolveProcessor::GetStatus(), CPSGS_ResolveProcessor::GetStatus(), and CPSGS_TSEChunkProcessor::GetStatus().

◆ GetVerboseFetches() string CPSGS_CassProcessorBase::GetVerboseFetches ( void  ) const ◆ IsCassandraProcessorEnabled() bool CPSGS_CassProcessorBase::IsCassandraProcessorEnabled ( shared_ptr< CPSGS_Request >  request ) const protected

Definition at line 280 of file cass_processor_base.cpp.

References NStr::CompareNocase(), CPubseqGatewayApp::GetInstance(), kCassandra, SPSGS_RequestBase::m_DisabledProcessors, and SPSGS_RequestBase::m_EnabledProcessors.

Referenced by CPSGS_AccessionVersionHistoryProcessor::CanProcess(), CPSGS_AnnotProcessor::CanProcess(), CPSGS_GetProcessor::CanProcess(), CPSGS_GetBlobProcessor::CanProcess(), CPSGS_IPGResolveProcessor::CanProcess(), CPSGS_ResolveProcessor::CanProcess(), and CPSGS_TSEChunkProcessor::CanProcess().

◆ IsError() bool CPSGS_CassProcessorBase::IsError ( EDiagSev  severity ) const protected

Definition at line 368 of file cass_processor_base.cpp.

References eDiag_Critical, eDiag_Error, and eDiag_Fatal.

Referenced by CountError(), CPSGS_CassBlobBase::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetSplitHistoryError(), CPSGS_CassBlobBase::OnPublicCommentError(), CPSGS_CassBlobBase::x_BlobErrorCallback(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistError(), CPSGS_IPGResolveProcessor::x_OnIPGResolveError(), and CPSGS_AnnotProcessor::x_OnNamedAnnotError().

◆ IsMyNCBIFinished() bool CPSGS_CassProcessorBase::IsMyNCBIFinished ( void  ) const protected ◆ IsTimeoutError() [1/2] ◆ IsTimeoutError() [2/2] bool CPSGS_CassProcessorBase::IsTimeoutError ( int  code ) const protected ◆ PopulateMyNCBIUser()

Definition at line 511 of file cass_processor_base.cpp.

References CRequestStatus::e404_NotFound, eDiag_Error, ePSGS_AddedToWaitlist, ePSGS_CookieNotPresent, ePSGS_FoundInErrorCache, ePSGS_FoundInNotFoundCache, ePSGS_FoundInOKCache, ePSGS_IncludeHUPSetToNo, SMyNCBIOKCacheItem::ePSGS_Ready, ePSGS_RequestInitiated, g_MyNCBICacheLock, CPubseqGatewayApp::GetInstance(), m_MyNCBICookie, IPSGS_Processor::m_Reply, IPSGS_Processor::m_Request, m_UserName, m_WhoAmIRequest, ReportExplicitIncludeHUPSetToNo(), and ReportNoWebCubbyUser().

Referenced by CPSGS_GetBlobProcessor::Process(), CPSGS_GetProcessor::x_GetBlob(), and CPSGS_TSEChunkProcessor::x_GetMyNCBIUser().

◆ ReportExplicitIncludeHUPSetToNo() void CPSGS_CassProcessorBase::ReportExplicitIncludeHUPSetToNo ( void  ) protected ◆ ReportFailureToGetCassConnection() [1/2] void CPSGS_CassProcessorBase::ReportFailureToGetCassConnection ( const string &  message ) protected ◆ ReportFailureToGetCassConnection() [2/2] void CPSGS_CassProcessorBase::ReportFailureToGetCassConnection ( void  ) protected

Definition at line 721 of file cass_processor_base.cpp.

References CRequestStatus::e500_InternalServerError, eDiag_Error, ePSGS_CassConnectionError, CPSGSCounters::ePSGS_FailureToGetCassConnectionCounter, CPubseqGatewayApp::GetInstance(), IPSGS_Processor::GetName(), IPSGS_Processor::m_Reply, PSG_ERROR, and UpdateOverallStatus().

Referenced by CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_CassBlobBase::x_PrepareBlobPropData(), CPSGS_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage(), CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage(), CPSGS_CassBlobBase::x_RequestID2BlobChunks(), CPSGS_CassBlobBase::x_RequestId2SplitBlobs(), CPSGS_CassBlobBase::x_RequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_RequestOriginalBlobChunks(), and CPSGS_TSEChunkProcessor::x_RequestTSEChunk().

◆ ReportMyNCBIError() ◆ ReportMyNCBINotFound() void CPSGS_CassProcessorBase::ReportMyNCBINotFound ( void  ) protected

Definition at line 704 of file cass_processor_base.cpp.

References CRequestStatus::e401_Unauthorized, eDiag_Warning, ePSGS_MyNCBINotFound, CPSGSCounters::ePSGS_MyNCBINotFoundCounter, CPubseqGatewayApp::GetInstance(), IPSGS_Processor::GetName(), IPSGS_Processor::m_Reply, PSG_NOTE, and UpdateOverallStatus().

Referenced by CPSGS_GetProcessor::x_OnMyNCBIError(), CPSGS_GetBlobProcessor::x_OnMyNCBIError(), and CPSGS_TSEChunkProcessor::x_OnMyNCBIError().

◆ ReportNoWebCubbyUser() void CPSGS_CassProcessorBase::ReportNoWebCubbyUser ( void  ) protected ◆ ReportSecureSatUnauthorized() void CPSGS_CassProcessorBase::ReportSecureSatUnauthorized ( const string &  user_name ) protected

Definition at line 781 of file cass_processor_base.cpp.

References CRequestStatus::e401_Unauthorized, eDiag_Error, ePSGS_SecureSatUnauthorized, CPSGSCounters::ePSGS_SecureSatUnauthorizedCounter, CPubseqGatewayApp::GetInstance(), IPSGS_Processor::GetName(), IPSGS_Processor::m_Reply, PSG_ERROR, and UpdateOverallStatus().

Referenced by CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_CassBlobBase::x_PrepareBlobPropData(), CPSGS_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage(), CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage(), CPSGS_CassBlobBase::x_RequestID2BlobChunks(), CPSGS_CassBlobBase::x_RequestId2SplitBlobs(), CPSGS_CassBlobBase::x_RequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_RequestOriginalBlobChunks(), and CPSGS_TSEChunkProcessor::x_RequestTSEChunk().

◆ SignalFinishProcessing() void CPSGS_CassProcessorBase::SignalFinishProcessing ( void  )

Definition at line 86 of file cass_processor_base.cpp.

References AreAllFinishedRead(), CRequestStatus::e100_Continue, CRequestStatus::e200_Ok, CRequestStatus::e500_InternalServerError, IsMyNCBIFinished(), IPSGS_Processor::m_FinishSignalled, m_Status, NCBI_PARAM_TYPE, IPSGS_Processor::SignalFinishProcessing(), and UnlockWaitingProcessor().

Referenced by CPSGS_AnnotProcessor::OnAnnotBlobProp(), CPSGS_GetProcessor::OnGetBlobChunk(), CPSGS_TSEChunkProcessor::OnGetBlobChunk(), CPSGS_AnnotProcessor::OnGetBlobError(), CPSGS_GetProcessor::OnGetBlobError(), CPSGS_GetBlobProcessor::OnGetBlobError(), CPSGS_TSEChunkProcessor::OnGetBlobError(), CPSGS_AnnotProcessor::OnGetBlobProp(), CPSGS_GetProcessor::OnGetBlobProp(), CPSGS_GetBlobProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), CPSGS_TSEChunkProcessor::OnGetSplitHistoryError(), CPSGS_AnnotProcessor::Process(), CPSGS_GetBlobProcessor::Process(), TranslateSatToKeyspace(), CPSGS_SNPProcessor::x_Finish(), CPSGS_GetProcessor::x_GetBlob(), CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_TSEChunkProcessor::x_GetMyNCBIUser(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistData(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistError(), 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_OnResolutionGoodData(), CPSGS_GetProcessor::x_OnResolutionGoodData(), CPSGS_ResolveProcessor::x_OnResolutionGoodData(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveError(), CPSGS_AnnotProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveError(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveError(), CPSGS_ResolveProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveFinished(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveFinished(), CPSGS_ResolveProcessor::x_OnSeqIdResolveFinished(), CPSGS_TSEChunkProcessor::x_ParseTSEChunkId2Info(), 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_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2Info(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage(), CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage(), CPSGS_AnnotProcessor::x_RequestBlobProp(), CPSGS_CassBlobBase::x_RequestOriginalBlobChunks(), CPSGS_TSEChunkProcessor::x_RequestTSEChunk(), CPSGS_AccessionVersionHistoryProcessor::x_SendBioseqInfo(), CPSGS_AnnotProcessor::x_SendBioseqInfo(), CPSGS_TSEChunkProcessor::x_SendProcessorError(), CPSGS_TSEChunkProcessor::x_TSEChunkSatToKeyspace(), and CPSGS_TSEChunkProcessor::x_ValidateTSEChunkNumber().

◆ TranslateSatToKeyspace()

Definition at line 318 of file cass_processor_base.cpp.

References CRequestStatus::e500_InternalServerError, eDiag_Error, CPSGSCounters::ePSGS_ServerSatToSatNameError, ePSGS_UnknownResolvedSatellite, CPubseqGatewayApp::GetInstance(), IPSGS_Processor::GetName(), IPSGS_Processor::m_Reply, SCass_BlobId::m_Sat, SCass_BlobId::MapSatToKeyspace(), msg(), PSG_ERROR, SignalFinishProcessing(), and UpdateOverallStatus().

Referenced by CPSGS_GetProcessor::x_OnSeqIdResolveFinished().

◆ UnlockWaitingProcessor() void CPSGS_CassProcessorBase::UnlockWaitingProcessor ( void  )

Definition at line 121 of file cass_processor_base.cpp.

References kCassandraProcessorEvent, IPSGS_Processor::m_Request, and m_Unlocked.

Referenced by Cancel(), CPSGS_GetBlobProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), SignalFinishProcessing(), CPSGS_AccessionVersionHistoryProcessor::x_OnResolutionGoodData(), CPSGS_GetProcessor::x_OnResolutionGoodData(), CPSGS_ResolveProcessor::x_OnResolutionGoodData(), and ~CPSGS_CassProcessorBase().

◆ UpdateOverallStatus()

Definition at line 271 of file cass_processor_base.cpp.

References m_Status, and max().

Referenced by CountError(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), CPSGS_AnnotProcessor::Process(), CPSGS_GetBlobProcessor::Process(), ReportExplicitIncludeHUPSetToNo(), ReportFailureToGetCassConnection(), ReportMyNCBIError(), ReportMyNCBINotFound(), ReportNoWebCubbyUser(), ReportSecureSatUnauthorized(), TranslateSatToKeyspace(), CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistData(), CPSGS_CassBlobBase::x_OnBlobPropNotFound(), CPSGS_IPGResolveProcessor::x_OnIPGResolveData(), CPSGS_AnnotProcessor::x_OnNamedAnnotData(), CPSGS_AnnotProcessor::x_OnNamedAnnotError(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveFinished(), CPSGS_TSEChunkProcessor::x_ParseTSEChunkId2Info(), 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_SNPProcessor::x_Peek(), CPSGS_TSEChunkProcessor::x_Peek(), CPSGS_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2Info(), CPSGS_AnnotProcessor::x_RequestBlobProp(), CPSGS_CassBlobBase::x_RequestID2BlobChunks(), CPSGS_CassBlobBase::x_RequestId2SplitBlobs(), CPSGS_CassBlobBase::x_RequestMoreChunksForSmartTSE(), CPSGS_TSEChunkProcessor::x_RequestTSEChunk(), CPSGS_TSEChunkProcessor::x_SendProcessorError(), CPSGS_TSEChunkProcessor::x_TSEChunkSatToKeyspace(), and CPSGS_TSEChunkProcessor::x_ValidateTSEChunkNumber().

◆ m_Canceled bool CPSGS_CassProcessorBase::m_Canceled protected

Definition at line 116 of file cass_processor_base.hpp.

Referenced by Cancel(), CPSGS_AccessionVersionHistoryProcessor::GetStatus(), CPSGS_AnnotProcessor::GetStatus(), CPSGS_GetProcessor::GetStatus(), CPSGS_GetBlobProcessor::GetStatus(), CPSGS_IPGResolveProcessor::GetStatus(), CPSGS_ResolveProcessor::GetStatus(), CPSGS_TSEChunkProcessor::GetStatus(), GetStatus(), CPSGS_AnnotProcessor::OnAnnotBlobProp(), 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_GetProcessor::OnGetBlobProp(), CPSGS_GetBlobProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetBlobProp(), CPSGS_TSEChunkProcessor::OnGetSplitHistory(), CPSGS_TSEChunkProcessor::OnGetSplitHistoryError(), CPSGS_CassBlobBase::OnPublicComment(), CPSGS_CassBlobBase::OnPublicCommentError(), CPSGS_AccessionVersionHistoryProcessor::x_OnAccVerHistData(), CPSGS_IPGResolveProcessor::x_OnIPGResolveData(), CPSGS_AnnotProcessor::x_OnNamedAnnotData(), CPSGS_AccessionVersionHistoryProcessor::x_OnResolutionGoodData(), CPSGS_GetProcessor::x_OnResolutionGoodData(), CPSGS_ResolveProcessor::x_OnResolutionGoodData(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveError(), CPSGS_AnnotProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveError(), CPSGS_IPGResolveProcessor::x_OnSeqIdResolveError(), CPSGS_ResolveProcessor::x_OnSeqIdResolveError(), CPSGS_GetProcessor::x_OnSeqIdResolveFinished(), CPSGS_ResolveProcessor::x_OnSeqIdResolveFinished(), 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_AccessionVersionHistoryProcessor::x_SendBioseqInfo(), CPSGS_AnnotProcessor::x_SendBioseqInfo(), and CPSGS_TSEChunkProcessor::x_SendProcessorError().

◆ m_FetchDetails list<unique_ptr<CCassFetch> > CPSGS_CassProcessorBase::m_FetchDetails protected

Definition at line 114 of file cass_processor_base.hpp.

Referenced by AreAllFinishedRead(), CancelLoaders(), EnforceWait(), GetVerboseFetches(), CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_IPGResolveProcessor::x_InitiateIPGFetch(), CPSGS_AsyncBioseqInfoBase::x_MakeRequest(), CPSGS_AccessionVersionHistoryProcessor::x_OnSeqIdResolveFinished(), CPSGS_AnnotProcessor::x_OnSeqIdResolveFinished(), 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_SNPProcessor::x_Peek(), CPSGS_TSEChunkProcessor::x_Peek(), CPSGS_CassBlobBase::x_PrepareBlobPropData(), CPSGS_AsyncResolveBase::x_PreparePrimaryBioseqInfoQuery(), CPSGS_AsyncResolveBase::x_PrepareSi2csiQuery(), CPSGS_GetBlobProcessor::x_Process(), 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(), and CPSGS_TSEChunkProcessor::x_RequestTSEChunk().

◆ m_MyNCBICookie optional<string> CPSGS_CassProcessorBase::m_MyNCBICookie protected ◆ m_Status ◆ m_Unlocked bool CPSGS_CassProcessorBase::m_Unlocked protected ◆ m_UserName optional<string> CPSGS_CassProcessorBase::m_UserName protected

Definition at line 125 of file cass_processor_base.hpp.

Referenced by PopulateMyNCBIUser(), CPSGS_GetProcessor::x_GetBlobFinalStage(), CPSGS_GetBlobProcessor::x_OnMyNCBIData(), CPSGS_GetProcessor::x_OnMyNCBIData(), CPSGS_TSEChunkProcessor::x_OnMyNCBIData(), CPSGS_CassBlobBase::x_PrepareBlobPropData(), CPSGS_GetBlobProcessor::x_Process(), CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage(), CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage(), CPSGS_CassBlobBase::x_RequestID2BlobChunks(), CPSGS_CassBlobBase::x_RequestId2SplitBlobs(), CPSGS_CassBlobBase::x_RequestMoreChunksForSmartTSE(), CPSGS_CassBlobBase::x_RequestOriginalBlobChunks(), and CPSGS_TSEChunkProcessor::x_RequestTSEChunk().

◆ m_WhoAmIRequest

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

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