source4/torture/rpc/echo.c new idl end TestBytePipeIn

diff --git a/source4/torture/rpc/echo.c b/source4/torture/rpc/echo.c
index 739f9e7b96fb6d2c3922562f05166118a3f9ddad..eb49aa9eb9a1756f41a305d85bbe8f7301efd7a8 100644 (file)
--- a/source4/torture/rpc/echo.c
+++ b/source4/torture/rpc/echo.c
@@ -398,26 +398,27 @@ static bool test_bytepipein(struct torture_context *tctx,
        struct tevent_req *subreq1;
        struct tevent_req *subreq2;
        size_t i;
-       uint8_t bytes[0x4000];
+       uint8_t bytes[0x8000];
        NTSTATUS status;
 
        in_pipe = dcerpc_echo_BytePipe_create(tctx);
 
        ZERO_STRUCT(r);
-       r.in.count = 1;
+       r.in.num_chunks = 1;
+       r.in.chunk_size = sizeof(bytes);
        r.in.in_pipe = in_pipe;
 
        ZERO_STRUCT(chunk);
 
        subreq1 = dcerpc_echo_TestBytePipeIn_r_send(tctx, tctx->ev, b, &r);
-       for (i=0; i <= r.in.count; i++) {
+       for (i=0; i <= r.in.num_chunks; i++) {
                struct timeval tv = timeval_current_ofs(0, 100);
 
                memset(bytes, i, sizeof(bytes));
-               chunk.count = sizeof(bytes);
+               chunk.count = r.in.chunk_size;
                chunk.array = bytes;
 
-               if (i == r.in.count) {
+               if (i == r.in.num_chunks) {
                        chunk.count = 0;
                }
 
@@ -433,6 +434,7 @@ static bool test_bytepipein(struct torture_context *tctx,
                TALLOC_FREE(subreq2);
                torture_assert_ntstatus_ok(tctx, status, __location__);
        }
+
        tevent_req_poll(subreq1, tctx->ev);
        status = dcerpc_echo_TestBytePipeIn_r_recv(subreq1, tctx);
        TALLOC_FREE(subreq1);