#include <fairmq/ofi/Socket.h>

Inheritance diagram for fair::mq::ofi::Socket:

Collaboration diagram for fair::mq::ofi::Socket:

Public Member Functions
	Socket (Context &context, const std::string &type, const std::string &name, const std::string &id="")

	Socket (const Socket &)=delete

Socket	operator= (const Socket &)=delete

auto	GetId () const -> std::string override

auto	Events (uint32_t *events) -> void override

auto	Bind (const std::string &address) -> bool override

auto	Connect (const std::string &address) -> bool override

auto	Send (MessagePtr &msg, int timeout=0) -> int64_t override

auto	Receive (MessagePtr &msg, int timeout=0) -> int64_t override

auto	Send (std::vector< MessagePtr > &msgVec, int timeout=0) -> int64_t override

auto	Receive (std::vector< MessagePtr > &msgVec, int timeout=0) -> int64_t override

auto	GetSocket () const -> void *

void	SetLinger (const int value) override

int	GetLinger () const override

void	SetSndBufSize (const int value) override

int	GetSndBufSize () const override

void	SetRcvBufSize (const int value) override

int	GetRcvBufSize () const override

void	SetSndKernelSize (const int value) override

int	GetSndKernelSize () const override

void	SetRcvKernelSize (const int value) override

int	GetRcvKernelSize () const override

auto	Close () -> void override

auto	SetOption (const std::string &option, const void *value, size_t valueSize) -> void override

auto	GetOption (const std::string &option, void value, size_t valueSize) -> void override

auto	GetBytesTx () const -> unsigned long override

auto	GetBytesRx () const -> unsigned long override

auto	GetMessagesTx () const -> unsigned long override

auto	GetMessagesRx () const -> unsigned long override

Public Member Functions inherited from FairMQSocket
	FairMQSocket (FairMQTransportFactory *fac)

virtual int64_t	Send (std::vector< std::unique_ptr< FairMQMessage >> &msgVec, int timeout=-1)=0

virtual int64_t	Receive (std::vector< std::unique_ptr< FairMQMessage >> &msgVec, int timeout=-1)=0

FairMQTransportFactory *	GetTransport ()

void	SetTransport (FairMQTransportFactory *transport)

Static Public Member Functions
static auto	GetConstant (const std::string &constant) -> int

Detailed Description

Todo:: TODO insert long description

Member Function Documentation

◆ Events()

auto fair::mq::ofi::Socket::Events ( uint32_t * events ) -> void

inlineoverridevirtual

If the backend supports it, fills the unsigned integer events with the ZMQ_EVENTS value DISCLAIMER: this API is experimental and unsupported and might be dropped / refactored in the future.

Implements FairMQSocket.

The documentation for this class was generated from the following files:

fairmq/ofi/Socket.h
fairmq/ofi/Socket.cxx

Public Member Functions

Static Public Member Functions

Detailed Description

Member Function Documentation

◆ Events()