Searched refs:queued (Results 1 - 25 of 27) sorted by relevance

12

/illumos-gate/usr/src/uts/common/os/
H A Dputnext.c154 boolean_t queued = B_FALSE; local
195 queued = qp->q_sqflags & Q_SQQUEUED;
245 queued = qp->q_sqflags & Q_SQQUEUED;
271 if (!queued) {
382 ASSERT((sq->sq_flags & (SQ_EXCL|SQ_CIPUT)) || queued);
383 ASSERT((flags & (SQ_EXCL|SQ_CIPUT)) || queued);
435 boolean_t queued = B_FALSE; local
463 queued = qp->q_sqflags & Q_SQQUEUED;
512 queued = qp->q_sqflags & Q_SQQUEUED;
538 if (!queued) {
[all...]
/illumos-gate/usr/src/cmd/mdb/common/modules/genunix/
H A Dtaskq.c147 size_t tact, tcount, queued, maxq; local
209 queued = tq.tq_tasks - tq.tq_executed;
232 if (active && tact == 0 && queued == 0)
243 addr, tq.tq_name, tact, tcount, queued);
/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/
H A Dsend.c140 * - queued acks can be delayed behind large messages
142 * - small message latency is higher behind queued large messages
166 * sendmsg calls here after having queued its message on the send
378 * We might be racing with another sender who queued a message but
380 * for queued messages after dropping the sem then either we'll
381 * see the queued message or the queuer will get the sem. If we
382 * notice the queued message then we trigger an immediate retry.
671 * Transports call here when they've determined that the receiver queued
802 * we only want this to fire once so we use the callers 'queued'. It's
809 uint16_be_t dport, int *queued)
807 rdsv3_send_queue_rm(struct rdsv3_sock *rs, struct rdsv3_connection *conn, struct rdsv3_message *rm, uint16_be_t sport, uint16_be_t dport, int *queued) argument
944 int queued = 0, allocated_mr = 0; local
[all...]
/illumos-gate/usr/src/uts/common/io/ral/
H A Drt2560_var.h104 int queued; member in struct:rt2560_tx_ring
H A Drt2560.c577 ring->queued = 0;
644 ring->queued = 0;
1084 sc->txq.queued--;
1088 sc->txq.queued < (RT2560_TX_RING_COUNT - 32)) {
1157 sc->prioq.queued--;
1454 if (sc->prioq.queued >= RT2560_PRIO_RING_COUNT) {
1537 sc->prioq.queued++; /* IF > RT2560_PRIO_RING_COUNT? FULL */
1581 if (sc->txq.queued >= RT2560_TX_RING_COUNT - 1) {
1691 sc->txq.queued++;
/illumos-gate/usr/src/uts/common/io/rwd/
H A Drt2661_var.h57 int queued; member in struct:rt2661_tx_ring
H A Drt2661.c619 ring->queued = 0;
705 ring->queued = 0;
947 ring->queued--;
1423 if (ring->queued > RT2661_TX_RING_COUNT - 8) {
1511 ring->queued++;
1553 if (ring->queued >= RT2661_MGT_RING_COUNT) {
1634 ring->queued++;
/illumos-gate/usr/src/uts/common/io/rwn/
H A Drt2860_var.h88 int queued; member in struct:rt2860_tx_ring
H A Drt2860.c774 ring->queued = 0;
812 ring->queued = 0;
1110 if (SLIST_EMPTY(&sc->data_pool) || (ring->queued > 15)) {
1251 ring->queued++;
1669 "hw = %x, ring->next = %x, queued = %d\n",
1670 hw, ring->next, ring->queued);
1692 ring->queued--;
1696 (ring->queued < RT2860_TX_RING_COUNT)) {
/illumos-gate/usr/src/uts/common/io/wpi/
H A Dwpivar.h100 int queued; member in struct:wpi_tx_ring
H A Dwpi.c1045 ring->queued = 0;
1142 ring->queued = 0;
1795 ring->queued--;
1796 if (ring->queued < 0)
1797 ring->queued = 0;
1798 if ((sc->sc_need_reschedule) && (ring->queued <= (ring->count << 3))) {
2104 if (ring->queued > ring->count - 64) {
2277 ring->queued++;
/illumos-gate/usr/src/uts/common/io/iwh/
H A Diwh_var.h73 int queued; member in struct:iwh_tx_ring
H A Diwh.c1569 ring->queued = 0;
1714 ring->queued = 0;
2469 ring->queued--;
2470 if (ring->queued < 0) {
2471 ring->queued = 0;
2474 if ((sc->sc_need_reschedule) && (ring->queued <= (ring->count >> 3))) {
3170 if (ring->queued > ring->count - IWH_MAX_WIN_SIZE) {
3186 ring->queued++;
3199 ring->queued--;
3200 if ((sc->sc_need_reschedule) && (ring->queued <
[all...]
/illumos-gate/usr/src/uts/common/io/iwk/
H A Diwk2_var.h73 int queued; member in struct:iwk_tx_ring
/illumos-gate/usr/src/uts/common/io/iwp/
H A Diwp_var.h73 int queued; member in struct:iwp_tx_ring
H A Diwp.c1508 ring->queued = 0;
1651 ring->queued = 0;
2373 ring->queued--;
2374 if (ring->queued < 0) {
2375 ring->queued = 0;
2378 if ((sc->sc_need_reschedule) && (ring->queued <= (ring->count >> 3))) {
3008 if (ring->queued > ring->count - IWP_MAX_WIN_SIZE) {
3024 ring->queued++;
3037 ring->queued--;
3038 if ((sc->sc_need_reschedule) && (ring->queued <
[all...]
/illumos-gate/usr/src/uts/common/avs/ns/rdc/
H A Drdc_clnt.c1280 rdc_aio_coalesce(rdc_aio_t *queued, rdc_aio_t *new) argument
1290 if ((queued == NULL) ||
1291 (queued->handle == NULL) ||
1295 if (queued->index != new->index || queued->len + new->len >
1299 if ((queued->pos + queued->len == new->pos) ||
1300 (new->pos + new->len == queued->pos)) {
1301 rc = nsc_alloc_abuf(queued->pos, queued
[all...]
/illumos-gate/usr/src/uts/common/io/xge/hal/xgehal/
H A Dxge-queue.c244 * @queued: Optional callback function to be called each time a new item is
257 int pages_max, xge_queued_f queued, void *queued_data)
264 queue->queued_func = queued;
256 xge_queue_create(pci_dev_h pdev, pci_irq_h irqh, int pages_initial, int pages_max, xge_queued_f queued, void *queued_data) argument
/illumos-gate/usr/src/uts/common/io/ib/mgt/ibcm/
H A Dibcm_impl.c179 uint_t queued; member in struct:ibcm_open_s
220 /* NONBLOCKING close requests are queued */
1434 ibcm_open.queued--;
1493 if (ibcm_open.queued == 0 && ibcm_ok_to_start(&ibcm_open)) {
1498 ibcm_open.queued++;
1515 ibcm_open.queued--;
1537 while (ibcm_open.queued > 0) {
1575 ibcm_open.queued = 0;
/illumos-gate/usr/src/uts/common/io/iwn/
H A Dif_iwnvar.h57 int queued; member in struct:iwn_tx_ring
/illumos-gate/usr/src/uts/common/io/usb/clients/video/usbvc/
H A Dusbvc_v4l2.c1135 boolean_t queued = B_FALSE; local
1155 queued = B_TRUE;
1163 if (queued) {
1173 "enqueue buffer(%d), already queued.", buf->index);
/illumos-gate/usr/src/uts/common/io/mwl/
H A Dmwl.c551 ring->queued = 0;
2761 if (ring->queued > 15) {
2763 "no txbuf, %d\n", ring->queued);
2868 "pktlen = %u, slot = %u, queued = %x\n",
2869 mblen, ring->cur, ring->queued);
2871 ring->queued++;
3085 if (!(ring->queued)) {
3124 ring->queued--;
3127 " tx done idx=%u, queued= %d\n",
3128 ring->next, ring->queued);
[all...]
H A Dmwl_var.h486 int queued; member in struct:mwl_tx_ring
/illumos-gate/usr/src/uts/sun4u/ml/
H A Dmach_interrupt.s256 ! If %g1 is less than zero, no interrupt will be queued.
/illumos-gate/usr/src/uts/common/io/scsi/targets/
H A Dst.c517 clock_t timeout_interval, int queued);
963 /* now we are ready to start up any queued I/Os */
4141 * If last command was non queued, wait till it finishes.
5036 * In persistent error mode sending a non-queued can hang
6448 int queued; local
6459 queued = 0;
6465 queued = 0;
6471 queued = 1;
6578 if (queued) {
6627 ST_TRAN_BUSY_TIMEOUT, queued)
6660 st_handle_start_busy(struct scsi_tape *un, struct buf *bp, clock_t timeout_interval, int queued) argument
6729 int queued; local
9117 int queued; local
10125 int queued; local
18011 int queued = 0; local
[all...]

Completed in 210 milliseconds

12