Revert "testprogs/win32/rpcecho-win32-pipe/server.c ..."

This reverts commit f7c033f91ad89176dbcae46de59b404e14c04e6c.

diff --git a/testprogs/win32/rpcecho-win32-pipe/server.c b/testprogs/win32/rpcecho-win32-pipe/server.c
index ea8ed694c4ef3733e25e5676e458bf65072283a1..4f4657af27a70bb4ea1276178ceb36f80fa5e12b 100755 (executable)
--- 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);
 }