src/libadmin/samples/rxdebug_conns.c

   1 /*
   2  * Copyright 2000, International Business Machines Corporation and others.
   3  * All Rights Reserved.
   4  *
   5  * This software has been released under the terms of the IBM Public
   6  * License.  For details, see the LICENSE file in the top-level source
   7  * directory or online at http://www.openafs.org/dl/license10.html
   8  */
   9
  10 /*
  11  * This file contains sample code for the rxstats interface
  12  */
  13
  14 #include <afsconfig.h>
  15 #include <afs/param.h>
  16
  17 RCSID
  18     ("$Header$");
  19
  20 #ifdef AFS_NT40_ENV
  21 #include <winsock2.h>
  22 #include <pthread.h>
  23 #endif
  24 #include <afs/afs_Admin.h>
  25 #include <afs/afs_clientAdmin.h>
  26 #include <afs/afs_utilAdmin.h>
  27
  28 void
  29 Usage()
  30 {
  31     fprintf(stderr, "Usage: rxdebug_conns <host> <port>\n");
  32     exit(1);
  33 }
  34
  35 void
  36 ParseArgs(int argc, char *argv[], char **srvrName, long *srvrPort)
  37 {
  38     char **argp = argv;
  39
  40     if (!*(++argp))
  41         Usage();
  42     *srvrName = *(argp++);
  43     if (!*(argp))
  44         Usage();
  45     *srvrPort = strtol(*(argp++), NULL, 0);
  46     if (*srvrPort <= 0 || *srvrPort >= 65536)
  47         Usage();
  48     if (*(argp))
  49         Usage();
  50 }
  51
  52 int
  53 main(int argc, char *argv[])
  54 {
  55     int rc;
  56     afs_status_t st = 0;
  57     rxdebugHandle_p handle;
  58     char *srvrName;
  59     long srvrPort;
  60     void *iterator;
  61     struct rx_debugConn conn;
  62     afs_uint32 supportedStats;
  63     afs_uint32 supportedValues;
  64     int allconns;
  65     int i;
  66
  67     ParseArgs(argc, argv, &srvrName, &srvrPort);
  68
  69     rc = afsclient_Init(&st);
  70     if (!rc) {
  71         fprintf(stderr, "afsclient_Init, status %d\n", st);
  72         exit(1);
  73     }
  74
  75     rc = afsclient_RXDebugOpenPort(srvrName, srvrPort, &handle, &st);
  76     if (!rc) {
  77         fprintf(stderr, "afsclient_RXDebugOpenPort, status %d\n", st);
  78         exit(1);
  79     }
  80
  81     rc = util_RXDebugSupportedStats(handle, &supportedStats, &st);
  82     if (!rc) {
  83         fprintf(stderr, "util_RXDebugSupportedStats, status %d\n", st);
  84         exit(1);
  85     }
  86
  87     rc = util_RXDebugConnectionsBegin(handle, allconns, &iterator, &st);
  88     if (!rc && st == ADMCLIENTRXDEBUGNOTSUPPORTED) {
  89         allconns = 0;
  90         rc = util_RXDebugConnectionsBegin(handle, allconns, &iterator, &st);
  91     }
  92     if (!rc) {
  93         fprintf(stderr, "util_RXDebugConnectionsBegin, status %d\n", st);
  94         exit(1);
  95     }
  96
  97     printf("\n");
  98     if (allconns) {
  99         printf("Listing all connections for server %s (port %d)\n", srvrName,
 100                srvrPort);
 101     } else {
 102         printf
 103             ("Listing only interesting connections for server %s (port %d)\n",
 104              srvrName, srvrPort);
 105     }
 106
 107     while (util_RXDebugConnectionsNext
 108            (iterator, &conn, &supportedValues, &st)) {
 109         printf("\n");
 110         printf("host:                     %u.%u.%u.%u\n",
 111                (conn.host >> 24) & 0xff, (conn.host >> 16) & 0xff,
 112                (conn.host >> 8) & 0xff, conn.host & 0xff);
 113         printf("cid:                      %08x\n", conn.cid);
 114         printf("serial:                   %08x\n", conn.serial);
 115         printf("error:                    %u\n", conn.error);
 116         printf("port:                     %u\n", conn.port);
 117         printf("flags:                    %x\n", conn.flags);
 118         printf("type:                     %u\n", conn.type);
 119         printf("securityIndex:            %u\n", conn.securityIndex);
 120         for (i = 0; i < RX_MAXCALLS; i++) {
 121             printf("callNumber[%u]:            %u\n", i, conn.callNumber[i]);
 122             printf("callState[%u]:             %u\n", i, conn.callState[i]);
 123             printf("callMode[%u]:              %u\n", i, conn.callMode[i]);
 124             printf("callFlags[%u]:             %x\n", i, conn.callFlags[i]);
 125             printf("callOther[%u]:             %x\n", i, conn.callOther[i]);
 126         }
 127         if (supportedStats & RX_SERVER_DEBUG_SEC_STATS) {
 128             printf("secStats.type:            %u\n", conn.secStats.type);
 129             printf("secStats.level:           %u\n", conn.secStats.level);
 130             printf("secStats.flags:           %x\n", conn.secStats.flags);
 131             printf("secStats.expires:         %x\n", conn.secStats.expires);
 132             printf("secStats.packetsReceived: %x\n",
 133                    conn.secStats.packetsReceived);
 134             printf("secStats.packetsSent:     %x\n",
 135                    conn.secStats.packetsSent);
 136             printf("secStats.bytesReceived:   %x\n",
 137                    conn.secStats.bytesReceived);
 138             printf("secStats.bytesSent:       %x\n", conn.secStats.bytesSent);
 139             printf("natMTU:                   %u\n", conn.natMTU);
 140             printf("epoch:                    %08x\n", conn.epoch);
 141         }
 142     }
 143     if (st != ADMITERATORDONE) {
 144         fprintf(stderr, "util_RXDebugConnectionsNext, status %d\n", st);
 145         exit(1);
 146     }
 147     printf("\n");
 148
 149     rc = util_RXDebugConnectionsDone(iterator, &st);
 150     if (!rc) {
 151         fprintf(stderr, "util_RXDebugConnectionsDone, status %d\n", st);
 152         exit(1);
 153     }
 154
 155     rc = afsclient_RXDebugClose(handle, &st);
 156     if (!rc) {
 157         fprintf(stderr, "afsclient_RXDebugClose, status %d\n", st);
 158         exit(1);
 159     }
 160
 161     exit(0);
 162 }