|
|
|
@ -33,6 +33,8 @@ local ctx = zmq.init(1)
|
|
|
|
local s = ctx:socket(zmq.PUB)
|
|
|
|
local s = ctx:socket(zmq.PUB)
|
|
|
|
s:connect(connect_to)
|
|
|
|
s:connect(connect_to)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
zmq.sleep(1)
|
|
|
|
|
|
|
|
|
|
|
|
local data = ("0"):rep(message_size)
|
|
|
|
local data = ("0"):rep(message_size)
|
|
|
|
local msg_data = zmq.zmq_msg_t.init_data(data)
|
|
|
|
local msg_data = zmq.zmq_msg_t.init_data(data)
|
|
|
|
local msg = zmq.zmq_msg_t.init()
|
|
|
|
local msg = zmq.zmq_msg_t.init()
|
|
|
|
@ -42,7 +44,6 @@ for i = 1, message_count do
|
|
|
|
assert(s:send_msg(msg))
|
|
|
|
assert(s:send_msg(msg))
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
--os.execute("sleep " .. 10)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
s:close()
|
|
|
|
s:close()
|
|
|
|
ctx:term()
|
|
|
|
ctx:term()
|
|
|
|
|
|
|
|
|
|
|
|
|