xrpld
Loading...
Searching...
No Matches
Public Member Functions | Private Member Functions | Private Attributes | List of all members
xrpl::GRPCServerImpl::CallData< Request, Response > Class Template Reference
Inheritance diagram for xrpl::GRPCServerImpl::CallData< Request, Response >:
Inheritance graph
[legend]
Collaboration diagram for xrpl::GRPCServerImpl::CallData< Request, Response >:
Collaboration graph
[legend]

Public Member Functions

 ~CallData () override=default
 CallData (org::xrpl::rpc::v1::XRPLedgerAPIService::AsyncService &service, grpc::ServerCompletionQueue &cq, Application &app, BindListener< Request, Response > bindListener, Handler< Request, Response > handler, Forward< Request, Response > forward, rpc::Condition requiredCondition, resource::Charge loadType, std::vector< boost::asio::ip::address > const &secureGatewayIPs)
 CallData (CallData const &)=delete
CallData & operator= (CallData const &)=delete
void process () override
bool isFinished () override
std::shared_ptr< Processor > clone () override
T shared_from_this (T... args)
T weak_from_this (T... args)

Private Member Functions

void process (std::shared_ptr< JobQueue::Coro > coro)
resource::Charge getLoadType ()
Role getRole (bool isUnlimited)
resource::Consumer getUsage ()
std::optional< boost::asio::ip::address > getClientIpAddress ()
std::optional< boost::asio::ip::tcp::endpoint > getClientEndpoint ()
std::optional< boost::asio::ip::address > getProxiedClientIpAddress ()
std::optional< boost::asio::ip::tcp::endpoint > getProxiedClientEndpoint ()
std::optional< std::string > getUser ()
void setIsUnlimited (Response &response, bool isUnlimited)
bool clientIsUnlimited ()
bool wasForwarded ()
void forwardToP2p (rpc::GRPCContext< Request > &context)

Private Attributes

org::xrpl::rpc::v1::XRPLedgerAPIService::AsyncService & service_
grpc::ServerCompletionQueue & cq_
grpc::ServerContext ctx_
std::atomic_bool finished_
Application & app_
Request request_
grpc::ServerAsyncResponseWriter< Response > responder_
BindListener< Request, Response > bindListener_
Handler< Request, Response > handler_
Forward< Request, Response > forward_
rpc::Condition requiredCondition_
resource::Charge loadType_
std::vector< boost::asio::ip::address > const & secureGatewayIPs_

Detailed Description

template<class Request, class Response>
class xrpl::GRPCServerImpl::CallData< Request, Response >

Definition at line 151 of file GRPCServer.h.

Constructor & Destructor Documentation

◆ ~CallData()

template<class Request, class Response>
xrpl::GRPCServerImpl::CallData< Request, Response >::~CallData ( )
overridedefault

◆ CallData() [1/2]

template<class Request, class Response>
xrpl::GRPCServerImpl::CallData< Request, Response >::CallData ( org::xrpl::rpc::v1::XRPLedgerAPIService::AsyncService & service,
grpc::ServerCompletionQueue & cq,
Application & app,
BindListener< Request, Response > bindListener,
Handler< Request, Response > handler,
Forward< Request, Response > forward,
rpc::Condition requiredCondition,
resource::Charge loadType,
std::vector< boost::asio::ip::address > const & secureGatewayIPs )
explicit

Definition at line 89 of file GRPCServer.cpp.

◆ CallData() [2/2]

template<class Request, class Response>
xrpl::GRPCServerImpl::CallData< Request, Response >::CallData ( CallData< Request, Response > const & )
delete

Member Function Documentation

◆ operator=()

template<class Request, class Response>
CallData & xrpl::GRPCServerImpl::CallData< Request, Response >::operator= ( CallData< Request, Response > const & )
delete

◆ process() [1/2]

template<class Request, class Response>
void xrpl::GRPCServerImpl::CallData< Request, Response >::process ( )
overridevirtual

Implements xrpl::Processor.

Definition at line 134 of file GRPCServer.cpp.

◆ isFinished()

template<class Request, class Response>
bool xrpl::GRPCServerImpl::CallData< Request, Response >::isFinished ( )
overridevirtual

Implements xrpl::Processor.

Definition at line 239 of file GRPCServer.cpp.

◆ clone()

template<class Request, class Response>
std::shared_ptr< Processor > xrpl::GRPCServerImpl::CallData< Request, Response >::clone ( )
overridevirtual

Implements xrpl::Processor.

Definition at line 118 of file GRPCServer.cpp.

◆ process() [2/2]

template<class Request, class Response>
void xrpl::GRPCServerImpl::CallData< Request, Response >::process ( std::shared_ptr< JobQueue::Coro > coro)
private

Definition at line 165 of file GRPCServer.cpp.

◆ getLoadType()

template<class Request, class Response>
resource::Charge xrpl::GRPCServerImpl::CallData< Request, Response >::getLoadType ( )
private

Definition at line 246 of file GRPCServer.cpp.

◆ getRole()

template<class Request, class Response>
Role xrpl::GRPCServerImpl::CallData< Request, Response >::getRole ( bool isUnlimited)
private

Definition at line 253 of file GRPCServer.cpp.

◆ getUsage()

template<class Request, class Response>
resource::Consumer xrpl::GRPCServerImpl::CallData< Request, Response >::getUsage ( )
private

Definition at line 328 of file GRPCServer.cpp.

◆ getClientIpAddress()

template<class Request, class Response>
std::optional< boost::asio::ip::address > xrpl::GRPCServerImpl::CallData< Request, Response >::getClientIpAddress ( )
private

Definition at line 280 of file GRPCServer.cpp.

◆ getClientEndpoint()

template<class Request, class Response>
std::optional< boost::asio::ip::tcp::endpoint > xrpl::GRPCServerImpl::CallData< Request, Response >::getClientEndpoint ( )
private

Definition at line 290 of file GRPCServer.cpp.

◆ getProxiedClientIpAddress()

template<class Request, class Response>
std::optional< boost::asio::ip::address > xrpl::GRPCServerImpl::CallData< Request, Response >::getProxiedClientIpAddress ( )
private

◆ getProxiedClientEndpoint()

template<class Request, class Response>
std::optional< boost::asio::ip::tcp::endpoint > xrpl::GRPCServerImpl::CallData< Request, Response >::getProxiedClientEndpoint ( )
private

◆ getUser()

template<class Request, class Response>
std::optional< std::string > xrpl::GRPCServerImpl::CallData< Request, Response >::getUser ( )
private

Definition at line 265 of file GRPCServer.cpp.

◆ setIsUnlimited()

template<class Request, class Response>
void xrpl::GRPCServerImpl::CallData< Request, Response >::setIsUnlimited ( Response & response,
bool isUnlimited )
private

Definition at line 315 of file GRPCServer.cpp.

◆ clientIsUnlimited()

template<class Request, class Response>
bool xrpl::GRPCServerImpl::CallData< Request, Response >::clientIsUnlimited ( )
private

Definition at line 297 of file GRPCServer.cpp.

◆ wasForwarded()

template<class Request, class Response>
bool xrpl::GRPCServerImpl::CallData< Request, Response >::wasForwarded ( )
private

◆ forwardToP2p()

template<class Request, class Response>
void xrpl::GRPCServerImpl::CallData< Request, Response >::forwardToP2p ( rpc::GRPCContext< Request > & context)
private

Member Data Documentation

◆ service_

template<class Request, class Response>
org::xrpl::rpc::v1::XRPLedgerAPIService::AsyncService& xrpl::GRPCServerImpl::CallData< Request, Response >::service_
private

Definition at line 157 of file GRPCServer.h.

◆ cq_

template<class Request, class Response>
grpc::ServerCompletionQueue& xrpl::GRPCServerImpl::CallData< Request, Response >::cq_
private

Definition at line 160 of file GRPCServer.h.

◆ ctx_

template<class Request, class Response>
grpc::ServerContext xrpl::GRPCServerImpl::CallData< Request, Response >::ctx_
private

Definition at line 165 of file GRPCServer.h.

◆ finished_

template<class Request, class Response>
std::atomic_bool xrpl::GRPCServerImpl::CallData< Request, Response >::finished_
private

Definition at line 172 of file GRPCServer.h.

◆ app_

template<class Request, class Response>
Application& xrpl::GRPCServerImpl::CallData< Request, Response >::app_
private

Definition at line 174 of file GRPCServer.h.

◆ request_

template<class Request, class Response>
Request xrpl::GRPCServerImpl::CallData< Request, Response >::request_
private

Definition at line 177 of file GRPCServer.h.

◆ responder_

template<class Request, class Response>
grpc::ServerAsyncResponseWriter<Response> xrpl::GRPCServerImpl::CallData< Request, Response >::responder_
private

Definition at line 180 of file GRPCServer.h.

◆ bindListener_

template<class Request, class Response>
BindListener<Request, Response> xrpl::GRPCServerImpl::CallData< Request, Response >::bindListener_
private

Definition at line 183 of file GRPCServer.h.

◆ handler_

template<class Request, class Response>
Handler<Request, Response> xrpl::GRPCServerImpl::CallData< Request, Response >::handler_
private

Definition at line 186 of file GRPCServer.h.

◆ forward_

template<class Request, class Response>
Forward<Request, Response> xrpl::GRPCServerImpl::CallData< Request, Response >::forward_
private

Definition at line 189 of file GRPCServer.h.

◆ requiredCondition_

template<class Request, class Response>
rpc::Condition xrpl::GRPCServerImpl::CallData< Request, Response >::requiredCondition_
private

Definition at line 192 of file GRPCServer.h.

◆ loadType_

template<class Request, class Response>
resource::Charge xrpl::GRPCServerImpl::CallData< Request, Response >::loadType_
private

Definition at line 195 of file GRPCServer.h.

◆ secureGatewayIPs_

template<class Request, class Response>
std::vector<boost::asio::ip::address> const& xrpl::GRPCServerImpl::CallData< Request, Response >::secureGatewayIPs_
private

Definition at line 197 of file GRPCServer.h.

Generated by doxygen 1.16.1