git.samba.org
/
metze
/
samba
/
wip.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
c7491c0
)
source4/torture/rpc/echo.c new idl end TestBytePipeIn
author
Stefan Metzmacher
<metze@samba.org>
Fri, 20 Sep 2013 20:27:33 +0000
(22:27 +0200)
committer
Stefan Metzmacher
<metze@samba.org>
Tue, 4 Jun 2019 11:15:20 +0000
(13:15 +0200)
source4/torture/rpc/echo.c
patch
|
blob
|
history
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;
struct tevent_req *subreq1;
struct tevent_req *subreq2;
size_t i;
- uint8_t bytes[0x
4
000];
+ uint8_t bytes[0x
8
000];
NTSTATUS status;
in_pipe = dcerpc_echo_BytePipe_create(tctx);
ZERO_STRUCT(r);
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);
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));
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;
chunk.array = bytes;
- if (i == r.in.
count
) {
+ if (i == r.in.
num_chunks
) {
chunk.count = 0;
}
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__);
}
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);
tevent_req_poll(subreq1, tctx->ev);
status = dcerpc_echo_TestBytePipeIn_r_recv(subreq1, tctx);
TALLOC_FREE(subreq1);