Lines Matching refs:queue
63 struct camq queue; member
106 u_int32_t camq_resize(struct camq *queue, int new_size);
116 void camq_fini(struct camq *queue);
122 void camq_insert(struct camq *queue, cam_pinfo *new_entry);
128 cam_pinfo *camq_remove(struct camq *queue, int index);
142 void camq_change_priority(struct camq *queue, int index,
161 cam_ccbq_send_ccb(struct cam_ccbq *queue, union ccb *send_ccb);
172 return (ccbq->queue.entries + ccbq->queue_extra_entries); in cam_ccbq_pending_ccb_count()
186 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
197 if (queue->entries == queue->array_size && in cam_ccbq_insert_ccb()
198 camq_resize(&ccbq->queue, queue->array_size * 2) != CAM_REQ_CMP) { in cam_ccbq_insert_ccb()
199 old_ccb = (struct ccb_hdr *)camq_remove(queue, queue->entries); in cam_ccbq_insert_ccb()
206 camq_insert(queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
213 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
225 removed_entry = camq_remove(queue, ccb->ccb_h.pinfo.index); in cam_ccbq_remove_ccb()
246 camq_insert(queue, &bccb->pinfo); in cam_ccbq_remove_ccb()
252 return((union ccb *)ccbq->queue.queue_array[index]); in cam_ccbq_peek_ccb()