From e1513e044f5d69f160939c4700882de8398109ae Mon Sep 17 00:00:00 2001 From: "Mark A. Grondona" Date: Wed, 16 May 2018 10:33:14 -0700 Subject: [PATCH] testsuite: lua/t0001-send-recv.t: test msg:respond() Extend the t0001-send-recv.t Lua test to test msg:respond() by opening a flux handle using the "loop" connector, and sending a request/response across the connector using msg:respond(). --- t/lua/t0001-send-recv.t | 25 ++++++++++++++++++++++++- 1 file changed, 24 insertions(+), 1 deletion(-) diff --git a/t/lua/t0001-send-recv.t b/t/lua/t0001-send-recv.t index e8bd7f776559..03c92f1973bf 100755 --- a/t/lua/t0001-send-recv.t +++ b/t/lua/t0001-send-recv.t @@ -5,7 +5,7 @@ local t = require 'fluxometer'.init (...) t:start_session { size = 2} -plan (22) +plan (34) local flux = require_ok ('flux') local f, err = flux.new() @@ -58,6 +58,29 @@ is (msg.data.seq, "1", "recv: got expected ping sequence") is (msg.data.pad, "xxxxxx", "recv: got expected ping pad") is (msg.tag, "cmb.ping", "recv: got expected tag on ping response") + +f, err = flux.new ("loop://") +type_ok (f, 'userdata', "create loop connector") +is (err, nil, "error is nil") + +local rc, err = f:send ("test", {foo = "bar"}, 0) +isnt (rc, 0, "loop: send over loop connector works") +is (err, nil, "loop: err is nil") + +local msg, err = f:recvmsg () +ok (msg, "loop: recvmsg: msg is non-nil") +ok (msg.type, "request", "loop: recvmsg: msg.type is correct") +is (msg.tag, "test", "loop: got expected message tag") +is (msg.data.foo, "bar", "loop: recvd message with expected payload") + +msg:respond { bar = "baz" } + +local msg, err = f:recvmsg () +ok (msg, "loop: got response") +ok (msg.type, "response", "loop: recvmsg response") +ok (msg.tag, "test", "response: msg.tag is correct") +ok (msg.data.bar, "baz", "response: msg.data payload is correct") + done_testing () -- vi: ts=4 sw=4 expandtab