From e4b409364e4c493a66d4b2a6fe897075aa5c174e Mon Sep 17 00:00:00 2001 From: ctiller Date: Wed, 7 Jan 2015 12:13:17 -0800 Subject: Add a --forever flag, to continuously run tests as things change. Change on 2015/01/07 by ctiller ------------- Created by MOE: http://code.google.com/p/moe-java MOE_MIGRATED_REVID=83451760 --- test/core/iomgr/tcp_posix_test.c | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) (limited to 'test/core/iomgr/tcp_posix_test.c') diff --git a/test/core/iomgr/tcp_posix_test.c b/test/core/iomgr/tcp_posix_test.c index 7fd2567cec..6a4ef0f984 100644 --- a/test/core/iomgr/tcp_posix_test.c +++ b/test/core/iomgr/tcp_posix_test.c @@ -154,7 +154,7 @@ static void read_cb(void *user_data, gpr_slice *slices, size_t nslices, if (state->read_bytes >= state->target_read_bytes) { gpr_cv_signal(&state->cv); } else { - grpc_endpoint_notify_on_read(state->ep, read_cb, state); + grpc_endpoint_notify_on_read(state->ep, read_cb, state, gpr_inf_future); } gpr_mu_unlock(&state->mu); } @@ -183,7 +183,7 @@ static void read_test(ssize_t num_bytes, ssize_t slice_size) { state.read_bytes = 0; state.target_read_bytes = written_bytes; - grpc_endpoint_notify_on_read(ep, read_cb, &state); + grpc_endpoint_notify_on_read(ep, read_cb, &state, gpr_inf_future); gpr_mu_lock(&state.mu); for (;;) { @@ -225,7 +225,7 @@ static void large_read_test(ssize_t slice_size) { state.read_bytes = 0; state.target_read_bytes = written_bytes; - grpc_endpoint_notify_on_read(ep, read_cb, &state); + grpc_endpoint_notify_on_read(ep, read_cb, &state, gpr_inf_future); gpr_mu_lock(&state.mu); for (;;) { @@ -363,8 +363,8 @@ static void write_test(ssize_t num_bytes, ssize_t slice_size) { slices = allocate_blocks(num_bytes, slice_size, &num_blocks, ¤t_data); - if (grpc_endpoint_write(ep, slices, num_blocks, write_done, &state) == - GRPC_ENDPOINT_WRITE_DONE) { + if (grpc_endpoint_write(ep, slices, num_blocks, write_done, &state, + gpr_inf_future) == GRPC_ENDPOINT_WRITE_DONE) { /* Write completed immediately */ read_bytes = drain_socket(sv[0]); GPR_ASSERT(read_bytes == num_bytes); @@ -421,13 +421,15 @@ static void write_error_test(ssize_t num_bytes, ssize_t slice_size) { slices = allocate_blocks(num_bytes, slice_size, &num_blocks, ¤t_data); - switch (grpc_endpoint_write(ep, slices, num_blocks, write_done, &state)) { + switch (grpc_endpoint_write(ep, slices, num_blocks, write_done, &state, + gpr_inf_future)) { case GRPC_ENDPOINT_WRITE_DONE: case GRPC_ENDPOINT_WRITE_ERROR: /* Write completed immediately */ break; case GRPC_ENDPOINT_WRITE_PENDING: - grpc_endpoint_notify_on_read(ep, read_done_for_write_error, NULL); + grpc_endpoint_notify_on_read(ep, read_done_for_write_error, NULL, + gpr_inf_future); gpr_mu_lock(&state.mu); for (;;) { if (state.write_done) { -- cgit v1.2.3