examples/v3api/local_lat_poll.rb in ffi-rzmq-0.9.3 vs examples/v3api/local_lat_poll.rb in ffi-rzmq-0.9.6
- old
+ new
@@ -36,22 +36,22 @@
start_time = Time.now
# kick it off
message = ZMQ::Message.new("a" * message_size)
-assert(s1.sendmsg(message, ZMQ::DONTWAIT))
+assert(s1.sendmsg(message, ZMQ::NonBlocking))
i = roundtrip_count
until i.zero?
i -= 1
assert(poller.poll_nonblock)
poller.readables.each do |socket|
received_message = ''
- assert(socket.recv_string(received_message, ZMQ::DONTWAIT))
- assert(socket.sendmsg(ZMQ::Message.new(received_message), ZMQ::DONTWAIT))
+ assert(socket.recv_string(received_message, ZMQ::NonBlocking))
+ assert(socket.sendmsg(ZMQ::Message.new(received_message), ZMQ::NonBlocking))
end
end
elapsed_usecs = (Time.now.to_f - start_time.to_f) * 1_000_000
latency = elapsed_usecs / roundtrip_count / 2