summaryrefslogtreecommitdiff
path: root/src/socket_base.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-09-14 11:25:57 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-09-14 11:25:57 +0200
commitc806aabb2d3e6b1ba9e3f61319f23d45c7f9a007 (patch)
treefb44aa2fba39f972b5d04eba7cda7dc310d4b188 /src/socket_base.cpp
parent36707529a7d82b164b59d42fe0d5d8a35c3dd279 (diff)
java binding sets socket options using setsockopt function
Diffstat (limited to 'src/socket_base.cpp')
-rw-r--r--src/socket_base.cpp16
1 files changed, 4 insertions, 12 deletions
diff --git a/src/socket_base.cpp b/src/socket_base.cpp
index 9412d67..0429726 100644
--- a/src/socket_base.cpp
+++ b/src/socket_base.cpp
@@ -125,14 +125,6 @@ int zmq::socket_base_t::setsockopt (int option_, const void *optval_,
options.swap = *((int64_t*) optval_);
return 0;
- case ZMQ_MASK:
- if (optvallen_ != sizeof (int64_t)) {
- errno = EINVAL;
- return -1;
- }
- options.mask = (uint64_t) *((int64_t*) optval_);
- return 0;
-
case ZMQ_AFFINITY:
if (optvallen_ != sizeof (int64_t)) {
errno = EINVAL;
@@ -151,19 +143,19 @@ int zmq::socket_base_t::setsockopt (int option_, const void *optval_,
return -1;
case ZMQ_RATE:
- if (optvallen_ != sizeof (uint32_t)) {
+ if (optvallen_ != sizeof (int64_t)) {
errno = EINVAL;
return -1;
}
- options.rate = *((int32_t*) optval_);
+ options.rate = (uint32_t) *((int64_t*) optval_);
return 0;
case ZMQ_RECOVERY_IVL:
- if (optvallen_ != sizeof (uint32_t)) {
+ if (optvallen_ != sizeof (int64_t)) {
errno = EINVAL;
return -1;
}
- options.recovery_ivl = *((int32_t*) optval_);
+ options.recovery_ivl = (uint32_t) *((int64_t*) optval_);
return 0;
default: