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

Search Toolkit Book for CPSGS_TSEChunkProcessor

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

+ Inheritance diagram for CPSGS_TSEChunkProcessor:
+ Collaboration diagram for CPSGS_TSEChunkProcessor:

Public Member Functions

virtual bool CanProcess (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply) const
 Tells if processor can process the given request. More...
 
virtual IPSGS_ProcessorCreateProcessor (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority) const
 Create processor to fulfil PSG request using the data source. More...
 
virtual void Process (void)
 Main processing function. More...
 
virtual EPSGS_Status GetStatus (void)
 Tells the processor status (if it has finished or in progress) More...
 
virtual string GetName (void) const
 Tells the processor name (used in logging and tracing) More...
 
virtual string GetGroupName (void) const
 Tells the processor group name. More...
 
virtual void ProcessEvent (void)
 Called when an event happened which may require to have some processing. More...
 
 CPSGS_TSEChunkProcessor ()
 
 CPSGS_TSEChunkProcessor (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, TProcessorPriority priority, shared_ptr< CPSGS_SatInfoChunksVerFlavorId2Info > sat_info_chunk_ver_id2info, shared_ptr< CPSGS_IdModifiedVerFlavorId2Info > id_mod_ver_id2info)
 
virtual ~CPSGS_TSEChunkProcessor ()
 
- Public Member Functions inherited from CPSGS_CassBlobBase
 CPSGS_CassBlobBase ()
 
 CPSGS_CassBlobBase (shared_ptr< CPSGS_Request > request, shared_ptr< CPSGS_Reply > reply, const string &processor_id, TBlobPropsCB blob_props_cb, TBlobChunkCB blob_chunk_cb, TBlobErrorCB blob_error_cb)
 
virtual ~CPSGS_CassBlobBase ()
 
- 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 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...
 
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...
 

Private Member Functions

void OnGetBlobProp (CCassBlobFetch *fetch_details, CBlobRecord const &blob, bool is_found)
 
void OnGetBlobError (CCassBlobFetch *fetch_details, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
void OnGetBlobChunk (CCassBlobFetch *fetch_details, CBlobRecord const &blob, const unsigned char *chunk_data, unsigned int data_size, int chunk_no)
 
void OnGetSplitHistoryError (CCassSplitHistoryFetch *fetch_details, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
void OnGetSplitHistory (CCassSplitHistoryFetch *fetch_details, vector< SSplitHistoryRecord > &&result)
 
void x_ProcessSatInfoChunkVerId2Info (void)
 
void x_ProcessSatInfoChunkVerId2InfoFinalStage (void)
 
void x_ProcessIdModVerId2Info (void)
 
void x_ProcessIdModVerId2InfoFinalStage (void)
 
void x_SendProcessorError (const string &msg, CRequestStatus::ECode status, int code)
 
bool x_ValidateTSEChunkNumber (int64_t requested_chunk, CPSGS_SatInfoChunksVerFlavorId2Info::TChunks total_chunks, bool need_finish)
 
bool x_TSEChunkSatToKeyspace (SCass_BlobId &blob_id)
 
EPSGSId2InfoFlavor x_DetectId2InfoFlavor (const string &id2_info, shared_ptr< CPSGS_SatInfoChunksVerFlavorId2Info > &sat_info_chunk_ver_id2info, shared_ptr< CPSGS_IdModifiedVerFlavorId2Info > &id_mod_ver_id2info) const
 
bool x_ParseTSEChunkId2Info (const string &info, unique_ptr< CPSGS_SatInfoChunksVerFlavorId2Info > &id2_info, const SCass_BlobId &blob_id, bool need_finish)
 
bool x_TSEChunkSatToKeyspace (SCass_BlobId &blob_id, bool need_finish)
 
void x_RequestTSEChunk (const SSplitHistoryRecord &split_record, CCassSplitHistoryFetch *fetch_details)
 
void x_Peek (bool need_wait)
 
bool x_Peek (unique_ptr< CCassFetch > &fetch_details, bool need_wait)
 
void x_OnMyNCBIError (const string &cookie, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
void x_OnMyNCBIData (const string &cookie, CPSG_MyNCBIRequest_WhoAmI::SUserInfo user_info)
 
bool x_GetMyNCBIUser (void)
 

Private Attributes

SPSGS_TSEChunkRequestm_TSEChunkRequest
 
shared_ptr< CPSGS_SatInfoChunksVerFlavorId2Infom_SatInfoChunkVerId2Info
 
shared_ptr< CPSGS_IdModifiedVerFlavorId2Infom_IdModVerId2Info
 
SCass_BlobId m_SatInfoChunkVerBlobId
 

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
}
 
- Protected Member Functions inherited from CPSGS_CassBlobBase
void OnGetBlobProp (CCassBlobFetch *fetch_details, CBlobRecord const &blob, bool is_found)
 
void OnGetBlobError (CCassBlobFetch *fetch_details, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
void OnGetBlobChunk (bool cancelled, CCassBlobFetch *fetch_details, const unsigned char *chunk_data, unsigned int data_size, int chunk_no)
 
bool NeedToAddId2CunkId2Info (void) const
 
void PrepareServerErrorMessage (CCassBlobFetch *fetch_details, int code, EDiagSev severity, const string &message)
 
void OnPublicCommentError (CCassPublicCommentFetch *fetch_details, CRequestStatus::ECode status, int code, EDiagSev severity, const string &message)
 
void OnPublicComment (CCassPublicCommentFetch *fetch_details, string comment, bool is_found)
 
- Protected Member Functions inherited from CPSGS_CassProcessorBase
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 (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 inherited from CPSGS_CassBlobBase
SCass_BlobId m_BlobId
 
CSeq_id m_ResolvedSeqID
 
- 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
 

Detailed Description

Definition at line 45 of file tse_chunk_processor.hpp.

Constructor & Destructor Documentation

◆ CPSGS_TSEChunkProcessor() [1/2]

CPSGS_TSEChunkProcessor::CPSGS_TSEChunkProcessor ( )

Definition at line 48 of file tse_chunk_processor.cpp.

Referenced by CreateProcessor().

◆ CPSGS_TSEChunkProcessor() [2/2]

CPSGS_TSEChunkProcessor::CPSGS_TSEChunkProcessor ( shared_ptr< CPSGS_Request request,
shared_ptr< CPSGS_Reply reply,
TProcessorPriority  priority,
shared_ptr< CPSGS_SatInfoChunksVerFlavorId2Info sat_info_chunk_ver_id2info,
shared_ptr< CPSGS_IdModifiedVerFlavorId2Info id_mod_ver_id2info 
)

Definition at line 53 of file tse_chunk_processor.cpp.

References m_TSEChunkRequest.

◆ ~CPSGS_TSEChunkProcessor()

CPSGS_TSEChunkProcessor::~CPSGS_TSEChunkProcessor ( )
virtual

Member Function Documentation

◆ CanProcess()

bool CPSGS_TSEChunkProcessor::CanProcess ( shared_ptr< CPSGS_Request request,
shared_ptr< CPSGS_Reply reply 
) const
virtual

Tells if processor can process the given request.

Parameters
requestPSG request to retrieve the data for. It is guaranteed to be not null.
replyThe 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 from IPSGS_Processor.

Definition at line 83 of file tse_chunk_processor.cpp.

References ePSGS_StartupDataOK, CPSGS_Request::ePSGS_TSEChunkRequest, ePSGS_UnknownId2InfoFlavor, GetCassStartupDataStateMessage(), CPubseqGatewayApp::GetInstance(), CPSGS_CassProcessorBase::IsCassandraProcessorEnabled(), kTSEChunkProcessorName, and x_DetectId2InfoFlavor().

Referenced by CreateProcessor().

◆ CreateProcessor()

IPSGS_Processor * CPSGS_TSEChunkProcessor::CreateProcessor ( shared_ptr< CPSGS_Request request,
shared_ptr< CPSGS_Reply reply,
TProcessorPriority  priority 
) const
virtual

Create processor to fulfil PSG request using the data source.

Parameters
requestPSG request to retrieve the data for. It is guaranteed to be not null.
replyThe 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.

Implements IPSGS_Processor.

Definition at line 127 of file tse_chunk_processor.cpp.

References CanProcess(), CPSGS_TSEChunkProcessor(), IPSGS_Processor::GetRequest(), and x_DetectId2InfoFlavor().

◆ GetGroupName()

string CPSGS_TSEChunkProcessor::GetGroupName ( void  ) const
virtual

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

Implements IPSGS_Processor.

Definition at line 1274 of file tse_chunk_processor.cpp.

References kCassandraProcessorGroupName.

◆ GetName()

string CPSGS_TSEChunkProcessor::GetName ( void  ) const
virtual

Tells the processor name (used in logging and tracing)

Returns
the processor name

Implements IPSGS_Processor.

Definition at line 1268 of file tse_chunk_processor.cpp.

References kTSEChunkProcessorName.

◆ GetStatus()

IPSGS_Processor::EPSGS_Status CPSGS_TSEChunkProcessor::GetStatus ( void  )
virtual

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

Returns
the current processor status

Reimplemented from CPSGS_CassProcessorBase.

Definition at line 1255 of file tse_chunk_processor.cpp.

References IPSGS_Processor::ePSGS_Canceled, IPSGS_Processor::ePSGS_InProgress, CPSGS_CassProcessorBase::GetStatus(), and CPSGS_CassProcessorBase::m_Canceled.

◆ OnGetBlobChunk()

void CPSGS_TSEChunkProcessor::OnGetBlobChunk ( CCassBlobFetch fetch_details,
CBlobRecord const blob,
const unsigned char *  chunk_data,
unsigned int  data_size,
int  chunk_no 
)
private

◆ OnGetBlobError()

void CPSGS_TSEChunkProcessor::OnGetBlobError ( CCassBlobFetch fetch_details,
CRequestStatus::ECode  status,
int  code,
EDiagSev  severity,
const string message 
)
private

◆ OnGetBlobProp()

void CPSGS_TSEChunkProcessor::OnGetBlobProp ( CCassBlobFetch fetch_details,
CBlobRecord const blob,
bool  is_found 
)
private

◆ OnGetSplitHistory()

void CPSGS_TSEChunkProcessor::OnGetSplitHistory ( CCassSplitHistoryFetch fetch_details,
vector< SSplitHistoryRecord > &&  result 
)
private

◆ OnGetSplitHistoryError()

void CPSGS_TSEChunkProcessor::OnGetSplitHistoryError ( CCassSplitHistoryFetch fetch_details,
CRequestStatus::ECode  status,
int  code,
EDiagSev  severity,
const string message 
)
private

◆ Process()

void CPSGS_TSEChunkProcessor::Process ( void  )
virtual

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.

Implements IPSGS_Processor.

Definition at line 238 of file tse_chunk_processor.cpp.

References kCassandraProcessorEvent, m_IdModVerId2Info, IPSGS_Processor::m_Request, m_SatInfoChunkVerId2Info, NCBI_THROW, x_ProcessIdModVerId2Info(), and x_ProcessSatInfoChunkVerId2Info().

◆ ProcessEvent()

void CPSGS_TSEChunkProcessor::ProcessEvent ( void  )
virtual

Called when an event happened which may require to have some processing.

By default nothing should be done. This method can be called as well on a timer event.

Reimplemented from IPSGS_Processor.

Definition at line 1280 of file tse_chunk_processor.cpp.

References x_Peek().

◆ x_DetectId2InfoFlavor()

EPSGSId2InfoFlavor CPSGS_TSEChunkProcessor::x_DetectId2InfoFlavor ( const string id2_info,
shared_ptr< CPSGS_SatInfoChunksVerFlavorId2Info > &  sat_info_chunk_ver_id2info,
shared_ptr< CPSGS_IdModifiedVerFlavorId2Info > &  id_mod_ver_id2info 
) const
private

◆ x_GetMyNCBIUser()

bool CPSGS_TSEChunkProcessor::x_GetMyNCBIUser ( void  )
private

◆ x_OnMyNCBIData()

void CPSGS_TSEChunkProcessor::x_OnMyNCBIData ( const string cookie,
CPSG_MyNCBIRequest_WhoAmI::SUserInfo  user_info 
)
private

◆ x_OnMyNCBIError()

void CPSGS_TSEChunkProcessor::x_OnMyNCBIError ( const string cookie,
CRequestStatus::ECode  status,
int  code,
EDiagSev  severity,
const string message 
)
private

◆ x_ParseTSEChunkId2Info()

bool CPSGS_TSEChunkProcessor::x_ParseTSEChunkId2Info ( const string info,
unique_ptr< CPSGS_SatInfoChunksVerFlavorId2Info > &  id2_info,
const SCass_BlobId blob_id,
bool  need_finish 
)
private

◆ x_Peek() [1/2]

void CPSGS_TSEChunkProcessor::x_Peek ( bool  need_wait)
private

◆ x_Peek() [2/2]

bool CPSGS_TSEChunkProcessor::x_Peek ( unique_ptr< CCassFetch > &  fetch_details,
bool  need_wait 
)
private

◆ x_ProcessIdModVerId2Info()

void CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2Info ( void  )
private

◆ x_ProcessIdModVerId2InfoFinalStage()

void CPSGS_TSEChunkProcessor::x_ProcessIdModVerId2InfoFinalStage ( void  )
private

Definition at line 297 of file tse_chunk_processor.cpp.

References ePSGS_CacheFailure, ePSGS_CacheHit, SPSGS_RequestBase::ePSGS_NoTracing, CPSGSCounters::ePSGS_TSEChunkSplitVersionCacheMatched, CPSGSCounters::ePSGS_TSEChunkSplitVersionCacheNotMatched, SPSGS_BlobRequestBase::ePSGS_UnknownTSE, SPSGS_RequestBase::ePSGS_UnknownUseCache, SPSGS_RequestBase::ePSGS_WithTracing, eTseChunkRetrieve, CPubseqGatewayApp::GetInstance(), INT64_MIN, CPSGCache::IsAllowed(), kSplitInfoChunk, CPSGCache::LookupBlobProp(), CPSGS_CassProcessorBase::m_FetchDetails, SPSGS_TSEChunkRequest::m_Id2Chunk, m_IdModVerId2Info, SCass_BlobId::m_Keyspace, IPSGS_Processor::m_Reply, IPSGS_Processor::m_Request, SCass_BlobId::m_Sat, SCass_BlobId::m_SatKey, m_TSEChunkRequest, CPSGS_CassProcessorBase::m_UserName, OnGetBlobChunk(), OnGetBlobError(), OnGetBlobProp(), OnGetSplitHistory(), OnGetSplitHistoryError(), PSG_WARNING, CPSGS_CassProcessorBase::ReportFailureToGetCassConnection(), CPSGS_CassProcessorBase::ReportSecureSatUnauthorized(), CCassBlobTaskLoadBlob::SetChunkCallback(), CCassBlobTaskFetchSplitHistory::SetConsumeCallback(), CCassBlobTaskFetchSplitHistory::SetDataReadyCB(), CCassBlobTaskLoadBlob::SetDataReadyCB(), CCassBlobWaiter::SetErrorCB(), CCassBlobTaskLoadBlob::SetPropsCallback(), CPSGS_CassProcessorBase::SignalFinishProcessing(), ToJsonString(), SCass_BlobId::ToString(), CCassBlobWaiter::Wait(), x_ParseTSEChunkId2Info(), x_Peek(), x_TSEChunkSatToKeyspace(), and x_ValidateTSEChunkNumber().

Referenced by x_OnMyNCBIData(), and x_ProcessIdModVerId2Info().

◆ x_ProcessSatInfoChunkVerId2Info()

void CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2Info ( void  )
private

◆ x_ProcessSatInfoChunkVerId2InfoFinalStage()

void CPSGS_TSEChunkProcessor::x_ProcessSatInfoChunkVerId2InfoFinalStage ( void  )
private

◆ x_RequestTSEChunk()

void CPSGS_TSEChunkProcessor::x_RequestTSEChunk ( const SSplitHistoryRecord split_record,
CCassSplitHistoryFetch fetch_details 
)
private

◆ x_SendProcessorError()

void CPSGS_TSEChunkProcessor::x_SendProcessorError ( const string msg,
CRequestStatus::ECode  status,
int  code 
)
private

◆ x_TSEChunkSatToKeyspace() [1/2]

bool CPSGS_TSEChunkProcessor::x_TSEChunkSatToKeyspace ( SCass_BlobId blob_id)
private

◆ x_TSEChunkSatToKeyspace() [2/2]

bool CPSGS_TSEChunkProcessor::x_TSEChunkSatToKeyspace ( SCass_BlobId blob_id,
bool  need_finish 
)
private

◆ x_ValidateTSEChunkNumber()

bool CPSGS_TSEChunkProcessor::x_ValidateTSEChunkNumber ( int64_t  requested_chunk,
CPSGS_SatInfoChunksVerFlavorId2Info::TChunks  total_chunks,
bool  need_finish 
)
private

Member Data Documentation

◆ m_IdModVerId2Info

shared_ptr<CPSGS_IdModifiedVerFlavorId2Info> CPSGS_TSEChunkProcessor::m_IdModVerId2Info
private

◆ m_SatInfoChunkVerBlobId

SCass_BlobId CPSGS_TSEChunkProcessor::m_SatInfoChunkVerBlobId
private

◆ m_SatInfoChunkVerId2Info

shared_ptr<CPSGS_SatInfoChunksVerFlavorId2Info> CPSGS_TSEChunkProcessor::m_SatInfoChunkVerId2Info
private

◆ m_TSEChunkRequest

SPSGS_TSEChunkRequest* CPSGS_TSEChunkProcessor::m_TSEChunkRequest
private

The documentation for this class was generated from the following files:
Modified on Sun May 19 04:46:57 2024 by modify_doxy.py rev. 669887