s4:torture: use tctx->ev as event context for polling

metze

4 files changed, 6 insertions, 8 deletions

diff --git a/source4/torture/raw/composite.c b/source4/torture/raw/composite.c
index ee3bf7260d..2a28b9d50e 100644
--- a/source4/torture/raw/composite.c
+++ b/source4/torture/raw/composite.c
@@ -88,7 +88,7 @@ static bool test_loadfile(struct smbcli_state *cli, struct torture_context *tctx
 
 	printf("waiting for completion\n");
 	while (*count != num_ops) {
-		tevent_loop_once(cli->transport->socket->event.ctx);
+		tevent_loop_once(tctx->ev);
 		if (torture_setting_bool(tctx, "progress", true)) {
 			printf("(%s) count=%d\r", __location__, *count);
 			fflush(stdout);
@@ -170,7 +170,7 @@ static bool test_fetchfile(struct smbcli_state *cli, struct torture_context *tct
 
 	printf("Testing parallel fetchfile with %d ops\n", torture_numops);
 
-	event_ctx = cli->transport->socket->event.ctx;
+	event_ctx = tctx->ev;
 	c = talloc_array(tctx, struct composite_context *, torture_numops);
 
 	for (i=0; i<torture_numops; i++) {
diff --git a/source4/torture/raw/oplock.c b/source4/torture/raw/oplock.c
index d3c7aae025..7b67c528a7 100644
--- a/source4/torture/raw/oplock.c
+++ b/source4/torture/raw/oplock.c
@@ -4133,8 +4133,7 @@ static bool oplock_handler_hold(struct smbcli_transport *transport,
 bool torture_hold_oplock(struct torture_context *torture, 
 			 struct smbcli_state *cli)
 {
-	struct tevent_context *ev = 
-		(struct tevent_context *)cli->transport->socket->event.ctx;
+	struct tevent_context *ev = torture->ev;
 	int i;
 
 	printf("Setting up open files with oplocks in %s\n", BASEDIR);
diff --git a/source4/torture/raw/qfileinfo.c b/source4/torture/raw/qfileinfo.c
index ca5f66795e..4f6d8d56b9 100644
--- a/source4/torture/raw/qfileinfo.c
+++ b/source4/torture/raw/qfileinfo.c
@@ -889,7 +889,7 @@ bool torture_raw_qfileinfo_pipe(struct torture_context *torture,
 	struct smbcli_tree *ipc_tree;
 	NTSTATUS status;
 
-	if (!(p = dcerpc_pipe_init(torture, cli->tree->session->transport->socket->event.ctx))) {
+	if (!(p = dcerpc_pipe_init(torture, torture->ev))) {
 		return false;
 	}
 
diff --git a/source4/torture/raw/samba3misc.c b/source4/torture/raw/samba3misc.c
index 0125d1f3d7..07669ed28b 100644
--- a/source4/torture/raw/samba3misc.c
+++ b/source4/torture/raw/samba3misc.c
@@ -839,7 +839,7 @@ bool torture_samba3_posixtimedlock(struct torture_context *tctx)
 	req->async.fn = receive_lock_result;
 	req->async.private_data = &lock_result;
 
-	te = tevent_add_timer(req->transport->socket->event.ctx,
+	te = tevent_add_timer(tctx->ev,
 			      tctx, timeval_current_ofs(1, 0),
 			      close_locked_file, &fd);
 	if (te == NULL) {
@@ -849,8 +849,7 @@ bool torture_samba3_posixtimedlock(struct torture_context *tctx)
 	}
 
 	while ((fd != -1) || (!lock_result.done)) {
-		if (tevent_loop_once(req->transport->socket->event.ctx)
-		    == -1) {
+		if (tevent_loop_once(tctx->ev) == -1) {
 			torture_warning(tctx, "tevent_loop_once failed: %s\n",
 					strerror(errno));
 			ret = false;