aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/core/surface/completion_queue_test.c
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 09:30:00 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 09:30:00 -0700
commitd9ccbbf6b98721f3e0256436e8a31fb378324d34 (patch)
tree70044a256dc950acf8b5fe203e417b00da6a1114 /test/core/surface/completion_queue_test.c
parent10ee2747a92a20c0bbe8cf3e2e759a121c6cb076 (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.c26
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) {