#include <afsconfig.h>
#include <afs/param.h>
-RCSID("$Header$");
#include <sys/types.h>
#include <errno.h>
#include <sys/socket.h>
#include <sys/file.h>
#include <netdb.h>
+#include <arpa/inet.h>
#endif
#ifdef HAVE_NETINET_IN_H
#include <netinet/in.h>
#ifdef HAVE_UNISTD_H
#include <unistd.h>
#endif
-#ifdef HAVE_STRING_H
#include <string.h>
-#else
-#ifdef HAVE_STRINGS_H
-#include <strings.h>
-#endif
-#endif
#include <sys/stat.h>
+#include <afs/afsutil.h>
#include <afs/stds.h>
#include <afs/cmd.h>
#define TIMEOUT 20
-extern struct hostent *hostutil_GetHostByName();
-
-static short PortNumber(aport)
-register char *aport;
+static short
+PortNumber(char *aport)
{
register int tc;
register short total;
total = 0;
- while (tc = *aport++) {
- if (tc < '0' || tc > '9') return -1; /* bad port number */
+ while ((tc = *aport++)) {
+ if (tc < '0' || tc > '9')
+ return -1; /* bad port number */
total *= 10;
- total += tc - (int) '0';
+ total += tc - (int)'0';
}
return htons(total);
}
-static short PortName(aname)
-register char *aname;
+static short
+PortName(char *aname)
{
register struct servent *ts;
- ts = getservbyname(aname, (char *) 0);
- if (!ts) return -1;
- return ts->s_port; /* returns it in network byte order */
+ ts = getservbyname(aname, NULL);
+ if (!ts)
+ return -1;
+ return ts->s_port; /* returns it in network byte order */
}
-int MainCommand(as, arock)
-char *arock;
-struct cmd_syndesc *as;
+int
+MainCommand(struct cmd_syndesc *as, void *arock)
{
register int i;
- int s;
+ osi_socket s;
int j;
struct sockaddr_in taddr;
afs_int32 host;
int withRxStats;
int withWaiters;
int withIdleThreads;
+ int withWaited;
int withPeers;
+ int withPackets;
struct rx_debugStats tstats;
char *portName, *hostName;
+ char hoststr[20];
struct rx_debugConn tconn;
short noConns;
short showPeers;
+ short showLong;
int version_flag;
char version[64];
- afs_int32 length=64;
+ afs_int32 length = 64;
afs_uint32 supportedDebugValues = 0;
afs_uint32 supportedStatValues = 0;
afs_uint32 supportedPeerValues = 0;
afs_int32 nextconn = 0;
afs_int32 nextpeer = 0;
-
+
nodally = (as->parms[2].items ? 1 : 0);
allconns = (as->parms[3].items ? 1 : 0);
rxstats = (as->parms[4].items ? 1 : 0);
onlyServer = (as->parms[5].items ? 1 : 0);
onlyClient = (as->parms[6].items ? 1 : 0);
- version_flag=(as->parms[10].items ? 1 : 0);
+ version_flag = (as->parms[10].items ? 1 : 0);
noConns = (as->parms[11].items ? 1 : 0);
showPeers = (as->parms[12].items ? 1 : 0);
+ showLong = (as->parms[13].items ? 1 : 0);
if (as->parms[0].items)
hostName = as->parms[0].items->data;
else
- hostName = (char *) 0;
+ hostName = NULL;
if (as->parms[1].items)
portName = as->parms[1].items->data;
else
- portName = (char *) 0;
+ portName = NULL;
if (as->parms[7].items) {
char *name = as->parms[7].items->data;
printf("rxdebug: can't resolve port name %s\n", name);
exit(1);
}
- } else onlyPort = -1;
+ } else
+ onlyPort = -1;
if (as->parms[8].items) {
char *name = as->parms[8].items->data;
exit(1);
}
memcpy(&onlyHost, th->h_addr, sizeof(afs_int32));
- } else onlyHost = -1;
+ } else
+ onlyHost = -1;
if (as->parms[9].items) {
char *name = as->parms[9].items->data;
- if (strcmp (name, "clear") == 0) onlyAuth = 0;
- else if (strcmp (name, "auth") == 0) onlyAuth = 1;
- else if (strcmp (name, "crypt") == 0) onlyAuth = 2;
- else if ((strcmp (name, "null") == 0) ||
- (strcmp (name, "none") == 0) ||
- (strncmp (name, "noauth", 6) == 0) ||
- (strncmp (name, "unauth", 6) == 0)) onlyAuth = -1;
+ if (strcmp(name, "clear") == 0)
+ onlyAuth = 0;
+ else if (strcmp(name, "auth") == 0)
+ onlyAuth = 1;
+ else if (strcmp(name, "crypt") == 0)
+ onlyAuth = 2;
+ else if ((strcmp(name, "null") == 0) || (strcmp(name, "none") == 0)
+ || (strncmp(name, "noauth", 6) == 0)
+ || (strncmp(name, "unauth", 6) == 0))
+ onlyAuth = -1;
else {
- fprintf (stderr, "Unknown authentication level: %s\n", name);
- exit (1);
+ fprintf(stderr, "Unknown authentication level: %s\n", name);
+ exit(1);
}
- } else onlyAuth = 999;
+ } else
+ onlyAuth = 999;
/* lookup host */
if (hostName) {
exit(1);
}
memcpy(&host, th->h_addr, sizeof(afs_int32));
- }
- else host = htonl(0x7f000001); /* IP localhost */
+ } else
+ host = htonl(0x7f000001); /* IP localhost */
if (!portName)
- port = htons(7000); /* default is fileserver */
+ port = htons(7000); /* default is fileserver */
else {
if ((port = PortNumber(portName)) == -1)
port = PortName(portName);
}
}
- dallyCounter = 0;
+ dallyCounter = 0;
hostAddr.s_addr = host;
- printf("Trying %s (port %d):\n", inet_ntoa(hostAddr), ntohs(port));
+ afs_inet_ntoa_r(hostAddr.s_addr, hoststr);
+ printf("Trying %s (port %d):\n", hoststr, ntohs(port));
s = socket(AF_INET, SOCK_DGRAM, 0);
taddr.sin_family = AF_INET;
taddr.sin_port = 0;
taddr.sin_addr.s_addr = 0;
- code = bind(s, (struct sockaddr *) &taddr, sizeof(struct sockaddr_in));
+#ifdef STRUCT_SOCKADDR_HAS_SA_LEN
+ taddr.sin_len = sizeof(struct sockaddr_in);
+#endif
+ code = bind(s, (struct sockaddr *)&taddr, sizeof(struct sockaddr_in));
if (code) {
perror("bind");
exit(1);
}
- if(version_flag)
- {
-
- code = rx_GetServerVersion(s, host, port, length, version);
- if (code < 0)
- {
- printf("get version call failed with code %d, errno %d\n",
- code,errno);
- exit(1);
- }
- printf("AFS version: %s\n",version);fflush(stdout);
-
- exit(0);
+ if (version_flag) {
+ code = rx_GetServerVersion(s, host, port, length, version);
+ if (code < 0) {
+ printf("get version call failed with code %d, errno %d\n", code,
+ errno);
+ exit(1);
}
+ printf("AFS version: %s\n", version);
+ fflush(stdout);
+
+ exit(0);
+
+ }
+
-
code = rx_GetServerDebug(s, host, port, &tstats, &supportedDebugValues);
if (code < 0) {
printf("getstats call failed with code %d\n", code);
withRxStats = (supportedDebugValues & RX_SERVER_DEBUG_RX_STATS);
withWaiters = (supportedDebugValues & RX_SERVER_DEBUG_WAITER_CNT);
withIdleThreads = (supportedDebugValues & RX_SERVER_DEBUG_IDLE_THREADS);
+ withWaited = (supportedDebugValues & RX_SERVER_DEBUG_WAITED_CNT);
withPeers = (supportedDebugValues & RX_SERVER_DEBUG_ALL_PEER);
+ withPackets = (supportedDebugValues & RX_SERVER_DEBUG_PACKETS_CNT);
- printf("Free packets: %d, packet reclaims: %d, calls: %d, used FDs: %d\n",
- tstats.nFreePackets, tstats.packetReclaims,
- tstats.callsExecuted, tstats.usedFDs);
- if (!tstats.waitingForPackets) printf("not ");
+ if (withPackets)
+ printf("Free packets: %d/%d, packet reclaims: %d, calls: %d, used FDs: %d\n",
+ tstats.nFreePackets, tstats.nPackets, tstats.packetReclaims,
+ tstats.callsExecuted, tstats.usedFDs);
+ else
+ printf("Free packets: %d, packet reclaims: %d, calls: %d, used FDs: %d\n",
+ tstats.nFreePackets, tstats.packetReclaims, tstats.callsExecuted,
+ tstats.usedFDs);
+ if (!tstats.waitingForPackets)
+ printf("not ");
printf("waiting for packets.\n");
if (withWaiters)
- printf("%d calls waiting for a thread\n",tstats.nWaiting);
- if ( withIdleThreads )
- printf("%d threads are idle\n", tstats.idleThreads);
+ printf("%d calls waiting for a thread\n", tstats.nWaiting);
+ if (withIdleThreads)
+ printf("%d threads are idle\n", tstats.idleThreads);
+ if (withWaited)
+ printf("%d calls have waited for a thread\n", tstats.nWaited);
if (rxstats) {
if (!withRxStats) {
- noRxStats:
+ noRxStats:
withRxStats = 0;
- fprintf (stderr, "WARNING: Server doesn't support retrieval of Rx statistics\n");
- }
- else {
- struct rx_stats rxstats;
+ fprintf(stderr,
+ "WARNING: Server doesn't support retrieval of Rx statistics\n");
+ } else {
+ union {
+ struct rx_statistics rxstats;
+ struct rx_debugIn debug;
+ } packet;
/* should gracefully handle the case where rx_stats grows */
- code = rx_GetServerStats(s, host, port, &rxstats, &supportedStatValues);
+ code =
+ rx_GetServerStats(s, host, port, &packet.rxstats,
+ &supportedStatValues);
if (code < 0) {
printf("rxstats call failed with code %d\n", code);
exit(1);
}
- if (code != sizeof(rxstats)) {
- if ((((struct rx_debugIn *)(&rxstats))->type ==
- RX_DEBUGI_BADTYPE)) goto noRxStats;
- printf ("WARNING: returned Rx statistics of unexpected size (got %d)\n",
- code);
+ if (code != sizeof(packet.rxstats)) {
+ if (packet.debug.type == RX_DEBUGI_BADTYPE)
+ goto noRxStats;
+ printf
+ ("WARNING: returned Rx statistics of unexpected size (got %d)\n",
+ code);
/* handle other versions?... */
}
- rx_PrintTheseStats (stdout, &rxstats, sizeof(rxstats),
- tstats.nFreePackets, tstats.version);
+ rx_PrintTheseStats(stdout, &packet.rxstats, sizeof(packet.rxstats),
+ tstats.nFreePackets, tstats.version);
}
}
if (!noConns) {
if (allconns) {
- if (!withAllConn) fprintf (stderr, "WARNING: Server doesn't support retrieval of all connections,\n getting only interesting instead.\n");
+ if (!withAllConn)
+ fprintf(stderr,
+ "WARNING: Server doesn't support retrieval of all connections,\n getting only interesting instead.\n");
}
- if (onlyServer) printf ("Showing only server connections\n");
- if (onlyClient) printf ("Showing only client connections\n");
+ if (onlyServer)
+ printf("Showing only server connections\n");
+ if (onlyClient)
+ printf("Showing only client connections\n");
if (onlyAuth != 999) {
static char *name[] =
- {"unauthenticated", "rxkad_clear", "rxkad_auth", "rxkad_crypt"};
- printf ("Showing only %s connections\n", name[onlyAuth+1]);
+ { "unauthenticated", "rxkad_clear", "rxkad_auth",
+ "rxkad_crypt"
+ };
+ printf("Showing only %s connections\n", name[onlyAuth + 1]);
}
if (onlyHost != -1) {
hostAddr.s_addr = onlyHost;
- printf ("Showing only connections from host %s\n",
- inet_ntoa(hostAddr));
+ afs_inet_ntoa_r(hostAddr.s_addr, hoststr);
+ printf("Showing only connections from host %s\n",
+ hoststr);
}
if (onlyPort != -1)
- printf ("Showing only connections on port %u\n", ntohs(onlyPort));
+ printf("Showing only connections on port %u\n", ntohs(onlyPort));
- for(i=0;;i++) {
- code = rx_GetServerConnections(s, host, port, &nextconn, allconns,
- supportedDebugValues, &tconn,
- &supportedConnValues);
+ for (i = 0;; i++) {
+ code =
+ rx_GetServerConnections(s, host, port, &nextconn, allconns,
+ supportedDebugValues, &tconn,
+ &supportedConnValues);
if (code < 0) {
printf("getconn call failed with code %d\n", code);
break;
}
- if (tconn.cid == 0xffffffff) {
+ if (tconn.cid == (afs_int32) 0xffffffff) {
printf("Done.\n");
break;
}
/* see if we're in nodally mode and all calls are dallying */
if (nodally) {
flag = 0;
- for(j=0;j<RX_MAXCALLS;j++) {
- if (tconn.callState[j] != RX_STATE_NOTINIT &&
- tconn.callState[j] != RX_STATE_DALLY) {
+ for (j = 0; j < RX_MAXCALLS; j++) {
+ if (tconn.callState[j] != RX_STATE_NOTINIT
+ && tconn.callState[j] != RX_STATE_DALLY) {
flag = 1;
break;
}
continue;
}
}
- if ((onlyHost != -1) && (onlyHost != tconn.host)) continue;
- if ((onlyPort != -1) && (onlyPort != tconn.port)) continue;
- if (onlyServer && (tconn.type != RX_SERVER_CONNECTION)) continue;
- if (onlyClient && (tconn.type != RX_CLIENT_CONNECTION)) continue;
+ if ((onlyHost != -1) && (onlyHost != tconn.host))
+ continue;
+ if ((onlyPort != -1) && (onlyPort != tconn.port))
+ continue;
+ if (onlyServer && (tconn.type != RX_SERVER_CONNECTION))
+ continue;
+ if (onlyClient && (tconn.type != RX_CLIENT_CONNECTION))
+ continue;
if (onlyAuth != 999) {
if (onlyAuth == -1) {
- if (tconn.securityIndex != 0) continue;
+ if (tconn.securityIndex != 0)
+ continue;
} else {
- if (tconn.securityIndex != 2) continue;
- if (withSecStats && (tconn.secStats.type == 3) &&
- (tconn.secStats.level != onlyAuth)) continue;
+ if (tconn.securityIndex != 2)
+ continue;
+ if (withSecStats && (tconn.secStats.type == 3)
+ && (tconn.secStats.level != onlyAuth))
+ continue;
}
}
/* now display the connection */
hostAddr.s_addr = tconn.host;
- printf("Connection from host %s, port %hu, ",
- inet_ntoa(hostAddr), ntohs(tconn.port));
+ afs_inet_ntoa_r(hostAddr.s_addr, hoststr);
+ printf("Connection from host %s, port %hu, ", hoststr,
+ ntohs(tconn.port));
if (tconn.epoch)
- printf ("Cuid %x/%x", tconn.epoch, tconn.cid);
- else printf ("cid %x", tconn.cid);
- if (tconn.error) printf (", error %d", tconn.error);
+ printf("Cuid %x/%x", tconn.epoch, tconn.cid);
+ else
+ printf("cid %x", tconn.cid);
+ if (tconn.error)
+ printf(", error %d", tconn.error);
printf("\n serial %d, ", tconn.serial);
printf(" natMTU %d, ", tconn.natMTU);
if (tconn.flags) {
- printf ("flags");
+ printf("flags");
if (tconn.flags & RX_CONN_MAKECALL_WAITING)
printf(" MAKECALL_WAITING");
- if (tconn.flags & RX_CONN_DESTROY_ME) printf(" DESTROYED");
- if (tconn.flags & RX_CONN_USING_PACKET_CKSUM) printf(" pktCksum");
- printf (", ");
+ if (tconn.flags & RX_CONN_DESTROY_ME)
+ printf(" DESTROYED");
+ if (tconn.flags & RX_CONN_USING_PACKET_CKSUM)
+ printf(" pktCksum");
+ if (tconn.flags & RX_CONN_KNOW_WINDOW)
+ printf(" knowWindow");
+ if (tconn.flags & RX_CONN_RESET)
+ printf(" reset");
+ if (tconn.flags & RX_CONN_BUSY)
+ printf(" busy");
+ if (tconn.flags & RX_CONN_ATTACHWAIT)
+ printf(" attachWait");
+ printf(", ");
}
printf("security index %d, ", tconn.securityIndex);
- if (tconn.type == RX_CLIENT_CONNECTION) printf("client conn\n");
- else printf("server conn\n");
+ if (tconn.type == RX_CLIENT_CONNECTION)
+ printf("client conn\n");
+ else
+ printf("server conn\n");
if (withSecStats) {
switch ((int)tconn.secStats.type) {
- case 0:
+ case 0:
if (tconn.securityIndex == 2)
- printf (" no GetStats procedure for security object\n");
+ printf
+ (" no GetStats procedure for security object\n");
break;
- case 1:
- printf (" rxnull level=%d, flags=%d\n",
- tconn.secStats.level, tconn.secStats.flags);
+ case 1:
+ printf(" rxnull level=%d, flags=%d\n",
+ tconn.secStats.level, tconn.secStats.flags);
break;
- case 2:
- printf (" rxvab level=%d, flags=%d\n",
- tconn.secStats.level, tconn.secStats.flags);
+ case 2:
+ printf(" rxvab level=%d, flags=%d\n",
+ tconn.secStats.level, tconn.secStats.flags);
break;
- case 3: {
- char *level;
- char flags = tconn.secStats.flags;
- if (tconn.secStats.level == 0) level = "clear";
- else if (tconn.secStats.level == 1) level = "auth";
- else if (tconn.secStats.level == 2) level = "crypt";
- else level = "unknown";
- printf (" rxkad: level %s", level);
- if (flags) printf (", flags");
- if (flags & 1) printf (" unalloc");
- if (flags & 2) printf (" authenticated");
- if (flags & 4) printf (" expired");
- if (flags & 8) printf (" pktCksum");
- if (tconn.secStats.expires)
- /* Apparently due to a bug in the RT compiler that
- * prevents (afs_uint32)0xffffffff => (double) from working,
- * this code produces negative lifetimes when run on the
- * RT. */
- printf (", expires in %.1f hours",
- ((afs_uint32)tconn.secStats.expires -
- time(0)) / 3600.0);
- if (!(flags & 1)) {
- printf ("\n Received %d bytes in %d packets\n",
- tconn.secStats.bytesReceived,
- tconn.secStats.packetsReceived);
- printf (" Sent %d bytes in %d packets\n",
- tconn.secStats.bytesSent,
- tconn.secStats.packetsSent);
- } else printf ("\n");
- break;
- }
-
- default: printf(" unknown\n");
+ case 3:{
+ char *level;
+ char flags = tconn.secStats.flags;
+ if (tconn.secStats.level == 0)
+ level = "clear";
+ else if (tconn.secStats.level == 1)
+ level = "auth";
+ else if (tconn.secStats.level == 2)
+ level = "crypt";
+ else
+ level = "unknown";
+ printf(" rxkad: level %s", level);
+ if (flags)
+ printf(", flags");
+ if (flags & 1)
+ printf(" unalloc");
+ if (flags & 2)
+ printf(" authenticated");
+ if (flags & 4)
+ printf(" expired");
+ if (flags & 8)
+ printf(" pktCksum");
+ if (tconn.secStats.expires)
+ /* Apparently due to a bug in the RT compiler that
+ * prevents (afs_uint32)0xffffffff => (double) from working,
+ * this code produces negative lifetimes when run on the
+ * RT. */
+ printf(", expires in %.1f hours",
+ ((afs_uint32) tconn.secStats.expires -
+ time(0)) / 3600.0);
+ if (!(flags & 1)) {
+ printf("\n Received %u bytes in %u packets\n",
+ tconn.secStats.bytesReceived,
+ tconn.secStats.packetsReceived);
+ printf(" Sent %u bytes in %u packets\n",
+ tconn.secStats.bytesSent,
+ tconn.secStats.packetsSent);
+ } else
+ printf("\n");
+ break;
+ }
+
+ default:
+ printf(" unknown\n");
}
}
- for(j=0;j<RX_MAXCALLS;j++) {
+ for (j = 0; j < RX_MAXCALLS; j++) {
printf(" call %d: # %d, state ", j, tconn.callNumber[j]);
- if (tconn.callState[j]==RX_STATE_NOTINIT) {
+ if (tconn.callState[j] == RX_STATE_NOTINIT) {
printf("not initialized\n");
continue;
- }
- else if (tconn.callState[j]==RX_STATE_PRECALL)
+ } else if (tconn.callState[j] == RX_STATE_PRECALL)
printf("precall, ");
else if (tconn.callState[j] == RX_STATE_ACTIVE)
printf("active, ");
else if (tconn.callState[j] == RX_STATE_HOLD)
printf("hold, ");
printf("mode: ");
- if (tconn.callMode[j]==RX_MODE_SENDING)
+ if (tconn.callMode[j] == RX_MODE_SENDING)
printf("sending");
- else if (tconn.callMode[j]==RX_MODE_RECEIVING)
+ else if (tconn.callMode[j] == RX_MODE_RECEIVING)
printf("receiving");
- else if (tconn.callMode[j]==RX_MODE_ERROR)
+ else if (tconn.callMode[j] == RX_MODE_ERROR)
printf("error");
else if (tconn.callMode[j] == RX_MODE_EOF)
printf("eof");
- else printf("unknown");
+ else
+ printf("unknown");
if (tconn.callFlags[j]) {
printf(", flags:");
- if (tconn.callFlags[j]&RX_CALL_READER_WAIT)
+ if (tconn.callFlags[j] & RX_CALL_READER_WAIT)
printf(" reader_wait");
- if (tconn.callFlags[j]&RX_CALL_WAIT_WINDOW_ALLOC)
+ if (tconn.callFlags[j] & RX_CALL_WAIT_WINDOW_ALLOC)
printf(" window_alloc");
- if (tconn.callFlags[j]&RX_CALL_WAIT_WINDOW_SEND)
+ if (tconn.callFlags[j] & RX_CALL_WAIT_WINDOW_SEND)
printf(" window_send");
- if (tconn.callFlags[j]&RX_CALL_WAIT_PACKETS)
+ if (tconn.callFlags[j] & RX_CALL_WAIT_PACKETS)
printf(" wait_packets");
- if (tconn.callFlags[j]&RX_CALL_WAIT_PROC)
+ if (tconn.callFlags[j] & RX_CALL_WAIT_PROC)
printf(" waiting_for_process");
- if (tconn.callFlags[j]&RX_CALL_RECEIVE_DONE)
+ if (tconn.callFlags[j] & RX_CALL_RECEIVE_DONE)
printf(" receive_done");
- if (tconn.callFlags[j]&RX_CALL_CLEARED)
+ if (tconn.callFlags[j] & RX_CALL_CLEARED)
printf(" call_cleared");
}
if (tconn.callOther[j] & RX_OTHER_IN)
printf("\n");
}
}
- if (nodally) printf("Skipped %d dallying connections.\n", dallyCounter);
+ if (nodally)
+ printf("Skipped %d dallying connections.\n", dallyCounter);
}
if (showPeers && withPeers) {
- for(i=0;;i++) {
+ for (i = 0;; i++) {
struct rx_debugPeer tpeer;
- code = rx_GetServerPeers(s, host, port, &nextpeer, allconns, &tpeer, &supportedPeerValues);
+ code =
+ rx_GetServerPeers(s, host, port, &nextpeer, allconns, &tpeer,
+ &supportedPeerValues);
if (code < 0) {
printf("getpeer call failed with code %d\n", code);
break;
break;
}
- if ((onlyHost != -1) && (onlyHost != tpeer.host)) continue;
- if ((onlyPort != -1) && (onlyPort != tpeer.port)) continue;
+ if ((onlyHost != -1) && (onlyHost != tpeer.host))
+ continue;
+ if ((onlyPort != -1) && (onlyPort != tpeer.port))
+ continue;
/* now display the peer */
hostAddr.s_addr = tpeer.host;
- printf("Peer at host %s, port %hu\n",
- inet_ntoa(hostAddr), ntohs(tpeer.port));
- printf("\tifMTU %hu\tnatMTU %hu\tmaxMTU %hu\n",
- tpeer.ifMTU, tpeer.natMTU, tpeer.maxMTU);
- printf("\tpackets sent %d\tpacket resends %d\n",
- tpeer.nSent, tpeer.reSends);
- printf("\tbytes sent high %d low %d\n",
- tpeer.bytesSent.high, tpeer.bytesSent.low);
- printf("\tbytes received high %d low %d\n",
+ afs_inet_ntoa_r(hostAddr.s_addr, hoststr);
+ printf("Peer at host %s, port %hu\n", hoststr,
+ ntohs(tpeer.port));
+ printf("\tifMTU %hu\tnatMTU %hu\tmaxMTU %hu\n", tpeer.ifMTU,
+ tpeer.natMTU, tpeer.maxMTU);
+ printf("\tpackets sent %u\tpacket resends %u\n", tpeer.nSent,
+ tpeer.reSends);
+ printf("\tbytes sent high %u low %u\n", tpeer.bytesSent.high,
+ tpeer.bytesSent.low);
+ printf("\tbytes received high %u low %u\n",
tpeer.bytesReceived.high, tpeer.bytesReceived.low);
- printf("\trtt %d msec, rtt_dev %d msec\n",
- tpeer.rtt >> 3, tpeer.rtt_dev >> 2);
- printf("\ttimeout %d.%03d sec\n",
- tpeer.timeout.sec, tpeer.timeout.usec / 1000);
+ printf("\trtt %u msec, rtt_dev %u msec\n", tpeer.rtt >> 3,
+ tpeer.rtt_dev >> 2);
+ printf("\ttimeout %u.%03u sec\n", tpeer.timeout.sec,
+ tpeer.timeout.usec / 1000);
+ if (!showLong)
+ continue;
+
+ printf("\tin/out packet skew: %d/%d\n", tpeer.inPacketSkew,
+ tpeer.outPacketSkew);
+ printf("\tcongestion window %d, MTU %d\n", tpeer.cwind,
+ tpeer.MTU);
+ printf("\tcurrent/if/max jumbogram size: %d/%d/%d\n",
+ tpeer.nDgramPackets, tpeer.ifDgramPackets,
+ tpeer.maxDgramPackets);
}
}
exit(0);
#ifndef AFS_NT40_ENV
#include "AFS_component_version_number.c"
#endif
-int main(argc, argv)
-int argc;
-char **argv;
+int
+main(int argc, char **argv)
{
struct cmd_syndesc *ts;
+#ifdef RXDEBUG
+ rxi_DebugInit();
+#endif
#ifdef AFS_NT40_ENV
- if (afs_winsockInit()<0) {
+ if (afs_winsockInit() < 0) {
printf("%s: Couldn't initialize winsock. Exiting...\n", argv[0]);
- return 1;
+ return 1;
}
#endif
- ts = cmd_CreateSyntax((char *) 0, MainCommand, 0, "probe RX server");
+ ts = cmd_CreateSyntax(NULL, MainCommand, NULL, "probe RX server");
cmd_AddParm(ts, "-servers", CMD_SINGLE, CMD_REQUIRED, "server machine");
cmd_AddParm(ts, "-port", CMD_SINGLE, CMD_OPTIONAL, "IP port");
cmd_AddParm(ts, "-nodally", CMD_FLAG, CMD_OPTIONAL,
"only show server conns");
cmd_AddParm(ts, "-onlyclient", CMD_FLAG, CMD_OPTIONAL,
"only show client conns");
- cmd_AddParm(ts, "-onlyport", CMD_SINGLE, CMD_OPTIONAL, "show only <port>");
- cmd_AddParm(ts, "-onlyhost", CMD_SINGLE, CMD_OPTIONAL, "show only <host>");
+ cmd_AddParm(ts, "-onlyport", CMD_SINGLE, CMD_OPTIONAL,
+ "show only <port>");
+ cmd_AddParm(ts, "-onlyhost", CMD_SINGLE, CMD_OPTIONAL,
+ "show only <host>");
cmd_AddParm(ts, "-onlyauth", CMD_SINGLE, CMD_OPTIONAL,
"show only <auth level>");
- cmd_AddParm(ts,"-version",CMD_FLAG,CMD_OPTIONAL,"show AFS version id");
- cmd_AddParm(ts,"-noconns",CMD_FLAG,CMD_OPTIONAL,"show no connections");
- cmd_AddParm(ts,"-peers",CMD_FLAG,CMD_OPTIONAL,"show peers");
+ cmd_AddParm(ts, "-version", CMD_FLAG, CMD_OPTIONAL,
+ "show AFS version id");
+ cmd_AddParm(ts, "-noconns", CMD_FLAG, CMD_OPTIONAL,
+ "show no connections");
+ cmd_AddParm(ts, "-peers", CMD_FLAG, CMD_OPTIONAL, "show peers");
+ cmd_AddParm(ts, "-long", CMD_FLAG, CMD_OPTIONAL, "detailed output");
cmd_Dispatch(argc, argv);
exit(0);
git://git.openafs.org / openafs.git / blobdiff