Lines Matching refs:clientp
76 write_connect_msg(vntsd_client_t *clientp, char *group_name, in write_connect_msg() argument
83 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) != in write_connect_msg()
92 if ((rv = vntsd_write_line(clientp, buf)) != VNTSD_SUCCESS) { in write_connect_msg()
96 if ((rv = vntsd_write_line(clientp, in write_connect_msg()
130 list_all_domains(vntsd_group_t *groupp, vntsd_client_t *clientp) in list_all_domains() argument
135 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) in list_all_domains()
150 if ((rv = vntsd_write_line(clientp, vntsd_line)) != VNTSD_SUCCESS) { in list_all_domains()
157 &(clientp->sockfd)) != NULL) { in list_all_domains()
168 display_help(vntsd_client_t *clientp) in display_help() argument
173 rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN); in display_help()
186 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
192 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
198 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
211 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
247 vntsd_client_t *clientp, char c) in select_cons() argument
270 if ((rv = vntsd_read_line(clientp, buf, &n)) != VNTSD_SUCCESS) { in select_cons()
349 connect_cons(vntsd_cons_t *consp, vntsd_client_t *clientp) in connect_cons() argument
357 assert(clientp); in connect_cons()
375 (void) mutex_lock(&clientp->lock); in connect_cons()
378 clientp->cons = consp; in connect_cons()
381 clientp->status &= ~VNTSD_CLIENT_DISABLE_DAEMON_CMD; in connect_cons()
391 (void) mutex_unlock(&clientp->lock); in connect_cons()
399 (void) mutex_unlock(&clientp->lock); in connect_cons()
406 rv = vntsd_que_rm(&groupp->no_cons_clientpq, clientp); in connect_cons()
409 rv = vntsd_que_append(&consp->clientpq, clientp); in connect_cons()
413 if (consp->clientpq->handle == clientp) { in connect_cons()
425 if (consp->clientpq->handle == clientp) { in connect_cons()
434 if ((rv = write_connect_msg(clientp, consp->group->group_name, in connect_cons()
440 rv = vntsd_read(clientp); in connect_cons()
447 rv1 = vntsd_que_rm(&consp->clientpq, clientp); in connect_cons()
451 rv1 = vntsd_que_append(&groupp->no_cons_clientpq, clientp); in connect_cons()
479 read_cmd(vntsd_client_t *clientp, char *prompt, char *cmd) in read_cmd() argument
484 (void) mutex_lock(&clientp->lock); in read_cmd()
485 clientp->status |= VNTSD_CLIENT_DISABLE_DAEMON_CMD; in read_cmd()
486 (void) mutex_unlock(&clientp->lock); in read_cmd()
488 rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN); in read_cmd()
493 rv = vntsd_write_client(clientp, prompt, strlen(prompt)); in read_cmd()
498 if ((rv = vntsd_read_data(clientp, cmd)) != VNTSD_SUCCESS) { in read_cmd()
505 rv = vntsd_write_client(clientp, cmd, 1); in read_cmd()
514 client_init(vntsd_client_t *clientp) in client_init() argument
516 (void) mutex_lock(&clientp->lock); in client_init()
517 clientp->cons = NULL; in client_init()
518 clientp->status = 0; in client_init()
519 (void) mutex_unlock(&clientp->lock); in client_init()
561 client_fini(vntsd_group_t *groupp, vntsd_client_t *clientp) in client_fini() argument
565 assert(clientp); in client_fini()
568 assert(clientp->sockfd != -1); in client_fini()
569 (void) close(clientp->sockfd); in client_fini()
584 (void) vntsd_que_rm(&groupp->no_cons_clientpq, clientp); in client_fini()
597 (void) mutex_destroy(&clientp->lock); in client_fini()
598 free(clientp); in client_fini()
605 console_chk_status(vntsd_group_t *groupp, vntsd_client_t *clientp, int status) in console_chk_status() argument
611 thr_self(), status, clientp->status, groupp->num_cons); in console_chk_status()
614 " num_cos=%d", clientp->sockfd, groupp->num_cons); in console_chk_status()
625 client_fini(groupp, clientp); in console_chk_status()
631 status = vntsd_cons_chk_intr(clientp); in console_chk_status()
638 client_fini(groupp, clientp); in console_chk_status()
643 if (clientp->cons == NULL) { in console_chk_status()
649 client_init(clientp); in console_chk_status()
654 ((clientp->status & VNTSD_CLIENT_CONS_DELETED) || in console_chk_status()
655 (groupp->conspq->handle == clientp->cons))) { in console_chk_status()
658 client_fini(groupp, clientp); in console_chk_status()
661 client_init(clientp); in console_chk_status()
667 if ((clientp->status & VNTSD_CLIENT_CONS_DELETED) == 0) { in console_chk_status()
670 status = vntsd_vcc_err(clientp->cons); in console_chk_status()
678 client_fini(groupp, clientp); in console_chk_status()
685 client_init(clientp); in console_chk_status()
697 clientp->cons = vntsd_que_pos(groupp->conspq, in console_chk_status()
698 clientp->cons, in console_chk_status()
706 client_init(clientp); in console_chk_status()
720 client_fini(groupp, clientp); in console_chk_status()
723 client_init(clientp); in console_chk_status()
736 client_fini(groupp, clientp); in console_chk_status()
747 vntsd_client_t *clientp; in vntsd_console_thread() local
757 clientp = (vntsd_client_t *)argp->arg; in vntsd_console_thread()
760 assert(clientp); in vntsd_console_thread()
768 groupp->tcp_port, clientp->sockfd); in vntsd_console_thread()
790 groupp->tcp_port, clientp->sockfd); in vntsd_console_thread()
794 if ((num_cons > 1) && (clientp->cons == NULL)) { in vntsd_console_thread()
796 rv = read_cmd(clientp, prompt, &cmd); in vntsd_console_thread()
798 console_chk_status(groupp, clientp, rv); in vntsd_console_thread()
812 rv = list_all_domains(groupp, clientp); in vntsd_console_thread()
829 if (clientp->cons == NULL) { in vntsd_console_thread()
839 consp = clientp->cons; in vntsd_console_thread()
843 rv = connect_cons(consp, clientp); in vntsd_console_thread()
850 if (clientp->cons == NULL) { in vntsd_console_thread()
851 rv = select_cons(groupp, &consp, clientp, cmd); in vntsd_console_thread()
853 rv = display_help(clientp); in vntsd_console_thread()
866 consp = clientp->cons; in vntsd_console_thread()
871 rv = connect_cons(consp, clientp); in vntsd_console_thread()
879 rv = display_help(clientp); in vntsd_console_thread()
885 console_chk_status(groupp, clientp, rv); in vntsd_console_thread()