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

Search Toolkit Book for SPSG_IoCoordinator

#include "psg_client_transport.hpp"
(Private to src/objtools/pubseq_gateway/client.)

+ Collaboration diagram for SPSG_IoCoordinator:

Public Member Functions

 SPSG_IoCoordinator (CServiceDiscovery service)
 
 ~SPSG_IoCoordinator ()
 
bool AddRequest (shared_ptr< SPSG_Request > req, const atomic_bool &stopped, const CDeadline &deadline)
 
string GetNewRequestId ()
 
bool RejectsRequests () const
 

Public Attributes

SPSG_Params params
 
shared_ptr< SPSG_Statsstats
 

Private Attributes

SPSG_Servers::TTS m_Servers
 
SUv_Barrier m_StartBarrier
 
SUv_Barrier m_StopBarrier
 
TPSG_AsyncQueues m_Queues
 
vector< unique_ptr< SPSG_Thread< SPSG_IoImpl > > > m_Io
 
SPSG_Thread< SPSG_DiscoveryImplm_Discovery
 
atomic< size_t > m_RequestCounter
 
atomic< size_t > m_RequestId
 

Detailed Description

Definition at line 1154 of file psg_client_transport.hpp.

Constructor & Destructor Documentation

◆ SPSG_IoCoordinator()

SPSG_IoCoordinator::SPSG_IoCoordinator ( CServiceDiscovery  service)

◆ ~SPSG_IoCoordinator()

SPSG_IoCoordinator::~SPSG_IoCoordinator ( )

Definition at line 1911 of file psg_client_transport.cpp.

References m_Discovery, m_Io, and SPSG_Thread< TImpl >::Shutdown().

Member Function Documentation

◆ AddRequest()

bool SPSG_IoCoordinator::AddRequest ( shared_ptr< SPSG_Request req,
const atomic_bool &  stopped,
const CDeadline deadline 
)

◆ GetNewRequestId()

string SPSG_IoCoordinator::GetNewRequestId ( )
inline

Definition at line 1166 of file psg_client_transport.hpp.

References m_RequestId.

◆ RejectsRequests()

bool SPSG_IoCoordinator::RejectsRequests ( ) const
inline

Member Data Documentation

◆ m_Discovery

SPSG_Thread<SPSG_DiscoveryImpl> SPSG_IoCoordinator::m_Discovery
private

Definition at line 1174 of file psg_client_transport.hpp.

Referenced by ~SPSG_IoCoordinator().

◆ m_Io

vector<unique_ptr<SPSG_Thread<SPSG_IoImpl> > > SPSG_IoCoordinator::m_Io
private

Definition at line 1173 of file psg_client_transport.hpp.

Referenced by AddRequest(), SPSG_IoCoordinator(), and ~SPSG_IoCoordinator().

◆ m_Queues

TPSG_AsyncQueues SPSG_IoCoordinator::m_Queues
private

Definition at line 1172 of file psg_client_transport.hpp.

Referenced by AddRequest(), and SPSG_IoCoordinator().

◆ m_RequestCounter

atomic<size_t> SPSG_IoCoordinator::m_RequestCounter
private

Definition at line 1175 of file psg_client_transport.hpp.

Referenced by AddRequest().

◆ m_RequestId

atomic<size_t> SPSG_IoCoordinator::m_RequestId
private

Definition at line 1176 of file psg_client_transport.hpp.

Referenced by GetNewRequestId().

◆ m_Servers

SPSG_Servers::TTS SPSG_IoCoordinator::m_Servers
private

Definition at line 1157 of file psg_client_transport.hpp.

Referenced by RejectsRequests(), and SPSG_IoCoordinator().

◆ m_StartBarrier

SUv_Barrier SPSG_IoCoordinator::m_StartBarrier
private

Definition at line 1170 of file psg_client_transport.hpp.

Referenced by SPSG_IoCoordinator().

◆ m_StopBarrier

SUv_Barrier SPSG_IoCoordinator::m_StopBarrier
private

Definition at line 1171 of file psg_client_transport.hpp.

Referenced by SPSG_IoCoordinator().

◆ params

SPSG_Params SPSG_IoCoordinator::params

◆ stats

shared_ptr<SPSG_Stats> SPSG_IoCoordinator::stats

Definition at line 1161 of file psg_client_transport.hpp.


The documentation for this struct was generated from the following files:
Modified on Sun Apr 21 03:40:11 2024 by modify_doxy.py rev. 669887