Lines Matching defs:kq
85 struct kcm_ops_queue *kq = talloc_get_type(private_data,
92 if (kq->head != NULL) {
98 key.ul = kq->uid;
103 ret = hash_delete(kq->qctx->wait_queue_hash, &key);
107 kq->uid);
112 "Removed queue for %"SPRIuid" \n", kq->uid);
113 talloc_free(kq);
157 struct kcm_ops_queue *kq;
170 kq = talloc_get_type(value.ptr, struct kcm_ops_queue);
171 if (kq == NULL) {
186 kq = talloc_zero(qctx->wait_queue_hash, struct kcm_ops_queue);
187 if (kq == NULL) {
190 kq->uid = uid;
191 kq->qctx = qctx;
192 kq->ev = ev;
195 value.ptr = kq;
209 return kq;
216 static errno_t kcm_op_queue_add_req(struct kcm_ops_queue *kq,
236 struct kcm_ops_queue *kq;
250 kq = kcm_op_queue_get(qctx, ev, uid);
251 if (kq == NULL) {
258 ret = kcm_op_queue_add_req(kq, req);
282 static errno_t kcm_op_queue_add_req(struct kcm_ops_queue *kq,
289 state->entry = talloc_zero(kq->qctx->wait_queue_hash, struct kcm_ops_queue_entry);
294 state->entry->queue = kq;
297 if (kq->head == NULL) {
305 DLIST_ADD_END(kq->head, state->entry, struct kcm_ops_queue_entry *);