fixup! Use barriers for netmgr synchronization
This commit is contained in:
@@ -137,7 +137,8 @@ async_cb(uv_async_t *handle);
|
||||
static bool
|
||||
process_netievent(isc__networker_t *worker, isc__netievent_t *ievent);
|
||||
static bool
|
||||
process_queue(isc__networker_t *worker, isc_queue_t *queue, unsigned int *quantump);
|
||||
process_queue(isc__networker_t *worker, isc_queue_t *queue,
|
||||
unsigned int *quantump);
|
||||
static void
|
||||
wait_for_priority_queue(isc__networker_t *worker);
|
||||
static bool
|
||||
|
||||
@@ -344,7 +344,7 @@ isc__nm_tcpdns_lb_socket(sa_family_t sa_family) {
|
||||
|
||||
static void
|
||||
start_tcpdns_child(isc_nm_t *mgr, isc_nmiface_t *iface, isc_nmsocket_t *sock,
|
||||
int tid) {
|
||||
int tid) {
|
||||
isc__netievent_tcpdnslisten_t *ievent = NULL;
|
||||
isc_nmsocket_t *csock = &sock->children[tid];
|
||||
|
||||
@@ -373,7 +373,7 @@ start_tcpdns_child(isc_nm_t *mgr, isc_nmiface_t *iface, isc_nmsocket_t *sock,
|
||||
|
||||
ievent = isc__nm_get_netievent_tcpdnslisten(mgr, csock);
|
||||
isc__nm_maybe_enqueue_ievent(&mgr->workers[tid],
|
||||
(isc__netievent_t *)ievent);
|
||||
(isc__netievent_t *)ievent);
|
||||
}
|
||||
isc_result_t
|
||||
isc_nm_listentcpdns(isc_nm_t *mgr, isc_nmiface_t *iface,
|
||||
|
||||
@@ -409,7 +409,7 @@ isc__nm_tlsdns_lb_socket(sa_family_t sa_family) {
|
||||
|
||||
static void
|
||||
start_tlsdns_child(isc_nm_t *mgr, isc_nmiface_t *iface, isc_nmsocket_t *sock,
|
||||
int tid) {
|
||||
int tid) {
|
||||
isc__netievent_tlsdnslisten_t *ievent = NULL;
|
||||
isc_nmsocket_t *csock = &sock->children[tid];
|
||||
|
||||
|
||||
Reference in New Issue
Block a user