Add asserts to catch errors from zeromq (like bind errors).

perf/local_lat.lua

@@ -30,8 +30,8 @@ local roundtrip_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.REP)
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.REP))
+assert(s:bind(bind_to))
 
 local msg = zmq.zmq_msg_t()
 

perf/local_multipart.lua

@@ -30,9 +30,9 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PULL)
+local s = assert(ctx:socket(zmq.PULL))
 --s:setopt(zmq.SUBSCRIBE, "");
-s:bind(bind_to)
+assert(s:bind(bind_to))
 
 local function recv_msg(s,msg)
 	assert(s:recv_msg(msg))

perf/local_pull.lua

@@ -30,8 +30,8 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PULL)
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.PULL))
+assert(s:bind(bind_to))
 
 print(string.format("message size: %i [B]", message_size))
 print(string.format("message count: %i", message_count))

perf/local_thr.lua

@@ -30,9 +30,9 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.SUB)
-s:setopt(zmq.SUBSCRIBE, "");
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.SUB))
+assert(s:setopt(zmq.SUBSCRIBE, ""))
+assert(s:bind(bind_to))
 
 print(string.format("message size: %i [B]", message_size))
 print(string.format("message count: %i", message_count))

perf/local_thr_poll.lua

@@ -34,9 +34,9 @@ local z_NOBLOCK = zmq.NOBLOCK
 local poller = z_poller(64)
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.SUB)
-s:setopt(zmq.SUBSCRIBE, "");
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.SUB))
+assert(s:setopt(zmq.SUBSCRIBE, ""))
+assert(s:bind(bind_to))
 
 print(string.format("message size: %i [B]", message_size))
 print(string.format("message count: %i", message_count))

perf/local_thr_push_pull.lua

@@ -30,8 +30,8 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PULL)
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.PULL))
+assert(s:bind(bind_to))
 
 print(string.format("message size: %i [B]", message_size))
 print(string.format("message count: %i", message_count))

perf/remote_lat.lua

@@ -30,8 +30,8 @@ local roundtrip_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.REQ)
-s:connect(connect_to)
+local s = assert(ctx:socket(zmq.REQ))
+assert(s:connect(connect_to))
 
 local data = ("0"):rep(message_size)
 local msg = zmq.zmq_msg_t.init_size(message_size)

perf/remote_multipart.lua

@@ -31,8 +31,8 @@ local zmq = require"zmq"
 local z_SNDMORE = zmq.SNDMORE
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PUSH)
-s:connect(connect_to)
+local s = assert(ctx:socket(zmq.PUSH))
+assert(s:connect(connect_to))
 
 local data = ("0"):rep(message_size/2)
 local msg = zmq.zmq_msg_t.init_size(message_size/2)

perf/remote_push.lua

@@ -30,8 +30,8 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PUSH)
-s:connect(connect_to)
+local s = assert(ctx:socket(zmq.PUSH))
+assert(s:connect(connect_to))
 
 local data = ("0"):rep(message_size)
 local msg = zmq.zmq_msg_t.init_size(message_size)

perf/remote_thr.lua

@@ -30,10 +30,10 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PUB)
+local s = assert(ctx:socket(zmq.PUB))
 -- for ZeroMQ 3.x need to change HWM option.
-s:set_hwm(0)
-s:connect(connect_to)
+assert(s:set_hwm(0))
+assert(s:connect(connect_to))
 
 zmq.sleep(1)
 

perf/remote_thr_push_pull.lua

@@ -30,8 +30,8 @@ local message_count = tonumber(arg[3])
 local zmq = require"zmq"
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PUSH)
-s:connect(connect_to)
+local s = assert(ctx:socket(zmq.PUSH))
+assert(s:connect(connect_to))
 
 zmq.sleep(1)
 

perf/thread_lat.lua

@@ -52,8 +52,8 @@ local child_code = [[
 ]]
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.REQ)
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.REQ))
+assert(s:bind(bind_to))
 
 local child_thread = zthreads.runstring(ctx, child_code, connect_to, message_size, roundtrip_count)
 child_thread:start()

perf/thread_push_pull.lua

@@ -37,9 +37,9 @@ local child_code = [[
 	local zthreads = require"zmq.threads"
 
 	local ctx = zthreads.get_parent_ctx()
-	local s = ctx:socket(zmq.PUSH)
-	s:setopt(zmq.HWM, message_count/4)
-	s:connect(connect_to)
+	local s = assert(ctx:socket(zmq.PUSH))
+	assert(s:setopt(zmq.HWM, message_count/4))
+	assert(s:connect(connect_to))
 
 	local data = ("0"):rep(message_size)
 	local msg_data = zmq.zmq_msg_t.init_data(data)
@@ -68,8 +68,8 @@ local child_code = [[
 ]]
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.PULL)
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.PULL))
+assert(s:bind(bind_to))
 
 print(string.format("message size: %i [B]", message_size))
 print(string.format("message count: %i", message_count))

perf/thread_thr.lua

@@ -37,10 +37,10 @@ local child_code = [[
 	local zthreads = require"zmq.threads"
 
 	local ctx = zthreads.get_parent_ctx()
-	local s = ctx:socket(zmq.PUB)
+	local s = assert(ctx:socket(zmq.PUB))
 	-- for ZeroMQ 3.x need to change HWM option.
-	s:set_hwm(0)
-	s:connect(connect_to)
+	assert(s:set_hwm(0))
+	assert(s:connect(connect_to))
 
 	local data = ("0"):rep(message_size)
 	local msg_data = zmq.zmq_msg_t.init_data(data)
@@ -69,9 +69,9 @@ local child_code = [[
 ]]
 
 local ctx = zmq.init(1)
-local s = ctx:socket(zmq.SUB)
-s:setopt(zmq.SUBSCRIBE, "");
-s:bind(bind_to)
+local s = assert(ctx:socket(zmq.SUB))
+assert(s:setopt(zmq.SUBSCRIBE, ""))
+assert(s:bind(bind_to))
 
 print(string.format("message size: %i [B]", message_size))
 print(string.format("message count: %i", message_count))