Lines Matching defs:consp
55 display_domain_name(vntsd_cons_t *consp, int *fd)
61 if (consp->clientpq != NULL) {
63 } else if (consp->status & VNTSD_CONS_DELETED) {
70 consp->cons_no, consp->domain_name, status, vntsd_eol);
107 create_write_thread(vntsd_cons_t *consp)
110 assert(consp);
113 (void) mutex_lock(&consp->lock);
115 (void *)consp, NULL, &consp->wr_tid)) {
119 thr_self(), consp->cons_no);
120 (void) close(consp->vcc_fd);
121 consp->vcc_fd = -1;
122 (void) mutex_unlock(&consp->lock);
126 (void) mutex_unlock(&consp->lock);
222 cons_by_name(vntsd_cons_t *consp, char *name)
224 if (consp->status & VNTSD_CONS_DELETED) {
227 return (strcmp(consp->domain_name, name) == 0);
234 vntsd_cons_t *consp;
236 consp = (vntsd_cons_t *)vntsd_que_find(groupp->conspq,
239 if (consp == NULL) {
243 return (consp->cons_no);
248 select_cons(vntsd_group_t *groupp, vntsd_cons_t **consp,
320 *consp = (vntsd_cons_t *)vntsd_que_find(groupp->conspq,
323 if (*consp == NULL) {
329 if ((*consp)->status & VNTSD_CONS_DELETED) {
340 find_cons_in_group(vntsd_cons_t *consp_in_group, vntsd_cons_t *consp)
342 if (consp_in_group == consp) {
351 connect_cons(vntsd_cons_t *consp, vntsd_client_t *clientp)
356 assert(consp);
357 groupp = consp->group;
364 consp = vntsd_que_find(groupp->conspq,
365 (compare_func_t)find_cons_in_group, consp);
367 if (consp == NULL) {
371 if (consp->status & VNTSD_CONS_DELETED) {
376 (void) mutex_lock(&consp->lock);
380 clientp->cons = consp;
385 if (consp->clientpq == NULL && consp->vcc_fd == -1) {
391 consp->vcc_fd = vntsd_open_vcc(consp->dev_name, consp->cons_no);
392 if (consp->vcc_fd < 0) {
394 (void) mutex_unlock(&consp->lock);
396 assert(consp->group);
397 return (vntsd_vcc_err(consp));
411 rv = vntsd_que_append(&consp->clientpq, clientp);
415 if (consp->clientpq->handle == clientp) {
417 (void) close(consp->vcc_fd);
418 consp->vcc_fd = -1;
421 (void) mutex_unlock(&consp->lock);
425 (void) mutex_unlock(&consp->lock);
427 if (consp->clientpq->handle == clientp) {
429 rv = create_write_thread(consp);
436 if ((rv = write_connect_msg(clientp, consp->group->group_name,
437 consp->domain_name)) != VNTSD_SUCCESS) {
448 (void) mutex_lock(&consp->lock);
449 rv1 = vntsd_que_rm(&consp->clientpq, clientp);
456 if (consp->clientpq == NULL) {
458 assert(consp->vcc_fd != -1);
461 assert(consp->wr_tid != (thread_t)-1);
462 (void) thr_kill(consp->wr_tid, SIGUSR1);
463 (void) mutex_unlock(&consp->lock);
464 (void) thr_join(consp->wr_tid, NULL, NULL);
465 (void) mutex_lock(&consp->lock);
468 if (consp->status & VNTSD_CONS_SIG_WAIT) {
470 (void) cond_signal(&consp->cvp);
473 (void) mutex_unlock(&consp->lock);
525 is_client_que_empty(vntsd_cons_t *consp)
529 (void) mutex_lock(&consp->lock);
531 if (consp->clientpq != NULL)
534 (void) mutex_unlock(&consp->lock);
546 close_one_vcc_fd(vntsd_cons_t *consp)
548 (void) mutex_lock(&consp->lock);
550 if (consp->vcc_fd != -1) {
551 (void) close(consp->vcc_fd);
552 consp->vcc_fd = -1;
555 (void) mutex_unlock(&consp->lock);
748 vntsd_cons_t *consp;
834 consp = (vntsd_cons_t *)
841 consp = clientp->cons;
845 rv = connect_cons(consp, clientp);
853 rv = select_cons(groupp, &consp, clientp, cmd);
868 consp = clientp->cons;
870 assert(consp);
873 rv = connect_cons(consp, clientp);