summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/options.cpp21
-rw-r--r--src/options.hpp5
-rw-r--r--src/pgm_socket.cpp4
3 files changed, 15 insertions, 15 deletions
diff --git a/src/options.cpp b/src/options.cpp
index 4c1289a..13332da 100644
--- a/src/options.cpp
+++ b/src/options.cpp
@@ -79,19 +79,19 @@ int zmq::options_t::setsockopt (int option_, const void *optval_,
return 0;
case ZMQ_RATE:
- if (optvallen_ != sizeof (int64_t) || *((int64_t*) optval_) <= 0) {
+ if (optvallen_ != sizeof (int) || *((int*) optval_) <= 0) {
errno = EINVAL;
return -1;
}
- rate = (uint32_t) *((int64_t*) optval_);
+ rate = *((int*) optval_);
return 0;
case ZMQ_RECOVERY_IVL:
- if (optvallen_ != sizeof (int64_t) || *((int64_t*) optval_) < 0) {
+ if (optvallen_ != sizeof (int) || *((int*) optval_) < 0) {
errno = EINVAL;
return -1;
}
- recovery_ivl = (uint32_t) *((int64_t*) optval_);
+ recovery_ivl = *((int*) optval_);
return 0;
case ZMQ_SNDBUF:
@@ -195,23 +195,22 @@ int zmq::options_t::getsockopt (int option_, void *optval_, size_t *optvallen_)
*optvallen_ = identity.size ();
return 0;
-
case ZMQ_RATE:
- if (*optvallen_ < sizeof (int64_t)) {
+ if (*optvallen_ < sizeof (int)) {
errno = EINVAL;
return -1;
}
- *((int64_t*) optval_) = rate;
- *optvallen_ = sizeof (int64_t);
+ *((int*) optval_) = rate;
+ *optvallen_ = sizeof (int);
return 0;
case ZMQ_RECOVERY_IVL:
- if (*optvallen_ < sizeof (int64_t)) {
+ if (*optvallen_ < sizeof (int)) {
errno = EINVAL;
return -1;
}
- *((int64_t*) optval_) = recovery_ivl;
- *optvallen_ = sizeof (int64_t);
+ *((int*) optval_) = recovery_ivl;
+ *optvallen_ = sizeof (int);
return 0;
case ZMQ_SNDBUF:
diff --git a/src/options.hpp b/src/options.hpp
index 1699c1a..d039554 100644
--- a/src/options.hpp
+++ b/src/options.hpp
@@ -40,10 +40,10 @@ namespace zmq
blob_t identity;
// Maximum tranfer rate [kb/s]. Default 100kb/s.
- uint32_t rate;
+ int rate;
// Reliability time interval [ms]. Default 10 seconds.
- uint32_t recovery_ivl;
+ int recovery_ivl;
// SO_SNDBUF and SO_RCVBUF to be passed to underlying transport sockets.
int sndbuf;
@@ -58,6 +58,7 @@ namespace zmq
// Minimum interval between attempts to reconnect, in milliseconds.
// Default 100ms
int reconnect_ivl;
+
// Maximum interval between attempts to reconnect, in milliseconds.
// Default 0 (unused)
int reconnect_ivl_max;
diff --git a/src/pgm_socket.cpp b/src/pgm_socket.cpp
index 10d8f39..d84ecb0 100644
--- a/src/pgm_socket.cpp
+++ b/src/pgm_socket.cpp
@@ -668,10 +668,10 @@ void zmq::pgm_socket_t::process_upstream ()
int zmq::pgm_socket_t::compute_sqns (int tpdu_)
{
// Convert rate into B/ms.
- uint64_t rate = ((uint64_t) options.rate) / 8;
+ uint64_t rate = uint64_t (options.rate) / 8;
// Compute the size of the buffer in bytes.
- uint64_t size = options.recovery_ivl * rate;
+ uint64_t size = uint64_t (options.recovery_ivl) * rate;
// Translate the size into number of packets.
uint64_t sqns = size / tpdu_;