/illumos-gate/usr/src/lib/libfakekernel/common/ |
H A D | taskq.c | 99 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 D | taskq.c | 757 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 D | tq.c | 63 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 D | eh.c | 270 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 D | taskq.c | 100 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 D | thread.c | 589 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 D | ql_mbx.c | 423 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 D | ql_isr.c | 707 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 D | ql_api.c | 5147 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 D | ql_init.c | 3088 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 D | ql_xioctl.c | 956 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 D | ql_iocb.c | 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() 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 D | iscsi_thread.c | 43 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 D | iscsi_thread.h | 61 ddi_taskq_t *tq; member
|
/illumos-gate/usr/src/lib/libinetutil/ |
H A D | Makefile.com | 29 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 D | ipc_action.c | 89 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 D | select.c | 87 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 D | agent.h | 55 extern iu_tq_t *tq;
|
H A D | agent.c | 68 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 D | states.c | 76 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 D | qlc.c | 829 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 D | ql_mbx.h | 797 #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 D | sctp.c | 1725 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 D | libzfs_mount.c | 1335 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 D | ibcm_sm.c | 728 *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 …]
|