1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/*
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * CDDL HEADER START
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo *
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * The contents of this file are subject to the terms of the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Common Development and Distribution License (the "License").
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * You may not use this file except in compliance with the License.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo *
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * or http://www.opensolaris.org/os/licensing.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * See the License for the specific language governing permissions
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * and limitations under the License.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo *
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * When distributing Covered Code, include this CDDL HEADER in each
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * If applicable, add the following below this CDDL HEADER, with the
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * fields enclosed by brackets "[]" replaced with your own identifying
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * information: Portions Copyright [yyyy] [name of copyright owner]
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo *
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * CDDL HEADER END
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/*
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Use is subject to license terms.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/*
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * Each group has a listen thread. It is created at the time
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * of a group creation and destroyed when a group does not have
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * any console associated with it.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <stdio.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <stdlib.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <string.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <unistd.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <sys/types.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <sys/socket.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <netinet/in.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <thread.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <assert.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <signal.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <ctype.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include <syslog.h>
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#include "vntsd.h"
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg#define MAX_BIND_RETRIES 6
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/*
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo * check the state of listen thread. exit if there is an fatal error
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * or the group is removed. Main thread will call free_group
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * to close group socket and free group structure.
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppostatic void
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppolisten_chk_status(vntsd_group_t *groupp, int status)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo{
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo char err_msg[VNTSD_LINE_LEN];
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo D1(stderr, "t@%d listen_chk_status() status=%d group=%s "
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo "tcp=%lld group status = %x\n", thr_self(), status,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo groupp->group_name, groupp->tcp_port, groupp->status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) snprintf(err_msg, sizeof (err_msg),
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo "Group:%s TCP port %lld status %x",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo groupp->group_name, groupp->tcp_port, groupp->status);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo switch (status) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VNTSD_SUCCESS:
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VNTSD_STATUS_ACCEPT_ERR:
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan case VNTSD_STATUS_INTR:
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan assert(groupp->status & VNTSD_GROUP_SIG_WAIT);
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan /*FALLTHRU*/
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo case VNTSD_STATUS_NO_CONS:
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo default:
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg /* fatal error or no console in the group, remove the group. */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_lock(&groupp->lock);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg if (groupp->status & VNTSD_GROUP_SIG_WAIT) {
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan /*
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan * group is already being deleted, notify main
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan * thread and exit.
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan */
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan groupp->status &= ~VNTSD_GROUP_SIG_WAIT;
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan (void) cond_signal(&groupp->cvp);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg (void) mutex_unlock(&groupp->lock);
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan thr_exit(0);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg }
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg /*
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * if there still is console(s) in the group,
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * the console(s) could not be connected any more because of
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * a fatal error. Therefore, mark the console and notify
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * main thread to delete console and group.
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg */
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg (void) vntsd_que_walk(groupp->conspq,
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg (el_func_t)vntsd_mark_deleted_cons);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg groupp->status |= VNTSD_GROUP_CLEAN_CONS;
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg /* signal main thread to delete the group */
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg (void) thr_kill(groupp->vntsd->tid, SIGUSR1);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg /* log error */
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg if (status != VNTSD_STATUS_NO_CONS)
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg vntsd_log(status, err_msg);
bd8f0338e0109a8df4e34499bdf42e592c77eedanarayan thr_exit(0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo}
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* allocate and initialize listening socket. */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppostatic int
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppoopen_socket(int port_no, int *sockfd)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo{
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo struct sockaddr_in addr;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo int on;
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg int retries = 0;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* allocate a socket */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo *sockfd = socket(AF_INET, SOCK_STREAM, 0);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (*sockfd < 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (errno == EINTR) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_STATUS_INTR);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_ERR_LISTEN_SOCKET);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#ifdef DEBUG
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* set reuse local socket address */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo on = 1;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (setsockopt(*sockfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof (on))) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_ERR_LISTEN_OPTS);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo#endif
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo addr.sin_family = AF_INET;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo addr.sin_addr.s_addr = (vntsd_ip_addr()).s_addr;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo addr.sin_port = htons(port_no);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* bind socket */
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg for (; ; ) {
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg /*
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * After a socket is closed, the port
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * is transitioned to TIME_WAIT state.
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * It may take a few retries to bind
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg * a just released port.
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg */
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg if (bind(*sockfd, (struct sockaddr *)&addr,
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna sizeof (addr)) < 0) {
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg if (errno == EINTR) {
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg return (VNTSD_STATUS_INTR);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg }
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg if (errno == EADDRINUSE && retries < MAX_BIND_RETRIES) {
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg /* port may be in TIME_WAIT state, retry */
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg (void) sleep(5);
3c96341aef2b4da56c902941f089284b52bd573fnarayan
3c96341aef2b4da56c902941f089284b52bd573fnarayan /* woke up by signal? */
3c96341aef2b4da56c902941f089284b52bd573fnarayan if (errno == EINTR) {
3c96341aef2b4da56c902941f089284b52bd573fnarayan return (VNTSD_STATUS_INTR);
3c96341aef2b4da56c902941f089284b52bd573fnarayan }
3c96341aef2b4da56c902941f089284b52bd573fnarayan
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg retries++;
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg continue;
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg }
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg return (VNTSD_ERR_LISTEN_BIND);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg break;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (listen(*sockfd, VNTSD_MAX_SOCKETS) == -1) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (errno == EINTR) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_STATUS_INTR);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_ERR_LISTEN_BIND);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo D1(stderr, "t@%d open_socket() sockfd=%d\n", thr_self(), *sockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_SUCCESS);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo}
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* ceate console selection thread */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppostatic int
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppocreate_console_thread(vntsd_group_t *groupp, int sockfd)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo{
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vntsd_client_t *clientp;
3c96341aef2b4da56c902941f089284b52bd573fnarayan vntsd_thr_arg_t *thr_arg;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo int rv;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo assert(groupp);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo D1(stderr, "t@%d create_console_thread@%lld:client@%d\n", thr_self(),
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo groupp->tcp_port, sockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* allocate a new client */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo clientp = (vntsd_client_t *)malloc(sizeof (vntsd_client_t));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (clientp == NULL) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_ERR_NO_MEM);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* initialize the client */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo bzero(clientp, sizeof (vntsd_client_t));
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo clientp->sockfd = sockfd;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo clientp->cons_tid = (thread_t)-1;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_init(&clientp->lock, USYNC_THREAD|LOCK_ERRORCHECK, NULL);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* append client to group */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_lock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
3c96341aef2b4da56c902941f089284b52bd573fnarayan /* check if the group is [being] removed */
3c96341aef2b4da56c902941f089284b52bd573fnarayan if (groupp->status & VNTSD_GROUP_IN_CLEANUP) {
3c96341aef2b4da56c902941f089284b52bd573fnarayan (void) mutex_unlock(&groupp->lock);
3c96341aef2b4da56c902941f089284b52bd573fnarayan vntsd_free_client(clientp);
3c96341aef2b4da56c902941f089284b52bd573fnarayan return (VNTSD_STATUS_NO_CONS);
3c96341aef2b4da56c902941f089284b52bd573fnarayan }
3c96341aef2b4da56c902941f089284b52bd573fnarayan
3c96341aef2b4da56c902941f089284b52bd573fnarayan
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if ((rv = vntsd_que_append(&groupp->no_cons_clientpq, clientp))
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo != VNTSD_SUCCESS) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vntsd_free_client(clientp);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (rv);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
3c96341aef2b4da56c902941f089284b52bd573fnarayan /*
3c96341aef2b4da56c902941f089284b52bd573fnarayan * allocate thr_arg from heap for console thread so
3c96341aef2b4da56c902941f089284b52bd573fnarayan * that thr_arg is still valid after this function exits.
3c96341aef2b4da56c902941f089284b52bd573fnarayan * console thread will free thr_arg.
3c96341aef2b4da56c902941f089284b52bd573fnarayan */
3c96341aef2b4da56c902941f089284b52bd573fnarayan
3c96341aef2b4da56c902941f089284b52bd573fnarayan thr_arg = (vntsd_thr_arg_t *)malloc(sizeof (vntsd_thr_arg_t));
3c96341aef2b4da56c902941f089284b52bd573fnarayan if (thr_arg == NULL) {
3c96341aef2b4da56c902941f089284b52bd573fnarayan vntsd_free_client(clientp);
3c96341aef2b4da56c902941f089284b52bd573fnarayan return (VNTSD_ERR_NO_MEM);
3c96341aef2b4da56c902941f089284b52bd573fnarayan }
3c96341aef2b4da56c902941f089284b52bd573fnarayan thr_arg->handle = groupp;
3c96341aef2b4da56c902941f089284b52bd573fnarayan thr_arg->arg = clientp;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
3c96341aef2b4da56c902941f089284b52bd573fnarayan (void) mutex_lock(&clientp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* create console selection thread */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (thr_create(NULL, 0, (thr_func_t)vntsd_console_thread,
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna thr_arg, THR_DETACHED, &clientp->cons_tid)) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
3c96341aef2b4da56c902941f089284b52bd573fnarayan free(thr_arg);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&clientp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_lock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) vntsd_que_rm(&groupp->no_cons_clientpq, clientp);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo vntsd_free_client(clientp);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_ERR_CREATE_CONS_THR);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&clientp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (VNTSD_SUCCESS);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo}
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo/* listen thread */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovoid *
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppovntsd_listen_thread(vntsd_group_t *groupp)
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo{
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo int newsockfd;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo size_t clilen;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo struct sockaddr_in cli_addr;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo int rv;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo int num_cons;
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna vntsd_t *vntsdp;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo assert(groupp);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo D1(stderr, "t@%d listen@%lld\n", thr_self(), groupp->tcp_port);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna vntsdp = groupp->vntsd;
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* initialize listen socket */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_lock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo rv = open_socket(groupp->tcp_port, &groupp->sockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) mutex_unlock(&groupp->lock);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo listen_chk_status(groupp, rv);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo for (; ; ) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo clilen = sizeof (cli_addr);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* listen to the socket */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo newsockfd = accept(groupp->sockfd, (struct sockaddr *)&cli_addr,
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna &clilen);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo D1(stderr, "t@%d listen_thread() connected sockfd=%d\n",
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo thr_self(), newsockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (newsockfd <= 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (errno == EINTR) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo listen_chk_status(groupp, VNTSD_STATUS_INTR);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo } else {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo listen_chk_status(groupp,
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo VNTSD_STATUS_ACCEPT_ERR);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo continue;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna /* Check authorization if enabled */
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna if ((vntsdp->options & VNTSD_OPT_AUTH_CHECK) != 0) {
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna rv = auth_check_fd(newsockfd, groupp->group_name);
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna if (rv != B_TRUE) {
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna D3(stderr, "t@%d listen@%lld group@%s: "
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna "authorization failure\n", thr_self(),
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna groupp->tcp_port, groupp->group_name);
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna (void) close(newsockfd);
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna continue;
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna }
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna }
28b1e50e4eed7be353f9778497714aab53ef2a0dSriharsha Basavapatna
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo num_cons = vntsd_chk_group_total_cons(groupp);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (num_cons == 0) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) close(newsockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo listen_chk_status(groupp, VNTSD_STATUS_NO_CONS);
4d39be2b45b5ac811d28452e6eb629ac64aebfc4sg continue;
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /* a connection is established */
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo rv = vntsd_set_telnet_options(newsockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (rv != VNTSD_SUCCESS) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) close(newsockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo listen_chk_status(groupp, rv);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo rv = create_console_thread(groupp, newsockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo if (rv != VNTSD_SUCCESS) {
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo (void) close(newsockfd);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo listen_chk_status(groupp, rv);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo }
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo /*NOTREACHED*/
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo return (NULL);
1ae0874509b6811fdde1dfd46f0d93fd09867a3fheppo}