xrpl::RPCSubImp Class Reference

Inheritance diagram for xrpl::RPCSubImp:

Collaboration diagram for xrpl::RPCSubImp:

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

Public Member Functions
	RPCSubImp (InfoSub::Source &source, boost::asio::io_context &ioContext, JobQueue &jobQueue, std::string const &strUrl, std::string strUsername, std::string strPassword, ServiceRegistry &registry)
	~RPCSubImp () override=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 () const
void	onSendEmpty ()
void	insertSubAccountInfo (AccountID const &account, bool rt)
void	deleteSubAccountInfo (AccountID const &account, bool rt)
void	insertBookSubscription (Book const &book)
	Record that this subscriber is following book.
void	deleteBookSubscription (Book const &book)
	Stop tracking book for this subscriber.
bool	insertSubAccountHistory (AccountID const &account)
void	deleteSubAccountHistory (AccountID const &account)
void	clearRequest ()
void	setRequest (std::shared_ptr< InfoSubRequest > const &req)
std::shared_ptr< InfoSubRequest > const &	getRequest ()
void	setApiVersion (unsigned int apiVersion)
unsigned int	getApiVersion () const noexcept

Public Attributes
friend	Object

Protected Attributes
std::mutex	lock_

Private Member Functions
void	sendThread ()

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

Private Attributes
boost::asio::io_context &	ioContext_
JobQueue &	jobQueue_
std::string	url_
std::string	ip_
std::uint16_t	port_
bool	ssl_ {false}
std::string	username_
std::string	password_
std::string	path_
int	seq_
bool	sending_ {false}
std::deque< std::pair< int, json::Value > >	deque_
beast::Journal const	j_
Logs &	logs_
Consumer	consumer_
Source &	source_
hash_set< AccountID >	realTimeSubscriptions_
hash_set< AccountID >	normalSubscriptions_
std::shared_ptr< InfoSubRequest >	request_
hash_set< AccountID >	accountHistorySubscriptions_
hash_set< Book >	bookSubscriptions_
unsigned int	apiVersion_ = 0

Detailed Description

Definition at line 30 of file RPCSub.cpp.

Member Typedef Documentation

pointer

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

inherited

Definition at line 47 of file InfoSub.h.

wptr

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

inherited

Definition at line 51 of file InfoSub.h.

ref

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

inherited

Definition at line 53 of file InfoSub.h.

Consumer

using xrpl::InfoSub::Consumer = Resource::Consumer

inherited

Definition at line 55 of file InfoSub.h.

Constructor & Destructor Documentation

RPCSubImp()

xrpl::RPCSubImp::RPCSubImp	(	InfoSub::Source &	source,
		boost::asio::io_context &	ioContext,
		JobQueue &	jobQueue,
		std::string const &	strUrl,
		std::string	strUsername,
		std::string	strPassword,
		ServiceRegistry &	registry )

Definition at line 33 of file RPCSub.cpp.

~RPCSubImp()

xrpl::RPCSubImp::~RPCSubImp ( )

overridedefault

Member Function Documentation

send()

void xrpl::RPCSubImp::send ( json::Value const & jvObj, bool broadcast )

overridevirtual

Implements xrpl::InfoSub.

Definition at line 85 of file RPCSub.cpp.

setUsername()

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

overridevirtual

Implements xrpl::RPCSub.

Definition at line 105 of file RPCSub.cpp.

setPassword()

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

overridevirtual

Implements xrpl::RPCSub.

Definition at line 113 of file RPCSub.cpp.

sendThread()

void xrpl::RPCSubImp::sendThread ( )

private

Definition at line 124 of file RPCSub.cpp.

getConsumer()

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

inherited

Definition at line 108 of file InfoSub.cpp.

getSeq()

std::uint64_t xrpl::InfoSub::getSeq ( ) const

nodiscardinherited

Definition at line 114 of file InfoSub.cpp.

onSendEmpty()

void xrpl::InfoSub::onSendEmpty ( )

inherited

Definition at line 120 of file InfoSub.cpp.

insertSubAccountInfo()

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

inherited

Definition at line 125 of file InfoSub.cpp.

deleteSubAccountInfo()

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

inherited

Definition at line 140 of file InfoSub.cpp.

insertBookSubscription()

void xrpl::InfoSub::insertBookSubscription ( Book const & book )

inherited

Record that this subscriber is following book.

Called by NetworkOPsImp::subBook so that ~InfoSub() can issue a matching unsubBook for every book this subscriber is tracking, keeping per-subscriber state symmetric with the server-side map.

Parameters

book	The order book this subscriber has just subscribed to.

Note

Idempotent: re-inserting an already-tracked book is a no-op.

Thread-safe: takes InfoSub::lock_.

Definition at line 169 of file InfoSub.cpp.

deleteBookSubscription()

void xrpl::InfoSub::deleteBookSubscription ( Book const & book )

inherited

Stop tracking book for this subscriber.

Called by the unsubscribe RPC handler so that the book is not re-unsubscribed by ~InfoSub(). Pairs with insertBookSubscription.

Parameters

book	The order book to forget.

Note

No-op if book was not previously inserted.

Thread-safe: takes InfoSub::lock_.

Definition at line 176 of file InfoSub.cpp.

insertSubAccountHistory()

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

inherited

Definition at line 155 of file InfoSub.cpp.

deleteSubAccountHistory()

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

inherited

Definition at line 162 of file InfoSub.cpp.

clearRequest()

void xrpl::InfoSub::clearRequest ( )

inherited

Definition at line 183 of file InfoSub.cpp.

setRequest()

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

inherited

Definition at line 189 of file InfoSub.cpp.

getRequest()

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

inherited

Definition at line 195 of file InfoSub.cpp.

setApiVersion()

void xrpl::InfoSub::setApiVersion ( unsigned int apiVersion )

inherited

Definition at line 201 of file InfoSub.cpp.

getApiVersion()

unsigned int xrpl::InfoSub::getApiVersion ( ) const

nodiscardnoexceptinherited

Definition at line 207 of file InfoSub.cpp.

assignId()

int xrpl::InfoSub::assignId ( )

staticprivateinherited

Definition at line 305 of file InfoSub.h.

getCounter()

auto & xrpl::CountedObject< InfoSub >::getCounter ( )

staticprivatenoexceptinherited

Definition at line 109 of file CountedObject.h.

Member Data Documentation

ioContext_

boost::asio::io_context& xrpl::RPCSubImp::ioContext_

private

Definition at line 183 of file RPCSub.cpp.

jobQueue_

JobQueue& xrpl::RPCSubImp::jobQueue_

private

Definition at line 184 of file RPCSub.cpp.

url_

std::string xrpl::RPCSubImp::url_

private

Definition at line 186 of file RPCSub.cpp.

ip_

std::string xrpl::RPCSubImp::ip_

private

Definition at line 187 of file RPCSub.cpp.

port_

std::uint16_t xrpl::RPCSubImp::port_

private

Definition at line 188 of file RPCSub.cpp.

ssl_

bool xrpl::RPCSubImp::ssl_ {false}

private

Definition at line 189 of file RPCSub.cpp.

username_

std::string xrpl::RPCSubImp::username_

private

Definition at line 190 of file RPCSub.cpp.

password_

std::string xrpl::RPCSubImp::password_

private

Definition at line 191 of file RPCSub.cpp.

path_

std::string xrpl::RPCSubImp::path_

private

Definition at line 192 of file RPCSub.cpp.

seq_

int xrpl::RPCSubImp::seq_

private

Definition at line 194 of file RPCSub.cpp.

sending_

bool xrpl::RPCSubImp::sending_ {false}

private

Definition at line 196 of file RPCSub.cpp.

deque_

std::deque<std::pair<int, json::Value> > xrpl::RPCSubImp::deque_

private

Definition at line 198 of file RPCSub.cpp.

j_

beast::Journal const xrpl::RPCSubImp::j_

private

Definition at line 200 of file RPCSub.cpp.

logs_

Logs& xrpl::RPCSubImp::logs_

private

Definition at line 201 of file RPCSub.cpp.

lock_

std::mutex xrpl::InfoSub::lock_

protectedinherited

Definition at line 291 of file InfoSub.h.

consumer_

Consumer xrpl::InfoSub::consumer_

privateinherited

Definition at line 294 of file InfoSub.h.

source_

Source& xrpl::InfoSub::source_

privateinherited

Definition at line 295 of file InfoSub.h.

realTimeSubscriptions_

hash_set<AccountID> xrpl::InfoSub::realTimeSubscriptions_

privateinherited

Definition at line 296 of file InfoSub.h.

normalSubscriptions_

hash_set<AccountID> xrpl::InfoSub::normalSubscriptions_

privateinherited

Definition at line 297 of file InfoSub.h.

request_

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

privateinherited

Definition at line 298 of file InfoSub.h.

accountHistorySubscriptions_

hash_set<AccountID> xrpl::InfoSub::accountHistorySubscriptions_

privateinherited

Definition at line 300 of file InfoSub.h.

bookSubscriptions_

hash_set<Book> xrpl::InfoSub::bookSubscriptions_

privateinherited

Definition at line 301 of file InfoSub.h.

apiVersion_

unsigned int xrpl::InfoSub::apiVersion_ = 0

privateinherited

Definition at line 302 of file InfoSub.h.

Object

friend xrpl::CountedObject< InfoSub >::InfoSub

inherited

Definition at line 134 of file CountedObject.h.