Lines Matching refs:clientp
77 write_connect_msg(vntsd_client_t *clientp, char *group_name, in write_connect_msg() argument
84 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) != in write_connect_msg()
93 if ((rv = vntsd_write_line(clientp, buf)) != VNTSD_SUCCESS) { in write_connect_msg()
97 if ((rv = vntsd_write_line(clientp, in write_connect_msg()
132 list_all_domains(vntsd_group_t *groupp, vntsd_client_t *clientp) in list_all_domains() argument
137 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) in list_all_domains()
152 if ((rv = vntsd_write_line(clientp, vntsd_line)) != VNTSD_SUCCESS) { in list_all_domains()
159 &(clientp->sockfd)) != NULL) { in list_all_domains()
170 display_help(vntsd_client_t *clientp) in display_help() argument
175 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) in display_help()
188 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
194 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
200 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
213 if ((rv = vntsd_write_line(clientp, bufp)) != VNTSD_SUCCESS) { in display_help()
249 vntsd_client_t *clientp, char c) in select_cons() argument
272 if ((rv = vntsd_read_line(clientp, buf, &n)) != VNTSD_SUCCESS) { in select_cons()
351 connect_cons(vntsd_cons_t *consp, vntsd_client_t *clientp) in connect_cons() argument
359 assert(clientp); in connect_cons()
377 (void) mutex_lock(&clientp->lock); in connect_cons()
380 clientp->cons = consp; in connect_cons()
383 clientp->status &= ~VNTSD_CLIENT_DISABLE_DAEMON_CMD; in connect_cons()
393 (void) mutex_unlock(&clientp->lock); in connect_cons()
401 (void) mutex_unlock(&clientp->lock); in connect_cons()
408 rv = vntsd_que_rm(&groupp->no_cons_clientpq, clientp); in connect_cons()
411 rv = vntsd_que_append(&consp->clientpq, clientp); in connect_cons()
415 if (consp->clientpq->handle == clientp) { in connect_cons()
427 if (consp->clientpq->handle == clientp) { in connect_cons()
436 if ((rv = write_connect_msg(clientp, consp->group->group_name, in connect_cons()
442 rv = vntsd_read(clientp); in connect_cons()
449 rv1 = vntsd_que_rm(&consp->clientpq, clientp); in connect_cons()
453 rv1 = vntsd_que_append(&groupp->no_cons_clientpq, clientp); in connect_cons()
481 read_cmd(vntsd_client_t *clientp, char *prompt, char *cmd) in read_cmd() argument
486 (void) mutex_lock(&clientp->lock); in read_cmd()
487 clientp->status |= VNTSD_CLIENT_DISABLE_DAEMON_CMD; in read_cmd()
488 (void) mutex_unlock(&clientp->lock); in read_cmd()
490 if ((rv = vntsd_write_client(clientp, vntsd_eol, VNTSD_EOL_LEN)) in read_cmd()
495 if ((rv = vntsd_write_client(clientp, prompt, strlen(prompt))) in read_cmd()
500 if ((rv = vntsd_read_data(clientp, cmd)) != VNTSD_SUCCESS) { in read_cmd()
507 rv = vntsd_write_client(clientp, cmd, 1); in read_cmd()
516 client_init(vntsd_client_t *clientp) in client_init() argument
518 (void) mutex_lock(&clientp->lock); in client_init()
519 clientp->cons = NULL; in client_init()
520 clientp->status = 0; in client_init()
521 (void) mutex_unlock(&clientp->lock); in client_init()
563 client_fini(vntsd_group_t *groupp, vntsd_client_t *clientp) in client_fini() argument
567 assert(clientp); in client_fini()
570 assert(clientp->sockfd != -1); in client_fini()
571 (void) close(clientp->sockfd); in client_fini()
586 (void) vntsd_que_rm(&groupp->no_cons_clientpq, clientp); in client_fini()
599 (void) mutex_destroy(&clientp->lock); in client_fini()
600 free(clientp); in client_fini()
607 console_chk_status(vntsd_group_t *groupp, vntsd_client_t *clientp, int status) in console_chk_status() argument
613 thr_self(), status, clientp->status, groupp->num_cons); in console_chk_status()
616 " num_cos=%d", clientp->sockfd, groupp->num_cons); in console_chk_status()
627 client_fini(groupp, clientp); in console_chk_status()
633 status = vntsd_cons_chk_intr(clientp); in console_chk_status()
640 client_fini(groupp, clientp); in console_chk_status()
645 if (clientp->cons == NULL) { in console_chk_status()
651 client_init(clientp); in console_chk_status()
656 ((clientp->status & VNTSD_CLIENT_CONS_DELETED) || in console_chk_status()
657 (groupp->conspq->handle == clientp->cons))) { in console_chk_status()
660 client_fini(groupp, clientp); in console_chk_status()
663 client_init(clientp); in console_chk_status()
669 if ((clientp->status & VNTSD_CLIENT_CONS_DELETED) == 0) { in console_chk_status()
672 status = vntsd_vcc_err(clientp->cons); in console_chk_status()
680 client_fini(groupp, clientp); in console_chk_status()
687 client_init(clientp); in console_chk_status()
699 clientp->cons = vntsd_que_pos(groupp->conspq, in console_chk_status()
700 clientp->cons, in console_chk_status()
708 client_init(clientp); in console_chk_status()
722 client_fini(groupp, clientp); in console_chk_status()
725 client_init(clientp); in console_chk_status()
738 client_fini(groupp, clientp); in console_chk_status()
749 vntsd_client_t *clientp; in vntsd_console_thread() local
759 clientp = (vntsd_client_t *)argp->arg; in vntsd_console_thread()
762 assert(clientp); in vntsd_console_thread()
770 groupp->tcp_port, clientp->sockfd); in vntsd_console_thread()
792 groupp->tcp_port, clientp->sockfd); in vntsd_console_thread()
796 if ((num_cons > 1) && (clientp->cons == NULL)) { in vntsd_console_thread()
798 rv = read_cmd(clientp, prompt, &cmd); in vntsd_console_thread()
800 console_chk_status(groupp, clientp, rv); in vntsd_console_thread()
814 rv = list_all_domains(groupp, clientp); in vntsd_console_thread()
831 if (clientp->cons == NULL) { in vntsd_console_thread()
841 consp = clientp->cons; in vntsd_console_thread()
845 rv = connect_cons(consp, clientp); in vntsd_console_thread()
852 if (clientp->cons == NULL) { in vntsd_console_thread()
853 rv = select_cons(groupp, &consp, clientp, cmd); in vntsd_console_thread()
855 rv = display_help(clientp); in vntsd_console_thread()
868 consp = clientp->cons; in vntsd_console_thread()
873 rv = connect_cons(consp, clientp); in vntsd_console_thread()
881 rv = display_help(clientp); in vntsd_console_thread()
887 console_chk_status(groupp, clientp, rv); in vntsd_console_thread()