From 3312d2312556206a6bafe1cdea5017e6d5405735 Mon Sep 17 00:00:00 2001 From: "Robert G. Jakabosky" Date: Wed, 20 Jul 2011 17:27:39 -0700 Subject: [PATCH] Use msg:copy() instead of msg:set_data(). --- perf/remote_thr.lua | 5 +++-- perf/thread_thr.lua | 5 +++-- 2 files changed, 6 insertions(+), 4 deletions(-) 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