ex_dscp.c revision 4573608322e68a31a57d0d851d7b324f4ffb66b5
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * CDDL HEADER START
25cf1a301a396c38e8adf52c15f537b80d2483f7jl *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * The contents of this file are subject to the terms of the
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Common Development and Distribution License (the "License").
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * You may not use this file except in compliance with the License.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * or http://www.opensolaris.org/os/licensing.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * See the License for the specific language governing permissions
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * and limitations under the License.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * When distributing Covered Code, include this CDDL HEADER in each
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * If applicable, add the following below this CDDL HEADER, with the
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * fields enclosed by brackets "[]" replaced with your own identifying
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * information: Portions Copyright [yyyy] [name of copyright owner]
25cf1a301a396c38e8adf52c15f537b80d2483f7jl *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * CDDL HEADER END
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Copyright 2006 Sun Microsystems, Inc. All rights reserved.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Use is subject to license terms.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl#pragma ident "%Z%%M% %I% %E% SMI"
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * FMA Event Transport Module Transport Layer API implementation.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Library for establishing connections and transporting FMA events between
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * ETMs (event-transport modules) in separate fault domains.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * The transport for this library is internet socket based and uses the DSCP
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * client services library (libdscp).
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt#include "ex_dscp.h"
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * On the SP, there is one DSCP interface for every domain.
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Each domain has one and only one DSCP interface to the SP.
d338766d6376ee721b7f1778e12bf79a112bd778jrutt *
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * The DSCP interface is created when the domain powers-on. On the SP,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * a sysevent will be generated when the DSCP interface is up. On the domain,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * the DSCP interface should be up when ETM loads.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_hdl_t *Exh_head = NULL; /* Head of ex_hdl_t list */
d338766d6376ee721b7f1778e12bf79a112bd778jruttpthread_mutex_t List_lock = PTHREAD_MUTEX_INITIALIZER;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Protects linked list of ex_hdl_t */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * * * * * * * * * * * * * *
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Module specific routines
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * * * * * * * * * * * * * *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Allocate and initialize a transport instance handle.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return hdl pointer for success, NULL for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jlstatic exs_hdl_t *
25cf1a301a396c38e8adf52c15f537b80d2483f7jlexs_hdl_alloc(fmd_hdl_t *hdl, char *endpoint_id,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt void *arg), void *cb_func_arg, int dom)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_hdl_t *hp;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp = fmd_hdl_zalloc(hdl, sizeof (exs_hdl_t), FMD_SLEEP);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_endpt_id = fmd_hdl_strdup(hdl, endpoint_id, FMD_SLEEP);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_dom = dom;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_accept.c_sd = EXS_SD_FREE;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_client.c_sd = EXS_SD_FREE;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_server.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_tid = EXS_TID_FREE;
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt hp->h_destroy = 0;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_hdl = hdl;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_cb_func = cb_func;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_cb_func_arg = cb_func_arg;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_quit = 0;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (hp);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Translate endpoint_id string to int.
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Return the domain ID via "dom_id".
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Return 0 for success, nonzero for failure
d338766d6376ee721b7f1778e12bf79a112bd778jrutt */
d338766d6376ee721b7f1778e12bf79a112bd778jruttstatic int
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_get_id(fmd_hdl_t *hdl, char *endpoint_id, int *dom_id)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt{
d338766d6376ee721b7f1778e12bf79a112bd778jrutt char *ptr;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (strstr(endpoint_id, EXS_SP_PREFIX) != NULL) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Remote endpoint is the SP */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt *dom_id = DSCP_IDENT_SP;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (0);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt } else {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((ptr = strstr(endpoint_id, EXS_DOMAIN_PREFIX)) == NULL) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hdl, "xport - %s not found in %s\n",
d338766d6376ee721b7f1778e12bf79a112bd778jrutt EXS_DOMAIN_PREFIX, endpoint_id);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (1);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt ptr += EXS_DOMAIN_PREFIX_LEN;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((sscanf(ptr, "%d", dom_id)) != 1) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hdl, "xport - no integer found in %s\n",
d338766d6376ee721b7f1778e12bf79a112bd778jrutt endpoint_id);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (1);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (0);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt}
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Prepare the client connection.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return 0 for success, nonzero for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jlstatic int
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_prep_client(exs_hdl_t *hp)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl int rv;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Find the DSCP address for the remote endpoint */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpAddr(hp->h_dom, DSCP_ADDR_REMOTE,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (struct sockaddr *)&hp->h_client.c_saddr,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl &hp->h_client.c_len)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpAddr on client socket "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "failed for %s : rv = %d\n", hp->h_endpt_id, rv);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (1);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if ((hp->h_client.c_sd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - client socket create failed "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "for %s", hp->h_endpt_id);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (2);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Bind the socket to the local IP address of the DSCP link */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpBind(hp->h_dom, hp->h_client.c_sd,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl EXS_CLIENT_PORT)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpBind on client socket "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "failed for %s : rv = %d\n", hp->h_endpt_id, rv);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) close(hp->h_client.c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_client.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (3);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_client.c_saddr.sin_port = htons(EXS_SERVER_PORT);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Set IPsec security policy for this socket */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpSecure(hp->h_dom, hp->h_client.c_sd)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpSecure on client socket "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "failed for %s : rv = %d\n", hp->h_endpt_id, rv);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) close(hp->h_client.c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_client.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (4);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Prepare to accept a connection.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return 0 for success, nonzero for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
4573608322e68a31a57d0d851d7b324f4ffb66b5jruttint
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_prep_accept(exs_hdl_t *hp)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt int flags, optval = 1;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl int rv;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((hp->h_accept.c_sd = socket(AF_INET, SOCK_STREAM, 0)) == -1) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - accept socket create failed "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "for %s", hp->h_endpt_id);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (1);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (setsockopt(hp->h_accept.c_sd, SOL_SOCKET, SO_REUSEADDR,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl &optval, sizeof (optval))) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - set REUSEADDR failed for %s",
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_endpt_id);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_accept.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_accept.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (2);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Bind the socket to the local IP address of the DSCP link */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpBind(hp->h_dom, hp->h_accept.c_sd,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl EXS_SERVER_PORT)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpBind on accept socket "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "failed for %s : rv = %d\n", hp->h_endpt_id, rv);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_accept.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_accept.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (3);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Activate IPsec security policy for this socket */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpSecure(hp->h_dom, hp->h_accept.c_sd)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpSecure on accept socket "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "failed for %s : rv = %d\n", hp->h_endpt_id, rv);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_accept.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_accept.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (4);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((listen(hp->h_accept.c_sd, EXS_NUM_SOCKS)) == -1) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hp->h_hdl, "xport - listen on accept socket "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "failed for %s", hp->h_endpt_id);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_accept.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_accept.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return (5);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt flags = fcntl(hp->h_accept.c_sd, F_GETFL, 0);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) fcntl(hp->h_accept.c_sd, F_SETFL, flags | O_NONBLOCK);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Notify ETM that incoming data is available on server connection.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
d338766d6376ee721b7f1778e12bf79a112bd778jruttstatic void
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_recv(exs_hdl_t *hp)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_cb_func(hp->h_hdl, &hp->h_server, ETM_CBFLAG_RECV,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_cb_func_arg)) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Any non-zero return means to close the connection */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_server.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_server.c_sd = EXS_SD_FREE;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Accept a new incoming connection.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
d338766d6376ee721b7f1778e12bf79a112bd778jruttstatic void
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_accept(exs_hdl_t *hp)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
d338766d6376ee721b7f1778e12bf79a112bd778jrutt int new_sd, dom, flags, rv;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt struct sockaddr_in new_saddr;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt socklen_t new_len = sizeof (struct sockaddr);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((new_sd = accept(hp->h_accept.c_sd, (struct sockaddr *)&new_saddr,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt &new_len)) != -1) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Translate saddr to domain id */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpIdent((struct sockaddr *)&new_saddr, (int)new_len,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt &dom)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpIdent failed "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "for %s : rv = %d\n", hp->h_endpt_id, rv);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_dom != dom) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hp->h_hdl, "xport - domain id (%d) does "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "not match dscpIdent (%d)", hp->h_dom, dom);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Authenticate this connection request */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((rv = dscpAuth(dom, (struct sockaddr *)&new_saddr,
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (int)new_len)) != DSCP_OK) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_error(hp->h_hdl, "xport - dscpAuth failed "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "for %s : rv = %d\n", hp->h_endpt_id, rv);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt return;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_server.c_sd != EXS_SD_FREE) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_server.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_server.c_sd = EXS_SD_FREE;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Set the socket to be non-blocking */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt flags = fcntl(new_sd, F_GETFL, 0);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) fcntl(new_sd, F_SETFL, flags | O_NONBLOCK);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_server.c_sd = new_sd;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt } else {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hp->h_hdl, "xport - accept failed");
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Server function/thread. There is one thread per endpoint.
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * Accepts incoming connections and notifies ETM of incoming data.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
d338766d6376ee721b7f1778e12bf79a112bd778jruttvoid
d338766d6376ee721b7f1778e12bf79a112bd778jruttexs_server(void *arg)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
d338766d6376ee721b7f1778e12bf79a112bd778jrutt exs_hdl_t *hp = (exs_hdl_t *)arg;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt struct pollfd pfd[2];
d338766d6376ee721b7f1778e12bf79a112bd778jrutt nfds_t nfds;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt while (!hp->h_quit) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt pfd[0].events = POLLIN;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt pfd[0].revents = 0;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt pfd[0].fd = hp->h_accept.c_sd;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt pfd[1].events = POLLIN;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt pfd[1].revents = 0;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt pfd[1].fd = hp->h_server.c_sd;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt nfds = (hp->h_server.c_sd != EXS_SD_FREE ? 2 : 1);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (poll(pfd, nfds, -1) <= 0)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt continue; /* loop around and check h_quit */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (pfd[0].revents & (POLLHUP | POLLERR)) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hp->h_hdl, "xport - poll hangup/err for "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "%s accept socket", hp->h_endpt_id);
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt hp->h_destroy++;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt break;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (pfd[1].revents & (POLLHUP | POLLERR)) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hp->h_hdl, "xport - poll hangup/err for "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "%s server socket", hp->h_endpt_id);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_server.c_sd != EXS_SD_FREE) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_server.c_sd);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_server.c_sd = EXS_SD_FREE;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt continue;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (pfd[0].revents & POLLIN)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt exs_accept(hp);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (pfd[1].revents & POLLIN)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt exs_recv(hp);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hp->h_hdl, "xport - exiting server thread for %s",
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_endpt_id);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_accept.c_sd != EXS_SD_FREE)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_accept.c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_server.c_sd != EXS_SD_FREE)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) close(hp->h_server.c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * * * * * * * * * * * * * * * * * * * * * * * * * * *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * ETM-to-Transport API Connection Management routines
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * * * * * * * * * * * * * * * * * * * * * * * * * * *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Initialize and setup any transport infrastructure before any connections
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * are opened.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return etm_xport_hdl_t for success, NULL for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_hdl_t
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_init(fmd_hdl_t *hdl, char *endpoint_id,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl int (*cb_func)(fmd_hdl_t *hdl, etm_xport_conn_t conn, etm_cb_flag_t flag,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl void *arg), void *cb_func_arg)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_hdl_t *hp, *curr;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt int dom;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if ((exs_get_id(hdl, endpoint_id, &dom)) == -1)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (NULL);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) pthread_mutex_lock(&List_lock);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Check for a duplicate endpoint_id on the list */
d338766d6376ee721b7f1778e12bf79a112bd778jrutt for (curr = Exh_head; curr; curr = curr->h_next) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (dom == curr->h_dom) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_debug(hdl, "xport - init failed, "
d338766d6376ee721b7f1778e12bf79a112bd778jrutt "duplicate domain id : %d\n", dom);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) pthread_mutex_unlock(&List_lock);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (NULL);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp = exs_hdl_alloc(hdl, endpoint_id, cb_func, cb_func_arg, dom);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl /* Add this transport instance handle to the list */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_next = Exh_head;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl Exh_head = hp;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt if (exs_prep_accept(hp) == 0)
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt /* A server thread is created for every endpoint */
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt hp->h_tid = fmd_thr_create(hdl, exs_server, hp);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) pthread_mutex_unlock(&List_lock);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return ((etm_xport_hdl_t)hp);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Teardown any transport infrastructure after all connections are closed.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return 0 for success, or nonzero for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jlint
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_fini(fmd_hdl_t *hdl, etm_xport_hdl_t tlhdl)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_hdl_t *hp = (exs_hdl_t *)tlhdl;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt exs_hdl_t *xp, **ppx = &Exh_head;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) pthread_mutex_lock(&List_lock);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt for (xp = *ppx; xp; xp = xp->h_next) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (xp != hp)
d338766d6376ee721b7f1778e12bf79a112bd778jrutt ppx = &xp->h_next;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt else
25cf1a301a396c38e8adf52c15f537b80d2483f7jl break;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (xp != hp) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) pthread_mutex_unlock(&List_lock);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_hdl_abort(hdl, "xport - fini failed, tlhdl %p not on list",
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void *)hp);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt *ppx = hp->h_next;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_next = NULL;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (hp->h_tid != EXS_TID_FREE) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt hp->h_quit = 1;
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_thr_signal(hdl, hp->h_tid);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt fmd_thr_destroy(hdl, hp->h_tid);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt /* Socket descr for h_accept and h_server are closed in exs_server */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (hp->h_client.c_sd != EXS_SD_FREE)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) close(hp->h_client.c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_strfree(hdl, hp->h_endpt_id);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_free(hdl, hp, sizeof (exs_hdl_t));
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
d338766d6376ee721b7f1778e12bf79a112bd778jrutt (void) pthread_mutex_unlock(&List_lock);
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Open a connection with the given endpoint,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return etm_xport_conn_t for success, NULL and set errno for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_conn_t
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_open(fmd_hdl_t *hdl, etm_xport_hdl_t tlhdl)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl int flags;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_hdl_t *hp = (exs_hdl_t *)tlhdl;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt if (hp->h_destroy) {
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt fmd_thr_destroy(hp->h_hdl, hp->h_tid);
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt hp->h_tid = EXS_TID_FREE;
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt hp->h_destroy = 0;
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt }
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt if (hp->h_tid == EXS_TID_FREE) {
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt if (exs_prep_accept(hp) == 0)
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt hp->h_tid = fmd_thr_create(hdl, exs_server, hp);
4573608322e68a31a57d0d851d7b324f4ffb66b5jrutt }
d338766d6376ee721b7f1778e12bf79a112bd778jrutt
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (hp->h_client.c_sd == EXS_SD_FREE) {
d338766d6376ee721b7f1778e12bf79a112bd778jrutt if (exs_prep_client(hp) != 0)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (NULL);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt /* Set the socket to be non-blocking */
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt flags = fcntl(hp->h_client.c_sd, F_GETFL, 0);
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt (void) fcntl(hp->h_client.c_sd, F_SETFL, flags | O_NONBLOCK);
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if ((connect(hp->h_client.c_sd,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (struct sockaddr *)&hp->h_client.c_saddr,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_client.c_len)) == -1) {
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt if (errno != EINPROGRESS) {
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt fmd_hdl_error(hdl, "xport - failed server connect : %s",
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt hp->h_endpt_id);
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt (void) close(hp->h_client.c_sd);
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt hp->h_client.c_sd = EXS_SD_FREE;
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt return (NULL);
154b1f02449b21af9273efd1a7776a3fe65a0744jrutt }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - connected client socket for %s",
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hp->h_endpt_id);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (&hp->h_client);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Close a connection from either endpoint.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return zero for success, nonzero for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*ARGSUSED*/
25cf1a301a396c38e8adf52c15f537b80d2483f7jlint
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_close(fmd_hdl_t *hdl, etm_xport_conn_t conn)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_conn_t *cp = (exs_conn_t *)conn;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (cp->c_sd == EXS_SD_FREE)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (0); /* Connection already closed */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) close(cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl cp->c_sd = EXS_SD_FREE;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * * * * * * * * * * * * * * * * * *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * ETM-to-Transport API I/O routines
d338766d6376ee721b7f1778e12bf79a112bd778jrutt * * * * * * * * * * * * * * * * * *
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Try to read byte_cnt bytes from the connection into the given buffer.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return how many bytes actually read for success, negative value for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jlssize_t
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_read(fmd_hdl_t *hdl, etm_xport_conn_t conn, hrtime_t timeout,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl void *buf, size_t byte_cnt)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl ssize_t len, nbytes = 0;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hrtime_t endtime, sleeptime;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl struct timespec tms;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl char *ptr = (char *)buf;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_conn_t *cp = (exs_conn_t *)conn;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (cp->c_sd == EXS_SD_FREE) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - read socket %d is closed\n",
25cf1a301a396c38e8adf52c15f537b80d2483f7jl cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (-EBADF);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl endtime = gethrtime() + timeout;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl sleeptime = timeout / EXS_IO_SLEEP_DIV;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl tms.tv_sec = 0;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl tms.tv_nsec = sleeptime;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl while (nbytes < byte_cnt) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (gethrtime() < endtime) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if ((len = recv(cp->c_sd, ptr, byte_cnt - nbytes,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl 0)) < 0) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (errno != EINTR && errno != EWOULDBLOCK) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - recv "
25cf1a301a396c38e8adf52c15f537b80d2483f7jl "failed for socket %d", cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) nanosleep(&tms, 0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl continue;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl } else if (len == 0) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - remote endpt "
25cf1a301a396c38e8adf52c15f537b80d2483f7jl "closed for socket %d", cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl ptr += len;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl nbytes += len;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl } else {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - read timed out for socket "
25cf1a301a396c38e8adf52c15f537b80d2483f7jl "%d", cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl break;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (nbytes)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (nbytes);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl else
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (-1);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl/*
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Try to write byte_cnt bytes to the connection from the given buffer.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * Return how many bytes actually written for success, negative value
25cf1a301a396c38e8adf52c15f537b80d2483f7jl * for failure.
25cf1a301a396c38e8adf52c15f537b80d2483f7jl */
25cf1a301a396c38e8adf52c15f537b80d2483f7jlssize_t
25cf1a301a396c38e8adf52c15f537b80d2483f7jletm_xport_write(fmd_hdl_t *hdl, etm_xport_conn_t conn, hrtime_t timeout,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl void *buf, size_t byte_cnt)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl{
25cf1a301a396c38e8adf52c15f537b80d2483f7jl ssize_t len, nbytes = 0;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl hrtime_t endtime, sleeptime;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl struct timespec tms;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl char *ptr = (char *)buf;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl exs_conn_t *cp = (exs_conn_t *)conn;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (cp->c_sd == EXS_SD_FREE) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - write socket %d is closed\n",
25cf1a301a396c38e8adf52c15f537b80d2483f7jl cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (-EBADF);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl endtime = gethrtime() + timeout;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl sleeptime = timeout / EXS_IO_SLEEP_DIV;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl tms.tv_sec = 0;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl tms.tv_nsec = sleeptime;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl while (nbytes < byte_cnt) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (gethrtime() < endtime) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if ((len = send(cp->c_sd, ptr, byte_cnt - nbytes,
25cf1a301a396c38e8adf52c15f537b80d2483f7jl 0)) < 0) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (errno != EINTR && errno != EWOULDBLOCK) {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - send "
25cf1a301a396c38e8adf52c15f537b80d2483f7jl "failed for socket %d", cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl (void) nanosleep(&tms, 0);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl continue;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl ptr += len;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl nbytes += len;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl } else {
25cf1a301a396c38e8adf52c15f537b80d2483f7jl fmd_hdl_debug(hdl, "xport - write timed out for socket "
25cf1a301a396c38e8adf52c15f537b80d2483f7jl "%d", cp->c_sd);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl break;
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl }
25cf1a301a396c38e8adf52c15f537b80d2483f7jl
25cf1a301a396c38e8adf52c15f537b80d2483f7jl if (nbytes)
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (nbytes);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl else
25cf1a301a396c38e8adf52c15f537b80d2483f7jl return (-1);
25cf1a301a396c38e8adf52c15f537b80d2483f7jl}