File PointToPointServer.h

namespace faabric

namespace transport

class PointToPointServer : public faabric::transport::MessageEndpointServer

Public Functions

PointToPointServer()

Private Functions

virtual void doAsyncRecv(transport::Message &message) override

virtual std::unique_ptr<google::protobuf::Message> doSyncRecv(transport::Message &message) override

virtual void onWorkerStop() override

std::unique_ptr<google::protobuf::Message> doRecvMappings(std::span<const uint8_t> buffer)

void recvGroupLock(std::span<const uint8_t> buffer, bool recursive)

void recvGroupUnlock(std::span<const uint8_t> buffer, bool recursive)

Private Members

PointToPointBroker &broker