Lines Matching refs:queue
63 struct camq queue; member
112 u_int32_t camq_resize(struct camq *queue, int new_size);
124 void camq_free(struct camq *queue);
129 void camq_fini(struct camq *queue);
135 void camq_insert(struct camq *queue, cam_pinfo *new_entry);
141 cam_pinfo *camq_remove(struct camq *queue, int index);
155 void camq_change_priority(struct camq *queue, int index,
174 cam_ccbq_send_ccb(struct cam_ccbq *queue, union ccb *send_ccb);
186 return (ccbq->queue.entries + ccbq->queue_extra_entries); in cam_ccbq_pending_ccb_count()
200 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
211 if (queue->entries == queue->array_size && in cam_ccbq_insert_ccb()
212 camq_resize(&ccbq->queue, queue->array_size * 2) != CAM_REQ_CMP) { in cam_ccbq_insert_ccb()
213 old_ccb = (struct ccb_hdr *)camq_remove(queue, queue->entries); in cam_ccbq_insert_ccb()
220 camq_insert(queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
227 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
239 removed_entry = camq_remove(queue, ccb->ccb_h.pinfo.index); in cam_ccbq_remove_ccb()
260 camq_insert(queue, &bccb->pinfo); in cam_ccbq_remove_ccb()
266 return((union ccb *)ccbq->queue.queue_array[index]); in cam_ccbq_peek_ccb()