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);
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);
}
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;
}
}
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);
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);
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;
}
return;
}
- if (flags & EVENT_FD_READ) {
+ if (flags & TEVENT_FD_READ) {
packet_recv(sock->packet);
}
}
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;