Home
last modified time | relevance | path

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

123

/illumos-gate/usr/src/lib/libfakekernel/common/
H A Dtaskq.c99 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
102 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
137 if (tq->tq_nalloc <= tq->tq_minalloc) { in task_free()
222 rv = (tq->tq_task.tqent_next == &tq->tq_task) && (tq->tq_active == 0); in taskq_empty()
232 while (tq->tq_task.tqent_next != &tq->tq_task || tq->tq_active != 0) in taskq_wait()
233 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); in taskq_wait()
329 tq->tq_task.tqent_next = &tq->tq_task; in taskq_create_proc()
330 tq->tq_task.tqent_prev = &tq->tq_task; in taskq_create_proc()
336 task_free(tq, task_alloc(tq, KM_SLEEP)); in taskq_create_proc()
361 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); in taskq_destroy()
[all …]
/illumos-gate/usr/src/uts/common/os/
H A Dtaskq.c757 if (tq->tq_tasks - tq->tq_executed > tq->tq_maxtasks) \
758 tq->tq_maxtasks = tq->tq_tasks - tq->tq_executed; \
793 tq->tq_task.tqent_next = &tq->tq_task; in taskq_constructor()
794 tq->tq_task.tqent_prev = &tq->tq_task; in taskq_constructor()
999 if (tq->tq_nalloc >= tq->tq_maxalloc) { in taskq_ent_alloc()
1050 if (tq->tq_nalloc <= tq->tq_minalloc) { in taskq_ent_free()
1338 rv = (tq->tq_task.tqent_next == &tq->tq_task) && (tq->tq_active == 0); in taskq_empty()
1354 while (tq->tq_task.tqent_next != &tq->tq_task || tq->tq_active != 0) in taskq_wait()
2062 tq->tq_kstat->ks_private = tq; in taskq_create_common()
2073 tq->tq_kstat->ks_private = tq; in taskq_create_common()
[all …]
/illumos-gate/usr/src/lib/libinetutil/common/
H A Dtq.c63 iu_tq_destroy(iu_tq_t *tq) in iu_tq_destroy() argument
69 destroy_timer(tq, node); in iu_tq_destroy()
72 free(tq); in iu_tq_destroy()
111 tq->iutq_head = node; in insert_timer()
156 if (tq->iutq_in_expire) { in destroy_timer()
236 remove_timer(tq, node); in iu_cancel_timer()
263 remove_timer(tq, node); in iu_adjust_timer()
327 tq->iutq_in_expire++; in iu_expire_timers()
370 remove_timer(tq, node); in iu_expire_timers()
375 tq->iutq_in_expire--; in iu_expire_timers()
[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()
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()
209 queued = tq.tq_tasks - tq.tq_executed; in taskq()
213 size_t bsize = tq.tq_nbuckets * sizeof (*tq.tq_buckets); in taskq()
222 tcount += (tq.tq_tcreates - tq.tq_tdeaths); in taskq()
398 taskq_t tq; in taskq_thread_walk_init() local
406 mdb_vread(&tq, sizeof (tq), wsp->walk_addr) != -1 && in taskq_thread_walk_init()
[all …]
H A Dthread.c589 taskq_t tq; in thread_getdesc() local
591 if (mdb_vread(&tq, sizeof (taskq_t), in thread_getdesc()
593 tq.tq_name[0] = '\0'; in thread_getdesc()
600 } else if (tq.tq_name[0] != '\0') { in thread_getdesc()
601 (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
1008 tq = NULL; in ql_target_reset()
1668 tq->loop_id, tq->d_id.b24); in ql_logout_fabric_port()
1677 rval = ql_log_iocb(ha, tq, tq->loop_id, flag, &mr); in ql_logout_fabric_port()
1685 rval = ql_log_iocb(ha, tq, tq->loop_id, flag, &mr); in ql_logout_fabric_port()
1690 tq, tq->loop_id, tq->d_id.b24, flag); in ql_logout_fabric_port()
1710 tq->d_id.b24, tq->loop_id); in ql_logout_fabric_port()
2045 tq->loop_id, tq->master_state, tq->slave_state); in ql_get_port_database()
2048 tq->flags = tq->prli_svc_param_word_3 & in ql_get_port_database()
2054 tq->flags = tq->prli_svc_param_word_3 & in ql_get_port_database()
[all …]
H A Dql_isr.c707 ql_tgt_t *tq; in ql_async_event() local
1293 tq->ub_seq_cnt < tq->ub_total_seg_cnt; cnt++) { in ql_async_event()
1512 tq->outcnt--; in ql_fast_fcp_post()
2246 ql_tgt_t *tq; in ql_status_error() local
2809 ql_tgt_t *tq; in ql_ip_entry() local
2957 ql_tgt_t *tq; in ql_ip_rcv_entry() local
3018 ql_tgt_t *tq; in ql_ip_rcv_cont_entry() local
3028 tq->ub_seq_cnt < tq->ub_total_seg_cnt; cnt++) { in ql_ip_rcv_cont_entry()
3067 ql_tgt_t *tq; in ql_ip_24xx_rcv_entry() local
3398 ql_tgt_t *tq; in ql_els_passthru_entry() local
[all …]
H A Dql_api.c5147 tq->flags, tq->d_id.b24); in ql_cmd_setup()
5468 tq->loop_id, tq->master_state); in ql_p2p_plogi()
5480 tq->loop_id, tq->master_state); in ql_p2p_plogi()
5504 tq->loop_id, tq->master_state); in ql_p2p_plogi()
6947 tq->loop_id, tq->port_name[0], tq->port_name[1], in ql_login_port()
6948 tq->port_name[2], tq->port_name[3], tq->port_name[4], in ql_login_port()
6949 tq->port_name[5], tq->port_name[6], tq->port_name[7]); in ql_login_port()
7207 tq->device.base_address = tq; in ql_dev_init()
10700 tq->port_name[1], tq->port_name[2], in ql_iidma()
10728 tq->d_id.b24, tq->iidma_rate); in ql_iidma()
[all …]
H A Dql_init.c3088 ql_tgt_t *tq; in ql_configure_n_port_info() local
3149 tq = &tmp_tq; in ql_configure_n_port_info()
3291 tq->d_id.b24, ha->n_port->n_port_handle, tq->loop_id); in ql_configure_n_port_info()
3458 ql_tgt_t *tq; in ql_configure_device_d_id() local
3680 ql_tgt_t *tq; in ql_configure_fabric() local
3689 if (tq != NULL) { in ql_configure_fabric()
4058 ql_tgt_t *tq; in ql_abort_isp() local
4257 ql_tgt_t *tq; in ql_requeue_all_cmds() local
4653 ql_tgt_t *tq; in ql_update_dev() local
4676 ha, tq); in ql_update_dev()
[all …]
H A Dql_xioctl.c956 ql_tgt_t *tq; in ql_qry_hba_port() local
1164 ql_tgt_t *tq; in ql_qry_disc_port() local
1278 ql_tgt_t *tq; in ql_qry_disc_tgt() local
1558 ql_tgt_t tq; in ql_fcct() local
2207 if (tq == NULL || !VALID_TARGET_ID(ha, tq->loop_id)) { in ql_scsi_passthru()
2478 rval = ql_login_fport(ha, tq, tq->loop_id, in ql_scsi_passthru()
2485 rval = ql_login_lport(ha, tq, tq->loop_id, in ql_scsi_passthru()
2816 if (tq == NULL || tq->flags & TQF_INITIATOR_DEVICE) { in ql_wwpn_to_scsiaddr()
5911 if (tq == NULL || !VALID_TARGET_ID(ha, tq->loop_id)) { in ql_get_statistics_fc()
6745 if (tq == NULL || !VALID_TARGET_ID(ha, tq->loop_id)) { in ql_get_target_id()
[all …]
H A Dql_iocb.c476 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()
726 pkt->target_id[1] = tq->d_id.b.area; in ql_command_24xx_iocb()
873 pkt->target_id[1] = tq->d_id.b.area; in ql_cmd_24xx_type_6_iocb()
1098 pkt->loop_id_l = LSB(tq->loop_id); in ql_ms_iocb()
1099 pkt->loop_id_h = MSB(tq->loop_id); in ql_ms_iocb()
1101 pkt->loop_id_h = LSB(tq->loop_id); in ql_ms_iocb()
1256 pkt->loop_id_l = LSB(tq->loop_id); in ql_ip_iocb()
1257 pkt->loop_id_h = MSB(tq->loop_id); in ql_ip_iocb()
[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/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/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()
H A Dstates.c76 lif->lif_iaid_id = iu_schedule_timer(tq, 60, in iaid_retry()
283 iu_cancel_timer(tq, inactivity_id, NULL) == 1) in insert_smach()
342 inactivity_id = iu_schedule_timer(tq, DHCP_INACTIVITY_WAIT, in free_smach()
662 retval = iu_cancel_timer(tq, dsmp->dsm_offer_timer, NULL); in cancel_offer_timer()
697 (void) iu_cancel_timer(tq, dsmp->dsm_start_timer, NULL); in cancel_smach_timers()
833 (void) iu_schedule_timer(tq, 60, duid_retry, NULL); in duid_retry()
/illumos-gate/usr/src/cmd/mdb/common/modules/qlc/
H A Dqlc.c829 ql_tgt_t *tq; in qlc_wdog_dcmd() local
905 if (tq->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()
920 if (tq->wdg.first == NULL) { in qlc_wdog_dcmd()
927 " at %p", tq->wdg.first); in qlc_wdog_dcmd()
1011 mdb_free(tq, sizeof (ql_tgt_t)); in qlc_wdog_dcmd()
1489 ql_tgt_t *tq; in qltgtq_dcmd() local
[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/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/io/ib/mgt/ibcm/
H A Dibcm_sm.c728 *argsp = tq->tq_args; in _NOTE()
749 tq->tq_args = args; in ibcm_recv_enqueue()
822 tq->tq_ibmf_msgp, tq->tq_args); in ibcm_recv_timeout_cb()
823 kmem_free(tq, sizeof (*tq)); in ibcm_recv_timeout_cb()
833 tq->tq_ibmf_msgp, tq->tq_args); in ibcm_recv_timeout_cb()
834 kmem_free(tq, sizeof (*tq)); in ibcm_recv_timeout_cb()
838 ibcm_drop_msg(tq->tq_ibmf_handle, tq->tq_ibmf_msgp); in ibcm_recv_timeout_cb()
860 tq = kmem_alloc(sizeof (*tq), KM_NOSLEEP); in ibcm_recv_add_one()
861 if (tq == NULL) { in ibcm_recv_add_one()
873 tq->tq_args = args; in ibcm_recv_add_one()
[all …]

123