2 * Copyright 2000, International Business Machines Corporation and others.
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
9 * Portions Copyright (c) 2003 Apple Computer, Inc.
13 * This file contains sample code for the rxstats interface
16 #include <afsconfig.h>
17 #include <afs/param.h>
19 #ifdef IGNORE_SOME_GCC_WARNINGS
20 # pragma GCC diagnostic warning "-Wformat"
30 #include <rx/rxstat.h>
32 #include <afs/afs_Admin.h>
33 #include <afs/afs_clientAdmin.h>
34 #include <afs/afs_utilAdmin.h>
37 pthread_mutex_t des_init_mutex = PTHREAD_MUTEX_INITIALIZER;
38 pthread_mutex_t des_random_mutex = PTHREAD_MUTEX_INITIALIZER;
39 pthread_mutex_t rxkad_random_mutex = PTHREAD_MUTEX_INITIALIZER;
40 #endif /* AFS_DARWIN_ENV */
45 fprintf(stderr, "Usage: rxdebug_peers <host> <port>\n");
50 ParseArgs(int argc, char *argv[], char **srvrName, long *srvrPort)
56 *srvrName = *(argp++);
59 *srvrPort = strtol(*(argp++), NULL, 0);
60 if (*srvrPort <= 0 || *srvrPort >= 65536)
67 main(int argc, char *argv[])
71 rxdebugHandle_p handle;
75 struct rx_debugPeer peer;
76 afs_uint32 supportedValues;
78 ParseArgs(argc, argv, &srvrName, &srvrPort);
80 rc = afsclient_Init(&st);
82 fprintf(stderr, "afsclient_Init, status %d\n", st);
86 rc = afsclient_RXDebugOpenPort(srvrName, srvrPort, &handle, &st);
88 fprintf(stderr, "afsclient_RXDebugOpenPort, status %d\n", st);
92 rc = util_RXDebugPeersBegin(handle, &iterator, &st);
94 fprintf(stderr, "util_RXDebugPeersBegin, status %d\n", st);
98 while (util_RXDebugPeersNext(iterator, &peer, &supportedValues, &st)) {
100 printf("host: %u.%u.%u.%u\n", (peer.host >> 24) & 0xff,
101 (peer.host >> 16) & 0xff, (peer.host >> 8) & 0xff,
103 printf("port: %u\n", peer.port);
104 printf("ifMTU: %u\n", peer.ifMTU);
105 printf("idleWhen: %u\n", peer.idleWhen);
106 printf("refCount: %u\n", peer.refCount);
107 printf("burstSize: %u\n", peer.burstSize);
108 printf("burst: %u\n", peer.burst);
109 printf("burstWait: %u\n", peer.burstWait);
110 printf("rtt: %u\n", peer.rtt);
111 printf("rtt_dev: %u\n", peer.rtt_dev);
112 printf("timeout: %u.%06u\n", peer.timeout.sec,
114 printf("nSent: %u\n", peer.nSent);
115 printf("reSends: %u\n", peer.reSends);
116 printf("inPacketSkew: %u\n", peer.inPacketSkew);
117 printf("outPacketSkew: %u\n", peer.outPacketSkew);
118 printf("rateFlag: %u\n", peer.rateFlag);
119 printf("natMTU: %u\n", peer.natMTU);
120 printf("maxMTU: %u\n", peer.maxMTU);
121 printf("maxDgramPackets: %u\n", peer.maxDgramPackets);
122 printf("ifDgramPackets: %u\n", peer.ifDgramPackets);
123 printf("MTU: %u\n", peer.MTU);
124 printf("cwind: %u\n", peer.cwind);
125 printf("nDgramPackets: %u\n", peer.nDgramPackets);
126 printf("congestSeq: %u\n", peer.congestSeq);
127 printf("bytesSent: (%u.%u)\n", hgethi(peer.bytesSent),
128 hgetlo(peer.bytesSent));
129 printf("bytesReceived: (%u.%u)\n", hgethi(peer.bytesReceived),
130 hgetlo(peer.bytesReceived));
132 if (st != ADMITERATORDONE) {
133 fprintf(stderr, "util_RXDebugPeersNext, status %d\n", st);
138 rc = util_RXDebugPeersDone(iterator, &st);
140 fprintf(stderr, "util_RXDebugPeersDone, status %d\n", st);
144 rc = afsclient_RXDebugClose(handle, &st);
146 fprintf(stderr, "afsclient_RXDebugClose, status %d\n", st);