THRIFT-2708 add support for oneway (async) function calls in erlang client Client: Erlang Patch: Nobuaki Sukegawa
Add timeout to oneway call in cross test client. Project: http://git-wip-us.apache.org/repos/asf/thrift/repo Commit: http://git-wip-us.apache.org/repos/asf/thrift/commit/7ab56e83 Tree: http://git-wip-us.apache.org/repos/asf/thrift/tree/7ab56e83 Diff: http://git-wip-us.apache.org/repos/asf/thrift/diff/7ab56e83 Branch: refs/heads/master Commit: 7ab56e835c8e44198c4f6875a8b2d761ae31ee40 Parents: 7bdba5c Author: Nobuaki Sukegawa <[email protected]> Authored: Sat Oct 31 12:17:46 2015 +0900 Committer: Nobuaki Sukegawa <[email protected]> Committed: Sun Nov 1 18:30:20 2015 +0900 ---------------------------------------------------------------------- test/erl/src/test_client.erl | 9 +++++++++ 1 file changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/thrift/blob/7ab56e83/test/erl/src/test_client.erl ---------------------------------------------------------------------- diff --git a/test/erl/src/test_client.erl b/test/erl/src/test_client.erl index 7dd5cbc..8cfeb8b 100644 --- a/test/erl/src/test_client.erl +++ b/test/erl/src/test_client.erl @@ -136,6 +136,15 @@ start(Args) -> ClientS4 end, + %% Use deprecated erlang:now until we start requiring OTP18 + %% Started = erlang:monotonic_time(milli_seconds), + {_, StartSec, StartUSec} = erlang:now(), {Client20, {ok, ok}} = thrift_client:call(Client19, testOneway, [1]), + {_, EndSec, EndUSec} = erlang:now(), + Elapsed = (EndSec - StartSec) * 1000 + (EndUSec - StartUSec) / 1000, + if + Elapsed > 1000 -> exit(1); + true -> true + end, thrift_client:close(Client20).
