/illumos-gate/usr/src/lib/libzpool/common/ |
H A D | taskq.c | 59 task_alloc(taskq_t *tq, int tqflags) argument 64 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { 65 tq->tq_freelist = t->tqent_next; 67 if (tq->tq_nalloc >= tq->tq_maxalloc) { 81 tq->tq_maxalloc_wait++; 82 rv = cv_timedwait(&tq->tq_maxalloc_cv, 83 &tq 100 task_free(taskq_t *tq, taskq_ent_t *t) argument 117 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument 150 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument 182 taskq_wait(taskq_t *tq) argument 193 taskq_t *tq = arg; local 232 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local 278 taskq_destroy(taskq_t *tq) argument 316 taskq_member(taskq_t *tq, void *t) argument [all...] |
/illumos-gate/usr/src/lib/libfakekernel/common/ |
H A D | taskq.c | 89 task_alloc(taskq_t *tq, int tqflags) argument 94 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { 95 tq->tq_freelist = t->tqent_next; 97 if (tq->tq_nalloc >= tq->tq_maxalloc) { 111 tq->tq_maxalloc_wait++; 112 rv = cv_timedwait(&tq->tq_maxalloc_cv, 113 &tq 130 task_free(taskq_t *tq, taskq_ent_t *t) argument 147 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument 180 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument 212 taskq_wait(taskq_t *tq) argument 223 taskq_t *tq = arg; local 271 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local 316 taskq_destroy(taskq_t *tq) argument 354 taskq_member(taskq_t *tq, struct _kthread *t) argument [all...] |
/illumos-gate/usr/src/uts/common/os/ |
H A D | taskq.c | 155 * taskqid_t taskq_dispatch(tq, func, arg, flags): 191 * void taskq_dispatch_ent(tq, func, arg, flags, tqent) 202 * void taskq_wait(tq): 209 * void taskq_suspend(tq) 215 * int taskq_suspended(tq) 220 * void taskq_resume(tq) 224 * int taskq_member(tq, thread) 226 * Returns 1 if 'thread' belongs to taskq 'tq' and 0 otherwise. The 691 #define TASKQ_D_RANDOM_DISPATCH_FAILURE(tq, flag) \ 698 #define TASKQ_S_RANDOM_DISPATCH_FAILURE(tq, fla 773 taskq_t *tq = buf; local 794 taskq_t *tq = buf; local 848 taskq_update_nthreads(taskq_t *tq, uint_t ncpus) argument 870 taskq_cpupct_install(taskq_t *tq, cpupart_t *cpup) argument 885 taskq_cpupct_remove(taskq_t *tq) argument 898 taskq_t *tq; local 970 taskq_ent_alloc(taskq_t *tq, int flags) argument 1037 taskq_ent_free(taskq_t *tq, taskq_ent_t *tqe) argument 1063 taskq_ent_exists(taskq_t *tq, task_func_t func, void *arg) argument 1137 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument 1294 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *tqe) argument 1323 taskq_wait(taskq_t *tq) argument 1352 taskq_suspend(taskq_t *tq) argument 1378 taskq_suspended(taskq_t *tq) argument 1387 taskq_resume(taskq_t *tq) argument 1409 taskq_member(taskq_t *tq, kthread_t *thread) argument 1423 taskq_thread_create(taskq_t *tq) argument 1480 taskq_thread_wait(taskq_t *tq, kmutex_t *mx, kcondvar_t *cv, callb_cpr_t *cprinfo, clock_t timeout) argument 1508 taskq_t *tq = arg; local 1672 taskq_t *tq = bucket->tqbucket_taskq; local 1864 taskq_t *tq = kmem_cache_alloc(taskq_cache, KM_SLEEP); local 2041 taskq_destroy(taskq_t *tq) argument 2171 taskq_t *tq = b->tqbucket_taskq; local 2243 taskq_t *tq = ksp->ks_private; local 2264 taskq_t *tq = ksp->ks_private; local [all...] |
/illumos-gate/usr/src/lib/libinetutil/common/ |
H A D | tq.c | 63 iu_tq_destroy(iu_tq_t *tq) argument 67 for (node = tq->iutq_head; node != NULL; node = next_node) { 69 destroy_timer(tq, node); 72 free(tq); 76 * insert_timer(): inserts a timer node into a tq's timer list 85 insert_timer(iu_tq_t *tq, iu_timer_node_t *node, uint64_t msec) argument 100 if (tq->iutq_head != NULL && 101 tq->iutq_head->iutn_abs_timeout < node->iutn_abs_timeout) 102 for (after = tq->iutq_head; after->iutn_next != NULL; 108 node->iutn_next = after ? after->iutn_next : tq 128 remove_timer(iu_tq_t *tq, iu_timer_node_t *node) argument 147 destroy_timer(iu_tq_t *tq, iu_timer_node_t *node) argument 176 iu_schedule_timer(iu_tq_t *tq, uint32_t sec, iu_tq_callback_t *callback, void *arg) argument 193 iu_schedule_timer_ms(iu_tq_t *tq, uint64_t ms, iu_tq_callback_t *callback, void *arg) argument 225 iu_cancel_timer(iu_tq_t *tq, iu_timer_id_t timer_id, void **arg) argument 254 iu_adjust_timer(iu_tq_t *tq, iu_timer_id_t timer_id, uint32_t sec) argument 280 iu_earliest_timer(iu_tq_t *tq) argument 315 iu_expire_timers(iu_tq_t *tq) argument 400 get_timer_id(iu_tq_t *tq) argument 436 release_timer_id(iu_tq_t *tq, iu_timer_id_t timer_id) argument [all...] |
H A D | eh.c | 272 iu_handle_events(iu_eh_t *eh, iu_tq_t *tq) argument 280 timeout = tq ? iu_earliest_timer(tq) : INFTIM; 316 * timeout occurred. we must have a valid tq pointer 320 (void) iu_expire_timers(tq);
|
/illumos-gate/usr/src/cmd/mdb/common/modules/genunix/ |
H A D | taskq.c | 100 taskq_t tq; local 107 if (mdb_vread(&tq, sizeof (tq), addr) == -1) { 114 strncpy(tqe->tq_name, tq.tq_name, TASKQ_NAMELEN); 115 tqe->tq_instance = tq.tq_instance; 116 tqe->tq_flags = tq.tq_flags; 139 taskq_t tq; local 199 if (mdb_vread(&tq, sizeof (tq), addr) == -1) { 205 tq 398 taskq_t tq; local 441 taskq_t *tq = (taskq_t *)tti->tti_addr; local [all...] |
H A D | thread.c | 574 taskq_t tq; local 626 if (mdb_vread(&tq, sizeof (taskq_t), (uintptr_t)t.t_taskq) == -1) 627 tq.tq_name[0] = '\0'; 637 if (tq.tq_name[0] != '\0') 638 mdb_printf(" TASKQ: %s\n", tq.tq_name); 657 if (tq.tq_name[0] != '\0') 658 mdb_printf(" tq:%s\n", tq.tq_name);
|
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/qlc/ |
H A D | ql_mbx.c | 423 ql_tgt_t *tq; local 446 tq = link->base_address; 447 tq->ub_total_seg_cnt = 0; 892 * tq: target queue pointer. 902 ql_clear_aca(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun) argument 911 rval = ql_task_mgmt_iocb(ha, tq, lun, CF_CLEAR_ACA, 0); 915 mcp->mb[1] = tq->loop_id; 917 mcp->mb[1] = (uint16_t)(tq->loop_id << 8); 926 (void) ql_marker(ha, tq->loop_id, lun, MK_SYNC_ID); 944 * tq 954 ql_target_reset(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t delay) argument 1057 ql_abort_target(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t delay) argument 1112 ql_lun_reset(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun) argument 1163 ql_clear_task_set(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun) argument 1215 ql_abort_task_set(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun) argument 1269 ql_task_mgmt_iocb(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun, uint32_t flags, uint16_t delay) argument 1341 ql_loop_port_bypass(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 1389 ql_loop_port_enable(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 1439 ql_login_lport(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t loop_id, uint16_t opt) argument 1501 ql_login_fport(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t loop_id, uint16_t opt, ql_mbx_data_t *mr) argument 1578 ql_logout_fabric_port(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 1639 ql_log_iocb(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t loop_id, uint16_t flags, ql_mbx_data_t *mr) argument 1816 ql_get_port_database(ql_adapter_state_t *ha, ql_tgt_t *tq, uint8_t opt) argument 2638 ql_tgt_t *tq = sp->lun_queue->target_queue; local 2693 ql_tgt_t *tq = sp->lun_queue->target_queue; local [all...] |
H A D | ql_api.c | 141 static void ql_abort_device_queues(ql_adapter_state_t *ha, ql_tgt_t *tq); 1765 ql_tgt_t *tq; local 1849 tq = link->base_address; 1851 ql_dev_free(ha, tq); 2519 ql_tgt_t *tq; local 2537 if ((tq = ql_loop_id_to_queue(ha, 2539 (void) ql_logout_fabric_port(ha, tq); 3701 ql_tgt_t *tq; local 3718 tq = ql_d_id_to_queue(ha, d_id); 3720 if ((tq 3994 ql_tgt_t *tq; local 4717 ql_tgt_t *tq; local 4765 ql_tgt_t *tq; local 4907 ql_tgt_t *tq = NULL; local 5093 ql_tgt_t *tq = &tmp; local 5189 ql_tgt_t *tq = NULL; local 5337 ql_tgt_t *tq; local 5417 ql_tgt_t *tq; local 5548 ql_tgt_t *tq; local 6148 ql_tgt_t *tq; local 6212 ql_tgt_t *tq; local 6277 ql_busy_plogi(ql_adapter_state_t *ha, fc_packet_t *pkt, ql_tgt_t *tq) argument 6381 ql_tgt_t *tq, *tq2; local 6586 ql_login_fabric_port(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t loop_id) argument 6739 ql_tgt_t *tq; local 6789 ql_tgt_t *tq; local 6862 ql_dev_free(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 6921 ql_lun_queue(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun) argument 6990 ql_tgt_t *tq; local 7092 ql_task_mgmt(ql_adapter_state_t *ha, ql_tgt_t *tq, fc_packet_t *pkt, ql_srb_t *sp) argument 7166 ql_tgt_t *tq; local 7237 ql_tgt_t *tq; local 7432 ql_start_cmd(ql_adapter_state_t *ha, ql_tgt_t *tq, fc_packet_t *pkt, ql_srb_t *sp) argument 7696 ql_tgt_t *tq = lq->target_queue; local 7784 ql_tgt_t *tq; local 8541 ql_tgt_t *tq; local 8648 ql_send_logo(ql_adapter_state_t *vha, ql_tgt_t *tq, ql_head_t *done_q) argument 8727 ql_process_logo_for_device(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 8769 ql_send_plogi(ql_adapter_state_t *ha, ql_tgt_t *tq, ql_head_t *done_q) argument 8869 ql_abort_device(ql_adapter_state_t *ha, ql_tgt_t *tq, int drain) argument 9017 ql_tgt_t *tq; local 9101 ql_tgt_t *tq; local 9187 ql_process_rscn_for_device(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 9248 ql_tgt_t *tq; local 9457 ql_ub_frame_hdr(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t index, ql_head_t *done_q) argument 9799 ql_timeout_insert(ql_adapter_state_t *ha, ql_tgt_t *tq, ql_srb_t *sp) argument 9866 ql_tgt_t *tq; local 9975 ql_cmd_timeout(ql_adapter_state_t *ha, ql_tgt_t *tq, ql_srb_t *sp, uint32_t *set_flags, uint32_t *reset_flags) argument 10125 ql_tgt_t *tq; local 10213 ql_tgt_t *tq; local 10265 ql_tgt_t *tq; local 10371 ql_tgt_t *tq; local 10450 ql_abort_device_queues(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 10657 ql_tgt_t *tq; local 10692 ql_tgt_t *tq; local 15414 ql_tgt_t *tq; local 17623 ql_tgt_t *tq; local [all...] |
H A D | ql_isr.c | 748 ql_tgt_t *tq; local 1221 if ((tq = ql_d_id_to_queue(ha, s_id)) == NULL) { 1232 tq->ub_sequence_length = mb[3]; 1233 tq->ub_total_seg_cnt = (uint8_t)(mb[3] / cnt); 1235 tq->ub_total_seg_cnt++; 1237 cnt = (uint16_t)(tq->ub_total_seg_cnt + 10); 1244 tq->ub_seq_id = ++ha->ub_seq_id; 1245 tq->ub_seq_cnt = 0; 1246 tq->ub_frame_ro = 0; 1247 tq 1444 ql_tgt_t *tq = lq->target_queue; local 2121 ql_tgt_t *tq; local 2671 ql_tgt_t *tq; local 2809 ql_tgt_t *tq; local 2868 ql_tgt_t *tq; local 2915 ql_tgt_t *tq; local 2976 ql_tgt_t *tq; local 3197 ql_tgt_t *tq; local [all...] |
H A D | ql_xioctl.c | 913 ql_tgt_t *tq; local 1039 tq = link->base_address; 1041 if (!VALID_TARGET_ID(ha, tq->loop_id)) { 1046 if ((tq->flags & TQF_INITIATOR_DEVICE) == 0) { 1093 ql_tgt_t *tq; local 1112 tq = link->base_address; 1114 if (!VALID_TARGET_ID(ha, tq->loop_id)) { 1123 bcopy(tq->node_name, tmp_port.WWNN, 1125 bcopy(tq->port_name, tmp_port.WWPN, 1141 tmp_port.Id[1] = tq 1200 ql_tgt_t *tq; local 1473 ql_tgt_t tq; local 1988 ql_tgt_t *tq = NULL; local 2687 ql_tgt_t *tq; local 3588 ql_tgt_t *tq; local 3982 ql_lun_count(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 4014 ql_report_lun(ql_adapter_state_t *ha, ql_tgt_t *tq) argument 4267 ql_inq_scan(ql_adapter_state_t *ha, ql_tgt_t *tq, int count) argument 4352 ql_inq(ql_adapter_state_t *ha, ql_tgt_t *tq, int lun, ql_mbx_iocb_t *pkt, uint8_t inq_len) argument 4630 ql_tgt_t *tq; local 5715 ql_tgt_t *tq = NULL; local 6230 ql_tgt_t *tq; local 6375 ql_tgt_t *tq; local 7482 ql_tgt_t *tq; local [all...] |
H A D | ql_iocb.c | 433 ql_tgt_t *tq = sp->lun_queue->target_queue; local 444 pkt->target_l = LSB(tq->loop_id); 445 pkt->target_h = MSB(tq->loop_id); 447 pkt->target_h = LSB(tq->loop_id); 645 ql_tgt_t *tq = sp->lun_queue->target_queue; local 665 ddi_put16(pha->hba_buf.acc_handle, &pkt->n_port_hdl, tq->loop_id); 668 pkt->target_id[0] = tq->d_id.b.al_pa; 669 pkt->target_id[1] = tq->d_id.b.area; 670 pkt->target_id[2] = tq->d_id.b.domain; 777 ql_tgt_t *tq local 988 ql_tgt_t *tq = sp->lun_queue->target_queue; local 1068 ql_tgt_t *tq = sp->lun_queue->target_queue; local 1146 ql_tgt_t *tq = sp->lun_queue->target_queue; local 1231 ql_tgt_t *tq = sp->lun_queue->target_queue; local [all...] |
H A D | ql_init.c | 2975 ql_tgt_t *tq; local 2980 tq = &tmp_tq; 2986 tq = link->base_address; 2988 ql_remove_link(&ha->dev[index], &tq->device); 2989 ql_dev_free(ha, tq); 3014 tq->d_id.b.al_pa = 0; 3015 tq->d_id.b.area = 0; 3016 tq->d_id.b.domain = 0; 3017 tq->loop_id = 0x7fe; 3019 rval = ql_get_port_database(ha, tq, PDF_NON 3246 ql_tgt_t *tq; local 3468 ql_tgt_t *tq; local 3845 ql_tgt_t *tq; local [all...] |
/illumos-gate/usr/src/lib/libinetutil/ |
H A D | Makefile.com | 28 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/uts/common/io/scsi/adapters/iscsi/ |
H A D | iscsi_thread.c | 43 thread->tq = ddi_taskq_create(dip, name, 1, 46 if (thread->tq != NULL) { 90 ddi_taskq_wait(thread->tq); 105 ddi_taskq_destroy(thread->tq); 141 ddi_taskq_wait(thread->tq); 150 if (ddi_taskq_dispatch(thread->tq, iscsi_threads_entry, 196 ddi_taskq_wait(thread->tq);
|
H A D | iscsi_thread.h | 61 ddi_taskq_t *tq; member in struct:_iscsi_thread
|
/illumos-gate/usr/src/cmd/cmd-inet/sbin/dhcpagent/ |
H A D | agent.h | 48 * global variables: `tq' and `eh' represent the global timer queue 57 extern iu_tq_t *tq;
|
H A D | ipc_action.c | 90 iareq->ia_tid = iu_schedule_timer(tq, 154 iu_cancel_timer(tq, dsmp->dsm_ia.ia_tid, NULL) == 1) { 178 ipc_action_timeout(iu_tq_t *tq, void *arg) argument
|
H A D | select.c | 87 dsmp->dsm_start_timer = iu_schedule_timer_ms(tq, 140 dsmp->dsm_offer_timer = iu_schedule_timer(tq,
|
/illumos-gate/usr/src/uts/sun4u/starfire/sys/ |
H A D | idn.h | 1404 #define IDN_TIMERQ_IS_LOCKED(tq) (MUTEX_HELD(&(tq)->tq_mutex)) 1405 #define IDN_TIMERQ_LOCK(tq) (mutex_enter(&(tq)->tq_mutex)) 1406 #define IDN_TIMERQ_UNLOCK(tq) (mutex_exit(&(tq)->tq_mutex)) 1408 #define IDN_TIMERQ_INIT(tq) (idn_timerq_init(tq)) 1409 #define IDN_TIMERQ_DEINIT(tq) (idn_timerq_deinit(tq)) [all...] |
/illumos-gate/usr/src/cmd/mdb/common/modules/qlc/ |
H A D | qlc.c | 811 ql_tgt_t *tq; local 848 tq = (ql_tgt_t *)mdb_alloc(sizeof (ql_tgt_t), UM_SLEEP); 876 if (mdb_vread(tq, sizeof (ql_tgt_t), 885 mdb_printf("flags: (%xh)", tq->flags); 887 if (tq->flags) { 888 ql_dump_flags((uint64_t)tq->flags, qltgt_flags); 892 tq->node_name[0], tq->node_name[1], 893 tq->node_name[2], tq 1471 ql_tgt_t *tq; local [all...] |
/illumos-gate/usr/src/uts/common/sys/ |
H A D | cpudrv.h | 85 ddi_taskq_t *tq; /* taskq handler for CPU monitor */ member in struct:cpudrv_pm
|
/illumos-gate/usr/src/uts/sun4u/starfire/io/ |
H A D | idn.c | 3608 idn_timerq_init(idn_timerq_t *tq) argument 3610 mutex_init(&tq->tq_mutex, NULL, MUTEX_DEFAULT, NULL); 3611 tq->tq_count = 0; 3612 tq->tq_queue = NULL; 3616 idn_timerq_deinit(idn_timerq_t *tq) argument 3618 ASSERT(tq->tq_queue == NULL); 3619 mutex_destroy(&tq->tq_mutex); 3628 idn_timer_get(idn_timerq_t *tq, int type, ushort_t tcookie) argument 3632 ASSERT(IDN_TIMERQ_IS_LOCKED(tq)); 3634 if ((tp = tq 3682 idn_timer_start(idn_timerq_t *tq, idn_timer_t *tp, clock_t tval) argument 3752 idn_timer_stop(idn_timerq_t *tq, int type, ushort_t tcookie) argument 3834 idn_timer_dequeue(idn_timerq_t *tq, idn_timer_t *tp) argument [all...] |
/illumos-gate/usr/src/uts/common/sys/fibre-channel/fca/qlc/ |
H A D | ql_mbx.h | 654 #define PD_PORT_LOGIN(tq) \ 655 (tq->master_state == PD_STATE_PROCESS_LOGIN || \ 656 tq->master_state == PD_STATE_PORT_LOGGED_IN || \ 657 tq->slave_state == PD_STATE_PROCESS_LOGIN || \ 658 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; local 1749 tq = taskq_create(tq_name, thrs, minclsyspri, sctp_recvq_tq_task_min, 1751 if (tq == NULL) { 1758 sctps->sctps_recvq_tq_list[sctps->sctps_recvq_tq_list_cur_sz] = tq; 1777 taskq_t *tq; local 1789 tq = sctps->sctps_recvq_tq_list[next_tq]; 1790 if (taskq_dispatch(tq, sctp_process_recvq, sctp, 1792 sctp->sctp_recvq_tq = tq; 1805 tq = sctps->sctps_recvq_tq_list[sctps->sctps_recvq_tq_list_cur_sz - 1]; 1806 if (taskq_dispatch(tq, sctp_process_recv [all...] |