send_queue
if (camq_init(&devq->send_queue, devices) != 0)
camq_fini(&devq->send_queue);
retval = camq_resize(&camq->send_queue, devices);
struct camq send_queue;
devq->send_queue.qfrozen_cnt++;
while ((devq->send_queue.entries > 0)
&& (devq->send_queue.qfrozen_cnt <= 1)) {
device = (struct cam_ed *)camq_remove(&devq->send_queue,
devq->send_queue.qfrozen_cnt--;
xpt_schedule_dev(&devq->send_queue,
camq_remove(&devq->send_queue, dev->devq_entry.index);
freeze = (devq->send_queue.qfrozen_cnt += count);
if (devq->send_queue.qfrozen_cnt <= 0) {
devq->send_queue.qfrozen_cnt);
devq->send_queue.qfrozen_cnt--;
if (devq->send_queue.qfrozen_cnt == 0) {
status = cam_devq_resize(devq, devq->send_queue.array_size + 1);
cam_devq_resize(devq, devq->send_queue.array_size - 1);
lchk = TAILQ_FIRST(&asoc->send_queue);
lchk = TAILQ_FIRST(&asoc->send_queue);
lchk = TAILQ_FIRST(&asoc->send_queue);
tp1 = TAILQ_FIRST(&stcb->asoc.send_queue);
if (TAILQ_EMPTY(&asoc->send_queue)) {
ttt = TAILQ_FIRST(&asoc->send_queue);
if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) {
TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) && TAILQ_EMPTY(&asoc->sent_queue)) {
TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
TAILQ_EMPTY(&asoc->send_queue) &&
lchk = TAILQ_LAST(&stcb->asoc.send_queue, sctpchunk_listhead);
if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
if (TAILQ_EMPTY(&stcb->asoc.send_queue)) {
tp1->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.tsn;
if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
if (TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
TAILQ_REMOVE(&asoc->send_queue, data_list[i], sctp_next);
TAILQ_INSERT_TAIL(&asoc->send_queue, chk, sctp_next);
TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
TAILQ_EMPTY(&asoc->send_queue) &&
TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
TAILQ_EMPTY(&asoc->send_queue)) {
TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
} else if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
struct sctpchunk_listhead send_queue;
KASSERT(TAILQ_EMPTY(&stcb->asoc.send_queue), ("send_queue not empty"));
if ((TAILQ_EMPTY(&stcb->asoc.send_queue)) &&
(TAILQ_EMPTY(&stcb->asoc.send_queue)) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&stcb->asoc.send_queue)) {
chk->rec.data.fast_retran_tsn = (TAILQ_FIRST(&stcb->asoc.send_queue))->rec.data.tsn;
TAILQ_FOREACH(chk, &asoc->send_queue, sctp_next) {
if (!TAILQ_EMPTY(&stcb->asoc.send_queue) ||
if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
if (TAILQ_EMPTY(&stcb->asoc.send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
TAILQ_EMPTY(&asoc->send_queue) &&
if (TAILQ_EMPTY(&asoc->send_queue) &&
TAILQ_INIT(&asoc->send_queue);
TAILQ_FOREACH_SAFE(chk, &asoc->send_queue, sctp_next, nchk) {
TAILQ_REMOVE(&asoc->send_queue, chk, sctp_next);
TAILQ_FOREACH_SAFE(tp1, &stcb->asoc.send_queue, sctp_next, tp2) {
TAILQ_REMOVE(&stcb->asoc.send_queue, tp1, sctp_next);
mad_send_wr->mad_list.mad_queue = &qp_info->send_queue;
spin_lock_irqsave(&qp_info->send_queue.lock, flags);
if (qp_info->send_queue.count < qp_info->send_queue.max_active) {
list = &qp_info->send_queue.list;
qp_info->send_queue.count++;
spin_unlock_irqrestore(&qp_info->send_queue.lock, flags);
struct ib_mad_queue *send_queue;
send_queue = mad_list->mad_queue;
qp_info = send_queue->qp_info;
spin_lock_irqsave(&send_queue->lock, flags);
if (send_queue->count-- > send_queue->max_active) {
list_move_tail(&mad_list->list, &send_queue->list);
spin_unlock_irqrestore(&send_queue->lock, flags);
spin_lock_irqsave(&qp_info->send_queue.lock, flags);
list_for_each_entry(mad_list, &qp_info->send_queue.list, list) {
spin_unlock_irqrestore(&qp_info->send_queue.lock, flags);
init_mad_queue(qp_info, &qp_info->send_queue);
qp_info->send_queue.max_active = mad_sendq_size;
struct ib_mad_queue send_queue;
send_queue(p);
send_queue(p);
send_queue(p);
send_queue(p);
res->send_queue =
value->v.uint32 = res->send_queue;
uint32_t send_queue;