Fix recv() method when used with ZeroMQ 3.1.x

pull/47/merge
Robert G. Jakabosky 15 years ago
parent 7664da27ed
commit a264b26c48

File diff suppressed because it is too large Load Diff

@ -693,7 +693,7 @@ local tmp_msg = ffi.new('zmq_msg_t')
if(0 == ${err}) {
/* receive message */
${err} = zmq_recvmsg(${this}, &msg, ${flags});
if(0 == ${err}) {
if(${err} >= 0) {
${data} = zmq_msg_data(&msg);
${data_len} = zmq_msg_size(&msg);
}
@ -712,7 +712,7 @@ local tmp_msg = ffi.new('zmq_msg_t')
-- receive message
${err} = zmq_recvmsg(${this}, msg, ${flags})
if 0 == ${err} then
if ${err} >= 0 then
local data = ffi.string(C.zmq_msg_data(msg), C.zmq_msg_size(msg))
-- close message
C.zmq_msg_close(msg)

Loading…
Cancel
Save