3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-09 15:26:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed some typos

Browse Source
This commit is contained in:
Kobolog 2012-03-15 15:15:44 +03:00
parent 8095a129e8
commit cb70c5e75d
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/zmq.h
View File

@ -230,7 +230,7 @@ ZMQ_EXPORT int zmq_term (zmq_ctx_t context);
#define ZMQ_SNDTIMEO 28
#define ZMQ_IPV4ONLY 31
#define ZMQ_LAST_ENDPOINT 32
#define ZMQ_FAIL_UNROUTEABLE 33
#define ZMQ_FAIL_UNROUTABLE 33
/* Message options */
#define ZMQ_MORE 1

8
src/xrep.cpp
View File

@ -34,7 +34,7 @@ zmq::xrep_t::xrep_t (class ctx_t *parent_, uint32_t tid_) :
current_out (NULL),
more_out (false),
next_peer_id (generate_random ()),
fail_unrouteable(false)
fail_unroutable(false)
{
options.type = ZMQ_XREP;
@ -86,12 +86,12 @@ int zmq::xrep_t::xsetsockopt (int option_, const void *optval_,
return -1;
}
if(sizeof(optvallen_) != sizeof(uint64_t)) {
if(sizeof(optvallen_) != sizeof(int)) {
errno = EINVAL;
return -1;
}
fail_unroutable = *((const uint64_t*) optval_);
fail_unroutable = *((const int*) optval_);
return 0;
}
@ -164,7 +164,7 @@ int zmq::xrep_t::xsend (msg_t *msg_, int flags_)
}
rc = empty.close ();
errno_assert (rc == 0);
} else if(fail_unreachable) {
} else if(fail_unroutable) {
more_out = false;
retval = EHOSTUNREACH;
}

2
src/xrep.hpp
View File

@ -102,7 +102,7 @@ namespace zmq
uint32_t next_peer_id;
// If true, fail on unroutable messages instead of silently dropping them.
bool fail_unrouteable;
bool fail_unroutable;
xrep_t (const xrep_t&);
const xrep_t &operator = (const xrep_t&);