From: Stefan Metzmacher Date: Fri, 20 Sep 2013 20:27:33 +0000 (+0200) Subject: source4/torture/rpc/echo.c new idl end TestBytePipeIn X-Git-Url: http://git.samba.org/?a=commitdiff_plain;h=1bee3df6e359161d2950d7b41060a7e1aa4935c6;hp=c7491c0e6fcb0ea1bbc8614fac2d9b3dedd987c8;p=metze%2Fsamba%2Fwip.git source4/torture/rpc/echo.c new idl end TestBytePipeIn --- diff --git a/source4/torture/rpc/echo.c b/source4/torture/rpc/echo.c index 739f9e7b96fb..eb49aa9eb9a1 100644 --- 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);