aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/cpp/end2end
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2018-11-14 11:47:15 -0800
committerGravatar Vijay Pai <vpai@google.com>2018-11-30 04:13:40 -0800
commitdac2066a1c0df628fefe4144ae0f97337af6324e (patch)
tree085c3f8e28a7bb9bfccf7fbf97320f5ef6091f8d /test/cpp/end2end
parent60949a823267d2bfa783f9488dddff515a7928c1 (diff)
Make StartCall() a releasing operation so that you can pile up ops
Diffstat (limited to 'test/cpp/end2end')
-rw-r--r--test/cpp/end2end/client_callback_end2end_test.cc4
-rw-r--r--test/cpp/end2end/test_service_impl.cc1
2 files changed, 3 insertions, 2 deletions
diff --git a/test/cpp/end2end/client_callback_end2end_test.cc b/test/cpp/end2end/client_callback_end2end_test.cc
index 31216f72cc..57c3cb87f2 100644
--- a/test/cpp/end2end/client_callback_end2end_test.cc
+++ b/test/cpp/end2end/client_callback_end2end_test.cc
@@ -194,11 +194,11 @@ class ClientCallbackEnd2endTest
stream_ =
test->generic_stub_->experimental().PrepareBidiStreamingCall(
&cli_ctx_, method_name, this);
- stream_->StartCall();
request_.set_message(test_str);
send_buf_ = SerializeToByteBuffer(&request_);
- stream_->Read(&recv_buf_);
stream_->Write(send_buf_.get());
+ stream_->Read(&recv_buf_);
+ stream_->StartCall();
}
void OnWriteDone(bool ok) override { stream_->WritesDone(); }
void OnReadDone(bool ok) override {
diff --git a/test/cpp/end2end/test_service_impl.cc b/test/cpp/end2end/test_service_impl.cc
index 605356724f..1726e87ea6 100644
--- a/test/cpp/end2end/test_service_impl.cc
+++ b/test/cpp/end2end/test_service_impl.cc
@@ -223,6 +223,7 @@ void CallbackTestServiceImpl::EchoNonDelayed(
return;
}
+ gpr_log(GPR_DEBUG, "Request message was %s", request->message().c_str());
response->set_message(request->message());
MaybeEchoDeadline(context, request, response);
if (host_) {