diff options
author | 2015-01-20 22:43:32 -0800 | |
---|---|---|
committer | 2015-01-20 22:43:32 -0800 | |
commit | 8379a06f8dddbe99b9f99163111255794eff07b5 (patch) | |
tree | 4273119573ade442f3cf43671aab8e24b28ee7a1 /test/core/end2end/dualstack_socket_test.c | |
parent | 18d4a86982178ff7bbec345a9772184c713cda35 (diff) | |
parent | 5d19e96f63ebeae7572e2495cfe9f628f74dffc2 (diff) |
Merge branch 'new_invoke_api' of github.com:google/grpc into update-api
Conflicts:
src/cpp/client/channel.cc
src/cpp/stream/stream_context.cc
src/cpp/stream/stream_context.h
src/php/ext/grpc/call.c
test/core/end2end/tests/max_concurrent_streams.c
Diffstat (limited to 'test/core/end2end/dualstack_socket_test.c')
-rw-r--r-- | test/core/end2end/dualstack_socket_test.c | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/test/core/end2end/dualstack_socket_test.c b/test/core/end2end/dualstack_socket_test.c index 4327b91298..6219f57500 100644 --- a/test/core/end2end/dualstack_socket_test.c +++ b/test/core/end2end/dualstack_socket_test.c @@ -115,14 +115,10 @@ void test_connect(const char *server_host, const char *client_host, int port, c = grpc_channel_create_call(client, "/foo", "test.google.com", deadline); GPR_ASSERT(c); - GPR_ASSERT(GRPC_CALL_OK == - grpc_call_start_invoke(c, client_cq, tag(1), tag(2), tag(3), 0)); + GPR_ASSERT(GRPC_CALL_OK == grpc_call_invoke(c, client_cq, tag(2), tag(3), 0)); + GPR_ASSERT(GRPC_CALL_OK == grpc_call_writes_done(c, tag(4))); if (expect_ok) { /* Check for a successful request. */ - cq_expect_invoke_accepted(v_client, tag(1), GRPC_OP_OK); - cq_verify(v_client); - - GPR_ASSERT(GRPC_CALL_OK == grpc_call_writes_done(c, tag(4))); cq_expect_finish_accepted(v_client, tag(4), GRPC_OP_OK); cq_verify(v_client); @@ -152,11 +148,11 @@ void test_connect(const char *server_host, const char *client_host, int port, grpc_call_destroy(s); } else { /* Check for a failed connection. */ - cq_expect_invoke_accepted(v_client, tag(1), GRPC_OP_ERROR); cq_expect_client_metadata_read(v_client, tag(2), NULL); cq_expect_finished_with_status(v_client, tag(3), GRPC_STATUS_DEADLINE_EXCEEDED, "Deadline Exceeded", NULL); + cq_expect_finish_accepted(v_client, tag(4), GRPC_OP_ERROR); cq_verify(v_client); grpc_call_destroy(c); |