cmd/vntsd/console.c

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