diff options
| author |  Vijay Pai <vpai@google.com> | 2018-02-07 11:12:35 -0800 |
|---|---|---|
| committer | Vijay Pai <vpai@google.com> | 2018-02-07 11:12:35 -0800 |
| commit | b1ef84a7fdef7fc06680515748b007b6142ae9d1 (patch) | |
| tree | b26c334e8472e5d8feffe31dc107d9f929cb5c59 /test/cpp/end2end/filter_end2end_test.cc | |
| parent | 091f5463a14da42715e63741ab6290e8988238ec (diff) | |
| parent | a485cf599f5e3e038d1db3dd2fae9d00cf5fcaa7 (diff) | |
Merge branch 'master' into gpr_review_host_port
Diffstat (limited to 'test/cpp/end2end/filter_end2end_test.cc')
| -rw-r--r-- | test/cpp/end2end/filter_end2end_test.cc | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/test/cpp/end2end/filter_end2end_test.cc b/test/cpp/end2end/filter_end2end_test.cc index be99a1aea4..53e86addef 100644 --- a/test/cpp/end2end/filter_end2end_test.cc +++ b/test/cpp/end2end/filter_end2end_test.cc @@ -175,7 +175,8 @@ class FilterEnd2endTest : public ::testing::Test { // The string needs to be long enough to test heap-based slice. send_request.set_message("Hello world. Hello world. Hello world."); std::unique_ptr<GenericClientAsyncReaderWriter> call = - generic_stub_->Call(&cli_ctx, kMethodName, &cli_cq_, tag(1)); + generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); + call->StartCall(tag(1)); client_ok(1); std::unique_ptr<ByteBuffer> send_buffer = SerializeToByteBuffer(&send_request); @@ -265,10 +266,11 @@ TEST_F(FilterEnd2endTest, SimpleBidiStreaming) { GenericServerContext srv_ctx; GenericServerAsyncReaderWriter srv_stream(&srv_ctx); - cli_ctx.set_compression_algorithm(GRPC_COMPRESS_MESSAGE_GZIP); + cli_ctx.set_compression_algorithm(GRPC_COMPRESS_GZIP); send_request.set_message("Hello"); std::unique_ptr<GenericClientAsyncReaderWriter> cli_stream = - generic_stub_->Call(&cli_ctx, kMethodName, &cli_cq_, tag(1)); + generic_stub_->PrepareCall(&cli_ctx, kMethodName, &cli_cq_); + cli_stream->StartCall(tag(1)); client_ok(1); generic_service_.RequestCall(&srv_ctx, &srv_stream, srv_cq_.get(), |