64 write_chk_status(vntsd_cons_t *consp, int status)  in write_chk_status()  argument
67 	if ((consp->status & VNTSD_CONS_DELETED) || (consp->clientpq == NULL)) {  in write_chk_status()
73 		assert(consp->group != NULL);  in write_chk_status()
74 		if (vntsd_vcc_err(consp) != VNTSD_STATUS_CONTINUE) {  in write_chk_status()
170 read_vcc(vntsd_cons_t *consp, char *buf, ssize_t *sz)  in read_vcc()  argument
173 	*sz = read(consp->vcc_fd, buf, VNTSD_MAX_BUF_SIZE);  in read_vcc()
210 vntsd_write_thread(vntsd_cons_t *consp)  in vntsd_write_thread()  argument
217 	D1(stderr, "t@%d vntsd_write@%d\n", thr_self(), consp->vcc_fd);  in vntsd_write_thread()
219 	assert(consp);  in vntsd_write_thread()
220 	write_chk_status(consp, VNTSD_SUCCESS);  in vntsd_write_thread()
226 		rv = read_vcc(consp, buf, &sz);  in vntsd_write_thread()
228 		write_chk_status(consp, rv);  in vntsd_write_thread()
248 		(void) mutex_lock(&consp->lock);  in vntsd_write_thread()
249 		(void) vntsd_que_find(consp->clientpq,  in vntsd_write_thread()
251 		(void) mutex_unlock(&consp->lock);  in vntsd_write_thread()
253 		write_chk_status(consp, VNTSD_SUCCESS);  in vntsd_write_thread()