NCBI C++ ToolKit
Public Member Functions | Public Attributes | List of all members
SProcessorGroup Struct Reference

Search Toolkit Book for SProcessorGroup

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

+ Collaboration diagram for SProcessorGroup:

Public Member Functions

 SProcessorGroup (size_t request_id)
 
 ~SProcessorGroup ()
 
bool IsSafeToDelete (void) const
 
void StartRequestTimer (uv_loop_t *uv_loop, uint64_t timer_millisec)
 
void StopRequestTimer (void)
 
void RestartTimer (uint64_t timer_millisec)
 

Public Attributes

size_t m_RequestId
 
vector< SProcessorDatam_Processors
 
uv_timer_t m_RequestTimer
 
bool m_TimerActive
 
bool m_TimerClosed
 
bool m_FinallyFlushed
 
bool m_AllProcessorsFinished
 
bool m_Libh2oFinished
 
bool m_LowLevelClose
 
bool m_RequestStopPrinted
 
IPSGS_Processorm_StartedProcessing
 

Detailed Description

Definition at line 85 of file psgs_dispatcher.hpp.

Constructor & Destructor Documentation

◆ SProcessorGroup()

SProcessorGroup::SProcessorGroup ( size_t  request_id)
inline

Definition at line 111 of file psgs_dispatcher.hpp.

References m_Processors, and MAX_PROCESSOR_GROUPS.

◆ ~SProcessorGroup()

SProcessorGroup::~SProcessorGroup ( )
inline

Definition at line 122 of file psgs_dispatcher.hpp.

References m_RequestId, m_TimerClosed, and PSG_ERROR.

Member Function Documentation

◆ IsSafeToDelete()

bool SProcessorGroup::IsSafeToDelete ( void  ) const
inline

◆ RestartTimer()

void SProcessorGroup::RestartTimer ( uint64_t  timer_millisec)
inline

Definition at line 186 of file psgs_dispatcher.hpp.

References m_RequestTimer, m_TimerActive, NCBI_THROW, and request_timer_cb().

◆ StartRequestTimer()

void SProcessorGroup::StartRequestTimer ( uv_loop_t *  uv_loop,
uint64_t  timer_millisec 
)
inline

◆ StopRequestTimer()

void SProcessorGroup::StopRequestTimer ( void  )
inline

Member Data Documentation

◆ m_AllProcessorsFinished

bool SProcessorGroup::m_AllProcessorsFinished

Definition at line 97 of file psgs_dispatcher.hpp.

Referenced by IsSafeToDelete().

◆ m_FinallyFlushed

bool SProcessorGroup::m_FinallyFlushed

Definition at line 96 of file psgs_dispatcher.hpp.

Referenced by IsSafeToDelete().

◆ m_Libh2oFinished

bool SProcessorGroup::m_Libh2oFinished

Definition at line 98 of file psgs_dispatcher.hpp.

Referenced by IsSafeToDelete().

◆ m_LowLevelClose

bool SProcessorGroup::m_LowLevelClose

Definition at line 103 of file psgs_dispatcher.hpp.

Referenced by IsSafeToDelete().

◆ m_Processors

vector<SProcessorData> SProcessorGroup::m_Processors

◆ m_RequestId

size_t SProcessorGroup::m_RequestId

Definition at line 87 of file psgs_dispatcher.hpp.

Referenced by StartRequestTimer(), and ~SProcessorGroup().

◆ m_RequestStopPrinted

bool SProcessorGroup::m_RequestStopPrinted

Definition at line 106 of file psgs_dispatcher.hpp.

◆ m_RequestTimer

uv_timer_t SProcessorGroup::m_RequestTimer

Definition at line 89 of file psgs_dispatcher.hpp.

Referenced by RestartTimer(), StartRequestTimer(), and StopRequestTimer().

◆ m_StartedProcessing

IPSGS_Processor* SProcessorGroup::m_StartedProcessing

Definition at line 109 of file psgs_dispatcher.hpp.

◆ m_TimerActive

bool SProcessorGroup::m_TimerActive

Definition at line 90 of file psgs_dispatcher.hpp.

Referenced by RestartTimer(), StartRequestTimer(), and StopRequestTimer().

◆ m_TimerClosed

bool SProcessorGroup::m_TimerClosed

Definition at line 91 of file psgs_dispatcher.hpp.

Referenced by IsSafeToDelete(), StartRequestTimer(), and ~SProcessorGroup().


The documentation for this struct was generated from the following file:
Modified on Fri May 24 14:51:55 2024 by modify_doxy.py rev. 669887