dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * CDDL HEADER START
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * The contents of this file are subject to the terms of the
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Common Development and Distribution License (the "License").
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * You may not use this file except in compliance with the License.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * or http://www.opensolaris.org/os/licensing.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * See the License for the specific language governing permissions
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * and limitations under the License.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * When distributing Covered Code, include this CDDL HEADER in each
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * If applicable, add the following below this CDDL HEADER, with the
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * fields enclosed by brackets "[]" replaced with your own identifying
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * information: Portions Copyright [yyyy] [name of copyright owner]
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * CDDL HEADER END
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Use is subject to license terms.
33f5ff17089e3a43e6e730bf80384c233123dbd9Milan Jurik * Copyright 2012 Milan Jurik. All rights reserved.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define ILBST_TIMESTAMP_HEADER 0x01 /* a timestamp w. every header */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define ILBST_DELTA_INTERVAL 0x02 /* delta over specified interval */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define ILBST_ABS_NUMBERS 0x04 /* print absolute numbers, no d's */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define ILBST_VERBOSE 0x10 /* verbose error info */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define ILBST_OLD_VALUES 0x20 /* for internal processing */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misratypedef struct {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"num_servers", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"bytes_not_processed", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"pkt_not_processed", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"bytes_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"pkt_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"nomem_bytes_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"nomem_pkt_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"noport_bytes_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"noport_pkt_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"icmp_echo_processed", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"icmp_dropped", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"icmp_too_big_processed", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"icmp_too_big_dropped", 0}
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra/* indices into array above, to avoid searching */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"bytes_processed", 0},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"pkt_processed", 0}
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra/* indices into array above, to avoid searching */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra/* values used for of_* commands as id */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra/* approx field widths */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic boolean_t of_rule_stats(ofmt_arg_t *, char *, uint_t);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic boolean_t of_server_stats(ofmt_arg_t *, char *, uint_t);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic boolean_t of_itemize_stats(ofmt_arg_t *, char *, uint_t);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic boolean_t of_timestamp(ofmt_arg_t *, char *, uint_t);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"RULENAME", ILB_NAMESZ, ILBST_ITEMIZE_RNAME, of_itemize_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"SERVERNAME", ILB_NAMESZ, ILBST_ITEMIZE_SNAME, of_itemize_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"PKT_P", ILBST_PKTCTR_W, ILBST_PKT_P, of_itemize_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"BYTES_P", ILBST_BYTECTR_W, ILBST_BYTES_P, of_itemize_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"TIME", ILBST_TIME_W, ILBST_TIMESTAMP, of_timestamp},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"PKT_P", ILBST_PKTCTR_W, ILBST_PKT_P, of_server_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"BYTES_P", ILBST_BYTECTR_W, ILBST_BYTES_P, of_server_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"PKT_U", ILBST_PKTCTR_W, ILBST_PKT_U, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"BYTES_U", ILBST_BYTECTR_W, ILBST_BYTES_U, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"PKT_D", ILBST_PKTCTR_W, ILBST_PKT_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"BYTES_D", ILBST_BYTECTR_W, ILBST_BYTES_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"ICMP_P", ILBST_PKTCTR_W, ILBST_ICMP_P, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"ICMP_D", ILBST_PKTCTR_W, ILBST_ICMP_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"ICMP2BIG_P", 11, ILBST_ICMP2BIG_P, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"ICMP2BIG_D", 11, ILBST_ICMP2BIG_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"NOMEMP_D", ILBST_PKTCTR_W, ILBST_NOMEMP_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"NOPORTP_D", ILBST_PKTCTR_W, ILBST_NOPORTP_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"NOMEMB_D", ILBST_PKTCTR_W, ILBST_NOMEMB_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"NOPORTB_D", ILBST_PKTCTR_W, ILBST_NOPORTB_D, of_rule_stats},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra {"TIME", ILBST_TIME_W, ILBST_TIMESTAMP, of_timestamp},
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic char stat_stdhdrs[] = "PKT_P,BYTES_P,PKT_U,BYTES_U,PKT_D,BYTES_D";
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic char stat_stdv_hdrs[] = "PKT_P,BYTES_P,PKT_U,BYTES_U,PKT_D,BYTES_D,"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra "ICMP_P,ICMP_D,ICMP2BIG_P,ICMP2BIG_D,NOMEMP_D,NOPORTP_D";
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic char stat_itemize_rule_hdrs[] = "SERVERNAME,PKT_P,BYTES_P";
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrastatic char stat_itemize_server_hdrs[] = "RULENAME,PKT_P,BYTES_P";
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define RSTAT_SZ (sizeof (rulestats)/sizeof (rulestats[0]))
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra#define SSTAT_SZ (sizeof (servstats)/sizeof (servstats[0]))
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misratypedef struct {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra char isd_servername[KSTAT_STRLEN]; /* serverID */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra hrtime_t isd_crtime; /* save for comparison purpose */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * this data structure stores statistics for a rule - both an old set
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * and a current/new set. we use pointers to the actual stores and switch
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * the pointers for every round. old_is_old in ilbst_arg_t indicates
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * which pointer points to the "old" data struct (ie, if true, _o pointer
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * points to old)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misratypedef struct {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra hrtime_t ird_crtime; /* save for comparison */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra hrtime_t ird_crtime_o; /* save for comparison */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * overall "container" for information pertaining to statistics, and
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * how to display them.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misratypedef struct {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* fields representing user input */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* "internal" fields for data and data presentation */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra int ilbst_rcount_prev; /* prev (different) count */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra int ilbst_rlist_sz; /* number of alloc'ed rules */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra int ilbst_rule_index; /* for itemizes display */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra/* ARGSUSED */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misraof_timestamp(ofmt_arg_t *of_arg, char *buf, uint_t bufsize)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) strftime(buf, bufsize, "%F:%H.%M.%S", now_tm);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_sum_per_rule_processed(ilbst_rule_desc_t *rp, uint64_t *resp, int index,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* if we do abs. numbers, we never look at the _o fields */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra assert((old && (flags & ILBST_ABS_NUMBERS)) == B_FALSE);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* we only check for validity under certain conditions */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra check_valid = !(old || (flags & ILBST_ABS_NUMBERS));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (check_valid && rp->ird_num_servers != rp->ird_num_servers_o)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra num_servers = old ? rp->ird_num_servers_o : rp->ird_num_servers;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < num_servers; i++) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * if creation times don't match, comparison is wrong; if
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * if we already know something is invalid, we don't
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * need to compare again.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * save the result even though it may be imprecise - let the
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * caller decide what to do
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misratypedef boolean_t (*sumfunc_t)(ilbst_rule_desc_t *, uint64_t *, int);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_sum_per_rule_pkt_p(ilbst_rule_desc_t *rp, uint64_t *resp, int flags)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra return (i_sum_per_rule_processed(rp, resp, SRVST_PKT_P, flags));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_sum_per_rule_bytes_p(ilbst_rule_desc_t *rp, uint64_t *resp, int flags)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra return (i_sum_per_rule_processed(rp, resp, SRVST_BYTES_P, flags));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misraof_server_stats(ofmt_arg_t *of_arg, char *buf, uint_t bufsize)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbst_arg_t *sta = (ilbst_arg_t *)of_arg->ofmt_cbarg;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_PKT_P: sumfunc = i_sum_per_rule_pkt_p;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_BYTES_P: sumfunc = i_sum_per_rule_bytes_p;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra valid = sumfunc(&sta->ilbst_rlist[i], &val, sta->ilbst_flags);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & ILBST_ABS_NUMBERS) != 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * normally, we print "change per second", which we calculate
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * here. otherwise, we print "change over interval"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & (ILBST_DELTA_INTERVAL|ILBST_ABS_NUMBERS)) == 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) snprintf(buf, bufsize, "%llu", count);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * this function is called when user wants itemized stats of every
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * server for a named rule, or vice vera.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * i_do_print sets sta->rule_index and the proper ird_srv_ind so
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * we don't have to differentiate between these two cases here.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misraof_itemize_stats(ofmt_arg_t *of_arg, char *buf, uint_t bufsize)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbst_arg_t *sta = (ilbst_arg_t *)of_arg->ofmt_cbarg;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra int srv_ind = sta->ilbst_rlist[rule_index].ird_srv_ind;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra srv = &sta->ilbst_rlist[rule_index].ird_srvlist[srv_ind];
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_BYTES_P: stat_ind = SRVST_BYTES_P;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) snprintf(buf, bufsize, "%s", srv->isd_servername);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra count = srv->isd_serverstats[stat_ind].is_value;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & ILBST_ABS_NUMBERS) != 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra osrv = &sta->ilbst_rlist[rule_index].ird_srvlist_o[srv_ind];
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra count -= osrv->isd_serverstats[stat_ind].is_value;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * normally, we print "change per second", which we calculate
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * here. otherwise, we print "change over interval" or absolute
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & (ILBST_DELTA_INTERVAL|ILBST_ABS_NUMBERS)) == 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) snprintf(buf, bufsize, "%llu", count);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misraof_rule_stats(ofmt_arg_t *of_arg, char *buf, uint_t bufsize)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbst_arg_t *sta = (ilbst_arg_t *)of_arg->ofmt_cbarg;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_ICMP2BIG_P: ind = RLSTA_ICMP2BIG_P;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_ICMP2BIG_D: ind = RLSTA_ICMP2BIG_D;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_NOPORTP_D: ind = RLSTA_NOPORTPKT_D;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_NOMEMB_D: ind = RLSTA_NOMEMBYTES_D;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ILBST_NOPORTB_D: ind = RLSTA_NOPORTBYTES_D;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra count += sta->ilbst_rlist[i].ird_rulestats[ind].is_value;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & ILBST_ABS_NUMBERS) != 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * the purist approach: if we can't say 100% that what we
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * calculate is correct, don't.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra count -= sta->ilbst_rlist[i].ird_rulestats_o[ind].is_value;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * normally, we print "change per second", which we calculate
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * here. otherwise, we print "change over interval"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & (ILBST_DELTA_INTERVAL|ILBST_ABS_NUMBERS)) == 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) snprintf(buf, bufsize, "%llu", count);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Get the number of kstat instances. Note that when rules are being
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * drained the number of kstats instances may be different than the
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * kstat counter num_rules (ilb:0:global:num_rules").
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Also there can be multiple instances of a rule in the following
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * A rule named rule A has been deleted but remains in kstats because
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * its undergoing connection draining. During this time, the user adds
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * a new rule with the same name(rule A). In this case, there would
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * be two kstats instances for rule A. Currently ilbadm's aggregate
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * results will include data from both instances of rule A. In,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * future we should have ilbadm stats only consider the latest instance
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * of the rule (ie only consider the the instance that corresponds
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * to the rule that was just added).
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra int num_instances = 0; /* nothing found, 0 rules */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (kp = kctl->kc_chain; kp != NULL; kp = kp->ks_next) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (strncmp("rulestat", kp->ks_class, 8) == 0 &&
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * since server stat's classname is made up of <rulename>-sstat,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * we walk the rule list to construct the comparison
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Return: pointer to rule whose name matches the class
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * NULL if no match
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misramatch_2_rnames(char *class, ilbst_rule_desc_t *rlist, int rcount)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < rcount; i++) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) snprintf(classname, sizeof (classname), "%s-sstat",
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (strncmp(classname, class, sizeof (classname)) == 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra return (&rlist[i]);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_stat_index(kstat_named_t *knp, ilbst_stat_t *stats, int count)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < count; i++) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (strcasecmp(stats[i].is_name, knp->name) == 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_copy_sstats(ilbst_srv_desc_t *sp, kstat_t *kp)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ind = i_stat_index(knp, servstats, SSTAT_SZ);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) strlcpy(sp->isd_serverstats[ind].is_name, knp->name,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra sp->isd_serverstats[ind].is_value = knp->value.ui64;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_get_server_descs(ilbst_arg_t *sta, kstat_ctl_t *kctl)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * find all "server" kstats, or the one specified in
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * sta->server
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (kp = kctl->kc_chain; kp != NULL; kp = kp->ks_next) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra strcasecmp(sta->ilbst_server, kp->ks_name) != 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra rp = match_2_rnames(kp->ks_class, rlist, rcount);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * This means that a server is added after we check last
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * time... Just make the array bigger.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((srvlist = realloc(rp->ird_srvlist, (i+1) *
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) strlcpy(rp->ird_srvlist[i].isd_servername, kp->ks_name,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < rcount; i++)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_copy_rstats(ilbst_rule_desc_t *rp, kstat_t *kp)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ind = i_stat_index(knp, rulestats, RSTAT_SZ);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) strlcpy(rp->ird_rulestats[ind].is_name, knp->name,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra rp->ird_rulestats[ind].is_value = knp->value.ui64;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_set_rlstats_ptr(ilbst_rule_desc_t *rp, boolean_t old_is_old)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * this function walks the array of rules and switches pointer to old
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * and new stats as well as serverlists.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_swap_rl_pointers(ilbst_arg_t *sta, int rcount)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < rcount; i++) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* swap srvlist pointers */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra rlist[i].ird_srvlist = rlist[i].ird_srvlist_o;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * swap server counts - we need the old one to
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * save reallocation calls
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra rlist[i].ird_num_servers_o = rlist[i].ird_num_servers;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* preserve creation time */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra i_set_rlstats_ptr(&rlist[i], sta->ilbst_old_is_old);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < rcount; i++) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra rlist[i].ird_rulestats = rlist[i].ird_rstats;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra rlist[i].ird_rulestats_o = rlist[i].ird_rstats_o;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * this function searches for kstats describing individual rules and
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * saves name, # of servers, and the kstat_t * describing them (this is
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * for sta->rulename == NULL);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * if sta->rulename != NULL, it names the rule we're looking for
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * and this function will fill in the other data (like the all_rules case)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * Returns: ILBADM_ENORULE named rule not found
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * ILBADM_ENOMEM no mem. available
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misrai_get_rule_descs(ilbst_arg_t *sta, kstat_ctl_t *kctl)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * find all "rule" kstats, or the one specified in
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * sta->ilbst_rulename.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0, kp = kctl->kc_chain; i < rcount && kp != NULL;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (strncmp("rulestat", kp->ks_class, 8) != 0 ||
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("kstat_data_lookup() failed: %s"),
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (strcasecmp(kp->ks_name, sta->ilbst_rulename)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) strlcpy(rlist[i].ird_rulename, kp->ks_name,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* only alloc the space we need, set counter here ... */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* ... furthermore, only reallocate if necessary */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (num_servers != rlist[i].ird_num_servers) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* if we know we're done, return */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (sta->ilbst_rulename != NULL || i == rcount) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* non-itemized display can go right ahead */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & ILBST_ITEMIZE) == 0) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * rulename is given, list a line per server
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * here's how we do it:
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * the _ITEMIZE flag indicates to the print function (called
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * from ofmt_print()) to look at server [ird_srv_ind] only.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra for (i = 0; i < sta->ilbst_rlist->ird_num_servers; i++) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* list one line for every rule for a given server */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * if a rule doesn't contain a given server, there's no
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * need to print it. Luckily, we can check that
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * fairly easily
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (sta->ilbst_rlist[i].ird_srvlist[0].isd_servername[0] ==
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra boolean_t pseudo_abs = B_FALSE; /* for first pass */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("kstat_open() failed: %s"), strerror(errno));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra sta->ilbst_rcount = sta->ilbst_rcount_prev = rcount;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * in the first pass, we always print absolute numbers. We
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * need to remember whether we wanted abs. numbers for
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * other samples as well
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & ILBST_ABS_NUMBERS) == 0) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (sta->ilbst_count == -1 || --(sta->ilbst_count) > 0)
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * we only need to continue with most of the rest of this if
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * the kstat chain id has changed
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("kstat_chain_update() failed: %s"),
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * find out whether the number of rules has changed.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * if so, adjust rcount and _o; if number has increased,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * expand array to hold all rules.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * we only shrink if rlist_sz is larger than both rcount and
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * rcount_prev;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* realloc doesn't zero out memory */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * even if rlist_sz was > rcount, it's now
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * shrunk to rcount
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * we may need to shrink the allocated slots down to the
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * actually required number - we need to make sure we
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * don't delete old or new stats.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if (sta->ilbst_rlist_sz > MAX(sta->ilbst_rcount,
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra MAX(sta->ilbst_rcount, sta->ilbst_rcount_prev);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra sizeof (*sta->ilbst_rlist) * sta->ilbst_rlist_sz);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * move pointers around so what used to point to "old"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * stats now points to new, and vice versa
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * if we're printing absolute numbers, this rigmarole is
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * not necessary.
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((sta->ilbst_flags & ILBST_ABS_NUMBERS) == 0) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra sta->ilbst_old_is_old = !sta->ilbst_old_is_old;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra if ((rc != ILBADM_OK) && (rc != ILBADM_LIBERR))
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra * read ilb's kernel statistics and (periodically) display
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra/* ARGSUSED */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra boolean_t r_opt = B_FALSE, s_opt = B_FALSE, i_opt = B_FALSE;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra boolean_t o_opt = B_FALSE, p_opt = B_FALSE, t_opt = B_FALSE;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra boolean_t v_opt = B_FALSE, A_opt = B_FALSE, d_opt = B_FALSE;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra while ((c = getopt(argc, argv, ":tdAr:s:ivo:p")) != -1) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra switch ((char)c) {
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case 't': sta.ilbst_flags |= ILBST_TIMESTAMP_HEADER;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case 'd': sta.ilbst_flags |= ILBST_DELTA_INTERVAL;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case 'A': sta.ilbst_flags |= ILBST_ABS_NUMBERS;
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra case ':': ilbadm_err(gettext("missing option-argument"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* not reached */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* not reached */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("options -s and -r are mutually exclusive"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra " either -r or -s"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("option -i and -v are mutually"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra " exclusive"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* only use "std" headers if none are specified */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra else /* must be s_opt */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("option -p requires -o"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("option -o and -v are mutually"
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra " exclusive"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra " explicit field names"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra (void) snprintf(fnames, len, "%s,TIME", fieldnames);
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("options -d and -A are mutually exclusive"));
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra /* find and parse interval and count arguments if present */
dbed73cbda2229fd1aa6dc5743993cae7f0a7ee9Sangeeta Misra ilbadm_err(gettext("illegal interval spec %s"),