PZmqBackend.cpp File Reference

#include "PZmqBackend.h"

Include dependency graph for PZmqBackend.cpp:

Go to the source code of this file.

Functions
zmq::recv_flags	convertToRecvFlag (PRecvFlag::PRecvFlag flag)
	Convert a recv flag into zmq flag. More...
zmq::send_flags	convertToSendFlag (PSendFlag::PSendFlag flag)
	Convert a send flag into zmq flag. More...
PZmqParam	pzmq_createParamClient (const std::string &address, size_t port, zmq::context_t *context, int type, int nbBufferMessage, int bufferSizeByte, size_t threadAffinity, ssize_t dataRate)
	Create param for a client socket. More...
PZmqParam	pzmq_createParamServer (const std::string &address, size_t port, zmq::context_t *context, int type, int nbBufferMessage, int bufferSizeByte, size_t threadAffinity, ssize_t dataRate)
	Create param for a client socket. More...

Function Documentation

convertToRecvFlag()

zmq::recv_flags convertToRecvFlag

(

PRecvFlag::PRecvFlag

flag

)

Convert a recv flag into zmq flag.

Parameters

flag	: generic PRecvFlag

Returns

corresponding zmq::recv_flags

Definition at line 172 of file PZmqBackend.cpp.

                                                        {
        if(flag == PRecvFlag::NON_BLOCK){return zmq::recv_flags::dontwait;}
        else{return zmq::recv_flags::none;}
}

References PRecvFlag::NON_BLOCK.

Referenced by PZmqBackend::recv().

Here is the caller graph for this function:

convertToSendFlag()

zmq::send_flags convertToSendFlag

(

PSendFlag::PSendFlag

flag

)

Convert a send flag into zmq flag.

Parameters

flag	: generic PSendFlag

Returns

corresponding zmq::send_flags

Definition at line 148 of file PZmqBackend.cpp.

                                                        {
        if(flag == PSendFlag::NON_BLOCK){return zmq::send_flags::dontwait;}
        else{return zmq::send_flags::none;}
}

References PSendFlag::NON_BLOCK.

Referenced by PZmqBackend::send().

Here is the caller graph for this function:

pzmq_createParamClient()

PZmqParam pzmq_createParamClient	(	const std::string &	address,
		size_t	port,
		zmq::context_t *	context,
		int	type,
		int	nbBufferMessage,
		int	bufferSizeByte,
		size_t	threadAffinity,
		ssize_t	dataRate
	)

Create param for a client socket.

Parameters

address	: address of the server to be connected to
port	: port to be used
context	: zmq context where to create socket
type	: type of the connection (ZMQ_PULL, ZMQ_PUSH, etc)
nbBufferMessage	: number of messages to be buffered
bufferSizeByte	: size of the zmq buffer in bytes
threadAffinity	: bit mask which determines which threads from the 0MQ I/O thread pool associated with the socket's context shall handle newly created connections (1 : means first, 2 : means second, 3 : means first and second, etc)
dataRate	: expected data rate (in kilobytes per second)

Returns

corresponding PZmqParam

Definition at line 20 of file PZmqBackend.cpp.

{
        PZmqParam param;
        param.address = address;
        param.port = port;
        param.context = context;
        param.type = type;
        param.nbBufferMessage = nbBufferMessage;
        param.bufferSizeByte = bufferSizeByte;
        param.threadAffinity = threadAffinity;
        param.dataRate = dataRate;
        return param;
}

References PZmqParam::address, PZmqParam::bufferSizeByte, PZmqParam::context, PZmqParam::dataRate, PZmqParam::nbBufferMessage, PZmqParam::port, PZmqParam::threadAffinity, and PZmqParam::type.

Referenced by PZmqBackend::client().

Here is the caller graph for this function:

pzmq_createParamServer()

PZmqParam pzmq_createParamServer	(	const std::string &	address,
		size_t	port,
		zmq::context_t *	context,
		int	type,
		int	nbBufferMessage,
		int	bufferSizeByte,
		size_t	threadAffinity,
		ssize_t	dataRate
	)

Create param for a client socket.

Parameters

address	: address of the server to be connected to
port	: port to be used
context	: zmq context where to create socket
type	: type of the connection (ZMQ_PULL, ZMQ_PUSH, etc)
nbBufferMessage	: number of messages to be buffered
bufferSizeByte	: size of the zmq buffer in bytes
threadAffinity	: bit mask which determines which threads from the 0MQ I/O thread pool associated with the socket's context shall handle newly created connections (1 : means first, 2 : means second, 3 : means first and second, etc)
dataRate	: expected data rate (in kilobytes per second)

Returns

corresponding PZmqParam

Definition at line 46 of file PZmqBackend.cpp.

{
        PZmqParam param;
        param.address = address;
        param.port = port;
        param.context = context;
        param.type = type;
        param.nbBufferMessage = nbBufferMessage;
        param.bufferSizeByte = bufferSizeByte;
        param.threadAffinity = threadAffinity;
        param.dataRate = dataRate;
        return param;
}

References PZmqParam::address, PZmqParam::bufferSizeByte, PZmqParam::context, PZmqParam::dataRate, PZmqParam::nbBufferMessage, PZmqParam::port, PZmqParam::threadAffinity, and PZmqParam::type.

Referenced by PZmqBackend::server().

Here is the caller graph for this function: