diff --git a/perf/remote_thr.lua b/perf/remote_thr.lua index 982f36a..967e08b 100644 --- a/perf/remote_thr.lua +++ b/perf/remote_thr.lua @@ -34,10 +34,11 @@ local s = ctx:socket(zmq.PUB) s:connect(connect_to) local data = ("0"):rep(message_size) -local msg = zmq.zmq_msg_t.init_size(message_size) +local msg_data = zmq.zmq_msg_t.init_data(data) +local msg = zmq.zmq_msg_t.init() for i = 1, message_count do - msg:set_data(data) + msg:copy(msg_data) assert(s:send_msg(msg)) end diff --git a/perf/thread_thr.lua b/perf/thread_thr.lua index b5ce029..7b9183a 100644 --- a/perf/thread_thr.lua +++ b/perf/thread_thr.lua @@ -41,12 +41,13 @@ local child_code = [[ s:connect(connect_to) local data = ("0"):rep(message_size) - local msg = zmq.zmq_msg_t.init_size(message_size) + local msg_data = zmq.zmq_msg_t.init_data(data) + local msg = zmq.zmq_msg_t.init() local timer = zmq.stopwatch_start() for i = 1, message_count do - msg:set_data(data) + msg:copy(msg_data) assert(s:send_msg(msg)) end