squeue_t
squeue_t squeue;
if (mdb_vread(&squeue, sizeof (squeue_t), addr) == -1) {
squeue_t *ixa_sqp; /* Set from conn_sqp as a hint */
squeue_t *ira_sqp;
squeue_t *ira_target_sqp;
struct mac_header_info_s *, squeue_t *, mblk_t **, uint_t *);
struct mac_header_info_s *, squeue_t *, mblk_t **, uint_t *);
extern mblk_t *ip_accept_tcp(ill_t *, ill_rx_ring_t *, squeue_t *,
extern mblk_t *ip_accept_tcp_v6(ill_t *, ill_rx_ring_t *, squeue_t *,
squeue_t *, mblk_t *, mblk_t **, uint_t *);
squeue_t *rr_sqp; /* Squeue the ring is bound to */
extern void ip_squeue_init(void (*)(squeue_t *));
extern squeue_t *ip_squeue_random(uint_t);
extern squeue_t *ip_squeue_get(ill_rx_ring_t *);
extern squeue_t *ip_squeue_getfree(pri_t);
extern int ip_squeue_cpu_move(squeue_t *, processorid_t);
ip_accept_tcp_v6(ill_t *ill, ill_rx_ring_t *ip_ring, squeue_t *target_sqp,
struct mac_header_info_s *mhip, squeue_t *target_sqp,
squeue_t *irm_sqp;
ip_accept_tcp(ill_t *ill, ill_rx_ring_t *ip_ring, squeue_t *target_sqp,
struct mac_header_info_s *mhip, squeue_t *target_sqp,
static void (*ip_squeue_create_callback)(squeue_t *) = NULL;
static squeue_t *ip_squeue_create(pri_t);
static void ip_squeue_set_move(squeue_t *, squeue_set_t *);
static squeue_t *
squeue_t *sqp;
squeue_t **lastsqp, *sq;
squeue_t **defaultq_lastp = NULL;
squeue_t *
squeue_t *sq;
ip_squeue_init(void (*callback)(squeue_t *))
squeue_t *
squeue_t *sq;
ip_squeue_set_move(squeue_t *sq, squeue_set_t *newset)
squeue_t **lastsqp;
ip_squeue_cpu_move(squeue_t *sq, processorid_t cpuid)
squeue_t *sq = NULL;
squeue_t *sqp;
squeue_t *sqp;
squeue_t *sqp;
squeue_t *
squeue_t *sqp;
squeue_t *sqp, *lastsqp = NULL;
squeue_t *conn_sqp; /* Squeue for processing */
squeue_t *conn_initial_sqp; /* Squeue at open time */
squeue_t *conn_final_sqp; /* Squeue after connect */
squeue_worker_thr_control(squeue_t *sqp)
squeue_worker(squeue_t *sqp)
squeue_getprivate(squeue_t *sqp, sqprivate_t p)
squeue_t *sqp = connp->conn_sqp;
squeue_t *sqp;
static void squeue_drain(squeue_t *, uint_t, hrtime_t);
static void squeue_worker(squeue_t *sqp);
squeue_try_drain_one(squeue_t *sqp, conn_t *compare_conn)
static void squeue_polling_thread(squeue_t *sqp);
static void squeue_worker_wakeup(squeue_t *sqp);
static void squeue_try_drain_one(squeue_t *, conn_t *);
DTRACE_PROBE3(squeue__proc__start, squeue_t *, sqp, mblk_t *, mp,
DTRACE_PROBE2(squeue__proc__end, squeue_t *, sqp, conn_t *, connp);
squeue_t *sqp = connp->conn_sqp;
DTRACE_PROBE4(squeue__enqueuechain, squeue_t *, sqp, \
sizeof (squeue_t), 64, NULL, NULL, NULL, NULL, NULL, 0);
squeue_t *
squeue_t *sqp = kmem_cache_alloc(squeue_cache, KM_SLEEP);
bzero(sqp, sizeof (squeue_t));
squeue_bind(squeue_t *sqp, processorid_t bind)
squeue_unbind(squeue_t *sqp)
squeue_enter(squeue_t *sqp, mblk_t *mp, mblk_t *tail, uint32_t cnt,
DTRACE_PROBE3(squeue__proc__start, squeue_t *,
DTRACE_PROBE2(squeue__proc__end, squeue_t *,
DTRACE_PROBE3(squeue__proc__start, squeue_t *,
DTRACE_PROBE2(squeue__proc__end, squeue_t *,
squeue_worker_wakeup(squeue_t *sqp)
squeue_drain(squeue_t *sqp, uint_t proc_type, hrtime_t expire)
DTRACE_PROBE3(squeue__proc__start, squeue_t *,
DTRACE_PROBE2(squeue__proc__end, squeue_t *,
squeue_poll_thr_control(squeue_t *sqp)
squeue_polling_thread(squeue_t *sqp)
squeue_t *sqp = (squeue_t *)arg;
squeue_t *sqp;
static void tcp_squeue_add(squeue_t *);
tcp_squeue_add(squeue_t *sqp)
squeue_t *new_sqp;
squeue_t *sqp = (squeue_t *)arg2;
squeue_t *new_sqp;
squeue_t *sqp = (squeue_t *)arg2;
squeue_t *sqp = tcp->tcp_connp->conn_sqp;
squeue_t *sqp = (squeue_t *)arg;
ASSERT((squeue_t *)arg2 == connp->conn_sqp);
extern squeue_t *squeue_create(pri_t);
extern void squeue_bind(squeue_t *, processorid_t);
extern void squeue_unbind(squeue_t *);
extern void squeue_enter(squeue_t *, mblk_t *, mblk_t *,
extern uintptr_t *squeue_getprivate(squeue_t *, sqprivate_t);
squeue_t *sq_next; /* managed by squeue creator */
squeue_t *sqs_head;
squeue_t *sqs_default;
typedef void (*sq_enter_proc_t)(squeue_t *, mblk_t *, mblk_t *, uint32_t,
typedef void (*sq_drain_proc_t)(squeue_t *, uint_t, hrtime_t);