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;
74 ParseArgs(argc, argv, &srvrName, &srvrPort);
76 rc = afsclient_Init(&st);
78 fprintf(stderr, "afsclient_Init, status %d\n", st);
82 rc = afsclient_RXDebugOpenPort(srvrName, srvrPort, &handle, &st);
84 fprintf(stderr, "afsclient_RXDebugOpenPort, status %d\n", st);
88 rc = util_RXDebugPeersBegin(handle, &iterator, &st);
90 fprintf(stderr, "util_RXDebugPeersBegin, status %d\n", st);
94 while (util_RXDebugPeersNext(iterator, &peer, &supportedValues, &st)) {
96 printf("host: %u.%u.%u.%u\n", (peer.host >> 24) & 0xff,
97 (peer.host >> 16) & 0xff, (peer.host >> 8) & 0xff,
99 printf("port: %u\n", peer.port);
100 printf("ifMTU: %u\n", peer.ifMTU);
101 printf("idleWhen: %u\n", peer.idleWhen);
102 printf("refCount: %u\n", peer.refCount);
103 printf("burstSize: %u\n", peer.burstSize);
104 printf("burst: %u\n", peer.burst);
105 printf("burstWait: %u\n", peer.burstWait);
106 printf("rtt: %u\n", peer.rtt);
107 printf("rtt_dev: %u\n", peer.rtt_dev);
108 printf("timeout: %u.%06u\n", peer.timeout.sec,
110 printf("nSent: %u\n", peer.nSent);
111 printf("reSends: %u\n", peer.reSends);
112 printf("inPacketSkew: %u\n", peer.inPacketSkew);
113 printf("outPacketSkew: %u\n", peer.outPacketSkew);
114 printf("rateFlag: %u\n", peer.rateFlag);
115 printf("natMTU: %u\n", peer.natMTU);
116 printf("maxMTU: %u\n", peer.maxMTU);
117 printf("maxDgramPackets: %u\n", peer.maxDgramPackets);
118 printf("ifDgramPackets: %u\n", peer.ifDgramPackets);
119 printf("MTU: %u\n", peer.MTU);
120 printf("cwind: %u\n", peer.cwind);
121 printf("nDgramPackets: %u\n", peer.nDgramPackets);
122 printf("congestSeq: %u\n", peer.congestSeq);
123 printf("bytesSent: (%u.%u)\n", hgethi(peer.bytesSent),
124 hgetlo(peer.bytesSent));
125 printf("bytesReceived: (%u.%u)\n", hgethi(peer.bytesReceived),
126 hgetlo(peer.bytesReceived));
128 if (st != ADMITERATORDONE) {
129 fprintf(stderr, "util_RXDebugPeersNext, status %d\n", st);
134 rc = util_RXDebugPeersDone(iterator, &st);
136 fprintf(stderr, "util_RXDebugPeersDone, status %d\n", st);
140 rc = afsclient_RXDebugClose(handle, &st);
142 fprintf(stderr, "afsclient_RXDebugClose, status %d\n", st);