/***************************************************************************** * * $Id$ * Purpose ...............: MBSE BBS Task Manager * ***************************************************************************** * Copyright (C) 1997-2004 * * Michiel Broek FIDO: 2:280/2802 * Beekmansbos 10 * 1971 BV IJmuiden * the Netherlands * * This file is part of MBSE BBS. * * This BBS is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License as published by the * Free Software Foundation; either version 2, or (at your option) any * later version. * * MBSE BBS is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with MBSE BBS; see the file COPYING. If not, write to the Free * Software Foundation, 675 Mass Ave, Cambridge, MA 02139, USA. *****************************************************************************/ #include "../config.h" #include "../lib/mbselib.h" #include "../paths.h" #include "signame.h" #include "taskstat.h" #include "taskutil.h" #include "taskregs.h" #include "taskcomm.h" #include "taskdisk.h" #include "callstat.h" #include "outstat.h" #include "../lib/nodelist.h" #include "ports.h" #include "calllist.h" #include "ping.h" #include "taskchat.h" #include "mbtask.h" #define NUM_THREADS 4 /* Max. nr of threads */ /* * Global variables */ static onetask task[MAXTASKS]; /* Array with tasks */ extern tocall calllist[MAXTASKS]; /* Array with calllist */ reg_info reginfo[MAXCLIENT]; /* Array with clients */ static pid_t pgrp; /* Pids group */ int sock = -1; /* Datagram socket */ struct sockaddr_un servaddr; /* Server address */ struct sockaddr_un from; /* From address */ int fromlen; char waitmsg[81]; /* Waiting message */ static char spath[PATH_MAX]; /* Socket path */ int logtrans = 0; /* Log transactions */ struct taskrec TCFG; /* Task config record */ struct sysconfig CFG; /* System config */ struct _nodeshdr nodeshdr; /* Nodes header record */ struct _nodes nodes; /* Nodes data record */ struct _fidonethdr fidonethdr; /* Fidonet header rec. */ struct _fidonet fidonet; /* Fidonet data record */ time_t tcfg_time; /* Config record time */ time_t cfg_time; /* Config record time */ time_t tty_time; /* TTY config time */ char tcfgfn[PATH_MAX]; /* Config file name */ char cfgfn[PATH_MAX]; /* Config file name */ char ttyfn[PATH_MAX]; /* TTY file name */ extern int ping_isocket; /* Ping socket */ int internet = FALSE; /* Internet is down */ double Load; /* System Load */ int Processing; /* Is system running */ int ZMH = FALSE; /* Zone Mail Hour */ int UPSalarm = FALSE; /* UPS alarm status */ extern int s_bbsopen; /* BBS open semafore */ extern int s_scanout; /* Scan outbound sema */ extern int s_mailout; /* Mail out semafore */ extern int s_mailin; /* Mail in semafore */ extern int s_index; /* Compile nl semafore */ extern int s_newnews; /* New news semafore */ extern int s_reqindex; /* Create req index sem */ extern int s_msglink; /* Messages link sem */ int masterinit = FALSE; /* Master init needed */ int ptimer = PAUSETIME; /* Pause timer */ int tflags = FALSE; /* if nodes with Txx */ extern int nxt_hour; /* Next event hour */ extern int nxt_min; /* Next event minute */ extern _alist_l *alist; /* Nodes to call list */ int rescan = FALSE; /* Master rescan flag */ extern int pots_calls; extern int isdn_calls; extern int inet_calls; extern int pots_lines; /* POTS lines available */ extern int isdn_lines; /* ISDN lines available */ extern int pots_free; /* POTS lines free */ extern int isdn_free; /* ISDN lines free */ extern pp_list *pl; /* List of tty ports */ extern int ipmailers; /* TCP/IP mail sessions */ extern int tosswait; /* Toss wait timer */ extern pid_t mypid; /* Pid of daemon */ int G_Shutdown = FALSE; /* Global shutdown */ int T_Shutdown = FALSE; /* Shutdown threads */ int nodaemon = FALSE; /* Run in foreground */ extern int cmd_run; /* Cmd running */ extern int ping_run; /* Ping running */ int sched_run = FALSE; /* Scheduler running */ extern int disk_run; /* Disk watch running */ /* * Global thread vaiables */ pthread_t p_thread[NUM_THREADS]; /* thread's structure */ /* * Load main configuration, if it doesn't exist, create it. * This is the case the very first time when you start MBSE BBS. */ void load_maincfg(void) { FILE *fp; struct utsname un; int i; if ((fp = fopen(cfgfn, "r")) == NULL) { masterinit = TRUE; memset(&CFG, 0, sizeof(CFG)); /* * Fill Registration defaults */ sprintf(CFG.bbs_name, "MBSE BBS"); uname((struct utsname *)&un); #ifdef __USE_GNU sprintf(CFG.sysdomain, "%s.%s", un.nodename, un.domainname); #else #ifdef __linux__ sprintf(CFG.sysdomain, "%s.%s", un.nodename, un.__domainname); #endif #endif sprintf(CFG.comment, "MBSE BBS development"); sprintf(CFG.origin, "MBSE BBS. Made in the Netherlands"); sprintf(CFG.location, "Earth"); /* * Fill Filenames defaults */ sprintf(CFG.logfile, "system.log"); sprintf(CFG.error_log, "error.log"); sprintf(CFG.default_menu, "main.mnu"); sprintf(CFG.current_language, "english.lang"); sprintf(CFG.chat_log, "chat.log"); sprintf(CFG.welcome_logo, "logo.asc"); sprintf(CFG.mgrlog, "manager.log"); sprintf(CFG.debuglog, "debug.log"); /* * Fill Global defaults */ sprintf(CFG.bbs_menus, "%s/english/menus", getenv("MBSE_ROOT")); sprintf(CFG.bbs_txtfiles, "%s/english/txtfiles", getenv("MBSE_ROOT")); sprintf(CFG.bbs_macros, "%s/english/macro", getenv("MBSE_ROOT")); sprintf(CFG.bbs_usersdir, "%s/home", getenv("MBSE_ROOT")); sprintf(CFG.nodelists, "%s/var/nodelist", getenv("MBSE_ROOT")); sprintf(CFG.inbound, "%s/var/unknown", getenv("MBSE_ROOT")); sprintf(CFG.pinbound, "%s/var/inbound", getenv("MBSE_ROOT")); sprintf(CFG.outbound, "%s/var/bso/outbound", getenv("MBSE_ROOT")); sprintf(CFG.msgs_path, "%s/var/msgs", getenv("MBSE_ROOT")); sprintf(CFG.uxpath, "%s", getenv("MBSE_ROOT")); sprintf(CFG.badtic, "%s/var/badtic", getenv("MBSE_ROOT")); sprintf(CFG.ticout, "%s/var/ticqueue", getenv("MBSE_ROOT")); sprintf(CFG.req_magic, "%s/magic", getenv("MBSE_ROOT")); sprintf(CFG.alists_path, "%s/var/arealists", getenv("MBSE_ROOT")); sprintf(CFG.out_queue, "%s/var/queue", getenv("MBSE_ROOT")); sprintf(CFG.rulesdir, "%s/var/rules", getenv("MBSE_ROOT")); CFG.leavecase = TRUE; /* * Newfiles reports */ sprintf(CFG.ftp_base, "%s/ftp/pub", getenv("MBSE_ROOT")); CFG.newdays = 30; CFG.security.level = 20; CFG.new_split = 27; CFG.new_force = 30; /* * BBS Globals */ CFG.CityLen = 6; CFG.exclude_sysop = TRUE; CFG.iConnectString = FALSE; CFG.iAskFileProtocols = FALSE; CFG.sysop_access = 32000; CFG.password_length = 4; CFG.iPasswd_Char = '.'; CFG.idleout = 3; CFG.iQuota = 10; CFG.iCRLoginCount = 10; CFG.bbs_loglevel = DLOG_ALLWAYS | DLOG_ERROR | DLOG_ATTENT | DLOG_NORMAL | DLOG_VERBOSE; CFG.util_loglevel = DLOG_ALLWAYS | DLOG_ERROR | DLOG_ATTENT | DLOG_NORMAL | DLOG_VERBOSE; CFG.OLR_NewFileLimit = 30; CFG.OLR_MaxReq = 25; CFG.slow_util = TRUE; CFG.iCrashLevel = 100; CFG.iAttachLevel = 100; CFG.new_groups = 25; CFG.max_logins = 1; CFG.AskScreenlen = ASK; CFG.AskNewmail = ASK; CFG.AskNewfiles = ASK; CFG.slow_util = TRUE; CFG.iCrashLevel = 100; CFG.iAttachLevel = 100; CFG.new_groups = 25; sprintf(CFG.startname, "bbs"); CFG.freespace = 10; /* * New Users */ CFG.newuser_access.level = 20; CFG.iCapUserName = TRUE; CFG.iAnsi = TRUE; CFG.iDataPhone = TRUE; CFG.iVoicePhone = TRUE; CFG.iDOB = TRUE; CFG.iTelephoneScan = TRUE; CFG.iLocation = TRUE; CFG.iHotkeys = TRUE; CFG.iCapLocation = FALSE; CFG.AskAddress = TRUE; CFG.GiveEmail = TRUE; /* * Colors */ CFG.TextColourF = CYAN; CFG.TextColourB = BLACK; CFG.UnderlineColourF = YELLOW; CFG.UnderlineColourB = BLACK; CFG.InputColourF = LIGHTCYAN; CFG.InputColourB = BLACK; CFG.CRColourF = WHITE; CFG.CRColourB = BLACK; CFG.MoreF = LIGHTMAGENTA; CFG.MoreB = BLACK; CFG.HiliteF = WHITE; CFG.HiliteB = BLACK; CFG.FilenameF = YELLOW; CFG.FilenameB = BLACK; CFG.FilesizeF = LIGHTMAGENTA; CFG.FilesizeB = BLACK; CFG.FiledateF = LIGHTGREEN; CFG.FiledateB = BLACK; CFG.FiledescF = CYAN; CFG.FiledescB = BLACK; CFG.MsgInputColourF = CYAN; CFG.MsgInputColourB = BLACK; /* * Paging */ CFG.iPageLength = 30; CFG.iMaxPageTimes = 5; CFG.iAskReason = TRUE; CFG.iSysopArea = 1; CFG.iAutoLog = TRUE; CFG.iChatPromptChk = TRUE; CFG.iStopChatTime = TRUE; /* * Fill ticconf defaults */ CFG.ct_PlusAll = TRUE; CFG.ct_Notify = TRUE; CFG.ct_Message = TRUE; CFG.ct_TIC = TRUE; CFG.tic_days = 30; sprintf(CFG.hatchpasswd, "DizIzMyBIGseeKret"); CFG.tic_systems = 10; CFG.tic_groups = 25; CFG.tic_dupes = 16000; /* * Fill Mail defaults */ CFG.maxpktsize = 150; CFG.maxarcsize = 300; sprintf(CFG.badboard, "%s/var/mail/badmail", getenv("MBSE_ROOT")); sprintf(CFG.dupboard, "%s/var/mail/dupemail", getenv("MBSE_ROOT")); sprintf(CFG.popnode, "localhost"); sprintf(CFG.smtpnode, "localhost"); sprintf(CFG.nntpnode, "localhost"); CFG.toss_days = 30; CFG.toss_dupes = 16000; CFG.toss_old = 60; CFG.defmsgs = 500; CFG.defdays = 90; CFG.toss_systems = 10; CFG.toss_groups = 25; CFG.UUCPgate.zone = 2; CFG.UUCPgate.net = 292; CFG.UUCPgate.node = 875; sprintf(CFG.UUCPgate.domain, "fidonet"); CFG.nntpdupes = 16000; CFG.ca_PlusAll = TRUE; CFG.ca_Notify = TRUE; CFG.ca_Passwd = TRUE; CFG.ca_Pause = TRUE; CFG.ca_Check = TRUE; for (i = 0; i < 32; i++) { sprintf(CFG.fname[i], "Flag %d", i+1); sprintf(CFG.aname[i], "Flag %d", i+1); } sprintf(CFG.aname[0], "Everyone"); /* * Fido mailer defaults */ CFG.timeoutreset = 3L; CFG.timeoutconnect = 60L; sprintf(CFG.phonetrans[0].match, "31-255"); sprintf(CFG.phonetrans[1].match, "31-"); sprintf(CFG.phonetrans[1].repl, "0"); sprintf(CFG.phonetrans[2].repl, "00"); CFG.IP_Speed = 256000; CFG.dialdelay = 60; sprintf(CFG.IP_Flags, "ICM,XX,IBN"); CFG.cico_loglevel = DLOG_ALLWAYS | DLOG_ERROR | DLOG_ATTENT | DLOG_NORMAL | DLOG_VERBOSE; /* * WWW defaults */ sprintf(CFG.www_root, "/var/www/htdocs"); sprintf(CFG.www_link2ftp, "files"); sprintf(CFG.www_url, "http://%s", CFG.sysdomain); sprintf(CFG.www_charset, "ISO 8859-1"); sprintf(CFG.www_author, "Your Name"); if (strlen(_PATH_CONVERT)) sprintf(CFG.www_convert,"%s -geometry x100", _PATH_CONVERT); CFG.www_files_page = 10; CFG.maxarticles = 500; CFG.priority = 15; #ifdef __linux__ CFG.do_sync = TRUE; #endif CFG.is_upgraded = TRUE; if ((fp = fopen(cfgfn, "a+")) == NULL) { perror(""); fprintf(stderr, "Can't create %s\n", cfgfn); exit(MBERR_INIT_ERROR); } fwrite(&CFG, sizeof(CFG), 1, fp); fclose(fp); chmod(cfgfn, 0640); } else { fread(&CFG, sizeof(CFG), 1, fp); fclose(fp); if (strlen(CFG.debuglog) == 0) sprintf(CFG.debuglog, "debug.log"); } cfg_time = file_time(cfgfn); } /* * Load task configuration data. */ void load_taskcfg(void) { FILE *fp; if ((fp = fopen(tcfgfn, "r")) == NULL) { memset(&TCFG, 0, sizeof(TCFG)); TCFG.maxload = 1.50; sprintf(TCFG.zmh_start, "02:30"); sprintf(TCFG.zmh_end, "03:30"); sprintf(TCFG.cmd_mailout, "%s/bin/mbfido scan web -quiet", getenv("MBSE_ROOT")); sprintf(TCFG.cmd_mailin, "%s/bin/mbfido tic toss web -quiet", getenv("MBSE_ROOT")); sprintf(TCFG.cmd_newnews, "%s/bin/mbfido news web -quiet", getenv("MBSE_ROOT")); sprintf(TCFG.cmd_mbindex1, "%s/bin/mbindex -quiet", getenv("MBSE_ROOT")); if (strlen(_PATH_GOLDNODE)) sprintf(TCFG.cmd_mbindex2, "%s -f -q", _PATH_GOLDNODE); sprintf(TCFG.cmd_msglink, "%s/bin/mbmsg link -quiet", getenv("MBSE_ROOT")); sprintf(TCFG.cmd_reqindex, "%s/bin/mbfile index -quiet", getenv("MBSE_ROOT")); TCFG.max_tcp = 0; sprintf(TCFG.isp_ping1, "192.168.1.1"); sprintf(TCFG.isp_ping2, "192.168.1.1"); if ((fp = fopen(tcfgfn, "a+")) == NULL) { Syslog('?', "$Can't create %s", tcfgfn); die(MBERR_INIT_ERROR); } fwrite(&TCFG, sizeof(TCFG), 1, fp); fclose(fp); chmod(tcfgfn, 0640); Syslog('+', "Created new %s", tcfgfn); } else { fread(&TCFG, sizeof(TCFG), 1, fp); fclose(fp); } tcfg_time = file_time(tcfgfn); } /* * Launch an external program in the background. * On success add it to the tasklist and return * the pid. Set the pause timer. */ pid_t launch(char *cmd, char *opts, char *name, int tasktype) { char buf[PATH_MAX], *vector[16]; int i, rc = 0; pid_t pid = 0; if (checktasks(0) >= MAXTASKS) { Syslog('?', "Launch: can't execute %s, maximum tasks reached", cmd); return 0; } memset(vector, 0, sizeof(vector)); if (opts == NULL) sprintf(buf, "%s", cmd); else sprintf(buf, "%s %s", cmd, opts); i = 0; vector[i++] = strtok(buf," \t\n\0"); while ((vector[i++] = strtok(NULL," \t\n")) && (i<16)); vector[15] = NULL; if (file_exist(vector[0], X_OK)) { Syslog('?', "Launch: can't execute %s, command not found", vector[0]); return 0; } pid = fork(); switch (pid) { case -1: Syslog('?', "$Launch: error, can't fork grandchild"); return 0; case 0: /* From Paul Vixies cron: */ (void)setsid(); /* It doesn't seem to help */ close(0); if (open("/dev/null", O_RDONLY) != 0) { Syslog('?', "$Launch: \"%s\": reopen of stdin to /dev/null failed", buf); _exit(MBERR_EXEC_FAILED); } close(1); if (open("/dev/null", O_WRONLY | O_APPEND | O_CREAT,0600) != 1) { Syslog('?', "$Launch: \"%s\": reopen of stdout to /dev/null failed", buf); _exit(MBERR_EXEC_FAILED); } close(2); if (open("/dev/null", O_WRONLY | O_APPEND | O_CREAT,0600) != 2) { Syslog('?', "$Launch: \"%s\": reopen of stderr to /dev/null failed", buf); _exit(MBERR_EXEC_FAILED); } errno = 0; rc = execv(vector[0],vector); Syslog('?', "$Launch: execv \"%s\" failed, returned %d", cmd, rc); _exit(MBERR_EXEC_FAILED); default: /* grandchild's daddy's process */ break; } /* * Add it to the tasklist. */ for (i = 0; i < MAXTASKS; i++) { if (strlen(task[i].name) == 0) { strcpy(task[i].name, name); strcpy(task[i].cmd, cmd); if (opts) strcpy(task[i].opts, opts); task[i].pid = pid; task[i].status = 0; task[i].running = TRUE; task[i].rc = 0; task[i].tasktype = tasktype; break; } } ptimer = PAUSETIME; if (opts) Syslog('+', "Launch: task %d \"%s %s\" success, pid=%d", i, cmd, opts, pid); else Syslog('+', "Launch: task %d \"%s\" success, pid=%d", i, cmd, pid); return pid; } /* * Count specific running tasks */ int runtasktype(int tasktype) { int i, count = 0; for (i = 0; i < MAXTASKS; i++) { if (strlen(task[i].name) && task[i].running && (task[i].tasktype == tasktype)) count++; } return count; } /* * Check all running tasks registered in the tasklist. * Report programs that are stopped. If signal is set * then send that signal. */ int checktasks(int onsig) { int i, j, rc, count = 0, first = TRUE, status; for (i = 0; i < MAXTASKS; i++) { if (strlen(task[i].name)) { if (onsig) { if (kill(task[i].pid, onsig) == 0) Syslog('+', "%s to %s (pid %d) succeeded", SigName[onsig], task[i].name, task[i].pid); else Syslog('+', "%s to %s (pid %d) failed", SigName[onsig], task[i].name, task[i].pid); } task[i].rc = wait4(task[i].pid, &status, WNOHANG | WUNTRACED, NULL); if (task[i].rc) { task[i].running = FALSE; /* * If a mailer call is finished, set the global rescan flag. */ if (task[i].tasktype == CM_POTS || task[i].tasktype == CM_ISDN || task[i].tasktype == CM_INET) rescan = TRUE; ptimer = PAUSETIME; /* * If a nodelist compiler is ready, reload the nodelists configuration */ if (task[i].tasktype == MBINDEX) { deinitnl(); initnl(); } } if (first && task[i].rc) { first = FALSE; Syslog('t', "Task Type pid stat"); Syslog('t', "---------------- ------- ----- ----"); for (j = 0; j < MAXTASKS; j++) if (strlen(task[j].name)) Syslog('t', "%-16s %s %5d %s", task[j].name, callmode(task[j].tasktype), task[j].pid, task[j].running?"runs":"stop"); } switch (task[i].rc) { case -1: if (errno == ECHILD) Syslog('+', "Task %d \"%s\" is ready", i, task[i].name); else Syslog('+', "Task %d \"%s\" is ready, error: %s", i, task[i].name, strerror(errno)); break; case 0: /* * Update last known status when running. */ task[i].status = status; count++; break; default: if (WIFEXITED(task[i].status)) { rc = WEXITSTATUS(task[i].status); if (rc) Syslog('+', "Task %s is ready, error=%d", task[i].name, rc); else Syslog('+', "Task %s is ready", task[i].name); } else if (WIFSIGNALED(task[i].status)) { rc = WTERMSIG(task[i].status); /* * Here we don't report an error number, on FreeBSD WIFSIGNALED * seems true while there's nothing wrong. */ Syslog('+', "Task %s terminated", task[i].name); } else if (WIFSTOPPED(task[i].status)) { rc = WSTOPSIG(task[i].status); Syslog('+', "Task %s stopped on signal %s (%d)", task[i].name, SigName[rc], rc); } else { Syslog('+', "FIXME: 1"); } break; } if (!task[i].running) { for (j = 0; j < MAXTASKS; j++) { if (calllist[j].taskpid == task[i].pid) { calllist[j].calling = FALSE; calllist[j].taskpid = 0; rescan = TRUE; } } memset(&task[i], 0, sizeof(onetask)); } } } return count; } /* * This function triggers the shutdown and is only installed for SIGTERM * and SIGINT. On NetBSD the threads signal handlers cannot be disabled, * so in fact all threads call this function as soon as one of these * signals is received. The first one arrived will initiate the shutdown. */ void start_shutdown(int onsig) { Syslog('s', "Trigger shutdown on signal %s", SigName[onsig]); signal(onsig, SIG_IGN); G_Shutdown = TRUE; } /* * Normal fatal signal handler, but also used during shutdown. */ void die(int onsig) { int i, count; time_t now; signal(onsig, SIG_IGN); if ((onsig == SIGTERM) || (nodaemon && (onsig == SIGINT))) { Syslog('+', "Starting normal shutdown (%s)", SigName[onsig]); } else { Syslog('+', "Abnormal shutdown on signal %s", SigName[onsig]); } /* * First check if there are tasks running, if so try to stop them */ if ((count = checktasks(0))) { Syslog('+', "There are %d tasks running, sending SIGTERM", count); checktasks(SIGTERM); for (i = 0; i < 15; i++) { sleep(1); count = checktasks(0); if (count == 0) break; } if (count) { /* * There are some diehards running... */ Syslog('+', "There are %d tasks running, sending SIGKILL", count); count = checktasks(SIGKILL); } if (count) { sleep(1); count = checktasks(0); if (count) Syslog('?', "Still %d tasks running, giving up", count); } } if ((count = checktasks(0))) Syslog('?', "Shutdown with %d tasks still running", count); else Syslog('+', "Good, no more tasks running"); /* * Now stop the threads */ T_Shutdown = TRUE; Syslog('+', "Signal all threads to stop"); /* * Wait at most 2 seconds for the threads, internal they are * build to stop within a second. */ now = time(NULL) + 2; while ((cmd_run || ping_run || sched_run || disk_run) && (time(NULL) < now)) { sleep(1); } if (cmd_run || ping_run || sched_run || disk_run) Syslog('+', "Not all threads stopped! Forced shutdown"); else Syslog('+', "All threads stopped"); /* * Free memory */ deinitnl(); ulocktask(); printable(NULL, 0); /* * Close socket */ if (sock != -1) close(sock); if (ping_isocket != -1) close(ping_isocket); if (!file_exist(spath, R_OK)) { unlink(spath); } Syslog(' ', "MBTASK finished"); exit(onsig); } /* * Put a lock on this program. */ int locktask(char *root) { char *tempfile, *lockfile; FILE *fp; pid_t oldpid; tempfile = calloc(PATH_MAX, sizeof(char)); lockfile = calloc(PATH_MAX, sizeof(char)); sprintf(tempfile, "%s/var/run/mbtask.tmp", root); sprintf(lockfile, "%s/var/run/mbtask", root); if ((fp = fopen(tempfile, "w")) == NULL) { perror("mbtask"); printf("Can't create lockfile \"%s\"\n", tempfile); free(tempfile); free(lockfile); return 1; } fprintf(fp, "%10u\n", getpid()); fclose(fp); while (TRUE) { if (link(tempfile, lockfile) == 0) { unlink(tempfile); free(tempfile); free(lockfile); return 0; } if ((fp = fopen(lockfile, "r")) == NULL) { perror("mbtask"); printf("Can't open lockfile \"%s\"\n", tempfile); unlink(tempfile); free(tempfile); free(lockfile); return 1; } if (fscanf(fp, "%u", &oldpid) != 1) { perror("mbtask"); printf("Can't read old pid from \"%s\"\n", tempfile); fclose(fp); unlink(tempfile); free(tempfile); free(lockfile); return 1; } fclose(fp); if (kill(oldpid,0) == -1) { if (errno == ESRCH) { printf("Stale lock found for pid %u\n", oldpid); unlink(lockfile); /* no return, try lock again */ } else { perror("mbtask"); printf("Kill for %u failed\n",oldpid); unlink(tempfile); free(tempfile); free(lockfile); return 1; } } else { printf("Another mbtask is already running, pid=%u\n", oldpid); unlink(tempfile); free(tempfile); free(lockfile); return 1; } } } void ulocktask(void) { char *lockfile; pid_t oldpid; FILE *fp; struct passwd *pw; pw = getpwnam((char *)"mbse"); lockfile = calloc(PATH_MAX, sizeof(char)); sprintf(lockfile, "%s/var/run/mbtask", pw->pw_dir); if ((fp = fopen(lockfile, "r")) == NULL) { WriteError("$Can't open lockfile \"%s\"", lockfile); free(lockfile); return; } if (fscanf(fp, "%u", &oldpid) != 1) { WriteError("$Can't read old pid from \"%s\"", lockfile); fclose(fp); unlink(lockfile); free(lockfile); return; } fclose(fp); if (oldpid == getpid()) { (void)unlink(lockfile); } free(lockfile); } /* * External Semafore Checks */ void test_sema(char *); void test_sema(char *sema) { if (IsSema(sema)) { RemoveSema(sema); Syslog('s', "Semafore %s detected", sema); sem_set(sema, TRUE); } } /* * Check semafore's, system status flags etc. This is called * each second to test for condition changes. */ void check_sema(void); void check_sema(void) { /* * Check UPS status. */ if (IsSema((char *)"upsalarm")) { if (!UPSalarm) Syslog('!', "UPS: power failure"); UPSalarm = TRUE; } else { if (UPSalarm) Syslog('!', "UPS: the power is back"); UPSalarm = FALSE; } if (IsSema((char *)"upsdown")) { Syslog('!', "UPS: power failure, starting shutdown"); /* * Since the upsdown semafore is permanent, the system WILL go down * there is no point for this program to stay. Signal all tasks and stop. */ die(MBERR_UPS_ALARM); } /* * Check Zone Mail Hour */ get_zmh(); /* * Semafore's that still can be detected, usefull for * external programs that create them. */ test_sema((char *)"newnews"); test_sema((char *)"mailout"); test_sema((char *)"mailin"); test_sema((char *)"scanout"); } void start_scheduler(void) { struct passwd *pw; char *cmd = NULL; int rc; InitFidonet(); /* * Registrate this server for mbmon in slot 0. */ reginfo[0].pid = getpid(); strcpy(reginfo[0].tty, "-"); strcpy(reginfo[0].uname, "mbse"); strcpy(reginfo[0].prg, "mbtask"); strcpy(reginfo[0].city, "localhost"); strcpy(reginfo[0].doing, "Start"); reginfo[0].started = time(NULL); Processing = TRUE; TouchSema((char *)"mbtask.last"); /* * Setup UNIX Datagram socket */ if ((sock = socket(AF_UNIX, SOCK_DGRAM, 0)) < 0) { WriteError("$Can't create socket"); die(MBERR_INIT_ERROR); } memset(&servaddr, 0, sizeof(servaddr)); servaddr.sun_family = AF_UNIX; strcpy(servaddr.sun_path, spath); if (bind(sock, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0) { close(sock); sock = -1; WriteError("$Can't bind socket %s", spath); die(MBERR_INIT_ERROR); } /* * The flag masterinit is set if a new config.data is created, this * is true if mbtask is started the very first time. Then we run * mbsetup init to create the default databases. */ if (masterinit) { pw = getpwuid(getuid()); cmd = xstrcpy(pw->pw_dir); cmd = xstrcat(cmd, (char *)"/bin/mbsetup"); launch(cmd, (char *)"init", (char *)"mbsetup", MBINIT); free(cmd); sleep(2); masterinit = FALSE; } initnl(); sem_set((char *)"scanout", TRUE); if (!TCFG.max_tcp && !pots_lines && !isdn_lines) { Syslog('?', "WARNING: this system cannot connect to other systems, check setup"); } /* * Install the threads that do the real work. */ if ((rc = pthread_create(&p_thread[0], NULL, (void (*))ping_thread, NULL))) { WriteError("$pthread_create ping_thread rc=%d", rc); die(SIGTERM); } else if ((rc = pthread_create(&p_thread[1], NULL, (void (*))cmd_thread, NULL))) { WriteError("$pthread_create cmd_thread rc=%d", rc); die(SIGTERM); } else if ((rc = pthread_create(&p_thread[2], NULL, (void (*))disk_thread, NULL))) { WriteError("$pthread_create disk_thread rc=%d", rc); die(SIGTERM); } else if ((rc = pthread_create(&p_thread[3], NULL, (void (*))scheduler, NULL))) { WriteError("$pthread_create scheduler rc=%d", rc); die(SIGTERM); } else { Syslog('+', "All threads installed"); } /* * Sleep until we die */ while (! G_Shutdown) { sleep(1); } die(SIGTERM); } /* * Scheduler thread */ void *scheduler(void) { struct passwd *pw; int running = 0, i, found; static int LOADhi = FALSE, oldmin = 70, olddo = 70, oldsec = 70; char *cmd = NULL, opts[41], port[21]; static char doing[32]; time_t now; struct tm *tm, *utm; #if defined(__linux__) FILE *fp; #endif int call_work = 0; static int call_entry = MAXTASKS; double loadavg[3]; pp_list *tpl; Syslog('+', "Starting scheduler thread"); sched_run = TRUE; pw = getpwuid(getuid()); /* * Enter the mainloop (forever) */ do { sleep(1); if (T_Shutdown) break; /* * Check all registered connections and semafore's */ reg_check(); check_sema(); check_ports(); /* * Check the systems load average. */ Load = loadavg[0] = loadavg[1] = loadavg[2] = 0.0; #if defined(__FreeBSD__) || defined(__NetBSD__) if (getloadavg(loadavg, 3) == 3) { Load = loadavg[0]; } #elif defined(__linux__) if ((fp = fopen((char *)"/proc/loadavg", "r"))) { if (fscanf(fp, "%lf %lf %lf", &loadavg[0], &loadavg[1], &loadavg[2]) == 3) { Load = loadavg[0]; } else { Syslog('-', "error"); } fclose(fp); } #endif if (Load >= TCFG.maxload) { if (!LOADhi) { Syslog('!', "System load too high: %2.2f (%2.2f)", Load, TCFG.maxload); LOADhi = TRUE; } } else { if (LOADhi) { Syslog('!', "System load normal: %2.2f (%2.2f)", Load, TCFG.maxload); LOADhi = FALSE; } } /* * Report to the system monitor. */ memset(&doing, 0, sizeof(doing)); if ((running = checktasks(0))) sprintf(doing, "Run %d tasks", running); else if (UPSalarm) sprintf(doing, "UPS alarm"); else if (!s_bbsopen) sprintf(doing, "BBS is closed"); else if (Processing) sprintf(doing, "%s", waitmsg); else sprintf(doing, "Overload %2.2f", Load); sprintf(reginfo[0].doing, "%s", doing); reginfo[0].lastcon = time(NULL); /* * Touch the mbtask.last semafore to prove this daemon * is actually running. * Reload configuration data if some file is changed. */ now = time(NULL); tm = localtime(&now); utm = gmtime(&now); if (tm->tm_min != olddo) { /* * Each minute we execute this part */ if (tosswait) tosswait--; olddo = tm->tm_min; TouchSema((char *)"mbtask.last"); if (file_time(tcfgfn) != tcfg_time) { Syslog('+', "Task configuration changed, reloading"); load_taskcfg(); deinitnl(); initnl(); sem_set((char *)"scanout", TRUE); } if (file_time(cfgfn) != cfg_time) { Syslog('+', "Main configuration changed, reloading"); load_maincfg(); deinitnl(); initnl(); sem_set((char *)"scanout", TRUE); } if (file_time(ttyfn) != tty_time) { Syslog('+', "Ports configuration changed, reloading"); load_ports(); check_ports(); deinitnl(); initnl(); sem_set((char *)"scanout", TRUE); } /* * If the next event time is reached, rescan the outbound */ if ((utm->tm_hour == nxt_hour) && (utm->tm_min == nxt_min)) { Syslog('+', "It is now %02d:%02d UTC, starting new event", utm->tm_hour, utm->tm_min); sem_set((char *)"scanout", TRUE); } } /* * Check system processing state */ if (s_bbsopen && !UPSalarm && !LOADhi) { if (!Processing) { Syslog('+', "Resuming normal operations"); Processing = TRUE; } } else { if (Processing) { Syslog('+', "Suspending operations"); Processing = FALSE; } } /* * Check Pause Timer, make sure it's only checked * once each second. Also do pingcheck. */ if (tm->tm_sec != oldsec) { oldsec = tm->tm_sec; if (ptimer) ptimer--; } if (Processing) { /* * Here we run all normal operations. */ running = checktasks(0); if (s_mailout && (!ptimer) && (!runtasktype(MBFIDO))) { launch(TCFG.cmd_mailout, NULL, (char *)"mailout", MBFIDO); running = checktasks(0); s_mailout = FALSE; } if (s_mailin && (!ptimer) && (!runtasktype(MBFIDO))) { /* * Here we should check if no mailers are running. Only start * processing the inbound if no mailers are running, but on busy * systems this may hardly be the case. So we wait for 30 minutes * and if there are still mailers running, mbfido is started * anyway. */ if ((ipmailers + runtasktype(CM_ISDN) + runtasktype(CM_POTS)) == 0) { Syslog('i', "Mailin, no mailers running, start direct"); tosswait = TOSSWAIT_TIME; launch(TCFG.cmd_mailin, NULL, (char *)"mailin", MBFIDO); running = checktasks(0); s_mailin = FALSE; } else { Syslog('i', "Mailin, tosswait=%d", tosswait); if (tosswait == 0) { launch(TCFG.cmd_mailin, NULL, (char *)"mailin", MBFIDO); running = checktasks(0); s_mailin = FALSE; } } } if (s_newnews && (!ptimer) && (!runtasktype(MBFIDO))) { launch(TCFG.cmd_newnews, NULL, (char *)"newnews", MBFIDO); running = checktasks(0); s_newnews = FALSE; } /* * Only run the nodelist compiler if nothing else * is running. There's no hurry to compile the * new lists. If more then one compiler is defined, * start them in parallel. */ if (s_index && (!ptimer) && (!running)) { if (strlen(TCFG.cmd_mbindex1)) launch(TCFG.cmd_mbindex1, NULL, (char *)"compiler 1", MBINDEX); if (strlen(TCFG.cmd_mbindex2)) launch(TCFG.cmd_mbindex2, NULL, (char *)"compiler 2", MBINDEX); if (strlen(TCFG.cmd_mbindex3)) launch(TCFG.cmd_mbindex3, NULL, (char *)"compiler 3", MBINDEX); running = checktasks(0); s_index = FALSE; } /* * Linking messages is also only done when there is * nothing else to do. */ if (s_msglink && (!ptimer) && (!running)) { launch(TCFG.cmd_msglink, NULL, (char *)"msglink", MBFIDO); running = checktasks(0); s_msglink = FALSE; } /* * Creating filerequest indexes, also only if nothing to do. */ if (s_reqindex && (!ptimer) && (!running)) { launch(TCFG.cmd_reqindex, NULL, (char *)"reqindex", MBFILE); running = checktasks(0); s_reqindex = FALSE; } } /* if (Processing) */ if ((tm->tm_sec / SLOWRUN) != oldmin) { /* * These tasks run once per 20 seconds. */ oldmin = tm->tm_sec / SLOWRUN; if (Processing) { /* * Update outbound status if needed. */ if (rescan) { rescan = FALSE; outstat(); call_work = check_calllist(); } /* * Launch the systems to call, start one system each time. * Set the safety counter to MAXTASKS + 1, this forces that * the counter really will advance to the next node in case * of failing sessions. */ i = MAXTASKS + 1; found = FALSE; if (call_work) { while (TRUE) { /* * Rotate the call entries */ if (call_entry == MAXTASKS) call_entry = 0; else call_entry++; /* * If a valid entry, and not yet calling, and the retry time is reached, * then launch a callprocess for this node. */ if (calllist[call_entry].addr.zone && !calllist[call_entry].calling && (calllist[call_entry].cst.trytime < now)) { if ((calllist[call_entry].callmode == CM_INET) && (ipmailers < TCFG.max_tcp) && internet) { found = TRUE; break; } if ((calllist[call_entry].callmode == CM_ISDN) && (runtasktype(CM_ISDN) < isdn_free)) { found = TRUE; break; } if ((calllist[call_entry].callmode == CM_POTS) && (runtasktype(CM_POTS) < pots_free)) { found = TRUE; break; } } /* * Safety counter, if all systems are already calling, we should * never break out of this loop anymore. */ i--; if (!i) break; } if (found) { cmd = xstrcpy(pw->pw_dir); cmd = xstrcat(cmd, (char *)"/bin/mbcico"); /* * For ISDN or POTS, select a free tty device. */ switch (calllist[call_entry].callmode) { case CM_ISDN: for (tpl = pl; tpl; tpl = tpl->next) { if (!tpl->locked && (tpl->dflags & calllist[call_entry].diflags)) { sprintf(port, "-l %s ", tpl->tty); break; } } break; case CM_POTS: for (tpl = pl; tpl; tpl = tpl->next) { if (!tpl->locked && (tpl->mflags & calllist[call_entry].moflags)) { sprintf(port, "-l %s ", tpl->tty); break; } } break; default: port[0] = '\0'; break; } if (calllist[call_entry].addr.point) { sprintf(opts, "%sp%u.f%u.n%u.z%u", port, calllist[call_entry].addr.point, calllist[call_entry].addr.node, calllist[call_entry].addr.net, calllist[call_entry].addr.zone); } else { sprintf(opts, "%sf%u.n%u.z%u", port, calllist[call_entry].addr.node, calllist[call_entry].addr.net, calllist[call_entry].addr.zone); } calllist[call_entry].taskpid = launch(cmd, opts, (char *)"mbcico", calllist[call_entry].callmode); if (calllist[call_entry].taskpid) calllist[call_entry].calling = TRUE; running = checktasks(0); rescan = TRUE; free(cmd); cmd = NULL; } } } /* if (Processing) */ } /* if ((tm->tm_sec / SLOWRUN) != oldmin) */ } while (! T_Shutdown); sched_run = FALSE; Syslog('+', "Scheduler thread stopped"); pthread_exit(NULL); } int main(int argc, char **argv) { struct passwd *pw; char *lockfile; int i; pid_t frk; FILE *fp; /* * Print copyright notices and setup logging. */ printf("MBTASK: MBSE BBS v%s Task Manager Daemon\n", VERSION); printf(" %s\n\n", COPYRIGHT); /* * Catch all the signals we can, and ignore the rest. Note that SIGKILL can't be ignored * but that's live. This daemon should only be stopped by SIGTERM. */ for (i = 0; i < NSIG; i++) { if ((i == SIGHUP) || (i == SIGBUS) || (i == SIGILL) || (i == SIGSEGV)) signal(i, (void (*))die); else if ((i == SIGINT) || (i == SIGTERM)) signal(i, (void (*))start_shutdown); else if (i == SIGCHLD) signal(i, SIG_DFL); else if ((i != SIGKILL) && (i != SIGSTOP)) signal(i, SIG_IGN); } init_pingsocket(); /* * Secret undocumented startup switch, ie: no help available. */ if ((argc == 2) && (strcmp(argv[1], "-nd") == 0)) { nodaemon = TRUE; } /* * mbtask is setuid root, drop privileges to user mbse. * This will stay forever like this, no need to become * root again. The child can't even become root anymore. */ pw = getpwnam((char *)"mbse"); if (setuid(pw->pw_uid)) { perror(""); fprintf(stderr, "can't setuid to mbse\n"); close(ping_isocket); exit(MBERR_INIT_ERROR); } /* * If running in the foreground under valgrind the next call fails. * Developers should know what they are doing so we are not bailing out. */ if (setgid(pw->pw_gid)) { perror(""); fprintf(stderr, "can't setgid to bbs\n"); if (! nodaemon) { close(ping_isocket); exit(MBERR_INIT_ERROR); } } umask(007); if (locktask(pw->pw_dir)) { close(ping_isocket); exit(MBERR_NO_PROGLOCK); } sprintf(cfgfn, "%s/etc/config.data", getenv("MBSE_ROOT")); load_maincfg(); mypid = getpid(); Syslog(' ', " "); Syslog(' ', "MBTASK v%s", VERSION); if (nodaemon) Syslog('+', "Starting in no-daemon mode"); sprintf(tcfgfn, "%s/etc/task.data", getenv("MBSE_ROOT")); load_taskcfg(); status_init(); memset(&task, 0, sizeof(task)); memset(®info, 0, sizeof(reginfo)); memset(&calllist, 0, sizeof(calllist)); sprintf(spath, "%s/tmp/mbtask", getenv("MBSE_ROOT")); sprintf(ttyfn, "%s/etc/ttyinfo.data", getenv("MBSE_ROOT")); initnl(); load_ports(); check_ports(); chat_init(); /* * Now that init is complete and this program is locked, it is * safe to remove a stale socket if it is there after a crash. */ if (!file_exist(spath, R_OK)) unlink(spath); if (nodaemon) { /* * For debugging, run in foreground mode */ mypid = getpid(); start_scheduler(); } else { /* * Server initialization is complete. Now we can fork the * daemon and return to the user. We need to do a setpgrp * so that the daemon will no longer be assosiated with the * users control terminal. This is done before the fork, so * that the child will not be a process group leader. Otherwise, * if the child were to open a terminal, it would become * associated with that terminal as its control terminal. */ if ((pgrp = setpgid(0, 0)) == -1) { Syslog('?', "$setpgid failed"); die(MBERR_INIT_ERROR); } frk = fork(); switch (frk) { case -1: Syslog('?', "$Unable to fork daemon"); die(MBERR_INIT_ERROR); case 0: /* * Starting the deamon child process here. */ fclose(stdin); if (open("/dev/null", O_RDONLY) != 0) { Syslog('?', "$Reopen of stdin to /dev/null failed"); _exit(MBERR_EXEC_FAILED); } fclose(stdout); if (open("/dev/null", O_WRONLY | O_APPEND | O_CREAT,0600) != 1) { Syslog('?', "$Reopen of stdout to /dev/null failed"); _exit(MBERR_EXEC_FAILED); } fclose(stderr); if (open("/dev/null", O_WRONLY | O_APPEND | O_CREAT,0600) != 2) { Syslog('?', "$Reopen of stderr to /dev/null failed"); _exit(MBERR_EXEC_FAILED); } mypid = getpid(); start_scheduler(); /* Not reached */ default: /* * Here we detach this process and let the child * run the deamon process. Put the child's pid * in the lockfile before leaving. */ lockfile = calloc(PATH_MAX, sizeof(char)); sprintf(lockfile, "%s/var/run/mbtask", pw->pw_dir); if ((fp = fopen(lockfile, "w"))) { fprintf(fp, "%10u\n", frk); fclose(fp); } free(lockfile); Syslog('+', "Starting daemon with pid %d", frk); pthread_exit(NULL); exit(MBERR_OK); } } /* * Not reached */ return 0; }