lib/dialects/netbsd/dsock.c - master - githubmirror/lsof

lib/dialects/netbsd/dsock.c
438 строк14 KB
Chen
Library part5 (#290)
24 май 2023, 13:55
24 май 2023, 13:55cab786c
/*
 * dsock.c - NetBSD socket processing functions for lsof
 */

/*
 * Copyright 1994 Purdue Research Foundation, West Lafayette, Indiana
 * 47907.  All rights reserved.
 *
 * Written by Victor A. Abell
 *
 * This software is not subject to any license of the American Telephone
 * and Telegraph Company or the Regents of the University of California.
 *
 * Permission is granted to anyone to use this software for any purpose on
 * any computer system, and to alter it and redistribute it freely, subject
 * to the following restrictions:
 *
 * 1. Neither the authors nor Purdue University are responsible for any
 *    consequences of the use of this software.
 *
 * 2. The origin of this software must not be misrepresented, either by
 *    explicit claim or by omission.  Credit to the authors and Purdue
 *    University must appear in documentation and sources.
 *
 * 3. Altered versions must be plainly marked as such, and must not be
 *    misrepresented as being the original software.
 *
 * 4. This notice may not be removed or altered.
 */

#ifndef lint
static char copyright[] =
    "@(#) Copyright 1994 Purdue Research Foundation.\nAll rights reserved.\n";
#endif

#include "common.h"

#if defined(HASIPv6)

/*
 * IPv6_2_IPv4()  -- macro to define the address of an IPv4 address contained
 *		     in an IPv6 address
 */

#    define IPv6_2_IPv4(v6) (((uint8_t *)((struct in6_addr *)v6)->s6_addr) + 12)
#endif /* defined(HASIPv6) */

/*
 * process_socket() - process socket
 */

void process_socket(struct lsof_context *ctx, /* context */
                    KA_T sa)                  /* socket address in kernel */
{
#if NETBSDV >= 9099104
#    define NETBSD_MERGED_INPCB
#endif
    struct domain d;
    unsigned char *fa = (unsigned char *)NULL;
    int fam;
    int fp, lp;
#ifdef NETBSD_MERGED_INPCB
    struct in4pcb inp;
#else
    struct inpcb inp;
#endif
    unsigned char *la = (unsigned char *)NULL;
    struct protosw p;
    struct socket s;
    struct tcpcb t;
    KA_T ta = (KA_T)NULL;
    struct unpcb uc, unp;
    struct sockaddr_un *ua = NULL;
    struct sockaddr_un un;

#if defined(HASIPv6) && defined(NETBSDV) && !defined(HASINRIAIPv6)
#    ifdef NETBSD_MERGED_INPCB
#        define in6p_ppcb in6p_pcb.inp_ppcb
#    endif
    struct in6pcb in6p;
#endif /* defined(HASIPv6) && defined(NETBSDV) && !defined(HASINRIAIPv6) */

#define UNPADDR_IN_MBUF

#if defined(NETBSDV)
#    if NETBSDV >= 1004000
#        undef UNPADDR_IN_MBUF
#    endif /* NETBSDV>=1004000 */
#endif     /* defined(NETBSDV) */

#if defined(UNPADDR_IN_MBUF)
    struct mbuf mb;
#endif /* defined(UNPADDR_IN_MBUF) */

    Lf->type = LSOF_FILE_SOCKET;
    Lf->inp_ty = 2;
    /*
     * Read the socket, protocol, and domain structures.
     */
    if (!sa) {
        enter_nm(ctx, "no socket address");
        return;
    }
    if (kread(ctx, sa, (char *)&s, sizeof(s))) {
        (void)snpf(Namech, Namechl, "can't read socket struct from %s",
                   print_kptr(sa, (char *)NULL, 0));
        enter_nm(ctx, Namech);
        return;
    }
    if (!s.so_type) {
        enter_nm(ctx, "no socket type");
        return;
    }
    if (!s.so_proto || kread(ctx, (KA_T)s.so_proto, (char *)&p, sizeof(p))) {
        (void)snpf(Namech, Namechl, "can't read protocol switch from %s",
                   print_kptr((KA_T)s.so_proto, (char *)NULL, 0));
        enter_nm(ctx, Namech);
        return;
    }
    if (!p.pr_domain || kread(ctx, (KA_T)p.pr_domain, (char *)&d, sizeof(d))) {
        (void)snpf(Namech, Namechl, "can't read domain struct from %s",
                   print_kptr((KA_T)p.pr_domain, (char *)NULL, 0));
        enter_nm(ctx, Namech);
        return;
    }
    /*
     * Save size information.
     */
    if (Lf->access == LSOF_FILE_ACCESS_READ)
        Lf->sz = (SZOFFTYPE)s.so_rcv.sb_cc;
    else if (Lf->access == LSOF_FILE_ACCESS_WRITE)
        Lf->sz = (SZOFFTYPE)s.so_snd.sb_cc;
    else
        Lf->sz = (SZOFFTYPE)(s.so_rcv.sb_cc + s.so_snd.sb_cc);
    Lf->sz_def = 1;

#if defined(HASTCPTPIQ)
    Lf->lts.rq = s.so_rcv.sb_cc;
    Lf->lts.sq = s.so_snd.sb_cc;
    Lf->lts.rqs = Lf->lts.sqs = 1;
#endif /* defined(HASTCPTPIQ) */

#if defined(HASSOOPT)
    Lf->lts.ltm = (unsigned int)s.so_linger;
    Lf->lts.opt = (unsigned int)s.so_options;
    Lf->lts.pqlen = (unsigned int)s.so_q0len;
    Lf->lts.qlen = (unsigned int)s.so_qlen;
    Lf->lts.qlim = (unsigned int)s.so_qlimit;
    Lf->lts.rbsz = (unsigned long)s.so_rcv.sb_mbmax;
    Lf->lts.sbsz = (unsigned long)s.so_snd.sb_mbmax;
    Lf->lts.pqlens = Lf->lts.qlens = Lf->lts.qlims = Lf->lts.rbszs =
        Lf->lts.sbszs = (unsigned char)1;
#endif /* defined(HASSOOPT) */

#if defined(HASSOSTATE)
    Lf->lts.ss = (unsigned int)s.so_state;
#endif /* defined(HASSOSTATE) */

    /*
     * Process socket by the associated domain family.
     */
    switch ((fam = d.dom_family)) {
        /*
         * Process an Internet domain socket.
         */
    case AF_INET:

#if defined(HASIPv6)
    case AF_INET6:
#endif /* defined(HASIPv6) */

        if (Fnet) {
            if (!FnetTy || ((FnetTy == 4) && (fam == AF_INET))

#if defined(HASIPv6)
                || ((FnetTy == 6) && (fam == AF_INET6))
#endif /* defined(HASIPv6) */
            )

                Lf->sf |= SELNET;
        }
        printiproto(ctx, p.pr_protocol);

#if defined(HASIPv6)
        Lf->type = (fam == AF_INET) ? LSOF_FILE_IPV4 : LSOF_FILE_IPV6;
#else  /* !defined(HASIPv6) */
        Lf->type = LSOF_FILE_INET;
#endif /* defined(HASIPv6) */

#if defined(HASIPv6) && defined(NETBSDV) && !defined(HASINRIAIPv6)
        if (fam == AF_INET6) {

            /*
             * Read IPv6 protocol control block.
             */
            if (!s.so_pcb ||
                kread(ctx, (KA_T)s.so_pcb, (char *)&in6p, sizeof(in6p))) {
                (void)snpf(Namech, Namechl, "can't read in6pcb at %s",
                           print_kptr((KA_T)s.so_pcb, (char *)NULL, 0));
                enter_nm(ctx, Namech);
                return;
            }
            /*
             * Save IPv6 address information.
             */
            enter_dev_ch(ctx, print_kptr((KA_T)(in6p.in6p_ppcb ? in6p.in6p_ppcb
                                                               : s.so_pcb),
                                         (char *)NULL, 0));
            if (p.pr_protocol == IPPROTO_TCP)
                ta = (KA_T)in6p.in6p_ppcb;
#    ifdef NETBSD_MERGED_INPCB
            la = (unsigned char *)&in6p_laddr(&in6p);
            lp = (int)ntohs(in6p.in6p_pcb.inp_lport);
            if (!IN6_IS_ADDR_UNSPECIFIED(&in6p_faddr(&in6p)) ||
                (in6p.in6p_pcb.inp_fport)) {
                fa = (unsigned char *)&in6p_faddr(&in6p);
                fp = (int)ntohs(in6p.in6p_pcb.inp_fport);
            }
#    else
            la = (unsigned char *)&in6p.in6p_laddr;
            lp = (int)ntohs(in6p.in6p_lport);
            if (!IN6_IS_ADDR_UNSPECIFIED(&in6p.in6p_faddr) || in6p.in6p_fport) {
                fa = (unsigned char *)&in6p.in6p_faddr;
                fp = (int)ntohs(in6p.in6p_fport);
            }
#    endif
        } else
#endif /* defined(HASIPv6) && defined(NETBSDV) && !defined(HASINRIAIPv6) */

        {

            /*
             * Read IPv4 or IPv6 (NetBSD) protocol control block.
             */
            if (!s.so_pcb ||
                kread(ctx, (KA_T)s.so_pcb, (char *)&inp, sizeof(inp))) {
                if (!s.so_pcb) {
                    (void)snpf(
                        Namech, Namechl, "no PCB%s%s",
                        (s.so_state & SS_CANTSENDMORE) ? ", CANTSENDMORE" : "",
                        (s.so_state & SS_CANTRCVMORE) ? ", CANTRCVMORE" : "");
                } else {
                    (void)snpf(Namech, Namechl, "can't read inpcb at %s",
                               print_kptr((KA_T)s.so_pcb, (char *)NULL, 0));
                }
                enter_nm(ctx, Namech);
                return;
            }
#ifdef NETBSD_MERGED_INPCB
#    define inp_ppcb in4p_pcb.inp_ppcb
#    define inp_lport in4p_pcb.inp_lport
#endif
            enter_dev_ch(
                ctx, print_kptr((KA_T)(inp.inp_ppcb ? inp.inp_ppcb : s.so_pcb),
                                (char *)NULL, 0));
            if (p.pr_protocol == IPPROTO_TCP)
                ta = (KA_T)inp.inp_ppcb;
            lp = (int)ntohs(inp.inp_lport);
#ifdef NETBSD_MERGED_INPCB
#    undef inp_ppcb
#    undef inp_lport
#endif
            if (fam == AF_INET) {

                /*
                 * Save IPv4 address information.
                 */
#ifdef NETBSD_MERGED_INPCB
                la = (unsigned char *)&in4p_laddr(&inp);
                if (in4p_faddr(&inp).s_addr != INADDR_ANY ||
                    inp.in4p_pcb.inp_fport) {
                    fa = (unsigned char *)&in4p_faddr(&inp);
                    fp = (int)ntohs(inp.in4p_pcb.inp_fport);
                }
#else
                la = (unsigned char *)&inp.inp_laddr;
                if (inp.inp_faddr.s_addr != INADDR_ANY || inp.inp_fport) {
                    fa = (unsigned char *)&inp.inp_faddr;
                    fp = (int)ntohs(inp.inp_fport);
                }
#endif
            }

#if defined(HASIPv6) && defined(HASINRIAIPv6)
            else {
                la = (unsigned char *)&inp.inp_laddr6;
                if (!IN6_IS_ADDR_UNSPECIFIED(&inp.inp_faddr6) ||
                    inp.inp_fport) {
                    fa = (unsigned char *)&inp.inp_faddr6;
                    fp = (int)ntohs(inp.inp_fport);
                }
            }
#endif /* defined(HASIPv6) && defined(HASINRIAIPv6) */
        }

#if defined(HASIPv6)
        if ((fam == AF_INET6) &&
            ((la && IN6_IS_ADDR_V4MAPPED((struct in6_addr *)la)) ||
             ((fa && IN6_IS_ADDR_V4MAPPED((struct in6_addr *)fa))))) {

            /*
             * Adjust for IPv4 addresses mapped in IPv6 addresses.
             */
            if (la)
                la = (unsigned char *)IPv6_2_IPv4(la);
            if (fa)
                fa = (unsigned char *)IPv6_2_IPv4(fa);
            fam = AF_INET;
        }
#endif /* defined(HASIPv6) */

        /*
         * Enter local and remote addresses by address family.
         */
        if (fa || la)
            (void)ent_inaddr(ctx, la, lp, fa, fp, fam);
        /*
         * If the protocol is TCP, and its address is available, read the
         * TCP protocol control block and save its state.
         */
        if (ta && !kread(ctx, ta, (char *)&t, sizeof(t))) {
            Lf->lts.type = 0;
            Lf->lts.state.i = (int)t.t_state;

#if defined(HASTCPOPT)
            Lf->lts.mss = (unsigned long)t.t_ourmss;

            Lf->lts.msss = (unsigned char)1;
            Lf->lts.topt = (unsigned int)t.t_flags;
#endif /* defined(HASTCPOPT) */
        }
        break;
        /*
         * Process a ROUTE domain socket.
         */
    case AF_ROUTE:
        Lf->type = LSOF_FILE_ROUTE;
        if (s.so_pcb)
            enter_dev_ch(ctx, print_kptr((KA_T)(s.so_pcb), (char *)NULL, 0));
        else
            (void)snpf(Namech, Namechl, "no protocol control block");
        break;
        /*
         * Process a Unix domain socket.
         */
    case AF_UNIX:
        if (Funix)
            Lf->sf |= SELUNX;
        Lf->type = LSOF_FILE_UNIX;
        /*
         * Read Unix protocol control block and the Unix address structure.
         */

        enter_dev_ch(ctx, print_kptr(sa, (char *)NULL, 0));
        if (kread(ctx, (KA_T)s.so_pcb, (char *)&unp, sizeof(unp))) {
            (void)snpf(Namech, Namechl, "can't read unpcb at %s",
                       print_kptr((KA_T)s.so_pcb, (char *)NULL, 0));
            break;
        }
        if ((struct socket *)sa != unp.unp_socket) {
            (void)snpf(Namech, Namechl, "unp_socket (%s) mismatch",
                       print_kptr((KA_T)unp.unp_socket, (char *)NULL, 0));
            break;
        }
        if (unp.unp_addr) {

#if defined(UNPADDR_IN_MBUF)
            if (kread(ctx, (KA_T)unp.unp_addr, (char *)&mb, sizeof(mb)))
#else  /* !defined(UNPADDR_IN_MBUF) */
            if (kread(ctx, (KA_T)unp.unp_addr, (char *)&un, sizeof(un)))
#endif /* defined(UNPADDR_IN_MBUF) */

            {
                (void)snpf(Namech, Namechl, "can't read unp_addr at %s",
                           print_kptr((KA_T)unp.unp_addr, (char *)NULL, 0));
                break;
            }

#if defined(UNPADDR_IN_MBUF)
            if (mb.m_hdr.mh_len == sizeof(struct sockaddr_un))
                ua = (struct sockaddr_un *)((char *)&mb +
                                            (mb.m_hdr.mh_data -
                                             (caddr_t)unp.unp_addr));
#else  /* !defined(UNPADDR_IN_MBUF) */
            ua = &un;
#endif /* defined(UNPADDR_IN_MBUF) */
        }
        if (!ua) {
            ua = &un;
            (void)bzero((char *)ua, sizeof(un));
            ua->sun_family = AF_UNSPEC;
        }
        /*
         * Print information on Unix socket that has no address bound
         * to it, although it may be connected to another Unix domain
         * socket as a pipe.
         */
        if (ua->sun_family != AF_UNIX) {
            if (ua->sun_family == AF_UNSPEC) {
                if (unp.unp_conn) {
                    if (kread(ctx, (KA_T)unp.unp_conn, (char *)&uc, sizeof(uc)))
                        (void)snpf(
                            Namech, Namechl, "can't read unp_conn at %s",
                            print_kptr((KA_T)unp.unp_conn, (char *)NULL, 0));
                    else
                        (void)snpf(
                            Namech, Namechl, "->%s",
                            print_kptr((KA_T)uc.unp_socket, (char *)NULL, 0));
                } else
                    (void)snpf(Namech, Namechl, "->(none)");
            } else
                (void)snpf(Namech, Namechl, "unknown sun_family (%d)",
                           ua->sun_family);
            break;
        }
        if (ua->sun_path[0]) {

#if defined(UNPADDR_IN_MBUF)
            if (mb.m_len >= sizeof(struct sockaddr_un))
                mb.m_len = sizeof(struct sockaddr_un) - 1;
            *((char *)ua + mb.m_len) = '\0';
#else  /* !defined(UNPADDR_IN_MBUF) */
            ua->sun_path[sizeof(ua->sun_path) - 1] = '\0';
#endif /* defined(UNPADDR_IN_MBUF) */

            if (Sfile && is_file_named(ctx, ua->sun_path, 0))
                Lf->sf |= SELNM;
            if (!Namech[0])
                (void)snpf(Namech, Namechl, "%s", ua->sun_path);
        } else
            (void)snpf(Namech, Namechl, "no address");
        break;
    default:
        printunkaf(ctx, fam, 1);
    }
    if (Namech[0])
        enter_nm(ctx, Namech);
}