ripple::RPCSubImp Class Reference

Inheritance diagram for ripple::RPCSubImp:

Collaboration diagram for ripple::RPCSubImp:

Public Types
using	pointer = std::shared_ptr< InfoSub >
using	wptr = std::weak_ptr< InfoSub >
using	ref = const std::shared_ptr< InfoSub > &
using	Consumer = Resource::Consumer

Public Member Functions
	RPCSubImp (InfoSub::Source &source, boost::asio::io_service &io_service, JobQueue &jobQueue, std::string const &strUrl, std::string const &strUsername, std::string const &strPassword, Logs &logs)
	~RPCSubImp ()=default
void	send (Json::Value const &jvObj, bool broadcast) override
void	setUsername (std::string const &strUsername) override
void	setPassword (std::string const &strPassword) override
Consumer &	getConsumer ()
std::uint64_t	getSeq ()
void	onSendEmpty ()
void	insertSubAccountInfo (AccountID const &account, bool rt)
void	deleteSubAccountInfo (AccountID const &account, bool rt)
bool	insertSubAccountHistory (AccountID const &account)
void	deleteSubAccountHistory (AccountID const &account)
void	clearRequest ()
void	setRequest (const std::shared_ptr< InfoSubRequest > &req)
std::shared_ptr< InfoSubRequest > const &	getRequest ()

Protected Attributes
std::mutex	mLock

Private Types
enum	{ eventQueueMax = 32 }

Private Member Functions
void	sendThread ()

Static Private Member Functions
static int	assign_id ()
static auto &	getCounter () noexcept

Private Attributes
boost::asio::io_service &	m_io_service
JobQueue &	m_jobQueue
std::string	mUrl
std::string	mIp
std::uint16_t	mPort
bool	mSSL
std::string	mUsername
std::string	mPassword
std::string	mPath
int	mSeq
bool	mSending
std::deque< std::pair< int, Json::Value > >	mDeque
const beast::Journal	j_
Logs &	logs_
Consumer	m_consumer
Source &	m_source
hash_set< AccountID >	realTimeSubscriptions_
hash_set< AccountID >	normalSubscriptions_
std::shared_ptr< InfoSubRequest >	request_
hash_set< AccountID >	accountHistorySubscriptions_

Detailed Description

Definition at line 31 of file RPCSub.cpp.

Member Typedef Documentation

pointer

using ripple::InfoSub::pointer = std::shared_ptr<InfoSub>

inherited

Definition at line 54 of file InfoSub.h.

wptr

using ripple::InfoSub::wptr = std::weak_ptr<InfoSub>

inherited

Definition at line 58 of file InfoSub.h.

ref

using ripple::InfoSub::ref = const std::shared_ptr<InfoSub>&

inherited

Definition at line 60 of file InfoSub.h.

Consumer

using ripple::InfoSub::Consumer = Resource::Consumer

inherited

Definition at line 62 of file InfoSub.h.

Member Enumeration Documentation

anonymous enum

anonymous enum

private

Enumerator
eventQueueMax

Definition at line 185 of file RPCSub.cpp.

Constructor & Destructor Documentation

RPCSubImp()

ripple::RPCSubImp::RPCSubImp	(	InfoSub::Source &	source,
		boost::asio::io_service &	io_service,
		JobQueue &	jobQueue,
		std::string const &	strUrl,
		std::string const &	strUsername,
		std::string const &	strPassword,
		Logs &	logs
	)

Definition at line 34 of file RPCSub.cpp.

~RPCSubImp()

ripple::RPCSubImp::~RPCSubImp ( )

default

Member Function Documentation

send()

void ripple::RPCSubImp::send ( Json::Value const &  jvObj, bool  broadcast  )

overridevirtual

Implements ripple::InfoSub.

Definition at line 77 of file RPCSub.cpp.

setUsername()

void ripple::RPCSubImp::setUsername ( std::string const &  strUsername )

overridevirtual

Implements ripple::RPCSub.

Definition at line 106 of file RPCSub.cpp.

setPassword()

void ripple::RPCSubImp::setPassword ( std::string const &  strPassword )

overridevirtual

Implements ripple::RPCSub.

Definition at line 114 of file RPCSub.cpp.

sendThread()

void ripple::RPCSubImp::sendThread ( )

private

Definition at line 125 of file RPCSub.cpp.

getConsumer()

Resource::Consumer & ripple::InfoSub::getConsumer ( )

inherited

Definition at line 69 of file InfoSub.cpp.

getSeq()

std::uint64_t ripple::InfoSub::getSeq ( )

inherited

Definition at line 75 of file InfoSub.cpp.

onSendEmpty()

void ripple::InfoSub::onSendEmpty ( )

inherited

Definition at line 81 of file InfoSub.cpp.

insertSubAccountInfo()

void ripple::InfoSub::insertSubAccountInfo ( AccountID const &  account, bool  rt  )

inherited

Definition at line 86 of file InfoSub.cpp.

deleteSubAccountInfo()

void ripple::InfoSub::deleteSubAccountInfo ( AccountID const &  account, bool  rt  )

inherited

Definition at line 97 of file InfoSub.cpp.

insertSubAccountHistory()

bool ripple::InfoSub::insertSubAccountHistory ( AccountID const &  account )

inherited

Definition at line 108 of file InfoSub.cpp.

deleteSubAccountHistory()

void ripple::InfoSub::deleteSubAccountHistory ( AccountID const &  account )

inherited

Definition at line 115 of file InfoSub.cpp.

clearRequest()

void ripple::InfoSub::clearRequest ( )

inherited

Definition at line 122 of file InfoSub.cpp.

setRequest()

void ripple::InfoSub::setRequest ( const std::shared_ptr< InfoSubRequest > &  req )

inherited

Definition at line 128 of file InfoSub.cpp.

getRequest()

const std::shared_ptr< InfoSubRequest > & ripple::InfoSub::getRequest ( )

inherited

Definition at line 134 of file InfoSub.cpp.

assign_id()

static int ripple::InfoSub::assign_id ( )

staticprivateinherited

Definition at line 245 of file InfoSub.h.

getCounter()

static auto& ripple::CountedObject< InfoSub >::getCounter ( )

staticprivatenoexceptinherited

Definition at line 128 of file CountedObject.h.

Member Data Documentation

m_io_service

boost::asio::io_service& ripple::RPCSubImp::m_io_service

private

Definition at line 187 of file RPCSub.cpp.

m_jobQueue

JobQueue& ripple::RPCSubImp::m_jobQueue

private

Definition at line 188 of file RPCSub.cpp.

mUrl

std::string ripple::RPCSubImp::mUrl

private

Definition at line 190 of file RPCSub.cpp.

mIp

std::string ripple::RPCSubImp::mIp

private

Definition at line 191 of file RPCSub.cpp.

mPort

std::uint16_t ripple::RPCSubImp::mPort

private

Definition at line 192 of file RPCSub.cpp.

mSSL

bool ripple::RPCSubImp::mSSL

private

Definition at line 193 of file RPCSub.cpp.

mUsername

std::string ripple::RPCSubImp::mUsername

private

Definition at line 194 of file RPCSub.cpp.

mPassword

std::string ripple::RPCSubImp::mPassword

private

Definition at line 195 of file RPCSub.cpp.

mPath

std::string ripple::RPCSubImp::mPath

private

Definition at line 196 of file RPCSub.cpp.

mSeq

int ripple::RPCSubImp::mSeq

private

Definition at line 198 of file RPCSub.cpp.

mSending

bool ripple::RPCSubImp::mSending

private

Definition at line 200 of file RPCSub.cpp.

mDeque

std::deque<std::pair<int, Json::Value> > ripple::RPCSubImp::mDeque

private

Definition at line 202 of file RPCSub.cpp.

j_

const beast::Journal ripple::RPCSubImp::j_

private

Definition at line 204 of file RPCSub.cpp.

logs_

Logs& ripple::RPCSubImp::logs_

private

Definition at line 205 of file RPCSub.cpp.

mLock

std::mutex ripple::InfoSub::mLock

protectedinherited

Definition at line 233 of file InfoSub.h.

m_consumer

Consumer ripple::InfoSub::m_consumer

privateinherited

Definition at line 236 of file InfoSub.h.

m_source

Source& ripple::InfoSub::m_source

privateinherited

Definition at line 237 of file InfoSub.h.

realTimeSubscriptions_

hash_set<AccountID> ripple::InfoSub::realTimeSubscriptions_

privateinherited

Definition at line 238 of file InfoSub.h.

normalSubscriptions_

hash_set<AccountID> ripple::InfoSub::normalSubscriptions_

privateinherited

Definition at line 239 of file InfoSub.h.

request_

std::shared_ptr<InfoSubRequest> ripple::InfoSub::request_

privateinherited

Definition at line 240 of file InfoSub.h.

accountHistorySubscriptions_

hash_set<AccountID> ripple::InfoSub::accountHistorySubscriptions_

privateinherited

Definition at line 242 of file InfoSub.h.