summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--source3/torture/torture.c6
-rw-r--r--source4/torture/basic/base.c2
-rw-r--r--source4/torture/basic/misc.c2
-rw-r--r--source4/torture/nbt/dgram.c20
-rw-r--r--source4/torture/nbt/query.c4
-rw-r--r--source4/torture/nbt/wins.c4
-rw-r--r--source4/torture/nbt/winsbench.c4
-rw-r--r--source4/torture/nbt/winsreplication.c12
-rw-r--r--source4/torture/raw/composite.c8
-rw-r--r--source4/torture/raw/lockbench.c14
-rw-r--r--source4/torture/raw/offline.c8
-rw-r--r--source4/torture/raw/open.c4
-rw-r--r--source4/torture/raw/openbench.c14
-rw-r--r--source4/torture/raw/oplock.c6
-rw-r--r--source4/torture/rpc/echo.c2
-rw-r--r--source4/torture/rpc/lsa.c2
-rw-r--r--source4/torture/rpc/netlogon.c4
-rw-r--r--source4/torture/rpc/schannel.c8
-rw-r--r--source4/torture/smb2/create.c4
-rw-r--r--source4/torture/smb2/lock.c2
-rw-r--r--source4/torture/smb2/notify.c10
-rw-r--r--source4/torture/smb2/oplock.c6
22 files changed, 73 insertions, 73 deletions
diff --git a/source3/torture/torture.c b/source3/torture/torture.c
index d5c2a567aa0..888bcb1c863 100644
--- a/source3/torture/torture.c
+++ b/source3/torture/torture.c
@@ -6517,7 +6517,7 @@ static bool run_chain1(int dummy)
}
while (!done) {
- event_loop_once(evt);
+ tevent_loop_once(evt);
}
torture_close_connection(cli1);
@@ -6573,7 +6573,7 @@ static bool run_chain2(int dummy)
}
while (!done) {
- event_loop_once(evt);
+ tevent_loop_once(evt);
}
torture_close_connection(cli1);
@@ -8424,7 +8424,7 @@ static bool run_local_wbclient(int dummy)
i = 0;
while (i < nprocs * torture_numops) {
- event_loop_once(ev);
+ tevent_loop_once(ev);
}
result = true;
diff --git a/source4/torture/basic/base.c b/source4/torture/basic/base.c
index d7bac459c37..3e405f7d091 100644
--- a/source4/torture/basic/base.c
+++ b/source4/torture/basic/base.c
@@ -360,7 +360,7 @@ static bool run_negprot_nowait(struct torture_context *tctx)
for (i=0;i<100;i++) {
struct smbcli_request *req;
req = smb_raw_negotiate_send(cli->transport, lpcfg_unicode(tctx->lp_ctx), PROTOCOL_NT1);
- event_loop_once(cli->transport->socket->event.ctx);
+ tevent_loop_once(cli->transport->socket->event.ctx);
if (req->state == SMBCLI_REQUEST_ERROR) {
if (i > 0) {
torture_comment(tctx, "Failed to fill pipe packet[%d] - %s (ignored)\n", i+1, nt_errstr(req->status));
diff --git a/source4/torture/basic/misc.c b/source4/torture/basic/misc.c
index 5fbbc61e0fb..0fa9a9e98f2 100644
--- a/source4/torture/basic/misc.c
+++ b/source4/torture/basic/misc.c
@@ -997,7 +997,7 @@ bool run_benchrw(struct torture_context *tctx)
finished++;
break;
default:
- event_loop_once(ev);
+ tevent_loop_once(ev);
}
}
}
diff --git a/source4/torture/nbt/dgram.c b/source4/torture/nbt/dgram.c
index aa4759edaf9..68d44ff774e 100644
--- a/source4/torture/nbt/dgram.c
+++ b/source4/torture/nbt/dgram.c
@@ -139,7 +139,7 @@ static bool nbt_test_netlogon(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send netlogon request");
while (timeval_elapsed(&tv) < 5 && !dgmslot->private_data) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -235,7 +235,7 @@ static bool nbt_test_netlogon2(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send netlogon request");
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -275,7 +275,7 @@ static bool nbt_test_netlogon2(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send netlogon request");
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -327,7 +327,7 @@ static bool nbt_test_netlogon2(struct torture_context *tctx)
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -369,7 +369,7 @@ static bool nbt_test_netlogon2(struct torture_context *tctx)
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -408,7 +408,7 @@ static bool nbt_test_netlogon2(struct torture_context *tctx)
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -517,7 +517,7 @@ static bool nbt_test_ntlogon(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send ntlogon request");
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -561,7 +561,7 @@ static bool nbt_test_ntlogon(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send ntlogon request");
while (timeval_elapsed(&tv) < 5 && dgmslot->private_data == NULL) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -602,7 +602,7 @@ static bool nbt_test_ntlogon(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send ntlogon request");
while (timeval_elapsed(&tv) < 5 && !dgmslot->private_data) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
@@ -640,7 +640,7 @@ static bool nbt_test_ntlogon(struct torture_context *tctx)
torture_assert_ntstatus_ok(tctx, status, "Failed to send ntlogon request");
while (timeval_elapsed(&tv) < 5 && !dgmslot->private_data) {
- event_loop_once(dgmsock->event_ctx);
+ tevent_loop_once(dgmsock->event_ctx);
}
response = talloc_get_type(dgmslot->private_data, struct nbt_netlogon_response);
diff --git a/source4/torture/nbt/query.c b/source4/torture/nbt/query.c
index d64683aa577..001ff19413b 100644
--- a/source4/torture/nbt/query.c
+++ b/source4/torture/nbt/query.c
@@ -88,11 +88,11 @@ static bool bench_namequery(struct torture_context *tctx)
}
}
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
}
while (num_sent != (result->num_pass + result->num_fail)) {
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
}
torture_comment(tctx, "%.1f queries per second (%d failures) \n",
diff --git a/source4/torture/nbt/wins.c b/source4/torture/nbt/wins.c
index 571249f562d..bd023294cbf 100644
--- a/source4/torture/nbt/wins.c
+++ b/source4/torture/nbt/wins.c
@@ -156,7 +156,7 @@ static bool nbt_test_wins_name(struct torture_context *tctx, const char *address
*/
req = nbt_name_register_send(nbtsock, &name_register);
while (true) {
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
if (req->state != NBT_REQUEST_WAIT) {
break;
}
@@ -170,7 +170,7 @@ static bool nbt_test_wins_name(struct torture_context *tctx, const char *address
req->state = NBT_REQUEST_SEND;
DLIST_ADD_END(nbtsock->send_queue, req,
struct nbt_name_request *);
- EVENT_FD_WRITEABLE(nbtsock->fde);
+ TEVENT_FD_WRITEABLE(nbtsock->fde);
break;
}
}
diff --git a/source4/torture/nbt/winsbench.c b/source4/torture/nbt/winsbench.c
index cb71d8755dd..3722202c6f4 100644
--- a/source4/torture/nbt/winsbench.c
+++ b/source4/torture/nbt/winsbench.c
@@ -270,11 +270,11 @@ static bool bench_wins(struct torture_context *tctx)
}
}
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
}
while (num_sent != (state->pass_count + state->fail_count)) {
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
}
torture_comment(tctx, "%.1f queries per second (%d failures) \n",
diff --git a/source4/torture/nbt/winsreplication.c b/source4/torture/nbt/winsreplication.c
index 7165f10dbbb..56a1c09301c 100644
--- a/source4/torture/nbt/winsreplication.c
+++ b/source4/torture/nbt/winsreplication.c
@@ -9378,7 +9378,7 @@ static bool test_conflict_owned_active_vs_replica(struct torture_context *tctx,
req = nbt_name_register_send(ctx->nbtsock, name_register);
/* push the request on the wire */
- event_loop_once(ctx->nbtsock->event_ctx);
+ tevent_loop_once(ctx->nbtsock->event_ctx);
/*
* if we register multiple addresses,
@@ -9389,7 +9389,7 @@ static bool test_conflict_owned_active_vs_replica(struct torture_context *tctx,
end = timeval_current_ofs(records[i].defend.timeout,0);
records[i].defend.ret = true;
while (records[i].defend.timeout > 0) {
- event_loop_once(ctx->nbtsock_srv->event_ctx);
+ tevent_loop_once(ctx->nbtsock_srv->event_ctx);
if (timeval_expired(&end)) break;
}
ret &= records[i].defend.ret;
@@ -9451,7 +9451,7 @@ static bool test_conflict_owned_active_vs_replica(struct torture_context *tctx,
end = timeval_current_ofs(records[i].defend.timeout,0);
records[i].defend.ret = true;
while (records[i].defend.timeout > 0) {
- event_loop_once(ctx->nbtsock_srv->event_ctx);
+ tevent_loop_once(ctx->nbtsock_srv->event_ctx);
if (timeval_expired(&end)) break;
}
ret &= records[i].defend.ret;
@@ -9466,7 +9466,7 @@ static bool test_conflict_owned_active_vs_replica(struct torture_context *tctx,
end = timeval_current_ofs(records[i].defend.timeout,0);
records[i].defend.ret = true;
while (records[i].defend.timeout > 0) {
- event_loop_once(ctx->nbtsock_srv->event_ctx);
+ tevent_loop_once(ctx->nbtsock_srv->event_ctx);
if (timeval_expired(&end)) break;
}
ret &= records[i].defend.ret;
@@ -9693,7 +9693,7 @@ static void test_conflict_owned_active_vs_replica_handler_query(struct nbt_name_
/* make sure we push the reply to the wire */
while (nbtsock->send_queue) {
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
}
smb_msleep(1000);
@@ -9750,7 +9750,7 @@ static void test_conflict_owned_active_vs_replica_handler_release(
/* make sure we push the reply to the wire */
while (nbtsock->send_queue) {
- event_loop_once(nbtsock->event_ctx);
+ tevent_loop_once(nbtsock->event_ctx);
}
smb_msleep(1000);
diff --git a/source4/torture/raw/composite.c b/source4/torture/raw/composite.c
index fd1f6aaf979..ee3bf7260da 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) {
- event_loop_once(cli->transport->socket->event.ctx);
+ tevent_loop_once(cli->transport->socket->event.ctx);
if (torture_setting_bool(tctx, "progress", true)) {
printf("(%s) count=%d\r", __location__, *count);
fflush(stdout);
@@ -182,7 +182,7 @@ static bool test_fetchfile(struct smbcli_state *cli, struct torture_context *tct
printf("waiting for completion\n");
while (*count != torture_numops) {
- event_loop_once(event_ctx);
+ tevent_loop_once(event_ctx);
if (torture_setting_bool(tctx, "progress", true)) {
printf("(%s) count=%d\r", __location__, *count);
fflush(stdout);
@@ -302,7 +302,7 @@ static bool test_appendacl(struct smbcli_state *cli, struct torture_context *tct
event_ctx = tctx->ev;
printf("waiting for completion\n");
while (*count != num_ops) {
- event_loop_once(event_ctx);
+ tevent_loop_once(event_ctx);
if (torture_setting_bool(tctx, "progress", true)) {
printf("(%s) count=%d\r", __location__, *count);
fflush(stdout);
@@ -372,7 +372,7 @@ static bool test_fsinfo(struct smbcli_state *cli, struct torture_context *tctx)
printf("waiting for completion\n");
while (*count < torture_numops) {
- event_loop_once(event_ctx);
+ tevent_loop_once(event_ctx);
if (torture_setting_bool(tctx, "progress", true)) {
printf("(%s) count=%d\r", __location__, *count);
fflush(stdout);
diff --git a/source4/torture/raw/lockbench.c b/source4/torture/raw/lockbench.c
index 58e709dd2b8..0a4faface87 100644
--- a/source4/torture/raw/lockbench.c
+++ b/source4/torture/raw/lockbench.c
@@ -153,7 +153,7 @@ static void reopen_connection_complete(struct composite_context *ctx)
status = smb_composite_connect_recv(ctx, state->mem_ctx);
if (!NT_STATUS_IS_OK(status)) {
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
return;
@@ -163,7 +163,7 @@ static void reopen_connection_complete(struct composite_context *ctx)
state->tree = io->out.tree;
/* do the reopen as a separate event */
- event_add_timed(state->ev, state->mem_ctx, timeval_zero(), reopen_file, state);
+ tevent_add_timer(state->ev, state->mem_ctx, timeval_zero(), reopen_file, state);
}
@@ -233,7 +233,7 @@ static void lock_completion(struct smbcli_request *req)
num_connected--;
DEBUG(0,("reopening connection to %s\n", state->dest_host));
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
} else {
@@ -272,7 +272,7 @@ static void echo_completion(struct smbcli_request *req)
num_connected--;
DEBUG(0,("reopening connection to %s\n", state->dest_host));
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
}
@@ -290,7 +290,7 @@ static void report_rate(struct tevent_context *ev, struct tevent_timer *te,
}
printf("\r");
fflush(stdout);
- event_add_timed(ev, state, timeval_current_ofs(1, 0), report_rate, state);
+ tevent_add_timer(ev, state, timeval_current_ofs(1, 0), report_rate, state);
/* send an echo on each interface to ensure it stays alive - this helps
with IP takeover */
@@ -396,12 +396,12 @@ bool torture_bench_lock(struct torture_context *torture)
tv = timeval_current();
if (progress) {
- event_add_timed(torture->ev, state, timeval_current_ofs(1, 0), report_rate, state);
+ tevent_add_timer(torture->ev, state, timeval_current_ofs(1, 0), report_rate, state);
}
printf("Running for %d seconds\n", timelimit);
while (timeval_elapsed(&tv) < timelimit) {
- event_loop_once(torture->ev);
+ tevent_loop_once(torture->ev);
if (lock_failed) {
DEBUG(0,("locking failed\n"));
diff --git a/source4/torture/raw/offline.c b/source4/torture/raw/offline.c
index a8259e2d421..85b1235ff6d 100644
--- a/source4/torture/raw/offline.c
+++ b/source4/torture/raw/offline.c
@@ -355,7 +355,7 @@ static void report_rate(struct tevent_context *ev, struct tevent_timer *te,
latencies[OP_LOADFILE],
worst_latencies[OP_LOADFILE]);
fflush(stdout);
- event_add_timed(ev, state, timeval_current_ofs(1, 0), report_rate, state);
+ tevent_add_timer(ev, state, timeval_current_ofs(1, 0), report_rate, state);
for (i=0;i<OP_ENDOFLIST;i++) {
if (latencies[i] > worst_latencies[i]) {
@@ -471,12 +471,12 @@ bool torture_test_offline(struct torture_context *torture)
tv = timeval_current();
if (progress) {
- event_add_timed(torture->ev, state, timeval_current_ofs(1, 0), report_rate, state);
+ tevent_add_timer(torture->ev, state, timeval_current_ofs(1, 0), report_rate, state);
}
printf("Running for %d seconds\n", timelimit);
while (timeval_elapsed(&tv) < timelimit) {
- event_loop_once(torture->ev);
+ tevent_loop_once(torture->ev);
if (test_failed) {
DEBUG(0,("test failed\n"));
@@ -490,7 +490,7 @@ bool torture_test_offline(struct torture_context *torture)
while (state[i].loadfile ||
state[i].savefile ||
state[i].req) {
- event_loop_once(torture->ev);
+ tevent_loop_once(torture->ev);
}
}
diff --git a/source4/torture/raw/open.c b/source4/torture/raw/open.c
index 8a66a12cd57..3460a172b62 100644
--- a/source4/torture/raw/open.c
+++ b/source4/torture/raw/open.c
@@ -1633,9 +1633,9 @@ static bool test_raw_open_multi(struct torture_context *tctx, struct smbcli_stat
break;
}
- if (event_loop_once(tctx->ev) != 0) {
+ if (tevent_loop_once(tctx->ev) != 0) {
torture_result(tctx, TORTURE_FAIL,
- "(%s): event_loop_once failed\n", __location__);
+ "(%s): tevent_loop_once failed\n", __location__);
return false;
}
}
diff --git a/source4/torture/raw/openbench.c b/source4/torture/raw/openbench.c
index d0c785d4607..9543eea1b10 100644
--- a/source4/torture/raw/openbench.c
+++ b/source4/torture/raw/openbench.c
@@ -91,7 +91,7 @@ static void reopen_connection_complete(struct composite_context *ctx)
status = smb_composite_connect_recv(ctx, state->mem_ctx);
if (!NT_STATUS_IS_OK(status)) {
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
return;
@@ -233,7 +233,7 @@ static void open_completed(struct smbcli_request *req)
DEBUG(0,("[%u] reopening connection to %s\n",
state->client_num, state->dest_host));
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
return;
@@ -293,7 +293,7 @@ static void close_completed(struct smbcli_request *req)
DEBUG(0,("[%u] reopening connection to %s\n",
state->client_num, state->dest_host));
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
return;
@@ -326,7 +326,7 @@ static void echo_completion(struct smbcli_request *req)
DEBUG(0,("[%u] reopening connection to %s\n",
state->client_num, state->dest_host));
talloc_free(state->te);
- state->te = event_add_timed(state->ev, state->mem_ctx,
+ state->te = tevent_add_timer(state->ev, state->mem_ctx,
timeval_current_ofs(1,0),
reopen_connection, state);
}
@@ -344,7 +344,7 @@ static void report_rate(struct tevent_context *ev, struct tevent_timer *te,
}
printf("\r");
fflush(stdout);
- report_te = event_add_timed(ev, state, timeval_current_ofs(1, 0),
+ report_te = tevent_add_timer(ev, state, timeval_current_ofs(1, 0),
report_rate, state);
/* send an echo on each interface to ensure it stays alive - this helps
@@ -434,13 +434,13 @@ bool torture_bench_open(struct torture_context *torture)
tv = timeval_current();
if (progress) {
- report_te = event_add_timed(torture->ev, state, timeval_current_ofs(1, 0),
+ report_te = tevent_add_timer(torture->ev, state, timeval_current_ofs(1, 0),
report_rate, state);
}
printf("Running for %d seconds\n", timelimit);
while (timeval_elapsed(&tv) < timelimit) {
- event_loop_once(torture->ev);
+ tevent_loop_once(torture->ev);
if (open_failed) {
DEBUG(0,("open failed\n"));
diff --git a/source4/torture/raw/oplock.c b/source4/torture/raw/oplock.c
index 01b1dd2b93d..46f2ed32301 100644
--- a/source4/torture/raw/oplock.c
+++ b/source4/torture/raw/oplock.c
@@ -226,7 +226,7 @@ static void torture_wait_for_oplock_break(struct torture_context *tctx)
/* Wait .1 seconds for an oplock break */
ne = tevent_timeval_current_ofs(0, 100000);
- if ((te = event_add_timed(tctx->ev, tmp_ctx, ne, timeout_cb, &timesup))
+ if ((te = tevent_add_timer(tctx->ev, tmp_ctx, ne, timeout_cb, &timesup))
== NULL)
{
torture_comment(tctx, "Failed to wait for an oplock break. "
@@ -235,7 +235,7 @@ static void torture_wait_for_oplock_break(struct torture_context *tctx)
}
while (!timesup && break_info.count < old_count + 1) {
- if (event_loop_once(tctx->ev) != 0) {
+ if (tevent_loop_once(tctx->ev) != 0) {
torture_comment(tctx, "Failed to wait for an oplock "
"break. test results may not be "
"accurate.");
@@ -4196,7 +4196,7 @@ bool torture_hold_oplock(struct torture_context *torture,
}
printf("Waiting for oplock events\n");
- event_loop_wait(ev);
+ tevent_loop_wait(ev);
return true;
}
diff --git a/source4/torture/rpc/echo.c b/source4/torture/rpc/echo.c
index 643b21fa7f3..db6d2414a93 100644
--- a/source4/torture/rpc/echo.c
+++ b/source4/torture/rpc/echo.c
@@ -258,7 +258,7 @@ static bool test_sleep(struct torture_context *tctx,
ctx = dcerpc_event_context(p);
while (total_done < ASYNC_COUNT) {
- torture_assert(tctx, event_loop_once(ctx) == 0,
+ torture_assert(tctx, tevent_loop_once(ctx) == 0,
"Event context loop failed");
for (i=0;i<ASYNC_COUNT;i++) {
if (done2[i] == false && done1[i] == true) {
diff --git a/source4/torture/rpc/lsa.c b/source4/torture/rpc/lsa.c
index 4fbf36c8940..c09a2daad2f 100644
--- a/source4/torture/rpc/lsa.c
+++ b/source4/torture/rpc/lsa.c
@@ -866,7 +866,7 @@ static bool test_LookupSids_async(struct dcerpc_binding_handle *b,
}
while (replies >= 0 && replies < num_async_requests) {
- event_loop_once(tctx->ev);
+ tevent_loop_once(tctx->ev);
}
talloc_free(req);
diff --git a/source4/torture/rpc/netlogon.c b/source4/torture/rpc/netlogon.c
index 70e1fd9ebbf..0fe594cf7ea 100644
--- a/source4/torture/rpc/netlogon.c
+++ b/source4/torture/rpc/netlogon.c
@@ -3453,8 +3453,8 @@ static bool test_GetDomainInfo_async(struct torture_context *tctx,
/* even with this flush per request a w2k3 server seems to
clag with multiple outstanding requests. bleergh. */
- torture_assert_int_equal(tctx, event_loop_once(dcerpc_event_context(p)), 0,
- "event_loop_once failed");
+ torture_assert_int_equal(tctx, tevent_loop_once(dcerpc_event_context(p)), 0,
+ "tevent_loop_once failed");
}
for (i=0;i<ASYNC_COUNT;i++) {
diff --git a/source4/torture/rpc/schannel.c b/source4/torture/rpc/schannel.c
index 245f33c991b..3bfed696e89 100644
--- a/source4/torture/rpc/schannel.c
+++ b/source4/torture/rpc/schannel.c
@@ -763,8 +763,8 @@ bool torture_rpc_schannel_bench1(struct torture_context *torture)
}
while (NT_STATUS_IS_OK(s->error) && s->nprocs != s->nconns) {
- int ev_ret = event_loop_once(torture->ev);
- torture_assert(torture, ev_ret == 0, "event_loop_once failed");
+ int ev_ret = tevent_loop_once(torture->ev);
+ torture_assert(torture, ev_ret == 0, "tevent_loop_once failed");
#endif
}
torture_assert_ntstatus_ok(torture, s->error, "Failed establish a connect");
@@ -851,8 +851,8 @@ bool torture_rpc_schannel_bench1(struct torture_context *torture)
end = timeval_add(&start, s->timelimit, 0);
while (NT_STATUS_IS_OK(s->error) && !timeval_expired(&end)) {
- int ev_ret = event_loop_once(torture->ev);
- torture_assert(torture, ev_ret == 0, "event_loop_once failed");
+ int ev_ret = tevent_loop_once(torture->ev);
+ torture_assert(torture, ev_ret == 0, "tevent_loop_once failed");
}
torture_assert_ntstatus_ok(torture, s->error, "Failed some request");
s->stopped = true;
diff --git a/source4/torture/smb2/create.c b/source4/torture/smb2/create.c
index f11c8375b19..47d61158c8b 100644
--- a/source4/torture/smb2/create.c
+++ b/source4/torture/smb2/create.c
@@ -966,8 +966,8 @@ static bool test_smb2_open_multi(struct torture_context *tctx,
break;
}
- if (event_loop_once(tctx->ev) != 0) {
- torture_comment(tctx, "event_loop_once failed\n");
+ if (tevent_loop_once(tctx->ev) != 0) {
+ torture_comment(tctx, "tevent_loop_once failed\n");
ret = false;
goto done;
}
diff --git a/source4/torture/smb2/lock.c b/source4/torture/smb2/lock.c
index 348312657b4..5bccf04f438 100644
--- a/source4/torture/smb2/lock.c
+++ b/source4/torture/smb2/lock.c
@@ -62,7 +62,7 @@
#define WAIT_FOR_ASYNC_RESPONSE(req) \
while (!req->cancel.can_cancel && req->state <= SMB2_REQUEST_RECV) { \
- if (event_loop_once(req->transport->socket->event.ctx) != 0) { \
+ if (tevent_loop_once(req->transport->socket->event.ctx) != 0) { \
break; \
} \
}
diff --git a/source4/torture/smb2/notify.c b/source4/torture/smb2/notify.c
index 80c560be007..0f0e866098a 100644
--- a/source4/torture/smb2/notify.c
+++ b/source4/torture/smb2/notify.c
@@ -101,7 +101,7 @@ static bool test_valid_request(struct torture_context *torture,
req = smb2_notify_send(tree, &n);
while (!req->cancel.can_cancel && req->state <= SMB2_REQUEST_RECV) {
- if (event_loop_once(req->transport->socket->event.ctx) != 0) {
+ if (tevent_loop_once(req->transport->socket->event.ctx) != 0) {
break;
}
}
@@ -123,7 +123,7 @@ static bool test_valid_request(struct torture_context *torture,
req = smb2_notify_send(tree, &n);
while (!req->cancel.can_cancel && req->state <= SMB2_REQUEST_RECV) {
- if (event_loop_once(req->transport->socket->event.ctx) != 0) {
+ if (tevent_loop_once(req->transport->socket->event.ctx) != 0) {
break;
}
}
@@ -142,7 +142,7 @@ static bool test_valid_request(struct torture_context *torture,
req = smb2_notify_send(tree, &n);
while (!req->cancel.can_cancel && req->state <= SMB2_REQUEST_RECV) {
- if (event_loop_once(req->transport->socket->event.ctx) != 0) {
+ if (tevent_loop_once(req->transport->socket->event.ctx) != 0) {
break;
}
}
@@ -174,7 +174,7 @@ static bool test_valid_request(struct torture_context *torture,
req = smb2_notify_send(tree, &n);
while (!req->cancel.can_cancel && req->state <= SMB2_REQUEST_RECV) {
- if (event_loop_once(req->transport->socket->event.ctx) != 0) {
+ if (tevent_loop_once(req->transport->socket->event.ctx) != 0) {
break;
}
}
@@ -188,7 +188,7 @@ static bool test_valid_request(struct torture_context *torture,
n.in.buffer_size = max_buffer_size;
req = smb2_notify_send(tree, &n);
while (!req->cancel.can_cancel && req->state <= SMB2_REQUEST_RECV) {
- if (event_loop_once(req->transport->socket->event.ctx) != 0) {
+ if (tevent_loop_once(req->transport->socket->event.ctx) != 0) {
break;
}
}
diff --git a/source4/torture/smb2/oplock.c b/source4/torture/smb2/oplock.c
index eeea03639ab..2d74c5d1f48 100644
--- a/source4/torture/smb2/oplock.c
+++ b/source4/torture/smb2/oplock.c
@@ -329,7 +329,7 @@ static void torture_wait_for_oplock_break(struct torture_context *tctx)
/* Wait .1 seconds for an oplock break */
ne = tevent_timeval_current_ofs(0, 100000);
- if ((te = event_add_timed(tctx->ev, tmp_ctx, ne, timeout_cb, &timesup))
+ if ((te = tevent_add_timer(tctx->ev, tmp_ctx, ne, timeout_cb, &timesup))
== NULL)
{
torture_comment(tctx, "Failed to wait for an oplock break. "
@@ -338,7 +338,7 @@ static void torture_wait_for_oplock_break(struct torture_context *tctx)
}
while (!timesup && break_info.count < old_count + 1) {
- if (event_loop_once(tctx->ev) != 0) {
+ if (tevent_loop_once(tctx->ev) != 0) {
torture_comment(tctx, "Failed to wait for an oplock "
"break. test results may not be "
"accurate.");
@@ -3606,7 +3606,7 @@ bool test_smb2_hold_oplock(struct torture_context *tctx,
}
torture_comment(tctx, "Waiting for oplock events\n");
- event_loop_wait(ev);
+ tevent_loop_wait(ev);
smb2_deltree(tree, BASEDIR);
talloc_free(mem_ctx);
return true;
View Lorry Controller Status