xref: /titanic_52/usr/src/cmd/cmd-inet/usr.sbin/snoop/snoop_solarnet.c (revision 7c478bd95313f5f23a4c958a745db2134aa03244)

/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License, Version 1.0 only
 * (the "License").  You may not use this file except in compliance
 * with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright (c) 1993, 1999 by Sun Microsystems, Inc.
 * All rights reserved.
 */

#pragma	ident	"%W%	%E% SMI"

#include <sys/types.h>
#include <sys/errno.h>
#include <setjmp.h>
#include <limits.h>
#include <netinet/in.h>
#include <string.h>

#include <rpc/types.h>
#include <rpc/rpc.h>
#include <rpc/xdr.h>
#include <rpc/auth.h>
#include <rpc/clnt.h>
#include <rpc/rpc_msg.h>
#include <fw.h>
#include <fw_rpc.h>
#include "snoop.h"

extern char *dlc_header;
extern jmp_buf xdr_err;

static char *procnames_short[] = {
	"Null",		/*  0 */
	"INVOKE",	/*  1 */
	"MORE",		/*  2 */
	"KILL",		/*  3 */
};

static char *procnames_long[] = {
	"Null procedure",	/*  0 */
	"Invoke operation",	/*  1 */
	"More data",		/*  2 */
	"Kill operation",	/*  3 */
};

#define	MAXPROC	3

enum Rec_type {
	REC_TYPE_NORM = 0,
	REC_TYPE_EOR = 1,
	REC_TYPE_EOF = 2
};
typedef enum Rec_type Rec_type;

void
interpret_solarnet_fw(
	int flags,
	int type,
	int xid,
	int vers,
	int proc,
	char *data,
	int len)
{
	char *line;
	char buff[CTXTLEN + 1];
	ulong_t thresh;
	char op[CTXTLEN + 1];
	bool_t b;
	Fw_err e;
	Rec_type rt;
	int new_row = 1, row = 0;

	if (proc < 0 || proc > MAXPROC)
		return;

	if (flags & F_SUM) {
		if (setjmp(xdr_err)) {
			return;
		}

		line = get_sum_line();

		if (type == CALL) {
			(void) sprintf(line,
				"SOLARNET C %s",
				procnames_short[proc]);
			line += strlen(line);

			switch (proc) {
			case FW_INVOKE:
				(void) sprintf(line, " %s",
				    getxdr_string(buff, CTXTLEN));
				line += strlen(line);
				(void) sprintf(line, "/%s",
				    getxdr_string(buff, CTXTLEN));
				line += strlen(line);
				getxdr_string(buff, CTXTLEN);
				if (strlen(buff) != 0) {
					(void) sprintf(line, ".%s", buff);
					line += strlen(line);
				}
				(void) getxdr_string(buff, CTXTLEN);
				thresh = getxdr_u_long();
				if (thresh == ULONG_MAX)
					(void) sprintf(line, " (all)");
				else
					(void) sprintf(line, " %lu", thresh);
				line += strlen(line);
				(void) getxdr_context(buff, CTXTLEN);
				break;
			case FW_MORE:
				(void) getxdr_context(buff, CTXTLEN);
				sscanf(buff, "%*s %*s %s.%*s", op);
				op[strlen(op)-1] = '\0';
				(void) sprintf(line, " %s", op);
				line += strlen(line);
				thresh = getxdr_u_long();
				if (thresh == ULONG_MAX)
					(void) sprintf(line, " (all)");
				else
					(void) sprintf(line, " %lu", thresh);
				line += strlen(line);
				break;
			case FW_KILL:
				(void) getxdr_context(buff, CTXTLEN);
				sscanf(buff, "%*s %*s %s.%*s", op);
				op[strlen(op)-1] = '\0';
				(void) sprintf(line, " %s", op);
				line += strlen(line);
				break;
			default:
				break;
			}

			check_retransmit(line, xid);
		} else {
			(void) sprintf(line, "SOLARNET R %s",
			    procnames_short[proc]);
			line += strlen(line);
			b = getxdr_bool();
			if (b) {
				e = getxdr_enum();
				if (e == FW_ERR_FW)
					sprintf(line, " FW");
				else if (e == FW_ERR_OP)
					sprintf(line, " OP");
				else
					sprintf(line, " NOERR");
				line += strlen(line);
				if (e != FW_ERR_NONE) {
					sprintf(line, " %lu", getxdr_u_long());
					line += strlen(line);
					(void) getxdr_bool();
					sprintf(line, " %s",
					    getxdr_string(buff, CTXTLEN));
					line += strlen(line);
				}
			} else {
				sprintf(line, " Success");
				line += strlen(line);
			}
			b = getxdr_bool();
			if (b) {
				sprintf(line, " %lu rows", getxdr_u_long());
				line += strlen(line);
			} else {
				sprintf(line, " (No output)");
				line += strlen(line);
			}
		}
	}

	if ((flags & F_DTAIL)) {
		show_header("SOLARNET:  ", "Solarnet Administration Service",
		    len);
		show_space();
		if (setjmp(xdr_err)) {
			return;
		}
		(void) sprintf(get_line(0, 0), "Proc = %d (%s)", proc,
		    procnames_long[proc]);
		if (type == CALL) {
			switch (proc) {
			case FW_INVOKE:
				(void) showxdr_string(CTXTLEN, "Category: %s");
				(void) showxdr_string(CTXTLEN, "Operation: %s");
				(void) showxdr_string(CTXTLEN, "Version: %s");
				(void) showxdr_string(CTXTLEN, "Locale: %s");
				(void) showxdr_u_long("Threshold: %lu rows");
				(void) showxdr_context("Context: %s");
				b = getxdr_bool();
				if (!b) {
					sprintf(get_line(0, 0),
					    "No input arguments");
					break;
				}
				thresh = showxdr_u_long("Input rows = %lu");
				(void) getxdr_bool();
				do {
					rt = getxdr_enum();
					if (rt == REC_TYPE_NORM) {
						if (new_row) {
							sprintf(get_line(0, 0),
							    "Row %d", ++row);
							new_row = 0;
						}
						(void) getxdr_string(buff,
						    CTXTLEN);
						(void) getxdr_string(op,
						    CTXTLEN);
						sprintf(get_line(0, 0),
						    "\t%s = %s", buff, op);
					} else if (rt == REC_TYPE_EOR) {
						new_row = 1;
					}
				} while (rt != REC_TYPE_EOF);
				break;
			case FW_MORE:
				(void) showxdr_context("Context: %s");
				(void) showxdr_u_long("Threshold: %lu rows");
				break;
			case FW_KILL:
				(void) showxdr_context("Context: %s");
				break;
			default:
				break;
			}
		} else {
			b = getxdr_bool();
			if (b) {
				e = getxdr_enum();
				if (e == FW_ERR_FW) {
					showxdr_u_long(
					    "Framework error code %lu");
				} else if (e == FW_ERR_OP) {
					showxdr_u_long(
					    "Operation error code %lu");
				} else {
					showxdr_u_long("No error %*lu");
				}
				(void) getxdr_bool();
				(void) getxdr_string(buff, CTXTLEN);
				if (e != FW_ERR_NONE) {
					sprintf(get_line(0, 0),
					    "Error message: %s", buff);
				} else {
				}
			} else {
				sprintf(get_line(0, 0),
				    "Operation was successful");
			}
			b = getxdr_bool();
			if (b) {
				showxdr_u_long("Output rows: %lu");
				(void) getxdr_bool();
				do {
					rt = getxdr_enum();
					if (rt == REC_TYPE_NORM) {
						if (new_row) {
							sprintf(get_line(0, 0),
							    "Row %d", ++row);
							new_row = 0;
						}
						(void) getxdr_string(buff,
						    CTXTLEN);
						(void) getxdr_string(op,
						    CTXTLEN);
						sprintf(get_line(0, 0),
						    "\t%s = %s", buff, op);
					} else if (rt == REC_TYPE_EOR) {
						new_row = 1;
					}
				} while (rt != REC_TYPE_EOF);
			} else {
				sprintf(get_line(0, 0), "No output");
			}
		}
		show_trailer();
	}

}