Lines Matching defs:buckets
381 fctxbucket_t * buckets;
1148 LOCK(&res->buckets[fctx->bucketnum].lock);
1154 UNLOCK(&res->buckets[fctx->bucketnum].lock);
1325 task = res->buckets[fctx->bucketnum].task;
1646 task = res->buckets[fctx->bucketnum].task;
2138 LOCK(&res->buckets[bucketnum].lock);
2170 UNLOCK(&res->buckets[bucketnum].lock);
2503 res->buckets[fctx->bucketnum].task,
3122 ISC_LIST_UNLINK(res->buckets[bucketnum].fctxs, fctx, link);
3128 if (res->buckets[bucketnum].exiting &&
3129 ISC_LIST_EMPTY(res->buckets[bucketnum].fctxs))
3287 isc_task_send(fctx->res->buckets[fctx->bucketnum].task,
3335 LOCK(&res->buckets[bucketnum].lock);
3354 UNLOCK(&res->buckets[bucketnum].lock);
3380 LOCK(&res->buckets[bucketnum].lock);
3420 UNLOCK(&res->buckets[bucketnum].lock);
3533 mctx = res->buckets[bucketnum].mctx;
3719 res->buckets[bucketnum].task, fctx_timeout,
3743 ISC_LIST_APPEND(res->buckets[bucketnum].fctxs, fctx, link);
3948 LOCK(&res->buckets[bucketnum].lock);
3964 UNLOCK(&res->buckets[bucketnum].lock);
4010 LOCK(&res->buckets[fctx->bucketnum].lock);
4035 UNLOCK(&res->buckets[bucketnum].lock);
4135 UNLOCK(&res->buckets[fctx->bucketnum].lock);
4263 UNLOCK(&res->buckets[fctx->bucketnum].lock);
4280 UNLOCK(&res->buckets[fctx->bucketnum].lock);
4355 UNLOCK(&res->buckets[fctx->bucketnum].lock);
4535 task = res->buckets[fctx->bucketnum].task;
4931 LOCK(&fctx->res->buckets[fctx->bucketnum].lock);
4954 UNLOCK(&fctx->res->buckets[fctx->bucketnum].lock);
5101 res->buckets[fctx->bucketnum].task);
5110 LOCK(&res->buckets[fctx->bucketnum].lock);
5162 UNLOCK(&res->buckets[fctx->bucketnum].lock);
6270 LOCK(&res->buckets[bucketnum].lock);
6284 LOCK(&res->buckets[bucketnum].lock);
6286 UNLOCK(&res->buckets[bucketnum].lock);
7130 LOCK(&fctx->res->buckets[fctx->bucketnum].lock);
7132 UNLOCK(&fctx->res->buckets[fctx->bucketnum].lock);
7188 INSIST(ISC_LIST_EMPTY(res->buckets[i].fctxs));
7189 isc_task_shutdown(res->buckets[i].task);
7190 isc_task_detach(&res->buckets[i].task);
7191 DESTROYLOCK(&res->buckets[i].lock);
7192 isc_mem_detach(&res->buckets[i].mctx);
7194 isc_mem_put(res->mctx, res->buckets,
7344 res->buckets = isc_mem_get(view->mctx,
7346 if (res->buckets == NULL) {
7351 result = isc_mutex_init(&res->buckets[i].lock);
7354 res->buckets[i].task = NULL;
7355 result = isc_task_create(taskmgr, 0, &res->buckets[i].task);
7357 DESTROYLOCK(&res->buckets[i].lock);
7360 res->buckets[i].mctx = NULL;
7368 result = isc_mem_create(0, 0, &res->buckets[i].mctx);
7370 isc_task_detach(&res->buckets[i].task);
7371 DESTROYLOCK(&res->buckets[i].lock);
7374 isc_mem_setname(res->buckets[i].mctx, name, NULL);
7376 isc_mem_attach(view->mctx, &res->buckets[i].mctx);
7378 isc_task_setname(res->buckets[i].task, name, res);
7379 ISC_LIST_INIT(res->buckets[i].fctxs);
7380 res->buckets[i].exiting = ISC_FALSE;
7477 isc_mem_detach(&res->buckets[i].mctx);
7478 DESTROYLOCK(&res->buckets[i].lock);
7479 isc_task_shutdown(res->buckets[i].task);
7480 isc_task_detach(&res->buckets[i].task);
7482 isc_mem_put(view->mctx, res->buckets,
7583 res->buckets[0].task,
7676 LOCK(&res->buckets[i].lock);
7677 for (fctx = ISC_LIST_HEAD(res->buckets[i].fctxs);
7683 isc_socket_cancel(sock, res->buckets[i].task,
7688 isc_socket_cancel(sock, res->buckets[i].task,
7691 res->buckets[i].exiting = ISC_TRUE;
7692 if (ISC_LIST_EMPTY(res->buckets[i].fctxs)) {
7696 UNLOCK(&res->buckets[i].lock);
7841 LOCK(&res->buckets[bucketnum].lock);
7843 if (res->buckets[bucketnum].exiting) {
7849 for (fctx = ISC_LIST_HEAD(res->buckets[bucketnum].fctxs);
7903 isc_task_send(res->buckets[bucketnum].task, &event);
7915 UNLOCK(&res->buckets[bucketnum].lock);
7943 LOCK(&res->buckets[fctx->bucketnum].lock);
7973 UNLOCK(&res->buckets[fctx->bucketnum].lock);
7995 LOCK(&res->buckets[bucketnum].lock);
8013 UNLOCK(&res->buckets[bucketnum].lock);
8036 LOCK(&res->buckets[fctx->bucketnum].lock);
8060 UNLOCK(&res->buckets[fctx->bucketnum].lock);