From ed75173f5a1cd8897ed105fc850dd049db13440d Mon Sep 17 00:00:00 2001 From: Stefan Metzmacher Date: Tue, 24 Sep 2013 20:43:03 +0200 Subject: [PATCH] Revert "testprogs/win32/rpcecho-win32-pipe/server.c ..." This reverts commit f7c033f91ad89176dbcae46de59b404e14c04e6c. --- testprogs/win32/rpcecho-win32-pipe/server.c | 54 ++++----------------- 1 file changed, 10 insertions(+), 44 deletions(-) diff --git a/testprogs/win32/rpcecho-win32-pipe/server.c b/testprogs/win32/rpcecho-win32-pipe/server.c index ea8ed694c4ef..4f4657af27a7 100755 --- a/testprogs/win32/rpcecho-win32-pipe/server.c +++ b/testprogs/win32/rpcecho-win32-pipe/server.c @@ -154,8 +154,7 @@ void TestBytePipeIn( long chunk_size, ASYNC_BYTE_PIPE *in_pipe) { - RPC_STATUS status; - long ret = -1; + long ret; byte *in_bytes; int in_alloc_size; int in_bytes_count; @@ -164,36 +163,20 @@ void TestBytePipeIn( printf("TestBytePipeIn: Start\n"); fflush(stdout); - in_alloc_size = chunk_size * sizeof(byte); + in_alloc_size = 5840 * sizeof(byte); in_bytes = malloc(in_alloc_size); - if (in_bytes == NULL) { - printf("nomem: %d\n", in_alloc_size); - fflush(stdout); - ret = -2; - goto done; - } in_bytes_count = chunk_size; for (i=0; in_bytes_count > 0; i++) { in_bytes_count = 0; - status = in_pipe->pull(in_pipe->state, in_bytes, in_alloc_size, &in_bytes_count); - if (status != 0) { - printf("status: %d\n", status); - fflush(stdout); - ret = -3; - goto done; - } + in_pipe->pull(in_pipe->state, in_bytes, in_alloc_size, &in_bytes_count); printf("pull[%u] bytes_count[%u]\n", i, in_bytes_count); fflush(stdout); } - ret = i; -done: - printf("TestBytePipeIn: End ret[%d]\n", ret); + printf("TestBytePipeIn: End\n"); fflush(stdout); - if (in_bytes) { - free(in_bytes); - } + ret = i; RpcAsyncCompleteCall(TestBytePipeIn_AsyncHandle, &ret); } @@ -203,8 +186,7 @@ void TestBytePipeOut( long chunk_size, ASYNC_BYTE_PIPE *out_pipe) { - RPC_STATUS status; - long ret = -1; + long ret; byte *out_bytes = NULL; unsigned long out_alloc_size = 0; unsigned long out_bytes_count = 0; @@ -214,13 +196,7 @@ void TestBytePipeOut( fflush(stdout); out_alloc_size = chunk_size * sizeof(byte); - status = out_pipe->alloc(out_pipe->state, out_alloc_size, &out_bytes, &out_bytes_count); - if (status != 0) { - printf("status: %d\n", status); - fflush(stdout); - ret = -2; - goto done; - } + out_pipe->alloc(out_pipe->state, out_alloc_size, &out_bytes, &out_bytes_count); memset(out_bytes, 0xCC, out_bytes_count * sizeof(byte)); for (i = 0; i <= num_chunks; i++) { @@ -229,22 +205,12 @@ void TestBytePipeOut( } printf("[%u] push outb_len[%u]\n", i, out_bytes_count); fflush(stdout); - status = out_pipe->push(out_pipe->state, out_bytes, out_bytes_count); - if (status != 0) { - printf("status: %d\n", status); - fflush(stdout); - ret = -3; - goto done; - } + out_pipe->push(out_pipe->state, out_bytes, out_bytes_count); } - ret = i; -done: - printf("TestBytePipeOut: End ret[%d]\n", ret); + printf("TestBytePipeOut: End\n"); fflush(stdout); - if (out_bytes) { - free(out_bytes); - } + ret = i; RpcAsyncCompleteCall(TestBytePipeOut_AsyncHandle, &ret); } -- 2.34.1