55 write_vcc(vntsd_client_t *clientp, char c)  in write_vcc()  argument
60 	assert(clientp);  in write_vcc()
61 	assert(clientp->cons);  in write_vcc()
63 	n = write(clientp->cons->vcc_fd, &c, 1);  in write_vcc()
68 			return (vntsd_cons_chk_intr(clientp));  in write_vcc()
84 acquire_writer(vntsd_client_t *clientp)  in acquire_writer()  argument
91 	    clientp->sockfd);  in acquire_writer()
93 	assert(clientp != NULL);  in acquire_writer()
94 	consp = clientp->cons;  in acquire_writer()
101 	if (consp->clientpq->handle == clientp) {  in acquire_writer()
112 	rv = vntsd_que_rm(&(consp->clientpq), clientp);  in acquire_writer()
115 	(void) mutex_lock(&clientp->lock);  in acquire_writer()
118 	consp->clientpq->handle = clientp;  in acquire_writer()
121 	rv =  vntsd_que_insert_after(consp->clientpq, clientp, writerp);  in acquire_writer()
125 	(void) mutex_unlock(&clientp->lock);  in acquire_writer()
144 vntsd_cons_chk_intr(vntsd_client_t *clientp)  in vntsd_cons_chk_intr()  argument
147 	if (clientp->status & VNTSD_CLIENT_TIMEOUT) {  in vntsd_cons_chk_intr()
150 	if (clientp->status & VNTSD_CLIENT_CONS_DELETED) {  in vntsd_cons_chk_intr()
154 	if (clientp->status & VNTSD_CLIENT_IO_ERR) {  in vntsd_cons_chk_intr()
162 read_char(vntsd_client_t *clientp, char *c)  in read_char()  argument
168 		rv = vntsd_read_data(clientp, c);  in read_char()
173 			clientp->prev_char = 0;  in read_char()
174 			rv = acquire_writer(clientp);  in read_char()
186 			if (clientp->prev_char == 0xd && *c == 0) {  in read_char()
187 				clientp->prev_char = *c;  in read_char()
191 			clientp->prev_char = *c;  in read_char()
196 			clientp->prev_char = 0;  in read_char()
205 vntsd_read(vntsd_client_t *clientp)  in vntsd_read()  argument
211 	assert(clientp);  in vntsd_read()
212 	D3(stderr, "t@%d vntsd_read@%d\n", thr_self(), clientp->sockfd);  in vntsd_read()
217 		rv = read_char(clientp, &c);  in vntsd_read()
220 			rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()
227 		assert(clientp->cons);  in vntsd_read()
235 		if (clientp->cons->clientpq->handle != clientp) {  in vntsd_read()
242 			rv = vntsd_write_line(clientp,  in vntsd_read()
247 				rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()
257 		rv = vntsd_ctrl_cmd(clientp, c);  in vntsd_read()
264 			rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()
276 		rv = write_vcc(clientp, c);  in vntsd_read()
278 			rv = vntsd_cons_chk_intr(clientp);  in vntsd_read()