54 write_vcc(vntsd_client_t *clientp, char c)  in write_vcc()  argument
59 	assert(clientp);  in write_vcc()
60 	assert(clientp->cons);  in write_vcc()
62 	n = write(clientp->cons->vcc_fd, &c, 1);  in write_vcc()
67 			return (vntsd_cons_chk_intr(clientp));  in write_vcc()
83 acquire_writer(vntsd_client_t *clientp)  in acquire_writer()  argument
90 	    clientp->sockfd);  in acquire_writer()
92 	assert(clientp != NULL);  in acquire_writer()
93 	consp = clientp->cons;  in acquire_writer()
100 	if (consp->clientpq->handle == clientp) {  in acquire_writer()
111 	rv = vntsd_que_rm(&(consp->clientpq), clientp);  in acquire_writer()
114 	(void) mutex_lock(&clientp->lock);  in acquire_writer()
117 	consp->clientpq->handle = clientp;  in acquire_writer()
120 	rv =  vntsd_que_insert_after(consp->clientpq, clientp, writerp);  in acquire_writer()
124 	(void) mutex_unlock(&clientp->lock);  in acquire_writer()
143 vntsd_cons_chk_intr(vntsd_client_t *clientp)  in vntsd_cons_chk_intr()  argument
146 	if (clientp->status & VNTSD_CLIENT_TIMEOUT) {  in vntsd_cons_chk_intr()
149 	if (clientp->status & VNTSD_CLIENT_CONS_DELETED) {  in vntsd_cons_chk_intr()
153 	if (clientp->status & VNTSD_CLIENT_IO_ERR) {  in vntsd_cons_chk_intr()
161 read_char(vntsd_client_t *clientp, char *c)  in read_char()  argument
167 		rv = vntsd_read_data(clientp, c);  in read_char()
172 			clientp->prev_char = 0;  in read_char()
173 			rv = acquire_writer(clientp);  in read_char()
185 			if (clientp->prev_char == 0xd && *c == 0) {  in read_char()
186 				clientp->prev_char = *c;  in read_char()
190 			clientp->prev_char = *c;  in read_char()
195 			clientp->prev_char = 0;  in read_char()
204 vntsd_read(vntsd_client_t *clientp)  in vntsd_read()  argument
210 	assert(clientp);  in vntsd_read()
211 	D3(stderr, "t@%d vntsd_read@%d\n", thr_self(), clientp->sockfd);  in vntsd_read()
216 		rv = read_char(clientp, &c);  in vntsd_read()
219 			rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()
226 		assert(clientp->cons);  in vntsd_read()
234 		if (clientp->cons->clientpq->handle != clientp) {  in vntsd_read()
241 			rv = vntsd_write_line(clientp,  in vntsd_read()
246 				rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()
256 		rv = vntsd_ctrl_cmd(clientp, c);  in vntsd_read()
263 			rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()
275 		rv = write_vcc(clientp, c);  in vntsd_read()
277 			rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()