Warning fix for gcc 4.5 "operation may be undefined" warnings
[openafs.git] / src / vlserver / vlserver.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
14 #include <afs/stds.h>
15 #include <sys/types.h>
16 #include <signal.h>
17 #include <sys/stat.h>
18 #include <string.h>
19 #ifdef HAVE_FCNTL_H
20 #include <fcntl.h>
21 #endif
22 #ifdef AFS_NT40_ENV
23 #include <winsock2.h>
24 #include <WINNT/afsevent.h>
25 #endif
26 #ifdef HAVE_SYS_FILE_H
27 #include <sys/file.h>
28 #endif
29 #include <time.h>
30 #ifdef HAVE_NETDB_H
31 #include <netdb.h>
32 #endif
33 #ifdef HAVE_NETINET_IN_H
34 #include <netinet/in.h>
35 #endif
36 #include <stdio.h>
37 #ifdef HAVE_STDINT_H
38 # include <stdint.h>
39 #endif
40
41 #include <rx/xdr.h>
42 #include <rx/rx.h>
43 #include <rx/rx_globals.h>
44 #include <rx/rxstat.h>
45 #include <afs/cellconfig.h>
46 #include <afs/keys.h>
47 #include <afs/auth.h>
48 #include <afs/audit.h>
49 #include <lock.h>
50 #include <ubik.h>
51 #include <afs/afsutil.h>
52 #include "vlserver.h"
53 #include "vlserver_internal.h"
54
55 #define MAXLWP 16
56 const char *vl_dbaseName;
57 struct afsconf_dir *vldb_confdir = 0;   /* vldb configuration dir */
58 int lwps = 9;
59
60 struct vldstats dynamic_statistics;
61 struct ubik_dbase *VL_dbase;
62 afs_uint32 rd_HostAddress[MAXSERVERID + 1];
63 afs_uint32 wr_HostAddress[MAXSERVERID + 1];
64
65 static void *CheckSignal(void*);
66 int LogLevel = 0;
67 int smallMem = 0;
68 int rxJumbograms = 0;           /* default is to not send and receive jumbo grams */
69 int rxMaxMTU = -1;
70 afs_int32 rxBind = 0;
71 int rxkadDisableDotCheck = 0;
72 int debuglevel = 0;
73
74 #define ADDRSPERSITE 16         /* Same global is in rx/rx_user.c */
75 afs_uint32 SHostAddrs[ADDRSPERSITE];
76
77 static void
78 CheckSignal_Signal(int unused)
79 {
80 #if defined(AFS_PTHREAD_ENV)
81     CheckSignal(0);
82 #else
83     IOMGR_SoftSig(CheckSignal, 0);
84 #endif
85 }
86
87 static void *
88 CheckSignal(void *unused)
89 {
90     int i, errorcode;
91     struct vl_ctx ctx;
92
93     if ((errorcode =
94         Init_VLdbase(&ctx, LOCKREAD, VLGETSTATS - VL_LOWEST_OPCODE)))
95         return (void *)(intptr_t)errorcode;
96     VLog(0, ("Dump name hash table out\n"));
97     for (i = 0; i < HASHSIZE; i++) {
98         HashNDump(&ctx, i);
99     }
100     VLog(0, ("Dump id hash table out\n"));
101     for (i = 0; i < HASHSIZE; i++) {
102         HashIdDump(&ctx, i);
103     }
104     return ((void *)(intptr_t)ubik_EndTrans(ctx.trans));
105 }                               /*CheckSignal */
106
107
108 /* Initialize the stats for the opcodes */
109 void
110 initialize_dstats(void)
111 {
112     int i;
113
114     dynamic_statistics.start_time = (afs_uint32) time(0);
115     for (i = 0; i < MAX_NUMBER_OPCODES; i++) {
116         dynamic_statistics.requests[i] = 0;
117         dynamic_statistics.aborts[i] = 0;
118     }
119 }
120
121 /* check whether caller is authorized to manage RX statistics */
122 int
123 vldb_rxstat_userok(struct rx_call *call)
124 {
125     return afsconf_SuperUser(vldb_confdir, call, NULL);
126 }
127
128 /* Main server module */
129
130 #include "AFS_component_version_number.c"
131
132 int
133 main(int argc, char **argv)
134 {
135     afs_int32 code;
136     afs_uint32 myHost;
137     struct rx_service *tservice;
138     struct rx_securityClass **securityClasses;
139     afs_int32 numClasses;
140     struct afsconf_dir *tdir;
141     struct ktc_encryptionKey tkey;
142     struct afsconf_cell info;
143     struct hostent *th;
144     char hostname[VL_MAXNAMELEN];
145     int noAuth = 0, index;
146     char clones[MAXHOSTSPERCELL];
147     char *auditFileName = NULL;
148     afs_uint32 host = ntohl(INADDR_ANY);
149
150 #ifdef  AFS_AIX32_ENV
151     /*
152      * The following signal action for AIX is necessary so that in case of a
153      * crash (i.e. core is generated) we can include the user's data section
154      * in the core dump. Unfortunately, by default, only a partial core is
155      * generated which, in many cases, isn't too useful.
156      */
157     struct sigaction nsa;
158
159     rx_extraPackets = 100;      /* should be a switch, I guess... */
160     sigemptyset(&nsa.sa_mask);
161     nsa.sa_handler = SIG_DFL;
162     nsa.sa_flags = SA_FULLDUMP;
163     sigaction(SIGABRT, &nsa, NULL);
164     sigaction(SIGSEGV, &nsa, NULL);
165 #endif
166     osi_audit_init();
167
168     /* Parse command line */
169     for (index = 1; index < argc; index++) {
170         if (strcmp(argv[index], "-noauth") == 0) {
171             noAuth = 1;
172         } else if (strcmp(argv[index], "-p") == 0) {
173             lwps = atoi(argv[++index]);
174             if (lwps > MAXLWP) {
175                 printf("Warning: '-p %d' is too big; using %d instead\n",
176                        lwps, MAXLWP);
177                 lwps = MAXLWP;
178             }
179         } else if (strcmp(argv[index], "-d") == 0) {
180             if ((index + 1) >= argc) {
181                 fprintf(stderr, "missing argument for -d\n");
182                 return -1;
183             }
184             debuglevel = atoi(argv[++index]);
185             LogLevel = debuglevel;
186         } else if (strcmp(argv[index], "-nojumbo") == 0) {
187             rxJumbograms = 0;
188         } else if (strcmp(argv[index], "-jumbo") == 0) {
189             rxJumbograms = 1;
190         } else if (strcmp(argv[index], "-rxbind") == 0) {
191             rxBind = 1;
192         } else if (strcmp(argv[index], "-allow-dotted-principals") == 0) {
193             rxkadDisableDotCheck = 1;
194         } else if (!strcmp(argv[index], "-rxmaxmtu")) {
195             if ((index + 1) >= argc) {
196                 fprintf(stderr, "missing argument for -rxmaxmtu\n");
197                 return -1;
198             }
199             rxMaxMTU = atoi(argv[++index]);
200             if ((rxMaxMTU < RX_MIN_PACKET_SIZE) ||
201                 (rxMaxMTU > RX_MAX_PACKET_DATA_SIZE)) {
202                 printf("rxMaxMTU %d invalid; must be between %d-%" AFS_SIZET_FMT "\n",
203                        rxMaxMTU, RX_MIN_PACKET_SIZE,
204                        RX_MAX_PACKET_DATA_SIZE);
205                 return -1;
206             }
207
208         } else if (strcmp(argv[index], "-smallmem") == 0) {
209             smallMem = 1;
210
211         } else if (strcmp(argv[index], "-trace") == 0) {
212             extern char rxi_tracename[80];
213             strcpy(rxi_tracename, argv[++index]);
214
215         } else if (strcmp(argv[index], "-auditlog") == 0) {
216             auditFileName = argv[++index];
217
218         } else if (strcmp(argv[index], "-audit-interface") == 0) {
219             char *interface = argv[++index];
220
221             if (osi_audit_interface(interface)) {
222                 printf("Invalid audit interface '%s'\n", interface);
223                 return -1;
224             }
225
226         } else if (strcmp(argv[index], "-enable_peer_stats") == 0) {
227             rx_enablePeerRPCStats();
228         } else if (strcmp(argv[index], "-enable_process_stats") == 0) {
229             rx_enableProcessRPCStats();
230 #ifndef AFS_NT40_ENV
231         } else if (strcmp(argv[index], "-syslog") == 0) {
232             /* set syslog logging flag */
233             serverLogSyslog = 1;
234         } else if (strncmp(argv[index], "-syslog=", 8) == 0) {
235             serverLogSyslog = 1;
236             serverLogSyslogFacility = atoi(argv[index] + 8);
237 #endif
238         } else {
239             /* support help flag */
240 #ifndef AFS_NT40_ENV
241             printf("Usage: vlserver [-p <number of processes>] [-nojumbo] "
242                    "[-rxmaxmtu <bytes>] [-rxbind] [-allow-dotted-principals] "
243                    "[-auditlog <log path>] [-jumbo] [-d <debug level>] "
244                    "[-syslog[=FACILITY]] "
245                    "[-enable_peer_stats] [-enable_process_stats] "
246                    "[-help]\n");
247 #else
248             printf("Usage: vlserver [-p <number of processes>] [-nojumbo] "
249                    "[-rxmaxmtu <bytes>] [-rxbind] [-allow-dotted-principals] "
250                    "[-auditlog <log path>] [-jumbo] [-d <debug level>] "
251                    "[-enable_peer_stats] [-enable_process_stats] "
252                    "[-help]\n");
253 #endif
254             fflush(stdout);
255             exit(0);
256         }
257     }
258
259     if (auditFileName) {
260         osi_audit_file(auditFileName);
261     }
262
263     /* Initialize dirpaths */
264     if (!(initAFSDirPath() & AFSDIR_SERVER_PATHS_OK)) {
265 #ifdef AFS_NT40_ENV
266         ReportErrorEventAlt(AFSEVT_SVR_NO_INSTALL_DIR, 0, argv[0], 0);
267 #endif
268         fprintf(stderr, "%s: Unable to obtain AFS server directory.\n",
269                 argv[0]);
270         exit(2);
271     }
272     vl_dbaseName = AFSDIR_SERVER_VLDB_FILEPATH;
273
274 #ifndef AFS_NT40_ENV
275     serverLogSyslogTag = "vlserver";
276 #endif
277     OpenLog(AFSDIR_SERVER_VLOG_FILEPATH);       /* set up logging */
278     SetupLogSignals();
279
280     tdir = afsconf_Open(AFSDIR_SERVER_ETC_DIRPATH);
281     if (!tdir) {
282         printf
283             ("vlserver: can't open configuration files in dir %s, giving up.\n",
284              AFSDIR_SERVER_ETC_DIRPATH);
285         exit(1);
286     }
287 #ifdef AFS_NT40_ENV
288     /* initialize winsock */
289     if (afs_winsockInit() < 0) {
290         ReportErrorEventAlt(AFSEVT_SVR_WINSOCK_INIT_FAILED, 0, argv[0], 0);
291         fprintf(stderr, "vlserver: couldn't initialize winsock. \n");
292         exit(1);
293     }
294 #endif
295     /* get this host */
296     gethostname(hostname, sizeof(hostname));
297     th = gethostbyname(hostname);
298     if (!th) {
299         printf("vlserver: couldn't get address of this host (%s).\n",
300                hostname);
301         exit(1);
302     }
303     memcpy(&myHost, th->h_addr, sizeof(afs_uint32));
304
305 #if !defined(AFS_HPUX_ENV) && !defined(AFS_NT40_ENV)
306     signal(SIGXCPU, CheckSignal_Signal);
307 #endif
308     /* get list of servers */
309     code =
310         afsconf_GetExtendedCellInfo(tdir, NULL, AFSCONF_VLDBSERVICE, &info,
311                                     clones);
312     if (code) {
313         printf("vlserver: Couldn't get cell server list for 'afsvldb'.\n");
314         exit(2);
315     }
316
317     vldb_confdir = tdir;        /* Preserve our configuration dir */
318     /* rxvab no longer supported */
319     memset(&tkey, 0, sizeof(tkey));
320
321     if (noAuth)
322         afsconf_SetNoAuthFlag(tdir, 1);
323
324     if (rxBind) {
325         afs_int32 ccode;
326 #ifndef AFS_NT40_ENV
327         if (AFSDIR_SERVER_NETRESTRICT_FILEPATH ||
328             AFSDIR_SERVER_NETINFO_FILEPATH) {
329             char reason[1024];
330             ccode = parseNetFiles(SHostAddrs, NULL, NULL,
331                                   ADDRSPERSITE, reason,
332                                   AFSDIR_SERVER_NETINFO_FILEPATH,
333                                   AFSDIR_SERVER_NETRESTRICT_FILEPATH);
334         } else
335 #endif
336         {
337             ccode = rx_getAllAddr(SHostAddrs, ADDRSPERSITE);
338         }
339         if (ccode == 1) {
340             host = SHostAddrs[0];
341             rx_InitHost(host, htons(AFSCONF_VLDBPORT));
342         }
343     }
344
345     ubik_nBuffers = 512;
346     ubik_CRXSecurityProc = afsconf_ClientAuth;
347     ubik_CRXSecurityRock = (char *)tdir;
348     ubik_SRXSecurityProc = afsconf_ServerAuth;
349     ubik_SRXSecurityRock = (char *)tdir;
350     ubik_CheckRXSecurityProc = afsconf_CheckAuth;
351     ubik_CheckRXSecurityRock = (char *)tdir;
352     ubik_SyncWriterCacheProc = vlsynccache;
353     code =
354         ubik_ServerInitByInfo(myHost, htons(AFSCONF_VLDBPORT), &info, clones,
355                               vl_dbaseName, &VL_dbase);
356     if (code) {
357         printf("vlserver: Ubik init failed with code %d\n", code);
358         exit(2);
359     }
360     if (!rxJumbograms) {
361         rx_SetNoJumbo();
362     }
363     if (rxMaxMTU != -1) {
364         rx_SetMaxMTU(rxMaxMTU);
365     }
366     rx_SetRxDeadTime(50);
367
368     memset(rd_HostAddress, 0, sizeof(rd_HostAddress));
369     memset(wr_HostAddress, 0, sizeof(wr_HostAddress));
370     initialize_dstats();
371
372     afsconf_BuildServerSecurityObjects(tdir, 0, &securityClasses, &numClasses);
373
374     tservice =
375         rx_NewServiceHost(host, 0, USER_SERVICE_ID, "Vldb server",
376                           securityClasses, numClasses,
377                           VL_ExecuteRequest);
378     if (tservice == (struct rx_service *)0) {
379         printf("vlserver: Could not create VLDB_SERVICE rx service\n");
380         exit(3);
381     }
382     rx_SetMinProcs(tservice, 2);
383     if (lwps < 4)
384         lwps = 4;
385     rx_SetMaxProcs(tservice, lwps);
386
387     if (rxkadDisableDotCheck) {
388         rx_SetSecurityConfiguration(tservice, RXS_CONFIG_FLAGS,
389                                     (void *)RXS_CONFIG_FLAGS_DISABLE_DOTCHECK);
390     }
391
392     tservice =
393         rx_NewServiceHost(host, 0, RX_STATS_SERVICE_ID, "rpcstats",
394                           securityClasses, numClasses,
395                           RXSTATS_ExecuteRequest);
396     if (tservice == (struct rx_service *)0) {
397         printf("vlserver: Could not create rpc stats rx service\n");
398         exit(3);
399     }
400     rx_SetMinProcs(tservice, 2);
401     rx_SetMaxProcs(tservice, 4);
402
403     LogCommandLine(argc, argv, "vlserver", VldbVersion, "Starting AFS", FSLog);
404     printf("%s\n", cml_version_number); /* Goes to the log */
405
406     /* allow super users to manage RX statistics */
407     rx_SetRxStatUserOk(vldb_rxstat_userok);
408
409     rx_StartServer(1);          /* Why waste this idle process?? */
410
411     return 0; /* not reachable */
412 }