| /illumos-gate/usr/src/cmd/vntsd/ |
| H A D | console.c | 54 display_domain_name(vntsd_cons_t *consp, int *fd) in display_domain_name() argument
60 if (consp->clientpq != NULL) { in display_domain_name()
62 } else if (consp->status & VNTSD_CONS_DELETED) { in display_domain_name()
69 consp->cons_no, consp->domain_name, status, vntsd_eol); in display_domain_name()
105 create_write_thread(vntsd_cons_t *consp) in create_write_thread() argument
108 assert(consp); in create_write_thread()
111 (void) mutex_lock(&consp->lock); in create_write_thread()
113 (void *)consp, 0, &consp->wr_tid)) { in create_write_thread()
117 thr_self(), consp->cons_no); in create_write_thread()
118 (void) close(consp->vcc_fd); in create_write_thread()
[all …]
|
| H A D | vntsdvcc.c | 66 free_cons(vntsd_cons_t *consp) in free_cons() argument
68 assert(consp); in free_cons()
69 (void) mutex_destroy(&consp->lock); in free_cons()
70 (void) cond_destroy(&consp->cvp); in free_cons()
71 if (consp->vcc_fd != -1) in free_cons()
72 (void) close(consp->vcc_fd); in free_cons()
73 free(consp); in free_cons()
93 cleanup_cons(vntsd_cons_t *consp) in cleanup_cons() argument
98 assert(consp); in cleanup_cons()
100 consp->cons_no); in cleanup_cons()
[all …]
|
| H A D | write.c | 63 write_chk_status(vntsd_cons_t *consp, int status) in write_chk_status() argument
66 if ((consp->status & VNTSD_CONS_DELETED) || (consp->clientpq == NULL)) { in write_chk_status()
72 assert(consp->group != NULL); in write_chk_status()
73 if (vntsd_vcc_err(consp) != VNTSD_STATUS_CONTINUE) { in write_chk_status()
169 read_vcc(vntsd_cons_t *consp, char *buf, ssize_t *sz) in read_vcc() argument
172 *sz = read(consp->vcc_fd, buf, VNTSD_MAX_BUF_SIZE); in read_vcc()
209 vntsd_write_thread(vntsd_cons_t *consp) in vntsd_write_thread() argument
216 D1(stderr, "t@%d vntsd_write@%d\n", thr_self(), consp->vcc_fd); in vntsd_write_thread()
218 assert(consp); in vntsd_write_thread()
219 write_chk_status(consp, VNTSD_SUCCESS); in vntsd_write_thread()
[all …]
|
| H A D | read.c | 85 vntsd_cons_t *consp; in acquire_writer() local
93 consp = clientp->cons; in acquire_writer()
95 assert(consp); in acquire_writer()
97 (void) mutex_lock(&consp->lock); in acquire_writer()
99 assert(consp->clientpq != NULL); in acquire_writer()
100 if (consp->clientpq->handle == clientp) { in acquire_writer()
102 (void) mutex_unlock(&consp->lock); in acquire_writer()
107 writerp = (vntsd_client_t *)(consp->clientpq->handle); in acquire_writer()
111 rv = vntsd_que_rm(&(consp->clientpq), clientp); in acquire_writer()
117 consp->clientpq->handle = clientp; in acquire_writer()
[all …]
|
| H A D | cmd.c | 82 vntsd_cons_t *consp; in genbrk() local
87 consp = clientp->cons; in genbrk()
89 consp->vcc_fd, clientp->sockfd); in genbrk()
91 assert(consp->clientpq != NULL); in genbrk()
92 if (consp->clientpq->handle != clientp) { in genbrk()
99 if (ioctl(consp->vcc_fd, TCSBRK, NULL)) { in genbrk()
111 vntsd_cons_t *consp; in genaltbrk() local
117 consp = clientp->cons; in genaltbrk()
119 consp->vcc_fd, clientp->sockfd); in genaltbrk()
121 assert(consp->clientpq != NULL); in genaltbrk()
[all …]
|
| H A D | common.c | 207 vntsd_cons_by_consno(vntsd_cons_t *consp, int *cons_id) in vntsd_cons_by_consno() argument
209 if (consp->status & VNTSD_CONS_DELETED) { in vntsd_cons_by_consno()
212 return (consp->cons_no == *cons_id); in vntsd_cons_by_consno()
426 vntsd_vcc_cons_alive(vntsd_cons_t *consp) in vntsd_vcc_cons_alive() argument
431 assert(consp); in vntsd_vcc_cons_alive()
432 assert(consp->group); in vntsd_vcc_cons_alive()
435 (void) strncpy(vcc_cons.domain_name, consp->domain_name, MAXPATHLEN); in vntsd_vcc_cons_alive()
436 (void) strncpy(vcc_cons.group_name, consp->group->group_name, in vntsd_vcc_cons_alive()
438 vcc_cons.tcp_port = consp->group->tcp_port; in vntsd_vcc_cons_alive()
439 vcc_cons.cons_no = consp->cons_no; in vntsd_vcc_cons_alive()
[all …]
|
| H A D | vntsd.c | 642 vntsd_vcc_err(vntsd_cons_t *consp) in vntsd_vcc_err() argument
646 assert(consp); in vntsd_vcc_err()
647 groupp = consp->group; in vntsd_vcc_err()
650 if (consp->status & VNTSD_CONS_DELETED) { in vntsd_vcc_err()
655 if (vntsd_vcc_cons_alive(consp)) { in vntsd_vcc_err()
661 (void) mutex_lock(&consp->lock); in vntsd_vcc_err()
662 consp->status |= VNTSD_CONS_DELETED; in vntsd_vcc_err()
668 (void) mutex_unlock(&consp->lock); in vntsd_vcc_err()
|
| H A D | vntsd.h | 431 void *vntsd_write_thread(vntsd_cons_t *consp);
433 boolean_t vntsd_cons_by_consno(vntsd_cons_t *consp, int *cons_id);
470 int vntsd_vcc_err(vntsd_cons_t *consp);
472 boolean_t vntsd_vcc_cons_alive(vntsd_cons_t *consp);
475 boolean_t vntsd_mark_deleted_cons(vntsd_cons_t *consp);
|
| /illumos-gate/usr/src/uts/common/xen/io/ |
| H A D | xnf.c | 2271 xnf_rx_one_packet(xnf_t *xnfp, RING_IDX prod, RING_IDX *consp, mblk_t **mpp) in xnf_rx_one_packet() argument
2277 RING_IDX cons = *consp; in xnf_rx_one_packet()
2458 ASSERT3U(*consp, !=, cons); in xnf_rx_one_packet()
2459 *consp = cons; in xnf_rx_one_packet()
|
| /illumos-gate/usr/src/uts/common/xen/dtrace/ |
| H A D | xdt.c | 1744 xdt_get_first_rec(uint_t *cpuidp, struct t_rec **recp, uint32_t *consp) in xdt_get_first_rec() argument
1780 *consp = cons; in xdt_get_first_rec()
|