CPSG_Queue::SImpl Struct Reference

Search Toolkit Book for CPSG_Queue::SImpl

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

Collaboration diagram for CPSG_Queue::SImpl:

Classes
class	CService

Public Member Functions
	SImpl (const string &service)
bool	SendRequest (shared_ptr< CPSG_Request > request, CDeadline deadline)
shared_ptr< CPSG_Reply >	SendRequestAndGetReply (shared_ptr< CPSG_Request > request, CDeadline deadline)
bool	WaitForEvents (CDeadline deadline)
bool	RejectsRequests () const
void	SetRequestFlags (CPSG_Request::TFlags request_flags)
void	SetUserArgs (SPSG_UserArgs user_args)

Static Public Member Functions
static TApiLock	GetApiLock ()

Public Attributes
shared_ptr< TPSG_Queue >	queue

Private Member Functions
string	x_GetAbsPathRef (shared_ptr< const CPSG_Request > user_request, const CPSG_Request::TFlags &flags, bool raw)

Private Attributes
CService	m_Service
CPSG_Request::TFlags	m_RequestFlags = CPSG_Request::eDefaultFlags
SThreadSafe< SPSG_UserArgsBuilder >	m_UserArgsBuilder

Detailed Description

Definition at line 117 of file psg_client_impl.hpp.

Constructor & Destructor Documentation

SImpl()

CPSG_Queue::SImpl::SImpl

(

const string &

service

)

Definition at line 712 of file psg_client.cpp.

Member Function Documentation

GetApiLock()

static TApiLock CPSG_Queue::SImpl::GetApiLock ( )

inlinestatic

Definition at line 131 of file psg_client_impl.hpp.

References CPSG_Queue::SImpl::CService::GetMap().

Referenced by CPSG_Queue::GetApiLock().

RejectsRequests()

bool CPSG_Queue::SImpl::RejectsRequests ( ) const

inline

Definition at line 127 of file psg_client_impl.hpp.

References CPSG_Queue::SImpl::CService::ioc, m_Service, and SPSG_IoCoordinator::RejectsRequests().

SendRequest()

bool CPSG_Queue::SImpl::SendRequest	(	shared_ptr< CPSG_Request >	request,
		CDeadline	deadline
	)

Definition at line 990 of file psg_client.cpp.

References _ASSERT, and CPSG_Queue::SendRequestAndGetReply().

SendRequestAndGetReply()

shared_ptr< CPSG_Reply > CPSG_Queue::SImpl::SendRequestAndGetReply	(	shared_ptr< CPSG_Request >	request,
		CDeadline	deadline
	)

Definition at line 952 of file psg_client.cpp.

References _ASSERT, CPSG_Request::eBlob, SPSG_StatsCounters::eRequest, CPSG_Queue::SImpl::CService::ioc, m_RequestFlags, m_Service, NCBI_THROW, SPSG_IoCoordinator::params, queue, r(), stats, and x_GetAbsPathRef().

SetRequestFlags()

void CPSG_Queue::SImpl::SetRequestFlags ( CPSG_Request::TFlags  request_flags )

inline

Definition at line 128 of file psg_client_impl.hpp.

References m_RequestFlags.

SetUserArgs()

void CPSG_Queue::SImpl::SetUserArgs ( SPSG_UserArgs  user_args )

inline

Definition at line 129 of file psg_client_impl.hpp.

References SThreadSafe< TType >::GetLock(), and m_UserArgsBuilder.

WaitForEvents()

bool CPSG_Queue::SImpl::WaitForEvents

(

CDeadline

deadline

)

Definition at line 1002 of file psg_client.cpp.

References _ASSERT.

x_GetAbsPathRef()

string CPSG_Queue::SImpl::x_GetAbsPathRef ( shared_ptr< const CPSG_Request >  user_request, const CPSG_Request::TFlags &  flags, bool  raw  )

private

Definition at line 748 of file psg_client.cpp.

References _ASSERT, CPSG_Request::fIncludeHUP, flags, and s_GetOtherArgs().

Referenced by SendRequestAndGetReply().

Member Data Documentation

m_RequestFlags

CPSG_Request::TFlags CPSG_Queue::SImpl::m_RequestFlags = CPSG_Request::eDefaultFlags

private

Definition at line 155 of file psg_client_impl.hpp.

Referenced by SendRequestAndGetReply(), and SetRequestFlags().

m_Service

CService CPSG_Queue::SImpl::m_Service

private

Definition at line 154 of file psg_client_impl.hpp.

Referenced by RejectsRequests(), and SendRequestAndGetReply().

m_UserArgsBuilder

SThreadSafe<SPSG_UserArgsBuilder> CPSG_Queue::SImpl::m_UserArgsBuilder

private

Definition at line 156 of file psg_client_impl.hpp.

Referenced by SetUserArgs().

queue

shared_ptr<TPSG_Queue> CPSG_Queue::SImpl::queue

Definition at line 119 of file psg_client_impl.hpp.

Referenced by SendRequestAndGetReply().

---

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

• src/objtools/pubseq_gateway/client/psg_client_impl.hpp
• src/objtools/pubseq_gateway/client/psg_client.cpp