amd64-udebug-20050621
[openafs.git] / src / ubik / udebug.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 #include <afsconfig.h>
11 #include <afs/param.h>
12
13 RCSID
14     ("$Header$");
15
16 #include <sys/types.h>
17 #include <stdlib.h>
18 #ifdef HAVE_STRING_H
19 #include <string.h>
20 #else
21 #ifdef HAVE_STRINGS_H
22 #include <strings.h>
23 #endif
24 #endif
25 #ifdef AFS_NT40_ENV
26 #include <winsock2.h>
27 #else
28 #include <sys/file.h>
29 #include <sys/param.h>
30 #include <netinet/in.h>
31 #include <netdb.h>
32 #endif
33 #ifdef HAVE_UNISTD_H
34 #include <unistd.h>
35 #endif
36 #include <signal.h>
37 #include <afs/afsutil.h>
38 #include <time.h>
39
40 #include <lock.h>
41 #include <rx/xdr.h>
42 #include <rx/rx.h>
43 #include <afs/cmd.h>
44
45 #define UBIK_INTERNALS
46 #include "ubik.h"
47 #include "ubik_int.h"
48
49 /* needed by Irix. Include a header to get it, or leave it alone. */
50 extern struct hostent *hostutil_GetHostByName();
51
52 static short
53 PortNumber(register char *aport)
54 {
55     register int tc;
56     register afs_int32 total;
57
58     total = 0;
59     while ((tc = *aport++)) {
60         if (tc < '0' || tc > '9')
61             return -1;          /* bad port number */
62         total *= 10;
63         total += tc - (int)'0';
64     }
65     return (total);
66 }
67
68 static short
69 PortName(char *aname)
70 {
71     struct servent *ts;
72     int len;
73
74     ts = getservbyname(aname, NULL);
75
76     if (ts)
77         return ntohs(ts->s_port);       /* returns it in host byte order */
78
79     len = strlen(aname);
80     if (strncmp(aname, "vlserver", len) == 0) {
81         return 7003;
82     } else if (strncmp(aname, "ptserver", len) == 0) {
83         return 7002;
84     } else if (strncmp(aname, "kaserver", len) == 0) {
85         return 7004;
86     } else if (strncmp(aname, "buserver", len) == 0) {
87         return 7021;
88     }
89     return (-1);
90 }
91
92 static int
93 CommandProc(struct cmd_syndesc *as, char *arock)
94 {
95     char *hostName, *portName, *times;
96     afs_int32 hostAddr;
97     register afs_int32 i, j, code;
98     short port;
99     int int32p;
100     time_t now, then, diff, newtime;
101     struct hostent *th;
102     struct rx_connection *tconn;
103     struct rx_securityClass *sc;
104     struct ubik_debug udebug;
105     struct ubik_sdebug usdebug;
106     int oldServer = 0;          /* are we talking to a pre 3.5 server? */
107     afs_int32 isClone = 0;
108
109     int32p = (as->parms[2].items ? 1 : 0);
110
111     if (as->parms[0].items)
112         hostName = as->parms[0].items->data;
113     else
114         hostName = NULL;
115
116     if (as->parms[1].items)
117         portName = as->parms[1].items->data;
118     else
119         portName = NULL;
120
121     /* lookup host */
122     if (hostName) {
123         th = hostutil_GetHostByName(hostName);
124         if (!th) {
125             printf("udebug: host %s not found in host table\n", hostName);
126             exit(1);
127         }
128         memcpy(&hostAddr, th->h_addr, sizeof(afs_int32));
129     } else
130         hostAddr = htonl(0x7f000001);   /* IP localhost */
131
132     if (!portName)
133         port = htons(3000);     /* default */
134     else {
135         port = PortNumber(portName);
136         if (port < 0)
137             port = PortName(portName);
138         if (port < 0) {
139             printf("udebug: can't resolve port name %s\n", portName);
140             exit(1);
141         }
142         port = htons(port);
143     }
144
145     rx_Init(0);
146     sc = rxnull_NewClientSecurityObject();
147     tconn = rx_NewConnection(hostAddr, port, VOTE_SERVICE_ID, sc, 0);
148
149     /* now do the main call */
150     code = VOTE_XDebug(tconn, &udebug, &isClone);
151     if (code)
152         code = VOTE_Debug(tconn, &udebug);
153     if (code == RXGEN_OPCODE) {
154         oldServer = 1;          /* talking to a pre 3.5 server */
155         memset(&udebug, 0, sizeof(udebug));
156         code = VOTE_DebugOld(tconn, &udebug);
157     }
158
159     if (code) {
160         printf("return code %d from VOTE_Debug\n", code);
161         exit(0);
162     }
163     now = time(0);
164     then = udebug.now;
165
166     /* now print the main info */
167     times = ctime(&then);
168     times[24] = 0;
169     if (!oldServer) {
170         printf("Host's addresses are: ");
171         for (j = 0; udebug.interfaceAddr[j] && (j < UBIK_MAX_INTERFACE_ADDR);
172              j++)
173             printf("%s ", afs_inet_ntoa(htonl(udebug.interfaceAddr[j])));
174         printf("\n");
175     }
176     printf("Host's %s time is %s\n", afs_inet_ntoa(hostAddr), times);
177
178     times = ctime(&now);
179     times[24] = 0;
180     diff = now - udebug.now;
181     printf("Local time is %s (time differential %d secs)\n", times, diff);
182     if (abs(diff) >= MAXSKEW)
183         printf("****clock may be bad\n");
184
185     /* UBIK skips the voting if 1 server - so we fudge it here */
186     if (udebug.amSyncSite && (udebug.nServers == 1)) {
187         udebug.lastYesHost = hostAddr;
188         udebug.lastYesTime = udebug.now;
189         udebug.lastYesState = 1;
190         udebug.lastYesClaim = udebug.now;
191         udebug.syncVersion.epoch = udebug.localVersion.epoch;
192         udebug.syncVersion.counter = udebug.localVersion.counter;
193     }
194
195     /* sockaddr is always in net-order */
196     if (udebug.lastYesHost == 0xffffffff) {
197         printf("Last yes vote not cast yet \n");
198     } else {
199         diff = udebug.now - udebug.lastYesTime;
200         printf("Last yes vote for %s was %d secs ago (%ssync site); \n",
201                afs_inet_ntoa(htonl(udebug.lastYesHost)), diff,
202                ((udebug.lastYesState) ? "" : "not "));
203
204         diff = udebug.now - udebug.lastYesClaim;
205         newtime = now - diff;
206         times = ctime(&newtime);
207         times[24] = 0;
208         printf("Last vote started %d secs ago (at %s)\n", diff, times);
209     }
210
211     printf("Local db version is %d.%d\n", udebug.localVersion.epoch,
212            udebug.localVersion.counter);
213
214     if (udebug.amSyncSite) {
215         if (udebug.syncSiteUntil == 0x7fffffff) {
216             printf("I am sync site forever (%d server%s)\n", udebug.nServers,
217                    ((udebug.nServers > 1) ? "s" : ""));
218         } else {
219             diff = udebug.syncSiteUntil - udebug.now;
220             newtime = now + diff;
221             times = ctime(&newtime);
222             times[24] = 0;
223             printf
224                 ("I am sync site until %d secs from now (at %s) (%d server%s)\n",
225                  diff, times, udebug.nServers,
226                  ((udebug.nServers > 1) ? "s" : ""));
227         }
228         printf("Recovery state %x\n", udebug.recoveryState);
229         if (udebug.activeWrite) {
230             printf("I am currently managing write trans %d.%d\n",
231                    udebug.epochTime, udebug.tidCounter);
232         }
233     } else {
234         if (isClone)
235             printf("I am a clone and never can become sync site\n");
236         else
237             printf("I am not sync site\n");
238         diff = udebug.now - udebug.lowestTime;
239         printf("Lowest host %s was set %d secs ago\n",
240                afs_inet_ntoa(htonl(udebug.lowestHost)),
241                diff);
242
243         diff = udebug.now - udebug.syncTime;
244         printf("Sync host %s was set %d secs ago\n",
245                afs_inet_ntoa(htonl(udebug.syncHost)),
246                diff);
247     }
248
249     printf("Sync site's db version is %d.%d\n", udebug.syncVersion.epoch,
250            udebug.syncVersion.counter);
251     printf("%d locked pages, %d of them for write\n", udebug.lockedPages,
252            udebug.writeLockedPages);
253
254     if (udebug.anyReadLocks)
255         printf("There are read locks held\n");
256     if (udebug.anyWriteLocks)
257         printf("There are write locks held\n");
258
259     if (udebug.currentTrans) {
260         if (udebug.writeTrans)
261             printf("There is an active write transaction\n");
262         else
263             printf("There is at least one active read transaction\n");
264         printf("Transaction tid is %d.%d\n", udebug.syncTid.epoch,
265                udebug.syncTid.counter);
266     }
267     if (udebug.epochTime) {
268         diff = udebug.now - udebug.epochTime;
269         newtime = now - diff;
270         times = ctime(&newtime);
271         times[24] = 0;
272         printf
273             ("Last time a new db version was labelled was:\n\t %d secs ago (at %s)\n",
274              diff, times);
275     }
276
277     if (int32p || udebug.amSyncSite) {
278         /* now do the subcalls */
279         for (i = 0;; i++) {
280             isClone = 0;
281             code = VOTE_XSDebug(tconn, i, &usdebug, &isClone);
282             if (code < 0) {
283                 if (oldServer) {        /* pre 3.5 server */
284                     memset(&usdebug, 0, sizeof(usdebug));
285                     code = VOTE_SDebugOld(tconn, i, &usdebug);
286                 } else
287                     code = VOTE_SDebug(tconn, i, &usdebug);
288             }
289             if (code > 0)
290                 break;          /* done */
291             if (code < 0) {
292                 printf("error code %d from VOTE_SDebug\n", code);
293                 break;
294             }
295             /* otherwise print the structure */
296             printf("\nServer (%s", afs_inet_ntoa(htonl(usdebug.addr)));
297             for (j = 0;
298                  ((usdebug.altAddr[j]) && (j < UBIK_MAX_INTERFACE_ADDR - 1));
299                  j++)
300                 printf(" %s", afs_inet_ntoa(htonl(usdebug.altAddr[j])));
301             printf("): (db %d.%d)", usdebug.remoteVersion.epoch,
302                    usdebug.remoteVersion.counter);
303             if (isClone)
304                 printf("    is only a clone!");
305             printf("\n");
306
307             if (usdebug.lastVoteTime == 0) {
308                 printf("    last vote never rcvd \n");
309             } else {
310                 diff = udebug.now - usdebug.lastVoteTime;
311                 newtime = now - diff;
312                 times = ctime(&newtime);
313                 times[24] = 0;
314                 printf("    last vote rcvd %d secs ago (at %s),\n", diff,
315                        times);
316             }
317
318             if (usdebug.lastBeaconSent == 0) {
319                 printf("    last beacon never sent \n");
320             } else {
321                 diff = udebug.now - usdebug.lastBeaconSent;
322                 newtime = now - diff;
323                 times = ctime(&newtime);
324                 times[24] = 0;
325                 printf
326                     ("    last beacon sent %d secs ago (at %s), last vote was %s\n",
327                      diff, times, ((usdebug.lastVote) ? "yes" : "no"));
328             }
329
330             printf("    dbcurrent=%d, up=%d beaconSince=%d\n",
331                    usdebug.currentDB, usdebug.up, usdebug.beaconSinceDown);
332         }
333     }
334     return (0);
335 }
336
337 #include "AFS_component_version_number.c"
338
339 int
340 main(int argc, char **argv)
341 {
342     struct cmd_syndesc *ts;
343
344 #ifdef  AFS_AIX32_ENV
345     /*
346      * The following signal action for AIX is necessary so that in case of a 
347      * crash (i.e. core is generated) we can include the user's data section 
348      * in the core dump. Unfortunately, by default, only a partial core is
349      * generated which, in many cases, isn't too useful.
350      */
351     struct sigaction nsa;
352
353     sigemptyset(&nsa.sa_mask);
354     nsa.sa_handler = SIG_DFL;
355     nsa.sa_flags = SA_FULLDUMP;
356     sigaction(SIGSEGV, &nsa, NULL);
357 #endif
358     ts = cmd_CreateSyntax(NULL, CommandProc, 0, "probe ubik server");
359     cmd_AddParm(ts, "-server", CMD_SINGLE, CMD_REQUIRED, "server machine");
360     cmd_AddParm(ts, "-port", CMD_SINGLE, CMD_OPTIONAL, "IP port");
361     cmd_AddParm(ts, "-long", CMD_FLAG, CMD_OPTIONAL, "print all info");
362
363     cmd_Dispatch(argc, argv);
364     exit(0);
365 }