Home
last modified time | relevance | path

Searched refs:tq (Results 1 – 25 of 66) sorted by relevance

123

/illumos-gate/usr/src/uts/common/os/
H A Dtaskq.c700 #define TASKQ_D_RANDOM_DISPATCH_FAILURE(tq, flag) \ argument
707 #define TASKQ_S_RANDOM_DISPATCH_FAILURE(tq, flag) \ argument
710 (!(tq->tq_flags & TASKQ_PREPOPULATE) || \
711 (tq->tq_nalloc > tq->tq_minalloc)) && \
713 mutex_exit(&tq->tq_lock); \
717 #define TASKQ_S_RANDOM_DISPATCH_FAILURE(tq, flag) argument
718 #define TASKQ_D_RANDOM_DISPATCH_FAILURE(tq, flag) argument
746 #define TQ_DO_ENQUEUE(tq, tqe, func, arg, front) { \ argument
747 ASSERT(MUTEX_HELD(&tq->tq_lock)); \
750 TQ_PREPEND(tq->tq_task, tqe); \
[all …]
/illumos-gate/usr/src/lib/libfakekernel/common/
H A Dtaskq.c94 task_alloc(taskq_t *tq, int tqflags) in task_alloc() argument
99 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
100 tq->tq_freelist = t->tqent_next; in task_alloc()
102 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
116 tq->tq_maxalloc_wait++; in task_alloc()
117 rv = cv_timedwait(&tq->tq_maxalloc_cv, in task_alloc()
118 &tq->tq_lock, ddi_get_lbolt() + hz); in task_alloc()
119 tq->tq_maxalloc_wait--; in task_alloc()
123 mutex_exit(&tq->tq_lock); in task_alloc()
127 mutex_enter(&tq->tq_lock); in task_alloc()
[all …]
/illumos-gate/usr/src/lib/libinetutil/common/
H A Dtq.c63 iu_tq_destroy(iu_tq_t *tq) in iu_tq_destroy() argument
67 for (node = tq->iutq_head; node != NULL; node = next_node) { in iu_tq_destroy()
69 destroy_timer(tq, node); in iu_tq_destroy()
72 free(tq); in iu_tq_destroy()
85 insert_timer(iu_tq_t *tq, iu_timer_node_t *node, uint64_t msec) in insert_timer() argument
100 if (tq->iutq_head != NULL && in insert_timer()
101 tq->iutq_head->iutn_abs_timeout < node->iutn_abs_timeout) in insert_timer()
102 for (after = tq->iutq_head; after->iutn_next != NULL; in insert_timer()
108 node->iutn_next = after ? after->iutn_next : tq->iutq_head; in insert_timer()
111 tq->iutq_head = node; in insert_timer()
[all …]
H A Deh.c270 iu_handle_events(iu_eh_t *eh, iu_tq_t *tq) in iu_handle_events() argument
278 timeout = tq ? iu_earliest_timer(tq) : INFTIM; in iu_handle_events()
318 (void) iu_expire_timers(tq); in iu_handle_events()
/illumos-gate/usr/src/cmd/mdb/common/modules/genunix/
H A Dtaskq.c100 taskq_t tq; in tq_fill() local
107 if (mdb_vread(&tq, sizeof (tq), addr) == -1) { in tq_fill()
114 strncpy(tqe->tq_name, tq.tq_name, TASKQ_NAMELEN); in tq_fill()
115 tqe->tq_instance = tq.tq_instance; in tq_fill()
116 tqe->tq_flags = tq.tq_flags; in tq_fill()
139 taskq_t tq; in taskq() local
199 if (mdb_vread(&tq, sizeof (tq), addr) == -1) { in taskq()
205 tq.tq_name[sizeof (tq.tq_name) - 1] = 0; in taskq()
207 tact = tq.tq_active; in taskq()
208 tcount = tq.tq_nthreads; in taskq()
[all …]
H A Dthread.c590 taskq_t tq; in thread_getdesc() local
592 if (mdb_vread(&tq, sizeof (taskq_t), in thread_getdesc()
594 tq.tq_name[0] = '\0'; in thread_getdesc()
601 } else if (tq.tq_name[0] != '\0') { in thread_getdesc()
602 (void) mdb_snprintf(buf, bufsize, "tq:%s", tq.tq_name); in thread_getdesc()
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/qlc/
H A Dql_mbx.c423 ql_tgt_t *tq; in ql_initialize_ip() local
445 tq = link->base_address; in ql_initialize_ip()
446 tq->ub_total_seg_cnt = 0; in ql_initialize_ip()
901 ql_clear_aca(ql_adapter_state_t *ha, ql_tgt_t *tq, ql_lun_t *lq) in ql_clear_aca() argument
910 rval = ql_task_mgmt_iocb(ha, tq, lq->lun_addr, in ql_clear_aca()
915 mcp->mb[1] = tq->loop_id; in ql_clear_aca()
917 mcp->mb[1] = (uint16_t)(tq->loop_id << 8); in ql_clear_aca()
926 (void) ql_marker(ha, tq->loop_id, lq, MK_SYNC_ID); in ql_clear_aca()
954 ql_target_reset(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t delay) in ql_target_reset() argument
965 ql_requeue_pending_cmds(ha, tq); in ql_target_reset()
[all …]
H A Dql_isr.c707 ql_tgt_t *tq; in ql_async_event() local
1261 if ((tq = ql_d_id_to_queue(ha, s_id)) == NULL) { in ql_async_event()
1272 tq->ub_sequence_length = mb[3]; in ql_async_event()
1273 tq->ub_total_seg_cnt = (uint8_t)(mb[3] / cnt); in ql_async_event()
1275 tq->ub_total_seg_cnt++; in ql_async_event()
1277 cnt = (uint16_t)(tq->ub_total_seg_cnt + 10); in ql_async_event()
1284 tq->ub_seq_id = ++ha->ub_seq_id; in ql_async_event()
1285 tq->ub_seq_cnt = 0; in ql_async_event()
1286 tq->ub_frame_ro = 0; in ql_async_event()
1287 tq->ub_loop_id = (uint16_t)(mb[0] == MBA_IP_BROADCAST ? in ql_async_event()
[all …]
H A Dql_api.c143 static void ql_abort_device_queues(ql_adapter_state_t *ha, ql_tgt_t *tq);
2004 ql_tgt_t *tq; in ql_detach() local
2107 tq = link->base_address; in ql_detach()
2109 ql_dev_free(ha, tq); in ql_detach()
2801 ql_tgt_t *tq; in ql_unbind_port() local
2820 if ((tq = ql_loop_id_to_queue(ha, in ql_unbind_port()
2822 (void) ql_logout_fabric_port(ha, tq); in ql_unbind_port()
3958 ql_tgt_t *tq; in ql_abort() local
3976 tq = ql_d_id_to_queue(ha, d_id); in ql_abort()
3978 if ((tq == NULL) || (lq = sp->lun_queue) == NULL || in ql_abort()
[all …]
H A Dql_init.c3088 ql_tgt_t *tq; in ql_configure_n_port_info() local
3105 tq = link->base_address; in ql_configure_n_port_info()
3110 if ((tq->loop_id != 0x7ff) && in ql_configure_n_port_info()
3111 (tq->loop_id != 0x7fe)) { in ql_configure_n_port_info()
3114 tq, PDF_NONE); in ql_configure_n_port_info()
3116 (tq->master_state == in ql_configure_n_port_info()
3121 tq->d_id.b24, in ql_configure_n_port_info()
3122 tq->loop_id); in ql_configure_n_port_info()
3123 bcopy((void *)&tq->port_name[0], in ql_configure_n_port_info()
3127 bcopy((void *)&tq->node_name[0], in ql_configure_n_port_info()
[all …]
H A Dql_xioctl.c956 ql_tgt_t *tq; in ql_qry_hba_port() local
1104 tq = link->base_address; in ql_qry_hba_port()
1106 if (!VALID_TARGET_ID(ha, tq->loop_id) || in ql_qry_hba_port()
1107 tq->d_id.b24 == FS_MANAGEMENT_SERVER) { in ql_qry_hba_port()
1111 if (tq->flags & (TQF_RSCN_RCVD | TQF_IIDMA_NEEDED | in ql_qry_hba_port()
1117 if ((tq->flags & TQF_INITIATOR_DEVICE) == 0) { in ql_qry_hba_port()
1164 ql_tgt_t *tq; in ql_qry_disc_port() local
1183 tq = link->base_address; in ql_qry_disc_port()
1185 if (!VALID_TARGET_ID(ha, tq->loop_id) || in ql_qry_disc_port()
1186 tq->d_id.b24 == FS_MANAGEMENT_SERVER) { in ql_qry_disc_port()
[all …]
H A Dql_iocb.c464 ql_tgt_t *tq = sp->lun_queue->target_queue; in ql_command_iocb() local
476 pkt->target_l = LSB(tq->loop_id); in ql_command_iocb()
477 pkt->target_h = MSB(tq->loop_id); in ql_command_iocb()
479 pkt->target_h = LSB(tq->loop_id); in ql_command_iocb()
694 ql_tgt_t *tq = sp->lun_queue->target_queue; in ql_command_24xx_iocb() local
722 ddi_put16(req_q->req_ring.acc_handle, &pkt->n_port_hdl, tq->loop_id); in ql_command_24xx_iocb()
725 pkt->target_id[0] = tq->d_id.b.al_pa; in ql_command_24xx_iocb()
726 pkt->target_id[1] = tq->d_id.b.area; in ql_command_24xx_iocb()
727 pkt->target_id[2] = tq->d_id.b.domain; in ql_command_24xx_iocb()
836 ql_tgt_t *tq = sp->lun_queue->target_queue; in ql_cmd_24xx_type_6_iocb() local
[all …]
/illumos-gate/usr/src/uts/common/io/scsi/adapters/iscsi/
H A Discsi_thread.c43 thread->tq = ddi_taskq_create(dip, name, 1, in iscsi_thread_create()
46 if (thread->tq != NULL) { in iscsi_thread_create()
90 ddi_taskq_wait(thread->tq); in iscsi_thread_destroy()
105 ddi_taskq_destroy(thread->tq); in iscsi_thread_destroy()
141 ddi_taskq_wait(thread->tq); in iscsi_thread_start()
150 if (ddi_taskq_dispatch(thread->tq, iscsi_threads_entry, in iscsi_thread_start()
196 ddi_taskq_wait(thread->tq); in iscsi_thread_stop()
H A Discsi_thread.h61 ddi_taskq_t *tq; member
/illumos-gate/usr/src/cmd/cmd-inet/sbin/dhcpagent/
H A Dipc_action.c89 iareq->ia_tid = iu_schedule_timer(tq, in ipc_action_start()
155 iu_cancel_timer(tq, dsmp->dsm_ia.ia_tid, NULL) == 1) { in ipc_action_finish()
179 ipc_action_timeout(iu_tq_t *tq, void *arg) in ipc_action_timeout() argument
H A Dselect.c87 dsmp->dsm_start_timer = iu_schedule_timer_ms(tq, in set_start_timer()
138 dsmp->dsm_offer_timer = iu_schedule_timer(tq, in dhcp_selecting()
H A Dagent.h55 extern iu_tq_t *tq;
H A Dagent.c68 iu_tq_t *tq; variable
209 tq = iu_tq_create(); in main()
212 if (eh == NULL || tq == NULL) { in main()
251 inactivity_id = iu_schedule_timer(tq, DHCP_INACTIVITY_WAIT, in main()
351 switch (iu_handle_events(eh, tq)) { in main()
374 iu_tq_destroy(tq); in main()
/illumos-gate/usr/src/lib/libinetutil/
H A DMakefile.com29 OBJECTS = octet.o inetutil.o ifspec.o ifaddrlist.o ifaddrlistx.o eh.o tq.o
41 $(SRCDIR)/ifspec.c $(SRCDIR)/eh.c $(SRCDIR)/tq.c \
/illumos-gate/usr/src/cmd/mdb/common/modules/qlc/
H A Dqlc.c829 ql_tgt_t *tq; in qlc_wdog_dcmd() local
866 tq = (ql_tgt_t *)mdb_alloc(sizeof (ql_tgt_t), UM_SLEEP); in qlc_wdog_dcmd()
894 if (mdb_vread(tq, sizeof (ql_tgt_t), in qlc_wdog_dcmd()
903 mdb_printf("flags: (%xh)", tq->flags); in qlc_wdog_dcmd()
905 if (tq->flags) { in qlc_wdog_dcmd()
906 ql_dump_flags((uint64_t)tq->flags, qltgt_flags); in qlc_wdog_dcmd()
910 tq->node_name[0], tq->node_name[1], in qlc_wdog_dcmd()
911 tq->node_name[2], tq->node_name[3], in qlc_wdog_dcmd()
912 tq->node_name[4], tq->node_name[5], in qlc_wdog_dcmd()
913 tq->node_name[6], tq->node_name[7]); in qlc_wdog_dcmd()
[all …]
/illumos-gate/usr/src/uts/common/sys/fibre-channel/fca/qlc/
H A Dql_mbx.h797 #define PD_PORT_LOGIN(tq) \ argument
798 (tq->master_state == PD_STATE_PROCESS_LOGIN || \
799 tq->master_state == PD_STATE_PORT_LOGGED_IN || \
800 tq->slave_state == PD_STATE_PROCESS_LOGIN || \
801 tq->slave_state == PD_STATE_PORT_LOGGED_IN)
/illumos-gate/usr/src/uts/common/inet/sctp/
H A Dsctp.c1725 taskq_t *tq; in sctp_inc_taskq() local
1749 tq = taskq_create(tq_name, thrs, minclsyspri, sctp_recvq_tq_task_min, in sctp_inc_taskq()
1751 if (tq == NULL) { in sctp_inc_taskq()
1758 sctps->sctps_recvq_tq_list[sctps->sctps_recvq_tq_list_cur_sz] = tq; in sctp_inc_taskq()
1777 taskq_t *tq; in sctp_find_next_tq() local
1789 tq = sctps->sctps_recvq_tq_list[next_tq]; in sctp_find_next_tq()
1790 if (taskq_dispatch(tq, sctp_process_recvq, sctp, in sctp_find_next_tq()
1792 sctp->sctp_recvq_tq = tq; in sctp_find_next_tq()
1805 tq = sctps->sctps_recvq_tq_list[sctps->sctps_recvq_tq_list_cur_sz - 1]; in sctp_find_next_tq()
1806 if (taskq_dispatch(tq, sctp_process_recvq, sctp, TQ_NOSLEEP) != in sctp_find_next_tq()
[all …]
/illumos-gate/usr/src/uts/common/io/ib/mgt/ibcm/
H A Dibcm_sm.c718 ibcm_taskq_args_t *tq; in _NOTE() local
725 tq = ibcm_recv_array + ibcm_get; in _NOTE()
726 *ibmf_handlep = tq->tq_ibmf_handle; in _NOTE()
727 *msgpp = tq->tq_ibmf_msgp; in _NOTE()
728 *argsp = tq->tq_args; in _NOTE()
736 ibcm_taskq_args_t *tq; in ibcm_recv_enqueue() local
745 tq = ibcm_recv_array + next; in ibcm_recv_enqueue()
746 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*tq)) in ibcm_recv_enqueue()
747 tq->tq_ibmf_handle = ibmf_handle; in ibcm_recv_enqueue()
748 tq->tq_ibmf_msgp = msgp; in ibcm_recv_enqueue()
[all …]
/illumos-gate/usr/src/lib/libzfs/common/
H A Dlibzfs_mount.c1335 size_t num_handles, int idx, zfs_iter_f func, void *data, zfs_taskq_t *tq) in zfs_dispatch_mount() argument
1340 mnt_param->mnt_tq = tq; in zfs_dispatch_mount()
1347 (void) zfs_taskq_dispatch(tq, zfs_mount_task, (void*)mnt_param, in zfs_dispatch_mount()
1487 zfs_taskq_t *tq = zfs_taskq_create("mount_taskq", mount_tq_nthr, 0, in zfs_foreach_mountpoint() local
1506 tq); in zfs_foreach_mountpoint()
1509 zfs_taskq_wait(tq); /* wait for all scheduled mounts to complete */ in zfs_foreach_mountpoint()
1510 zfs_taskq_destroy(tq); in zfs_foreach_mountpoint()
/illumos-gate/usr/src/uts/common/rpc/sec_gss/
H A Dsvc_rpcsec_gss.c268 taskq_t *tq; in svc_gss_create_taskq() local
276 tq = taskq_create_proc("rpcsec_gss_init_taskq", in svc_gss_create_taskq()
281 if (tq == NULL) in svc_gss_create_taskq()
284 return (tq); in svc_gss_create_taskq()
1032 taskq_t *tq = zsd->sgz_init_taskq; in rpcsec_gss_init() local
1034 if (tq == NULL) { in rpcsec_gss_init()
1038 tq = zsd->sgz_init_taskq; in rpcsec_gss_init()
1040 if (tq == NULL) { in rpcsec_gss_init()
1109 if (taskq_dispatch(tq, svcrpcsec_gss_taskq_func, arg, TQ_SLEEP) in rpcsec_gss_init()

123