diff options
author | 2015-09-22 09:30:00 -0700 | |
---|---|---|
committer | 2015-09-22 09:30:00 -0700 | |
commit | d9ccbbf6b98721f3e0256436e8a31fb378324d34 (patch) | |
tree | 70044a256dc950acf8b5fe203e417b00da6a1114 /test/core/channel/channel_stack_test.c | |
parent | 10ee2747a92a20c0bbe8cf3e2e759a121c6cb076 (diff) |
Rename call_list to closure_list
Diffstat (limited to 'test/core/channel/channel_stack_test.c')
-rw-r--r-- | test/core/channel/channel_stack_test.c | 27 |
1 files changed, 14 insertions, 13 deletions
diff --git a/test/core/channel/channel_stack_test.c b/test/core/channel/channel_stack_test.c index 07df921270..72b48e208d 100644 --- a/test/core/channel/channel_stack_test.c +++ b/test/core/channel/channel_stack_test.c @@ -44,7 +44,7 @@ static void channel_init_func(grpc_channel_element *elem, grpc_channel *master, const grpc_channel_args *args, grpc_mdctx *metadata_context, int is_first, - int is_last, grpc_call_list *call_list) { + int is_last, grpc_closure_list *closure_list) { GPR_ASSERT(args->num_args == 1); GPR_ASSERT(args->args[0].type == GRPC_ARG_INTEGER); GPR_ASSERT(0 == strcmp(args->args[0].key, "test_key")); @@ -57,30 +57,31 @@ static void channel_init_func(grpc_channel_element *elem, grpc_channel *master, static void call_init_func(grpc_call_element *elem, const void *server_transport_data, grpc_transport_stream_op *initial_op, - grpc_call_list *call_list) { + grpc_closure_list *closure_list) { ++*(int *)(elem->channel_data); *(int *)(elem->call_data) = 0; } static void channel_destroy_func(grpc_channel_element *elem, - grpc_call_list *call_list) {} + grpc_closure_list *closure_list) {} static void call_destroy_func(grpc_call_element *elem, - grpc_call_list *call_list) { + grpc_closure_list *closure_list) { ++*(int *)(elem->channel_data); } static void call_func(grpc_call_element *elem, grpc_transport_stream_op *op, - grpc_call_list *call_list) { + grpc_closure_list *closure_list) { ++*(int *)(elem->call_data); } static void channel_func(grpc_channel_element *elem, grpc_transport_op *op, - grpc_call_list *call_list) { + grpc_closure_list *closure_list) { ++*(int *)(elem->channel_data); } -static char *get_peer(grpc_call_element *elem, grpc_call_list *call_list) { +static char *get_peer(grpc_call_element *elem, + grpc_closure_list *closure_list) { return gpr_strdup("peer"); } @@ -100,7 +101,7 @@ static void test_create_channel_stack(void) { grpc_mdctx *metadata_context; int *channel_data; int *call_data; - grpc_call_list call_list = GRPC_CALL_LIST_INIT; + grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT; metadata_context = grpc_mdctx_create(); @@ -113,14 +114,14 @@ static void test_create_channel_stack(void) { channel_stack = gpr_malloc(grpc_channel_stack_size(&filters, 1)); grpc_channel_stack_init(&filters, 1, NULL, &chan_args, metadata_context, - channel_stack, &call_list); + channel_stack, &closure_list); GPR_ASSERT(channel_stack->count == 1); channel_elem = grpc_channel_stack_element(channel_stack, 0); channel_data = (int *)channel_elem->channel_data; GPR_ASSERT(*channel_data == 0); call_stack = gpr_malloc(channel_stack->call_stack_size); - grpc_call_stack_init(channel_stack, NULL, NULL, call_stack, &call_list); + grpc_call_stack_init(channel_stack, NULL, NULL, call_stack, &closure_list); GPR_ASSERT(call_stack->count == 1); call_elem = grpc_call_stack_element(call_stack, 0); GPR_ASSERT(call_elem->filter == channel_elem->filter); @@ -129,16 +130,16 @@ static void test_create_channel_stack(void) { GPR_ASSERT(*call_data == 0); GPR_ASSERT(*channel_data == 1); - grpc_call_stack_destroy(call_stack, &call_list); + grpc_call_stack_destroy(call_stack, &closure_list); gpr_free(call_stack); GPR_ASSERT(*channel_data == 2); - grpc_channel_stack_destroy(channel_stack, &call_list); + grpc_channel_stack_destroy(channel_stack, &closure_list); gpr_free(channel_stack); grpc_mdctx_unref(metadata_context); - GPR_ASSERT(grpc_call_list_empty(call_list)); + GPR_ASSERT(grpc_closure_list_empty(closure_list)); } int main(int argc, char **argv) { |