diff options
-rw-r--r-- | source4/librpc/rpc/dcerpc.c | 8 | ||||
-rw-r--r-- | source4/librpc/rpc/dcerpc_connect.c | 2 | ||||
-rw-r--r-- | source4/librpc/rpc/dcerpc_sock.c | 8 |
3 files changed, 9 insertions, 9 deletions
diff --git a/source4/librpc/rpc/dcerpc.c b/source4/librpc/rpc/dcerpc.c index 496cc0b2a6..77b1d29236 100644 --- a/source4/librpc/rpc/dcerpc.c +++ b/source4/librpc/rpc/dcerpc.c @@ -1180,7 +1180,7 @@ struct composite_context *dcerpc_bind_send(struct dcerpc_pipe *p, true); if (!composite_is_ok(c)) return c; - event_add_timed(c->event_ctx, req, + tevent_add_timer(c->event_ctx, req, timeval_current_ofs(DCERPC_REQUEST_TIMEOUT, 0), dcerpc_timeout_handler, req); @@ -1413,7 +1413,7 @@ static struct rpc_request *dcerpc_request_send(struct dcerpc_pipe *p, dcerpc_ship_next_request(p->conn); if (p->request_timeout) { - event_add_timed(dcerpc_event_context(p), req, + tevent_add_timer(dcerpc_event_context(p), req, timeval_current_ofs(p->request_timeout, 0), dcerpc_timeout_handler, req); } @@ -1560,7 +1560,7 @@ static NTSTATUS dcerpc_request_recv(struct rpc_request *req, while (req->state != RPC_REQUEST_DONE) { struct tevent_context *ctx = dcerpc_event_context(req->p); - if (event_loop_once(ctx) != 0) { + if (tevent_loop_once(ctx) != 0) { return NT_STATUS_CONNECTION_DISCONNECTED; } } @@ -1931,7 +1931,7 @@ struct composite_context *dcerpc_alter_context_send(struct dcerpc_pipe *p, c->status = p->conn->transport.send_request(p->conn, &blob, true); if (!composite_is_ok(c)) return c; - event_add_timed(c->event_ctx, req, + tevent_add_timer(c->event_ctx, req, timeval_current_ofs(DCERPC_REQUEST_TIMEOUT, 0), dcerpc_timeout_handler, req); diff --git a/source4/librpc/rpc/dcerpc_connect.c b/source4/librpc/rpc/dcerpc_connect.c index c236399b52..dc70736e3f 100644 --- a/source4/librpc/rpc/dcerpc_connect.c +++ b/source4/librpc/rpc/dcerpc_connect.c @@ -759,7 +759,7 @@ _PUBLIC_ struct composite_context* dcerpc_pipe_connect_b_send(TALLOC_CTX *parent s->credentials = credentials; s->lp_ctx = lp_ctx; - event_add_timed(c->event_ctx, c, + tevent_add_timer(c->event_ctx, c, timeval_current_ofs(DCERPC_REQUEST_TIMEOUT, 0), dcerpc_connect_timeout_handler, c); diff --git a/source4/librpc/rpc/dcerpc_sock.c b/source4/librpc/rpc/dcerpc_sock.c index 1dd993d94b..d0d28bc47e 100644 --- a/source4/librpc/rpc/dcerpc_sock.c +++ b/source4/librpc/rpc/dcerpc_sock.c @@ -134,7 +134,7 @@ static void sock_io_handler(struct tevent_context *ev, struct tevent_fd *fde, struct dcecli_connection); struct sock_private *sock = (struct sock_private *)p->transport.private_data; - if (flags & EVENT_FD_WRITE) { + if (flags & TEVENT_FD_WRITE) { packet_queue_run(sock->packet); return; } @@ -143,7 +143,7 @@ static void sock_io_handler(struct tevent_context *ev, struct tevent_fd *fde, return; } - if (flags & EVENT_FD_READ) { + if (flags & TEVENT_FD_READ) { packet_recv(sock->packet); } } @@ -276,8 +276,8 @@ static void continue_socket_connect(struct composite_context *ctx) sock->pending_reads = 0; sock->server_name = strupper_talloc(sock, s->target_hostname); - sock->fde = event_add_fd(conn->event_ctx, sock->sock, socket_get_fd(sock->sock), - EVENT_FD_READ, sock_io_handler, conn); + sock->fde = tevent_add_fd(conn->event_ctx, sock->sock, socket_get_fd(sock->sock), + TEVENT_FD_READ, sock_io_handler, conn); conn->transport.private_data = sock; |