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 libraries 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 #if defined(__linux__)
32 #define _POSIX_C_SOURCE 2
35 #include <EUSCompat.h>
43 #include <sys/resource.h>
46 #include <netinet/in.h>
47 #endif /* _NETINET_IN_H */
51 #include <netconfig.h>
53 #include <sys/stropts.h>
56 #include <sys/param.h>
61 #include <sys/signal.h>
64 #include "rpcextras.h"
66 #include "cmscalendar.h"
72 #define S_IRWXU (S_IRUSR|S_IWUSR|S_IXUSR)
75 #define S_IRWXG (S_IRGRP|S_IWGRP|S_IXGRP)
78 #define S_IRWXO (S_IROTH|S_IWOTH|S_IXOTH)
81 #define S_MASK (S_INPUT|S_HIPRI|S_ERROR|S_HANGUP)
84 static int standalone; /* default is 0 */
85 static int received_sighup = 0; /* 1 means we get SIGHUP */
86 static int rpc_in_process = 0; /* 1 means processing client request */
87 static int garbage_collection_time = 240; /* in min; default time is 4:00am */
95 * get garbage collection time
96 * the given string should be in the format hhmm
97 * where hh is 0 - 23 and mm is 00 - 59
100 _GetGtime(char *timestr)
102 int hour, minute, len, i;
107 if ((len = strlen(timestr)) > 4)
110 for (i = 0; i < len; i++) {
111 if (timestr[i] < '0' || timestr[i] > '9')
115 minute = atoi(×tr[len - 2]);
116 timestr[len - 2] = '\0';
117 hour = atoi(timestr);
119 if (hour > 23 || minute > 59)
122 garbage_collection_time = hour * 60 + minute;
127 fprintf(stderr, "The time specified is invalid.\n");
132 parse_args(int argc, char **argv)
136 if (pgname = strrchr (argv[0], '/'))
141 while ((opt = getopt (argc, argv, "dsg:")) != -1)
152 if (_GetGtime(optarg))
165 * rpc.cmsd gets started by the inetd.
166 * On AIX inetd requires that two arguments be supplied to the RPC
167 * programs as follows (from the inetd.conf man page):
169 * ServerArgs Specifies the command line arguments that the
170 * inetd daemon should use to execute the server. The maximum number
171 * of arguments is five. The first argument specifies the name of the
172 * server used. If the SocketType parameter is sunrpc_tcp or
173 * sunrpc_udp, * the second argument specifies the program name and
174 * the third argument specifies the version of the program. For
175 * services that the inetd daemon provides internally, this field
179 else if (optind == 1 && argc >= 3)
187 argv_r = (char **) malloc(argc * sizeof(char *));
190 for (i=optind+2, j=1; i<argc; i++,j++)
192 parse_args(argc-2, argv_r);
194 free((void *) argv_r);
200 fprintf (stderr, "Usage: %s [-d] [-s] [-g hhmm]\n", pgname);
207 char *dir = _DtCMS_DEFAULT_DIR;
216 "%s: must be run in super-user mode! Exited.\n",
222 if (stat(dir, &info))
224 /* if directory does not exist, create the directory */
225 if ((errno != ENOENT) || mkdir(dir, S_IRWXU|S_IRWXG|S_IRWXO))
228 sprintf(msgbuf, "%s: cannot create %s.\n%s: %s",
229 pgname, dir, pgname, "System error");
231 sprintf(msgbuf, "%s: cannot access %s.\n%s: %s",
232 pgname, dir, pgname, "System error");
239 /* if dir is just created, we need to do chmod and chown.
240 * Otherwise, only do chmod and/or chown if permssion and/or
241 * ownership is wrong.
243 mode = S_ISGID|S_ISVTX|S_IRWXU|S_IRWXG|S_IRWXO;
245 if (create_dir || info.st_mode != (mode | S_IFDIR)) {
247 /* set directory permission to be "rwxrwsrwt" */
248 if (chmod(dir, mode)) {
249 sprintf(msgbuf, "%s: Permission on %s%s\n%s%s\n%s%s",
251 " is wrong but cannot be corrected.", pgname,
252 ": This might happen if you are mounting the directory.",
253 pgname, ": System error");
261 if (create_dir || info.st_uid!=daemon_uid || info.st_gid!=daemon_gid) {
262 /* set directory ownership to: owner = 1, group = 1 */
263 if (chown(dir, daemon_uid, daemon_gid)) {
264 sprintf(msgbuf, "%s: Ownership on %s%s\n%s%s\n%s%s",
266 " is wrong but cannot be corrected.", pgname,
267 ": This might happen if you are mounting the directory.",
268 pgname, ": System error");
276 /* Change current directory, so core file can be dumped. */
277 if(-1 == chdir (dir)) {
278 perror(strerror(errno));
283 * send a SIGHUP signal to the rpc.cmsd that is already running
290 pid_t pid, mypid = getpid();
291 extern FILE *popen(const char *, const char *);
292 extern int pclose(FILE *);
294 sprintf(buf, "ps -e|grep rpc.cmsd|grep -v grep");
296 if ((fp = popen(buf, "r")) == NULL) {
298 fprintf(stderr, "rpc.cmsd: popen failed\n");
300 while (fgets(buf, sizeof(buf), fp) != NULL) {
301 if ((pid = atol(buf)) != mypid) {
302 if (kill(pid, SIGHUP))
303 perror("rpc.cmsd: failed to send SIGHUP");
305 fprintf(stderr, "rpc.cmsd: %s %ld\n",
306 "sent SIGHUP to", (long)pid);
314 * We only allow one rpc.cmsd to run on each machine.
319 char *dir = _DtCMS_DEFAULT_DIR;
320 char buff [MAXPATHLEN];
325 locker.l_type = F_WRLCK;
332 * /var/spool might be mounted. Use .lock.hostname to
333 * prevent more than one cms running in each host.
335 snprintf(buff, sizeof(buff), "%s/.lock.%s", dir, _DtCmGetLocalHost());
337 fd = open(buff, O_WRONLY|O_CREAT, S_IRUSR|S_IWUSR|S_IRGRP|S_IWGRP);
345 * Note, we have to use flock() instead of lockf() because cms process
346 * is run in each host.
349 if (fcntl (fd, F_SETLK, &locker) != 0)
351 if (flock (fd, LOCK_EX|LOCK_NB) != 0)
358 if (error != EWOULDBLOCK && error != EACCES) {
360 perror ("rpc.cmsd: failed to lock lockfile");
361 fprintf(stderr, "error = %d\n", error);
366 fprintf(stderr, "rpc.cmsd: %s\n",
367 "lock_it failed due to another process");
369 /* cms has been running.... */
378 program(struct svc_req *rqstp, SVCXPRT *transp)
381 char *argument = NULL;
382 program_handle ph = getph();
383 struct rpcgen_table *proc;
385 /* set rpc_in_process so that sighup handler won't exit right away */
388 /* first do some bounds checking: */
389 if (rqstp->rq_vers >= ph->nvers) {
390 svcerr_noproc(transp);
393 if (ph->prog[rqstp->rq_vers].nproc == 0) {
394 svcerr_noproc(transp);
397 if (rqstp->rq_proc >= ph->prog[rqstp->rq_vers].nproc) {
398 svcerr_noproc(transp);
402 if (rqstp->rq_proc == NULLPROC) {
403 if (debug) fprintf(stderr, "rpc.cmsd: ping\n");
404 (void)svc_sendreply(transp, (xdrproc_t)xdr_void, (caddr_t)NULL);
408 /* assert - the program number, version and proc numbers are valid */
409 proc = &(ph->prog[rqstp->rq_vers].vers[rqstp->rq_proc]);
410 argument = (char*)calloc(proc->len_arg, sizeof(char));
411 if (!svc_getargs(transp, proc->xdr_arg, argument)) {
412 svcerr_decode(transp);
416 result = (*proc->proc)(argument, rqstp);
417 if (result != NULL && !svc_sendreply(transp, proc->xdr_res, result)) {
418 svcerr_systemerr(transp);
421 if (!svc_freeargs(transp, proc->xdr_arg, argument)) {
422 (void)fprintf(stderr, "unable to free arguments");
430 /* exit if we have received the SIGHUP signal */
431 if (received_sighup == 1) {
433 fprintf(stderr, "rpc.cmsd: received SIGHUP, %s",
434 "exiting after finished processing\n");
440 * Signal handler for SIGHUP.
441 * If we are in the middle of processing a client request,
442 * finish processing before we exit.
445 sighup_handler(int sig_num)
448 fprintf(stderr, "rpc.cmsd: sighup received\n");
450 if (rpc_in_process == 0) {
452 fprintf(stderr, "rpc.cmsd: exit from sighup_handler\n");
456 fprintf(stderr, "rpc.cmsd: set received_sighup to 1\n");
462 * garbage_collection_time (in min) is the time to do garbage collection
464 * This routine returns the difference between the first garbage collection
465 * time and now so that the calling routine can set the alarm.
468 _GetFirstGarbageCollectionTime(void)
470 int n=0, midnight=0, gtime=0;
474 /* try today first */
475 midnight = next_ndays(n, 0);
476 gtime = next_nmins(midnight, garbage_collection_time);
479 /* the first garbage collection will be done tomorrow */
480 midnight = next_ndays(n, 1);
481 gtime = next_nmins(midnight, garbage_collection_time);
491 extern void garbage_collect();
492 extern void debug_switch();
494 #if defined(SVR4) && !defined(__linux__)
495 extern void (*sigset(int, void (*)(int)))(int);
496 sigset(SIGUSR1, garbage_collect);
497 sigset(SIGALRM, garbage_collect);
498 sigset(SIGUSR2, debug_switch);
500 signal(SIGUSR1, garbage_collect);
501 signal(SIGALRM, garbage_collect);
502 signal(SIGUSR2, debug_switch);
505 next = _GetFirstGarbageCollectionTime();
506 alarm((unsigned) next);
510 main(int argc, char **argv)
513 program_handle ph = newph();
517 struct sockaddr_in saddr;
518 int asize = sizeof (saddr);
519 SVCXPRT *tcp_transp = (SVCXPRT *)-1;
520 SVCXPRT *udp_transp = (SVCXPRT *)-1;
524 struct netconfig *nconf_udp;
525 struct netconfig *nconf_tcp;
527 char mname[FMNAMESZ+1];
530 pw = (struct passwd *)getpwnam("daemon");
531 gr = (struct group *)getgrnam("daemon");
533 daemon_uid = pw->pw_uid;
537 daemon_gid = gr->gr_gid;
541 parse_args(argc, argv);
543 /* check to see if we are started by inetd */
544 if (getsockname(0, (struct sockaddr *)&saddr, &asize) == 0) {
549 /* we need a TLI endpoint rather than a socket */
550 if (ioctl(0, I_LOOK, mname) != 0) {
551 perror("rpc.cmsd: ioctl failed to get module name");
554 if (strcmp(mname, "sockmod") == 0) {
555 /* Change socket fd to TLI fd */
556 if (ioctl(0, I_POP, 0) || ioctl(0, I_PUSH, "timod")) {
557 perror("rpc.cmsd: ioctl I_POP/I_PUSH failed");
560 } else if (strcmp(mname, "timod") != 0) {
561 fprintf(stderr, "rpc.cmsd: fd 0 is not timod\n");
565 } else if (t_getinfo(0, &info) == 0) {
574 * if it is started by inetd, make stderr to be
578 if ((fd = open ("/dev/console", O_WRONLY)) >= 0) {
586 /* Set up private directory and switch euid/egid to daemon. */
590 /* Don't allow multiple cms processes running in the same host. */
591 if ((error = lock_it()) != 0 && !standalone) {
592 /* we are invoked by inetd but another rpc.cmsd
593 * is alreay running, so send SIGHUP to it
598 /* try to lock it again */
599 if (lock_it() != 0) {
601 fprintf(stderr, "cm: rpc.cmsd is still running\n");
605 } else if (error != 0) {
606 fprintf(stderr, "rpc.cmsd: rpc.cmsd is already running.\n");
610 /* use signal because we only need it once */
611 signal(SIGHUP, sighup_handler);
615 /* raise the soft limit of number of file descriptor */
616 /* this is to prevent the backend from running out of open file des */
617 getrlimit(RLIMIT_NOFILE, &rl);
618 rl.rlim_cur = (rl.rlim_max <= 256) ? rl.rlim_max : 256;
619 setrlimit(RLIMIT_NOFILE, &rl);
623 nconf_udp = getnetconfigent("udp");
624 nconf_tcp = getnetconfigent("tcp");
626 for (version = 0; version < ph->nvers; version++) {
627 /* don't register unsupported versions: */
628 if (ph->prog[version].nproc == 0) continue;
631 rpcb_unset(ph->program_num, version, NULL);
634 "rpc.cmsd: rpcb_unset for version %ld\n",
638 /* brought up by inetd, use fd 0 which must be a TLI fd */
639 if (udp_transp == (SVCXPRT *)-1) {
640 udp_transp = svc_tli_create(standalone ? RPC_ANYFD : 0,
641 nconf_udp, (struct t_bind*) NULL, 0, 0);
643 if (udp_transp == NULL) {
644 t_error("rtable_main.c: svc_tli_create(udp)");
649 if (svc_reg(udp_transp, ph->program_num, version, program,
650 standalone ? nconf_udp : NULL) == 0) {
651 t_error("rtable_main.c: svc_reg");
655 /* Set up tcp for calls that potentially return */
656 /* large amount of data. This transport is not */
657 /* registered with inetd so need to register it */
658 /* with rpcbind ourselves. */
660 rpcb_unset(ph->program_num, version, nconf_tcp);
662 if (tcp_transp == (SVCXPRT *)-1) {
663 tcp_transp = svc_tli_create(RPC_ANYFD, nconf_tcp,
664 (struct t_bind *)NULL, 0, 0);
666 if (tcp_transp == NULL) {
667 t_error("rtable_main.c: svc_til_create(tcp)");
672 if (svc_reg(tcp_transp, ph->program_num, version, program,
674 t_error("rtable_main.c: svc_reg(tcp)");
680 freenetconfigent(nconf_udp);
682 freenetconfigent(nconf_tcp);
686 for (version = 0; version < ph->nvers; version++) {
687 /* don't register unsupported versions: */
688 if (ph->prog[version].nproc == 0) continue;
693 (void) pmap_unset(ph->program_num, version);
695 if (udp_transp == (SVCXPRT *)-1) {
696 udp_transp = svcudp_create(standalone ? RPC_ANYSOCK : 0
697 #if defined(_AIX) || defined(hpV4) || defined(__linux__) || defined(CSRG_BASED)
702 if (udp_transp == NULL) {
703 (void)fprintf(stderr,
704 "rtable_main.c: cannot create udp service.\n");
710 if (!svc_register(udp_transp, ph->program_num, version, program,
711 standalone ? IPPROTO_UDP : 0)) {
713 if (!svc_register(udp_transp, ph->program_num, version, program,
716 (void)fprintf(stderr, "rtable_main.c: unable to register");
720 /* Set up tcp for calls that potentially return */
721 /* large amount of data. This transport is not */
722 /* registered with inetd so need to register it */
723 /* with rpcbind ourselves. */
725 if (tcp_transp == (SVCXPRT *)-1) {
726 tcp_transp = svctcp_create(RPC_ANYSOCK, 0, 0);
727 if (tcp_transp == NULL) {
728 (void)fprintf(stderr,
729 "rtable_main.c: cannot create tcp service.\n");
734 if (!svc_register(tcp_transp, ph->program_num, version, program,
736 (void)fprintf(stderr, "rtable_main.c: unable to register(tcp)");
748 if(-1 == setegid (daemon_gid)) {
749 perror(strerror(errno));
751 if(-1 == seteuid (daemon_uid)) {
752 perror(strerror(errno));
763 (void)fprintf(stderr, "rpc.cmsd: svc_run returned\n");