diff options
author | 2017-03-02 13:15:39 -0800 | |
---|---|---|
committer | 2017-03-02 13:15:39 -0800 | |
commit | 4f31f44f344bdb1da1429db830989a3aced27b8a (patch) | |
tree | 8a24e5c593d97a5b0a92443344d4e19981fc60b8 /test/core/surface/completion_queue_threading_test.c | |
parent | 0393d5d0a6f3567fd9f38580ae2651ceade7dfcc (diff) |
rebase with latest master
Diffstat (limited to 'test/core/surface/completion_queue_threading_test.c')
-rw-r--r-- | test/core/surface/completion_queue_threading_test.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/core/surface/completion_queue_threading_test.c b/test/core/surface/completion_queue_threading_test.c index 2d55ead843..0945597284 100644 --- a/test/core/surface/completion_queue_threading_test.c +++ b/test/core/surface/completion_queue_threading_test.c @@ -84,7 +84,7 @@ static void test_too_many_plucks(void) { LOG_TEST("test_too_many_plucks"); - cc = grpc_completion_queue_create(NULL); + cc = grpc_completion_queue_create(GRPC_CQ_PLUCK, DEFAULT_POLLING, NULL); gpr_thd_options_set_joinable(&thread_options); for (i = 0; i < GPR_ARRAY_SIZE(tags); i++) { @@ -210,7 +210,8 @@ static void test_threading(size_t producers, size_t consumers) { gpr_malloc((producers + consumers) * sizeof(test_thread_options)); gpr_event phase1 = GPR_EVENT_INIT; gpr_event phase2 = GPR_EVENT_INIT; - grpc_completion_queue *cc = grpc_completion_queue_create(NULL); + grpc_completion_queue *cc = + grpc_completion_queue_create(GRPC_CQ_NEXT, DEFAULT_POLLING, NULL); size_t i; size_t total_consumed = 0; static int optid = 101; |