Skip to content

PollingRPCWorker

template<class ServiceType, typename RequestType, typename ResponseType>
class PollingRPCWorker : public FRunnable

Template Parameters

  • class ServiceType
  • typename RequestType
  • typename ResponseType

Inherits from: public FRunnable

Public Interface

Constructor:

PollingRPCWorker

inline PollingRPCWorker(ServerCompletionQueue *CQueue)

Parameters:

NameTypeDefault
CQueueServerCompletionQueue *

Attributes: inline

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 21, column 1)

Destructor:

~PollingRPCWorker

inline ~PollingRPCWorker()

Attributes: inline

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 26, column 1)

Public Functions:

Init

inline virtual bool Init()

Initialize the worker.

Returns: True. Since initialization cannot fail

Returns: bool

Attributes: inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 35, column 14)

Run

inline virtual uint32 Run()

This workers main method.

Returns: A status code representing the result

Returns: uint32

Attributes: inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 45, column 16)

Start

inline void Start()

Start the worker.

Attributes: inline

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 92, column 6)

Stop

inline virtual void Stop()

Shutdown the worker and it’s associated completion queue.

Attributes: inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 101, column 14)

Exit

inline virtual void Exit()

Attributes: inline, virtual

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 112, column 14)

Public Members:

FRunnableThread * Thread

FRunnableThread * Thread = = nullptr

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 18, column 16)

TQueue<RequestType> Requests

TQueue<RequestType> Requests = = TQueue<RequestType>()

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 19, column 8)

Private Interface

Private Members:

ServerCompletionQueue * CQueue

ServerCompletionQueue * CQueue

Attributes: private

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 15, column 23)

Used By: PollingRPCBackend

Source: Schola/Source/Schola/Public/Communicator/PollingRPCBackend.h (line 10, column 1)