Lines Matching refs:queue
61 struct camq queue; member
104 u_int32_t camq_resize(struct camq *queue, int new_size);
114 void camq_fini(struct camq *queue);
120 void camq_insert(struct camq *queue, cam_pinfo *new_entry);
126 cam_pinfo *camq_remove(struct camq *queue, int index);
140 void camq_change_priority(struct camq *queue, int index,
159 cam_ccbq_send_ccb(struct cam_ccbq *queue, union ccb *send_ccb);
170 return (ccbq->queue.entries + ccbq->queue_extra_entries); in cam_ccbq_pending_ccb_count()
184 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
195 if (queue->entries == queue->array_size && in cam_ccbq_insert_ccb()
196 camq_resize(&ccbq->queue, queue->array_size * 2) != CAM_REQ_CMP) { in cam_ccbq_insert_ccb()
197 old_ccb = (struct ccb_hdr *)camq_remove(queue, queue->entries); in cam_ccbq_insert_ccb()
204 camq_insert(queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
211 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
223 removed_entry = camq_remove(queue, ccb->ccb_h.pinfo.index); in cam_ccbq_remove_ccb()
244 camq_insert(queue, &bccb->pinfo); in cam_ccbq_remove_ccb()
250 return((union ccb *)ccbq->queue.queue_array[index]); in cam_ccbq_peek_ccb()