diff options
author | Vijay Pai <vpai@google.com> | 2018-02-19 22:45:47 -0800 |
---|---|---|
committer | Vijay Pai <vpai@google.com> | 2018-02-19 22:45:47 -0800 |
commit | 87e2e6a58aac78279578ee26c1625eb3eb016cce (patch) | |
tree | 0a4a9aa91dfec4e019fa787df8b45c763ab26741 /test/core/end2end/bad_server_response_test.cc | |
parent | 4258f11d88a4da003377354c40a81e5f786e25c8 (diff) |
clang-fmt
Diffstat (limited to 'test/core/end2end/bad_server_response_test.cc')
-rw-r--r-- | test/core/end2end/bad_server_response_test.cc | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/test/core/end2end/bad_server_response_test.cc b/test/core/end2end/bad_server_response_test.cc index 0dbde3d788..3d133cfc18 100644 --- a/test/core/end2end/bad_server_response_test.cc +++ b/test/core/end2end/bad_server_response_test.cc @@ -254,16 +254,15 @@ static void actually_poll_server(void* arg) { gpr_free(pa); } -static grpc_core::Thread* - poll_server_until_read_done(test_tcp_server* server, - gpr_event* signal_when_done) { +static grpc_core::Thread* poll_server_until_read_done( + test_tcp_server* server, gpr_event* signal_when_done) { gpr_atm_rel_store(&state.done_atm, 0); state.write_done = 0; poll_args* pa = static_cast<poll_args*>(gpr_malloc(sizeof(*pa))); pa->server = server; pa->signal_when_done = signal_when_done; auto* th = grpc_core::New<grpc_core::Thread>("grpc_poll_server", - actually_poll_server, pa); + actually_poll_server, pa); th->Start(); return th; } @@ -285,8 +284,8 @@ static void run_test(const char* response_payload, state.response_payload_length = response_payload_length; /* poll server until sending out the response */ - grpc_core::UniquePtr<grpc_core::Thread> - thdptr(poll_server_until_read_done(&test_server, &ev)); + grpc_core::UniquePtr<grpc_core::Thread> thdptr( + poll_server_until_read_done(&test_server, &ev)); start_rpc(server_port, expected_status, expected_detail); gpr_event_wait(&ev, gpr_inf_future(GPR_CLOCK_REALTIME)); thdptr->Join(); |