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