diff options
author | David Klempner <klempner@google.com> | 2015-04-28 13:49:29 -0700 |
---|---|---|
committer | David Klempner <klempner@google.com> | 2015-04-28 13:49:29 -0700 |
commit | 29c4d0a42d553fd73d8b1e9f11d15e9cf700c8b4 (patch) | |
tree | 244eac2c87700d54b80aaef7a9ca014019a46da6 | |
parent | ad2a0e4369d0cebc1e3dfb86082168cee9d31a43 (diff) | |
parent | 31c489c9ebd52a3e955a4a2a30814ab15de34724 (diff) |
Merge pull request #1390 from ctiller/tcp-test
Fix test for multiple reads
-rw-r--r-- | test/core/iomgr/tcp_posix_test.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/test/core/iomgr/tcp_posix_test.c b/test/core/iomgr/tcp_posix_test.c index 59e525a8e1..40abed5f6e 100644 --- a/test/core/iomgr/tcp_posix_test.c +++ b/test/core/iomgr/tcp_posix_test.c @@ -40,6 +40,7 @@ #include <sys/socket.h> #include <unistd.h> +#include <grpc/grpc.h> #include <grpc/support/alloc.h> #include <grpc/support/log.h> #include <grpc/support/time.h> @@ -140,11 +141,12 @@ static void read_cb(void *user_data, gpr_slice *slices, size_t nslices, grpc_endpoint_cb_status error) { struct read_socket_state *state = (struct read_socket_state *)user_data; ssize_t read_bytes; - int current_data = 0; + int current_data; GPR_ASSERT(error == GRPC_ENDPOINT_CB_OK); gpr_mu_lock(&state->mu); + current_data = state->read_bytes % 256; read_bytes = count_and_unref_slices(slices, nslices, ¤t_data); state->read_bytes += read_bytes; gpr_log(GPR_INFO, "Read %d bytes of %d", read_bytes, @@ -483,10 +485,10 @@ static grpc_endpoint_test_config configs[] = { int main(int argc, char **argv) { grpc_test_init(argc, argv); - grpc_iomgr_init(); + grpc_init(); run_tests(); grpc_endpoint_tests(configs[0]); - grpc_iomgr_shutdown(); + grpc_shutdown(); return 0; } |