跳至内容

PollingRPCBackend

template<class ServiceType, typename RequestType, typename ResponseType>
class PollingRPCBackend : public RPCBackend<ServiceType, RequestType, ResponseType>, public IPollingBackendInterface<RequestType>

模板参数

  • class ServiceType
  • typename RequestType
  • typename ResponseType

依赖项: IPollingBackendInterface, PollingRPCWorker, RPCBackend

继承自: public RPCBackend<ServiceType, RequestType, ResponseType>, public IPollingBackendInterface<RequestType>

公共接口

构造函数

PollingRPCBackend

inline PollingRPCBackend(RPCBackend::AsyncRPCHandle TargetRPC, std::shared_ptr<ServiceType> Service, std::unique_ptr<ServerCompletionQueue> CQueue)

参数

名称类型默认
TargetRPCRPCBackend::AsyncRPCHandle
Servicestd::shared_ptr<ServiceType>
CQueuestd::unique_ptr<ServerCompletionQueue>

属性: inline

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 127, column 1)

析构函数

~PollingRPCBackend

inline ~PollingRPCBackend()

属性: inline

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 133, column 1)

公共函数

轮询

inline virtual TOptional<const RequestType *> Poll() override

轮询后端以从客户端获取消息。

返回值: 如果未收到消息,则为空可选值,否则为已填充的值

注意: 此函数应为非阻塞的

返回: TOptional&lt;const RequestType &#42;&gt;

属性: inline, virtual

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 139, column 11)

Initialize

inline virtual void Initialize()

执行任何发生在建立任何外部连接之前的设置。

这可能包括打开套接字并等待连接。

属性: inline, virtual

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 154, column 14)

Start

inline virtual void Start() override

属性: inline, virtual

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 156, column 14)

Establish

inline virtual void Establish()

执行涉及与外部通信进行握手的任何设置(例如。

设置序列化)。在 Initialize 之后使用。

属性: inline, virtual

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 161, column 14)

关闭

inline virtual void Shutdown() override

关闭外部连接。

属性: inline, virtual

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 163, column 14)

Restart

inline virtual void Restart()

重置通信后端。

属性: inline, virtual

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 168, column 14)

私有接口

私有成员

PollingRPCWorker<ServiceType, RequestType, ResponseType> * Worker

PollingRPCWorker<ServiceType, RequestType, ResponseType> * Worker

属性: private

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 123, column 18)

来源: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 119, column 1)

© . This site is unofficial and not affiliated with AMD.