/titanic_41/usr/src/uts/common/io/mac/ |
H A D | mac_soft_ring.c | 125 mac_soft_ring_worker_wakeup(mac_soft_ring_t *ringp) in mac_soft_ring_worker_wakeup() argument 127 ASSERT(MUTEX_HELD(&ringp->s_ring_lock)); in mac_soft_ring_worker_wakeup() 128 if (!(ringp->s_ring_state & S_RING_PROC) && in mac_soft_ring_worker_wakeup() 129 !(ringp->s_ring_state & S_RING_BLANK) && in mac_soft_ring_worker_wakeup() 130 (ringp->s_ring_tid == NULL)) { in mac_soft_ring_worker_wakeup() 131 if (ringp->s_ring_wait != 0) { in mac_soft_ring_worker_wakeup() 132 ringp->s_ring_tid = in mac_soft_ring_worker_wakeup() 133 timeout(mac_soft_ring_fire, ringp, in mac_soft_ring_worker_wakeup() 134 ringp->s_ring_wait); in mac_soft_ring_worker_wakeup() 137 cv_signal(&ringp->s_ring_async); in mac_soft_ring_worker_wakeup() [all …]
|
H A D | mac_sched.c | 4615 #define SOFT_RING_ENQUEUE_CHAIN(ringp, mp, tail, cnt, sz) { \ argument 4619 ASSERT(MUTEX_HELD(&(ringp)->s_ring_lock)); \ 4621 if ((ringp)->s_ring_last != NULL) \ 4622 (ringp)->s_ring_last->b_next = (mp); \ 4624 (ringp)->s_ring_first = (mp); \ 4625 (ringp)->s_ring_last = (tail); \ 4626 (ringp)->s_ring_count += (cnt); \ 4627 ASSERT((ringp)->s_ring_count > 0); \ 4628 if ((ringp)->s_ring_type & ST_RING_BW_CTL) { \ 4629 (ringp)->s_ring_size += sz; \ [all …]
|
H A D | mac_stat.c | 820 mac_soft_ring_t *ringp = (mac_soft_ring_t *)handle; in i_mac_tx_hwlane_stat_get() local 821 mac_tx_stats_t *mac_tx_stat = &ringp->s_st_stat; in i_mac_tx_hwlane_stat_get() 855 i_mac_tx_hwlane_stat_create(mac_soft_ring_t *ringp, const char *modname, in i_mac_tx_hwlane_stat_create() argument 860 ksp = i_mac_stat_create(ringp, modname, statname, in i_mac_tx_hwlane_stat_create() 864 ringp->s_ring_ksp = ksp; in i_mac_tx_hwlane_stat_create() 920 i_mac_rx_fanout_stat_create(mac_soft_ring_t *ringp, const char *modname, in i_mac_rx_fanout_stat_create() argument 925 ksp = i_mac_stat_create(ringp, modname, statname, in i_mac_rx_fanout_stat_create() 929 ringp->s_ring_ksp = ksp; in i_mac_rx_fanout_stat_create() 1092 mac_soft_ring_stat_create(mac_soft_ring_t *ringp) in mac_soft_ring_stat_create() argument 1094 mac_soft_ring_set_t *mac_srs = ringp->s_ring_set; in mac_soft_ring_stat_create() [all …]
|
H A D | mac_datapath_setup.c | 1441 mac_soft_ring_t *ringp; in mac_update_srs_priority() local 1453 if ((ringp = mac_srs->srs_soft_ring_head) == NULL) in mac_update_srs_priority() 1455 while (ringp != mac_srs->srs_soft_ring_tail) { in mac_update_srs_priority() 1456 thread_lock(ringp->s_ring_worker); in mac_update_srs_priority() 1457 (void) thread_change_pri(ringp->s_ring_worker, in mac_update_srs_priority() 1459 thread_unlock(ringp->s_ring_worker); in mac_update_srs_priority() 1460 ringp = ringp->s_ring_next; in mac_update_srs_priority() 1462 ASSERT(ringp == mac_srs->srs_soft_ring_tail); in mac_update_srs_priority() 1463 thread_lock(ringp->s_ring_worker); in mac_update_srs_priority() 1464 (void) thread_change_pri(ringp->s_ring_worker, mac_srs->srs_pri, 0); in mac_update_srs_priority() [all …]
|
/titanic_41/usr/src/uts/common/io/ib/clients/rdsv3/ |
H A D | rdsv3_af_thr.c | 188 rdsv3_af_thr_t *ringp; in rdsv3_af_intr_thr_create() local 193 ringp = rdsv3_af_thr_create(fn, data, flag, hcagp); in rdsv3_af_intr_thr_create() 194 if (ringp == NULL) in rdsv3_af_intr_thr_create() 201 (void) rdsv3_af_thr_bind(ringp, cpuid); in rdsv3_af_intr_thr_create() 204 if (ringp->aft_intr) { in rdsv3_af_intr_thr_create() 206 (void) ddi_intr_set_affinity(ringp->aft_intr, cpuid); in rdsv3_af_intr_thr_create() 208 (void) ddi_intr_set_affinity(ringp->aft_intr, in rdsv3_af_intr_thr_create() 212 return (ringp); in rdsv3_af_intr_thr_create() 219 rdsv3_af_thr_t *ringp; in rdsv3_af_thr_create() local 224 ringp = kmem_zalloc(sizeof (rdsv3_af_thr_t), KM_NOSLEEP); in rdsv3_af_thr_create() [all …]
|
/titanic_41/usr/src/uts/common/xen/os/ |
H A D | xvdi.c | 622 xvdi_reinit_ring(dev_info_t *dip, grant_ref_t *gref, xendev_ring_t *ringp) in xvdi_reinit_ring() argument 627 ASSERT((ringp != NULL) && (ringp->xr_paddr != 0)); in xvdi_reinit_ring() 628 rpaddr = ringp->xr_paddr; in xvdi_reinit_ring() 631 gnttab_grant_foreign_access_ref(ringp->xr_gref, xvdi_get_oeid(dip), in xvdi_reinit_ring() 633 *gref = ringp->xr_gref; in xvdi_reinit_ring() 636 xvdi_ring_init_sring(ringp); in xvdi_reinit_ring() 637 xvdi_ring_init_front_ring(ringp, ringp->xr_sring.fr.nr_ents, in xvdi_reinit_ring() 638 ringp->xr_entry_size); in xvdi_reinit_ring() 2043 #define GET_RING_SIZE(_ringp) RING_SIZE(FRONT_RING(ringp)) 2052 xvdi_ring_avail_slots(xendev_ring_t *ringp) in xvdi_ring_avail_slots() argument [all …]
|
/titanic_41/usr/src/uts/common/sys/ib/clients/rdsv3/ |
H A D | rdsv3_af_thr_impl.h | 89 static void rdsv3_af_thr_worker(rdsv3_af_thr_t *ringp); 90 static cpu_t *rdsv3_af_thr_bind(rdsv3_af_thr_t *ringp, processorid_t cpuid); 91 static void rdsv3_af_thr_unbind(rdsv3_af_thr_t *ringp);
|
H A D | rdsv3_af_thr.h | 66 void rdsv3_af_thr_destroy(rdsv3_af_thr_t *ringp); 67 void rdsv3_af_thr_fire(rdsv3_af_thr_t *ringp);
|
/titanic_41/usr/src/uts/common/xen/io/ |
H A D | blk_common.c | 169 blk_ring_init(blk_ringinit_args_t *args, blk_ring_t *ringp) in blk_ring_init() argument 224 *ringp = ring; in blk_ring_init() 246 blk_ring_fini(blk_ring_t *ringp) in blk_ring_fini() argument 251 ring = *ringp; in blk_ring_fini() 266 *ringp = NULL; in blk_ring_fini()
|
/titanic_41/usr/src/uts/common/io/hxge/ |
H A D | hxge_rxdma.c | 1218 p_rx_rcr_ring_t ringp; in hxge_enable_poll() local 1229 ringp = hxgep->rx_rcr_rings->rcr_rings[ring_handle->index]; in hxge_enable_poll() 1231 MUTEX_ENTER(&ringp->lock); in hxge_enable_poll() 1236 if (ringp->poll_flag) { in hxge_enable_poll() 1237 MUTEX_EXIT(&ringp->lock); in hxge_enable_poll() 1241 ldgp = ringp->ldgp; in hxge_enable_poll() 1243 MUTEX_EXIT(&ringp->lock); in hxge_enable_poll() 1250 ringp->poll_flag = B_TRUE; in hxge_enable_poll() 1252 MUTEX_EXIT(&ringp->lock); in hxge_enable_poll() 1263 p_rx_rcr_ring_t ringp; in hxge_disable_poll() local [all …]
|
/titanic_41/usr/src/uts/common/io/nxge/ |
H A D | nxge_rxdma.c | 2747 p_rx_rcr_ring_t ringp; in nxge_enable_poll() local 2759 ringp = nxgep->rx_rcr_rings->rcr_rings[channel]; in nxge_enable_poll() 2761 "==> nxge_enable_poll: rdc %d ", ringp->rdc)); in nxge_enable_poll() 2762 ldgp = ringp->ldgp; in nxge_enable_poll() 2766 ringp->rdc)); in nxge_enable_poll() 2770 MUTEX_ENTER(&ringp->lock); in nxge_enable_poll() 2772 if (ringp->poll_flag == 0) { in nxge_enable_poll() 2773 ringp->poll_flag = 1; in nxge_enable_poll() 2776 ringp->rdc)); in nxge_enable_poll() 2779 MUTEX_EXIT(&ringp->lock); in nxge_enable_poll() [all …]
|
/titanic_41/usr/src/uts/sun4v/io/ |
H A D | vnet.c | 1085 vnet_free_pseudo_rx_ring(vnet_t *vnetp, vnet_pseudo_rx_ring_t *ringp) in vnet_free_pseudo_rx_ring() argument 1089 ASSERT(ringp->index >= VNET_NUM_PSEUDO_RXRINGS_DEFAULT); in vnet_free_pseudo_rx_ring() 1093 if (ringp->state != VNET_RXRING_FREE) { in vnet_free_pseudo_rx_ring() 1094 ringp->state = VNET_RXRING_FREE; in vnet_free_pseudo_rx_ring() 1095 ringp->handle = NULL; in vnet_free_pseudo_rx_ring() 1374 vnet_pseudo_rx_ring_t *ringp; in vnet_rx() local 1381 ringp = vresp->rx_ringp; in vnet_rx() 1382 mac_rx_ring(vnetp->mh, ringp->handle, mp, ringp->gen_num); in vnet_rx() 2636 vnet_pseudo_rx_ring_t *ringp = (vnet_pseudo_rx_ring_t *)mrh; in vnet_hio_rx_cb() local 2652 mac_rx_ring(vnetp->mh, ringp->handle, mp, ringp->gen_num); in vnet_hio_rx_cb()
|