diff options
author | Craig Tiller <ctiller@google.com> | 2015-09-22 09:30:00 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-09-22 09:30:00 -0700 |
commit | d9ccbbf6b98721f3e0256436e8a31fb378324d34 (patch) | |
tree | 70044a256dc950acf8b5fe203e417b00da6a1114 /test/core/surface/completion_queue_test.c | |
parent | 10ee2747a92a20c0bbe8cf3e2e759a121c6cb076 (diff) |
Rename call_list to closure_list
Diffstat (limited to 'test/core/surface/completion_queue_test.c')
-rw-r--r-- | test/core/surface/completion_queue_test.c | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/test/core/surface/completion_queue_test.c b/test/core/surface/completion_queue_test.c index 85a021da89..3dee8f23af 100644 --- a/test/core/surface/completion_queue_test.c +++ b/test/core/surface/completion_queue_test.c @@ -76,13 +76,13 @@ static void test_wait_empty(void) { } static void do_nothing_end_completion(void *arg, grpc_cq_completion *c, - grpc_call_list *call_list) {} + grpc_closure_list *closure_list) {} static void test_cq_end_op(void) { grpc_event ev; grpc_completion_queue *cc; grpc_cq_completion completion; - grpc_call_list call_list = GRPC_CALL_LIST_INIT; + grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT; void *tag = create_test_tag(); LOG_TEST("test_cq_end_op"); @@ -91,7 +91,7 @@ static void test_cq_end_op(void) { grpc_cq_begin_op(cc); grpc_cq_end_op(cc, tag, 1, do_nothing_end_completion, NULL, &completion, - &call_list); + &closure_list); ev = grpc_completion_queue_next(cc, gpr_inf_past(GPR_CLOCK_REALTIME), NULL); GPR_ASSERT(ev.type == GRPC_OP_COMPLETE); @@ -99,7 +99,7 @@ static void test_cq_end_op(void) { GPR_ASSERT(ev.success); shutdown_and_destroy(cc); - GPR_ASSERT(grpc_call_list_empty(call_list)); + GPR_ASSERT(grpc_closure_list_empty(closure_list)); } static void test_shutdown_then_next_polling(void) { @@ -133,7 +133,7 @@ static void test_pluck(void) { grpc_completion_queue *cc; void *tags[128]; grpc_cq_completion completions[GPR_ARRAY_SIZE(tags)]; - grpc_call_list call_list = GRPC_CALL_LIST_INIT; + grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT; unsigned i, j; LOG_TEST("test_pluck"); @@ -150,7 +150,7 @@ static void test_pluck(void) { for (i = 0; i < GPR_ARRAY_SIZE(tags); i++) { grpc_cq_begin_op(cc); grpc_cq_end_op(cc, tags[i], 1, do_nothing_end_completion, NULL, - &completions[i], &call_list); + &completions[i], &closure_list); } for (i = 0; i < GPR_ARRAY_SIZE(tags); i++) { @@ -162,7 +162,7 @@ static void test_pluck(void) { for (i = 0; i < GPR_ARRAY_SIZE(tags); i++) { grpc_cq_begin_op(cc); grpc_cq_end_op(cc, tags[i], 1, do_nothing_end_completion, NULL, - &completions[i], &call_list); + &completions[i], &closure_list); } for (i = 0; i < GPR_ARRAY_SIZE(tags); i++) { @@ -172,7 +172,7 @@ static void test_pluck(void) { } shutdown_and_destroy(cc); - GPR_ASSERT(grpc_call_list_empty(call_list)); + GPR_ASSERT(grpc_closure_list_empty(closure_list)); } #define TEST_THREAD_EVENTS 10000 @@ -193,14 +193,14 @@ gpr_timespec ten_seconds_time(void) { } static void free_completion(void *arg, grpc_cq_completion *completion, - grpc_call_list *call_list) { + grpc_closure_list *closure_list) { gpr_free(completion); } static void producer_thread(void *arg) { test_thread_options *opt = arg; int i; - grpc_call_list call_list = GRPC_CALL_LIST_INIT; + grpc_closure_list closure_list = GRPC_CLOSURE_LIST_INIT; gpr_log(GPR_INFO, "producer %d started", opt->id); gpr_event_set(&opt->on_started, (void *)(gpr_intptr)1); @@ -218,14 +218,14 @@ static void producer_thread(void *arg) { gpr_log(GPR_INFO, "producer %d phase 2", opt->id); for (i = 0; i < TEST_THREAD_EVENTS; i++) { grpc_cq_end_op(opt->cc, (void *)(gpr_intptr)1, 1, free_completion, NULL, - gpr_malloc(sizeof(grpc_cq_completion)), &call_list); + gpr_malloc(sizeof(grpc_cq_completion)), &closure_list); opt->events_triggered++; - grpc_call_list_run(&call_list); + grpc_closure_list_run(&closure_list); } gpr_log(GPR_INFO, "producer %d phase 2 done", opt->id); gpr_event_set(&opt->on_finished, (void *)(gpr_intptr)1); - GPR_ASSERT(grpc_call_list_empty(call_list)); + GPR_ASSERT(grpc_closure_list_empty(closure_list)); } static void consumer_thread(void *arg) { |