diff options
author | Robbie Shade <robbie.shade@gmail.com> | 2015-08-13 19:03:15 -0400 |
---|---|---|
committer | Robbie Shade <robbie.shade@gmail.com> | 2015-08-13 19:03:15 -0400 |
commit | 00436a256dd81b10df5da1154f48b9f81056824b (patch) | |
tree | 01c8b4698f5773a709cc128cadf182c3232f85a3 | |
parent | a294487e37a8aeb47859423ee2fb6aec18cdae13 (diff) |
Update to latest API changes.
-rw-r--r-- | test/core/iomgr/udp_server_test.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/test/core/iomgr/udp_server_test.c b/test/core/iomgr/udp_server_test.c index bce7642120..74b78958b0 100644 --- a/test/core/iomgr/udp_server_test.c +++ b/test/core/iomgr/udp_server_test.c @@ -62,7 +62,7 @@ static void on_read(int fd, grpc_udp_server_cb new_transport_cb, void *cb_arg) { g_number_of_reads++; g_number_of_bytes_read += byte_count; - grpc_pollset_kick(&g_pollset); + grpc_pollset_kick(&g_pollset, NULL); gpr_mu_unlock(GRPC_POLLSET_MU(&g_pollset)); } @@ -144,8 +144,9 @@ static void test_receive(int number_of_clients) { GPR_ASSERT(connect(clifd, (struct sockaddr *)&addr, addr_len) == 0); GPR_ASSERT(5 == write(clifd, "hello", 5)); while (g_number_of_reads == number_of_reads_before && - gpr_time_cmp(deadline, gpr_now()) > 0) { - grpc_pollset_work(&g_pollset, deadline); + gpr_time_cmp(deadline, gpr_now(deadline.clock_type)) > 0) { + grpc_pollset_worker worker; + grpc_pollset_work(&g_pollset, &worker, deadline); } GPR_ASSERT(g_number_of_reads == number_of_reads_before + 1); close(clifd); |