Home
last modified time | relevance | path

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

123

/titanic_50/usr/src/lib/libzpool/common/
H A Dtaskq.c59 task_alloc(taskq_t *tq, int tqflags) in task_alloc() argument
64 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
65 tq->tq_freelist = t->tqent_next; in task_alloc()
67 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
81 tq->tq_maxalloc_wait++; in task_alloc()
82 rv = cv_timedwait(&tq->tq_maxalloc_cv, in task_alloc()
83 &tq->tq_lock, ddi_get_lbolt() + hz); in task_alloc()
84 tq->tq_maxalloc_wait--; in task_alloc()
88 mutex_exit(&tq->tq_lock); in task_alloc()
92 mutex_enter(&tq->tq_lock); in task_alloc()
[all …]
/titanic_50/usr/src/lib/libfakekernel/common/
H A Dtaskq.c89 task_alloc(taskq_t *tq, int tqflags) in task_alloc() argument
94 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
95 tq->tq_freelist = t->tqent_next; in task_alloc()
97 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
111 tq->tq_maxalloc_wait++; in task_alloc()
112 rv = cv_timedwait(&tq->tq_maxalloc_cv, in task_alloc()
113 &tq->tq_lock, ddi_get_lbolt() + hz); in task_alloc()
114 tq->tq_maxalloc_wait--; in task_alloc()
118 mutex_exit(&tq->tq_lock); in task_alloc()
122 mutex_enter(&tq->tq_lock); in task_alloc()
[all …]
/titanic_50/usr/src/uts/common/os/
H A Dtaskq.c691 #define TASKQ_D_RANDOM_DISPATCH_FAILURE(tq, flag) \ argument
698 #define TASKQ_S_RANDOM_DISPATCH_FAILURE(tq, flag) \ argument
701 (!(tq->tq_flags & TASKQ_PREPOPULATE) || \
702 (tq->tq_nalloc > tq->tq_minalloc)) && \
704 mutex_exit(&tq->tq_lock); \
708 #define TASKQ_S_RANDOM_DISPATCH_FAILURE(tq, flag) argument
709 #define TASKQ_D_RANDOM_DISPATCH_FAILURE(tq, flag) argument
737 #define TQ_DO_ENQUEUE(tq, tqe, func, arg, front) { \ argument
738 ASSERT(MUTEX_HELD(&tq->tq_lock)); \
741 TQ_PREPEND(tq->tq_task, tqe); \
[all …]
/titanic_50/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.c272 iu_handle_events(iu_eh_t *eh, iu_tq_t *tq) in iu_handle_events() argument
280 timeout = tq ? iu_earliest_timer(tq) : INFTIM; in iu_handle_events()
320 (void) iu_expire_timers(tq); in iu_handle_events()
/titanic_50/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.c574 taskq_t tq; in threadlist() local
626 if (mdb_vread(&tq, sizeof (taskq_t), (uintptr_t)t.t_taskq) == -1) in threadlist()
627 tq.tq_name[0] = '\0'; in threadlist()
637 if (tq.tq_name[0] != '\0') in threadlist()
638 mdb_printf(" TASKQ: %s\n", tq.tq_name); in threadlist()
657 if (tq.tq_name[0] != '\0') in threadlist()
658 mdb_printf(" tq:%s\n", tq.tq_name); in threadlist()
/titanic_50/usr/src/uts/common/io/fibre-channel/fca/qlc/
H A Dql_api.c141 static void ql_abort_device_queues(ql_adapter_state_t *ha, ql_tgt_t *tq);
1765 ql_tgt_t *tq; in ql_detach() local
1849 tq = link->base_address; in ql_detach()
1851 ql_dev_free(ha, tq); in ql_detach()
2519 ql_tgt_t *tq; in ql_unbind_port() local
2537 if ((tq = ql_loop_id_to_queue(ha, in ql_unbind_port()
2539 (void) ql_logout_fabric_port(ha, tq); in ql_unbind_port()
3701 ql_tgt_t *tq; in ql_abort() local
3718 tq = ql_d_id_to_queue(ha, d_id); in ql_abort()
3720 if ((tq == NULL) || (pha->task_daemon_flags & LOOP_DOWN)) { in ql_abort()
[all …]
H A Dql_mbx.c423 ql_tgt_t *tq; in ql_initialize_ip() local
446 tq = link->base_address; in ql_initialize_ip()
447 tq->ub_total_seg_cnt = 0; in ql_initialize_ip()
902 ql_clear_aca(ql_adapter_state_t *ha, ql_tgt_t *tq, uint16_t lun) in ql_clear_aca() argument
911 rval = ql_task_mgmt_iocb(ha, tq, lun, CF_CLEAR_ACA, 0); 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, lun, 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
966 if (tq == NULL) { in ql_target_reset()
[all …]
H A Dql_isr.c748 ql_tgt_t *tq; in ql_async_event() local
1221 if ((tq = ql_d_id_to_queue(ha, s_id)) == NULL) { in ql_async_event()
1232 tq->ub_sequence_length = mb[3]; in ql_async_event()
1233 tq->ub_total_seg_cnt = (uint8_t)(mb[3] / cnt); in ql_async_event()
1235 tq->ub_total_seg_cnt++; in ql_async_event()
1237 cnt = (uint16_t)(tq->ub_total_seg_cnt + 10); in ql_async_event()
1244 tq->ub_seq_id = ++ha->ub_seq_id; in ql_async_event()
1245 tq->ub_seq_cnt = 0; in ql_async_event()
1246 tq->ub_frame_ro = 0; in ql_async_event()
1247 tq->ub_loop_id = (uint16_t)(mb[0] == MBA_IP_BROADCAST ? in ql_async_event()
[all …]
H A Dql_xioctl.c913 ql_tgt_t *tq; in ql_qry_hba_port() local
1039 tq = link->base_address; in ql_qry_hba_port()
1041 if (!VALID_TARGET_ID(ha, tq->loop_id)) { in ql_qry_hba_port()
1046 if ((tq->flags & TQF_INITIATOR_DEVICE) == 0) { in ql_qry_hba_port()
1093 ql_tgt_t *tq; in ql_qry_disc_port() local
1112 tq = link->base_address; in ql_qry_disc_port()
1114 if (!VALID_TARGET_ID(ha, tq->loop_id)) { in ql_qry_disc_port()
1123 bcopy(tq->node_name, tmp_port.WWNN, in ql_qry_disc_port()
1125 bcopy(tq->port_name, tmp_port.WWPN, in ql_qry_disc_port()
1141 tmp_port.Id[1] = tq->d_id.b.domain; in ql_qry_disc_port()
[all …]
H A Dql_iocb.c433 ql_tgt_t *tq = sp->lun_queue->target_queue; in ql_command_iocb() local
444 pkt->target_l = LSB(tq->loop_id); in ql_command_iocb()
445 pkt->target_h = MSB(tq->loop_id); in ql_command_iocb()
447 pkt->target_h = LSB(tq->loop_id); in ql_command_iocb()
645 ql_tgt_t *tq = sp->lun_queue->target_queue; in ql_command_24xx_iocb() local
665 ddi_put16(pha->hba_buf.acc_handle, &pkt->n_port_hdl, tq->loop_id); in ql_command_24xx_iocb()
668 pkt->target_id[0] = tq->d_id.b.al_pa; in ql_command_24xx_iocb()
669 pkt->target_id[1] = tq->d_id.b.area; in ql_command_24xx_iocb()
670 pkt->target_id[2] = tq->d_id.b.domain; in ql_command_24xx_iocb()
777 ql_tgt_t *tq = sp->lun_queue->target_queue; in ql_cmd_24xx_type_6_iocb() local
[all …]
H A Dql_init.c2975 ql_tgt_t *tq; in ql_configure_n_port_info() local
2980 tq = &tmp_tq; in ql_configure_n_port_info()
2986 tq = link->base_address; in ql_configure_n_port_info()
2988 ql_remove_link(&ha->dev[index], &tq->device); in ql_configure_n_port_info()
2989 ql_dev_free(ha, tq); in ql_configure_n_port_info()
3014 tq->d_id.b.al_pa = 0; in ql_configure_n_port_info()
3015 tq->d_id.b.area = 0; in ql_configure_n_port_info()
3016 tq->d_id.b.domain = 0; in ql_configure_n_port_info()
3017 tq->loop_id = 0x7fe; in ql_configure_n_port_info()
3019 rval = ql_get_port_database(ha, tq, PDF_NONE); in ql_configure_n_port_info()
[all …]
/titanic_50/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
/titanic_50/usr/src/cmd/cmd-inet/sbin/dhcpagent/
H A Dipc_action.c90 iareq->ia_tid = iu_schedule_timer(tq, in ipc_action_start()
154 iu_cancel_timer(tq, dsmp->dsm_ia.ia_tid, NULL) == 1) { in ipc_action_finish()
178 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()
140 dsmp->dsm_offer_timer = iu_schedule_timer(tq, in dhcp_selecting()
H A Dagent.h57 extern iu_tq_t *tq;
/titanic_50/usr/src/lib/libinetutil/
H A DMakefile.com28 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 \
/titanic_50/usr/src/cmd/mdb/common/modules/qlc/
H A Dqlc.c811 ql_tgt_t *tq; in qlc_wdog_dcmd() local
848 tq = (ql_tgt_t *)mdb_alloc(sizeof (ql_tgt_t), UM_SLEEP); in qlc_wdog_dcmd()
876 if (mdb_vread(tq, sizeof (ql_tgt_t), in qlc_wdog_dcmd()
885 mdb_printf("flags: (%xh)", tq->flags); in qlc_wdog_dcmd()
887 if (tq->flags) { in qlc_wdog_dcmd()
888 ql_dump_flags((uint64_t)tq->flags, qltgt_flags); in qlc_wdog_dcmd()
892 tq->node_name[0], tq->node_name[1], in qlc_wdog_dcmd()
893 tq->node_name[2], tq->node_name[3], in qlc_wdog_dcmd()
894 tq->node_name[4], tq->node_name[5], in qlc_wdog_dcmd()
895 tq->node_name[6], tq->node_name[7]); in qlc_wdog_dcmd()
[all …]
/titanic_50/usr/src/cmd/ssh/ssh-keyscan/
H A Dssh-keyscan.c98 TAILQ_HEAD(conlist, Connection) tq; /* Timeout Queue */
460 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); in conalloc()
478 TAILQ_REMOVE(&tq, &fdcon[s], c_link); in confree()
486 TAILQ_REMOVE(&tq, &fdcon[s], c_link); in contouch()
489 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link); in contouch()
619 c = TAILQ_FIRST(&tq); in conloop()
652 c = TAILQ_FIRST(&tq); in conloop()
719 TAILQ_INIT(&tq); in main()
/titanic_50/usr/src/uts/sun4u/starfire/sys/
H A Didn.h1404 #define IDN_TIMERQ_IS_LOCKED(tq) (MUTEX_HELD(&(tq)->tq_mutex)) argument
1405 #define IDN_TIMERQ_LOCK(tq) (mutex_enter(&(tq)->tq_mutex)) argument
1406 #define IDN_TIMERQ_UNLOCK(tq) (mutex_exit(&(tq)->tq_mutex)) argument
1408 #define IDN_TIMERQ_INIT(tq) (idn_timerq_init(tq)) argument
1409 #define IDN_TIMERQ_DEINIT(tq) (idn_timerq_deinit(tq)) argument
1413 #define IDN_TIMER_START(tq, tp, tim) \ argument
1414 (idn_timer_start((tq), (tp), (tim)))
1415 #define IDN_TIMER_STOP(tq, typ, ck) \ argument
1416 ((void) idn_timer_stop((tq), (typ), (ck)))
1419 #define IDN_TIMER_GET(tq, typ, tp, ck) \ argument
[all …]
/titanic_50/usr/src/uts/sun4u/starfire/io/
H A Didn.c3608 idn_timerq_init(idn_timerq_t *tq) in idn_timerq_init() argument
3610 mutex_init(&tq->tq_mutex, NULL, MUTEX_DEFAULT, NULL); in idn_timerq_init()
3611 tq->tq_count = 0; in idn_timerq_init()
3612 tq->tq_queue = NULL; in idn_timerq_init()
3616 idn_timerq_deinit(idn_timerq_t *tq) in idn_timerq_deinit() argument
3618 ASSERT(tq->tq_queue == NULL); in idn_timerq_deinit()
3619 mutex_destroy(&tq->tq_mutex); in idn_timerq_deinit()
3628 idn_timer_get(idn_timerq_t *tq, int type, ushort_t tcookie) in idn_timer_get() argument
3632 ASSERT(IDN_TIMERQ_IS_LOCKED(tq)); in idn_timer_get()
3634 if ((tp = tq->tq_queue) == NULL) in idn_timer_get()
[all …]
/titanic_50/usr/src/cmd/ssh/sftp/
H A Dsftp-client.c778 TAILQ_ENTRY(request) tq; in do_download()
870 TAILQ_INSERT_TAIL(&requests, req, tq); in do_download()
884 req = TAILQ_NEXT(req, tq)) in do_download()
895 TAILQ_REMOVE(&requests, req, tq); in do_download()
918 TAILQ_REMOVE(&requests, req, tq); in do_download()
1017 TAILQ_ENTRY(outstanding_ack) tq; in do_upload()
1101 TAILQ_INSERT_TAIL(&acks, ack, tq); in do_upload()
1137 ack = TAILQ_NEXT(ack, tq)) in do_upload()
1141 TAILQ_REMOVE(&acks, ack, tq); in do_upload()
/titanic_50/usr/src/uts/common/sys/fibre-channel/fca/qlc/
H A Dql_mbx.h654 #define PD_PORT_LOGIN(tq) \ argument
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)

123