7 #ifndef __PHOENIX_ZMQ_H__
8 #define __PHOENIX_ZMQ_H__
14 zmq::socket_t*
pzmq_createClientSocket(zmq::context_t & context,
int type,
const std::string & address,
size_t port);
15 zmq::socket_t*
pzmq_createClientSocket(zmq::context_t & context,
const std::string & address,
size_t port,
int type,
int nbBufferMessage,
16 int bufferSizeByte,
size_t threadAffinity, ssize_t dataRate);
19 zmq::socket_t*
pzmq_createServerSocket(zmq::context_t & context,
size_t port,
int type,
int nbBufferMessage,
int bufferSizeByte,
20 size_t threadAffinity, ssize_t dataRate);
31 void pzmq_setBufferSize(zmq::socket_t* socket,
int type,
int nbBufferMessage,
int dataRate,
size_t bufferSizeByte);
void pzmq_setSendBufferSize(zmq::socket_t *socket, int bufferSizeByte)
Set the size of the buffer to send messages.
zmq::socket_t * pzmq_createServerSocket(zmq::context_t &context, int type, size_t port)
Create a server socket to be used by the SocketManagerZMQ.
zmq::socket_t * pzmq_createClientSocket(zmq::context_t &context, int type, const std::string &address, size_t port)
Create a client socket to be used by the SocketManagerZMQ.
void pzmq_closeServerSocket(zmq::socket_t *&socket)
Close the given server socket.
void pzmq_setThreadAffinity(zmq::socket_t *socket, size_t threadAffinity)
Set the thread affinity of zmq.
void pzmq_setRecvBufferSize(zmq::socket_t *socket, int bufferSizeByte)
Set the size of the buffer to recieved messages.
void pzmq_setBufferSize(zmq::socket_t *socket, int type, int nbBufferMessage, int dataRate, size_t bufferSizeByte)
Set the size of the buffer to send messages.
void pzmq_setDataRate(zmq::socket_t *socket, int type, int dataRate)
Set the data rate of the socket.
void pzmq_setNbMessageBuffer(zmq::socket_t *socket, int nbBufferMessage)
Set the number of messages in the messages buffer.
1.9.1