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>
26 #include <rx/rxstat.h>
28 #include <afs/afs_Admin.h>
29 #include <afs/afs_clientAdmin.h>
30 #include <afs/afs_utilAdmin.h>
33 pthread_mutex_t des_init_mutex = PTHREAD_MUTEX_INITIALIZER;
34 pthread_mutex_t des_random_mutex = PTHREAD_MUTEX_INITIALIZER;
35 pthread_mutex_t rxkad_random_mutex = PTHREAD_MUTEX_INITIALIZER;
36 #endif /* AFS_DARWIN_ENV */
41 fprintf(stderr, "Usage: rxdebug_peers <host> <port>\n");
46 ParseArgs(int argc, char *argv[], char **srvrName, long *srvrPort)
52 *srvrName = *(argp++);
55 *srvrPort = strtol(*(argp++), NULL, 0);
56 if (*srvrPort <= 0 || *srvrPort >= 65536)
63 main(int argc, char *argv[])
67 rxdebugHandle_p handle;
71 struct rx_debugPeer peer;
72 afs_uint32 supportedValues;
75 ParseArgs(argc, argv, &srvrName, &srvrPort);
77 rc = afsclient_Init(&st);
79 fprintf(stderr, "afsclient_Init, status %d\n", st);
83 rc = afsclient_RXDebugOpenPort(srvrName, srvrPort, &handle, &st);
85 fprintf(stderr, "afsclient_RXDebugOpenPort, status %d\n", st);
89 rc = util_RXDebugPeersBegin(handle, &iterator, &st);
91 fprintf(stderr, "util_RXDebugPeersBegin, status %d\n", st);
95 while (util_RXDebugPeersNext(iterator, &peer, &supportedValues, &st)) {
97 printf("host: %u.%u.%u.%u\n", (peer.host >> 24) & 0xff,
98 (peer.host >> 16) & 0xff, (peer.host >> 8) & 0xff,
100 printf("port: %u\n", peer.port);
101 printf("ifMTU: %u\n", peer.ifMTU);
102 printf("idleWhen: %u\n", peer.idleWhen);
103 printf("refCount: %u\n", peer.refCount);
104 printf("burstSize: %u\n", peer.burstSize);
105 printf("burst: %u\n", peer.burst);
106 printf("burstWait: %u\n", peer.burstWait);
107 printf("rtt: %u\n", peer.rtt);
108 printf("rtt_dev: %u\n", peer.rtt_dev);
109 printf("timeout: %u.%06u\n", peer.timeout.sec,
111 printf("nSent: %u\n", peer.nSent);
112 printf("reSends: %u\n", peer.reSends);
113 printf("inPacketSkew: %u\n", peer.inPacketSkew);
114 printf("outPacketSkew: %u\n", peer.outPacketSkew);
115 printf("rateFlag: %u\n", peer.rateFlag);
116 printf("natMTU: %u\n", peer.natMTU);
117 printf("maxMTU: %u\n", peer.maxMTU);
118 printf("maxDgramPackets: %u\n", peer.maxDgramPackets);
119 printf("ifDgramPackets: %u\n", peer.ifDgramPackets);
120 printf("MTU: %u\n", peer.MTU);
121 printf("cwind: %u\n", peer.cwind);
122 printf("nDgramPackets: %u\n", peer.nDgramPackets);
123 printf("congestSeq: %u\n", peer.congestSeq);
124 printf("bytesSent: (%u.%u)\n", hgethi(peer.bytesSent),
125 hgetlo(peer.bytesSent));
126 printf("bytesReceived: (%u.%u)\n", hgethi(peer.bytesReceived),
127 hgetlo(peer.bytesReceived));
129 if (st != ADMITERATORDONE) {
130 fprintf(stderr, "util_RXDebugPeersNext, status %d\n", st);
135 rc = util_RXDebugPeersDone(iterator, &st);
137 fprintf(stderr, "util_RXDebugPeersDone, status %d\n", st);
141 rc = afsclient_RXDebugClose(handle, &st);
143 fprintf(stderr, "afsclient_RXDebugClose, status %d\n", st);