2 * CDE - Common Desktop Environment
4 * Copyright (c) 1993-2012, The Open Group. All rights reserved.
6 * These libraries and programs are free software; you can
7 * redistribute them and/or modify them under the terms of the GNU
8 * Lesser General Public License as published by the Free Software
9 * Foundation; either version 2 of the License, or (at your option)
12 * These libraries and programs are distributed in the hope that
13 * they will be useful, but WITHOUT ANY WARRANTY; without even the
14 * implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
15 * PURPOSE. See the GNU Lesser General Public License for more
18 * You should have received a copy of the GNU Lesser General Public
19 * License along with these librararies and programs; if not, write
20 * to the Free Software Foundation, Inc., 51 Franklin Street, Fifth
21 * Floor, Boston, MA 02110-1301 USA
23 /* $TOG: svcmain.c /main/10 1998/04/06 13:13:49 mgreess $ */
25 * (c) Copyright 1993, 1994 Hewlett-Packard Company
26 * (c) Copyright 1993, 1994 International Business Machines Corp.
27 * (c) Copyright 1993, 1994 Novell, Inc.
28 * (c) Copyright 1993, 1994 Sun Microsystems, Inc.
31 #include <EUSCompat.h>
38 #include <sys/resource.h>
41 #include <netinet/in.h>
42 #endif /* _NETINET_IN_H */
45 #if defined(SunOS) || defined(USL) || defined(__uxp__)
46 #include <netconfig.h>
48 #include <sys/stropts.h>
50 #endif /* SunOS || USL || __uxp__ */
51 #include <sys/param.h>
56 #include <sys/signal.h>
59 #include "rpcextras.h"
61 #include "cmscalendar.h"
67 #define S_IRWXU (S_IRUSR|S_IWUSR|S_IXUSR)
70 #define S_IRWXG (S_IRGRP|S_IWGRP|S_IXGRP)
73 #define S_IRWXO (S_IROTH|S_IWOTH|S_IXOTH)
76 #define S_MASK (S_INPUT|S_HIPRI|S_ERROR|S_HANGUP)
79 static int standalone; /* default is 0 */
80 static int received_sighup = 0; /* 1 means we get SIGHUP */
81 static int rpc_in_process = 0; /* 1 means processing client request */
82 static int garbage_collection_time = 240; /* in min; default time is 4:00am */
90 * get garbage collection time
91 * the given string should be in the format hhmm
92 * where hh is 0 - 23 and mm is 00 - 59
95 _GetGtime(char *timestr)
97 int hour, minute, len, i;
102 if ((len = strlen(timestr)) > 4)
105 for (i = 0; i < len; i++) {
106 if (timestr[i] < '0' || timestr[i] > '9')
110 minute = atoi(×tr[len - 2]);
111 timestr[len - 2] = NULL;
112 hour = atoi(timestr);
114 if (hour > 23 || minute > 59)
117 garbage_collection_time = hour * 60 + minute;
122 fprintf(stderr, "The time specified is invalid.\n");
127 parse_args(int argc, char **argv)
131 if (pgname = strrchr (argv[0], '/'))
136 while ((opt = getopt (argc, argv, "dsg:")) != -1)
147 if (_GetGtime(optarg))
160 * rpc.cmsd gets started by the inetd.
161 * On AIX inetd requires that two arguments be supplied to the RPC
162 * programs as follows (from the inetd.conf man page):
164 * ServerArgs Specifies the command line arguments that the
165 * inetd daemon should use to execute the server. The maximum number
166 * of arguments is five. The first argument specifies the name of the
167 * server used. If the SocketType parameter is sunrpc_tcp or
168 * sunrpc_udp, * the second argument specifies the program name and
169 * the third argument specifies the version of the program. For
170 * services that the inetd daemon provides internally, this field
174 else if (optind == 1 && argc >= 3)
182 argv_r = (char **) malloc(argc * sizeof(char *));
185 for (i=optind+2, j=1; i<argc; i++,j++)
187 parse_args(argc-2, argv_r);
189 free((void *) argv_r);
195 fprintf (stderr, "Usage: %s [-d] [-s] [-g hhmm]\n", pgname);
202 char *dir = _DtCMS_DEFAULT_DIR;
211 "%s: must be run in super-user mode! Exited.\n",
217 if (stat(dir, &info))
219 /* if directory does not exist, create the directory */
220 if ((errno != ENOENT) || mkdir(dir, S_IRWXU|S_IRWXG|S_IRWXO))
223 sprintf(msgbuf, "%s: cannot create %s.\n%s: %s",
224 pgname, dir, pgname, "System error");
226 sprintf(msgbuf, "%s: cannot access %s.\n%s: %s",
227 pgname, dir, pgname, "System error");
234 /* if dir is just created, we need to do chmod and chown.
235 * Otherwise, only do chmod and/or chown if permssion and/or
236 * ownership is wrong.
238 mode = S_ISGID|S_ISVTX|S_IRWXU|S_IRWXG|S_IRWXO;
240 if (create_dir || info.st_mode != (mode | S_IFDIR)) {
242 /* set directory permission to be "rwxrwsrwt" */
243 if (chmod(dir, mode)) {
244 sprintf(msgbuf, "%s: Permission on %s%s\n%s%s\n%s%s",
246 " is wrong but cannot be corrected.", pgname,
247 ": This might happen if you are mounting the directory.",
248 pgname, ": System error");
256 if (create_dir || info.st_uid!=daemon_uid || info.st_gid!=daemon_gid) {
257 /* set directory ownership to: owner = 1, group = 1 */
258 if (chown(dir, daemon_uid, daemon_gid)) {
259 sprintf(msgbuf, "%s: Ownership on %s%s\n%s%s\n%s%s",
261 " is wrong but cannot be corrected.", pgname,
262 ": This might happen if you are mounting the directory.",
263 pgname, ": System error");
271 /* Change current directory, so core file can be dumped. */
276 * send a SIGHUP signal to the rpc.cmsd that is already running
283 pid_t pid, mypid = getpid();
284 extern FILE *popen(const char *, const char *);
285 extern int pclose(FILE *);
287 sprintf(buf, "ps -e|grep rpc.cmsd|grep -v grep");
289 if ((fp = popen(buf, "r")) == NULL) {
291 fprintf(stderr, "rpc.cmsd: popen failed\n");
293 while (fgets(buf, sizeof(buf), fp) != NULL) {
294 if ((pid = atol(buf)) != mypid) {
295 if (kill(pid, SIGHUP))
296 perror("rpc.cmsd: failed to send SIGHUP");
298 fprintf(stderr, "rpc.cmsd: %s %ld\n",
299 "sent SIGHUP to", (long)pid);
307 * We only allow one rpc.cmsd to run on each machine.
312 char *dir = _DtCMS_DEFAULT_DIR;
313 char buff [MAXPATHLEN];
318 locker.l_type = F_WRLCK;
325 strcat (buff, "/.lock.");
328 * /var/spool might be mounted. Use .lock.hostname to
329 * prevent more than one cms running in each host.
331 strcat(buff, _DtCmGetLocalHost());
333 fd = open(buff, O_WRONLY|O_CREAT, S_IRUSR|S_IWUSR|S_IRGRP|S_IWGRP);
341 * Note, we have to use flock() instead of lockf() because cms process
342 * is run in each host.
345 if (fcntl (fd, F_SETLK, &locker) != 0)
347 if (flock (fd, LOCK_EX|LOCK_NB) != 0)
354 if (error != EWOULDBLOCK && error != EACCES) {
356 perror ("rpc.cmsd: failed to lock lockfile");
357 fprintf(stderr, "error = %d\n", error);
362 fprintf(stderr, "rpc.cmsd: %s\n",
363 "lock_it failed due to another process");
365 /* cms has been running.... */
374 program(struct svc_req *rqstp, register SVCXPRT *transp)
377 char *argument = NULL;
378 program_handle ph = getph();
379 struct rpcgen_table *proc;
381 /* set rpc_in_process so that sighup handler won't exit right away */
384 /* first do some bounds checking: */
385 if (rqstp->rq_vers >= ph->nvers) {
386 svcerr_noproc(transp);
389 if (ph->prog[rqstp->rq_vers].nproc == 0) {
390 svcerr_noproc(transp);
393 if (rqstp->rq_proc >= ph->prog[rqstp->rq_vers].nproc) {
394 svcerr_noproc(transp);
398 if (rqstp->rq_proc == NULLPROC) {
399 if (debug) fprintf(stderr, "rpc.cmsd: ping\n");
400 (void)svc_sendreply(transp, (xdrproc_t)xdr_void, (caddr_t)NULL);
404 /* assert - the program number, version and proc numbers are valid */
405 proc = &(ph->prog[rqstp->rq_vers].vers[rqstp->rq_proc]);
406 argument = (char*)calloc(proc->len_arg, sizeof(char));
407 if (!svc_getargs(transp, proc->xdr_arg, argument)) {
408 svcerr_decode(transp);
412 result = (*proc->proc)(argument, rqstp);
413 if (result != NULL && !svc_sendreply(transp, proc->xdr_res, result)) {
414 svcerr_systemerr(transp);
417 if (!svc_freeargs(transp, proc->xdr_arg, argument)) {
418 (void)fprintf(stderr, "unable to free arguments");
426 /* exit if we have received the SIGHUP signal */
427 if (received_sighup == 1) {
429 fprintf(stderr, "rpc.cmsd: received SIGHUP, %s",
430 "exiting after finished processing\n");
436 * Signal handler for SIGHUP.
437 * If we are in the middle of processing a client request,
438 * finish processing before we exit.
441 sighup_handler(int sig_num)
444 fprintf(stderr, "rpc.cmsd: sighup received\n");
446 if (rpc_in_process == 0) {
448 fprintf(stderr, "rpc.cmsd: exit from sighup_handler\n");
452 fprintf(stderr, "rpc.cmsd: set received_sighup to 1\n");
458 * garbage_collection_time (in min) is the time to do garbage collection
460 * This routine returns the difference between the first garbage collection
461 * time and now so that the calling routine can set the alarm.
464 _GetFirstGarbageCollectionTime()
466 int n=0, midnight=0, gtime=0;
470 /* try today first */
471 midnight = next_ndays(n, 0);
472 gtime = next_nmins(midnight, garbage_collection_time);
475 /* the first garbage collection will be done tomorrow */
476 midnight = next_ndays(n, 1);
477 gtime = next_nmins(midnight, garbage_collection_time);
487 extern void garbage_collect();
488 extern void debug_switch();
490 #if defined(SVR4) && !defined(linux)
491 extern void (*sigset(int, void (*)(int)))(int);
492 sigset(SIGUSR1, garbage_collect);
493 sigset(SIGALRM, garbage_collect);
494 sigset(SIGUSR2, debug_switch);
496 signal(SIGUSR1, garbage_collect);
497 signal(SIGALRM, garbage_collect);
498 signal(SIGUSR2, debug_switch);
501 next = _GetFirstGarbageCollectionTime();
502 alarm((unsigned) next);
505 main(int argc, char **argv)
508 program_handle ph = newph();
512 struct sockaddr_in saddr;
513 int asize = sizeof (saddr);
514 SVCXPRT *tcp_transp = (SVCXPRT *)-1;
515 SVCXPRT *udp_transp = (SVCXPRT *)-1;
518 #if defined(SunOS) || defined(USL) || defined(__uxp__)
519 struct netconfig *nconf_udp;
520 struct netconfig *nconf_tcp;
522 #if !defined(USL) || (defined(USL) && (OSMAJORVERSION > 1))
523 char mname[FMNAMESZ+1];
525 #endif /* SunOS || USL */
527 pw = (struct passwd *)getpwnam("daemon");
528 gr = (struct group *)getgrnam("daemon");
530 daemon_uid = pw->pw_uid;
534 daemon_gid = gr->gr_gid;
538 parse_args(argc, argv);
540 /* check to see if we are started by inetd */
541 if (getsockname(0, (struct sockaddr *)&saddr, &asize) == 0) {
545 #if defined(SunOS) || defined(USL) || defined(__uxp__)
546 #if !defined(USL) || (defined(USL) && (OSMAJORVERSION > 1))
547 /* we need a TLI endpoint rather than a socket */
548 if (ioctl(0, I_LOOK, mname) != 0) {
549 perror("rpc.cmsd: ioctl failed to get module name");
552 if (strcmp(mname, "sockmod") == 0) {
553 /* Change socket fd to TLI fd */
554 if (ioctl(0, I_POP, 0) || ioctl(0, I_PUSH, "timod")) {
555 perror("rpc.cmsd: ioctl I_POP/I_PUSH failed");
558 } else if (strcmp(mname, "timod") != 0) {
559 fprintf(stderr, "rpc.cmsd: fd 0 is not timod\n");
562 #else /* !USL || (USL && OSMAJORVERSION > 1) */
563 if (ioctl(0, I_POP, 0) || ioctl(0, I_PUSH, "timod")) {
564 perror("rpc.cmsd: ioctl I_POP/I_PUSH failed");
567 #endif /* !USL || (USL && OSMAJORVERSION > 1) */
569 } else if (t_getinfo(0, &info) == 0) {
572 #endif /* SunOS || USL */
578 * if it is started by inetd, make stderr to be
582 if ((fd = open ("/dev/console", O_WRONLY)) >= 0) {
590 /* Set up private directory and switch euid/egid to daemon. */
594 /* Don't allow multiple cms processes running in the same host. */
595 if ((error = lock_it()) != 0 && !standalone) {
596 /* we are invoked by inetd but another rpc.cmsd
597 * is alreay running, so send SIGHUP to it
602 /* try to lock it again */
603 if (lock_it() != 0) {
605 fprintf(stderr, "cm: rpc.cmsd is still running\n");
609 } else if (error != 0) {
610 fprintf(stderr, "rpc.cmsd: rpc.cmsd is already running.\n");
614 /* use signal because we only need it once */
615 signal(SIGHUP, sighup_handler);
618 #if defined(SunOS) || defined(USL) || defined(__uxp__)
619 /* raise the soft limit of number of file descriptor */
620 /* this is to prevent the backend from running out of open file des */
621 getrlimit(RLIMIT_NOFILE, &rl);
622 rl.rlim_cur = (rl.rlim_max <= 256) ? rl.rlim_max : 256;
623 setrlimit(RLIMIT_NOFILE, &rl);
626 #if defined(SunOS) || defined(USL) || defined(__uxp__)
627 nconf_udp = getnetconfigent("udp");
628 nconf_tcp = getnetconfigent("tcp");
630 for (version = 0; version < ph->nvers; version++) {
631 /* don't register unsupported versions: */
632 if (ph->prog[version].nproc == 0) continue;
635 rpcb_unset(ph->program_num, version, NULL);
638 "rpc.cmsd: rpcb_unset for version %ld\n",
642 /* brought up by inetd, use fd 0 which must be a TLI fd */
643 if (udp_transp == (SVCXPRT *)-1) {
644 udp_transp = svc_tli_create(standalone ? RPC_ANYFD : 0,
645 nconf_udp, (struct t_bind*) NULL, 0, 0);
647 if (udp_transp == NULL) {
648 t_error("rtable_main.c: svc_tli_create(udp)");
653 if (svc_reg(udp_transp, ph->program_num, version, program,
654 standalone ? nconf_udp : NULL) == 0) {
655 t_error("rtable_main.c: svc_reg");
659 /* Set up tcp for calls that potentially return */
660 /* large amount of data. This transport is not */
661 /* registered with inetd so need to register it */
662 /* with rpcbind ourselves. */
664 rpcb_unset(ph->program_num, version, nconf_tcp);
666 if (tcp_transp == (SVCXPRT *)-1) {
667 tcp_transp = svc_tli_create(RPC_ANYFD, nconf_tcp,
668 (struct t_bind *)NULL, 0, 0);
670 if (tcp_transp == NULL) {
671 t_error("rtable_main.c: svc_til_create(tcp)");
676 if (svc_reg(tcp_transp, ph->program_num, version, program,
678 t_error("rtable_main.c: svc_reg(tcp)");
684 freenetconfigent(nconf_udp);
686 freenetconfigent(nconf_tcp);
690 for (version = 0; version < ph->nvers; version++) {
691 /* don't register unsupported versions: */
692 if (ph->prog[version].nproc == 0) continue;
697 (void) pmap_unset(ph->program_num, version);
699 if (udp_transp == (SVCXPRT *)-1) {
700 udp_transp = svcudp_create(standalone ? RPC_ANYSOCK : 0
701 #if defined(_AIX) || defined(hpV4) || defined(__osf__) || defined(linux)
706 if (udp_transp == NULL) {
707 (void)fprintf(stderr,
708 "rtable_main.c: cannot create udp service.\n");
714 if (!svc_register(udp_transp, ph->program_num, version, program,
715 standalone ? IPPROTO_UDP : 0)) {
717 if (!svc_register(udp_transp, ph->program_num, version, program,
720 (void)fprintf(stderr, "rtable_main.c: unable to register");
724 /* Set up tcp for calls that potentially return */
725 /* large amount of data. This transport is not */
726 /* registered with inetd so need to register it */
727 /* with rpcbind ourselves. */
729 if (tcp_transp == (SVCXPRT *)-1) {
730 tcp_transp = svctcp_create(RPC_ANYSOCK, 0, 0);
731 if (tcp_transp == NULL) {
732 (void)fprintf(stderr,
733 "rtable_main.c: cannot create tcp service.\n");
738 if (!svc_register(tcp_transp, ph->program_num, version, program,
740 (void)fprintf(stderr, "rtable_main.c: unable to register(tcp)");
745 #endif /* SunOS || USL */
752 setegid (daemon_gid);
753 seteuid (daemon_uid);
763 (void)fprintf(stderr, "rpc.cmsd: svc_run returned\n");