SWC::Comm::Protocol::Rgr::Req::RangeLoad Class Reference

#include <swcdb/manager/Protocol/Rgr/req/RangeLoad.h>

Inheritance diagram for SWC::Comm::Protocol::Rgr::Req::RangeLoad:

Collaboration diagram for SWC::Comm::Protocol::Rgr::Req::RangeLoad:

Public Types
typedef std::shared_ptr< RangeLoad >	Ptr
Public Types inherited from SWC::Comm::client::ConnQueueReqBase
typedef std::shared_ptr< ConnQueueReqBase >	Ptr
Public Types inherited from SWC::Comm::DispatchHandler
typedef std::shared_ptr< DispatchHandler >	Ptr

Public Member Functions
	RangeLoad (const Manager::Ranger::Ptr &rgr, const Manager::Column::Ptr &col, const Manager::Range::Ptr &range, const DB::Schema::Ptr &schema)
	RangeLoad (RangeLoad &&)=delete
	RangeLoad (const RangeLoad &)=delete
RangeLoad &	operator= (RangeLoad &&)=delete
RangeLoad &	operator= (const RangeLoad &)=delete
virtual	~RangeLoad () noexcept
void	handle (ConnHandlerPtr conn, const Event::Ptr &ev) override
bool	valid () override
void	handle_no_conn () override
void	loaded (int err, bool failure, const DB::Cells::Interval &intval, int64_t revision)
Public Member Functions inherited from SWC::Comm::client::ConnQueueReqBase
SWC_CAN_INLINE	ConnQueueReqBase (Buffers::Ptr &&a_cbp) noexcept
SWC_CAN_INLINE	ConnQueueReqBase (Buffers::Ptr &&a_cbp, const ConnQueuePtr &a_queue) noexcept
SWC_CAN_INLINE Ptr	req () noexcept
virtual bool	insistent () noexcept
void	request_again ()
void	print (std::ostream &out)
Public Member Functions inherited from SWC::Comm::DispatchHandler
virtual bool	run ()

Private Attributes
Manager::Ranger::Ptr	rgr
Manager::Column::Ptr	col
Manager::Range::Ptr	range
int64_t	schema_revision

Additional Inherited Members
Public Attributes inherited from SWC::Comm::client::ConnQueueReqBase
Buffers::Ptr	cbp
ConnQueuePtr	queue
Protected Member Functions inherited from SWC::Comm::client::ConnQueueReqBase
virtual	~ConnQueueReqBase () noexcept
Protected Member Functions inherited from SWC::Comm::DispatchHandler
virtual	~DispatchHandler () noexcept

Detailed Description

Definition at line 13 of file RangeLoad.h.

Member Typedef Documentation

Ptr

typedef std::shared_ptr<RangeLoad> SWC::Comm::Protocol::Rgr::Req::RangeLoad::Ptr

Definition at line 15 of file RangeLoad.h.

Constructor & Destructor Documentation

RangeLoad() [1/3]

SWC_CAN_INLINE SWC::Comm::Protocol::Rgr::Req::RangeLoad::RangeLoad	(	const Manager::Ranger::Ptr &	rgr,
		const Manager::Column::Ptr &	col,
		const Manager::Range::Ptr &	range,
		const DB::Schema::Ptr &	schema
	)

Definition at line 14 of file RangeLoad.cc.

References SWC::LOG_INFO, range, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

RangeLoad() [2/3]

SWC::Comm::Protocol::Rgr::Req::RangeLoad::RangeLoad ( RangeLoad &&  )

delete

RangeLoad() [3/3]

SWC::Comm::Protocol::Rgr::Req::RangeLoad::RangeLoad ( const RangeLoad &  )

delete

~RangeLoad()

virtual SWC::Comm::Protocol::Rgr::Req::RangeLoad::~RangeLoad ( )

inlinevirtualnoexcept

Definition at line 27 of file RangeLoad.h.

Member Function Documentation

handle()

void SWC::Comm::Protocol::Rgr::Req::RangeLoad::handle ( ConnHandlerPtr  conn, const Event::Ptr &  ev  )

overridevirtual

Implements SWC::Comm::DispatchHandler.

Definition at line 30 of file RangeLoad.cc.

References SWC::Error::Exception::code(), SWC::Comm::Serializable::decode(), handle_no_conn(), SWC::Comm::Protocol::Rgr::Params::RangeLoaded::interval, loaded(), SWC::LOG_ERROR, range, SWC::Comm::Protocol::Rgr::Params::RangeLoaded::revision, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, SWC_LOG_OUT, and valid().

Here is the call graph for this function:

handle_no_conn()

void SWC::Comm::Protocol::Rgr::Req::RangeLoad::handle_no_conn ( )

overridevirtual

Implements SWC::Comm::DispatchHandler.

Definition at line 56 of file RangeLoad.cc.

References SWC::Error::COMM_NOT_CONNECTED, loaded(), and range.

Referenced by handle().

Here is the call graph for this function:

Here is the caller graph for this function:

loaded()

void SWC::Comm::Protocol::Rgr::Req::RangeLoad::loaded	(	int	err,
		bool	failure,
		const DB::Cells::Interval &	intval,
		int64_t	revision
	)

Definition at line 62 of file RangeLoad.cc.

References col, SWC::LOG_INFO, SWC::Error::print(), range, SWC::Manager::Rangers::range_loaded(), SWC::Env::Mngr::rangers(), rgr, schema_revision, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by handle(), and handle_no_conn().

Here is the call graph for this function:

Here is the caller graph for this function:

operator=() [1/2]

RangeLoad& SWC::Comm::Protocol::Rgr::Req::RangeLoad::operator= ( const RangeLoad &  )

delete

operator=() [2/2]

RangeLoad& SWC::Comm::Protocol::Rgr::Req::RangeLoad::operator= ( RangeLoad &&  )

delete

valid()

bool SWC::Comm::Protocol::Rgr::Req::RangeLoad::valid ( )

overridevirtual

Reimplemented from SWC::Comm::DispatchHandler.

Definition at line 51 of file RangeLoad.cc.

References range, SWC::Env::Mngr::rangers(), and SWC::Manager::Rangers::running().

Referenced by handle().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

col

Manager::Column::Ptr SWC::Comm::Protocol::Rgr::Req::RangeLoad::col

private

Definition at line 41 of file RangeLoad.h.

Referenced by loaded().

range

Manager::Range::Ptr SWC::Comm::Protocol::Rgr::Req::RangeLoad::range

private

Definition at line 42 of file RangeLoad.h.

Referenced by handle(), handle_no_conn(), loaded(), RangeLoad(), and valid().

rgr

Manager::Ranger::Ptr SWC::Comm::Protocol::Rgr::Req::RangeLoad::rgr

private

Definition at line 40 of file RangeLoad.h.

Referenced by loaded().

schema_revision

int64_t SWC::Comm::Protocol::Rgr::Req::RangeLoad::schema_revision

private

Definition at line 43 of file RangeLoad.h.

Referenced by loaded().

---

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

• include/swcdb/manager/Protocol/Rgr/req/RangeLoad.h
• lib/swcdb/manager/Protocol/Rgr/req/RangeLoad.cc