xref: /src/usr.bin/netstat/atalk.c

/*	$NetBSD: atalk.c,v 1.16.18.2 2022/09/12 14:23:41 martin Exp $	*/

/*
 * Copyright (c) 1983, 1988, 1993
 *	The Regents of the University of California.  All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the University nor the names of its contributors
 *    may be used to endorse or promote products derived from this software
 *    without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */

#include <sys/cdefs.h>
#ifndef lint
#if 0
static char sccsid[] = "from @(#)atalk.c	1.1 (Whistle) 6/6/96";
#else
__RCSID("$NetBSD: atalk.c,v 1.16.18.2 2022/09/12 14:23:41 martin Exp $");
#endif
#endif /* not lint */

#include <sys/param.h>
#include <sys/queue.h>
#include <sys/socket.h>
#include <sys/socketvar.h>
#include <sys/mbuf.h>
#include <sys/protosw.h>
#include <sys/sysctl.h>

#include <net/route.h>
#include <net/if.h>

#include <netinet/tcp_fsm.h>

#include <netatalk/at.h>
#include <netatalk/ddp_var.h>

#include <err.h>
#include <nlist.h>
#include <kvm.h>
#include <errno.h>
#include <stdio.h>
#include <string.h>
#include "netstat.h"
#include "prog_ops.h"

static int first = 1;

/*
 * Print a summary of connections related to a Network Systems
 * protocol.  For XXX, also give state of connection.
 * Listening processes (aflag) are suppressed unless the
 * -a (all) flag is specified.
 */

static const char *
at_pr_net(const struct sockaddr_at *sat, int numeric)
{
	static char mybuf[50];

	if (!numeric) {
		switch (sat->sat_addr.s_net) {
		case 0xffff:
			return "????";
		case ATADDR_ANYNET:
			return "*";
		}
	}
	(void)snprintf(mybuf, sizeof(mybuf), "%hu",
	    ntohs(sat->sat_addr.s_net));
	return mybuf;
}

static const char *
at_pr_host(const struct sockaddr_at *sat, int numeric)
{
	static char mybuf[50];

	if (!numeric) {
		switch (sat->sat_addr.s_node) {
		case ATADDR_BCAST:
			return "bcast";
		case ATADDR_ANYNODE:
			return "*";
		}
	}
	(void)snprintf(mybuf, sizeof(mybuf), "%d",
	    (unsigned int)sat->sat_addr.s_node);
	return mybuf;
}

static const char *
at_pr_port(const struct sockaddr_at *sat)
{
	static char mybuf[50];

	switch (sat->sat_port) {
	case ATADDR_ANYPORT:
		return "*";
	case 0xff:
		return "????";
	default:
		(void)snprintf(mybuf, sizeof(mybuf), "%d",
		    (unsigned int)sat->sat_port);
		return mybuf;
	}
}

static const char *
at_pr_range(const struct sockaddr_at *sat)
{
	static char mybuf[50];

	if (sat->sat_range.r_netrange.nr_firstnet
	    != sat->sat_range.r_netrange.nr_lastnet) {
		(void)snprintf(mybuf, sizeof(mybuf), "%d-%d",
			ntohs(sat->sat_range.r_netrange.nr_firstnet),
			ntohs(sat->sat_range.r_netrange.nr_lastnet));
	} else {
		(void)snprintf(mybuf, sizeof(mybuf), "%d",
			ntohs(sat->sat_range.r_netrange.nr_firstnet));
	}
	return mybuf;
}


/* what == 0 for addr only == 3
 *	1 for net
 *	2 for host
 *	4 for port
 *	8 for numeric only
 */
const char *
atalk_print(const struct sockaddr *sa, int what)
{
	const struct sockaddr_at *sat = (const struct sockaddr_at *) sa;
	static char mybuf[50];
	int numeric = (what & 0x08);

	mybuf[0] = 0;
	switch (what & 0x13) {
	case 0:
		mybuf[0] = 0;
		break;
	case 1:
		(void)snprintf(mybuf, sizeof(mybuf), "%s",
		    at_pr_net(sat, numeric));
		break;
	case 2:
		(void)snprintf(mybuf, sizeof(mybuf), "%s",
		    at_pr_host(sat, numeric));
		break;
	case 3:
		(void)snprintf(mybuf, sizeof(mybuf), "%s.%s",
			at_pr_net(sat, numeric),
			at_pr_host(sat, numeric));
		break;
	case 0x10:
		(void)snprintf(mybuf, sizeof(mybuf), "%s", at_pr_range(sat));
	}
	if (what & 4) {
		(void)snprintf(mybuf + strlen(mybuf),
		    sizeof(mybuf) - strlen(mybuf), ".%s", at_pr_port(sat));
	}
	return mybuf;
}

const char *
atalk_print2(const struct sockaddr *sa, const struct sockaddr *mask, int what)
{
	int		n, l;
	static char     buf[100];
	const struct sockaddr_at *sat1, *sat2;
	struct sockaddr_at thesockaddr;
	struct sockaddr *sa2;

	sat1 = (const struct sockaddr_at *) sa;
	sat2 = (const struct sockaddr_at *) mask;
	sa2 = (struct sockaddr *) & thesockaddr;

	thesockaddr.sat_addr.s_net = sat1->sat_addr.s_net &
	    sat2->sat_addr.s_net;
	n = snprintf(buf, sizeof(buf), "%s", atalk_print(sa2, 1 | (what & 8)));
	if (n >= (int)sizeof(buf))
		n = sizeof(buf) - 1;
	else if (n == -1)
		n = 0;	/* What else can be done ? */
	if (sat2->sat_addr.s_net != 0xFFFF) {
		thesockaddr.sat_addr.s_net = sat1->sat_addr.s_net |
		    ~sat2->sat_addr.s_net;
		l = snprintf(buf + n, sizeof(buf) - n,
		    "-%s", atalk_print(sa2, 1 | (what & 8)));
		if (l >= (int)(sizeof(buf) - n))
			l = sizeof(buf) - n - 1;
		if (l > 0)
			n += l;
	}
	if (what & 2) {
		l = snprintf(buf + n, sizeof(buf) - n, ".%s",
		    atalk_print(sa, what & (~1)));
		if (l >= (int)(sizeof(buf) - n))
			l = sizeof(buf) - n - 1;
		if (l > 0)
			n += l;
	}
	return buf;
}

void
atalkprotopr(u_long off, const char *name)
{
	struct ddpcb ddpcb;
	struct socket sockb;
	struct ddpcb *next;
	struct ddpcb *initial;
	int width = 22;
	if (off == 0)
		return;
	if (kread(off, (char *)&initial, sizeof(struct ddpcb *)) < 0)
		return;
	for (next = initial; next != NULL;) {
		u_long	ppcb = (u_long)next;

		if (kread((u_long)next, (char *)&ddpcb, sizeof(ddpcb)) < 0)
			return;
		next = ddpcb.ddp_next;
#if 0
		if (!aflag && atalk_nullhost(ddpcb.ddp_lsat))
			continue;
#endif
		if (kread((u_long)ddpcb.ddp_socket,
			  (char *)&sockb, sizeof(sockb)) < 0)
			return;
		if (first) {
			printf("Active ATALK connections");
			if (aflag)
				printf(" (including servers)");
			putchar('\n');
			if (Aflag) {
				width = 18;
				printf("%-8.8s ", "PCB");
			}
			printf("%-5.5s %-6.6s %-6.6s  %*.*s %*.*s %s\n",
			       "Proto", "Recv-Q", "Send-Q",
			       -width, width, "Local Address",
			       -width, width, "Foreign Address", "(state)");
			first = 0;
		}
		if (Aflag)
			printf("%8lx ", ppcb);
		printf("%-5.5s %6ld %6ld ", name, sockb.so_rcv.sb_cc,
		       sockb.so_snd.sb_cc);
		printf(" %*.*s", -width, width,
		       atalk_print((struct sockaddr *)&ddpcb.ddp_lsat, 7));
		printf(" %*.*s", -width, width,
		       atalk_print((struct sockaddr *)&ddpcb.ddp_fsat, 7));
		putchar('\n');
	}
}
#define ANY(x,y,z)							      \
	((sflag==1 || (x)) ?						      \
	    printf("\t%llu %s%s%s\n",(unsigned long long)x,y,plural(x),z) : 0)

/*
 * Dump DDP statistics structure.
 */
void
ddp_stats(u_long off, const char *name)
{
	uint64_t ddpstat[DDP_NSTATS];

	if (use_sysctl) {
		size_t size = sizeof(ddpstat);

		if (prog_sysctlbyname("net.atalk.ddp.stats", ddpstat, &size,
				 NULL, 0) == -1)
			return;
	} else {
		warnx("%s stats not available via KVM.", name);
		return;
	}

	printf("%s:\n", name);

	ANY(ddpstat[DDP_STAT_SHORT], "packet", " with short headers ");
	ANY(ddpstat[DDP_STAT_LONG], "packet", " with long headers ");
	ANY(ddpstat[DDP_STAT_NOSUM], "packet", " with no checksum ");
	ANY(ddpstat[DDP_STAT_TOOSHORT], "packet", " too short ");
	ANY(ddpstat[DDP_STAT_BADSUM], "packet", " with bad checksum ");
	ANY(ddpstat[DDP_STAT_TOOSMALL], "packet", " with not enough data ");
	ANY(ddpstat[DDP_STAT_FORWARD], "packet", " forwarded ");
	ANY(ddpstat[DDP_STAT_ENCAP], "packet", " encapsulated ");
	ANY(ddpstat[DDP_STAT_CANTFORWARD], "packet",
	    " rcvd for unreachable dest ");
	ANY(ddpstat[DDP_STAT_NOSOCKSPACE], "packet",
	    " dropped due to no socket space ");
}
#undef ANY