mirror of
https://github.com/libevent/libevent.git
synced 2025-01-31 09:12:55 +08:00
Fix non-std printf %p arguments (#1327)
* Fix non-std printf %p arguments when running with -Werror -pedantic-errors Co-authored-by: Mareks Malnacs <mareks.malnacs>
This commit is contained in:
parent
bb57cea387
commit
b19af675c7
@ -501,7 +501,7 @@ bufferevent_enable(struct bufferevent *bufev, short event)
|
|||||||
if (impl_events && bufev->be_ops->enable(bufev, impl_events) < 0)
|
if (impl_events && bufev->be_ops->enable(bufev, impl_events) < 0)
|
||||||
r = -1;
|
r = -1;
|
||||||
if (r)
|
if (r)
|
||||||
event_debug(("%s: cannot enable 0x%hx on %p", __func__, event, bufev));
|
event_debug(("%s: cannot enable 0x%hx on %p", __func__, event, (void *)bufev));
|
||||||
|
|
||||||
bufferevent_decref_and_unlock_(bufev);
|
bufferevent_decref_and_unlock_(bufev);
|
||||||
return r;
|
return r;
|
||||||
@ -585,7 +585,7 @@ bufferevent_disable(struct bufferevent *bufev, short event)
|
|||||||
if (bufev->be_ops->disable(bufev, event) < 0)
|
if (bufev->be_ops->disable(bufev, event) < 0)
|
||||||
r = -1;
|
r = -1;
|
||||||
if (r)
|
if (r)
|
||||||
event_debug(("%s: cannot disable 0x%hx on %p", __func__, event, bufev));
|
event_debug(("%s: cannot disable 0x%hx on %p", __func__, event, (void *)bufev));
|
||||||
|
|
||||||
BEV_UNLOCK(bufev);
|
BEV_UNLOCK(bufev);
|
||||||
return r;
|
return r;
|
||||||
@ -876,7 +876,7 @@ bufferevent_setfd(struct bufferevent *bev, evutil_socket_t fd)
|
|||||||
if (bev->be_ops->ctrl)
|
if (bev->be_ops->ctrl)
|
||||||
res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d);
|
res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d);
|
||||||
if (res)
|
if (res)
|
||||||
event_debug(("%s: cannot set fd for %p to "EV_SOCK_FMT, __func__, bev, fd));
|
event_debug(("%s: cannot set fd for %p to "EV_SOCK_FMT, __func__, (void *)bev, fd));
|
||||||
BEV_UNLOCK(bev);
|
BEV_UNLOCK(bev);
|
||||||
return res;
|
return res;
|
||||||
}
|
}
|
||||||
@ -903,7 +903,7 @@ bufferevent_replacefd(struct bufferevent *bev, evutil_socket_t fd)
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (err)
|
if (err)
|
||||||
event_debug(("%s: cannot replace fd for %p from "EV_SOCK_FMT" to "EV_SOCK_FMT, __func__, bev, old_fd, fd));
|
event_debug(("%s: cannot replace fd for %p from "EV_SOCK_FMT" to "EV_SOCK_FMT, __func__, (void *)bev, old_fd, fd));
|
||||||
BEV_UNLOCK(bev);
|
BEV_UNLOCK(bev);
|
||||||
|
|
||||||
return err;
|
return err;
|
||||||
@ -919,7 +919,7 @@ bufferevent_getfd(struct bufferevent *bev)
|
|||||||
if (bev->be_ops->ctrl)
|
if (bev->be_ops->ctrl)
|
||||||
res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d);
|
res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d);
|
||||||
if (res)
|
if (res)
|
||||||
event_debug(("%s: cannot get fd for %p", __func__, bev));
|
event_debug(("%s: cannot get fd for %p", __func__, (void *)bev));
|
||||||
BEV_UNLOCK(bev);
|
BEV_UNLOCK(bev);
|
||||||
return (res<0) ? -1 : d.fd;
|
return (res<0) ? -1 : d.fd;
|
||||||
}
|
}
|
||||||
|
30
evdns.c
30
evdns.c
@ -854,7 +854,7 @@ request_finished(struct request *const req, struct request **head, int free_hand
|
|||||||
if (head)
|
if (head)
|
||||||
evdns_request_remove(req, head);
|
evdns_request_remove(req, head);
|
||||||
|
|
||||||
log(EVDNS_LOG_DEBUG, "Removing timeout for request %p", req);
|
log(EVDNS_LOG_DEBUG, "Removing timeout for request %p", (void *)req);
|
||||||
if (was_inflight) {
|
if (was_inflight) {
|
||||||
evtimer_del(&req->timeout_event);
|
evtimer_del(&req->timeout_event);
|
||||||
base->global_requests_inflight--;
|
base->global_requests_inflight--;
|
||||||
@ -1755,7 +1755,7 @@ server_send_response(struct evdns_server_port *port, struct server_request *req)
|
|||||||
}
|
}
|
||||||
|
|
||||||
beferevent_error:
|
beferevent_error:
|
||||||
log(EVDNS_LOG_WARN, "Failed to send reply to request %p for client %p", req, req->client);
|
log(EVDNS_LOG_WARN, "Failed to send reply to request %p for client %p", (void *)req, (void *)req->client);
|
||||||
/* disconnect if we got bufferevent error */
|
/* disconnect if we got bufferevent error */
|
||||||
evdns_remove_tcp_client(port, req->client);
|
evdns_remove_tcp_client(port, req->client);
|
||||||
return -1;
|
return -1;
|
||||||
@ -2196,7 +2196,7 @@ server_tcp_read_packet_cb(struct bufferevent *bev, void *ctx)
|
|||||||
|
|
||||||
while (1) {
|
while (1) {
|
||||||
if (tcp_read_message(conn, &msg, &msg_len)) {
|
if (tcp_read_message(conn, &msg, &msg_len)) {
|
||||||
log(EVDNS_LOG_MSG, "Closing client connection %p due to error", bev);
|
log(EVDNS_LOG_MSG, "Closing client connection %p due to error", (void *)bev);
|
||||||
evdns_remove_tcp_client(port, client);
|
evdns_remove_tcp_client(port, client);
|
||||||
rc = port->refcnt;
|
rc = port->refcnt;
|
||||||
EVDNS_UNLOCK(port);
|
EVDNS_UNLOCK(port);
|
||||||
@ -2230,7 +2230,7 @@ server_tcp_event_cb(struct bufferevent *bev, short events, void *ctx)
|
|||||||
EVUTIL_ASSERT(port && bev);
|
EVUTIL_ASSERT(port && bev);
|
||||||
EVDNS_LOCK(port);
|
EVDNS_LOCK(port);
|
||||||
if (events & (BEV_EVENT_EOF | BEV_EVENT_ERROR | BEV_EVENT_TIMEOUT)) {
|
if (events & (BEV_EVENT_EOF | BEV_EVENT_ERROR | BEV_EVENT_TIMEOUT)) {
|
||||||
log(EVDNS_LOG_DEBUG, "Closing connection %p", bev);
|
log(EVDNS_LOG_DEBUG, "Closing connection %p", (void *)bev);
|
||||||
evdns_remove_tcp_client(port, client);
|
evdns_remove_tcp_client(port, client);
|
||||||
}
|
}
|
||||||
rc = port->refcnt;
|
rc = port->refcnt;
|
||||||
@ -2250,7 +2250,7 @@ incoming_conn_cb(struct evconnlistener *listener, evutil_socket_t fd,
|
|||||||
|
|
||||||
if (!bev)
|
if (!bev)
|
||||||
goto error;
|
goto error;
|
||||||
log(EVDNS_LOG_DEBUG, "New incoming client connection %p", bev);
|
log(EVDNS_LOG_DEBUG, "New incoming client connection %p", (void *)bev);
|
||||||
|
|
||||||
bufferevent_set_timeouts(bev, &port->tcp_idle_timeout, &port->tcp_idle_timeout);
|
bufferevent_set_timeouts(bev, &port->tcp_idle_timeout, &port->tcp_idle_timeout);
|
||||||
|
|
||||||
@ -2721,7 +2721,7 @@ retransmit_all_tcp_requests_for(struct nameserver *server)
|
|||||||
if (req->ns == server && (req->handle->tcp_flags & DNS_QUERY_USEVC)) {
|
if (req->ns == server && (req->handle->tcp_flags & DNS_QUERY_USEVC)) {
|
||||||
if (req->tx_count >= req->base->global_max_retransmits) {
|
if (req->tx_count >= req->base->global_max_retransmits) {
|
||||||
log(EVDNS_LOG_DEBUG, "Giving up on request %p; tx_count==%d",
|
log(EVDNS_LOG_DEBUG, "Giving up on request %p; tx_count==%d",
|
||||||
req, req->tx_count);
|
(void *)req, req->tx_count);
|
||||||
reply_schedule_callback(req, 0, DNS_ERR_TIMEOUT, NULL);
|
reply_schedule_callback(req, 0, DNS_ERR_TIMEOUT, NULL);
|
||||||
request_finished(req, &REQ_HEAD(req->base, req->trans_id), 1);
|
request_finished(req, &REQ_HEAD(req->base, req->trans_id), 1);
|
||||||
} else {
|
} else {
|
||||||
@ -2843,7 +2843,7 @@ evdns_tcp_connect_if_disconnected(struct nameserver *server)
|
|||||||
return 1;
|
return 1;
|
||||||
|
|
||||||
conn->state = TS_CONNECTING;
|
conn->state = TS_CONNECTING;
|
||||||
log(EVDNS_LOG_DEBUG, "New tcp connection %p created", conn);
|
log(EVDNS_LOG_DEBUG, "New tcp connection %p created", (void *)conn);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -2893,7 +2893,7 @@ client_tcp_event_cb(struct bufferevent *bev, short events, void *ctx) {
|
|||||||
EVDNS_LOCK(server->base);
|
EVDNS_LOCK(server->base);
|
||||||
EVUTIL_ASSERT(conn && conn->bev == bev && bev);
|
EVUTIL_ASSERT(conn && conn->bev == bev && bev);
|
||||||
|
|
||||||
log(EVDNS_LOG_DEBUG, "Event %d on connection %p", events, conn);
|
log(EVDNS_LOG_DEBUG, "Event %d on connection %p", events, (void *)conn);
|
||||||
|
|
||||||
if (events & (BEV_EVENT_TIMEOUT)) {
|
if (events & (BEV_EVENT_TIMEOUT)) {
|
||||||
disconnect_and_free_connection(server->connection);
|
disconnect_and_free_connection(server->connection);
|
||||||
@ -2931,7 +2931,7 @@ evdns_request_transmit_through_tcp(struct request *req, struct nameserver *serve
|
|||||||
conn = server->connection;
|
conn = server->connection;
|
||||||
bufferevent_setcb(conn->bev, client_tcp_read_packet_cb, NULL, client_tcp_event_cb, server);
|
bufferevent_setcb(conn->bev, client_tcp_read_packet_cb, NULL, client_tcp_event_cb, server);
|
||||||
|
|
||||||
log(EVDNS_LOG_DEBUG, "Sending request %p via tcp connection %p", req, conn);
|
log(EVDNS_LOG_DEBUG, "Sending request %p via tcp connection %p", (void *)req, (void *)conn);
|
||||||
packet_size = htons(req->request_len);
|
packet_size = htons(req->request_len);
|
||||||
if (bufferevent_write(conn->bev, &packet_size, sizeof(packet_size)) )
|
if (bufferevent_write(conn->bev, &packet_size, sizeof(packet_size)) )
|
||||||
goto fail;
|
goto fail;
|
||||||
@ -2944,7 +2944,7 @@ evdns_request_transmit_through_tcp(struct request *req, struct nameserver *serve
|
|||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
fail:
|
fail:
|
||||||
log(EVDNS_LOG_WARN, "Failed to send request %p via tcp connection %p", req, conn);
|
log(EVDNS_LOG_WARN, "Failed to send request %p via tcp connection %p", (void *)req, (void *)conn);
|
||||||
disconnect_and_free_connection(server->connection);
|
disconnect_and_free_connection(server->connection);
|
||||||
server->connection = NULL;
|
server->connection = NULL;
|
||||||
return 2;
|
return 2;
|
||||||
@ -3006,11 +3006,11 @@ evdns_request_transmit(struct request *req) {
|
|||||||
default:
|
default:
|
||||||
/* all ok */
|
/* all ok */
|
||||||
log(EVDNS_LOG_DEBUG,
|
log(EVDNS_LOG_DEBUG,
|
||||||
"Setting timeout for request %p, sent to nameserver %p", req, req->ns);
|
"Setting timeout for request %p, sent to nameserver %p", (void *)req, (void *)req->ns);
|
||||||
if (evtimer_add(&req->timeout_event, &req->base->global_timeout) < 0) {
|
if (evtimer_add(&req->timeout_event, &req->base->global_timeout) < 0) {
|
||||||
log(EVDNS_LOG_WARN,
|
log(EVDNS_LOG_WARN,
|
||||||
"Error from libevent when adding timer for request %p",
|
"Error from libevent when adding timer for request %p",
|
||||||
req);
|
(void *)req);
|
||||||
/* ???? Do more? */
|
/* ???? Do more? */
|
||||||
}
|
}
|
||||||
req->tx_count++;
|
req->tx_count++;
|
||||||
@ -3290,7 +3290,7 @@ evdns_nameserver_add_impl_(struct evdns_base *base, const struct sockaddr *addre
|
|||||||
}
|
}
|
||||||
|
|
||||||
log(EVDNS_LOG_DEBUG, "Added nameserver %s as %p",
|
log(EVDNS_LOG_DEBUG, "Added nameserver %s as %p",
|
||||||
evutil_format_sockaddr_port_(address, addrbuf, sizeof(addrbuf)), ns);
|
evutil_format_sockaddr_port_(address, addrbuf, sizeof(addrbuf)), (void *)ns);
|
||||||
|
|
||||||
/* insert this nameserver into the list of them */
|
/* insert this nameserver into the list of them */
|
||||||
if (!base->server_head) {
|
if (!base->server_head) {
|
||||||
@ -5670,7 +5670,7 @@ evdns_getaddrinfo(struct evdns_base *dns_base,
|
|||||||
|
|
||||||
if (hints.ai_family != PF_INET6) {
|
if (hints.ai_family != PF_INET6) {
|
||||||
log(EVDNS_LOG_DEBUG, "Sending request for %s on ipv4 as %p",
|
log(EVDNS_LOG_DEBUG, "Sending request for %s on ipv4 as %p",
|
||||||
nodename, &data->ipv4_request);
|
nodename, (void *)&data->ipv4_request);
|
||||||
|
|
||||||
data->ipv4_request.r = evdns_base_resolve_ipv4(dns_base,
|
data->ipv4_request.r = evdns_base_resolve_ipv4(dns_base,
|
||||||
nodename, 0, evdns_getaddrinfo_gotresolve,
|
nodename, 0, evdns_getaddrinfo_gotresolve,
|
||||||
@ -5681,7 +5681,7 @@ evdns_getaddrinfo(struct evdns_base *dns_base,
|
|||||||
}
|
}
|
||||||
if (hints.ai_family != PF_INET) {
|
if (hints.ai_family != PF_INET) {
|
||||||
log(EVDNS_LOG_DEBUG, "Sending request for %s on ipv6 as %p",
|
log(EVDNS_LOG_DEBUG, "Sending request for %s on ipv6 as %p",
|
||||||
nodename, &data->ipv6_request);
|
nodename, (void *)&data->ipv6_request);
|
||||||
|
|
||||||
data->ipv6_request.r = evdns_base_resolve_ipv6(dns_base,
|
data->ipv6_request.r = evdns_base_resolve_ipv6(dns_base,
|
||||||
nodename, 0, evdns_getaddrinfo_gotresolve,
|
nodename, 0, evdns_getaddrinfo_gotresolve,
|
||||||
|
42
event.c
42
event.c
@ -302,7 +302,7 @@ static void event_debug_note_add_(const struct event *ev)
|
|||||||
"%s: noting an add on a non-setup event %p"
|
"%s: noting an add on a non-setup event %p"
|
||||||
" (events: 0x%x, fd: "EV_SOCK_FMT
|
" (events: 0x%x, fd: "EV_SOCK_FMT
|
||||||
", flags: 0x%x)",
|
", flags: 0x%x)",
|
||||||
__func__, ev, ev->ev_events,
|
__func__, (void *)ev, ev->ev_events,
|
||||||
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
||||||
}
|
}
|
||||||
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
||||||
@ -328,7 +328,7 @@ static void event_debug_note_del_(const struct event *ev)
|
|||||||
"%s: noting a del on a non-setup event %p"
|
"%s: noting a del on a non-setup event %p"
|
||||||
" (events: 0x%x, fd: "EV_SOCK_FMT
|
" (events: 0x%x, fd: "EV_SOCK_FMT
|
||||||
", flags: 0x%x)",
|
", flags: 0x%x)",
|
||||||
__func__, ev, ev->ev_events,
|
__func__, (void *)ev, ev->ev_events,
|
||||||
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
||||||
}
|
}
|
||||||
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
||||||
@ -352,7 +352,7 @@ static void event_debug_assert_is_setup_(const struct event *ev)
|
|||||||
"%s called on a non-initialized event %p"
|
"%s called on a non-initialized event %p"
|
||||||
" (events: 0x%x, fd: "EV_SOCK_FMT
|
" (events: 0x%x, fd: "EV_SOCK_FMT
|
||||||
", flags: 0x%x)",
|
", flags: 0x%x)",
|
||||||
__func__, ev, ev->ev_events,
|
__func__, (void *)ev, ev->ev_events,
|
||||||
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
||||||
}
|
}
|
||||||
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
||||||
@ -373,7 +373,7 @@ static void event_debug_assert_not_added_(const struct event *ev)
|
|||||||
"%s called on an already added event %p"
|
"%s called on an already added event %p"
|
||||||
" (events: 0x%x, fd: "EV_SOCK_FMT", "
|
" (events: 0x%x, fd: "EV_SOCK_FMT", "
|
||||||
"flags: 0x%x)",
|
"flags: 0x%x)",
|
||||||
__func__, ev, ev->ev_events,
|
__func__, (void *)ev, ev->ev_events,
|
||||||
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
EV_SOCK_ARG(ev->ev_fd), ev->ev_flags);
|
||||||
}
|
}
|
||||||
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
EVLOCK_UNLOCK(event_debug_map_lock_, 0);
|
||||||
@ -1673,16 +1673,16 @@ event_process_active_single_queue(struct event_base *base,
|
|||||||
event_del_nolock_(ev, EVENT_DEL_NOBLOCK);
|
event_del_nolock_(ev, EVENT_DEL_NOBLOCK);
|
||||||
event_debug((
|
event_debug((
|
||||||
"event_process_active: event: %p, %s%s%scall %p",
|
"event_process_active: event: %p, %s%s%scall %p",
|
||||||
ev,
|
(void *)ev,
|
||||||
ev->ev_res & EV_READ ? "EV_READ " : " ",
|
ev->ev_res & EV_READ ? "EV_READ " : " ",
|
||||||
ev->ev_res & EV_WRITE ? "EV_WRITE " : " ",
|
ev->ev_res & EV_WRITE ? "EV_WRITE " : " ",
|
||||||
ev->ev_res & EV_CLOSED ? "EV_CLOSED " : " ",
|
ev->ev_res & EV_CLOSED ? "EV_CLOSED " : " ",
|
||||||
ev->ev_callback));
|
(void *)ev->ev_callback));
|
||||||
} else {
|
} else {
|
||||||
event_queue_remove_active(base, evcb);
|
event_queue_remove_active(base, evcb);
|
||||||
event_debug(("event_process_active: event_callback %p, "
|
event_debug(("event_process_active: event_callback %p, "
|
||||||
"closure %d, call %p",
|
"closure %d, call %p",
|
||||||
evcb, evcb->evcb_closure, evcb->evcb_cb_union.evcb_callback));
|
(void *)evcb, evcb->evcb_closure, (void *)evcb->evcb_cb_union.evcb_callback));
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!(evcb->evcb_flags & EVLIST_INTERNAL))
|
if (!(evcb->evcb_flags & EVLIST_INTERNAL))
|
||||||
@ -2600,7 +2600,7 @@ event_remove_timer_nolock_(struct event *ev)
|
|||||||
EVENT_BASE_ASSERT_LOCKED(base);
|
EVENT_BASE_ASSERT_LOCKED(base);
|
||||||
event_debug_assert_is_setup_(ev);
|
event_debug_assert_is_setup_(ev);
|
||||||
|
|
||||||
event_debug(("event_remove_timer_nolock: event: %p", ev));
|
event_debug(("event_remove_timer_nolock: event: %p", (void *)ev));
|
||||||
|
|
||||||
/* If it's not pending on a timeout, we don't need to do anything. */
|
/* If it's not pending on a timeout, we don't need to do anything. */
|
||||||
if (ev->ev_flags & EVLIST_TIMEOUT) {
|
if (ev->ev_flags & EVLIST_TIMEOUT) {
|
||||||
@ -2647,13 +2647,13 @@ event_add_nolock_(struct event *ev, const struct timeval *tv,
|
|||||||
|
|
||||||
event_debug((
|
event_debug((
|
||||||
"event_add: event: %p (fd "EV_SOCK_FMT"), %s%s%s%scall %p",
|
"event_add: event: %p (fd "EV_SOCK_FMT"), %s%s%s%scall %p",
|
||||||
ev,
|
(void *)ev,
|
||||||
EV_SOCK_ARG(ev->ev_fd),
|
EV_SOCK_ARG(ev->ev_fd),
|
||||||
ev->ev_events & EV_READ ? "EV_READ " : " ",
|
ev->ev_events & EV_READ ? "EV_READ " : " ",
|
||||||
ev->ev_events & EV_WRITE ? "EV_WRITE " : " ",
|
ev->ev_events & EV_WRITE ? "EV_WRITE " : " ",
|
||||||
ev->ev_events & EV_CLOSED ? "EV_CLOSED " : " ",
|
ev->ev_events & EV_CLOSED ? "EV_CLOSED " : " ",
|
||||||
tv ? "EV_TIMEOUT " : " ",
|
tv ? "EV_TIMEOUT " : " ",
|
||||||
ev->ev_callback));
|
(void *)ev->ev_callback));
|
||||||
|
|
||||||
EVUTIL_ASSERT(!(ev->ev_flags & ~EVLIST_ALL));
|
EVUTIL_ASSERT(!(ev->ev_flags & ~EVLIST_ALL));
|
||||||
|
|
||||||
@ -2767,7 +2767,7 @@ event_add_nolock_(struct event *ev, const struct timeval *tv,
|
|||||||
|
|
||||||
event_debug((
|
event_debug((
|
||||||
"event_add: event %p, timeout in %d seconds %d useconds, call %p",
|
"event_add: event %p, timeout in %d seconds %d useconds, call %p",
|
||||||
ev, (int)tv->tv_sec, (int)tv->tv_usec, ev->ev_callback));
|
(void *)ev, (int)tv->tv_sec, (int)tv->tv_usec, (void *)ev->ev_callback));
|
||||||
|
|
||||||
#ifdef USE_REINSERT_TIMEOUT
|
#ifdef USE_REINSERT_TIMEOUT
|
||||||
event_queue_reinsert_timeout(base, ev, was_common, common_timeout, old_timeout_idx);
|
event_queue_reinsert_timeout(base, ev, was_common, common_timeout, old_timeout_idx);
|
||||||
@ -2854,7 +2854,7 @@ event_del_nolock_(struct event *ev, int blocking)
|
|||||||
int res = 0, notify = 0;
|
int res = 0, notify = 0;
|
||||||
|
|
||||||
event_debug(("event_del: %p (fd "EV_SOCK_FMT"), callback %p",
|
event_debug(("event_del: %p (fd "EV_SOCK_FMT"), callback %p",
|
||||||
ev, EV_SOCK_ARG(ev->ev_fd), ev->ev_callback));
|
(void *)ev, EV_SOCK_ARG(ev->ev_fd), (void *)ev->ev_callback));
|
||||||
|
|
||||||
/* An event without a base has not been added */
|
/* An event without a base has not been added */
|
||||||
if (ev->ev_base == NULL)
|
if (ev->ev_base == NULL)
|
||||||
@ -2962,7 +2962,7 @@ event_active_nolock_(struct event *ev, int res, short ncalls)
|
|||||||
struct event_base *base;
|
struct event_base *base;
|
||||||
|
|
||||||
event_debug(("event_active: %p (fd "EV_SOCK_FMT"), res %d, callback %p",
|
event_debug(("event_active: %p (fd "EV_SOCK_FMT"), res %d, callback %p",
|
||||||
ev, EV_SOCK_ARG(ev->ev_fd), (int)res, ev->ev_callback));
|
(void *)ev, EV_SOCK_ARG(ev->ev_fd), (int)res, (void *)ev->ev_callback));
|
||||||
|
|
||||||
base = ev->ev_base;
|
base = ev->ev_base;
|
||||||
EVENT_BASE_ASSERT_LOCKED(base);
|
EVENT_BASE_ASSERT_LOCKED(base);
|
||||||
@ -3211,7 +3211,7 @@ timeout_next(struct event_base *base, struct timeval **tv_p)
|
|||||||
|
|
||||||
EVUTIL_ASSERT(tv->tv_sec >= 0);
|
EVUTIL_ASSERT(tv->tv_sec >= 0);
|
||||||
EVUTIL_ASSERT(tv->tv_usec >= 0);
|
EVUTIL_ASSERT(tv->tv_usec >= 0);
|
||||||
event_debug(("timeout_next: event: %p, in %d seconds, %d useconds", ev, (int)tv->tv_sec, (int)tv->tv_usec));
|
event_debug(("timeout_next: event: %p, in %d seconds, %d useconds", (void *)ev, (int)tv->tv_sec, (int)tv->tv_usec));
|
||||||
|
|
||||||
out:
|
out:
|
||||||
return (res);
|
return (res);
|
||||||
@ -3239,7 +3239,7 @@ timeout_process(struct event_base *base)
|
|||||||
event_del_nolock_(ev, EVENT_DEL_NOBLOCK);
|
event_del_nolock_(ev, EVENT_DEL_NOBLOCK);
|
||||||
|
|
||||||
event_debug(("timeout_process: event: %p, call %p",
|
event_debug(("timeout_process: event: %p, call %p",
|
||||||
ev, ev->ev_callback));
|
(void *)ev, (void *)ev->ev_callback));
|
||||||
event_active_nolock_(ev, EV_TIMEOUT, 1);
|
event_active_nolock_(ev, EV_TIMEOUT, 1);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -3267,7 +3267,7 @@ event_queue_remove_inserted(struct event_base *base, struct event *ev)
|
|||||||
EVENT_BASE_ASSERT_LOCKED(base);
|
EVENT_BASE_ASSERT_LOCKED(base);
|
||||||
if (EVUTIL_FAILURE_CHECK(!(ev->ev_flags & EVLIST_INSERTED))) {
|
if (EVUTIL_FAILURE_CHECK(!(ev->ev_flags & EVLIST_INSERTED))) {
|
||||||
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") not on queue %x", __func__,
|
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") not on queue %x", __func__,
|
||||||
ev, EV_SOCK_ARG(ev->ev_fd), EVLIST_INSERTED);
|
(void *)ev, EV_SOCK_ARG(ev->ev_fd), EVLIST_INSERTED);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
DECR_EVENT_COUNT(base, ev->ev_flags);
|
DECR_EVENT_COUNT(base, ev->ev_flags);
|
||||||
@ -3279,7 +3279,7 @@ event_queue_remove_active(struct event_base *base, struct event_callback *evcb)
|
|||||||
EVENT_BASE_ASSERT_LOCKED(base);
|
EVENT_BASE_ASSERT_LOCKED(base);
|
||||||
if (EVUTIL_FAILURE_CHECK(!(evcb->evcb_flags & EVLIST_ACTIVE))) {
|
if (EVUTIL_FAILURE_CHECK(!(evcb->evcb_flags & EVLIST_ACTIVE))) {
|
||||||
event_errx(1, "%s: %p not on queue %x", __func__,
|
event_errx(1, "%s: %p not on queue %x", __func__,
|
||||||
evcb, EVLIST_ACTIVE);
|
(void *)evcb, EVLIST_ACTIVE);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
DECR_EVENT_COUNT(base, evcb->evcb_flags);
|
DECR_EVENT_COUNT(base, evcb->evcb_flags);
|
||||||
@ -3295,7 +3295,7 @@ event_queue_remove_active_later(struct event_base *base, struct event_callback *
|
|||||||
EVENT_BASE_ASSERT_LOCKED(base);
|
EVENT_BASE_ASSERT_LOCKED(base);
|
||||||
if (EVUTIL_FAILURE_CHECK(!(evcb->evcb_flags & EVLIST_ACTIVE_LATER))) {
|
if (EVUTIL_FAILURE_CHECK(!(evcb->evcb_flags & EVLIST_ACTIVE_LATER))) {
|
||||||
event_errx(1, "%s: %p not on queue %x", __func__,
|
event_errx(1, "%s: %p not on queue %x", __func__,
|
||||||
evcb, EVLIST_ACTIVE_LATER);
|
(void *)evcb, EVLIST_ACTIVE_LATER);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
DECR_EVENT_COUNT(base, evcb->evcb_flags);
|
DECR_EVENT_COUNT(base, evcb->evcb_flags);
|
||||||
@ -3310,7 +3310,7 @@ event_queue_remove_timeout(struct event_base *base, struct event *ev)
|
|||||||
EVENT_BASE_ASSERT_LOCKED(base);
|
EVENT_BASE_ASSERT_LOCKED(base);
|
||||||
if (EVUTIL_FAILURE_CHECK(!(ev->ev_flags & EVLIST_TIMEOUT))) {
|
if (EVUTIL_FAILURE_CHECK(!(ev->ev_flags & EVLIST_TIMEOUT))) {
|
||||||
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") not on queue %x", __func__,
|
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") not on queue %x", __func__,
|
||||||
ev, EV_SOCK_ARG(ev->ev_fd), EVLIST_TIMEOUT);
|
(void *)ev, EV_SOCK_ARG(ev->ev_fd), EVLIST_TIMEOUT);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
DECR_EVENT_COUNT(base, ev->ev_flags);
|
DECR_EVENT_COUNT(base, ev->ev_flags);
|
||||||
@ -3405,7 +3405,7 @@ event_queue_insert_inserted(struct event_base *base, struct event *ev)
|
|||||||
|
|
||||||
if (EVUTIL_FAILURE_CHECK(ev->ev_flags & EVLIST_INSERTED)) {
|
if (EVUTIL_FAILURE_CHECK(ev->ev_flags & EVLIST_INSERTED)) {
|
||||||
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") already inserted", __func__,
|
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") already inserted", __func__,
|
||||||
ev, EV_SOCK_ARG(ev->ev_fd));
|
(void *)ev, EV_SOCK_ARG(ev->ev_fd));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -3459,7 +3459,7 @@ event_queue_insert_timeout(struct event_base *base, struct event *ev)
|
|||||||
|
|
||||||
if (EVUTIL_FAILURE_CHECK(ev->ev_flags & EVLIST_TIMEOUT)) {
|
if (EVUTIL_FAILURE_CHECK(ev->ev_flags & EVLIST_TIMEOUT)) {
|
||||||
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") already on timeout", __func__,
|
event_errx(1, "%s: %p(fd "EV_SOCK_FMT") already on timeout", __func__,
|
||||||
ev, EV_SOCK_ARG(ev->ev_fd));
|
(void *)ev, EV_SOCK_ARG(ev->ev_fd));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
8
http.c
8
http.c
@ -1742,7 +1742,7 @@ evhttp_parse_http_version(const char *version, struct evhttp_request *req)
|
|||||||
int n = sscanf(version, "HTTP/%d.%d%c", &major, &minor, &ch);
|
int n = sscanf(version, "HTTP/%d.%d%c", &major, &minor, &ch);
|
||||||
if (n != 2 || major > 1) {
|
if (n != 2 || major > 1) {
|
||||||
event_debug(("%s: bad version %s on message %p from %s",
|
event_debug(("%s: bad version %s on message %p from %s",
|
||||||
__func__, version, req, req->remote_host));
|
__func__, version, (void *)req, req->remote_host));
|
||||||
return (-1);
|
return (-1);
|
||||||
}
|
}
|
||||||
req->major = major;
|
req->major = major;
|
||||||
@ -2014,7 +2014,7 @@ evhttp_parse_request_line(struct evhttp_request *req, char *line, size_t len)
|
|||||||
|
|
||||||
if (!type) {
|
if (!type) {
|
||||||
event_debug(("%s: bad method %s on request %p from %s",
|
event_debug(("%s: bad method %s on request %p from %s",
|
||||||
__func__, method, req, req->remote_host));
|
__func__, method, (void *)req, req->remote_host));
|
||||||
/* No error yet; we'll give a better error later when
|
/* No error yet; we'll give a better error later when
|
||||||
* we see that req->type is unsupported. */
|
* we see that req->type is unsupported. */
|
||||||
}
|
}
|
||||||
@ -4433,7 +4433,7 @@ evhttp_request_set_on_complete_cb(struct evhttp_request *req,
|
|||||||
const char *
|
const char *
|
||||||
evhttp_request_get_uri(const struct evhttp_request *req) {
|
evhttp_request_get_uri(const struct evhttp_request *req) {
|
||||||
if (req->uri == NULL)
|
if (req->uri == NULL)
|
||||||
event_debug(("%s: request %p has no uri\n", __func__, req));
|
event_debug(("%s: request %p has no uri\n", __func__, (void *)req));
|
||||||
return (req->uri);
|
return (req->uri);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -4441,7 +4441,7 @@ const struct evhttp_uri *
|
|||||||
evhttp_request_get_evhttp_uri(const struct evhttp_request *req) {
|
evhttp_request_get_evhttp_uri(const struct evhttp_request *req) {
|
||||||
if (req->uri_elems == NULL)
|
if (req->uri_elems == NULL)
|
||||||
event_debug(("%s: request %p has no uri elems\n",
|
event_debug(("%s: request %p has no uri elems\n",
|
||||||
__func__, req));
|
__func__, (void *)req));
|
||||||
return (req->uri_elems);
|
return (req->uri_elems);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
2
signal.c
2
signal.c
@ -295,7 +295,7 @@ evsig_add(struct event_base *base, evutil_socket_t evsignal, short old, short ev
|
|||||||
"the most recently added signal or the most recent "
|
"the most recently added signal or the most recent "
|
||||||
"event_base_loop() call gets preference; do "
|
"event_base_loop() call gets preference; do "
|
||||||
"not rely on this behavior in future Libevent versions.",
|
"not rely on this behavior in future Libevent versions.",
|
||||||
base, evsig_base, base->evsel->name);
|
(void *)base, (void *)evsig_base, base->evsel->name);
|
||||||
}
|
}
|
||||||
evsig_base = base;
|
evsig_base = base;
|
||||||
evsig_base_n_signals_added = ++sig->ev_n_signals_added;
|
evsig_base_n_signals_added = ++sig->ev_n_signals_added;
|
||||||
|
Loading…
x
Reference in New Issue
Block a user