diff options
Diffstat (limited to 'test/core/end2end/bad_server_response_test.c')
| -rw-r--r-- | test/core/end2end/bad_server_response_test.c | 60 |
1 files changed, 30 insertions, 30 deletions
diff --git a/test/core/end2end/bad_server_response_test.c b/test/core/end2end/bad_server_response_test.c index 2070fa5b02..ea7857d8d7 100644 --- a/test/core/end2end/bad_server_response_test.c +++ b/test/core/end2end/bad_server_response_test.c @@ -70,17 +70,17 @@ #define SERVER_INCOMING_DATA_LENGTH_LOWER_THRESHOLD (size_t)200 struct rpc_state { - char *target; - grpc_completion_queue *cq; - grpc_channel *channel; - grpc_call *call; + char* target; + grpc_completion_queue* cq; + grpc_channel* channel; + grpc_call* call; size_t incoming_data_length; grpc_slice_buffer temp_incoming_buffer; grpc_slice_buffer outgoing_buffer; - grpc_endpoint *tcp; + grpc_endpoint* tcp; gpr_atm done_atm; bool write_done; - const char *response_payload; + const char* response_payload; size_t response_payload_length; }; @@ -89,15 +89,15 @@ static struct rpc_state state; static grpc_closure on_read; static grpc_closure on_write; -static void *tag(intptr_t t) { return (void *)t; } +static void* tag(intptr_t t) { return (void*)t; } -static void done_write(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) { +static void done_write(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) { GPR_ASSERT(error == GRPC_ERROR_NONE); gpr_atm_rel_store(&state.done_atm, 1); } -static void handle_write(grpc_exec_ctx *exec_ctx) { +static void handle_write(grpc_exec_ctx* exec_ctx) { grpc_slice slice = grpc_slice_from_copied_buffer( state.response_payload, state.response_payload_length); @@ -106,13 +106,13 @@ static void handle_write(grpc_exec_ctx *exec_ctx) { grpc_endpoint_write(exec_ctx, state.tcp, &state.outgoing_buffer, &on_write); } -static void handle_read(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) { +static void handle_read(grpc_exec_ctx* exec_ctx, void* arg, grpc_error* error) { GPR_ASSERT(error == GRPC_ERROR_NONE); state.incoming_data_length += state.temp_incoming_buffer.length; size_t i; for (i = 0; i < state.temp_incoming_buffer.count; i++) { - char *dump = grpc_dump_slice(state.temp_incoming_buffer.slices[i], + char* dump = grpc_dump_slice(state.temp_incoming_buffer.slices[i], GPR_DUMP_HEX | GPR_DUMP_ASCII); gpr_log(GPR_DEBUG, "Server received: %s", dump); gpr_free(dump); @@ -130,11 +130,11 @@ static void handle_read(grpc_exec_ctx *exec_ctx, void *arg, grpc_error *error) { } } -static void on_connect(grpc_exec_ctx *exec_ctx, void *arg, grpc_endpoint *tcp, - grpc_pollset *accepting_pollset, - grpc_tcp_server_acceptor *acceptor) { +static void on_connect(grpc_exec_ctx* exec_ctx, void* arg, grpc_endpoint* tcp, + grpc_pollset* accepting_pollset, + grpc_tcp_server_acceptor* acceptor) { gpr_free(acceptor); - test_tcp_server *server = (test_tcp_server *)arg; + test_tcp_server* server = (test_tcp_server*)arg; GRPC_CLOSURE_INIT(&on_read, handle_read, NULL, grpc_schedule_on_exec_ctx); GRPC_CLOSURE_INIT(&on_write, done_write, NULL, grpc_schedule_on_exec_ctx); grpc_slice_buffer_init(&state.temp_incoming_buffer); @@ -151,14 +151,14 @@ static gpr_timespec n_sec_deadline(int seconds) { } static void start_rpc(int target_port, grpc_status_code expected_status, - const char *expected_detail) { + const char* expected_detail) { grpc_op ops[6]; - grpc_op *op; + grpc_op* op; grpc_metadata_array initial_metadata_recv; grpc_metadata_array trailing_metadata_recv; grpc_status_code status; grpc_call_error error; - cq_verifier *cqv; + cq_verifier* cqv; grpc_slice details; state.cq = grpc_completion_queue_create_for_next(NULL); @@ -217,7 +217,7 @@ static void start_rpc(int target_port, grpc_status_code expected_status, cq_verifier_destroy(cqv); } -static void cleanup_rpc(grpc_exec_ctx *exec_ctx) { +static void cleanup_rpc(grpc_exec_ctx* exec_ctx) { grpc_event ev; grpc_slice_buffer_destroy_internal(exec_ctx, &state.temp_incoming_buffer); grpc_slice_buffer_destroy_internal(exec_ctx, &state.outgoing_buffer); @@ -232,12 +232,12 @@ static void cleanup_rpc(grpc_exec_ctx *exec_ctx) { } typedef struct { - test_tcp_server *server; - gpr_event *signal_when_done; + test_tcp_server* server; + gpr_event* signal_when_done; } poll_args; -static void actually_poll_server(void *arg) { - poll_args *pa = (poll_args *)arg; +static void actually_poll_server(void* arg) { + poll_args* pa = (poll_args*)arg; gpr_timespec deadline = n_sec_deadline(10); while (true) { bool done = gpr_atm_acq_load(&state.done_atm) != 0; @@ -250,25 +250,25 @@ static void actually_poll_server(void *arg) { } test_tcp_server_poll(pa->server, 1); } - gpr_event_set(pa->signal_when_done, (void *)1); + gpr_event_set(pa->signal_when_done, (void*)1); gpr_free(pa); } -static void poll_server_until_read_done(test_tcp_server *server, - gpr_event *signal_when_done) { +static void 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; gpr_thd_id id; - poll_args *pa = (poll_args *)gpr_malloc(sizeof(*pa)); + poll_args* pa = (poll_args*)gpr_malloc(sizeof(*pa)); pa->server = server; pa->signal_when_done = signal_when_done; gpr_thd_new(&id, actually_poll_server, pa, NULL); } -static void run_test(const char *response_payload, +static void run_test(const char* response_payload, size_t response_payload_length, grpc_status_code expected_status, - const char *expected_detail) { + const char* expected_detail) { test_tcp_server test_server; grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; gpr_event ev; @@ -297,7 +297,7 @@ static void run_test(const char *response_payload, grpc_shutdown(); } -int main(int argc, char **argv) { +int main(int argc, char** argv) { grpc_test_init(argc, argv); /* status defined in hpack static table */ |