From 5ef174b5c1ab1ddd32f430ccacbad6d94e8dc452 Mon Sep 17 00:00:00 2001 From: zeshuai007 <51382517@qq.com> Date: Sat, 7 Nov 2020 15:45:11 +0800 Subject: Implement Validate message reply seq ids --- compiler/cpp/src/thrift/generate/t_rb_generator.cc | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'compiler') diff --git a/compiler/cpp/src/thrift/generate/t_rb_generator.cc b/compiler/cpp/src/thrift/generate/t_rb_generator.cc index 90dbfe5d7..17e57cf95 100644 --- a/compiler/cpp/src/thrift/generate/t_rb_generator.cc +++ b/compiler/cpp/src/thrift/generate/t_rb_generator.cc @@ -944,7 +944,12 @@ void t_rb_generator::generate_service_client(t_service* tservice) { f_service_.indent() << "def " << function_signature(&recv_function) << endl; f_service_.indent_up(); - // TODO(mcslee): Validate message reply here, seq ids etc. + f_service_.indent() << "fname, mtype, rseqid = receive_message_begin()" << endl; + f_service_.indent() << "handle_exception(mtype)" << endl; + + f_service_.indent() << "if reply_seqid(rseqid)==false" << endl; + f_service_.indent() << " raise \"seqid reply faild\"" << endl; + f_service_.indent() << "end" << endl; f_service_.indent() << "result = receive_message(" << resultname << ")" << endl; -- cgit v1.2.1