Searched defs:tq (Results 1 - 25 of 40) sorted by relevance

12

/illumos-gate/usr/src/cmd/cmd-inet/sbin/dhcpagent/
H A Dipc_action.c90 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 Dagent.c65 iu_tq_t *tq; variable
202 tq = iu_tq_create();
205 if (eh == NULL || tq == NULL) {
244 inactivity_id = iu_schedule_timer(tq, DHCP_INACTIVITY_WAIT,
344 switch (iu_handle_events(eh, tq)) {
367 iu_tq_destroy(tq);
/illumos-gate/usr/src/uts/common/io/scsi/adapters/iscsi/
H A Discsi_thread.h61 ddi_taskq_t *tq; member in struct:_iscsi_thread
/illumos-gate/usr/src/lib/libinetutil/common/
H A Deh.c272 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);
H A Dtq.c63 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...]
/illumos-gate/usr/src/cmd/cmd-inet/usr.lib/inetd/
H A Dwait.c155 method_timeout(iu_tq_t *tq, void *arg) argument
H A Dinetd.c651 conn_rate_online(iu_tq_t *tq, void *arg) argument
804 retry_bind(iu_tq_t *tq, void *arg) argument
/illumos-gate/usr/src/lib/libzpool/common/
H A Dtaskq.c59 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/uts/common/io/fibre-channel/fca/qlc/
H A Dql_iocb.c433 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 Dql_ioctl.c1907 ql_tgt_t *tq; local
1920 tq = link->base_address;
1922 if (!VALID_TARGET_ID(ha, tq->loop_id)) {
1930 bcopy(tq->port_name, dev.wwpn, 8);
1931 dev.address = tq->d_id.b24;
1932 dev.loop_id = tq->loop_id;
1933 if (tq->flags & TQF_TAPE_DEVICE) {
1935 } else if (tq->flags & TQF_INITIATOR_DEVICE) {
H A Dql_isr.c748 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 Dql_init.c2975 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...]
H A Dql_mbx.c423 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...]
/illumos-gate/usr/src/uts/common/sys/
H A Dcpudrv.h85 ddi_taskq_t *tq; /* taskq handler for CPU monitor */ member in struct:cpudrv_pm
/illumos-gate/usr/src/lib/libfakekernel/common/
H A Dtaskq.c89 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/cmd/mdb/common/modules/genunix/
H A Dtaskq.c100 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 Dthread.c574 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/cmd/mdb/common/modules/qlc/
H A Dqlc.c811 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/lib/libc/port/i18n/
H A Dgettext_real.c291 Nlstmp *tp, *tq; local
295 tq = tp->next;
297 tp = tq;
/illumos-gate/usr/src/cmd/cmd-inet/usr.lib/ilbd/
H A Dilbd_hc.c647 ilbd_hc_kill_timer(iu_tq_t *tq, void *arg) argument
660 ilbd_hc_probe_timer(iu_tq_t *tq, void *arg) argument
/illumos-gate/usr/src/lib/libshell/common/sh/
H A Dnvtype.c1291 Namval_t *tq; local
1294 if(nv_isarray(np) && (tq=nv_type(np)))
1296 if(tp==tq)
/illumos-gate/usr/src/uts/common/inet/ip/
H A Dip_netinfo.c938 ddi_taskq_t *tq = NULL; local
959 tq = eventq_queue_in;
974 tq = eventq_queue_out;
1006 ASSERT(tq != NULL);
1009 if (ddi_taskq_dispatch(tq, func, (void *)inject,
/illumos-gate/usr/src/uts/common/inet/sctp/
H A Dsctp.c1725 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...]
/illumos-gate/usr/src/uts/common/os/
H A Dtaskq.c155 * 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/uts/common/xen/os/
H A Dxvdi.c1360 ddi_taskq_t *tq; local
1379 tq = pdp->xd_xb_watch_taskq;
1382 if (tq != NULL)
1383 ddi_taskq_destroy(tq);

Completed in 134 milliseconds

12