NCBI C++ ToolKit
Public Member Functions | Protected Member Functions | Protected Attributes | Private Types | Private Member Functions | List of all members
CPSGS_AsyncResolveBase Class Reference

Search Toolkit Book for CPSGS_AsyncResolveBase

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

+ Inheritance diagram for CPSGS_AsyncResolveBase:
+ Collaboration diagram for CPSGS_AsyncResolveBase:

Public Member Functions

 CPSGS_AsyncResolveBase ()
 
 CPSGS_AsyncResolveBase (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TContinueResolveCB continue_resolve_cb, TSeqIdResolutionFinishedCB finished_cb, TSeqIdResolutionErrorCB error_cb, TSeqIdResolutionStartProcessingCB start_processing_cb)
 
virtual ~CPSGS_AsyncResolveBase ()
 
void Process (int16_t effective_version, int16_t effective_seq_id_type, list< string > &&secondary_id_list, string &&primary_seq_id, bool composed_ok, SBioseqResolution &&bioseq_resolution)
 
void x_OnBioseqInfo (vector< CBioseqInfoRecord > &&records)
 
void x_OnBioseqInfoWithoutSeqIdType (vector< CBioseqInfoRecord > &&records)
 
void x_OnBioseqInfoError (CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
void x_OnSi2csiRecord (vector< CSI2CSIRecord > &&records)
 
void x_OnSi2csiError (CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
- Public Member Functions inherited from CPSGS_CassProcessorBase
 CPSGS_CassProcessorBase ()
 
 CPSGS_CassProcessorBase (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority)
 
virtual ~CPSGS_CassProcessorBase ()
 
virtual void Cancel (void)
 The infrastructure request to cancel processing. More...
 
void SignalFinishProcessing (void)
 
void UnlockWaitingProcessor (void)
 
void CallOnData (void)
 
string GetVerboseFetches (void) const
 
void EnforceWait (void) const
 
- Public Member Functions inherited from IPSGS_Processor
 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< stringWhatCanProcess (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_ProcessorCreateProcessor (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_RequestGetRequest (void) const
 Provides the user request. More...
 
shared_ptr< CPSGS_ReplyGetReply (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...
 

Protected Member Functions

int16_t GetEffectiveVersion (const CTextseq_id *text_seq_id)
 
SPSGS_ResolveRequest::TPSGS_BioseqIncludeData GetBioseqInfoFields (void)
 
bool NonKeyBioseqInfoFieldsRequested (void)
 
bool CanSkipBioseqInfoRetrieval (const CBioseqInfoRecord &bioseq_info_record)
 
SPSGS_RequestBase::EPSGS_AccSubstitutioOption GetAccessionSubstitutionOption (void)
 
EPSGS_AccessionAdjustmentResult AdjustBioseqAccession (SBioseqResolution &bioseq_resolution)
 
void SetupSeqIdToResolve (void)
 
void SetupSeqIdToResolve (const string &seq_id, int16_t seq_id_type)
 
string GetCouldNotResolveMessage (void) const
 
psg_time_point_t GetAsyncResolutionStartTimestamp (void) const
 
void SetAsyncResolutionStartTimestamp (const psg_time_point_t &ts)
 
bool MoveToNextSeqId (void)
 
- Protected Member Functions inherited from CPSGS_CassProcessorBase
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)
 
- Protected Member Functions inherited from IPSGS_Processor
bool GetEffectiveSeqIdType (const objects::CSeq_id &parsed_seq_id, int request_seq_id_type, int16_t &eff_seq_id_type, bool need_trace)
 

Protected Attributes

TContinueResolveCB m_ContinueResolveCB
 
TSeqIdResolutionFinishedCB m_FinishedCB
 
TSeqIdResolutionErrorCB m_ErrorCB
 
TSeqIdResolutionStartProcessingCB m_StartProcessingCB
 
EPSGS_ResolveStage m_ResolveStage
 
bool m_ComposedOk
 
string m_PrimarySeqId
 
int16_t m_EffectiveVersion
 
int16_t m_EffectiveSeqIdType
 
size_t m_SecondaryIndex
 
list< stringm_SecondaryIdList
 
SBioseqResolution m_BioseqResolution
 
CCassFetchm_CurrentFetch
 
CCassFetchm_NoSeqIdTypeFetch
 
CBioseqInfoRecord::TAccession m_BioseqInfoRequestedAccession
 
CBioseqInfoRecord::TVersion m_BioseqInfoRequestedVersion
 
CBioseqInfoRecord::TSeqIdType m_BioseqInfoRequestedSeqIdType
 
CBioseqInfoRecord::TGI m_BioseqInfoRequestedGI
 
psg_time_point_t m_BioseqInfoStart
 
psg_time_point_t m_Si2csiStart
 
psg_time_point_t m_AsyncCassResolutionStart
 
bool m_StartProcessingCalled
 
list< SPSGSeqIdm_SeqIdsToResolve
 
list< SPSGSeqId >::const_iterator m_CurrentSeqIdToResolve
 
CPSGSResolveErrors m_ResolveErrors
 
- Protected Attributes inherited from CPSGS_CassProcessorBase
list< unique_ptr< CCassFetch > > m_FetchDetails
 
bool m_Canceled
 
bool m_Unlocked
 
CRequestStatus::ECode m_Status
 
optional< stringm_UserName
 
shared_ptr< CPSG_MyNCBIRequest_WhoAmIm_WhoAmIRequest
 
optional< stringm_MyNCBICookie
 
- Protected Attributes inherited from IPSGS_Processor
shared_ptr< CPSGS_Requestm_Request
 
shared_ptr< CPSGS_Replym_Reply
 
TProcessorPriority m_Priority
 
bool m_FinishSignalled
 
uv_thread_t m_UVThreadId
 

Private Types

enum  EPSGS_ResolveStage {
  eInit , ePrimaryBioseq , eSecondarySi2csi , eSecondaryAsIs ,
  eFinished , ePostSi2Csi
}
 

Private Member Functions

void x_Process (void)
 
string x_GetRequestSeqId (void)
 
int16_t x_GetRequestSeqIdType (void)
 
string x_GetSeqIdsToResolveList (void) const
 
void x_PreparePrimaryBioseqInfoQuery (const CBioseqInfoRecord::TAccession &seq_id, CBioseqInfoRecord::TVersion version, CBioseqInfoRecord::TSeqIdType seq_id_type, CBioseqInfoRecord::TGI gi, bool with_seq_id_type)
 
void x_PrepareSecondarySi2csiQuery (void)
 
void x_PrepareSecondaryAsIsSi2csiQuery (void)
 
void x_PrepareSi2csiQuery (const string &secondary_id, int16_t effective_seq_id_type)
 
void x_OnSeqIdAsyncResolutionFinished (SBioseqResolution &&async_bioseq_resolution)
 
void x_SignalStartProcessing (void)
 

Additional Inherited Members

- Public Types inherited from IPSGS_Processor
enum  EPSGS_Status {
  ePSGS_InProgress , ePSGS_Done , ePSGS_NotFound , ePSGS_Canceled ,
  ePSGS_Timeout , ePSGS_Error , ePSGS_Unauthorized
}
 The GetStatus() method returns a processor current status. More...
 
enum  EPSGS_StartProcessing { ePSGS_Proceed , ePSGS_Cancel }
 Tells wether to continue or not after a processor called SignalStartProcessing() method. More...
 
- Static Public Member Functions inherited from IPSGS_Processor
static string StatusToString (EPSGS_Status status)
 Converts the processor status to a string for tracing and logging purposes. More...
 
static string StatusToProgressMessage (EPSGS_Status status)
 Converts the processor status to a string for protocol message. More...
 
- Protected Types inherited from CPSGS_CassProcessorBase
enum  EPSGS_MyNCBILookupResult {
  ePSGS_IncludeHUPSetToNo , ePSGS_FoundInOKCache , ePSGS_FoundInErrorCache , ePSGS_FoundInNotFoundCache ,
  ePSGS_CookieNotPresent , ePSGS_RequestInitiated , ePSGS_AddedToWaitlist
}
 

Detailed Description

Definition at line 87 of file async_resolve_base.hpp.

Member Enumeration Documentation

◆ EPSGS_ResolveStage

Enumerator
eInit 
ePrimaryBioseq 
eSecondarySi2csi 
eSecondaryAsIs 
eFinished 
ePostSi2Csi 

Definition at line 110 of file async_resolve_base.hpp.

Constructor & Destructor Documentation

◆ CPSGS_AsyncResolveBase() [1/2]

CPSGS_AsyncResolveBase::CPSGS_AsyncResolveBase ( )

Definition at line 111 of file async_resolve_base.cpp.

◆ CPSGS_AsyncResolveBase() [2/2]

CPSGS_AsyncResolveBase::CPSGS_AsyncResolveBase ( shared_ptr< CPSGS_Request request,
shared_ptr< CPSGS_Reply reply,
TContinueResolveCB  continue_resolve_cb,
TSeqIdResolutionFinishedCB  finished_cb,
TSeqIdResolutionErrorCB  error_cb,
TSeqIdResolutionStartProcessingCB  start_processing_cb 
)

Definition at line 115 of file async_resolve_base.cpp.

◆ ~CPSGS_AsyncResolveBase()

CPSGS_AsyncResolveBase::~CPSGS_AsyncResolveBase ( )
virtual

Definition at line 134 of file async_resolve_base.cpp.

Member Function Documentation

◆ AdjustBioseqAccession()

EPSGS_AccessionAdjustmentResult CPSGS_AsyncResolveBase::AdjustBioseqAccession ( SBioseqResolution bioseq_resolution)
protected

◆ CanSkipBioseqInfoRetrieval()

bool CPSGS_AsyncResolveBase::CanSkipBioseqInfoRetrieval ( const CBioseqInfoRecord bioseq_info_record)
protected

◆ GetAccessionSubstitutionOption()

SPSGS_RequestBase::EPSGS_AccSubstitutioOption CPSGS_AsyncResolveBase::GetAccessionSubstitutionOption ( void  )
protected

◆ GetAsyncResolutionStartTimestamp()

psg_time_point_t CPSGS_AsyncResolveBase::GetAsyncResolutionStartTimestamp ( void  ) const
inlineprotected

◆ GetBioseqInfoFields()

SPSGS_ResolveRequest::TPSGS_BioseqIncludeData CPSGS_AsyncResolveBase::GetBioseqInfoFields ( void  )
protected

◆ GetCouldNotResolveMessage()

string CPSGS_AsyncResolveBase::GetCouldNotResolveMessage ( void  ) const
protected

◆ GetEffectiveVersion()

int16_t CPSGS_AsyncResolveBase::GetEffectiveVersion ( const CTextseq_id text_seq_id)
protected

◆ MoveToNextSeqId()

bool CPSGS_AsyncResolveBase::MoveToNextSeqId ( void  )
protected

◆ NonKeyBioseqInfoFieldsRequested()

bool CPSGS_AsyncResolveBase::NonKeyBioseqInfoFieldsRequested ( void  )
protected

◆ Process()

void CPSGS_AsyncResolveBase::Process ( int16_t  effective_version,
int16_t  effective_seq_id_type,
list< string > &&  secondary_id_list,
string &&  primary_seq_id,
bool  composed_ok,
SBioseqResolution &&  bioseq_resolution 
)

◆ SetAsyncResolutionStartTimestamp()

void CPSGS_AsyncResolveBase::SetAsyncResolutionStartTimestamp ( const psg_time_point_t ts)
inlineprotected

◆ SetupSeqIdToResolve() [1/2]

void CPSGS_AsyncResolveBase::SetupSeqIdToResolve ( const string seq_id,
int16_t  seq_id_type 
)
protected

Definition at line 234 of file async_resolve_base.cpp.

References m_CurrentSeqIdToResolve, and m_SeqIdsToResolve.

◆ SetupSeqIdToResolve() [2/2]

void CPSGS_AsyncResolveBase::SetupSeqIdToResolve ( void  )
protected

◆ x_GetRequestSeqId()

string CPSGS_AsyncResolveBase::x_GetRequestSeqId ( void  )
private

◆ x_GetRequestSeqIdType()

int16_t CPSGS_AsyncResolveBase::x_GetRequestSeqIdType ( void  )
private

◆ x_GetSeqIdsToResolveList()

string CPSGS_AsyncResolveBase::x_GetSeqIdsToResolveList ( void  ) const
private

Definition at line 176 of file async_resolve_base.cpp.

References m_SeqIdsToResolve.

Referenced by SetupSeqIdToResolve().

◆ x_OnBioseqInfo()

void CPSGS_AsyncResolveBase::x_OnBioseqInfo ( vector< CBioseqInfoRecord > &&  records)

Definition at line 646 of file async_resolve_base.cpp.

References AdjustBioseqAccession(), CPSGSResolveErrors::AppendError(), CCassBlobWaiter::ClearError(), CRequestStatus::e502_BadGateway, eDiag_Error, eLookupCassBioseqInfo, eOpStatusFound, eOpStatusNotFound, ePostSi2Csi, ePSGS_BioseqDB, ePSGS_BioseqInfoAccessionAdjustmentError, CPSGSCounters::ePSGS_BioseqInfoFoundMany, CPSGSCounters::ePSGS_BioseqInfoFoundOne, CPSGSCounters::ePSGS_BioseqInfoNotFound, ePSGS_LogicError, ePSGS_NeedLogging, ePSGS_NoBioseqInfoForGiError, ePSGS_SeqIdsEmpty, SPSGS_ResolveRequest::fPSGS_AllBioseqFields, CBioseqInfoRecord::GetAccession(), SBioseqResolution::GetBioseqInfo(), CPSGSResolveErrors::GetCombinedErrorCode(), CPSGSResolveErrors::GetCombinedErrorMessage(), GetCouldNotResolveMessage(), CPubseqGatewayApp::GetInstance(), CCassFetch::GetLoader(), IsINSDCSeqIdType(), SBioseqResolution::m_AdjustmentError, m_BioseqInfoRequestedAccession, m_BioseqInfoRequestedGI, m_BioseqInfoRequestedSeqIdType, m_BioseqInfoRequestedVersion, m_BioseqInfoStart, m_BioseqResolution, m_ContinueResolveCB, m_CurrentFetch, m_ErrorCB, IPSGS_Processor::m_Reply, IPSGS_Processor::m_Request, SBioseqResolution::m_ResolutionResult, m_ResolveErrors, m_ResolveStage, m_SeqIdsToResolve, MoveToNextSeqId(), prefix, SelectBioseqInfoRecord(), SBioseqResolution::SetBioseqInfo(), CCassFetch::SetReadFinished(), ToJsonString(), x_OnSeqIdAsyncResolutionFinished(), x_PreparePrimaryBioseqInfoQuery(), x_Process(), and x_SignalStartProcessing().

Referenced by x_PreparePrimaryBioseqInfoQuery().

◆ x_OnBioseqInfoError()

void CPSGS_AsyncResolveBase::x_OnBioseqInfoError ( CRequestStatus::ECode  status,
int  code,
EDiagSev  severity,
const string message 
)

◆ x_OnBioseqInfoWithoutSeqIdType()

void CPSGS_AsyncResolveBase::x_OnBioseqInfoWithoutSeqIdType ( vector< CBioseqInfoRecord > &&  records)

◆ x_OnSeqIdAsyncResolutionFinished()

void CPSGS_AsyncResolveBase::x_OnSeqIdAsyncResolutionFinished ( SBioseqResolution &&  async_bioseq_resolution)
private

◆ x_OnSi2csiError()

void CPSGS_AsyncResolveBase::x_OnSi2csiError ( CRequestStatus::ECode  status,
int  code,
EDiagSev  severity,
const string message 
)

◆ x_OnSi2csiRecord()

void CPSGS_AsyncResolveBase::x_OnSi2csiRecord ( vector< CSI2CSIRecord > &&  records)

◆ x_PreparePrimaryBioseqInfoQuery()

void CPSGS_AsyncResolveBase::x_PreparePrimaryBioseqInfoQuery ( const CBioseqInfoRecord::TAccession seq_id,
CBioseqInfoRecord::TVersion  version,
CBioseqInfoRecord::TSeqIdType  seq_id_type,
CBioseqInfoRecord::TGI  gi,
bool  with_seq_id_type 
)
private

◆ x_PrepareSecondaryAsIsSi2csiQuery()

void CPSGS_AsyncResolveBase::x_PrepareSecondaryAsIsSi2csiQuery ( void  )
private

◆ x_PrepareSecondarySi2csiQuery()

void CPSGS_AsyncResolveBase::x_PrepareSecondarySi2csiQuery ( void  )
private

◆ x_PrepareSi2csiQuery()

void CPSGS_AsyncResolveBase::x_PrepareSi2csiQuery ( const string secondary_id,
int16_t  effective_seq_id_type 
)
private

◆ x_Process()

void CPSGS_AsyncResolveBase::x_Process ( void  )
private

◆ x_SignalStartProcessing()

void CPSGS_AsyncResolveBase::x_SignalStartProcessing ( void  )
private

Member Data Documentation

◆ m_AsyncCassResolutionStart

psg_time_point_t CPSGS_AsyncResolveBase::m_AsyncCassResolutionStart
protected

◆ m_BioseqInfoRequestedAccession

CBioseqInfoRecord::TAccession CPSGS_AsyncResolveBase::m_BioseqInfoRequestedAccession
protected

Definition at line 200 of file async_resolve_base.hpp.

Referenced by x_OnBioseqInfo(), and x_PreparePrimaryBioseqInfoQuery().

◆ m_BioseqInfoRequestedGI

CBioseqInfoRecord::TGI CPSGS_AsyncResolveBase::m_BioseqInfoRequestedGI
protected

Definition at line 203 of file async_resolve_base.hpp.

Referenced by x_OnBioseqInfo(), and x_PreparePrimaryBioseqInfoQuery().

◆ m_BioseqInfoRequestedSeqIdType

CBioseqInfoRecord::TSeqIdType CPSGS_AsyncResolveBase::m_BioseqInfoRequestedSeqIdType
protected

Definition at line 202 of file async_resolve_base.hpp.

Referenced by x_OnBioseqInfo(), and x_PreparePrimaryBioseqInfoQuery().

◆ m_BioseqInfoRequestedVersion

CBioseqInfoRecord::TVersion CPSGS_AsyncResolveBase::m_BioseqInfoRequestedVersion
protected

◆ m_BioseqInfoStart

psg_time_point_t CPSGS_AsyncResolveBase::m_BioseqInfoStart
protected

◆ m_BioseqResolution

SBioseqResolution CPSGS_AsyncResolveBase::m_BioseqResolution
protected

◆ m_ComposedOk

bool CPSGS_AsyncResolveBase::m_ComposedOk
protected

Definition at line 189 of file async_resolve_base.hpp.

Referenced by Process(), and x_Process().

◆ m_ContinueResolveCB

TContinueResolveCB CPSGS_AsyncResolveBase::m_ContinueResolveCB
protected

◆ m_CurrentFetch

CCassFetch* CPSGS_AsyncResolveBase::m_CurrentFetch
protected

◆ m_CurrentSeqIdToResolve

list<SPSGSeqId>::const_iterator CPSGS_AsyncResolveBase::m_CurrentSeqIdToResolve
protected

◆ m_EffectiveSeqIdType

int16_t CPSGS_AsyncResolveBase::m_EffectiveSeqIdType
protected

◆ m_EffectiveVersion

int16_t CPSGS_AsyncResolveBase::m_EffectiveVersion
protected

Definition at line 191 of file async_resolve_base.hpp.

Referenced by Process(), and x_Process().

◆ m_ErrorCB

TSeqIdResolutionErrorCB CPSGS_AsyncResolveBase::m_ErrorCB
protected

◆ m_FinishedCB

TSeqIdResolutionFinishedCB CPSGS_AsyncResolveBase::m_FinishedCB
protected

Definition at line 184 of file async_resolve_base.hpp.

Referenced by x_OnSeqIdAsyncResolutionFinished().

◆ m_NoSeqIdTypeFetch

CCassFetch* CPSGS_AsyncResolveBase::m_NoSeqIdTypeFetch
protected

◆ m_PrimarySeqId

string CPSGS_AsyncResolveBase::m_PrimarySeqId
protected

Definition at line 190 of file async_resolve_base.hpp.

Referenced by Process(), x_PrepareSecondaryAsIsSi2csiQuery(), and x_Process().

◆ m_ResolveErrors

CPSGSResolveErrors CPSGS_AsyncResolveBase::m_ResolveErrors
protected

◆ m_ResolveStage

EPSGS_ResolveStage CPSGS_AsyncResolveBase::m_ResolveStage
protected

◆ m_SecondaryIdList

list<string> CPSGS_AsyncResolveBase::m_SecondaryIdList
protected

Definition at line 194 of file async_resolve_base.hpp.

Referenced by Process(), x_PrepareSecondarySi2csiQuery(), and x_Process().

◆ m_SecondaryIndex

size_t CPSGS_AsyncResolveBase::m_SecondaryIndex
protected

Definition at line 193 of file async_resolve_base.hpp.

Referenced by x_PrepareSecondarySi2csiQuery(), and x_Process().

◆ m_SeqIdsToResolve

list<SPSGSeqId> CPSGS_AsyncResolveBase::m_SeqIdsToResolve
protected

◆ m_Si2csiStart

psg_time_point_t CPSGS_AsyncResolveBase::m_Si2csiStart
protected

Definition at line 206 of file async_resolve_base.hpp.

Referenced by x_OnSi2csiRecord(), and x_PrepareSi2csiQuery().

◆ m_StartProcessingCalled

bool CPSGS_AsyncResolveBase::m_StartProcessingCalled
protected

Definition at line 209 of file async_resolve_base.hpp.

Referenced by x_SignalStartProcessing().

◆ m_StartProcessingCB

TSeqIdResolutionStartProcessingCB CPSGS_AsyncResolveBase::m_StartProcessingCB
protected

Definition at line 186 of file async_resolve_base.hpp.

Referenced by x_SignalStartProcessing().


The documentation for this class was generated from the following files:
Modified on Fri May 24 14:52:08 2024 by modify_doxy.py rev. 669887