Annotation of freem/src/mumps.c, revision 1.20

1.1       snw         1: /*
1.20    ! snw         2:  *   $Id: mumps.c,v 1.19 2025/04/10 01:24:38 snw Exp $
1.1       snw         3:  *    main module of freem
                      4:  *
                      5:  *  
1.3       snw         6:  *   Author: Serena Willis <snw@coherent-logic.com>
1.1       snw         7:  *    Copyright (C) 1998 MUG Deutschland
1.4       snw         8:  *    Copyright (C) 2020, 2025 Coherent Logic Development LLC
1.1       snw         9:  *
                     10:  *
                     11:  *   This file is part of FreeM.
                     12:  *
                     13:  *   FreeM is free software: you can redistribute it and/or modify
                     14:  *   it under the terms of the GNU Affero Public License as published by
                     15:  *   the Free Software Foundation, either version 3 of the License, or
                     16:  *   (at your option) any later version.
                     17:  *
                     18:  *   FreeM is distributed in the hope that it will be useful,
                     19:  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
                     20:  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
                     21:  *   GNU Affero Public License for more details.
                     22:  *
                     23:  *   You should have received a copy of the GNU Affero Public License
                     24:  *   along with FreeM.  If not, see <https://www.gnu.org/licenses/>.
                     25:  *
1.5       snw        26:  *   $Log: mumps.c,v $
1.20    ! snw        27:  *   Revision 1.19  2025/04/10 01:24:38  snw
        !            28:  *   Remove C++ style comments
        !            29:  *
1.19      snw        30:  *   Revision 1.18  2025/04/09 19:52:02  snw
                     31:  *   Eliminate as many warnings as possible while building with -Wall
                     32:  *
1.18      snw        33:  *   Revision 1.17  2025/04/04 21:28:16  snw
                     34:  *   Remove custom_user and custom_group vars from freem and shed privileges per environment catalog settings
                     35:  *
1.17      snw        36:  *   Revision 1.16  2025/04/04 19:43:18  snw
                     37:  *   Switch to using environment catalog to determine user and group for environment, and remove -u and -g flags from freem
                     38:  *
1.16      snw        39:  *   Revision 1.15  2025/04/03 20:48:14  snw
                     40:  *   Improve daemon error diagnostics and bump to 0.63.0-rc3
                     41:  *
1.15      snw        42:  *   Revision 1.14  2025/04/02 04:50:49  snw
                     43:  *   Allow vendor routines to be upgraded
                     44:  *
1.14      snw        45:  *   Revision 1.13  2025/04/02 03:26:22  snw
                     46:  *   Don't corrupt the terminal if FreeM runs before fmadm configure has been run
                     47:  *
1.13      snw        48:  *   Revision 1.12  2025/04/02 02:16:27  snw
                     49:  *   Add fmadm status environment command and move journals to a better location
                     50:  *
1.12      snw        51:  *   Revision 1.11  2025/04/01 23:21:45  snw
                     52:  *   fmadm commands for stopping, starting, and restarting environments now functional
                     53:  *
1.11      snw        54:  *   Revision 1.10  2025/04/01 20:11:46  snw
                     55:  *   Further work on fmadm
                     56:  *
1.10      snw        57:  *   Revision 1.9  2025/03/31 20:01:13  snw
                     58:  *   Set d_uid in daemon
                     59:  *
1.9       snw        60:  *   Revision 1.8  2025/03/24 16:10:48  snw
                     61:  *   Print error message and exit on OS/2 if daemon is run without --nofork
                     62:  *
1.8       snw        63:  *   Revision 1.7  2025/03/24 16:07:55  snw
                     64:  *   Force daemon into foreground on OS/2
                     65:  *
1.7       snw        66:  *   Revision 1.6  2025/03/24 16:04:49  snw
                     67:  *   Force daemon into foreground on OS/2
                     68:  *
1.6       snw        69:  *   Revision 1.5  2025/03/22 21:44:32  snw
                     70:  *   Make the startup messages fewer and add environment name to direct-mode prompt
                     71:  *
1.5       snw        72:  *   Revision 1.4  2025/03/09 19:50:47  snw
                     73:  *   Second phase of REUSE compliance and header reformat
                     74:  *
1.4       snw        75:  *
                     76:  * SPDX-FileCopyrightText:  (C) 2025 Coherent Logic Development LLC
                     77:  * SPDX-License-Identifier: AGPL-3.0-or-later
1.1       snw        78:  **/
                     79: 
1.16      snw        80: #define _GNU_SOURCE
1.1       snw        81: #include <stdlib.h>
                     82: #include <stddef.h>
                     83: #include "mpsdef.h"
                     84: #include "errmsg.h"
                     85: #include "iniconf.h"
                     86: #include "namespace.h"
                     87: #include "transact.h"
                     88: #include "init.h"
                     89: #include "consttbl.h"
                     90: #include <setjmp.h>
                     91: #include <stdio.h>
                     92: #include <signal.h>
                     93: #include <time.h>
                     94: #include <unistd.h>
                     95: #include <sys/types.h>
                     96: #include <sys/wait.h>
                     97: #include <sys/stat.h>
                     98: #include <limits.h>
                     99: #include <sys/types.h>
                    100: #include <pwd.h>
                    101: #include <string.h>
                    102: #include <fcntl.h>
                    103: #include "version.h"
                    104: #include "shmmgr.h"
                    105: #include "jobtab.h"
                    106: #include <errno.h>
                    107: #include <pwd.h>
                    108: #include <grp.h>
                    109: 
                    110: 
                    111: #if defined(HAVE_GETOPT_H)
                    112: # include <getopt.h>
                    113: #endif
                    114: 
                    115: #if !defined(PATH_MAX) && defined(_SCO_DS)
                    116: # define PATH_MAX 1024
                    117: #endif
                    118: 
                    119: extern int xecline(int typ);
                    120: extern char *getenv(const char *name);
                    121: void freem_usage(void);
                    122: void freem_print_version(void);
                    123: void init_ztrap(void);
                    124: void m_log (int, const char *);
                    125: 
                    126: int main (int argc, char **argv, char **envp)
                    127: {
                    128:     pid_t fork_pid = 0;
                    129:     short dx_mode = 0;
                    130:     
                    131:     int c;
                    132:     int import_env = FALSE;
                    133:     short skip_init = 0;
                    134:     
                    135:     int option_index = 0;
                    136: 
1.13      snw       137:     char fm_initialized = FALSE;
                    138:     
1.1       snw       139:     char dx_mcode[512];
                    140:     char startup_routine[256];
                    141:     short routine_mode;
                    142:     char m_dialect[50];
                    143: 
                    144:     char nsnbuf[256];
                    145: 
                    146:     char d_username[40];
                    147:     char d_groupname[40];
                    148:     struct group *d_grp;
                    149:     struct passwd *d_user;
                    150:     gid_t d_gid;
                    151:     uid_t d_uid;
                    152: 
                    153: #if defined(HAVE_GETOPT_LONG)
                    154:     struct option long_options[] = {       
                    155:         {"help", no_argument, 0, 'h'},
                    156:         {"filter", no_argument, &frm_filter, TRUE},
                    157:         {"standard", required_argument, 0, 's'},
                    158:         {"import", no_argument, &import_env, TRUE},
                    159:         {"quiet", no_argument, &quiet_mode, TRUE},
                    160:         {"restricted", no_argument, &restricted_mode, TRUE},
                    161:         {"routine", required_argument, 0, 'r'},
                    162:         {"namespace", required_argument, 0, 'n'},
                    163:         {"environment", required_argument, 0, 'e'},
                    164:        {"version", no_argument, 0, 'v'},
                    165:        {"execute", required_argument, 0, 'x'},
                    166:         {"daemon", no_argument, 0, 'd'},
                    167:         {"nofork", no_argument, 0, 'k'},
                    168:         {"shmsize", required_argument, 0, 'S'},
                    169:         {"user", required_argument, 0, 'u'},
                    170:         {"group", required_argument, 0, 'g'},
                    171:         {0, 0, 0, 0}
                    172:     };
                    173: #endif
                    174:     
                    175:     char **env;      
                    176:     char *varname = (char *) calloc(STRLEN, sizeof(char));
                    177:     char *varval = (char *) calloc(STRLEN, sizeof(char));
                    178: 
                    179:     char *symname = (char *) calloc(STRLEN, sizeof(char));
                    180:     char *symval = (char *) calloc(STRLEN, sizeof(char));
1.18      snw       181:     
1.1       snw       182:     char cli_rtn_path[PATH_MAX] = {0};
                    183:     char *cli_rtn_file;
                    184:     char cli_rtn_name[256];
                    185: 
1.16      snw       186:     char env_ena[25];
                    187:     
1.1       snw       188:     routine_mode = FALSE;
                    189:     strcpy (m_dialect, "FREEM");
                    190:     
                    191:     m_argc = argc;                     /* save arguments count     */
                    192:     m_argv = argv;                     /* save arguments string    */
                    193:     m_envp = envp;                     /* save environment pointer */
                    194: 
                    195:     strncpy (shm_env, "DEFAULT", 8);    /* establish default environment name */
                    196:     
                    197:     strncpy (d_username, "freem", 40);
                    198:     strncpy (d_groupname, "freem", 40);
                    199:     
                    200:     strcpy (zb, argv[0]);              /* name with which mumps has been called */
                    201:     stcnv_c2m (zb);
                    202:     strcpy (stack0, argv[0]);
                    203:     stcnv_c2m (stack0);
                    204: 
                    205: 
                    206:     /* strncpy (config_file, SYSCONFDIR"/freem.conf", 100); */
                    207: 
                    208: 
                    209: 
                    210: #if defined(HAVE_GETOPT_LONG)
                    211:     
                    212:     extern char *optarg;
                    213:     extern int optind, optopt;
                    214:     
                    215:     while (1) {
                    216:         
1.16      snw       217:         c = getopt_long (argc, argv, "hsfiqRr:n:e:vx:dkpS", long_options, &option_index);
1.1       snw       218: 
                    219:         if (c == -1) break;
                    220:        if (c == '?') freem_usage ();
                    221:        
                    222:         switch (c) {
                    223:             case 'h':
                    224:                 freem_usage ();
                    225:                 break;
                    226: 
                    227:             case 'f':
                    228:                 frm_filter = TRUE;
                    229:                 break;
                    230: 
                    231:             case 'i':
                    232:                 import_env = TRUE;
                    233:                 break;
                    234: 
                    235:             case 'q':
                    236:                 quiet_mode = TRUE;
                    237:                 break;
                    238: 
                    239:             case 'e': /* specify FreeM environment */
1.19      snw       240:                 strncpy (shm_env, optarg, sizeof (shm_env) - 1);
1.1       snw       241:                 break;
                    242: 
                    243:             case 'R':
                    244:                 restricted_mode = TRUE;
                    245:                 break;
                    246: 
                    247:             case 'r': /* startup routine */
                    248:                 direct_mode = FALSE;
                    249:                 usermode = 0;
                    250: 
                    251:                 strcpy (startup_routine, optarg);
                    252:                 startup_routine[strlen (startup_routine)] = '\201';
                    253: 
                    254:                 routine_mode = TRUE;
                    255:                 break;
                    256: 
                    257:             case 'n': /* namespace */
                    258:             {
                    259:                 if (validate_namespace (optarg) == TRUE) {                
                    260:                     strcpy (nsname, optarg);
                    261:                 }
                    262:                 else {
                    263:                     fprintf (stderr, "freem:  invalid namespace '%s'\n", optarg);
                    264:                     exit (1);
                    265:                 }
                    266:                 
                    267:                 break;
                    268:             }
                    269:            case 'v': /* version */
                    270:                freem_print_version ();
                    271:                break;
                    272: 
                    273:            case 'x': /* execute */
                    274:                direct_mode = FALSE;
                    275:                usermode = 0;
                    276:                dx_mode = 1;
                    277:                
                    278:                strncpy (dx_mcode, optarg, 512 - 1);
                    279: 
                    280:                stcnv_c2m (dx_mcode);
                    281: 
                    282:                break;
                    283: 
                    284:             case 's': /* --standard */
                    285: 
                    286:                 if (strcmp (optarg, "M77") == 0) {
                    287:                     standard = D_M77;
                    288:                     strcpy (m_dialect, "M 1977");
                    289:                 }
                    290:                 else if (strcmp (optarg, "M84") == 0) {
                    291:                     standard = D_M84;
                    292:                     strcpy (m_dialect, "M 1984");
                    293:                 }
                    294:                 else if (strcmp (optarg, "M90") == 0) {
                    295:                     standard = D_M90;
                    296:                     strcpy (m_dialect, "M 1990");
                    297:                 }
                    298:                 else if (strcmp (optarg, "M95") == 0) {
                    299:                     standard = D_M95;
                    300:                     strcpy (m_dialect, "M 1995");
                    301:                 }
                    302:                 else if (strcmp (optarg, "MDS") == 0) {
                    303:                     standard = D_MDS;
                    304:                     strcpy (m_dialect, "Millennium Draft Standard");
                    305:                 }
                    306:                 else if (strcmp (optarg, "M5") == 0) {
                    307:                     standard = D_M5;
                    308:                     strcpy (m_dialect, "M5");
                    309:                 }
                    310:                 else if (strcmp (optarg, "FREEM") == 0) {
                    311:                     standard = D_FREEM;
                    312:                     strcpy (m_dialect, "FREEM");
                    313:                 }
                    314:                 else {
                    315:                     freem_usage ();
                    316:                 }
                    317:                 
                    318:                 break;                
                    319: 
                    320:             case 'd': /* --daemon */
                    321:                 run_daemon = TRUE;                
                    322:                 break;
                    323: 
                    324:             case 'k': /* --nofork */
                    325:                nofork = TRUE;
                    326:                 break;
                    327: 
                    328:             case 'S': /* --shmsize */
                    329:                 shm_init_size = atol (optarg);
1.16      snw       330:                 break;                
1.1       snw       331: 
                    332:         } 
                    333: 
                    334:     }
                    335: 
                    336: #else
                    337:     
                    338:     {
                    339:         extern char *optarg;
                    340:         extern int optind, optopt;
                    341: 
1.16      snw       342:         while ((c = getopt (argc, argv, "hsfiqRr:n:e:vx:dkS:")) != -1) {
1.1       snw       343: 
                    344:            if (c == '?') freem_usage ();
                    345:            
                    346:             switch (c) {
                    347: 
                    348:                case 'h':
                    349:                    freem_usage ();
                    350:                    break;
                    351:                
                    352:                 case 'f':
                    353:                     frm_filter = TRUE;
                    354:                     break;
                    355: 
                    356:                 case 'i':
                    357:                     import_env = TRUE;
                    358:                     break;
                    359: 
                    360:                 case 'q':
                    361:                     quiet_mode = TRUE;
                    362:                     break;
                    363: 
                    364:                 case 'e':  /* specify FreeM environment */
1.19      snw       365:                     strncpy (shm_env, optarg, sizeof (shm_env) - 1);
1.1       snw       366:                     break;
                    367: 
                    368:                 case 'R':
                    369:                     restricted_mode = TRUE;
                    370:                     break;
                    371:                     
                    372:                 case 'r': /* startup routine */
                    373:                     direct_mode = FALSE;
                    374:                     usermode = 0;
                    375: 
                    376:                     strcpy (startup_routine, optarg);
                    377:                     startup_routine[strlen (startup_routine)] = '\201';
                    378: 
                    379:                     routine_mode = TRUE;
                    380:                     break;
                    381: 
                    382:                 case 'n': /* namespace */
                    383:                     strcpy (nsname, optarg);               
                    384:                     break;
                    385: 
                    386:                case 'v':
                    387:                    freem_print_version ();
                    388:                    break;
                    389: 
                    390:                case 'x': /* execute */
                    391:                    direct_mode = FALSE;
                    392:                    usermode = 0;
                    393:                    dx_mode = 1;
                    394:                    
                    395:                    strncpy (dx_mcode, optarg, 512 - 1);
                    396:                    
                    397:                    stcnv_c2m (dx_mcode);
                    398: 
                    399:                     break;
                    400:                     
                    401:                 case 'd': /* --daemon */
                    402:                     run_daemon = TRUE;
                    403:                     break;
                    404: 
                    405:                 case 'k': /* --nofork */
                    406:                     nofork = TRUE;
                    407:                     break;
                    408: 
                    409:                 case 's': /* --standard */
                    410:                     
                    411:                     if (strcmp (optarg, "M77") == 0) {
                    412:                         standard = D_M77;
                    413:                         strcpy (m_dialect, "M 1977");
                    414:                     }
                    415:                     else if (strcmp (optarg, "M84") == 0) {
                    416:                         standard = D_M84;
                    417:                         strcpy (m_dialect, "M 1984");
                    418:                     }
                    419:                     else if (strcmp (optarg, "M90") == 0) {
                    420:                         standard = D_M90;
                    421:                         strcpy (m_dialect, "M 1990");
                    422:                     }
                    423:                     else if (strcmp (optarg, "M95") == 0) {
                    424:                         standard = D_M95;
                    425:                         strcpy (m_dialect, "M 1995");
                    426:                     }
                    427:                     else if (strcmp (optarg, "MDS") == 0) {
                    428:                         standard = D_MDS;
                    429:                         strcpy (m_dialect, "Millennium Draft Standard");
                    430:                     }
                    431:                     else if (strcmp (optarg, "M5") == 0) {
                    432:                         standard = D_M5;
                    433:                         strcpy (m_dialect, "M5");
                    434:                     }
                    435:                     else if (strcmp (optarg, "FREEM") == 0) {
                    436:                         standard = D_FREEM;
                    437:                         strcpy (m_dialect, "FREEM");
                    438:                     }
                    439:                     else {
                    440:                         freem_usage ();
                    441:                     }
                    442:                 
                    443:                     break;                
                    444: 
                    445:                     
                    446:                 case 'S': /* --shmsize */
                    447:                     shm_init_size = atol (optarg);
                    448:                     break;
                    449: 
                    450:             } 
                    451:         }
                    452:     }
                    453: #endif
1.6       snw       454: 
                    455: #if defined(__OS2__)
                    456:     if (run_daemon == TRUE && nofork == FALSE) {
1.8       snw       457:         printf ("freem:  running on OS/2; daemon must be run with --nofork or -k\r\n");
                    458:         exit (1);
1.6       snw       459:     }
                    460: #endif
                    461:     
1.20    ! snw       462:     snprintf (config_file, sizeof (config_file) - 1, "%s/freem/%s/freem.conf", SYSCONFDIR, shm_env);
        !           463:     snprintf (env_config_file, sizeof (config_file) - 1, "%s/freem/env.conf", SYSCONFDIR);    
1.1       snw       464:     
1.16      snw       465:     if (!file_exists (env_config_file)) {
                    466:         fprintf (stderr, "freem:  environment catalog does not exist; may need to run fmadm configure\n");
                    467:         exit (1);
                    468:     }
                    469: 
                    470:     if (!file_exists (config_file)) {
                    471:         fprintf (stderr, "freem:  configuration file for %s does not exist; may need to run fmadm configure\n", shm_env);
                    472:         exit (1);
                    473:     }
                    474: 
                    475:     if (read_profile_string (env_config_file, shm_env, "user", d_username) == FALSE) {
                    476:         fprintf (stderr, "freem:  could not determine owning user for environment %s\n", shm_env);
                    477:         exit (1);
                    478:     }
                    479: 
                    480:     if (read_profile_string (env_config_file, shm_env, "group", d_groupname) == FALSE) {
                    481:         fprintf (stderr, "freem:  could not determine owning group for environment %s\n", shm_env);
                    482:         exit (1);
                    483:     }
1.1       snw       484: 
1.16      snw       485:     if (read_profile_string (env_config_file, shm_env, "enabled", env_ena) == FALSE) {
                    486:         fprintf (stderr, "freem:  could not discover enabled state for environment %s\n", shm_env);
                    487:         exit (1);
                    488:     }
1.1       snw       489: 
1.16      snw       490:     if (strcmp (env_ena, "true") != 0) {
                    491:         fprintf (stderr, "freem:  environment %s is administratively disabled\n", shm_env);
                    492:         exit (1);
                    493:     }    
1.1       snw       494: 
1.16      snw       495:     d_grp = getgrnam (d_groupname);        
                    496:     if (d_grp == NULL) {
                    497:         fprintf (stderr, "freem:  invalid group '%s'\n", d_groupname);
                    498:         exit (1);
                    499:     }            
                    500:     d_gid = d_grp->gr_gid;
                    501:         
                    502:     d_user = getpwnam (d_username);
                    503:     if (d_user == NULL) {
                    504:         fprintf (stderr, "freem:  invalid user '%s'\n", d_username);
                    505:         exit (1);
                    506:     }            
                    507:     d_uid = d_user->pw_uid;
1.1       snw       508: 
1.16      snw       509:     
                    510: #if defined(__linux__)    
                    511:     if (run_daemon == FALSE && group_member (d_gid) == 0) {
                    512:         fprintf (stderr, "freem:  you must be a member of the %s group to use environment %s\n", d_groupname, shm_env);
                    513:         exit (1);
1.17      snw       514:     }        
1.16      snw       515: #endif    
                    516:     
                    517:     if (run_daemon == TRUE) {
                    518:         if (geteuid () != 0 && nofork == FALSE) {
                    519:             fprintf (stderr, "freem:  forking daemon must be run as root\n");
                    520:             exit (1);
                    521:         }                
1.1       snw       522:     }
                    523:     
                    524:     if ((nofork == TRUE) && (run_daemon == FALSE)) {
                    525:         freem_usage ();
                    526:         exit (1);
                    527:     }
                    528: 
                    529:     if ((run_daemon == TRUE) && (nofork == FALSE)) {
                    530: 
                    531:         int fork_fd;
                    532:         
                    533:         /* daemonize */
                    534: 
                    535:         fork_pid = fork ();
                    536: 
                    537:         if (fork_pid < 0) {
                    538:             fprintf (stderr, "freem:  failure in fork()\r\n");
                    539:             m_log (1, "failure in initial fork()\r\n");
                    540:             exit (1);
                    541:         }
                    542: 
                    543:         if (fork_pid > 0) {
                    544:             exit (0);
                    545:         }
                    546: 
                    547:         if (setsid () < 0) {
                    548:             fprintf (stderr, "freem:  failure in setsid()\r\n");
                    549:             m_log (1, "failure in setsid()\r\n");
                    550:             exit (1);
                    551:         }
                    552: 
                    553:         signal (SIGCHLD, SIG_IGN);
                    554: 
                    555:         fork_pid = fork ();
                    556: 
                    557:         if (fork_pid < 0) {
                    558:             fprintf (stderr, "freem:  failure in fork()\r\n");
                    559:             m_log (1, "failure in second fork()\r\n");
                    560:             exit (1);
                    561:         }
                    562: 
                    563:         if (fork_pid > 0) {
                    564:             exit (0);
                    565:             m_log (1, "exiting from second fork");
                    566:         }
                    567: 
                    568:         umask (0);
                    569: 
                    570:         chdir ("/");       
                    571: 
                    572:         for (fork_fd = sysconf (_SC_OPEN_MAX); fork_fd > 0; fork_fd--) {
                    573:             close (fork_fd);
                    574:         }
                    575:         
                    576:         if (geteuid () == 0) {
                    577:             /* shed privileges */
                    578: 
1.17      snw       579: 
                    580:             fprintf (stderr, "freem:  switching to group %s\n", d_groupname);
                    581:             m_log (1, "switching groups");
                    582:                 
                    583:             if (setgid (d_gid) == -1) {
                    584:                 fprintf (stderr, "freem:  failure switching GID\n");
                    585:                 m_log (1, "failure switching GIDs");
                    586:                 exit (1);
1.1       snw       587:             }
1.17      snw       588:         
1.1       snw       589: 
                    590: 
1.17      snw       591:             if (d_uid != geteuid ()) {
1.1       snw       592:                 fprintf (stderr, "freem:  switching to username %s\n", d_username);
                    593:                 m_log (1, "switching users");
                    594:                 
                    595:                 if (setuid (d_uid) == -1) {
                    596:                     fprintf (stderr, "freem:  failure switching UID\n");
                    597:                     m_log (1, "failure switching UIDs");
                    598:                     exit (1);
                    599:                 }
                    600:             }
                    601: 
                    602:         }
                    603:         else {
                    604:             fprintf (stderr, "not euid 0");
                    605:         }
                    606: 
                    607:        freopen ("/dev/null", "r", stdin);
                    608:        freopen ("/dev/null", "w+", stdout);
                    609:        freopen ("/dev/null", "w+", stderr);
                    610: 
                    611:         run_daemon = TRUE;
                    612:         nofork = FALSE;        
                    613:         
                    614:         {
                    615:             char pidfile_buf[256];
                    616:             int errsav;
                    617: 
1.11      snw       618:             pid_file_path = (char *) malloc (PATH_MAX * sizeof (char));
                    619:             NULLPTRCHK(pid_file_path,"main");
                    620:             
1.10      snw       621:             snprintf (pid_file_path, PATH_MAX - 1, "%s/freem/run/%s.pid", LOCALSTATEDIR, shm_env);
                    622: 
1.1       snw       623:             pid_fd = open (pid_file_path, O_RDWR | O_CREAT, 0640);
                    624:             errsav = errno;
                    625:             
                    626:             if (pid_fd < 0) {
1.15      snw       627:                 fprintf (stderr, "freem:  could not open PID file %s [%s]\n", pid_file_path, strerror (errsav));
1.1       snw       628:                 m_log (1, "freem:  could not open PID file");
                    629:                 m_log (1, strerror (errsav));
                    630:                 exit (1);
                    631:             }
                    632: 
                    633:             if (lockf (pid_fd, F_TLOCK, 0) < 0) {
                    634:                 errsav = errno;
1.15      snw       635:                 fprintf (stderr, "freem:  could not lock PID file [%s]\n", strerror (errsav));
1.1       snw       636:                 m_log (1, "freem: could not lock PID file - perhaps already running?");
                    637:                 m_log (1, strerror (errsav));
                    638:                 exit (1);
                    639:             }
                    640: 
1.10      snw       641:             sprintf (pidfile_buf, "%ld\n", (long) getpid ());
1.1       snw       642:             write (pid_fd, pidfile_buf, strlen (pidfile_buf));
1.10      snw       643: 
1.1       snw       644:         }
                    645:        
                    646:         
                    647:     } /* END of daemonization */
                    648:     
                    649:     /* handle passing of an arbitrary .m file on the command line */
                    650:     /* this is most often used for shebang-line scripts. */
                    651:     if (optind < argc) {
                    652: 
                    653:         /* not valid for daemon mode */
                    654:         if (run_daemon == TRUE) {
                    655:             fprintf (stderr, "freem:  cannot pass --daemon flag in shebang line\r\n");
                    656:             exit (1);
                    657:         }
                    658:         
                    659:         /* bail if file does not exist */
                    660:         if (access (argv[optind], F_OK) == -1) {
                    661: 
                    662:             set_io (UNIX);
                    663:             
                    664:             fprintf (stderr, "Routine %s does not exist.\n", argv[optind]);
                    665: 
                    666:             exit (1);
                    667: 
                    668:         }
                    669: 
                    670:        skip_init = 1;
                    671: 
                    672:        /* initialize FreeM environment */
1.19      snw       673:        strncpy (nsnbuf, nsname, sizeof (nsnbuf));    
1.1       snw       674:        if (init (nsnbuf) == FALSE) {
                    675:            
1.14      snw       676:            if (fm_initialized) set_io (UNIX);
1.1       snw       677:            fprintf (stderr, "\nError initializing FreeM.\n");
                    678:            
                    679:            exit (1);            
                    680:            
1.13      snw       681:        }
                    682:         else {
                    683:             fm_initialized = TRUE;
                    684:         }
1.1       snw       685: 
                    686:        
                    687:         direct_mode = FALSE;
                    688:         usermode = 0;
                    689: 
                    690:         /* was a path specified at all? */
                    691:         if (strchr (argv[optind], '/') == NULL) {
                    692:            
                    693:             /* the entirety of argv[optind] is the filename */
                    694:             cli_rtn_file = argv[optind];            
                    695: 
                    696:             /* use the current directory */
                    697:             sprintf (cli_rtn_path, ".");
                    698: 
                    699:         }
                    700:         else {
                    701: 
                    702:             /* isolate the filename from the path */
                    703:             cli_rtn_file = strrchr (argv[optind], '/') + 1;
                    704:             
                    705:             /* isolate the routine name from the filename */
                    706:             strncpy (cli_rtn_name, cli_rtn_file, strchr (cli_rtn_file, '.') - cli_rtn_file);
                    707:             
                    708:             /* isolate the path from the routine file */
                    709:             strncpy (cli_rtn_path, argv[optind], strrchr (argv[optind], '/') - argv[optind]);      
                    710:            
                    711:         }
                    712: 
                    713:         /* do we have a file extension? */
                    714:         if (strchr (cli_rtn_file, '.') != NULL) {
                    715:             
                    716:             /* if so, just remove it */
                    717:             strncpy (cli_rtn_name, cli_rtn_file, strchr (cli_rtn_file, '.') - cli_rtn_file);
                    718: 
                    719:         }
                    720:         else {
                    721: 
                    722:             /* otherwise, just take a direct copy */
                    723:             strcpy (cli_rtn_name, cli_rtn_file);
                    724: 
                    725:         }
                    726: 
                    727:         /* make this the startup routine */
1.20    ! snw       728:         snprintf (startuprou, sizeof (startuprou) - 1, "^%s\201", cli_rtn_name);
1.1       snw       729: 
                    730:         /* re-work the namespace config to search for the 
                    731:            routine in the discovered path */
                    732:         if (cli_rtn_name[0] == '%') {
                    733: 
1.20    ! snw       734:             snprintf (rou0plib, sizeof (rou0plib) - 1, "%s\201", cli_rtn_path);
        !           735:             snprintf (rou1plib, sizeof (rou1plib) - 1, "%s\201", cli_rtn_path);
1.1       snw       736: 
                    737:         }
                    738:         else {
                    739: 
1.20    ! snw       740:             snprintf (rou0path, sizeof (rou0path) - 1, "%s\201", cli_rtn_path);
        !           741:             snprintf (rou1path, sizeof (rou1path) - 1, "%s\201", cli_rtn_path);
1.1       snw       742: 
                    743:         }
                    744: 
                    745:     }
                    746: 
1.13      snw       747:     
1.1       snw       748:     if (!file_exists (config_file)) {
                    749: 
1.13      snw       750:         if (fm_initialized == TRUE) set_io (UNIX);
                    751:         
1.1       snw       752:         fprintf (stderr, "\nFreeM has not been configured. Please run 'fmadm configure'.\n\n\n\n");
                    753:         
                    754:         exit (2);
                    755: 
                    756:     }
                    757: 
                    758:     if (!skip_init) {
                    759:        /* initialize FreeM environment */
1.19      snw       760:        strncpy (nsnbuf, nsname, sizeof (nsnbuf));    
1.13      snw       761:        if (init (nsnbuf) == FALSE) {       
1.1       snw       762:            set_io (UNIX);
                    763:            fprintf (stderr, "\nError initializing FreeM.\n");
                    764: 
                    765:            exit (1);
                    766:        }
1.13      snw       767:         else {
                    768:             fm_initialized = TRUE;
                    769:         }
1.1       snw       770:     }
                    771: 
                    772:     if (first_process == TRUE) {
                    773:         
                    774:         char verstr[500];
                    775:         pid_t stop_requester;
                    776: 
                    777:         if (run_daemon == FALSE) {
                    778:             fprintf (stderr, "freem:  re-run with --daemon or -d command-line flags\r\n");
                    779:             cleanup ();
                    780:             exit (1);
                    781:         }
                    782:         
                    783:         stcpy (verstr, FREEM_VERSION_STR);
                    784:         stcnv_m2c (verstr);
                    785:         
                    786:         fprintf (stderr, "Coherent Logic Development FreeM version %s\r\n", verstr);
1.2       snw       787:         fprintf (stderr, "freem:  shared memory for environment %s initialized (%ld bytes of shared memory @ '%p')\r\nfreem:  system ready\r\n", shm_env, (long) shm_init_size, shm_config->dta);
1.1       snw       788:         
                    789:         for (;;) {
                    790: 
                    791:             job_set_status (pid, JSTAT_HOUSEKEEPING);
                    792:             
                    793: 
                    794:             if (shm_config->hdr->maintenance_mode == 1) {
                    795: 
                    796:                 job_slot_t *slot;
                    797: 
                    798:                 fprintf (stderr, "freem:  entering maintenance mode\r\n");
                    799:                 m_log (1, "freem:  entering maintenance mode");
                    800:                 
                    801:                 for (slot = shm_config->hdr->jobtab_head; slot != NULL; slot = slot->next) {
                    802: 
                    803:                     if ((slot->pid != pid) && ((slot->flags & JFLG_FMADM) != JFLG_FMADM)) {
                    804:                         kill (slot->pid, SIGINT);
                    805:                     }
                    806: 
                    807:                 }
                    808:                 
                    809:             }
                    810:             
                    811:             if ((stop_requester = job_stop_requested (pid)) != 0) {
                    812:                 int connected_jobs;
                    813:                 
                    814:                 job_set_status (pid, JSTAT_SHUTDOWN);
                    815:                 
                    816:                 connected_jobs = job_count ();
                    817:                 
                    818:                 fprintf (stderr, "freem:  STOP requested by pid %d\r\n", stop_requester);
                    819:                 fprintf (stderr, "freem:  there are %d job(s) connected to this environment\r\n", connected_jobs);
                    820:                 
                    821:                 if (connected_jobs > 1) {
                    822:                     
                    823:                     fprintf (stderr, "freem:  asking non-daemon job(s) to disconnect and halt...\r\n");
                    824:                     job_request_all_stop ();
                    825: 
                    826:                     fprintf (stderr, "freem:  waiting 5 seconds for job(s) to disconnect...\r\n");
                    827:                     sleep (5);
                    828: 
                    829:                     connected_jobs = job_count ();
                    830:                     if (connected_jobs > 1) {
                    831:                         fprintf (stderr, "freem:  sending SIGTERM to %d job(s)...\r\n", connected_jobs);
                    832:                         job_signal_all (SIGTERM);
                    833:                         fprintf (stderr, "freem:  waiting 5 seconds for job(s) to disconnect...\r\n");
                    834:                         
                    835:                         sleep (5);
                    836:                     }
                    837:                     
                    838:                     connected_jobs = job_count ();
                    839:                     if (connected_jobs > 1) {
                    840:                         fprintf (stderr, "freem:  sending SIGKILL to %d job(s)...\r\n", connected_jobs);
                    841:                         job_signal_all (SIGKILL);
                    842:                     }
                    843:                    
                    844:                     job_gc_mark ();
                    845:                     job_gc_sweep ();
                    846:                     
                    847:                 }
                    848: 
                    849:                 fprintf (stderr, "freem:  terminating\r\n");
                    850:                 cleanup ();
1.11      snw       851:                 
1.1       snw       852:                 exit (0);
                    853:                 
                    854:             }
                    855:             
                    856:             job_gc_mark ();
                    857:             job_set_status (pid, JSTAT_IDLE);
                    858:             sleep (1);
                    859:             
                    860:             job_set_status (pid, JSTAT_HOUSEKEEPING);
                    861:             job_gc_sweep ();
                    862:             sleep (1);
                    863:         }
                    864:             
                    865:     }
                    866:         
                    867:     
                    868: #if !defined(_AIX)
1.18      snw       869:     if (import_env == TRUE) {
1.1       snw       870:        int i_maxlen = 255;
                    871:        
1.18      snw       872:         for (env = envp; *env != 0; env++) {                   
                    873:             varname = strtok (*env, "=");
                    874:             varval = strtok (NULL, "=");
1.1       snw       875: 
1.18      snw       876:             if (varval != NULL) {
1.1       snw       877:                snprintf (symname, i_maxlen, "ENV.%s\201\201", varname);
1.19      snw       878:                 strncpy (symval, varval, i_maxlen - 1);
1.1       snw       879:                
                    880:                 stcnv_c2m (symval);
                    881: 
                    882:                 symtab (set_sym, symname, symval);
                    883:             }
                    884:         }
                    885:     }
                    886: #endif    
                    887: 
                    888:     
                    889:     if (direct_mode == TRUE && quiet_mode == FALSE) {
                    890: 
                    891:        char verstr[500];
                    892:         char version[256];
                    893:        
                    894:        stcpy (verstr, FREEM_VERSION_STR);
                    895:        stcnv_m2c (verstr);
                    896:                
1.20    ! snw       897:         snprintf (version, sizeof (version) - 1, "\r\nCoherent Logic Development FreeM version %s [DIALECT: %s%s]\r\n\201", verstr, m_dialect, (restricted_mode == TRUE ? "/RESTRICTED" : ""));
1.1       snw       898:        write_m (version);
                    899: 
1.20    ! snw       900:        snprintf (version, sizeof (version) - 1, "Copyright (C) 2014, 2020, 2021, 2023, 2025 Coherent Logic Development LLC\r\n\r\n\201");
1.1       snw       901:        write_m (version);
                    902: 
1.5       snw       903:         /*
1.1       snw       904:         printf ("Environment:       \t%s\r\n", shm_env);
                    905:         printf ("Environment Daemon:\tPID %d\r\n", shm_config->hdr->first_process);
                    906:         printf ("Interpreter Process:\tPID %d\r\n", pid);
1.5       snw       907:         */
1.1       snw       908: 
                    909:     }
                    910:     else {
                    911:         write_m ("\r\n\r\n\201");
                    912:     }
                    913: 
                    914:     if (dx_mode) {
                    915:        char k_buf[512];        
                    916: 
1.20    ! snw       917:        snprintf (k_buf, sizeof (k_buf) - 1, "%%TMPINITMCODE\201\201");
1.1       snw       918:        symtab (set_sym, k_buf, dx_mcode);
                    919:         const_define (k_buf, dx_mcode);
                    920:     }
                    921: 
                    922:     if (routine_mode) {
                    923:         char k_buf[512];
                    924: 
1.20    ! snw       925:         snprintf (k_buf, sizeof (k_buf) - 1, "%%TMPINITROUTINE\201\201");
1.1       snw       926:         symtab (set_sym, k_buf, startup_routine);
                    927:         const_define (k_buf, startup_routine);
                    928:     }
                    929:     
                    930:     /* run mumps */
                    931:     xecline (1);
                    932: 
                    933:     exit (0);  /* we should never reach that statement */
                    934: 
                    935: } /* end of main() */
                    936: 
                    937: void freem_usage(void)
                    938: {
                    939:     fprintf (stdout, "\nusage:  freem [OPTION...]\n\n");
                    940:     
                    941:     fprintf (stdout, "OPTIONS:\n\n");
                    942:     
                    943: #if defined(HAVE_GETOPT_LONG)
                    944:     fprintf (stdout, "\t-h, --help\n\t\tdisplays this help message\n\n");
                    945:     fprintf (stdout, "\t-i, --import\n\t\timports UNIX environment variables as M locals\n\n");
                    946:     fprintf (stdout, "\t-e <environment-name>, --environment=<environment-name>\n\t\tsets active environment to <environment-name> (DEFAULT if unspecified)\n\n");
                    947:     fprintf (stdout, "\t-f, --filter\n\t\tallows M code to be used as a filter\n\n");
                    948:     fprintf (stdout, "\t-n <NAMESPACE>, --namespace=<NAMESPACE>\n\t\tselects <NAMESPACE> as the startup namespace instead of USER\n\n");
                    949:     fprintf (stdout, "\t-q, --quiet\n\t\tdisables startup messages and prompt string\n\n");
                    950:     fprintf (stdout, "\t-r <LABEL^ROUTINE>, --routine=<LABEL^ROUTINE>\n\t\texecute <LABEL^ROUTINE> on startup instead of entering direct mode\n\n");
                    951:     fprintf (stdout, "\t-s, --standard\n\t\trestrict access to FreeM vendor extensions not present in relevant standards*\n\n");
                    952:     fprintf (stdout, "\t-v, --version\n\t\tdisplay FreeM version information\n\n");
                    953:     fprintf (stdout, "\t-x <MCODE>, --execute=<MCODE>\n\t\texecute M code <MCODE> on startup\n\n");
                    954:     fprintf (stdout, "\t-d, --daemon\n\t\trun the FreeM daemon (one and only one FreeM daemon must always be running)\n\n");
                    955:     fprintf (stdout, "\t-k, --nofork\n\t\trun the FreeM daemon in foreground (requires --daemon)\n\n");
                    956:     fprintf (stdout, "\t-S <BYTES>, --shmsize=<BYTES>\n\t\tsets the size of the shared memory segment where FreeM stores the job table, lock table, and IPC table.\n");
                    957: #else
                    958:     fprintf (stdout, "\t-h\n\t\tdisplays this help message\n\n");
                    959:     fprintf (stdout, "\t-i\n\t\timports UNIX environment variables as M locals\n\n");
                    960:     fprintf (stdout, "\t-e <environment-name>\n\t\tsets active environment to <environment-name> (DEFAULT if unspecified)\n\n");
                    961:     fprintf (stdout, "\t-f\n\t\tallows M code to be used as a filter\n\n");
                    962:     fprintf (stdout, "\t-n <NAMESPACE>\n\t\tselects <NAMESPACE> as the startup namespace instead of USER\n\n");
                    963:     fprintf (stdout, "\t-q\n\t\tdisables startup messages and prompt string\n\n");
                    964:     fprintf (stdout, "\t-r <LABEL^ROUTINE>\n\t\texecute <LABEL^ROUTINE> on startup instead of entering direct mode\n\n");
                    965:     fprintf (stdout, "\t-s\n\t\trestrict access to FreeM vendor extensions not present in relevant standards*\n\n");
                    966:     fprintf (stdout, "\t-v\n\t\tdisplay FreeM version information\n\n");
                    967:     fprintf (stdout, "\t-x <MCODE>\n\t\texecute M code <MCODE> on startup\n\n");
                    968:     fprintf (stdout, "\t-d\n\t\trun the FreeM daemon (one and only one FreeM daemon must always be running)\n\n");
                    969:     fprintf (stdout, "\t-k\n\t\trun the FreeM daemon in foreground (requires --daemon)\n\n");
                    970:     fprintf (stdout, "\t-S <BYTES>\n\t\tsets the size of the shared memory segment where FreeM stores the job table, lock table, and IPC table.\n");
                    971: #endif    
                    972:     fprintf (stdout, "\t\t  - Each concurrent job takes %d bytes (1 page) of shared memory\n", PG_SIZE);
                    973:     fprintf (stdout, "\t\t  - Each LOCK takes %d bytes (2 pages) of shared memory\n", PG_SIZE * 2);
                    974:     fprintf (stdout, "\t\t  - Each IPC takes %d bytes (1 page) of shared memory\n\n", PG_SIZE);
                    975:     fprintf (stdout, "\t* FreeM attempts to conform (at least loosely) to the Millennium Draft Standard when this mode is selected.\n\n\n");
                    976:     fprintf (stdout, "Report bugs to: freem-bugs@coherent-logic.com\n");
                    977:     fprintf (stdout, "FreeM home page: <https://freem.coherent-logic.com>\n\n");   
                    978:     
                    979:     exit (1);
                    980: }
                    981: 
                    982: void freem_print_version(void)
                    983: {
                    984:     char verstr[500];
                    985:     stcpy (verstr, FREEM_VERSION_STR);
                    986:     stcnv_m2c (verstr);
                    987:     
                    988:     fprintf (stdout, "Coherent Logic Development FreeM %s\n", verstr);
                    989:     fprintf (stdout, "Copyright (C) 2014, 2020, 2021, 2023 Coherent Logic Development LLC\n\n");
                    990:     fprintf (stdout, "License AGPLv3+: GNU AGPL version 3 or later <https://gnu.org/license/agpl-3.0.html>\n");
                    991:     fprintf (stdout, "This is free software: you are free to change and redistribute it.\n");
                    992:     fprintf (stdout, "There is NO WARRANTY, to the extent permitted by law.\n");
                    993:     
                    994:     exit (0);
                    995: }

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>