generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-14 02:57:47 +01:00
Code Issues Projects Releases Wiki Activity

Renamed raw option to ZMQ_ROUTER_RAW

Browse Source
This commit is contained in:
Pieter Hintjens 2012-11-06 13:18:58 +01:00
parent 80aef8dfda
commit 777c38ae32
4 changed files with 21 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
doc/zmq_setsockopt.txt
View File

@ -381,6 +381,23 @@ Default value:: 0
Applicable socket types:: ZMQ_ROUTER Applicable socket types:: ZMQ_ROUTER
ZMQ_ROUTER_RAW: switch ROUTER socket to raw mode
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Sets the raw mode on the 'ROUTER', when set to 1. When the ROUTER socket is in
raw mode, and when using the tcp:// transport, it will read and write TCP data
without 0MQ framing. This lets 0MQ applications talk to non-0MQ applications.
When using raw mode, you cannot set explicit identities, and the ZMQ_MSGMORE
flag is ignored when sending data messages. In raw mode you can close a specific
connection by sending it a zero-length message (following the identity frame).
[horizontal]
Option value type:: int
Option value unit:: 0, 1
Default value:: 0
Applicable socket types:: ZMQ_ROUTER
ZMQ_XPUB_VERBOSE: provide all subscription messages on XPUB sockets ZMQ_XPUB_VERBOSE: provide all subscription messages on XPUB sockets
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~

2
include/zmq.h
View File

@ -250,7 +250,7 @@ ZMQ_EXPORT int zmq_msg_set (zmq_msg_t *msg, int option, int optval);
#define ZMQ_TCP_ACCEPT_FILTER 38 #define ZMQ_TCP_ACCEPT_FILTER 38
#define ZMQ_DELAY_ATTACH_ON_CONNECT 39 #define ZMQ_DELAY_ATTACH_ON_CONNECT 39
#define ZMQ_XPUB_VERBOSE 40 #define ZMQ_XPUB_VERBOSE 40
#define ZMQ_ROUTER_RAW_SOCK 41 #define ZMQ_ROUTER_RAW 41
/* Message options */ /* Message options */

4
src/router.cpp
View File

@ -79,7 +79,7 @@ int zmq::router_t::xsetsockopt (int option_, const void *optval_,
size_t optvallen_) size_t optvallen_)
{ {
if (option_ != ZMQ_ROUTER_MANDATORY if (option_ != ZMQ_ROUTER_MANDATORY
&& option_ != ZMQ_ROUTER_RAW_SOCK) { && option_ != ZMQ_ROUTER_RAW) {
errno = EINVAL; errno = EINVAL;
return -1; return -1;
} }
@ -87,7 +87,7 @@ int zmq::router_t::xsetsockopt (int option_, const void *optval_,
errno = EINVAL; errno = EINVAL;
return -1; return -1;
} }
if (option_ == ZMQ_ROUTER_RAW_SOCK) { if (option_ == ZMQ_ROUTER_RAW) {
raw_sock = *static_cast <const int*> (optval_); raw_sock = *static_cast <const int*> (optval_);
if (raw_sock) { if (raw_sock) {
options.recv_identity = false; options.recv_identity = false;

2
tests/test_raw_sock.cpp
View File

@ -110,7 +110,7 @@ int main ()
assert (sb); assert (sb);
int raw_sock = 1; int raw_sock = 1;
int rc = zmq_setsockopt (sb, ZMQ_ROUTER_RAW_SOCK, &raw_sock, sizeof raw_sock); int rc = zmq_setsockopt (sb, ZMQ_ROUTER_RAW, &raw_sock, sizeof raw_sock);
assert (rc == 0); assert (rc == 0);
rc = zmq_bind (sb, "tcp://127.0.0.1:5555"); rc = zmq_bind (sb, "tcp://127.0.0.1:5555");
assert (rc == 0); assert (rc == 0);