ripple::AsyncCallData Class Reference

Collaboration diagram for ripple::AsyncCallData:

Public Types
enum	CallStatus { CallStatus::MORE, CallStatus::DONE, CallStatus::ERRORED }

Public Member Functions
	AsyncCallData (uint256 &marker, std::optional< uint256 > nextMarker, uint32_t seq, beast::Journal &j)
CallStatus	process (std::unique_ptr< org::xrpl::rpc::v1::XRPLedgerAPIService::Stub > &stub, grpc::CompletionQueue &cq, ThreadSafeQueue< std::shared_ptr< SLE >> &queue, bool abort=false)
void	call (std::unique_ptr< org::xrpl::rpc::v1::XRPLedgerAPIService::Stub > &stub, grpc::CompletionQueue &cq)
std::string	getMarkerPrefix ()

Private Attributes
std::unique_ptr< org::xrpl::rpc::v1::GetLedgerDataResponse >	cur_
std::unique_ptr< org::xrpl::rpc::v1::GetLedgerDataResponse >	next_
org::xrpl::rpc::v1::GetLedgerDataRequest	request_
std::unique_ptr< grpc::ClientContext >	context_
grpc::Status	status_
unsigned char	nextPrefix_
beast::Journal	journal_

Detailed Description

Definition at line 416 of file ETLSource.cpp.

Member Enumeration Documentation

CallStatus

enum ripple::AsyncCallData::CallStatus

strong

Enumerator
MORE
DONE
ERRORED

Definition at line 464 of file ETLSource.cpp.

Constructor & Destructor Documentation

AsyncCallData()

ripple::AsyncCallData::AsyncCallData	(	uint256 &	marker,
		std::optional< uint256 >	nextMarker,
		uint32_t	seq,
		beast::Journal &	j
	)

Definition at line 431 of file ETLSource.cpp.

Member Function Documentation

process()

CallStatus ripple::AsyncCallData::process	(	std::unique_ptr< org::xrpl::rpc::v1::XRPLedgerAPIService::Stub > &	stub,
		grpc::CompletionQueue &	cq,
		ThreadSafeQueue< std::shared_ptr< SLE >> &	queue,
		bool	abort = false
	)

Definition at line 466 of file ETLSource.cpp.

call()

void ripple::AsyncCallData::call	(	std::unique_ptr< org::xrpl::rpc::v1::XRPLedgerAPIService::Stub > &	stub,
		grpc::CompletionQueue &	cq
	)

Definition at line 531 of file ETLSource.cpp.

getMarkerPrefix()

std::string ripple::AsyncCallData::getMarkerPrefix

(

)

Definition at line 547 of file ETLSource.cpp.

Member Data Documentation

cur_

std::unique_ptr<org::xrpl::rpc::v1::GetLedgerDataResponse> ripple::AsyncCallData::cur_

private

Definition at line 418 of file ETLSource.cpp.

next_

std::unique_ptr<org::xrpl::rpc::v1::GetLedgerDataResponse> ripple::AsyncCallData::next_

private

Definition at line 419 of file ETLSource.cpp.

request_

org::xrpl::rpc::v1::GetLedgerDataRequest ripple::AsyncCallData::request_

private

Definition at line 421 of file ETLSource.cpp.

context_

std::unique_ptr<grpc::ClientContext> ripple::AsyncCallData::context_

private

Definition at line 422 of file ETLSource.cpp.

status_

grpc::Status ripple::AsyncCallData::status_

private

Definition at line 424 of file ETLSource.cpp.

nextPrefix_

unsigned char ripple::AsyncCallData::nextPrefix_

private

Definition at line 426 of file ETLSource.cpp.

journal_

beast::Journal ripple::AsyncCallData::journal_

private

Definition at line 428 of file ETLSource.cpp.