netievent_tcpstartread,
netievent_tcppauseread,
netievent_tcpchildlisten,
- netievent_tcpstopchildlisten,
+ netievent_tcpchildstop,
netievent_closecb,
netievent_shutdown,
netievent_stop,
- netievent_udpstoplisten,
- netievent_tcpstoplisten,
+ netievent_udpstop,
+ netievent_tcpstop,
netievent_tcpclose,
netievent_tcpdnsclose,
netievent_prio = 0xff, /* event type values higher than this
} isc__netievent__socket_t;
typedef isc__netievent__socket_t isc__netievent_udplisten_t;
-typedef isc__netievent__socket_t isc__netievent_udpstoplisten_t;
-typedef isc__netievent__socket_t isc__netievent_tcpstoplisten_t;
-typedef isc__netievent__socket_t isc__netievent_tcpstopchildlisten_t;
+typedef isc__netievent__socket_t isc__netievent_udpstop_t;
+typedef isc__netievent__socket_t isc__netievent_tcpstop_t;
+typedef isc__netievent__socket_t isc__netievent_tcpchildstop_t;
typedef isc__netievent__socket_t isc__netievent_tcpclose_t;
typedef isc__netievent__socket_t isc__netievent_tcpdnsclose_t;
typedef isc__netievent__socket_t isc__netievent_startread_t;
*/
void
-isc__nm_async_closecb(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_closecb(isc__networker_t *worker, isc__netievent_t *ev0);
/*%<
* Issue a 'handle closed' callback on the socket.
*/
void
-isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0);
/*%<
* Walk through all uv handles, get the underlying sockets and issue
* close on them.
*/
void
-isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_udpstoplisten(isc__networker_t *worker,
- isc__netievent_t *ievent0);
+isc__nm_async_udpstop(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_udpsend(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_udpsend(isc__networker_t *worker, isc__netievent_t *ev0);
/*%<
* Callback handlers for asynchronous UDP events (listen, stoplisten, send).
*/
*/
void
-isc__nm_async_tcpconnect(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_tcpconnect(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_tcplisten(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_tcplisten(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_tcpchildlisten(isc__networker_t *worker,
- isc__netievent_t *ievent0);
+isc__nm_async_tcpchildlisten(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_tcpstoplisten(isc__networker_t *worker,
- isc__netievent_t *ievent0);
+isc__nm_async_tcpstop(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_tcpstopchildlisten(isc__networker_t *worker,
- isc__netievent_t *ievent0);
+isc__nm_async_tcpchildstop(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_tcpsend(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_tcpsend(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_startread(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_startread(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_pauseread(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_pauseread(isc__networker_t *worker, isc__netievent_t *ev0);
void
-isc__nm_async_tcpclose(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_tcpclose(isc__networker_t *worker, isc__netievent_t *ev0);
/*%<
* Callback handlers for asynchronous TCP events (connect, listen,
* stoplisten, send, read, pause, close).
*/
void
-isc__nm_async_tcpdnsclose(isc__networker_t *worker, isc__netievent_t *ievent0);
+isc__nm_async_tcpdnsclose(isc__networker_t *worker, isc__netievent_t *ev0);
#define isc__nm_uverr2result(x) \
isc___nm_uverr2result(x, true, __FILE__, __LINE__)
case netievent_udplisten:
isc__nm_async_udplisten(worker, ievent);
break;
- case netievent_udpstoplisten:
- isc__nm_async_udpstoplisten(worker, ievent);
+ case netievent_udpstop:
+ isc__nm_async_udpstop(worker, ievent);
break;
case netievent_udpsend:
isc__nm_async_udpsend(worker, ievent);
case netievent_tcpsend:
isc__nm_async_tcpsend(worker, ievent);
break;
- case netievent_tcpstoplisten:
- isc__nm_async_tcpstoplisten(worker, ievent);
+ case netievent_tcpstop:
+ isc__nm_async_tcpstop(worker, ievent);
break;
- case netievent_tcpstopchildlisten:
- isc__nm_async_tcpstopchildlisten(worker, ievent);
+ case netievent_tcpchildstop:
+ isc__nm_async_tcpchildstop(worker, ievent);
break;
case netievent_tcpclose:
isc__nm_async_tcpclose(worker, ievent);
}
void
-isc__nm_async_closecb(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_closecb(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_closecb_t *ievent =
- (isc__netievent_closecb_t *) ievent0;
+ (isc__netievent_closecb_t *) ev0;
REQUIRE(VALID_NMSOCK(ievent->sock));
REQUIRE(ievent->sock->tid == isc_nm_tid());
}
void
-isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ievent0) {
- UNUSED(ievent0);
+isc__nm_async_shutdown(isc__networker_t *worker, isc__netievent_t *ev0) {
+ UNUSED(ev0);
uv_walk(&worker->loop, shutdown_walk_cb, NULL);
}
}
void
-isc__nm_async_tcpconnect(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_tcpconnect(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_tcpconnect_t *ievent =
- (isc__netievent_tcpconnect_t *) ievent0;
+ (isc__netievent_tcpconnect_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
isc__nm_uvreq_t *req = ievent->req;
int r;
* they have been deprecated and removed.)
*/
void
-isc__nm_async_tcplisten(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_tcplisten(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_tcplisten_t *ievent =
- (isc__netievent_tcplisten_t *) ievent0;
+ (isc__netievent_tcplisten_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
int r;
* for the socket we'll be listening on.
*/
void
-isc__nm_async_tcpchildlisten(isc__networker_t *worker,
- isc__netievent_t *ievent0)
-{
- isc__netievent_tcplisten_t *ievent =
- (isc__netievent_tcplisten_t *) ievent0;
+isc__nm_async_tcpchildlisten(isc__networker_t *worker, isc__netievent_t *ev0) {
+ isc__netievent_tcpchildlisten_t *ievent =
+ (isc__netievent_tcpchildlisten_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
isc__nm_uvreq_t *req = NULL;
int r;
void
isc_nm_tcp_stoplistening(isc_nmsocket_t *sock) {
- isc__netievent_tcpstoplisten_t *ievent = NULL;
+ isc__netievent_tcpstop_t *ievent = NULL;
REQUIRE(VALID_NMSOCK(sock));
REQUIRE(!isc__nm_in_netthread());
- ievent = isc__nm_get_ievent(sock->mgr, netievent_tcpstoplisten);
+ ievent = isc__nm_get_ievent(sock->mgr, netievent_tcpstop);
isc_nmsocket_attach(sock, &ievent->sock);
isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
(isc__netievent_t *) ievent);
}
void
-isc__nm_async_tcpstoplisten(isc__networker_t *worker,
- isc__netievent_t *ievent0)
-{
- isc__netievent_tcpstoplisten_t *ievent =
- (isc__netievent_tcpstoplisten_t *) ievent0;
+isc__nm_async_tcpstop(isc__networker_t *worker, isc__netievent_t *ev0) {
+ isc__netievent_tcpstop_t *ievent = (isc__netievent_tcpstop_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
UNUSED(worker);
* If network manager is interlocked, re-enqueue the event for later.
*/
if (!isc__nm_acquire_interlocked(sock->mgr)) {
- isc__netievent_tcpstoplisten_t *event = NULL;
+ isc__netievent_tcpstop_t *event = NULL;
event = isc__nm_get_ievent(sock->mgr,
- netievent_tcpstoplisten);
+ netievent_tcpstop);
event->sock = sock;
isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
(isc__netievent_t *) event);
static void
stoplistening(isc_nmsocket_t *sock) {
for (int i = 0; i < sock->nchildren; i++) {
- isc__netievent_tcpstopchildlisten_t *event = NULL;
+ isc__netievent_tcpchildstop_t *event = NULL;
/*
* We can ignore the overhead of event allocation because
* stoplistening is a rare event, and doing it this way
* simplifies sock reference counting.
*/
- event = isc__nm_get_ievent(sock->mgr,
- netievent_tcpstopchildlisten);
+ event = isc__nm_get_ievent(sock->mgr, netievent_tcpchildstop);
isc_nmsocket_attach(&sock->children[i], &event->sock);
if (i == sock->tid) {
- isc__nm_async_tcpstopchildlisten(
- &sock->mgr->workers[i],
+ isc__nm_async_tcpchildstop(&sock->mgr->workers[i],
(isc__netievent_t *) event);
isc__nm_put_ievent(sock->mgr, event);
} else {
}
void
-isc__nm_async_tcpstopchildlisten(isc__networker_t *worker,
- isc__netievent_t *ievent0)
-{
- isc__netievent_tcpstoplisten_t *ievent =
- (isc__netievent_tcpstoplisten_t *) ievent0;
+isc__nm_async_tcpchildstop(isc__networker_t *worker, isc__netievent_t *ev0) {
+ isc__netievent_tcpchildstop_t *ievent =
+ (isc__netievent_tcpchildstop_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
UNUSED(worker);
}
void
-isc__nm_async_startread(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_startread(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_startread_t *ievent =
- (isc__netievent_startread_t *) ievent0;
+ (isc__netievent_startread_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
REQUIRE(worker->id == isc_nm_tid());
}
void
-isc__nm_async_pauseread(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_pauseread(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_pauseread_t *ievent =
- (isc__netievent_pauseread_t *) ievent0;
+ (isc__netievent_pauseread_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
REQUIRE(VALID_NMSOCK(sock));
* Handle 'tcpsend' async event - send a packet on the socket
*/
void
-isc__nm_async_tcpsend(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_tcpsend(isc__networker_t *worker, isc__netievent_t *ev0) {
isc_result_t result;
- isc__netievent_tcpsend_t *ievent = (isc__netievent_tcpsend_t *) ievent0;
+ isc__netievent_tcpsend_t *ievent = (isc__netievent_tcpsend_t *) ev0;
REQUIRE(worker->id == ievent->sock->tid);
}
void
-isc__nm_async_tcpclose(isc__networker_t *worker, isc__netievent_t *ievent0) {
- isc__netievent_tcpclose_t *ievent =
- (isc__netievent_tcpclose_t *) ievent0;
+isc__nm_async_tcpclose(isc__networker_t *worker, isc__netievent_t *ev0) {
+ isc__netievent_tcpclose_t *ievent = (isc__netievent_tcpclose_t *) ev0;
REQUIRE(worker->id == ievent->sock->tid);
}
void
-isc__nm_async_tcpdnsclose(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_tcpdnsclose(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_tcpdnsclose_t *ievent =
- (isc__netievent_tcpdnsclose_t *) ievent0;
+ (isc__netievent_tcpdnsclose_t *) ev0;
REQUIRE(worker->id == ievent->sock->tid);
* handle 'udplisten' async call - start listening on a socket.
*/
void
-isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_udplisten(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_udplisten_t *ievent =
- (isc__netievent_udplisten_t *) ievent0;
+ (isc__netievent_udplisten_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
REQUIRE(sock->type == isc_nm_udpsocket);
INSIST(sock->type == isc_nm_udplistener);
for (int i = 0; i < sock->nchildren; i++) {
- isc__netievent_udpstoplisten_t *event = NULL;
+ isc__netievent_udpstop_t *event = NULL;
if (i == sock->tid) {
stop_udp_child(&sock->children[i]);
continue;
}
- event = isc__nm_get_ievent(sock->mgr, netievent_udpstoplisten);
+ event = isc__nm_get_ievent(sock->mgr, netievent_udpstop);
event->sock = &sock->children[i];
isc__nm_enqueue_ievent(&sock->mgr->workers[i],
(isc__netievent_t *) event);
void
isc_nm_udp_stoplistening(isc_nmsocket_t *sock) {
- isc__netievent_udpstoplisten_t *ievent = NULL;
+ isc__netievent_udpstop_t *ievent = NULL;
/* We can't be launched from network thread, we'd deadlock */
REQUIRE(!isc__nm_in_netthread());
* event. Otherwise, go ahead and stop listening right away.
*/
if (!isc__nm_acquire_interlocked(sock->mgr)) {
- ievent = isc__nm_get_ievent(sock->mgr, netievent_udpstoplisten);
+ ievent = isc__nm_get_ievent(sock->mgr, netievent_udpstop);
ievent->sock = sock;
isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
(isc__netievent_t *) ievent);
}
/*
- * handle 'udpstoplisten' async call - stop listening on a socket.
+ * handle 'udpstop' async call - stop listening on a socket.
*/
void
-isc__nm_async_udpstoplisten(isc__networker_t *worker,
- isc__netievent_t *ievent0)
-{
- isc__netievent_udplisten_t *ievent =
- (isc__netievent_udplisten_t *) ievent0;
+isc__nm_async_udpstop(isc__networker_t *worker, isc__netievent_t *ev0) {
+ isc__netievent_udpstop_t *ievent = (isc__netievent_udpstop_t *) ev0;
isc_nmsocket_t *sock = ievent->sock;
REQUIRE(sock->iface != NULL);
if (!isc__nm_acquire_interlocked(sock->mgr)) {
isc__netievent_udplisten_t *event = NULL;
- event = isc__nm_get_ievent(sock->mgr, netievent_udpstoplisten);
+ event = isc__nm_get_ievent(sock->mgr, netievent_udpstop);
event->sock = sock;
isc__nm_enqueue_ievent(&sock->mgr->workers[sock->tid],
(isc__netievent_t *) event);
* handle 'udpsend' async event - send a packet on the socket
*/
void
-isc__nm_async_udpsend(isc__networker_t *worker, isc__netievent_t *ievent0) {
+isc__nm_async_udpsend(isc__networker_t *worker, isc__netievent_t *ev0) {
isc__netievent_udpsend_t *ievent =
- (isc__netievent_udpsend_t *) ievent0;
+ (isc__netievent_udpsend_t *) ev0;
REQUIRE(worker->id == ievent->sock->tid);