cmd/vntsd/read.c

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