128fb27baSJustin T. Gibbs /* 228fb27baSJustin T. Gibbs * Copyright (c) 1997, 1998 Kenneth D. Merry. 328fb27baSJustin T. Gibbs * All rights reserved. 428fb27baSJustin T. Gibbs * 528fb27baSJustin T. Gibbs * Redistribution and use in source and binary forms, with or without 628fb27baSJustin T. Gibbs * modification, are permitted provided that the following conditions 728fb27baSJustin T. Gibbs * are met: 828fb27baSJustin T. Gibbs * 1. Redistributions of source code must retain the above copyright 928fb27baSJustin T. Gibbs * notice, this list of conditions and the following disclaimer. 1028fb27baSJustin T. Gibbs * 2. Redistributions in binary form must reproduce the above copyright 1128fb27baSJustin T. Gibbs * notice, this list of conditions and the following disclaimer in the 1228fb27baSJustin T. Gibbs * documentation and/or other materials provided with the distribution. 1328fb27baSJustin T. Gibbs * 3. The name of the author may not be used to endorse or promote products 1428fb27baSJustin T. Gibbs * derived from this software without specific prior written permission. 1528fb27baSJustin T. Gibbs * 1628fb27baSJustin T. Gibbs * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 1728fb27baSJustin T. Gibbs * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 1828fb27baSJustin T. Gibbs * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 1928fb27baSJustin T. Gibbs * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 2028fb27baSJustin T. Gibbs * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 2128fb27baSJustin T. Gibbs * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 2228fb27baSJustin T. Gibbs * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 2328fb27baSJustin T. Gibbs * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 2428fb27baSJustin T. Gibbs * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 2528fb27baSJustin T. Gibbs * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 2628fb27baSJustin T. Gibbs * SUCH DAMAGE. 2728fb27baSJustin T. Gibbs * 287f3dea24SPeter Wemm * $FreeBSD$ 2928fb27baSJustin T. Gibbs */ 3028fb27baSJustin T. Gibbs 3128fb27baSJustin T. Gibbs #include <sys/types.h> 3228fb27baSJustin T. Gibbs #include <sys/sysctl.h> 3328fb27baSJustin T. Gibbs #include <sys/errno.h> 3428fb27baSJustin T. Gibbs #include <sys/dkstat.h> 35c4a5ef6eSThomas Moestl #include <sys/queue.h> 3628fb27baSJustin T. Gibbs 37eded794aSKenneth D. Merry #include <ctype.h> 3828fb27baSJustin T. Gibbs #include <err.h> 39c4a5ef6eSThomas Moestl #include <fcntl.h> 40c4a5ef6eSThomas Moestl #include <limits.h> 4128fb27baSJustin T. Gibbs #include <stdio.h> 4228fb27baSJustin T. Gibbs #include <stdlib.h> 4328fb27baSJustin T. Gibbs #include <string.h> 44c4a5ef6eSThomas Moestl #include <stdarg.h> 45c4a5ef6eSThomas Moestl #include <kvm.h> 4628fb27baSJustin T. Gibbs 4728fb27baSJustin T. Gibbs #include "devstat.h" 4828fb27baSJustin T. Gibbs 49c4a5ef6eSThomas Moestl typedef enum { 50c4a5ef6eSThomas Moestl DEVSTAT_ARG_NOTYPE, 51c4a5ef6eSThomas Moestl DEVSTAT_ARG_UINT64, 52884539f7SKenneth D. Merry DEVSTAT_ARG_LD, 53884539f7SKenneth D. Merry DEVSTAT_ARG_SKIP 54c4a5ef6eSThomas Moestl } devstat_arg_type; 55c4a5ef6eSThomas Moestl 5628fb27baSJustin T. Gibbs char devstat_errbuf[DEVSTAT_ERRBUF_SIZE]; 5728fb27baSJustin T. Gibbs 5828fb27baSJustin T. Gibbs /* 5928fb27baSJustin T. Gibbs * Table to match descriptive strings with device types. These are in 6028fb27baSJustin T. Gibbs * order from most common to least common to speed search time. 6128fb27baSJustin T. Gibbs */ 6228fb27baSJustin T. Gibbs struct devstat_match_table match_table[] = { 6328fb27baSJustin T. Gibbs {"da", DEVSTAT_TYPE_DIRECT, DEVSTAT_MATCH_TYPE}, 6428fb27baSJustin T. Gibbs {"cd", DEVSTAT_TYPE_CDROM, DEVSTAT_MATCH_TYPE}, 6528fb27baSJustin T. Gibbs {"scsi", DEVSTAT_TYPE_IF_SCSI, DEVSTAT_MATCH_IF}, 6628fb27baSJustin T. Gibbs {"ide", DEVSTAT_TYPE_IF_IDE, DEVSTAT_MATCH_IF}, 6728fb27baSJustin T. Gibbs {"other", DEVSTAT_TYPE_IF_OTHER, DEVSTAT_MATCH_IF}, 6828fb27baSJustin T. Gibbs {"worm", DEVSTAT_TYPE_WORM, DEVSTAT_MATCH_TYPE}, 6928fb27baSJustin T. Gibbs {"sa", DEVSTAT_TYPE_SEQUENTIAL,DEVSTAT_MATCH_TYPE}, 7028fb27baSJustin T. Gibbs {"pass", DEVSTAT_TYPE_PASS, DEVSTAT_MATCH_PASS}, 7128fb27baSJustin T. Gibbs {"optical", DEVSTAT_TYPE_OPTICAL, DEVSTAT_MATCH_TYPE}, 7228fb27baSJustin T. Gibbs {"array", DEVSTAT_TYPE_STORARRAY, DEVSTAT_MATCH_TYPE}, 7328fb27baSJustin T. Gibbs {"changer", DEVSTAT_TYPE_CHANGER, DEVSTAT_MATCH_TYPE}, 7428fb27baSJustin T. Gibbs {"scanner", DEVSTAT_TYPE_SCANNER, DEVSTAT_MATCH_TYPE}, 7528fb27baSJustin T. Gibbs {"printer", DEVSTAT_TYPE_PRINTER, DEVSTAT_MATCH_TYPE}, 7628fb27baSJustin T. Gibbs {"floppy", DEVSTAT_TYPE_FLOPPY, DEVSTAT_MATCH_TYPE}, 7728fb27baSJustin T. Gibbs {"proc", DEVSTAT_TYPE_PROCESSOR, DEVSTAT_MATCH_TYPE}, 7828fb27baSJustin T. Gibbs {"comm", DEVSTAT_TYPE_COMM, DEVSTAT_MATCH_TYPE}, 7928fb27baSJustin T. Gibbs {"enclosure", DEVSTAT_TYPE_ENCLOSURE, DEVSTAT_MATCH_TYPE}, 8028fb27baSJustin T. Gibbs {NULL, 0, 0} 8128fb27baSJustin T. Gibbs }; 8228fb27baSJustin T. Gibbs 83c4a5ef6eSThomas Moestl struct devstat_args { 84c4a5ef6eSThomas Moestl devstat_metric metric; 85c4a5ef6eSThomas Moestl devstat_arg_type argtype; 86c4a5ef6eSThomas Moestl } devstat_arg_list[] = { 87c4a5ef6eSThomas Moestl { DSM_NONE, DEVSTAT_ARG_NOTYPE }, 88c4a5ef6eSThomas Moestl { DSM_TOTAL_BYTES, DEVSTAT_ARG_UINT64 }, 89c4a5ef6eSThomas Moestl { DSM_TOTAL_BYTES_READ, DEVSTAT_ARG_UINT64 }, 90c4a5ef6eSThomas Moestl { DSM_TOTAL_BYTES_WRITE, DEVSTAT_ARG_UINT64 }, 91c4a5ef6eSThomas Moestl { DSM_TOTAL_TRANSFERS, DEVSTAT_ARG_UINT64 }, 92c4a5ef6eSThomas Moestl { DSM_TOTAL_TRANSFERS_READ, DEVSTAT_ARG_UINT64 }, 93c4a5ef6eSThomas Moestl { DSM_TOTAL_TRANSFERS_WRITE, DEVSTAT_ARG_UINT64 }, 94c4a5ef6eSThomas Moestl { DSM_TOTAL_TRANSFERS_OTHER, DEVSTAT_ARG_UINT64 }, 95c4a5ef6eSThomas Moestl { DSM_TOTAL_BLOCKS, DEVSTAT_ARG_UINT64 }, 96c4a5ef6eSThomas Moestl { DSM_TOTAL_BLOCKS_READ, DEVSTAT_ARG_UINT64 }, 97c4a5ef6eSThomas Moestl { DSM_TOTAL_BLOCKS_WRITE, DEVSTAT_ARG_UINT64 }, 98c4a5ef6eSThomas Moestl { DSM_KB_PER_TRANSFER, DEVSTAT_ARG_LD }, 99c4a5ef6eSThomas Moestl { DSM_KB_PER_TRANSFER_READ, DEVSTAT_ARG_LD }, 100c4a5ef6eSThomas Moestl { DSM_KB_PER_TRANSFER_WRITE, DEVSTAT_ARG_LD }, 101c4a5ef6eSThomas Moestl { DSM_TRANSFERS_PER_SECOND, DEVSTAT_ARG_LD }, 102c4a5ef6eSThomas Moestl { DSM_TRANSFERS_PER_SECOND_READ, DEVSTAT_ARG_LD }, 103c4a5ef6eSThomas Moestl { DSM_TRANSFERS_PER_SECOND_WRITE, DEVSTAT_ARG_LD }, 104c4a5ef6eSThomas Moestl { DSM_TRANSFERS_PER_SECOND_OTHER, DEVSTAT_ARG_LD }, 105c4a5ef6eSThomas Moestl { DSM_MB_PER_SECOND, DEVSTAT_ARG_LD }, 106c4a5ef6eSThomas Moestl { DSM_MB_PER_SECOND_READ, DEVSTAT_ARG_LD }, 107c4a5ef6eSThomas Moestl { DSM_MB_PER_SECOND_WRITE, DEVSTAT_ARG_LD }, 108c4a5ef6eSThomas Moestl { DSM_BLOCKS_PER_SECOND, DEVSTAT_ARG_LD }, 109c4a5ef6eSThomas Moestl { DSM_BLOCKS_PER_SECOND_READ, DEVSTAT_ARG_LD }, 110c4a5ef6eSThomas Moestl { DSM_BLOCKS_PER_SECOND_WRITE, DEVSTAT_ARG_LD }, 111c4a5ef6eSThomas Moestl { DSM_MS_PER_TRANSACTION, DEVSTAT_ARG_LD }, 112c4a5ef6eSThomas Moestl { DSM_MS_PER_TRANSACTION_READ, DEVSTAT_ARG_LD }, 113884539f7SKenneth D. Merry { DSM_MS_PER_TRANSACTION_WRITE, DEVSTAT_ARG_LD }, 114884539f7SKenneth D. Merry { DSM_SKIP, DEVSTAT_ARG_SKIP } 115c4a5ef6eSThomas Moestl }; 116c4a5ef6eSThomas Moestl 117c4a5ef6eSThomas Moestl static char *namelist[] = { 118c4a5ef6eSThomas Moestl #define X_NUMDEVS 0 119c4a5ef6eSThomas Moestl "_devstat_num_devs", 120c4a5ef6eSThomas Moestl #define X_GENERATION 1 121c4a5ef6eSThomas Moestl "_devstat_generation", 122c4a5ef6eSThomas Moestl #define X_VERSION 2 123c4a5ef6eSThomas Moestl "_devstat_version", 124c4a5ef6eSThomas Moestl #define X_DEVICE_STATQ 3 125c4a5ef6eSThomas Moestl "_device_statq", 126c4a5ef6eSThomas Moestl #define X_END 4 127c4a5ef6eSThomas Moestl }; 128c4a5ef6eSThomas Moestl 12928fb27baSJustin T. Gibbs /* 13028fb27baSJustin T. Gibbs * Local function declarations. 13128fb27baSJustin T. Gibbs */ 13228fb27baSJustin T. Gibbs static int compare_select(const void *arg1, const void *arg2); 133c4a5ef6eSThomas Moestl static int readkmem(kvm_t *kd, unsigned long addr, void *buf, size_t nbytes); 134c4a5ef6eSThomas Moestl static int readkmem_nl(kvm_t *kd, char *name, void *buf, size_t nbytes); 135c4a5ef6eSThomas Moestl static char *get_devstat_kvm(kvm_t *kd); 136c4a5ef6eSThomas Moestl 137c4a5ef6eSThomas Moestl #define KREADNL(kd, var, val) \ 138c4a5ef6eSThomas Moestl readkmem_nl(kd, namelist[var], &val, sizeof(val)) 13928fb27baSJustin T. Gibbs 14028fb27baSJustin T. Gibbs int 141c4a5ef6eSThomas Moestl devstat_getnumdevs(kvm_t *kd) 14228fb27baSJustin T. Gibbs { 14328fb27baSJustin T. Gibbs size_t numdevsize; 14428fb27baSJustin T. Gibbs int numdevs; 145c4a5ef6eSThomas Moestl char *func_name = "devstat_getnumdevs"; 14628fb27baSJustin T. Gibbs 14728fb27baSJustin T. Gibbs numdevsize = sizeof(int); 14828fb27baSJustin T. Gibbs 14928fb27baSJustin T. Gibbs /* 15028fb27baSJustin T. Gibbs * Find out how many devices we have in the system. 15128fb27baSJustin T. Gibbs */ 152c4a5ef6eSThomas Moestl if (kd == NULL) { 15328fb27baSJustin T. Gibbs if (sysctlbyname("kern.devstat.numdevs", &numdevs, 15428fb27baSJustin T. Gibbs &numdevsize, NULL, 0) == -1) { 155c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 156c4a5ef6eSThomas Moestl "%s: error getting number of devices\n" 157c4a5ef6eSThomas Moestl "%s: %s", func_name, func_name, 158c4a5ef6eSThomas Moestl strerror(errno)); 15928fb27baSJustin T. Gibbs return(-1); 16028fb27baSJustin T. Gibbs } else 16128fb27baSJustin T. Gibbs return(numdevs); 162c4a5ef6eSThomas Moestl } else { 163c4a5ef6eSThomas Moestl if (KREADNL(kd, X_NUMDEVS, numdevs) == -1) 164c4a5ef6eSThomas Moestl return(-1); 165c4a5ef6eSThomas Moestl else 166c4a5ef6eSThomas Moestl return(numdevs); 167c4a5ef6eSThomas Moestl } 16828fb27baSJustin T. Gibbs } 16928fb27baSJustin T. Gibbs 17028fb27baSJustin T. Gibbs /* 17128fb27baSJustin T. Gibbs * This is an easy way to get the generation number, but the generation is 17228fb27baSJustin T. Gibbs * supplied in a more atmoic manner by the kern.devstat.all sysctl. 17328fb27baSJustin T. Gibbs * Because this generation sysctl is separate from the statistics sysctl, 17428fb27baSJustin T. Gibbs * the device list and the generation could change between the time that 17528fb27baSJustin T. Gibbs * this function is called and the device list is retreived. 17628fb27baSJustin T. Gibbs */ 177bcc6a3daSKenneth D. Merry long 178c4a5ef6eSThomas Moestl devstat_getgeneration(kvm_t *kd) 17928fb27baSJustin T. Gibbs { 18028fb27baSJustin T. Gibbs size_t gensize; 181bcc6a3daSKenneth D. Merry long generation; 182c4a5ef6eSThomas Moestl char *func_name = "devstat_getgeneration"; 18328fb27baSJustin T. Gibbs 184bcc6a3daSKenneth D. Merry gensize = sizeof(long); 18528fb27baSJustin T. Gibbs 18628fb27baSJustin T. Gibbs /* 18728fb27baSJustin T. Gibbs * Get the current generation number. 18828fb27baSJustin T. Gibbs */ 189c4a5ef6eSThomas Moestl if (kd == NULL) { 19028fb27baSJustin T. Gibbs if (sysctlbyname("kern.devstat.generation", &generation, 19128fb27baSJustin T. Gibbs &gensize, NULL, 0) == -1) { 192c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 193c4a5ef6eSThomas Moestl "%s: error getting devstat generation\n%s: %s", 194c4a5ef6eSThomas Moestl func_name, func_name, strerror(errno)); 19528fb27baSJustin T. Gibbs return(-1); 19628fb27baSJustin T. Gibbs } else 19728fb27baSJustin T. Gibbs return(generation); 198c4a5ef6eSThomas Moestl } else { 199c4a5ef6eSThomas Moestl if (KREADNL(kd, X_GENERATION, generation) == -1) 200c4a5ef6eSThomas Moestl return(-1); 201c4a5ef6eSThomas Moestl else 202c4a5ef6eSThomas Moestl return(generation); 203c4a5ef6eSThomas Moestl } 20428fb27baSJustin T. Gibbs } 20528fb27baSJustin T. Gibbs 20628fb27baSJustin T. Gibbs /* 20728fb27baSJustin T. Gibbs * Get the current devstat version. The return value of this function 20828fb27baSJustin T. Gibbs * should be compared with DEVSTAT_VERSION, which is defined in 20928fb27baSJustin T. Gibbs * sys/devicestat.h. This will enable userland programs to determine 21028fb27baSJustin T. Gibbs * whether they are out of sync with the kernel. 21128fb27baSJustin T. Gibbs */ 21228fb27baSJustin T. Gibbs int 213c4a5ef6eSThomas Moestl devstat_getversion(kvm_t *kd) 21428fb27baSJustin T. Gibbs { 21528fb27baSJustin T. Gibbs size_t versize; 21628fb27baSJustin T. Gibbs int version; 217c4a5ef6eSThomas Moestl char *func_name = "devstat_getversion"; 21828fb27baSJustin T. Gibbs 21928fb27baSJustin T. Gibbs versize = sizeof(int); 22028fb27baSJustin T. Gibbs 22128fb27baSJustin T. Gibbs /* 22228fb27baSJustin T. Gibbs * Get the current devstat version. 22328fb27baSJustin T. Gibbs */ 224c4a5ef6eSThomas Moestl if (kd == NULL) { 22528fb27baSJustin T. Gibbs if (sysctlbyname("kern.devstat.version", &version, &versize, 22628fb27baSJustin T. Gibbs NULL, 0) == -1) { 227c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 228c4a5ef6eSThomas Moestl "%s: error getting devstat version\n%s: %s", 229c4a5ef6eSThomas Moestl func_name, func_name, strerror(errno)); 23028fb27baSJustin T. Gibbs return(-1); 23128fb27baSJustin T. Gibbs } else 23228fb27baSJustin T. Gibbs return(version); 233c4a5ef6eSThomas Moestl } else { 234c4a5ef6eSThomas Moestl if (KREADNL(kd, X_VERSION, version) == -1) 235c4a5ef6eSThomas Moestl return(-1); 236c4a5ef6eSThomas Moestl else 237c4a5ef6eSThomas Moestl return(version); 238c4a5ef6eSThomas Moestl } 23928fb27baSJustin T. Gibbs } 24028fb27baSJustin T. Gibbs 24128fb27baSJustin T. Gibbs /* 24228fb27baSJustin T. Gibbs * Check the devstat version we know about against the devstat version the 24328fb27baSJustin T. Gibbs * kernel knows about. If they don't match, print an error into the 24428fb27baSJustin T. Gibbs * devstat error buffer, and return -1. If they match, return 0. 24528fb27baSJustin T. Gibbs */ 24628fb27baSJustin T. Gibbs int 247c4a5ef6eSThomas Moestl devstat_checkversion(kvm_t *kd) 24828fb27baSJustin T. Gibbs { 249c4a5ef6eSThomas Moestl char *func_name = "devstat_checkversion"; 2506d3e1426SBrian Somers int buflen, res, retval = 0, version; 25128fb27baSJustin T. Gibbs 252c4a5ef6eSThomas Moestl version = devstat_getversion(kd); 253eded794aSKenneth D. Merry 254eded794aSKenneth D. Merry if (version != DEVSTAT_VERSION) { 255eded794aSKenneth D. Merry /* 2566d3e1426SBrian Somers * If getversion() returns an error (i.e. -1), then it 257eded794aSKenneth D. Merry * has printed an error message in the buffer. Therefore, 258eded794aSKenneth D. Merry * we need to add a \n to the end of that message before we 259eded794aSKenneth D. Merry * print our own message in the buffer. 260eded794aSKenneth D. Merry */ 2616d3e1426SBrian Somers if (version == -1) 262eded794aSKenneth D. Merry buflen = strlen(devstat_errbuf); 2636d3e1426SBrian Somers else 2646d3e1426SBrian Somers buflen = 0; 265eded794aSKenneth D. Merry 2666d3e1426SBrian Somers res = snprintf(devstat_errbuf + buflen, 2676d3e1426SBrian Somers DEVSTAT_ERRBUF_SIZE - buflen, 2686d3e1426SBrian Somers "%s%s: userland devstat version %d is not " 2694fb9d384SKenneth D. Merry "the same as the kernel\n%s: devstat " 2704fb9d384SKenneth D. Merry "version %d\n", version == -1 ? "\n" : "", 2714fb9d384SKenneth D. Merry func_name, DEVSTAT_VERSION, func_name, version); 27228fb27baSJustin T. Gibbs 2736d3e1426SBrian Somers if (res < 0) 2746d3e1426SBrian Somers devstat_errbuf[buflen] = '\0'; 275eded794aSKenneth D. Merry 2766d3e1426SBrian Somers buflen = strlen(devstat_errbuf); 277eded794aSKenneth D. Merry if (version < DEVSTAT_VERSION) 2786d3e1426SBrian Somers res = snprintf(devstat_errbuf + buflen, 2796d3e1426SBrian Somers DEVSTAT_ERRBUF_SIZE - buflen, 2804fb9d384SKenneth D. Merry "%s: libdevstat newer than kernel\n", 2814fb9d384SKenneth D. Merry func_name); 28228fb27baSJustin T. Gibbs else 2836d3e1426SBrian Somers res = snprintf(devstat_errbuf + buflen, 2846d3e1426SBrian Somers DEVSTAT_ERRBUF_SIZE - buflen, 2854fb9d384SKenneth D. Merry "%s: kernel newer than libdevstat\n", 2864fb9d384SKenneth D. Merry func_name); 28728fb27baSJustin T. Gibbs 2886d3e1426SBrian Somers if (res < 0) 2896d3e1426SBrian Somers devstat_errbuf[buflen] = '\0'; 29028fb27baSJustin T. Gibbs 29128fb27baSJustin T. Gibbs retval = -1; 29228fb27baSJustin T. Gibbs } 29328fb27baSJustin T. Gibbs 29428fb27baSJustin T. Gibbs return(retval); 29528fb27baSJustin T. Gibbs } 29628fb27baSJustin T. Gibbs 29728fb27baSJustin T. Gibbs /* 29828fb27baSJustin T. Gibbs * Get the current list of devices and statistics, and the current 29928fb27baSJustin T. Gibbs * generation number. 30028fb27baSJustin T. Gibbs * 30128fb27baSJustin T. Gibbs * Return values: 30228fb27baSJustin T. Gibbs * -1 -- error 30328fb27baSJustin T. Gibbs * 0 -- device list is unchanged 30428fb27baSJustin T. Gibbs * 1 -- device list has changed 30528fb27baSJustin T. Gibbs */ 30628fb27baSJustin T. Gibbs int 307c4a5ef6eSThomas Moestl devstat_getdevs(kvm_t *kd, struct statinfo *stats) 30828fb27baSJustin T. Gibbs { 30928fb27baSJustin T. Gibbs int error; 31028fb27baSJustin T. Gibbs size_t dssize; 311bcc6a3daSKenneth D. Merry int oldnumdevs; 312bcc6a3daSKenneth D. Merry long oldgeneration; 31328fb27baSJustin T. Gibbs int retval = 0; 31428fb27baSJustin T. Gibbs struct devinfo *dinfo; 315c4a5ef6eSThomas Moestl char *func_name = "devstat_getdevs"; 31628fb27baSJustin T. Gibbs 31728fb27baSJustin T. Gibbs dinfo = stats->dinfo; 31828fb27baSJustin T. Gibbs 31928fb27baSJustin T. Gibbs if (dinfo == NULL) { 320c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 321c4a5ef6eSThomas Moestl "%s: stats->dinfo was NULL", func_name); 32228fb27baSJustin T. Gibbs return(-1); 32328fb27baSJustin T. Gibbs } 32428fb27baSJustin T. Gibbs 32528fb27baSJustin T. Gibbs oldnumdevs = dinfo->numdevs; 32628fb27baSJustin T. Gibbs oldgeneration = dinfo->generation; 32728fb27baSJustin T. Gibbs 328c4a5ef6eSThomas Moestl /* Get the current time when we get the stats */ 329c4a5ef6eSThomas Moestl gettimeofday(&stats->busy_time, NULL); 330c4a5ef6eSThomas Moestl 331c4a5ef6eSThomas Moestl if (kd == NULL) { 332c4a5ef6eSThomas Moestl /* If this is our first time through, mem_ptr will be null. */ 33328fb27baSJustin T. Gibbs if (dinfo->mem_ptr == NULL) { 33428fb27baSJustin T. Gibbs /* 33528fb27baSJustin T. Gibbs * Get the number of devices. If it's negative, it's an 33628fb27baSJustin T. Gibbs * error. Don't bother setting the error string, since 33728fb27baSJustin T. Gibbs * getnumdevs() has already done that for us. 33828fb27baSJustin T. Gibbs */ 33928fb27baSJustin T. Gibbs if ((dinfo->numdevs = getnumdevs()) < 0) 34028fb27baSJustin T. Gibbs return(-1); 34128fb27baSJustin T. Gibbs 34228fb27baSJustin T. Gibbs /* 343c4a5ef6eSThomas Moestl * The kern.devstat.all sysctl returns the current 344c4a5ef6eSThomas Moestl * generation number, as well as all the devices. 345c4a5ef6eSThomas Moestl * So we need four bytes more. 34628fb27baSJustin T. Gibbs */ 347c4a5ef6eSThomas Moestl dssize = (dinfo->numdevs * sizeof(struct devstat)) + 348c4a5ef6eSThomas Moestl sizeof(long); 34928fb27baSJustin T. Gibbs dinfo->mem_ptr = (u_int8_t *)malloc(dssize); 35028fb27baSJustin T. Gibbs } else 351c4a5ef6eSThomas Moestl dssize = (dinfo->numdevs * sizeof(struct devstat)) + 352c4a5ef6eSThomas Moestl sizeof(long); 35328fb27baSJustin T. Gibbs 35428fb27baSJustin T. Gibbs /* 35528fb27baSJustin T. Gibbs * Request all of the devices. We only really allow for one 356c4a5ef6eSThomas Moestl * ENOMEM failure. It would, of course, be possible to just go 357c4a5ef6eSThomas Moestl * in a loop and keep reallocing the device structure until we 358c4a5ef6eSThomas Moestl * don't get ENOMEM back. I'm not sure it's worth it, though. 359c4a5ef6eSThomas Moestl * If devices are being added to the system that quickly, maybe 360c4a5ef6eSThomas Moestl * the user can just wait until all devices are added. 36128fb27baSJustin T. Gibbs */ 36228fb27baSJustin T. Gibbs if ((error = sysctlbyname("kern.devstat.all", dinfo->mem_ptr, 36328fb27baSJustin T. Gibbs &dssize, NULL, 0)) == -1) { 36428fb27baSJustin T. Gibbs /* 36528fb27baSJustin T. Gibbs * If we get ENOMEM back, that means that there are 36628fb27baSJustin T. Gibbs * more devices now, so we need to allocate more 36728fb27baSJustin T. Gibbs * space for the device array. 36828fb27baSJustin T. Gibbs */ 36928fb27baSJustin T. Gibbs if (errno == ENOMEM) { 37028fb27baSJustin T. Gibbs /* 371c4a5ef6eSThomas Moestl * No need to set the error string here, 372c4a5ef6eSThomas Moestl * getnumdevs() will do that if it fails. 37328fb27baSJustin T. Gibbs */ 37428fb27baSJustin T. Gibbs if ((dinfo->numdevs = getnumdevs()) < 0) 37528fb27baSJustin T. Gibbs return(-1); 37628fb27baSJustin T. Gibbs 377c4a5ef6eSThomas Moestl dssize = (dinfo->numdevs * 378c4a5ef6eSThomas Moestl sizeof(struct devstat)) + sizeof(long); 379c4a5ef6eSThomas Moestl dinfo->mem_ptr = (u_int8_t *) 380c4a5ef6eSThomas Moestl realloc(dinfo->mem_ptr, dssize); 38128fb27baSJustin T. Gibbs if ((error = sysctlbyname("kern.devstat.all", 38228fb27baSJustin T. Gibbs dinfo->mem_ptr, &dssize, NULL, 0)) == -1) { 383c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, 384c4a5ef6eSThomas Moestl sizeof(devstat_errbuf), 385c4a5ef6eSThomas Moestl "%s: error getting device " 386c4a5ef6eSThomas Moestl "stats\n%s: %s", func_name, 387c4a5ef6eSThomas Moestl func_name, strerror(errno)); 38828fb27baSJustin T. Gibbs return(-1); 38928fb27baSJustin T. Gibbs } 39028fb27baSJustin T. Gibbs } else { 391c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 39228fb27baSJustin T. Gibbs "%s: error getting device stats\n" 39328fb27baSJustin T. Gibbs "%s: %s", func_name, func_name, 39428fb27baSJustin T. Gibbs strerror(errno)); 39528fb27baSJustin T. Gibbs return(-1); 39628fb27baSJustin T. Gibbs } 39728fb27baSJustin T. Gibbs } 39828fb27baSJustin T. Gibbs 399c4a5ef6eSThomas Moestl } else { 400c4a5ef6eSThomas Moestl /* 401c4a5ef6eSThomas Moestl * This is of course non-atomic, but since we are working 402c4a5ef6eSThomas Moestl * on a core dump, the generation is unlikely to change 403c4a5ef6eSThomas Moestl */ 404c4a5ef6eSThomas Moestl if ((dinfo->numdevs = getnumdevs()) == -1) 405c4a5ef6eSThomas Moestl return(-1); 406c4a5ef6eSThomas Moestl if ((dinfo->mem_ptr = get_devstat_kvm(kd)) == NULL) 407c4a5ef6eSThomas Moestl return(-1); 408c4a5ef6eSThomas Moestl } 40928fb27baSJustin T. Gibbs /* 41028fb27baSJustin T. Gibbs * The sysctl spits out the generation as the first four bytes, 41128fb27baSJustin T. Gibbs * then all of the device statistics structures. 41228fb27baSJustin T. Gibbs */ 413bcc6a3daSKenneth D. Merry dinfo->generation = *(long *)dinfo->mem_ptr; 41428fb27baSJustin T. Gibbs 41528fb27baSJustin T. Gibbs /* 41628fb27baSJustin T. Gibbs * If the generation has changed, and if the current number of 41728fb27baSJustin T. Gibbs * devices is not the same as the number of devices recorded in the 41828fb27baSJustin T. Gibbs * devinfo structure, it is likely that the device list has shrunk. 41928fb27baSJustin T. Gibbs * The reason that it is likely that the device list has shrunk in 42028fb27baSJustin T. Gibbs * this case is that if the device list has grown, the sysctl above 42128fb27baSJustin T. Gibbs * will return an ENOMEM error, and we will reset the number of 42228fb27baSJustin T. Gibbs * devices and reallocate the device array. If the second sysctl 42328fb27baSJustin T. Gibbs * fails, we will return an error and therefore never get to this 42428fb27baSJustin T. Gibbs * point. If the device list has shrunk, the sysctl will not 42528fb27baSJustin T. Gibbs * return an error since we have more space allocated than is 42628fb27baSJustin T. Gibbs * necessary. So, in the shrinkage case, we catch it here and 42728fb27baSJustin T. Gibbs * reallocate the array so that we don't use any more space than is 42828fb27baSJustin T. Gibbs * necessary. 42928fb27baSJustin T. Gibbs */ 43028fb27baSJustin T. Gibbs if (oldgeneration != dinfo->generation) { 43128fb27baSJustin T. Gibbs if (getnumdevs() != dinfo->numdevs) { 43228fb27baSJustin T. Gibbs if ((dinfo->numdevs = getnumdevs()) < 0) 43328fb27baSJustin T. Gibbs return(-1); 43428fb27baSJustin T. Gibbs dssize = (dinfo->numdevs * sizeof(struct devstat)) + 435bcc6a3daSKenneth D. Merry sizeof(long); 43628fb27baSJustin T. Gibbs dinfo->mem_ptr = (u_int8_t *)realloc(dinfo->mem_ptr, 43728fb27baSJustin T. Gibbs dssize); 43828fb27baSJustin T. Gibbs } 43928fb27baSJustin T. Gibbs retval = 1; 44028fb27baSJustin T. Gibbs } 44128fb27baSJustin T. Gibbs 442bcc6a3daSKenneth D. Merry dinfo->devices = (struct devstat *)(dinfo->mem_ptr + sizeof(long)); 44328fb27baSJustin T. Gibbs 44428fb27baSJustin T. Gibbs return(retval); 44528fb27baSJustin T. Gibbs } 44628fb27baSJustin T. Gibbs 44728fb27baSJustin T. Gibbs /* 44828fb27baSJustin T. Gibbs * selectdevs(): 44928fb27baSJustin T. Gibbs * 45028fb27baSJustin T. Gibbs * Devices are selected/deselected based upon the following criteria: 45128fb27baSJustin T. Gibbs * - devices specified by the user on the command line 45228fb27baSJustin T. Gibbs * - devices matching any device type expressions given on the command line 45328fb27baSJustin T. Gibbs * - devices with the highest I/O, if 'top' mode is enabled 45428fb27baSJustin T. Gibbs * - the first n unselected devices in the device list, if maxshowdevs 45528fb27baSJustin T. Gibbs * devices haven't already been selected and if the user has not 45628fb27baSJustin T. Gibbs * specified any devices on the command line and if we're in "add" mode. 45728fb27baSJustin T. Gibbs * 45828fb27baSJustin T. Gibbs * Input parameters: 45928fb27baSJustin T. Gibbs * - device selection list (dev_select) 46028fb27baSJustin T. Gibbs * - current number of devices selected (num_selected) 46128fb27baSJustin T. Gibbs * - total number of devices in the selection list (num_selections) 46228fb27baSJustin T. Gibbs * - devstat generation as of the last time selectdevs() was called 46328fb27baSJustin T. Gibbs * (select_generation) 46428fb27baSJustin T. Gibbs * - current devstat generation (current_generation) 46528fb27baSJustin T. Gibbs * - current list of devices and statistics (devices) 46628fb27baSJustin T. Gibbs * - number of devices in the current device list (numdevs) 46728fb27baSJustin T. Gibbs * - compiled version of the command line device type arguments (matches) 46828fb27baSJustin T. Gibbs * - This is optional. If the number of devices is 0, this will be ignored. 46928fb27baSJustin T. Gibbs * - The matching code pays attention to the current selection mode. So 47028fb27baSJustin T. Gibbs * if you pass in a matching expression, it will be evaluated based 47128fb27baSJustin T. Gibbs * upon the selection mode that is passed in. See below for details. 47228fb27baSJustin T. Gibbs * - number of device type matching expressions (num_matches) 47328fb27baSJustin T. Gibbs * - Set to 0 to disable the matching code. 47428fb27baSJustin T. Gibbs * - list of devices specified on the command line by the user (dev_selections) 47528fb27baSJustin T. Gibbs * - number of devices selected on the command line by the user 47628fb27baSJustin T. Gibbs * (num_dev_selections) 47728fb27baSJustin T. Gibbs * - Our selection mode. There are four different selection modes: 47828fb27baSJustin T. Gibbs * - add mode. (DS_SELECT_ADD) Any devices matching devices explicitly 47928fb27baSJustin T. Gibbs * selected by the user or devices matching a pattern given by the 48028fb27baSJustin T. Gibbs * user will be selected in addition to devices that are already 48128fb27baSJustin T. Gibbs * selected. Additional devices will be selected, up to maxshowdevs 48228fb27baSJustin T. Gibbs * number of devices. 48328fb27baSJustin T. Gibbs * - only mode. (DS_SELECT_ONLY) Only devices matching devices 48428fb27baSJustin T. Gibbs * explicitly given by the user or devices matching a pattern 48528fb27baSJustin T. Gibbs * given by the user will be selected. No other devices will be 48628fb27baSJustin T. Gibbs * selected. 48728fb27baSJustin T. Gibbs * - addonly mode. (DS_SELECT_ADDONLY) This is similar to add and 48828fb27baSJustin T. Gibbs * only. Basically, this will not de-select any devices that are 48928fb27baSJustin T. Gibbs * current selected, as only mode would, but it will also not 49028fb27baSJustin T. Gibbs * gratuitously select up to maxshowdevs devices as add mode would. 49128fb27baSJustin T. Gibbs * - remove mode. (DS_SELECT_REMOVE) Any devices matching devices 49228fb27baSJustin T. Gibbs * explicitly selected by the user or devices matching a pattern 49328fb27baSJustin T. Gibbs * given by the user will be de-selected. 49428fb27baSJustin T. Gibbs * - maximum number of devices we can select (maxshowdevs) 49528fb27baSJustin T. Gibbs * - flag indicating whether or not we're in 'top' mode (perf_select) 49628fb27baSJustin T. Gibbs * 49728fb27baSJustin T. Gibbs * Output data: 49828fb27baSJustin T. Gibbs * - the device selection list may be modified and passed back out 49928fb27baSJustin T. Gibbs * - the number of devices selected and the total number of items in the 50028fb27baSJustin T. Gibbs * device selection list may be changed 50128fb27baSJustin T. Gibbs * - the selection generation may be changed to match the current generation 50228fb27baSJustin T. Gibbs * 50328fb27baSJustin T. Gibbs * Return values: 50428fb27baSJustin T. Gibbs * -1 -- error 50528fb27baSJustin T. Gibbs * 0 -- selected devices are unchanged 50628fb27baSJustin T. Gibbs * 1 -- selected devices changed 50728fb27baSJustin T. Gibbs */ 50828fb27baSJustin T. Gibbs int 509c4a5ef6eSThomas Moestl devstat_selectdevs(struct device_selection **dev_select, int *num_selected, 510bcc6a3daSKenneth D. Merry int *num_selections, long *select_generation, 511c4a5ef6eSThomas Moestl long current_generation, struct devstat *devices, 512c4a5ef6eSThomas Moestl int numdevs, struct devstat_match *matches, int num_matches, 51328fb27baSJustin T. Gibbs char **dev_selections, int num_dev_selections, 514c4a5ef6eSThomas Moestl devstat_select_mode select_mode, int maxshowdevs, 515c4a5ef6eSThomas Moestl int perf_select) 51628fb27baSJustin T. Gibbs { 51728fb27baSJustin T. Gibbs register int i, j, k; 51828fb27baSJustin T. Gibbs int init_selections = 0, init_selected_var = 0; 51928fb27baSJustin T. Gibbs struct device_selection *old_dev_select = NULL; 52028fb27baSJustin T. Gibbs int old_num_selections = 0, old_num_selected; 52128fb27baSJustin T. Gibbs int selection_number = 0; 52228fb27baSJustin T. Gibbs int changed = 0, found = 0; 52328fb27baSJustin T. Gibbs 52428fb27baSJustin T. Gibbs if ((dev_select == NULL) || (devices == NULL) || (numdevs <= 0)) 52528fb27baSJustin T. Gibbs return(-1); 52628fb27baSJustin T. Gibbs 52728fb27baSJustin T. Gibbs /* 52828fb27baSJustin T. Gibbs * We always want to make sure that we have as many dev_select 52928fb27baSJustin T. Gibbs * entries as there are devices. 53028fb27baSJustin T. Gibbs */ 53128fb27baSJustin T. Gibbs /* 53228fb27baSJustin T. Gibbs * In this case, we haven't selected devices before. 53328fb27baSJustin T. Gibbs */ 53428fb27baSJustin T. Gibbs if (*dev_select == NULL) { 53528fb27baSJustin T. Gibbs *dev_select = (struct device_selection *)malloc(numdevs * 53628fb27baSJustin T. Gibbs sizeof(struct device_selection)); 53728fb27baSJustin T. Gibbs *select_generation = current_generation; 53828fb27baSJustin T. Gibbs init_selections = 1; 53928fb27baSJustin T. Gibbs changed = 1; 54028fb27baSJustin T. Gibbs /* 54128fb27baSJustin T. Gibbs * In this case, we have selected devices before, but the device 54228fb27baSJustin T. Gibbs * list has changed since we last selected devices, so we need to 54328fb27baSJustin T. Gibbs * either enlarge or reduce the size of the device selection list. 54428fb27baSJustin T. Gibbs */ 54528fb27baSJustin T. Gibbs } else if (*num_selections != numdevs) { 54628fb27baSJustin T. Gibbs *dev_select = (struct device_selection *)realloc(*dev_select, 54728fb27baSJustin T. Gibbs numdevs * sizeof(struct device_selection)); 54828fb27baSJustin T. Gibbs *select_generation = current_generation; 54928fb27baSJustin T. Gibbs init_selections = 1; 55028fb27baSJustin T. Gibbs /* 55128fb27baSJustin T. Gibbs * In this case, we've selected devices before, and the selection 55228fb27baSJustin T. Gibbs * list is the same size as it was the last time, but the device 55328fb27baSJustin T. Gibbs * list has changed. 55428fb27baSJustin T. Gibbs */ 55528fb27baSJustin T. Gibbs } else if (*select_generation < current_generation) { 55628fb27baSJustin T. Gibbs *select_generation = current_generation; 55728fb27baSJustin T. Gibbs init_selections = 1; 55828fb27baSJustin T. Gibbs } 55928fb27baSJustin T. Gibbs 56028fb27baSJustin T. Gibbs /* 56128fb27baSJustin T. Gibbs * If we're in "only" mode, we want to clear out the selected 56228fb27baSJustin T. Gibbs * variable since we're going to select exactly what the user wants 56328fb27baSJustin T. Gibbs * this time through. 56428fb27baSJustin T. Gibbs */ 56528fb27baSJustin T. Gibbs if (select_mode == DS_SELECT_ONLY) 56628fb27baSJustin T. Gibbs init_selected_var = 1; 56728fb27baSJustin T. Gibbs 56828fb27baSJustin T. Gibbs /* 56928fb27baSJustin T. Gibbs * In all cases, we want to back up the number of selected devices. 57028fb27baSJustin T. Gibbs * It is a quick and accurate way to determine whether the selected 57128fb27baSJustin T. Gibbs * devices have changed. 57228fb27baSJustin T. Gibbs */ 57328fb27baSJustin T. Gibbs old_num_selected = *num_selected; 57428fb27baSJustin T. Gibbs 57528fb27baSJustin T. Gibbs /* 57628fb27baSJustin T. Gibbs * We want to make a backup of the current selection list if 57728fb27baSJustin T. Gibbs * the list of devices has changed, or if we're in performance 57828fb27baSJustin T. Gibbs * selection mode. In both cases, we don't want to make a backup 57928fb27baSJustin T. Gibbs * if we already know for sure that the list will be different. 58028fb27baSJustin T. Gibbs * This is certainly the case if this is our first time through the 58128fb27baSJustin T. Gibbs * selection code. 58228fb27baSJustin T. Gibbs */ 58328fb27baSJustin T. Gibbs if (((init_selected_var != 0) || (init_selections != 0) 58428fb27baSJustin T. Gibbs || (perf_select != 0)) && (changed == 0)){ 58528fb27baSJustin T. Gibbs old_dev_select = (struct device_selection *)malloc( 58628fb27baSJustin T. Gibbs *num_selections * sizeof(struct device_selection)); 58728fb27baSJustin T. Gibbs old_num_selections = *num_selections; 58828fb27baSJustin T. Gibbs bcopy(*dev_select, old_dev_select, 58928fb27baSJustin T. Gibbs sizeof(struct device_selection) * *num_selections); 59028fb27baSJustin T. Gibbs } 59128fb27baSJustin T. Gibbs 59228fb27baSJustin T. Gibbs if (init_selections != 0) { 59328fb27baSJustin T. Gibbs bzero(*dev_select, sizeof(struct device_selection) * numdevs); 59428fb27baSJustin T. Gibbs 59528fb27baSJustin T. Gibbs for (i = 0; i < numdevs; i++) { 59628fb27baSJustin T. Gibbs (*dev_select)[i].device_number = 59728fb27baSJustin T. Gibbs devices[i].device_number; 59828fb27baSJustin T. Gibbs strncpy((*dev_select)[i].device_name, 59928fb27baSJustin T. Gibbs devices[i].device_name, 60028fb27baSJustin T. Gibbs DEVSTAT_NAME_LEN); 60117ee2b20SKenneth D. Merry (*dev_select)[i].device_name[DEVSTAT_NAME_LEN - 1]='\0'; 60228fb27baSJustin T. Gibbs (*dev_select)[i].unit_number = devices[i].unit_number; 60328fb27baSJustin T. Gibbs (*dev_select)[i].position = i; 60428fb27baSJustin T. Gibbs } 60528fb27baSJustin T. Gibbs *num_selections = numdevs; 60628fb27baSJustin T. Gibbs } else if (init_selected_var != 0) { 60728fb27baSJustin T. Gibbs for (i = 0; i < numdevs; i++) 60828fb27baSJustin T. Gibbs (*dev_select)[i].selected = 0; 60928fb27baSJustin T. Gibbs } 61028fb27baSJustin T. Gibbs 61128fb27baSJustin T. Gibbs /* we haven't gotten around to selecting anything yet.. */ 61228fb27baSJustin T. Gibbs if ((select_mode == DS_SELECT_ONLY) || (init_selections != 0) 61328fb27baSJustin T. Gibbs || (init_selected_var != 0)) 61428fb27baSJustin T. Gibbs *num_selected = 0; 61528fb27baSJustin T. Gibbs 61628fb27baSJustin T. Gibbs /* 61728fb27baSJustin T. Gibbs * Look through any devices the user specified on the command line 61828fb27baSJustin T. Gibbs * and see if they match known devices. If so, select them. 61928fb27baSJustin T. Gibbs */ 62028fb27baSJustin T. Gibbs for (i = 0; (i < *num_selections) && (num_dev_selections > 0); i++) { 62128fb27baSJustin T. Gibbs char tmpstr[80]; 62228fb27baSJustin T. Gibbs 62317ee2b20SKenneth D. Merry snprintf(tmpstr, sizeof(tmpstr), "%s%d", 62417ee2b20SKenneth D. Merry (*dev_select)[i].device_name, 62528fb27baSJustin T. Gibbs (*dev_select)[i].unit_number); 62628fb27baSJustin T. Gibbs for (j = 0; j < num_dev_selections; j++) { 62728fb27baSJustin T. Gibbs if (strcmp(tmpstr, dev_selections[j]) == 0) { 62828fb27baSJustin T. Gibbs /* 62928fb27baSJustin T. Gibbs * Here we do different things based on the 63028fb27baSJustin T. Gibbs * mode we're in. If we're in add or 63128fb27baSJustin T. Gibbs * addonly mode, we only select this device 63228fb27baSJustin T. Gibbs * if it hasn't already been selected. 63328fb27baSJustin T. Gibbs * Otherwise, we would be unnecessarily 63428fb27baSJustin T. Gibbs * changing the selection order and 63528fb27baSJustin T. Gibbs * incrementing the selection count. If 63628fb27baSJustin T. Gibbs * we're in only mode, we unconditionally 63728fb27baSJustin T. Gibbs * select this device, since in only mode 63828fb27baSJustin T. Gibbs * any previous selections are erased and 63928fb27baSJustin T. Gibbs * manually specified devices are the first 64028fb27baSJustin T. Gibbs * ones to be selected. If we're in remove 64128fb27baSJustin T. Gibbs * mode, we de-select the specified device and 64228fb27baSJustin T. Gibbs * decrement the selection count. 64328fb27baSJustin T. Gibbs */ 64428fb27baSJustin T. Gibbs switch(select_mode) { 64528fb27baSJustin T. Gibbs case DS_SELECT_ADD: 64628fb27baSJustin T. Gibbs case DS_SELECT_ADDONLY: 64728fb27baSJustin T. Gibbs if ((*dev_select)[i].selected) 64828fb27baSJustin T. Gibbs break; 64928fb27baSJustin T. Gibbs /* FALLTHROUGH */ 65028fb27baSJustin T. Gibbs case DS_SELECT_ONLY: 65128fb27baSJustin T. Gibbs (*dev_select)[i].selected = 65228fb27baSJustin T. Gibbs ++selection_number; 65328fb27baSJustin T. Gibbs (*num_selected)++; 65428fb27baSJustin T. Gibbs break; 65528fb27baSJustin T. Gibbs case DS_SELECT_REMOVE: 65628fb27baSJustin T. Gibbs (*dev_select)[i].selected = 0; 65728fb27baSJustin T. Gibbs (*num_selected)--; 65828fb27baSJustin T. Gibbs /* 65928fb27baSJustin T. Gibbs * This isn't passed back out, we 66028fb27baSJustin T. Gibbs * just use it to keep track of 66128fb27baSJustin T. Gibbs * how many devices we've removed. 66228fb27baSJustin T. Gibbs */ 66328fb27baSJustin T. Gibbs num_dev_selections--; 66428fb27baSJustin T. Gibbs break; 66528fb27baSJustin T. Gibbs } 66628fb27baSJustin T. Gibbs break; 66728fb27baSJustin T. Gibbs } 66828fb27baSJustin T. Gibbs } 66928fb27baSJustin T. Gibbs } 67028fb27baSJustin T. Gibbs 67128fb27baSJustin T. Gibbs /* 67228fb27baSJustin T. Gibbs * Go through the user's device type expressions and select devices 67328fb27baSJustin T. Gibbs * accordingly. We only do this if the number of devices already 67428fb27baSJustin T. Gibbs * selected is less than the maximum number we can show. 67528fb27baSJustin T. Gibbs */ 67628fb27baSJustin T. Gibbs for (i = 0; (i < num_matches) && (*num_selected < maxshowdevs); i++) { 67728fb27baSJustin T. Gibbs /* We should probably indicate some error here */ 67828fb27baSJustin T. Gibbs if ((matches[i].match_fields == DEVSTAT_MATCH_NONE) 67928fb27baSJustin T. Gibbs || (matches[i].num_match_categories <= 0)) 68028fb27baSJustin T. Gibbs continue; 68128fb27baSJustin T. Gibbs 68228fb27baSJustin T. Gibbs for (j = 0; j < numdevs; j++) { 68328fb27baSJustin T. Gibbs int num_match_categories; 68428fb27baSJustin T. Gibbs 68528fb27baSJustin T. Gibbs num_match_categories = matches[i].num_match_categories; 68628fb27baSJustin T. Gibbs 68728fb27baSJustin T. Gibbs /* 68828fb27baSJustin T. Gibbs * Determine whether or not the current device 68928fb27baSJustin T. Gibbs * matches the given matching expression. This if 69028fb27baSJustin T. Gibbs * statement consists of three components: 69128fb27baSJustin T. Gibbs * - the device type check 69228fb27baSJustin T. Gibbs * - the device interface check 69328fb27baSJustin T. Gibbs * - the passthrough check 69428fb27baSJustin T. Gibbs * If a the matching test is successful, it 69528fb27baSJustin T. Gibbs * decrements the number of matching categories, 69628fb27baSJustin T. Gibbs * and if we've reached the last element that 69728fb27baSJustin T. Gibbs * needed to be matched, the if statement succeeds. 69828fb27baSJustin T. Gibbs * 69928fb27baSJustin T. Gibbs */ 70028fb27baSJustin T. Gibbs if ((((matches[i].match_fields & DEVSTAT_MATCH_TYPE)!=0) 70128fb27baSJustin T. Gibbs && ((devices[j].device_type & DEVSTAT_TYPE_MASK) == 70228fb27baSJustin T. Gibbs (matches[i].device_type & DEVSTAT_TYPE_MASK)) 70328fb27baSJustin T. Gibbs &&(((matches[i].match_fields & DEVSTAT_MATCH_PASS)!=0) 70428fb27baSJustin T. Gibbs || (((matches[i].match_fields & 70528fb27baSJustin T. Gibbs DEVSTAT_MATCH_PASS) == 0) 70628fb27baSJustin T. Gibbs && ((devices[j].device_type & 70728fb27baSJustin T. Gibbs DEVSTAT_TYPE_PASS) == 0))) 70828fb27baSJustin T. Gibbs && (--num_match_categories == 0)) 70928fb27baSJustin T. Gibbs || (((matches[i].match_fields & DEVSTAT_MATCH_IF) != 0) 71028fb27baSJustin T. Gibbs && ((devices[j].device_type & DEVSTAT_TYPE_IF_MASK) == 71128fb27baSJustin T. Gibbs (matches[i].device_type & DEVSTAT_TYPE_IF_MASK)) 71228fb27baSJustin T. Gibbs &&(((matches[i].match_fields & DEVSTAT_MATCH_PASS)!=0) 71328fb27baSJustin T. Gibbs || (((matches[i].match_fields & 71428fb27baSJustin T. Gibbs DEVSTAT_MATCH_PASS) == 0) 71528fb27baSJustin T. Gibbs && ((devices[j].device_type & 71628fb27baSJustin T. Gibbs DEVSTAT_TYPE_PASS) == 0))) 71728fb27baSJustin T. Gibbs && (--num_match_categories == 0)) 71828fb27baSJustin T. Gibbs || (((matches[i].match_fields & DEVSTAT_MATCH_PASS)!=0) 71928fb27baSJustin T. Gibbs && ((devices[j].device_type & DEVSTAT_TYPE_PASS) != 0) 72028fb27baSJustin T. Gibbs && (--num_match_categories == 0))) { 72128fb27baSJustin T. Gibbs 72228fb27baSJustin T. Gibbs /* 72328fb27baSJustin T. Gibbs * This is probably a non-optimal solution 72428fb27baSJustin T. Gibbs * to the problem that the devices in the 72528fb27baSJustin T. Gibbs * device list will not be in the same 72628fb27baSJustin T. Gibbs * order as the devices in the selection 72728fb27baSJustin T. Gibbs * array. 72828fb27baSJustin T. Gibbs */ 72928fb27baSJustin T. Gibbs for (k = 0; k < numdevs; k++) { 73028fb27baSJustin T. Gibbs if ((*dev_select)[k].position == j) { 73128fb27baSJustin T. Gibbs found = 1; 73228fb27baSJustin T. Gibbs break; 73328fb27baSJustin T. Gibbs } 73428fb27baSJustin T. Gibbs } 73528fb27baSJustin T. Gibbs 73628fb27baSJustin T. Gibbs /* 73728fb27baSJustin T. Gibbs * There shouldn't be a case where a device 73828fb27baSJustin T. Gibbs * in the device list is not in the 73928fb27baSJustin T. Gibbs * selection list...but it could happen. 74028fb27baSJustin T. Gibbs */ 74128fb27baSJustin T. Gibbs if (found != 1) { 74228fb27baSJustin T. Gibbs fprintf(stderr, "selectdevs: couldn't" 74328fb27baSJustin T. Gibbs " find %s%d in selection " 74428fb27baSJustin T. Gibbs "list\n", 74528fb27baSJustin T. Gibbs devices[j].device_name, 74628fb27baSJustin T. Gibbs devices[j].unit_number); 74728fb27baSJustin T. Gibbs break; 74828fb27baSJustin T. Gibbs } 74928fb27baSJustin T. Gibbs 75028fb27baSJustin T. Gibbs /* 75128fb27baSJustin T. Gibbs * We do different things based upon the 75228fb27baSJustin T. Gibbs * mode we're in. If we're in add or only 75328fb27baSJustin T. Gibbs * mode, we go ahead and select this device 75428fb27baSJustin T. Gibbs * if it hasn't already been selected. If 75528fb27baSJustin T. Gibbs * it has already been selected, we leave 75628fb27baSJustin T. Gibbs * it alone so we don't mess up the 75728fb27baSJustin T. Gibbs * selection ordering. Manually specified 75828fb27baSJustin T. Gibbs * devices have already been selected, and 75928fb27baSJustin T. Gibbs * they have higher priority than pattern 76028fb27baSJustin T. Gibbs * matched devices. If we're in remove 76128fb27baSJustin T. Gibbs * mode, we de-select the given device and 76228fb27baSJustin T. Gibbs * decrement the selected count. 76328fb27baSJustin T. Gibbs */ 76428fb27baSJustin T. Gibbs switch(select_mode) { 76528fb27baSJustin T. Gibbs case DS_SELECT_ADD: 76628fb27baSJustin T. Gibbs case DS_SELECT_ADDONLY: 76728fb27baSJustin T. Gibbs case DS_SELECT_ONLY: 76828fb27baSJustin T. Gibbs if ((*dev_select)[k].selected != 0) 76928fb27baSJustin T. Gibbs break; 77028fb27baSJustin T. Gibbs (*dev_select)[k].selected = 77128fb27baSJustin T. Gibbs ++selection_number; 77228fb27baSJustin T. Gibbs (*num_selected)++; 77328fb27baSJustin T. Gibbs break; 77428fb27baSJustin T. Gibbs case DS_SELECT_REMOVE: 77528fb27baSJustin T. Gibbs (*dev_select)[k].selected = 0; 77628fb27baSJustin T. Gibbs (*num_selected)--; 77728fb27baSJustin T. Gibbs break; 77828fb27baSJustin T. Gibbs } 77928fb27baSJustin T. Gibbs } 78028fb27baSJustin T. Gibbs } 78128fb27baSJustin T. Gibbs } 78228fb27baSJustin T. Gibbs 78328fb27baSJustin T. Gibbs /* 78428fb27baSJustin T. Gibbs * Here we implement "top" mode. Devices are sorted in the 78528fb27baSJustin T. Gibbs * selection array based on two criteria: whether or not they are 78628fb27baSJustin T. Gibbs * selected (not selection number, just the fact that they are 78728fb27baSJustin T. Gibbs * selected!) and the number of bytes in the "bytes" field of the 78828fb27baSJustin T. Gibbs * selection structure. The bytes field generally must be kept up 78928fb27baSJustin T. Gibbs * by the user. In the future, it may be maintained by library 79028fb27baSJustin T. Gibbs * functions, but for now the user has to do the work. 79128fb27baSJustin T. Gibbs * 79228fb27baSJustin T. Gibbs * At first glance, it may seem wrong that we don't go through and 79328fb27baSJustin T. Gibbs * select every device in the case where the user hasn't specified 79428fb27baSJustin T. Gibbs * any devices or patterns. In fact, though, it won't make any 79528fb27baSJustin T. Gibbs * difference in the device sorting. In that particular case (i.e. 79628fb27baSJustin T. Gibbs * when we're in "add" or "only" mode, and the user hasn't 79728fb27baSJustin T. Gibbs * specified anything) the first time through no devices will be 79828fb27baSJustin T. Gibbs * selected, so the only criterion used to sort them will be their 79928fb27baSJustin T. Gibbs * performance. The second time through, and every time thereafter, 80028fb27baSJustin T. Gibbs * all devices will be selected, so again selection won't matter. 80128fb27baSJustin T. Gibbs */ 80228fb27baSJustin T. Gibbs if (perf_select != 0) { 80328fb27baSJustin T. Gibbs 80428fb27baSJustin T. Gibbs /* Sort the device array by throughput */ 80528fb27baSJustin T. Gibbs qsort(*dev_select, *num_selections, 80628fb27baSJustin T. Gibbs sizeof(struct device_selection), 80728fb27baSJustin T. Gibbs compare_select); 80828fb27baSJustin T. Gibbs 80928fb27baSJustin T. Gibbs if (*num_selected == 0) { 81028fb27baSJustin T. Gibbs /* 81128fb27baSJustin T. Gibbs * Here we select every device in the array, if it 81228fb27baSJustin T. Gibbs * isn't already selected. Because the 'selected' 81328fb27baSJustin T. Gibbs * variable in the selection array entries contains 81428fb27baSJustin T. Gibbs * the selection order, the devstats routine can show 81528fb27baSJustin T. Gibbs * the devices that were selected first. 81628fb27baSJustin T. Gibbs */ 81728fb27baSJustin T. Gibbs for (i = 0; i < *num_selections; i++) { 81828fb27baSJustin T. Gibbs if ((*dev_select)[i].selected == 0) { 81928fb27baSJustin T. Gibbs (*dev_select)[i].selected = 82028fb27baSJustin T. Gibbs ++selection_number; 82128fb27baSJustin T. Gibbs (*num_selected)++; 82228fb27baSJustin T. Gibbs } 82328fb27baSJustin T. Gibbs } 82428fb27baSJustin T. Gibbs } else { 82528fb27baSJustin T. Gibbs selection_number = 0; 82628fb27baSJustin T. Gibbs for (i = 0; i < *num_selections; i++) { 82728fb27baSJustin T. Gibbs if ((*dev_select)[i].selected != 0) { 82828fb27baSJustin T. Gibbs (*dev_select)[i].selected = 82928fb27baSJustin T. Gibbs ++selection_number; 83028fb27baSJustin T. Gibbs } 83128fb27baSJustin T. Gibbs } 83228fb27baSJustin T. Gibbs } 83328fb27baSJustin T. Gibbs } 83428fb27baSJustin T. Gibbs 83528fb27baSJustin T. Gibbs /* 83628fb27baSJustin T. Gibbs * If we're in the "add" selection mode and if we haven't already 83728fb27baSJustin T. Gibbs * selected maxshowdevs number of devices, go through the array and 83828fb27baSJustin T. Gibbs * select any unselected devices. If we're in "only" mode, we 83928fb27baSJustin T. Gibbs * obviously don't want to select anything other than what the user 84028fb27baSJustin T. Gibbs * specifies. If we're in "remove" mode, it probably isn't a good 84128fb27baSJustin T. Gibbs * idea to go through and select any more devices, since we might 84228fb27baSJustin T. Gibbs * end up selecting something that the user wants removed. Through 84328fb27baSJustin T. Gibbs * more complicated logic, we could actually figure this out, but 84428fb27baSJustin T. Gibbs * that would probably require combining this loop with the various 84528fb27baSJustin T. Gibbs * selections loops above. 84628fb27baSJustin T. Gibbs */ 84728fb27baSJustin T. Gibbs if ((select_mode == DS_SELECT_ADD) && (*num_selected < maxshowdevs)) { 84828fb27baSJustin T. Gibbs for (i = 0; i < *num_selections; i++) 84928fb27baSJustin T. Gibbs if ((*dev_select)[i].selected == 0) { 85028fb27baSJustin T. Gibbs (*dev_select)[i].selected = ++selection_number; 85128fb27baSJustin T. Gibbs (*num_selected)++; 85228fb27baSJustin T. Gibbs } 85328fb27baSJustin T. Gibbs } 85428fb27baSJustin T. Gibbs 85528fb27baSJustin T. Gibbs /* 85628fb27baSJustin T. Gibbs * Look at the number of devices that have been selected. If it 85728fb27baSJustin T. Gibbs * has changed, set the changed variable. Otherwise, if we've 85828fb27baSJustin T. Gibbs * made a backup of the selection list, compare it to the current 85928fb27baSJustin T. Gibbs * selection list to see if the selected devices have changed. 86028fb27baSJustin T. Gibbs */ 86128fb27baSJustin T. Gibbs if ((changed == 0) && (old_num_selected != *num_selected)) 86228fb27baSJustin T. Gibbs changed = 1; 86328fb27baSJustin T. Gibbs else if ((changed == 0) && (old_dev_select != NULL)) { 86428fb27baSJustin T. Gibbs /* 86528fb27baSJustin T. Gibbs * Now we go through the selection list and we look at 86628fb27baSJustin T. Gibbs * it three different ways. 86728fb27baSJustin T. Gibbs */ 86828fb27baSJustin T. Gibbs for (i = 0; (i < *num_selections) && (changed == 0) && 86928fb27baSJustin T. Gibbs (i < old_num_selections); i++) { 87028fb27baSJustin T. Gibbs /* 87128fb27baSJustin T. Gibbs * If the device at index i in both the new and old 87228fb27baSJustin T. Gibbs * selection arrays has the same device number and 87328fb27baSJustin T. Gibbs * selection status, it hasn't changed. We 87428fb27baSJustin T. Gibbs * continue on to the next index. 87528fb27baSJustin T. Gibbs */ 87628fb27baSJustin T. Gibbs if (((*dev_select)[i].device_number == 87728fb27baSJustin T. Gibbs old_dev_select[i].device_number) 87828fb27baSJustin T. Gibbs && ((*dev_select)[i].selected == 87928fb27baSJustin T. Gibbs old_dev_select[i].selected)) 88028fb27baSJustin T. Gibbs continue; 88128fb27baSJustin T. Gibbs 88228fb27baSJustin T. Gibbs /* 88328fb27baSJustin T. Gibbs * Now, if we're still going through the if 88428fb27baSJustin T. Gibbs * statement, the above test wasn't true. So we 88528fb27baSJustin T. Gibbs * check here to see if the device at index i in 88628fb27baSJustin T. Gibbs * the current array is the same as the device at 88728fb27baSJustin T. Gibbs * index i in the old array. If it is, that means 88828fb27baSJustin T. Gibbs * that its selection number has changed. Set 88928fb27baSJustin T. Gibbs * changed to 1 and exit the loop. 89028fb27baSJustin T. Gibbs */ 89128fb27baSJustin T. Gibbs else if ((*dev_select)[i].device_number == 89228fb27baSJustin T. Gibbs old_dev_select[i].device_number) { 89328fb27baSJustin T. Gibbs changed = 1; 89428fb27baSJustin T. Gibbs break; 89528fb27baSJustin T. Gibbs } 89628fb27baSJustin T. Gibbs /* 89728fb27baSJustin T. Gibbs * If we get here, then the device at index i in 89828fb27baSJustin T. Gibbs * the current array isn't the same device as the 89928fb27baSJustin T. Gibbs * device at index i in the old array. 90028fb27baSJustin T. Gibbs */ 90128fb27baSJustin T. Gibbs else { 90228fb27baSJustin T. Gibbs int found = 0; 90328fb27baSJustin T. Gibbs 90428fb27baSJustin T. Gibbs /* 90528fb27baSJustin T. Gibbs * Search through the old selection array 90628fb27baSJustin T. Gibbs * looking for a device with the same 90728fb27baSJustin T. Gibbs * device number as the device at index i 90828fb27baSJustin T. Gibbs * in the current array. If the selection 90928fb27baSJustin T. Gibbs * status is the same, then we mark it as 91028fb27baSJustin T. Gibbs * found. If the selection status isn't 91128fb27baSJustin T. Gibbs * the same, we break out of the loop. 91228fb27baSJustin T. Gibbs * Since found isn't set, changed will be 91328fb27baSJustin T. Gibbs * set to 1 below. 91428fb27baSJustin T. Gibbs */ 91528fb27baSJustin T. Gibbs for (j = 0; j < old_num_selections; j++) { 91628fb27baSJustin T. Gibbs if (((*dev_select)[i].device_number == 91728fb27baSJustin T. Gibbs old_dev_select[j].device_number) 91828fb27baSJustin T. Gibbs && ((*dev_select)[i].selected == 91928fb27baSJustin T. Gibbs old_dev_select[j].selected)){ 92028fb27baSJustin T. Gibbs found = 1; 92128fb27baSJustin T. Gibbs break; 92228fb27baSJustin T. Gibbs } 92328fb27baSJustin T. Gibbs else if ((*dev_select)[i].device_number 92428fb27baSJustin T. Gibbs == old_dev_select[j].device_number) 92528fb27baSJustin T. Gibbs break; 92628fb27baSJustin T. Gibbs } 92728fb27baSJustin T. Gibbs if (found == 0) 92828fb27baSJustin T. Gibbs changed = 1; 92928fb27baSJustin T. Gibbs } 93028fb27baSJustin T. Gibbs } 93128fb27baSJustin T. Gibbs } 93228fb27baSJustin T. Gibbs if (old_dev_select != NULL) 93328fb27baSJustin T. Gibbs free(old_dev_select); 93428fb27baSJustin T. Gibbs 93528fb27baSJustin T. Gibbs return(changed); 93628fb27baSJustin T. Gibbs } 93728fb27baSJustin T. Gibbs 93828fb27baSJustin T. Gibbs /* 93928fb27baSJustin T. Gibbs * Comparison routine for qsort() above. Note that the comparison here is 94028fb27baSJustin T. Gibbs * backwards -- generally, it should return a value to indicate whether 94128fb27baSJustin T. Gibbs * arg1 is <, =, or > arg2. Instead, it returns the opposite. The reason 94228fb27baSJustin T. Gibbs * it returns the opposite is so that the selection array will be sorted in 94328fb27baSJustin T. Gibbs * order of decreasing performance. We sort on two parameters. The first 94428fb27baSJustin T. Gibbs * sort key is whether or not one or the other of the devices in question 94528fb27baSJustin T. Gibbs * has been selected. If one of them has, and the other one has not, the 94628fb27baSJustin T. Gibbs * selected device is automatically more important than the unselected 94728fb27baSJustin T. Gibbs * device. If neither device is selected, we judge the devices based upon 94828fb27baSJustin T. Gibbs * performance. 94928fb27baSJustin T. Gibbs */ 95028fb27baSJustin T. Gibbs static int 95128fb27baSJustin T. Gibbs compare_select(const void *arg1, const void *arg2) 95228fb27baSJustin T. Gibbs { 95328fb27baSJustin T. Gibbs if ((((struct device_selection *)arg1)->selected) 95428fb27baSJustin T. Gibbs && (((struct device_selection *)arg2)->selected == 0)) 95528fb27baSJustin T. Gibbs return(-1); 95628fb27baSJustin T. Gibbs else if ((((struct device_selection *)arg1)->selected == 0) 95728fb27baSJustin T. Gibbs && (((struct device_selection *)arg2)->selected)) 95828fb27baSJustin T. Gibbs return(1); 95928fb27baSJustin T. Gibbs else if (((struct device_selection *)arg2)->bytes < 96028fb27baSJustin T. Gibbs ((struct device_selection *)arg1)->bytes) 96128fb27baSJustin T. Gibbs return(-1); 96228fb27baSJustin T. Gibbs else if (((struct device_selection *)arg2)->bytes > 96328fb27baSJustin T. Gibbs ((struct device_selection *)arg1)->bytes) 96428fb27baSJustin T. Gibbs return(1); 96528fb27baSJustin T. Gibbs else 96628fb27baSJustin T. Gibbs return(0); 96728fb27baSJustin T. Gibbs } 96828fb27baSJustin T. Gibbs 96928fb27baSJustin T. Gibbs /* 97028fb27baSJustin T. Gibbs * Take a string with the general format "arg1,arg2,arg3", and build a 97128fb27baSJustin T. Gibbs * device matching expression from it. 97228fb27baSJustin T. Gibbs */ 97328fb27baSJustin T. Gibbs int 974c4a5ef6eSThomas Moestl devstat_buildmatch(char *match_str, struct devstat_match **matches, 975c4a5ef6eSThomas Moestl int *num_matches) 97628fb27baSJustin T. Gibbs { 97728fb27baSJustin T. Gibbs char *tstr[5]; 97828fb27baSJustin T. Gibbs char **tempstr; 97928fb27baSJustin T. Gibbs int num_args; 98028fb27baSJustin T. Gibbs register int i, j; 981c4a5ef6eSThomas Moestl char *func_name = "devstat_buildmatch"; 98228fb27baSJustin T. Gibbs 98328fb27baSJustin T. Gibbs /* We can't do much without a string to parse */ 98428fb27baSJustin T. Gibbs if (match_str == NULL) { 985c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 986c4a5ef6eSThomas Moestl "%s: no match expression", func_name); 98728fb27baSJustin T. Gibbs return(-1); 98828fb27baSJustin T. Gibbs } 98928fb27baSJustin T. Gibbs 99028fb27baSJustin T. Gibbs /* 99128fb27baSJustin T. Gibbs * Break the (comma delimited) input string out into separate strings. 99228fb27baSJustin T. Gibbs */ 99328fb27baSJustin T. Gibbs for (tempstr = tstr, num_args = 0; 99428fb27baSJustin T. Gibbs (*tempstr = strsep(&match_str, ",")) != NULL && (num_args < 5); 99528fb27baSJustin T. Gibbs num_args++) 99628fb27baSJustin T. Gibbs if (**tempstr != '\0') 99728fb27baSJustin T. Gibbs if (++tempstr >= &tstr[5]) 99828fb27baSJustin T. Gibbs break; 99928fb27baSJustin T. Gibbs 100028fb27baSJustin T. Gibbs /* The user gave us too many type arguments */ 100128fb27baSJustin T. Gibbs if (num_args > 3) { 1002c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1003c4a5ef6eSThomas Moestl "%s: too many type arguments", func_name); 100428fb27baSJustin T. Gibbs return(-1); 100528fb27baSJustin T. Gibbs } 100628fb27baSJustin T. Gibbs 100728fb27baSJustin T. Gibbs /* 100828fb27baSJustin T. Gibbs * Since you can't realloc a pointer that hasn't been malloced 100928fb27baSJustin T. Gibbs * first, we malloc first and then realloc. 101028fb27baSJustin T. Gibbs */ 101128fb27baSJustin T. Gibbs if (*num_matches == 0) 101228fb27baSJustin T. Gibbs *matches = (struct devstat_match *)malloc( 101328fb27baSJustin T. Gibbs sizeof(struct devstat_match)); 101428fb27baSJustin T. Gibbs else 101528fb27baSJustin T. Gibbs *matches = (struct devstat_match *)realloc(*matches, 101628fb27baSJustin T. Gibbs sizeof(struct devstat_match) * (*num_matches + 1)); 101728fb27baSJustin T. Gibbs 101828fb27baSJustin T. Gibbs /* Make sure the current entry is clear */ 101928fb27baSJustin T. Gibbs bzero(&matches[0][*num_matches], sizeof(struct devstat_match)); 102028fb27baSJustin T. Gibbs 102128fb27baSJustin T. Gibbs /* 102228fb27baSJustin T. Gibbs * Step through the arguments the user gave us and build a device 102328fb27baSJustin T. Gibbs * matching expression from them. 102428fb27baSJustin T. Gibbs */ 102528fb27baSJustin T. Gibbs for (i = 0; i < num_args; i++) { 102628fb27baSJustin T. Gibbs char *tempstr2, *tempstr3; 102728fb27baSJustin T. Gibbs 102828fb27baSJustin T. Gibbs /* 102928fb27baSJustin T. Gibbs * Get rid of leading white space. 103028fb27baSJustin T. Gibbs */ 103128fb27baSJustin T. Gibbs tempstr2 = tstr[i]; 103228fb27baSJustin T. Gibbs while (isspace(*tempstr2) && (*tempstr2 != '\0')) 103328fb27baSJustin T. Gibbs tempstr2++; 103428fb27baSJustin T. Gibbs 103528fb27baSJustin T. Gibbs /* 103628fb27baSJustin T. Gibbs * Get rid of trailing white space. 103728fb27baSJustin T. Gibbs */ 103828fb27baSJustin T. Gibbs tempstr3 = &tempstr2[strlen(tempstr2) - 1]; 103928fb27baSJustin T. Gibbs 104028fb27baSJustin T. Gibbs while ((*tempstr3 != '\0') && (tempstr3 > tempstr2) 104128fb27baSJustin T. Gibbs && (isspace(*tempstr3))) { 104228fb27baSJustin T. Gibbs *tempstr3 = '\0'; 104328fb27baSJustin T. Gibbs tempstr3--; 104428fb27baSJustin T. Gibbs } 104528fb27baSJustin T. Gibbs 104628fb27baSJustin T. Gibbs /* 104728fb27baSJustin T. Gibbs * Go through the match table comparing the user's 104828fb27baSJustin T. Gibbs * arguments to known device types, interfaces, etc. 104928fb27baSJustin T. Gibbs */ 105028fb27baSJustin T. Gibbs for (j = 0; match_table[j].match_str != NULL; j++) { 105128fb27baSJustin T. Gibbs /* 105228fb27baSJustin T. Gibbs * We do case-insensitive matching, in case someone 105328fb27baSJustin T. Gibbs * wants to enter "SCSI" instead of "scsi" or 105428fb27baSJustin T. Gibbs * something like that. Only compare as many 105528fb27baSJustin T. Gibbs * characters as are in the string in the match 105628fb27baSJustin T. Gibbs * table. This should help if someone tries to use 105728fb27baSJustin T. Gibbs * a super-long match expression. 105828fb27baSJustin T. Gibbs */ 105928fb27baSJustin T. Gibbs if (strncasecmp(tempstr2, match_table[j].match_str, 106028fb27baSJustin T. Gibbs strlen(match_table[j].match_str)) == 0) { 106128fb27baSJustin T. Gibbs /* 106228fb27baSJustin T. Gibbs * Make sure the user hasn't specified two 106328fb27baSJustin T. Gibbs * items of the same type, like "da" and 106428fb27baSJustin T. Gibbs * "cd". One device cannot be both. 106528fb27baSJustin T. Gibbs */ 106628fb27baSJustin T. Gibbs if (((*matches)[*num_matches].match_fields & 106728fb27baSJustin T. Gibbs match_table[j].match_field) != 0) { 1068c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, 1069c4a5ef6eSThomas Moestl sizeof(devstat_errbuf), 107028fb27baSJustin T. Gibbs "%s: cannot have more than " 107128fb27baSJustin T. Gibbs "one match item in a single " 107228fb27baSJustin T. Gibbs "category", func_name); 107328fb27baSJustin T. Gibbs return(-1); 107428fb27baSJustin T. Gibbs } 107528fb27baSJustin T. Gibbs /* 107628fb27baSJustin T. Gibbs * If we've gotten this far, we have a 107728fb27baSJustin T. Gibbs * winner. Set the appropriate fields in 107828fb27baSJustin T. Gibbs * the match entry. 107928fb27baSJustin T. Gibbs */ 108028fb27baSJustin T. Gibbs (*matches)[*num_matches].match_fields |= 108128fb27baSJustin T. Gibbs match_table[j].match_field; 108228fb27baSJustin T. Gibbs (*matches)[*num_matches].device_type |= 108328fb27baSJustin T. Gibbs match_table[j].type; 108428fb27baSJustin T. Gibbs (*matches)[*num_matches].num_match_categories++; 108528fb27baSJustin T. Gibbs break; 108628fb27baSJustin T. Gibbs } 108728fb27baSJustin T. Gibbs } 108828fb27baSJustin T. Gibbs /* 108928fb27baSJustin T. Gibbs * We should have found a match in the above for loop. If 109028fb27baSJustin T. Gibbs * not, that means the user entered an invalid device type 109128fb27baSJustin T. Gibbs * or interface. 109228fb27baSJustin T. Gibbs */ 109328fb27baSJustin T. Gibbs if ((*matches)[*num_matches].num_match_categories != (i + 1)) { 109417ee2b20SKenneth D. Merry snprintf(devstat_errbuf, sizeof(devstat_errbuf), 109528fb27baSJustin T. Gibbs "%s: unknown match item \"%s\"", func_name, 109628fb27baSJustin T. Gibbs tstr[i]); 109728fb27baSJustin T. Gibbs return(-1); 109828fb27baSJustin T. Gibbs } 109928fb27baSJustin T. Gibbs } 110028fb27baSJustin T. Gibbs 110128fb27baSJustin T. Gibbs (*num_matches)++; 110228fb27baSJustin T. Gibbs 110328fb27baSJustin T. Gibbs return(0); 110428fb27baSJustin T. Gibbs } 110528fb27baSJustin T. Gibbs 110628fb27baSJustin T. Gibbs /* 110728fb27baSJustin T. Gibbs * Compute a number of device statistics. Only one field is mandatory, and 110828fb27baSJustin T. Gibbs * that is "current". Everything else is optional. The caller passes in 110928fb27baSJustin T. Gibbs * pointers to variables to hold the various statistics he desires. If he 111028fb27baSJustin T. Gibbs * doesn't want a particular staistic, he should pass in a NULL pointer. 111128fb27baSJustin T. Gibbs * Return values: 111228fb27baSJustin T. Gibbs * 0 -- success 111328fb27baSJustin T. Gibbs * -1 -- failure 111428fb27baSJustin T. Gibbs */ 111528fb27baSJustin T. Gibbs int 111628fb27baSJustin T. Gibbs compute_stats(struct devstat *current, struct devstat *previous, 111728fb27baSJustin T. Gibbs long double etime, u_int64_t *total_bytes, 111828fb27baSJustin T. Gibbs u_int64_t *total_transfers, u_int64_t *total_blocks, 111928fb27baSJustin T. Gibbs long double *kb_per_transfer, long double *transfers_per_second, 112028fb27baSJustin T. Gibbs long double *mb_per_second, long double *blocks_per_second, 112128fb27baSJustin T. Gibbs long double *ms_per_transaction) 112228fb27baSJustin T. Gibbs { 1123884539f7SKenneth D. Merry return(devstat_compute_statistics(current, previous, etime, 1124884539f7SKenneth D. Merry total_bytes ? DSM_TOTAL_BYTES : DSM_SKIP, 1125884539f7SKenneth D. Merry total_bytes, 1126884539f7SKenneth D. Merry total_transfers ? DSM_TOTAL_TRANSFERS : DSM_SKIP, 1127884539f7SKenneth D. Merry total_transfers, 1128884539f7SKenneth D. Merry total_blocks ? DSM_TOTAL_BLOCKS : DSM_SKIP, 1129884539f7SKenneth D. Merry total_blocks, 1130884539f7SKenneth D. Merry kb_per_transfer ? DSM_KB_PER_TRANSFER : DSM_SKIP, 1131884539f7SKenneth D. Merry kb_per_transfer, 1132884539f7SKenneth D. Merry transfers_per_second ? DSM_TRANSFERS_PER_SECOND : DSM_SKIP, 1133884539f7SKenneth D. Merry transfers_per_second, 1134884539f7SKenneth D. Merry mb_per_second ? DSM_MB_PER_SECOND : DSM_SKIP, 1135884539f7SKenneth D. Merry mb_per_second, 1136884539f7SKenneth D. Merry blocks_per_second ? DSM_BLOCKS_PER_SECOND : DSM_SKIP, 1137884539f7SKenneth D. Merry blocks_per_second, 1138884539f7SKenneth D. Merry ms_per_transaction ? DSM_MS_PER_TRANSACTION : DSM_SKIP, 1139884539f7SKenneth D. Merry ms_per_transaction, 1140884539f7SKenneth D. Merry DSM_NONE)); 114128fb27baSJustin T. Gibbs } 114228fb27baSJustin T. Gibbs 114328fb27baSJustin T. Gibbs long double 1144c4a5ef6eSThomas Moestl devstat_compute_etime(struct timeval cur_time, struct timeval prev_time) 114528fb27baSJustin T. Gibbs { 114628fb27baSJustin T. Gibbs struct timeval busy_time; 114728fb27baSJustin T. Gibbs u_int64_t busy_usec; 114828fb27baSJustin T. Gibbs long double etime; 114928fb27baSJustin T. Gibbs 115028fb27baSJustin T. Gibbs timersub(&cur_time, &prev_time, &busy_time); 115128fb27baSJustin T. Gibbs 115228fb27baSJustin T. Gibbs busy_usec = busy_time.tv_sec; 115328fb27baSJustin T. Gibbs busy_usec *= 1000000; 115428fb27baSJustin T. Gibbs busy_usec += busy_time.tv_usec; 115528fb27baSJustin T. Gibbs etime = busy_usec; 115628fb27baSJustin T. Gibbs etime /= 1000000; 115728fb27baSJustin T. Gibbs 115828fb27baSJustin T. Gibbs return(etime); 115928fb27baSJustin T. Gibbs } 1160c4a5ef6eSThomas Moestl 1161c4a5ef6eSThomas Moestl int 1162c4a5ef6eSThomas Moestl devstat_compute_statistics(struct devstat *current, struct devstat *previous, 1163c4a5ef6eSThomas Moestl long double etime, ...) 1164c4a5ef6eSThomas Moestl { 1165c4a5ef6eSThomas Moestl char *func_name = "devstat_compute_statistics"; 1166c4a5ef6eSThomas Moestl u_int64_t totalbytes, totalbytesread, totalbyteswrite; 1167c4a5ef6eSThomas Moestl u_int64_t totaltransfers, totaltransfersread, totaltransferswrite; 1168c4a5ef6eSThomas Moestl u_int64_t totaltransfersother, totalblocks, totalblocksread; 1169c4a5ef6eSThomas Moestl u_int64_t totalblockswrite; 1170c4a5ef6eSThomas Moestl va_list ap; 1171c4a5ef6eSThomas Moestl devstat_metric metric; 1172c4a5ef6eSThomas Moestl u_int64_t *destu64; 1173c4a5ef6eSThomas Moestl long double *destld; 1174c4a5ef6eSThomas Moestl int retval; 1175c4a5ef6eSThomas Moestl 1176c4a5ef6eSThomas Moestl retval = 0; 1177c4a5ef6eSThomas Moestl 1178c4a5ef6eSThomas Moestl /* 1179c4a5ef6eSThomas Moestl * current is the only mandatory field. 1180c4a5ef6eSThomas Moestl */ 1181c4a5ef6eSThomas Moestl if (current == NULL) { 1182c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1183c4a5ef6eSThomas Moestl "%s: current stats structure was NULL", func_name); 1184c4a5ef6eSThomas Moestl return(-1); 1185c4a5ef6eSThomas Moestl } 1186c4a5ef6eSThomas Moestl 1187c4a5ef6eSThomas Moestl totalbytesread = current->bytes_read - 1188c4a5ef6eSThomas Moestl ((previous) ? previous->bytes_read : 0); 1189c4a5ef6eSThomas Moestl totalbyteswrite = current->bytes_written - 1190c4a5ef6eSThomas Moestl ((previous) ? previous->bytes_written : 0); 1191c4a5ef6eSThomas Moestl 1192c4a5ef6eSThomas Moestl totalbytes = totalbytesread + totalbyteswrite; 1193c4a5ef6eSThomas Moestl 1194c4a5ef6eSThomas Moestl totaltransfersread = current->num_reads - 1195c4a5ef6eSThomas Moestl ((previous) ? previous->num_reads : 0); 1196c4a5ef6eSThomas Moestl 1197c4a5ef6eSThomas Moestl totaltransferswrite = current->num_writes - 1198c4a5ef6eSThomas Moestl ((previous) ? previous->num_writes : 0); 1199c4a5ef6eSThomas Moestl 1200c4a5ef6eSThomas Moestl totaltransfersother = current->num_other - 1201c4a5ef6eSThomas Moestl ((previous) ? previous->num_other : 0); 1202c4a5ef6eSThomas Moestl 1203c4a5ef6eSThomas Moestl totaltransfers = totaltransfersread + totaltransferswrite + 1204c4a5ef6eSThomas Moestl totaltransfersother; 1205c4a5ef6eSThomas Moestl 1206c4a5ef6eSThomas Moestl totalblocks = totalbytes; 1207c4a5ef6eSThomas Moestl totalblocksread = totalbytesread; 1208c4a5ef6eSThomas Moestl totalblockswrite = totalbyteswrite; 1209c4a5ef6eSThomas Moestl 1210c4a5ef6eSThomas Moestl if (current->block_size > 0) { 1211c4a5ef6eSThomas Moestl totalblocks /= current->block_size; 1212c4a5ef6eSThomas Moestl totalblocksread /= current->block_size; 1213c4a5ef6eSThomas Moestl totalblockswrite /= current->block_size; 1214c4a5ef6eSThomas Moestl } else { 1215c4a5ef6eSThomas Moestl totalblocks /= 512; 1216c4a5ef6eSThomas Moestl totalblocksread /= 512; 1217c4a5ef6eSThomas Moestl totalblockswrite /= 512; 1218c4a5ef6eSThomas Moestl } 1219c4a5ef6eSThomas Moestl 1220c4a5ef6eSThomas Moestl va_start(ap, etime); 1221c4a5ef6eSThomas Moestl 1222c4a5ef6eSThomas Moestl while ((metric = (devstat_metric)va_arg(ap, devstat_metric)) != 0) { 1223c4a5ef6eSThomas Moestl 1224c4a5ef6eSThomas Moestl if (metric == DSM_NONE) 1225c4a5ef6eSThomas Moestl break; 1226c4a5ef6eSThomas Moestl 1227c4a5ef6eSThomas Moestl if (metric >= DSM_MAX) { 1228c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1229c4a5ef6eSThomas Moestl "%s: metric %d is out of range", func_name, 1230c4a5ef6eSThomas Moestl metric); 1231c4a5ef6eSThomas Moestl retval = -1; 1232c4a5ef6eSThomas Moestl goto bailout; 1233c4a5ef6eSThomas Moestl } 1234c4a5ef6eSThomas Moestl 1235c4a5ef6eSThomas Moestl switch (devstat_arg_list[metric].argtype) { 1236c4a5ef6eSThomas Moestl case DEVSTAT_ARG_UINT64: 1237c4a5ef6eSThomas Moestl destu64 = (u_int64_t *)va_arg(ap, u_int64_t *); 1238c4a5ef6eSThomas Moestl break; 1239c4a5ef6eSThomas Moestl case DEVSTAT_ARG_LD: 1240c4a5ef6eSThomas Moestl destld = (long double *)va_arg(ap, long double *); 1241884539f7SKenneth D. Merry break; 1242884539f7SKenneth D. Merry case DEVSTAT_ARG_SKIP: 1243884539f7SKenneth D. Merry destld = (long double *)va_arg(ap, long double *); 1244c4a5ef6eSThomas Moestl break; 1245c4a5ef6eSThomas Moestl default: 1246c4a5ef6eSThomas Moestl retval = -1; 1247c4a5ef6eSThomas Moestl goto bailout; 1248c4a5ef6eSThomas Moestl break; /* NOTREACHED */ 1249c4a5ef6eSThomas Moestl } 1250c4a5ef6eSThomas Moestl 1251884539f7SKenneth D. Merry if (devstat_arg_list[metric].argtype == DEVSTAT_ARG_SKIP) 1252884539f7SKenneth D. Merry continue; 1253884539f7SKenneth D. Merry 1254c4a5ef6eSThomas Moestl switch (metric) { 1255c4a5ef6eSThomas Moestl case DSM_TOTAL_BYTES: 1256c4a5ef6eSThomas Moestl *destu64 = totalbytes; 1257c4a5ef6eSThomas Moestl break; 1258c4a5ef6eSThomas Moestl case DSM_TOTAL_BYTES_READ: 1259c4a5ef6eSThomas Moestl *destu64 = totalbytesread; 1260c4a5ef6eSThomas Moestl break; 1261c4a5ef6eSThomas Moestl case DSM_TOTAL_BYTES_WRITE: 1262c4a5ef6eSThomas Moestl *destu64 = totalbyteswrite; 1263c4a5ef6eSThomas Moestl break; 1264c4a5ef6eSThomas Moestl case DSM_TOTAL_TRANSFERS: 1265c4a5ef6eSThomas Moestl *destu64 = totaltransfers; 1266c4a5ef6eSThomas Moestl break; 1267c4a5ef6eSThomas Moestl case DSM_TOTAL_TRANSFERS_READ: 1268c4a5ef6eSThomas Moestl *destu64 = totaltransfersread; 1269c4a5ef6eSThomas Moestl break; 1270c4a5ef6eSThomas Moestl case DSM_TOTAL_TRANSFERS_WRITE: 1271c4a5ef6eSThomas Moestl *destu64 = totaltransferswrite; 1272c4a5ef6eSThomas Moestl break; 1273c4a5ef6eSThomas Moestl case DSM_TOTAL_TRANSFERS_OTHER: 1274c4a5ef6eSThomas Moestl *destu64 = totaltransfersother; 1275c4a5ef6eSThomas Moestl break; 1276c4a5ef6eSThomas Moestl case DSM_TOTAL_BLOCKS: 1277c4a5ef6eSThomas Moestl *destu64 = totalblocks; 1278c4a5ef6eSThomas Moestl break; 1279c4a5ef6eSThomas Moestl case DSM_TOTAL_BLOCKS_READ: 1280c4a5ef6eSThomas Moestl *destu64 = totalblocksread; 1281c4a5ef6eSThomas Moestl break; 1282c4a5ef6eSThomas Moestl case DSM_TOTAL_BLOCKS_WRITE: 1283c4a5ef6eSThomas Moestl *destu64 = totalblockswrite; 1284c4a5ef6eSThomas Moestl break; 1285c4a5ef6eSThomas Moestl case DSM_KB_PER_TRANSFER: 1286c4a5ef6eSThomas Moestl *destld = totalbytes; 1287c4a5ef6eSThomas Moestl *destld /= 1024; 1288c4a5ef6eSThomas Moestl if (totaltransfers > 0) 1289c4a5ef6eSThomas Moestl *destld /= totaltransfers; 1290c4a5ef6eSThomas Moestl else 1291c4a5ef6eSThomas Moestl *destld = 0.0; 1292c4a5ef6eSThomas Moestl break; 1293c4a5ef6eSThomas Moestl case DSM_KB_PER_TRANSFER_READ: 1294c4a5ef6eSThomas Moestl *destld = totalbytesread; 1295c4a5ef6eSThomas Moestl *destld /= 1024; 1296c4a5ef6eSThomas Moestl if (totaltransfersread > 0) 1297c4a5ef6eSThomas Moestl *destld /= totaltransfersread; 1298c4a5ef6eSThomas Moestl else 1299c4a5ef6eSThomas Moestl *destld = 0.0; 1300c4a5ef6eSThomas Moestl break; 1301c4a5ef6eSThomas Moestl case DSM_KB_PER_TRANSFER_WRITE: 1302c4a5ef6eSThomas Moestl *destld = totalbyteswrite; 1303c4a5ef6eSThomas Moestl *destld /= 1024; 1304c4a5ef6eSThomas Moestl if (totaltransferswrite > 0) 1305c4a5ef6eSThomas Moestl *destld /= totaltransferswrite; 1306c4a5ef6eSThomas Moestl else 1307c4a5ef6eSThomas Moestl *destld = 0.0; 1308c4a5ef6eSThomas Moestl break; 1309c4a5ef6eSThomas Moestl case DSM_TRANSFERS_PER_SECOND: 1310c4a5ef6eSThomas Moestl if (etime > 0.0) { 1311c4a5ef6eSThomas Moestl *destld = totaltransfers; 1312c4a5ef6eSThomas Moestl *destld /= etime; 1313c4a5ef6eSThomas Moestl } else 1314c4a5ef6eSThomas Moestl *destld = 0.0; 1315c4a5ef6eSThomas Moestl break; 1316c4a5ef6eSThomas Moestl case DSM_TRANSFERS_PER_SECOND_READ: 1317c4a5ef6eSThomas Moestl if (etime > 0.0) { 1318c4a5ef6eSThomas Moestl *destld = totaltransfersread; 1319c4a5ef6eSThomas Moestl *destld /= etime; 1320c4a5ef6eSThomas Moestl } else 1321c4a5ef6eSThomas Moestl *destld = 0.0; 1322c4a5ef6eSThomas Moestl break; 1323c4a5ef6eSThomas Moestl case DSM_TRANSFERS_PER_SECOND_WRITE: 1324c4a5ef6eSThomas Moestl if (etime > 0.0) { 1325c4a5ef6eSThomas Moestl *destld = totaltransferswrite; 1326c4a5ef6eSThomas Moestl *destld /= etime; 1327c4a5ef6eSThomas Moestl } else 1328c4a5ef6eSThomas Moestl *destld = 0.0; 1329c4a5ef6eSThomas Moestl break; 1330c4a5ef6eSThomas Moestl case DSM_TRANSFERS_PER_SECOND_OTHER: 1331c4a5ef6eSThomas Moestl if (etime > 0.0) { 1332c4a5ef6eSThomas Moestl *destld = totaltransfersother; 1333c4a5ef6eSThomas Moestl *destld /= etime; 1334c4a5ef6eSThomas Moestl } else 1335c4a5ef6eSThomas Moestl *destld = 0.0; 1336c4a5ef6eSThomas Moestl break; 1337c4a5ef6eSThomas Moestl case DSM_MB_PER_SECOND: 1338c4a5ef6eSThomas Moestl *destld = totalbytes; 1339c4a5ef6eSThomas Moestl *destld /= 1024 * 1024; 1340c4a5ef6eSThomas Moestl if (etime > 0.0) 1341c4a5ef6eSThomas Moestl *destld /= etime; 1342c4a5ef6eSThomas Moestl else 1343c4a5ef6eSThomas Moestl *destld = 0.0; 1344c4a5ef6eSThomas Moestl break; 1345c4a5ef6eSThomas Moestl case DSM_MB_PER_SECOND_READ: 1346c4a5ef6eSThomas Moestl *destld = totalbytesread; 1347c4a5ef6eSThomas Moestl *destld /= 1024 * 1024; 1348c4a5ef6eSThomas Moestl if (etime > 0.0) 1349c4a5ef6eSThomas Moestl *destld /= etime; 1350c4a5ef6eSThomas Moestl else 1351c4a5ef6eSThomas Moestl *destld = 0.0; 1352c4a5ef6eSThomas Moestl break; 1353c4a5ef6eSThomas Moestl case DSM_MB_PER_SECOND_WRITE: 1354c4a5ef6eSThomas Moestl *destld = totalbyteswrite; 1355c4a5ef6eSThomas Moestl *destld /= 1024 * 1024; 1356c4a5ef6eSThomas Moestl if (etime > 0.0) 1357c4a5ef6eSThomas Moestl *destld /= etime; 1358c4a5ef6eSThomas Moestl else 1359c4a5ef6eSThomas Moestl *destld = 0.0; 1360c4a5ef6eSThomas Moestl break; 1361c4a5ef6eSThomas Moestl case DSM_BLOCKS_PER_SECOND: 1362c4a5ef6eSThomas Moestl *destld = totalblocks; 1363c4a5ef6eSThomas Moestl if (etime > 0.0) 1364c4a5ef6eSThomas Moestl *destld /= etime; 1365c4a5ef6eSThomas Moestl else 1366c4a5ef6eSThomas Moestl *destld = 0.0; 1367c4a5ef6eSThomas Moestl break; 1368c4a5ef6eSThomas Moestl case DSM_BLOCKS_PER_SECOND_READ: 1369c4a5ef6eSThomas Moestl *destld = totalblocksread; 1370c4a5ef6eSThomas Moestl if (etime > 0.0) 1371c4a5ef6eSThomas Moestl *destld /= etime; 1372c4a5ef6eSThomas Moestl else 1373c4a5ef6eSThomas Moestl *destld = 0.0; 1374c4a5ef6eSThomas Moestl break; 1375c4a5ef6eSThomas Moestl case DSM_BLOCKS_PER_SECOND_WRITE: 1376c4a5ef6eSThomas Moestl *destld = totalblockswrite; 1377c4a5ef6eSThomas Moestl if (etime > 0.0) 1378c4a5ef6eSThomas Moestl *destld /= etime; 1379c4a5ef6eSThomas Moestl else 1380c4a5ef6eSThomas Moestl *destld = 0.0; 1381c4a5ef6eSThomas Moestl break; 1382c4a5ef6eSThomas Moestl /* 1383c4a5ef6eSThomas Moestl * This calculation is somewhat bogus. It simply divides 1384c4a5ef6eSThomas Moestl * the elapsed time by the total number of transactions 1385c4a5ef6eSThomas Moestl * completed. While that does give the caller a good 1386c4a5ef6eSThomas Moestl * picture of the average rate of transaction completion, 1387c4a5ef6eSThomas Moestl * it doesn't necessarily give the caller a good view of 1388c4a5ef6eSThomas Moestl * how long transactions took to complete on average. 1389c4a5ef6eSThomas Moestl * Those two numbers will be different for a device that 1390c4a5ef6eSThomas Moestl * can handle more than one transaction at a time. e.g. 1391c4a5ef6eSThomas Moestl * SCSI disks doing tagged queueing. 1392c4a5ef6eSThomas Moestl * 1393c4a5ef6eSThomas Moestl * The only way to accurately determine the real average 1394c4a5ef6eSThomas Moestl * time per transaction would be to compute and store the 1395c4a5ef6eSThomas Moestl * time on a per-transaction basis. That currently isn't 1396c4a5ef6eSThomas Moestl * done in the kernel, and would only be desireable if it 1397c4a5ef6eSThomas Moestl * could be implemented in a somewhat non-intrusive and high 1398c4a5ef6eSThomas Moestl * performance way. 1399c4a5ef6eSThomas Moestl */ 1400c4a5ef6eSThomas Moestl case DSM_MS_PER_TRANSACTION: 1401c4a5ef6eSThomas Moestl if (totaltransfers > 0) { 1402c4a5ef6eSThomas Moestl *destld = etime; 1403c4a5ef6eSThomas Moestl *destld /= totaltransfers; 1404c4a5ef6eSThomas Moestl *destld *= 1000; 1405c4a5ef6eSThomas Moestl } else 1406c4a5ef6eSThomas Moestl *destld = 0.0; 1407c4a5ef6eSThomas Moestl break; 1408c4a5ef6eSThomas Moestl /* 1409c4a5ef6eSThomas Moestl * As above, these next two really only give the average 1410c4a5ef6eSThomas Moestl * rate of completion for read and write transactions, not 1411c4a5ef6eSThomas Moestl * the average time the transaction took to complete. 1412c4a5ef6eSThomas Moestl */ 1413c4a5ef6eSThomas Moestl case DSM_MS_PER_TRANSACTION_READ: 1414c4a5ef6eSThomas Moestl if (totaltransfersread > 0) { 1415c4a5ef6eSThomas Moestl *destld = etime; 1416c4a5ef6eSThomas Moestl *destld /= totaltransfersread; 1417c4a5ef6eSThomas Moestl *destld *= 1000; 1418c4a5ef6eSThomas Moestl } else 1419c4a5ef6eSThomas Moestl *destld = 0.0; 1420c4a5ef6eSThomas Moestl break; 1421c4a5ef6eSThomas Moestl case DSM_MS_PER_TRANSACTION_WRITE: 1422c4a5ef6eSThomas Moestl if (totaltransferswrite > 0) { 1423c4a5ef6eSThomas Moestl *destld = etime; 1424c4a5ef6eSThomas Moestl *destld /= totaltransferswrite; 1425c4a5ef6eSThomas Moestl *destld *= 1000; 1426c4a5ef6eSThomas Moestl } else 1427c4a5ef6eSThomas Moestl *destld = 0.0; 1428c4a5ef6eSThomas Moestl break; 1429c4a5ef6eSThomas Moestl default: 1430c4a5ef6eSThomas Moestl /* 1431c4a5ef6eSThomas Moestl * This shouldn't happen, since we should have 1432c4a5ef6eSThomas Moestl * caught any out of range metrics at the top of 1433c4a5ef6eSThomas Moestl * the loop. 1434c4a5ef6eSThomas Moestl */ 1435c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1436c4a5ef6eSThomas Moestl "%s: unknown metric %d", func_name, metric); 1437c4a5ef6eSThomas Moestl retval = -1; 1438c4a5ef6eSThomas Moestl goto bailout; 1439c4a5ef6eSThomas Moestl break; /* NOTREACHED */ 1440c4a5ef6eSThomas Moestl } 1441c4a5ef6eSThomas Moestl } 1442c4a5ef6eSThomas Moestl 1443c4a5ef6eSThomas Moestl bailout: 1444c4a5ef6eSThomas Moestl 1445c4a5ef6eSThomas Moestl va_end(ap); 1446c4a5ef6eSThomas Moestl return(retval); 1447c4a5ef6eSThomas Moestl } 1448c4a5ef6eSThomas Moestl 1449c4a5ef6eSThomas Moestl static int 1450c4a5ef6eSThomas Moestl readkmem(kvm_t *kd, unsigned long addr, void *buf, size_t nbytes) 1451c4a5ef6eSThomas Moestl { 1452c4a5ef6eSThomas Moestl char *func_name = "readkmem"; 1453c4a5ef6eSThomas Moestl 1454c4a5ef6eSThomas Moestl if (kvm_read(kd, addr, buf, nbytes) == -1) { 1455c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1456c4a5ef6eSThomas Moestl "%s: error reading value (kvm_read): %s", func_name, 1457c4a5ef6eSThomas Moestl kvm_geterr(kd)); 1458c4a5ef6eSThomas Moestl return(-1); 1459c4a5ef6eSThomas Moestl } 1460c4a5ef6eSThomas Moestl return(0); 1461c4a5ef6eSThomas Moestl } 1462c4a5ef6eSThomas Moestl 1463c4a5ef6eSThomas Moestl static int 1464c4a5ef6eSThomas Moestl readkmem_nl(kvm_t *kd, char *name, void *buf, size_t nbytes) 1465c4a5ef6eSThomas Moestl { 1466c4a5ef6eSThomas Moestl char *func_name = "readkmem_nl"; 1467c4a5ef6eSThomas Moestl struct nlist nl[2] = { { name }, { NULL } }; 1468c4a5ef6eSThomas Moestl 1469c4a5ef6eSThomas Moestl if (kvm_nlist(kd, nl) == -1) { 1470c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1471c4a5ef6eSThomas Moestl "%s: error getting name list (kvm_nlist): %s", 1472c4a5ef6eSThomas Moestl func_name, kvm_geterr(kd)); 1473c4a5ef6eSThomas Moestl return(-1); 1474c4a5ef6eSThomas Moestl } 1475c4a5ef6eSThomas Moestl return(readkmem(kd, nl[0].n_value, buf, nbytes)); 1476c4a5ef6eSThomas Moestl } 1477c4a5ef6eSThomas Moestl 1478c4a5ef6eSThomas Moestl /* 1479c4a5ef6eSThomas Moestl * This duplicates the functionality of the kernel sysctl handler for poking 1480c4a5ef6eSThomas Moestl * through crash dumps. 1481c4a5ef6eSThomas Moestl */ 1482c4a5ef6eSThomas Moestl static char * 1483c4a5ef6eSThomas Moestl get_devstat_kvm(kvm_t *kd) 1484c4a5ef6eSThomas Moestl { 1485c4a5ef6eSThomas Moestl int error, i, wp; 1486c4a5ef6eSThomas Moestl long gen; 1487c4a5ef6eSThomas Moestl struct devstat *nds; 1488c4a5ef6eSThomas Moestl struct devstat ds; 1489c4a5ef6eSThomas Moestl struct devstatlist dhead; 1490c4a5ef6eSThomas Moestl int num_devs; 1491c4a5ef6eSThomas Moestl char *rv = NULL; 1492c4a5ef6eSThomas Moestl char *func_name = "get_devstat_kvm"; 1493c4a5ef6eSThomas Moestl 1494c4a5ef6eSThomas Moestl if ((num_devs = getnumdevs()) <= 0) 1495c4a5ef6eSThomas Moestl return(NULL); 1496c4a5ef6eSThomas Moestl error = 0; 1497c4a5ef6eSThomas Moestl if (KREADNL(kd, X_DEVICE_STATQ, dhead) == -1) 1498c4a5ef6eSThomas Moestl return(NULL); 1499c4a5ef6eSThomas Moestl 1500c4a5ef6eSThomas Moestl nds = STAILQ_FIRST(&dhead); 1501c4a5ef6eSThomas Moestl 1502c4a5ef6eSThomas Moestl if ((rv = malloc(sizeof(gen))) == NULL) { 1503c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1504c4a5ef6eSThomas Moestl "%s: out of memory (initial malloc failed)", 1505c4a5ef6eSThomas Moestl func_name); 1506c4a5ef6eSThomas Moestl return(NULL); 1507c4a5ef6eSThomas Moestl } 1508c4a5ef6eSThomas Moestl gen = getgeneration(); 1509c4a5ef6eSThomas Moestl memcpy(rv, &gen, sizeof(gen)); 1510c4a5ef6eSThomas Moestl wp = sizeof(gen); 1511c4a5ef6eSThomas Moestl /* 1512c4a5ef6eSThomas Moestl * Now push out all the devices. 1513c4a5ef6eSThomas Moestl */ 1514c4a5ef6eSThomas Moestl for (i = 0; (nds != NULL) && (i < num_devs); 1515c4a5ef6eSThomas Moestl nds = STAILQ_NEXT(nds, dev_links), i++) { 1516c4a5ef6eSThomas Moestl if (readkmem(kd, (long)nds, &ds, sizeof(ds)) == -1) { 1517c4a5ef6eSThomas Moestl free(rv); 1518c4a5ef6eSThomas Moestl return(NULL); 1519c4a5ef6eSThomas Moestl } 1520c4a5ef6eSThomas Moestl nds = &ds; 1521c4a5ef6eSThomas Moestl rv = (char *)reallocf(rv, sizeof(gen) + 1522c4a5ef6eSThomas Moestl sizeof(ds) * (i + 1)); 1523c4a5ef6eSThomas Moestl if (rv == NULL) { 1524c4a5ef6eSThomas Moestl snprintf(devstat_errbuf, sizeof(devstat_errbuf), 1525c4a5ef6eSThomas Moestl "%s: out of memory (malloc failed)", 1526c4a5ef6eSThomas Moestl func_name); 1527c4a5ef6eSThomas Moestl return(NULL); 1528c4a5ef6eSThomas Moestl } 1529c4a5ef6eSThomas Moestl memcpy(rv + wp, &ds, sizeof(ds)); 1530c4a5ef6eSThomas Moestl wp += sizeof(ds); 1531c4a5ef6eSThomas Moestl } 1532c4a5ef6eSThomas Moestl return(rv); 1533c4a5ef6eSThomas Moestl } 1534c4a5ef6eSThomas Moestl 1535c4a5ef6eSThomas Moestl /* 1536c4a5ef6eSThomas Moestl * Compatability functions for libdevstat 2. These are deprecated and may 1537c4a5ef6eSThomas Moestl * eventually be removed. 1538c4a5ef6eSThomas Moestl */ 1539c4a5ef6eSThomas Moestl int 1540c4a5ef6eSThomas Moestl getnumdevs(void) 1541c4a5ef6eSThomas Moestl { 1542c4a5ef6eSThomas Moestl return(devstat_getnumdevs(NULL)); 1543c4a5ef6eSThomas Moestl } 1544c4a5ef6eSThomas Moestl 1545c4a5ef6eSThomas Moestl long 1546c4a5ef6eSThomas Moestl getgeneration(void) 1547c4a5ef6eSThomas Moestl { 1548c4a5ef6eSThomas Moestl return(devstat_getgeneration(NULL)); 1549c4a5ef6eSThomas Moestl } 1550c4a5ef6eSThomas Moestl 1551c4a5ef6eSThomas Moestl int 1552c4a5ef6eSThomas Moestl getversion(void) 1553c4a5ef6eSThomas Moestl { 1554c4a5ef6eSThomas Moestl return(devstat_getversion(NULL)); 1555c4a5ef6eSThomas Moestl } 1556c4a5ef6eSThomas Moestl 1557c4a5ef6eSThomas Moestl int 1558c4a5ef6eSThomas Moestl checkversion(void) 1559c4a5ef6eSThomas Moestl { 1560c4a5ef6eSThomas Moestl return(devstat_checkversion(NULL)); 1561c4a5ef6eSThomas Moestl } 1562c4a5ef6eSThomas Moestl 1563c4a5ef6eSThomas Moestl int 1564c4a5ef6eSThomas Moestl getdevs(struct statinfo *stats) 1565c4a5ef6eSThomas Moestl { 1566c4a5ef6eSThomas Moestl return(devstat_getdevs(NULL, stats)); 1567c4a5ef6eSThomas Moestl } 1568c4a5ef6eSThomas Moestl 1569c4a5ef6eSThomas Moestl int 1570c4a5ef6eSThomas Moestl selectdevs(struct device_selection **dev_select, int *num_selected, 1571c4a5ef6eSThomas Moestl int *num_selections, long *select_generation, 1572c4a5ef6eSThomas Moestl long current_generation, struct devstat *devices, int numdevs, 1573c4a5ef6eSThomas Moestl struct devstat_match *matches, int num_matches, 1574c4a5ef6eSThomas Moestl char **dev_selections, int num_dev_selections, 1575c4a5ef6eSThomas Moestl devstat_select_mode select_mode, int maxshowdevs, 1576c4a5ef6eSThomas Moestl int perf_select) 1577c4a5ef6eSThomas Moestl { 1578c4a5ef6eSThomas Moestl 1579c4a5ef6eSThomas Moestl return(devstat_selectdevs(dev_select, num_selected, num_selections, 1580c4a5ef6eSThomas Moestl select_generation, current_generation, devices, numdevs, 1581c4a5ef6eSThomas Moestl matches, num_matches, dev_selections, num_dev_selections, 1582c4a5ef6eSThomas Moestl select_mode, maxshowdevs, perf_select)); 1583c4a5ef6eSThomas Moestl } 1584c4a5ef6eSThomas Moestl 1585c4a5ef6eSThomas Moestl int 1586c4a5ef6eSThomas Moestl buildmatch(char *match_str, struct devstat_match **matches, 1587c4a5ef6eSThomas Moestl int *num_matches) 1588c4a5ef6eSThomas Moestl { 1589c4a5ef6eSThomas Moestl return(devstat_buildmatch(match_str, matches, num_matches)); 1590c4a5ef6eSThomas Moestl } 1591c4a5ef6eSThomas Moestl 1592c4a5ef6eSThomas Moestl long double 1593c4a5ef6eSThomas Moestl compute_etime(struct timeval cur_time, struct timeval prev_time) 1594c4a5ef6eSThomas Moestl { 1595c4a5ef6eSThomas Moestl return(devstat_compute_etime(cur_time, prev_time)); 1596c4a5ef6eSThomas Moestl } 1597