Lines Matching refs:buckets

174 /* Number of hash buckets for zone counters */
474 fctxbucket_t * buckets;
878 LOCK(&res->buckets[bucket].lock);
880 UNLOCK(&res->buckets[bucket].lock);
1444 LOCK(&res->buckets[fctx->bucketnum].lock);
1450 UNLOCK(&res->buckets[fctx->bucketnum].lock);
1642 task = res->buckets[fctx->bucketnum].task;
2139 task = res->buckets[fctx->bucketnum].task;
2787 LOCK(&res->buckets[bucketnum].lock);
2820 UNLOCK(&res->buckets[bucketnum].lock);
3112 res->buckets[fctx->bucketnum].task,
3791 LOCK(&res->buckets[bucketnum].lock);
3793 UNLOCK(&res->buckets[bucketnum].lock);
3825 ISC_LIST_UNLINK(res->buckets[bucketnum].fctxs, fctx, link);
3832 if (res->buckets[bucketnum].exiting &&
3833 ISC_LIST_EMPTY(res->buckets[bucketnum].fctxs))
3996 isc_task_send(fctx->res->buckets[fctx->bucketnum].task,
4045 LOCK(&res->buckets[bucketnum].lock);
4064 UNLOCK(&res->buckets[bucketnum].lock);
4090 LOCK(&res->buckets[bucketnum].lock);
4130 UNLOCK(&res->buckets[bucketnum].lock);
4244 mctx = res->buckets[bucketnum].mctx;
4465 res->buckets[bucketnum].task, fctx_timeout,
4489 ISC_LIST_APPEND(res->buckets[bucketnum].fctxs, fctx, link);
4769 LOCK(&res->buckets[bucketnum].lock);
4785 UNLOCK(&res->buckets[bucketnum].lock);
4835 LOCK(&res->buckets[bucketnum].lock);
4859 UNLOCK(&res->buckets[bucketnum].lock);
4959 UNLOCK(&res->buckets[bucketnum].lock);
5094 UNLOCK(&res->buckets[bucketnum].lock);
5111 UNLOCK(&res->buckets[bucketnum].lock);
5194 UNLOCK(&res->buckets[bucketnum].lock);
5371 task = res->buckets[fctx->bucketnum].task;
5841 LOCK(&fctx->res->buckets[fctx->bucketnum].lock);
5864 UNLOCK(&fctx->res->buckets[fctx->bucketnum].lock);
6020 res->buckets[fctx->bucketnum].task);
6029 LOCK(&res->buckets[fctx->bucketnum].lock);
6086 UNLOCK(&res->buckets[fctx->bucketnum].lock);
7275 LOCK(&fctx->res->buckets[fctx->bucketnum].lock);
7277 UNLOCK(&fctx->res->buckets[fctx->bucketnum].lock);
7448 LOCK(&res->buckets[bucketnum].lock);
7460 LOCK(&res->buckets[bucketnum].lock);
7462 UNLOCK(&res->buckets[bucketnum].lock);
8644 LOCK(&res->buckets[bucketnum].lock);
8646 UNLOCK(&res->buckets[bucketnum].lock);
8730 INSIST(ISC_LIST_EMPTY(res->buckets[i].fctxs));
8731 isc_task_shutdown(res->buckets[i].task);
8732 isc_task_detach(&res->buckets[i].task);
8733 DESTROYLOCK(&res->buckets[i].lock);
8734 isc_mem_detach(&res->buckets[i].mctx);
8736 isc_mem_put(res->mctx, res->buckets,
8903 res->buckets = isc_mem_get(view->mctx,
8905 if (res->buckets == NULL) {
8910 result = isc_mutex_init(&res->buckets[i].lock);
8913 res->buckets[i].task = NULL;
8914 result = isc_task_create(taskmgr, 0, &res->buckets[i].task);
8916 DESTROYLOCK(&res->buckets[i].lock);
8919 res->buckets[i].mctx = NULL;
8927 result = isc_mem_create(0, 0, &res->buckets[i].mctx);
8929 isc_task_detach(&res->buckets[i].task);
8930 DESTROYLOCK(&res->buckets[i].lock);
8933 isc_mem_setname(res->buckets[i].mctx, name, NULL);
8935 isc_mem_attach(view->mctx, &res->buckets[i].mctx);
8937 isc_task_setname(res->buckets[i].task, name, res);
8938 ISC_LIST_INIT(res->buckets[i].fctxs);
8939 res->buckets[i].exiting = ISC_FALSE;
9067 isc_mem_detach(&res->buckets[i].mctx);
9068 DESTROYLOCK(&res->buckets[i].lock);
9069 isc_task_shutdown(res->buckets[i].task);
9070 isc_task_detach(&res->buckets[i].task);
9072 isc_mem_put(view->mctx, res->buckets,
9177 res->buckets[0].task,
9268 LOCK(&res->buckets[i].lock);
9269 for (fctx = ISC_LIST_HEAD(res->buckets[i].fctxs);
9275 res->buckets[i].task);
9279 res->buckets[i].task);
9281 res->buckets[i].exiting = ISC_TRUE;
9282 if (ISC_LIST_EMPTY(res->buckets[i].fctxs)) {
9286 UNLOCK(&res->buckets[i].lock);
9456 LOCK(&res->buckets[bucketnum].lock);
9458 if (res->buckets[bucketnum].exiting) {
9464 for (fctx = ISC_LIST_HEAD(res->buckets[bucketnum].fctxs);
9519 isc_task_send(res->buckets[bucketnum].task, &event);
9531 UNLOCK(&res->buckets[bucketnum].lock);
9559 LOCK(&res->buckets[fctx->bucketnum].lock);
9589 UNLOCK(&res->buckets[fctx->bucketnum].lock);
9611 LOCK(&res->buckets[bucketnum].lock);
9629 UNLOCK(&res->buckets[bucketnum].lock);
9652 LOCK(&res->buckets[fctx->bucketnum].lock);
9677 UNLOCK(&res->buckets[fctx->bucketnum].lock);