1 /*
   2  * CDDL HEADER START
   3  *
   4  * The contents of this file are subject to the terms of the
   5  * Common Development and Distribution License (the "License").
   6  * You may not use this file except in compliance with the License.
   7  *
   8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
   9  * or http://www.opensolaris.org/os/licensing.
  10  * See the License for the specific language governing permissions
  11  * and limitations under the License.
  12  *
  13  * When distributing Covered Code, include this CDDL HEADER in each
  14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
  15  * If applicable, add the following below this CDDL HEADER, with the
  16  * fields enclosed by brackets "[]" replaced with your own identifying
  17  * information: Portions Copyright [yyyy] [name of copyright owner]
  18  *
  19  * CDDL HEADER END
  20  */
  21 /*
  22  * Copyright 2008 Sun Microsystems, Inc.  All rights reserved.
  23  * Use is subject to license terms.
  24  * Copyright 2012 Milan Jurik. All rights reserved.
  25  * Copyright (c) 2013 Gary Mills
  26  */
  27 
  28 /*
  29  *      Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T
  30  *      All Rights Reserved
  31  */
  32 
  33 /*
  34  * University Copyright- Copyright (c) 1982, 1986, 1988
  35  * The Regents of the University of California
  36  * All Rights Reserved
  37  *
  38  * University Acknowledgment- Portions of this document are derived from
  39  * software developed by the University of California, Berkeley, and its
  40  * contributors.
  41  */
  42 
  43 /*
  44  *  syslogd -- log system messages
  45  *
  46  * This program implements a system log. It takes a series of lines.
  47  * Each line may have a priority, signified as "<n>" as
  48  * the first characters of the line.  If this is
  49  * not present, a default priority is used.
  50  *
  51  * To kill syslogd, send a signal 15 (terminate).  A signal 1 (hup) will
  52  * cause it to reconfigure.
  53  *
  54  * Defined Constants:
  55  *
  56  * MAXLINE -- the maximimum line length that can be handled.
  57  * DEFUPRI -- the default priority for user messages.
  58  * DEFSPRI -- the default priority for kernel messages.
  59  *
  60  */
  61 
  62 #include <unistd.h>
  63 #include <note.h>
  64 #include <errno.h>
  65 #include <sys/types.h>
  66 #include <stdio.h>
  67 #include <stdio_ext.h>
  68 #include <stdlib.h>
  69 #include <ctype.h>
  70 #include <signal.h>
  71 #include <string.h>
  72 #include <strings.h>
  73 #include <libscf.h>
  74 #include <netconfig.h>
  75 #include <netdir.h>
  76 #include <pwd.h>
  77 #include <sys/socket.h>
  78 #include <tiuser.h>
  79 #include <utmpx.h>
  80 #include <limits.h>
  81 #include <pthread.h>
  82 #include <fcntl.h>
  83 #include <stropts.h>
  84 #include <assert.h>
  85 #include <sys/statvfs.h>
  86 
  87 #include <sys/param.h>
  88 #include <sys/sysmacros.h>
  89 #include <sys/syslog.h>
  90 #include <sys/strlog.h>
  91 #include <sys/stat.h>
  92 #include <sys/time.h>
  93 #include <sys/utsname.h>
  94 #include <sys/poll.h>
  95 #include <sys/wait.h>
  96 #include <sys/resource.h>
  97 #include <sys/mman.h>
  98 #include <sys/note.h>
  99 #include <door.h>
 100 
 101 #include <wchar.h>
 102 #include <locale.h>
 103 #include <stdarg.h>
 104 
 105 #include "dataq.h"
 106 #include "conf.h"
 107 #include "syslogd.h"
 108 
 109 #define DOORFILE                "/var/run/syslog_door"
 110 #define RELATIVE_DOORFILE       "../var/run/syslog_door"
 111 #define OLD_DOORFILE            "/etc/.syslog_door"
 112 
 113 #define PIDFILE                 "/var/run/syslog.pid"
 114 #define RELATIVE_PIDFILE        "../var/run/syslog.pid"
 115 #define OLD_PIDFILE             "/etc/syslog.pid"
 116 
 117 static char             *LogName = "/dev/log";
 118 static char             *ConfFile = "/etc/syslog.conf";
 119 static char             ctty[] = "/dev/console";
 120 static char             sysmsg[] = "/dev/sysmsg";
 121 static int              DoorFd = -1;
 122 static int              DoorCreated = 0;
 123 static int              PidfileCreated = 0;
 124 static char             *DoorFileName = DOORFILE;
 125 static char             *PidFileName = PIDFILE;
 126 
 127 /*
 128  * configuration file directives
 129  */
 130 
 131 static struct code      PriNames[] = {
 132         "panic",        LOG_EMERG,
 133         "emerg",        LOG_EMERG,
 134         "alert",        LOG_ALERT,
 135         "crit",         LOG_CRIT,
 136         "err",          LOG_ERR,
 137         "error",        LOG_ERR,
 138         "warn",         LOG_WARNING,
 139         "warning",      LOG_WARNING,
 140         "notice",       LOG_NOTICE,
 141         "info",         LOG_INFO,
 142         "debug",        LOG_DEBUG,
 143         "none",         NOPRI,
 144         NULL,           -1
 145 };
 146 
 147 static struct code      FacNames[] = {
 148         "kern",         LOG_KERN,
 149         "user",         LOG_USER,
 150         "mail",         LOG_MAIL,
 151         "daemon",       LOG_DAEMON,
 152         "auth",         LOG_AUTH,
 153         "security",     LOG_AUTH,
 154         "mark",         LOG_MARK,
 155         "syslog",       LOG_SYSLOG,
 156         "lpr",          LOG_LPR,
 157         "news",         LOG_NEWS,
 158         "uucp",         LOG_UUCP,
 159         "altcron",      LOG_ALTCRON,
 160         "authpriv",     LOG_AUTHPRIV,
 161         "ftp",          LOG_FTP,
 162         "ntp",          LOG_NTP,
 163         "audit",        LOG_AUDIT,
 164         "console",      LOG_CONSOLE,
 165         "cron",         LOG_CRON,
 166         "local0",       LOG_LOCAL0,
 167         "local1",       LOG_LOCAL1,
 168         "local2",       LOG_LOCAL2,
 169         "local3",       LOG_LOCAL3,
 170         "local4",       LOG_LOCAL4,
 171         "local5",       LOG_LOCAL5,
 172         "local6",       LOG_LOCAL6,
 173         "local7",       LOG_LOCAL7,
 174         NULL,           -1
 175 };
 176 
 177 static char             *TypeNames[7] = {
 178         "UNUSED",       "FILE",         "TTY",          "CONSOLE",
 179         "FORW",         "USERS",        "WALL"
 180 };
 181 
 182 /*
 183  * we allocate our own thread stacks so we can create them
 184  * without the MAP_NORESERVE option. We need to be sure
 185  * we have stack space even if the machine runs out of swap
 186  */
 187 
 188 #define DEFAULT_STACKSIZE (100 * 1024)  /* 100 k stack */
 189 #define DEFAULT_REDZONESIZE (8 * 1024)  /* 8k redzone */
 190 
 191 static pthread_mutex_t wmp = PTHREAD_MUTEX_INITIALIZER; /* wallmsg lock */
 192 
 193 static pthread_mutex_t cft = PTHREAD_MUTEX_INITIALIZER;
 194 static int conf_threads = 0;
 195 
 196 static pthread_mutex_t hup_lock = PTHREAD_MUTEX_INITIALIZER;
 197 static pthread_cond_t hup_done = PTHREAD_COND_INITIALIZER;
 198 
 199 static pthread_mutex_t logerror_lock = PTHREAD_MUTEX_INITIALIZER;
 200 
 201 #define HUP_ACCEPTABLE          0x0000  /* can start SIGHUP process */
 202 #define HUP_INPROGRESS          0x0001  /* SIGHUP process in progress */
 203 #define HUP_COMPLETED           0x0002  /* SIGHUP process completed */
 204 #define HUP_SUSP_LOGMSG_REQD    0x1000  /* request to suspend */
 205 #define HUP_LOGMSG_SUSPENDED    0x2000  /* logmsg is suspended */
 206 static int hup_state = HUP_ACCEPTABLE;
 207 
 208 static size_t stacksize;                /* thread stack size */
 209 static size_t redzonesize;              /* thread stack redzone size */
 210 static char *stack_ptr;                 /* ptr to allocated stacks */
 211 static char *cstack_ptr;                /* ptr to conf_thr stacks */
 212 
 213 static time_t start_time;
 214 
 215 static pthread_t sys_thread;            /* queues messages from us */
 216 static pthread_t net_thread;            /* queues messages from the net */
 217 static pthread_t log_thread;            /* message processing thread */
 218 static pthread_t hnl_thread;            /* hostname lookup thread */
 219 
 220 static dataq_t inputq;                  /* the input queue */
 221 static dataq_t tmpq;                    /* temporary queue for err msg */
 222 static dataq_t hnlq;                    /* hostname lookup queue */
 223 
 224 static struct filed fallback[2];
 225 static struct filed *Files;
 226 static int nlogs;
 227 static int Debug;                       /* debug flag */
 228 static host_list_t LocalHostName;       /* our hostname */
 229 static host_list_t NullHostName;        /* in case of lookup failure */
 230 static int debuglev = 1;                /* debug print level */
 231 static int interrorlog;                 /* internal error logging */
 232 
 233 static int MarkInterval = 20;           /* interval between marks (mins) */
 234 static int Marking = 0;                 /* non-zero if marking some file */
 235 static int Ninputs = 0;                 /* number of network inputs */
 236 static int curalarm = 0;                /* current timeout value (secs) */
 237 static int sys_msg_count = 0;           /* total msgs rcvd from local log */
 238 static int sys_init_msg_count = 0;      /* initially received */
 239 static int net_msg_count = 0;           /* total msgs rcvd from net */
 240 
 241 static struct pollfd Pfd;               /* Pollfd for local the log device */
 242 static struct pollfd *Nfd;              /* Array of pollfds for udp ports */
 243 static struct netconfig *Ncf;
 244 static struct netbuf **Myaddrs;
 245 static struct t_unitdata **Udp;
 246 static struct t_uderr **Errp;
 247 static int turnoff = 0;
 248 static int shutting_down;
 249 
 250 /* for managing door server threads */
 251 static pthread_mutex_t door_server_cnt_lock = PTHREAD_MUTEX_INITIALIZER;
 252 static uint_t door_server_cnt = 0;
 253 static pthread_attr_t door_thr_attr;
 254 
 255 static struct hostname_cache **hnc_cache;
 256 static pthread_mutex_t hnc_mutex = PTHREAD_MUTEX_INITIALIZER;
 257 static size_t hnc_size = DEF_HNC_SIZE;
 258 static unsigned int hnc_ttl = DEF_HNC_TTL;
 259 
 260 #define DPRINT0(d, m)           if ((Debug) && debuglev >= (d)) \
 261                                 (void) fprintf(stderr, m)
 262 #define DPRINT1(d, m, a)        if ((Debug) && debuglev >= (d)) \
 263                                 (void) fprintf(stderr, m, a)
 264 #define DPRINT2(d, m, a, b)     if ((Debug) && debuglev >= (d)) \
 265                                 (void) fprintf(stderr, m, a, b)
 266 #define DPRINT3(d, m, a, b, c)  if ((Debug) && debuglev >= (d)) \
 267                                 (void) fprintf(stderr, m, a, b, c)
 268 #define DPRINT4(d, m, a, b, c, e)       if ((Debug) && debuglev >= (d)) \
 269                                 (void) fprintf(stderr, m, a, b, c, e)
 270 #define MALLOC_FAIL(x)  \
 271                 logerror("malloc failed: " x)
 272 #define MALLOC_FAIL_EXIT        \
 273                 logerror("malloc failed - fatal"); \
 274                 exit(1)
 275 
 276 
 277 #define MAILCMD "mailx -s \"syslogd shut down\" root"
 278 
 279 /*
 280  * Number of seconds to wait before giving up on threads that won't
 281  * shutdown: (that's right, 10 minutes!)
 282  */
 283 #define LOOP_MAX        (10 * 60)
 284 
 285 /*
 286  * Interval(sec) to check the status of output queue while processing
 287  * HUP signal.
 288  */
 289 #define LOOP_INTERVAL   (15)
 290 
 291 int
 292 main(int argc, char **argv)
 293 {
 294         int i;
 295         char *pstr;
 296         int sig, fd;
 297         int tflag = 0, Tflag = 0;
 298         sigset_t sigs, allsigs;
 299         struct rlimit rlim;
 300         char *debugstr;
 301         int mcount = 0;
 302         struct sigaction act;
 303         pthread_t mythreadno = 0;
 304         char cbuf [30];
 305         struct stat sb;
 306 
 307 #ifdef DEBUG
 308 #define DEBUGDIR "/var/tmp"
 309         if (chdir(DEBUGDIR))
 310                 DPRINT2(1, "main(%u): Unable to cd to %s\n", mythreadno,
 311                     DEBUGDIR);
 312 #endif /* DEBUG */
 313 
 314         (void) setlocale(LC_ALL, "");
 315 
 316         if ((debugstr = getenv("SYSLOGD_DEBUG")) != NULL)
 317                 if ((debuglev = atoi(debugstr)) == 0)
 318                         debuglev = 1;
 319 
 320 #if ! defined(TEXT_DOMAIN)      /* should be defined by cc -D */
 321 #define TEXT_DOMAIN "SYS_TEST"
 322 #endif
 323         (void) textdomain(TEXT_DOMAIN);
 324 
 325         (void) time(&start_time);
 326 
 327         if (lstat("/var/run", &sb) != 0 || !(S_ISDIR(sb.st_mode))) {
 328                 DoorFileName = OLD_DOORFILE;
 329                 PidFileName  = OLD_PIDFILE;
 330         }
 331 
 332         properties();
 333 
 334         while ((i = getopt(argc, argv, "df:p:m:tT")) != EOF) {
 335                 switch (i) {
 336                 case 'f':               /* configuration file */
 337                         ConfFile = optarg;
 338                         break;
 339 
 340                 case 'd':               /* debug */
 341                         Debug++;
 342                         break;
 343 
 344                 case 'p':               /* path */
 345                         LogName = optarg;
 346                         break;
 347 
 348                 case 'm':               /* mark interval */
 349                         for (pstr = optarg; *pstr; pstr++) {
 350                                 if (! (isdigit(*pstr))) {
 351                                         (void) fprintf(stderr,
 352                                             "Illegal interval\n");
 353                                         usage();
 354                                 }
 355                         }
 356                         MarkInterval = atoi(optarg);
 357                         if (MarkInterval < 1 || MarkInterval > INT_MAX) {
 358                                 (void) fprintf(stderr,
 359                                     "Interval must be between 1 and %d\n",
 360                                     INT_MAX);
 361                                 usage();
 362                         }
 363                         break;
 364                 case 't':               /* turn off remote reception */
 365                         tflag++;
 366                         turnoff++;
 367                         break;
 368                 case 'T':               /* turn on remote reception */
 369                         Tflag++;
 370                         turnoff = 0;
 371                         break;
 372                 default:
 373                         usage();
 374                 }
 375         }
 376 
 377         if (optind < argc)
 378                 usage();
 379 
 380         if (tflag && Tflag) {
 381                 (void) fprintf(stderr, "specify only one of -t and -T\n");
 382                 usage();
 383         }
 384 
 385         /*
 386          * close all fd's except 0-2
 387          */
 388 
 389         closefrom(3);
 390 
 391         if (!Debug) {
 392                 if (fork())
 393                         return (0);
 394                 (void) close(0);
 395                 (void) open("/", 0);
 396                 (void) dup2(0, 1);
 397                 (void) dup2(0, 2);
 398                 untty();
 399         }
 400 
 401         if (Debug) {
 402                 mythreadno = pthread_self();
 403         }
 404 
 405         /*
 406          * DO NOT call logerror() until tmpq is initialized.
 407          */
 408         disable_errorlog();
 409 
 410         /*
 411          * ensure that file descriptor limit is "high enough"
 412          */
 413         (void) getrlimit(RLIMIT_NOFILE, &rlim);
 414         if (rlim.rlim_cur < rlim.rlim_max)
 415                 rlim.rlim_cur = rlim.rlim_max;
 416         if (setrlimit(RLIMIT_NOFILE, &rlim) < 0)
 417                 logerror("Unable to increase file descriptor limit.");
 418         (void) enable_extended_FILE_stdio(-1, -1);
 419 
 420         /* block all signals from all threads initially */
 421         (void) sigfillset(&allsigs);
 422         (void) pthread_sigmask(SIG_BLOCK, &allsigs, NULL);
 423 
 424         DPRINT2(1, "main(%u): Started at time %s", mythreadno,
 425             ctime_r(&start_time, cbuf));
 426 
 427         init();                 /* read configuration, start threads */
 428 
 429         DPRINT1(1, "main(%u): off & running....\n", mythreadno);
 430 
 431         /* now set up to catch signals we care about */
 432 
 433         (void) sigemptyset(&sigs);
 434         (void) sigaddset(&sigs, SIGHUP);    /* reconfigure */
 435         (void) sigaddset(&sigs, SIGALRM);   /* mark & flush timer */
 436         (void) sigaddset(&sigs, SIGTERM);   /* exit */
 437         (void) sigaddset(&sigs, SIGINT);    /* exit if debugging */
 438         (void) sigaddset(&sigs, SIGQUIT);   /* exit if debugging */
 439         (void) sigaddset(&sigs, SIGPIPE);   /* catch & discard */
 440         (void) sigaddset(&sigs, SIGUSR1);   /* dump debug stats */
 441 
 442         /*
 443          * We must set up to catch these signals, even though sigwait
 444          * will get them before the isr does.  Setting SA_SIGINFO ensures
 445          * that signals will be enqueued.
 446          */
 447 
 448         act.sa_flags = SA_SIGINFO;
 449         act.sa_sigaction = signull;
 450 
 451         (void) sigaction(SIGHUP, &act, NULL);
 452         (void) sigaction(SIGALRM, &act, NULL);
 453         (void) sigaction(SIGTERM, &act, NULL);
 454         (void) sigaction(SIGINT, &act, NULL);
 455         (void) sigaction(SIGQUIT, &act, NULL);
 456         (void) sigaction(SIGPIPE, &act, NULL);
 457         (void) sigaction(SIGUSR1, &act, NULL);
 458 
 459         /* we now turn into the signal handling thread */
 460 
 461         DPRINT1(2, "main(%u): now handling signals\n", mythreadno);
 462         for (;;) {
 463                 (void) sigwait(&sigs, &sig);
 464                 DPRINT2(2, "main(%u): received signal %d\n", mythreadno, sig);
 465                 switch (sig) {
 466                 case SIGALRM:
 467                         DPRINT1(1, "main(%u): Got SIGALRM\n",
 468                             mythreadno);
 469                         flushmsg(NOCOPY);
 470                         if (Marking && (++mcount % MARKCOUNT == 0)) {
 471                                 if (logmymsg(LOG_INFO, "-- MARK --",
 472                                     ADDDATE|MARK|NOCOPY, 0) == -1) {
 473                                         MALLOC_FAIL(
 474                                             "dropping MARK message");
 475                                 }
 476 
 477                                 mcount = 0;
 478                         }
 479                         curalarm = MarkInterval * 60 / MARKCOUNT;
 480                         (void) alarm((unsigned)curalarm);
 481                         DPRINT2(2, "main(%u): Next alarm in %d "
 482                             "seconds\n", mythreadno, curalarm);
 483                         break;
 484                 case SIGHUP:
 485                         DPRINT1(1, "main(%u): got SIGHUP - "
 486                             "reconfiguring\n", mythreadno);
 487 
 488                         reconfigure();
 489 
 490                         DPRINT1(1, "main(%u): done processing SIGHUP\n",
 491                             mythreadno);
 492                         break;
 493                 case SIGQUIT:
 494                 case SIGINT:
 495                         if (!Debug) {
 496                                 /* allow these signals if debugging */
 497                                 break;
 498                         }
 499                         /* FALLTHROUGH */
 500                 case SIGTERM:
 501                         DPRINT2(1, "main(%u): going down on signal %d\n",
 502                             mythreadno, sig);
 503                         (void) alarm(0);
 504                         flushmsg(0);
 505                         errno = 0;
 506                         t_errno = 0;
 507                         logerror("going down on signal %d", sig);
 508                         disable_errorlog();     /* force msg to console */
 509                         (void) shutdown_msg();  /* stop threads */
 510                         shutdown_input();
 511                         close_door();
 512                         delete_doorfiles();
 513                         return (0);
 514                 case SIGUSR1:                   /* secret debug dump mode */
 515                         /* if in debug mode, use stdout */
 516 
 517                         if (Debug) {
 518                                 dumpstats(STDOUT_FILENO);
 519                                 break;
 520                         }
 521                         /* otherwise dump to a debug file */
 522                         if ((fd = open(DEBUGFILE,
 523                             (O_WRONLY|O_CREAT|O_TRUNC|O_EXCL),
 524                             0644)) < 0)
 525                                 break;
 526                         dumpstats(fd);
 527                         (void) close(fd);
 528                         break;
 529                 default:
 530                         DPRINT2(2, "main(%u): unexpected signal %d\n",
 531                             mythreadno, sig);
 532                         break;
 533                 }
 534         }
 535 }
 536 
 537 /*
 538  * Attempts to open the local log device
 539  * and return a file descriptor.
 540  */
 541 static int
 542 openklog(char *name, int mode)
 543 {
 544         int fd;
 545         struct strioctl str;
 546         pthread_t mythreadno;
 547 
 548         if (Debug) {
 549                 mythreadno = pthread_self();
 550         }
 551 
 552         if ((fd = open(name, mode)) < 0) {
 553                 logerror("cannot open %s", name);
 554                 DPRINT3(1, "openklog(%u): cannot create %s (%d)\n",
 555                     mythreadno, name, errno);
 556                 return (-1);
 557         }
 558         str.ic_cmd = I_CONSLOG;
 559         str.ic_timout = 0;
 560         str.ic_len = 0;
 561         str.ic_dp = NULL;
 562         if (ioctl(fd, I_STR, &str) < 0) {
 563                 logerror("cannot register to log console messages");
 564                 DPRINT2(1, "openklog(%u): cannot register to log "
 565                     "console messages (%d)\n", mythreadno, errno);
 566                 return (-1);
 567         }
 568         return (fd);
 569 }
 570 
 571 
 572 /*
 573  * Open the log device, and pull up all pending messages.
 574  */
 575 static void
 576 prepare_sys_poll()
 577 {
 578         int nfds, funix;
 579 
 580         if ((funix = openklog(LogName, O_RDONLY)) < 0) {
 581                 logerror("can't open kernel log device - fatal");
 582                 exit(1);
 583         }
 584 
 585         Pfd.fd = funix;
 586         Pfd.events = POLLIN;
 587 
 588         for (;;) {
 589                 nfds = poll(&Pfd, 1, 0);
 590                 if (nfds <= 0) {
 591                         if (sys_init_msg_count > 0)
 592                                 flushmsg(SYNC_FILE);
 593                         break;
 594                 }
 595 
 596                 if (Pfd.revents & POLLIN) {
 597                         getkmsg(0);
 598                 } else if (Pfd.revents & (POLLNVAL|POLLHUP|POLLERR)) {
 599                         logerror("kernel log driver poll error");
 600                         break;
 601                 }
 602         }
 603 
 604 }
 605 
 606 /*
 607  * this thread listens to the local stream log driver for log messages
 608  * generated by this host, formats them, and queues them to the logger
 609  * thread.
 610  */
 611 /*ARGSUSED*/
 612 static void *
 613 sys_poll(void *ap)
 614 {
 615         int nfds;
 616         static int klogerrs = 0;
 617         pthread_t mythreadno;
 618 
 619         if (Debug) {
 620                 mythreadno = pthread_self();
 621         }
 622 
 623         DPRINT1(1, "sys_poll(%u): sys_thread started\n", mythreadno);
 624 
 625         /*
 626          * Process messages, blocking on poll because timeout is set
 627          * to INFTIM.  When poll returns with a message, call getkmsg
 628          * to pull up one message from the log driver and enqueue it
 629          * with the sync flag set.
 630          */
 631 
 632         sys_init_msg_count = 0;
 633 
 634         for (;;) {
 635                 errno = 0;
 636                 t_errno = 0;
 637 
 638                 nfds = poll(&Pfd, 1, INFTIM);
 639 
 640                 if (nfds == 0)
 641                         continue;
 642 
 643                 if (nfds < 0) {
 644                         if (errno != EINTR)
 645                                 logerror("poll");
 646                         continue;
 647                 }
 648                 if (Pfd.revents & POLLIN) {
 649                         getkmsg(INFTIM);
 650                 } else {
 651                         if (shutting_down) {
 652                                 pthread_exit(0);
 653                         }
 654                         if (Pfd.revents & (POLLNVAL|POLLHUP|POLLERR)) {
 655                                 logerror("kernel log driver poll error");
 656                                 (void) close(Pfd.fd);
 657                                 Pfd.fd = -1;
 658                         }
 659                 }
 660 
 661                 while (Pfd.fd == -1 && klogerrs++ < 10) {
 662                         Pfd.fd = openklog(LogName, O_RDONLY);
 663                 }
 664                 if (klogerrs >= 10) {
 665                         logerror("can't reopen kernel log device - fatal");
 666                         exit(1);
 667                 }
 668         }
 669         /*NOTREACHED*/
 670         return (NULL);
 671 }
 672 
 673 /*
 674  * Pull up one message from log driver.
 675  */
 676 static void
 677 getkmsg(int timeout)
 678 {
 679         int flags = 0, i;
 680         char *lastline;
 681         struct strbuf ctl, dat;
 682         struct log_ctl hdr;
 683         char buf[MAXLINE+1];
 684         size_t buflen;
 685         size_t len;
 686         char tmpbuf[MAXLINE+1];
 687         pthread_t mythreadno;
 688 
 689         if (Debug) {
 690                 mythreadno = pthread_self();
 691         }
 692 
 693         dat.maxlen = MAXLINE;
 694         dat.buf = buf;
 695         ctl.maxlen = sizeof (struct log_ctl);
 696         ctl.buf = (caddr_t)&hdr;
 697 
 698         while ((i = getmsg(Pfd.fd, &ctl, &dat, &flags)) == MOREDATA) {
 699                 lastline = &dat.buf[dat.len];
 700                 *lastline = '\0';
 701 
 702                 DPRINT2(5, "getkmsg:(%u): getmsg: dat.len = %d\n",
 703                     mythreadno, dat.len);
 704                 buflen = strlen(buf);
 705                 len = findnl_bkwd(buf, buflen);
 706 
 707                 (void) memcpy(tmpbuf, buf, len);
 708                 tmpbuf[len] = '\0';
 709 
 710                 /*
 711                  * Format sys will enqueue the log message.
 712                  * Set the sync flag if timeout != 0, which
 713                  * means that we're done handling all the
 714                  * initial messages ready during startup.
 715                  */
 716                 if (timeout == 0) {
 717                         formatsys(&hdr, tmpbuf, 0);
 718                         sys_init_msg_count++;
 719                 } else {
 720                         formatsys(&hdr, tmpbuf, 1);
 721                 }
 722                 sys_msg_count++;
 723 
 724                 if (len != buflen) {
 725                         /* If anything remains in buf */
 726                         size_t remlen;
 727 
 728                         if (buf[len] == '\n') {
 729                                 /* skip newline */
 730                                 len++;
 731                         }
 732 
 733                         /*
 734                          *  Move the remaining bytes to
 735                          * the beginnning of buf.
 736                          */
 737 
 738                         remlen = buflen - len;
 739                         (void) memcpy(buf, &buf[len], remlen);
 740                         dat.maxlen = MAXLINE - remlen;
 741                         dat.buf = &buf[remlen];
 742                 } else {
 743                         dat.maxlen = MAXLINE;
 744                         dat.buf = buf;
 745                 }
 746         }
 747 
 748         if (i == 0 && dat.len > 0) {
 749                 dat.buf[dat.len] = '\0';
 750                 /*
 751                  * Format sys will enqueue the log message.
 752                  * Set the sync flag if timeout != 0, which
 753                  * means that we're done handling all the
 754                  * initial messages ready during startup.
 755                  */
 756                 DPRINT2(5, "getkmsg(%u): getmsg: dat.maxlen = %d\n",
 757                     mythreadno, dat.maxlen);
 758                 DPRINT2(5, "getkmsg(%u): getmsg: dat.len = %d\n",
 759                     mythreadno, dat.len);
 760                 DPRINT2(5, "getkmsg(%u): getmsg: strlen(dat.buf) = %d\n",
 761                     mythreadno, strlen(dat.buf));
 762                 DPRINT2(5, "getkmsg(%u): getmsg: dat.buf = \"%s\"\n",
 763                     mythreadno, dat.buf);
 764                 DPRINT2(5, "getkmsg(%u): buf len = %d\n",
 765                     mythreadno, strlen(buf));
 766                 if (timeout == 0) {
 767                         formatsys(&hdr, buf, 0);
 768                         sys_init_msg_count++;
 769                 } else {
 770                         formatsys(&hdr, buf, 1);
 771                 }
 772                 sys_msg_count++;
 773         } else if (i < 0 && errno != EINTR) {
 774                 if (!shutting_down) {
 775                         logerror("kernel log driver read error");
 776                 }
 777                 (void) close(Pfd.fd);
 778                 Pfd.fd = -1;
 779         }
 780 }
 781 
 782 /*
 783  * this thread polls all the network interfaces for syslog messages
 784  * forwarded to us, tags them with the hostname they are received
 785  * from, and queues them to the logger thread.
 786  */
 787 /*ARGSUSED*/
 788 static void *
 789 net_poll(void *ap)
 790 {
 791         int nfds, i;
 792         int flags = 0;
 793         struct t_unitdata *udp;
 794         struct t_uderr *errp;
 795         char buf[MAXLINE+1];
 796         char *uap;
 797         log_message_t *mp;
 798         host_info_t *hinfo;
 799         pthread_t mythreadno;
 800 
 801         if (Debug) {
 802                 mythreadno = pthread_self();
 803         }
 804 
 805         DPRINT1(1, "net_poll(%u): net_thread started\n", mythreadno);
 806 
 807         _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*mp))
 808 
 809         for (;;) {
 810                 errno = 0;
 811                 t_errno = 0;
 812                 nfds = poll(Nfd, Ninputs, -1);
 813                 if (nfds == 0)
 814                         continue;
 815 
 816                 if (nfds < 0) {
 817                         if (errno != EINTR)
 818                                 logerror("poll");
 819                         continue;
 820                 }
 821                 for (i = 0; nfds > 0 && i < Ninputs; i++) {
 822                         if ((Nfd[i].revents & POLLIN) == 0) {
 823                                 if (shutting_down) {
 824                                         pthread_exit(0);
 825                                 }
 826                                 if (Nfd[i].revents &
 827                                     (POLLNVAL|POLLHUP|POLLERR)) {
 828                                         logerror("POLLNVAL|POLLHUP|POLLERR");
 829                                         (void) t_close(Nfd[i].fd);
 830                                         Nfd[i].fd = -1;
 831                                         nfds--;
 832                                 }
 833                                 continue;
 834                         }
 835 
 836                         udp = Udp[i];
 837                         udp->udata.buf = buf;
 838                         udp->udata.maxlen = MAXLINE;
 839                         udp->udata.len = 0;
 840                         flags = 0;
 841                         if (t_rcvudata(Nfd[i].fd, udp, &flags) < 0) {
 842                                 errp = Errp[i];
 843                                 if (t_errno == TLOOK) {
 844                                         if (t_rcvuderr(Nfd[i].fd, errp) < 0) {
 845                                                 if (!shutting_down) {
 846                                                         logerror("t_rcvuderr");
 847                                                 }
 848                                                 (void) t_close(Nfd[i].fd);
 849                                                 Nfd[i].fd = -1;
 850                                         }
 851                                 } else {
 852                                         if (!shutting_down) {
 853                                                 logerror("t_rcvudata");
 854                                         }
 855                                         (void) t_close(Nfd[i].fd);
 856                                         Nfd[i].fd = -1;
 857                                 }
 858                                 nfds--;
 859                                 if (shutting_down) {
 860                                         pthread_exit(0);
 861                                 }
 862                                 continue;
 863                         }
 864                         nfds--;
 865 
 866                         if (udp->udata.len == 0) {
 867                                 if (Debug) {
 868                                         uap = NULL;
 869                                         if (udp->addr.len > 0) {
 870                                                 uap = taddr2uaddr(&Ncf[i],
 871                                                     &udp->addr);
 872                                         }
 873                                         DPRINT2(1, "net_poll(%u):"
 874                                             " received empty packet"
 875                                             " from %s\n", mythreadno,
 876                                             uap ? uap : "<unknown>");
 877                                         if (uap)
 878                                                 free(uap);
 879                                 }
 880                                 continue;       /* No data */
 881                         }
 882                         if (udp->addr.len == 0) {
 883                                 /*
 884                                  * The previous message was larger than
 885                                  * MAXLINE, and T_MORE should have been set.
 886                                  * Further data needs to be discarded as
 887                                  * we've already received MAXLINE.
 888                                  */
 889                                 DPRINT1(1, "net_poll(%u): discarding packet "
 890                                     "exceeds max line size\n", mythreadno);
 891                                 continue;
 892                         }
 893 
 894                         net_msg_count++;
 895 
 896                         if ((mp = new_msg()) == NULL) {
 897                                 MALLOC_FAIL("dropping message from "
 898                                     "remote");
 899                                 continue;
 900                         }
 901 
 902                         buf[udp->udata.len] = '\0';
 903                         formatnet(&udp->udata, mp);
 904 
 905                         if (Debug) {
 906                                 uap = taddr2uaddr(&Ncf[i], &udp->addr);
 907                                 DPRINT2(1, "net_poll(%u): received message"
 908                                     " from %s\n", mythreadno,
 909                                     uap ? uap : "<unknown>");
 910                                 free(uap);
 911                         }
 912                         if ((hinfo = malloc(sizeof (*hinfo))) == NULL ||
 913                             (hinfo->addr.buf =
 914                             malloc(udp->addr.len)) == NULL) {
 915                                 MALLOC_FAIL("dropping message from "
 916                                     "remote");
 917                                 if (hinfo) {
 918                                         free(hinfo);
 919                                 }
 920                                 free_msg(mp);
 921                                 continue;
 922                         }
 923 
 924                         hinfo->ncp = &Ncf[i];
 925                         hinfo->addr.len = udp->addr.len;
 926                         (void) memcpy(hinfo->addr.buf, udp->addr.buf,
 927                             udp->addr.len);
 928                         mp->ptr = hinfo;
 929                         if (dataq_enqueue(&hnlq, (void *)mp) == -1) {
 930                                 MALLOC_FAIL("dropping message from "
 931                                     "remote");
 932                                 free_msg(mp);
 933                                 free(hinfo->addr.buf);
 934                                 free(hinfo);
 935                                 continue;
 936                         }
 937                         DPRINT3(5, "net_poll(%u): enqueued msg %p "
 938                             "on queue %p\n", mythreadno, (void *)mp,
 939                             (void *)&hnlq);
 940                 }
 941         }
 942         /*NOTREACHED*/
 943         return (NULL);
 944 }
 945 
 946 static void
 947 usage(void)
 948 {
 949         (void) fprintf(stderr,
 950             "usage: syslogd [-d] [-t|-T] [-mmarkinterval] [-ppath]"
 951             " [-fconffile]\n");
 952         exit(1);
 953 }
 954 
 955 static void
 956 untty(void)
 957 {
 958         if (!Debug)
 959                 (void) setsid();
 960 }
 961 
 962 /*
 963  * generate a log message internally. The original version of syslogd
 964  * simply called logmsg directly, but because everything is now based
 965  * on message passing, we need an internal way to generate and queue
 966  * log messages from within syslogd itself.
 967  */
 968 static int
 969 logmymsg(int pri, char *msg, int flags, int pending)
 970 {
 971         log_message_t *mp;
 972         pthread_t mythreadno;
 973         dataq_t *qptr;
 974 
 975         if (Debug) {
 976                 mythreadno = pthread_self();
 977         }
 978 
 979         if ((mp = new_msg()) == NULL) {
 980                 return (-1);
 981         }
 982 
 983         _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*mp))
 984         mp->pri = pri;
 985         mp->hlp = &LocalHostName;
 986         (void) strlcpy(mp->msg, msg, MAXLINE+1);
 987         mp->flags = flags;
 988         (void) time(&mp->ts);
 989 
 990         qptr = pending ? &tmpq : &inputq;
 991         if (dataq_enqueue(qptr, (void *)mp) == -1) {
 992                 free_msg(mp);
 993                 return (-1);
 994         }
 995 
 996         DPRINT3(5, "logmymsg(%u): enqueued msg %p on queue %p\n",
 997             mythreadno, (void *)mp, (void *)qptr);
 998         DPRINT2(5, "logmymsg(%u): Message content: %s\n", mythreadno, msg);
 999         return (0);
1000 }
1001 
1002 /*
1003  * Generate an internal shutdown message
1004  */
1005 static int
1006 shutdown_msg(void)
1007 {
1008         pthread_t mythreadno;
1009         log_message_t *mp;
1010 
1011         if (Debug) {
1012                 mythreadno = pthread_self();
1013         }
1014 
1015         if ((mp = new_msg()) == NULL) {
1016                 return (-1);
1017         }
1018 
1019         _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*mp));
1020         mp->flags = SHUTDOWN;
1021         mp->hlp = &LocalHostName;
1022 
1023         if (dataq_enqueue(&inputq, (void *)mp) == -1) {
1024                 free_msg(mp);
1025                 return (-1);
1026         }
1027 
1028         DPRINT3(5, "shutdown_msg(%u): enqueued msg %p on queue %p\n",
1029             mythreadno, (void *)mp, (void *)&inputq);
1030         return (0);
1031 }
1032 
1033 /*
1034  * Generate an internal flush message
1035  */
1036 static void
1037 flushmsg(int flags)
1038 {
1039         log_message_t *mp;
1040         pthread_t mythreadno;
1041 
1042         if (Debug) {
1043                 mythreadno = pthread_self();
1044         }
1045 
1046         if ((mp = new_msg()) == NULL) {
1047                 MALLOC_FAIL("dropping flush msg");
1048                 return;
1049         }
1050 
1051         _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*mp));
1052         mp->flags = FLUSHMSG | flags;
1053         mp->hlp = &LocalHostName;
1054 
1055         if (dataq_enqueue(&inputq, (void *)mp) == -1) {
1056                 free_msg(mp);
1057                 MALLOC_FAIL("dropping flush msg");
1058                 return;
1059         }
1060 
1061         DPRINT4(5, "flush_msg(%u): enqueued msg %p on queue %p, flags "
1062             "0x%x\n", mythreadno, (void *)mp, (void *)&inputq, flags);
1063 }
1064 
1065 /*
1066  * Do some processing on messages received from the net
1067  */
1068 static void
1069 formatnet(struct netbuf *nbp, log_message_t *mp)
1070 {
1071         char *p;
1072         int pri;
1073         pthread_t mythreadno;
1074 
1075         if (Debug) {
1076                 mythreadno = pthread_self();
1077         }
1078 
1079         DPRINT2(5, "formatnet(%u): called for msg %p\n", mythreadno,
1080             (void *)mp);
1081 
1082         mp->flags = NETWORK;
1083         (void) time(&mp->ts);
1084 
1085         /* test for special codes */
1086         pri = DEFUPRI;
1087         p = nbp->buf;
1088         DPRINT2(9, "formatnet(%u): Message content:\n>%s<\n", mythreadno,
1089             p);
1090         if (*p == '<' && isdigit(*(p+1))) {
1091                 pri = 0;
1092                 while (isdigit(*++p))
1093                         pri = 10 * pri + (*p - '0');
1094                 if (*p == '>')
1095                         ++p;
1096                 if (pri <= 0 || pri >= (LOG_NFACILITIES << 3))
1097                         pri = DEFUPRI;
1098         }
1099 
1100         mp->pri = pri;
1101         (void) strlcpy(mp->msg, p, MAXLINE+1);
1102 }
1103 
1104 /*
1105  * Do some processing on messages generated by this host
1106  * and then enqueue the log message.
1107  */
1108 static void
1109 formatsys(struct log_ctl *lp, char *msg, int sync)
1110 {
1111         char *p, *q;
1112         char line[MAXLINE + 1];
1113         size_t msglen;
1114         log_message_t   *mp;
1115         char cbuf[30];
1116         pthread_t mythreadno;
1117 
1118         if (Debug) {
1119                 mythreadno = pthread_self();
1120         }
1121 
1122         DPRINT3(3, "formatsys(%u): log_ctl.mid = %d, log_ctl.sid = %d\n",
1123             mythreadno, lp->mid, lp->sid);
1124         DPRINT2(9, "formatsys(%u): Message Content:\n>%s<\n", mythreadno,
1125             msg);
1126 
1127         /* msglen includes the null termination */
1128         msglen = strlen(msg) + 1;
1129 
1130         for (p = msg; *p != '\0'; ) {
1131                 size_t linelen;
1132                 size_t len;
1133 
1134                 /*
1135                  * Allocate a log_message_t structure.
1136                  * We should do it here since a single message (msg)
1137                  * could be composed of many lines.
1138                  */
1139                 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*mp));
1140 
1141                 if ((mp = new_msg()) == NULL) {
1142                         MALLOC_FAIL("dropping message");
1143                         /*
1144                          * Should bail out from the loop.
1145                          */
1146                         break;
1147                 }
1148 
1149                 mp->flags &= ~NETWORK;
1150                 mp->hlp = &LocalHostName;
1151                 mp->ts = lp->ttime;
1152                 if (lp->flags & SL_LOGONLY)
1153                         mp->flags |= IGN_CONS;
1154                 if (lp->flags & SL_CONSONLY)
1155                         mp->flags |= IGN_FILE;
1156 
1157                 /* extract facility */
1158                 if ((lp->pri & LOG_FACMASK) == LOG_KERN) {
1159                         (void) sprintf(line, "%.15s ",
1160                             ctime_r(&mp->ts, cbuf) + 4);
1161                 } else {
1162                         (void) sprintf(line, "");
1163                 }
1164 
1165                 linelen = strlen(line);
1166                 q = line + linelen;
1167 
1168                 DPRINT2(5, "formatsys(%u): msglen = %d\n", mythreadno, msglen);
1169                 len = copynl_frwd(q, MAXLINE + 1 - linelen, p, msglen);
1170                 DPRINT2(5, "formatsys(%u): len (copynl_frwd) = %d\n",
1171                     mythreadno, len);
1172 
1173                 p += len;
1174                 msglen -= len;
1175 
1176                 if (*p == '\n') {
1177                         /* skip newline */
1178                         p++;
1179                 }
1180 
1181                 if (sync && ((lp->pri & LOG_FACMASK) == LOG_KERN))
1182                         mp->flags |= SYNC_FILE;      /* fsync file after write */
1183 
1184                 if (len != 0) {
1185                         (void) strlcpy(mp->msg, line, MAXLINE+1);
1186                         mp->pri = lp->pri;
1187 
1188                         if (dataq_enqueue(&inputq, (void *)mp) == -1) {
1189                                 free_msg(mp);
1190                                 MALLOC_FAIL("dropping message");
1191                                 break;
1192                         }
1193 
1194                         DPRINT3(5, "formatsys(%u): sys_thread enqueued msg "
1195                             "%p on queue %p\n", mythreadno, (void *)mp,
1196                             (void *)&inputq);
1197                 } else
1198                         free_msg(mp);
1199         }
1200 }
1201 
1202 /*
1203  * Log a message to the appropriate log files, users, etc. based on
1204  * the priority.
1205  */
1206 /*ARGSUSED*/
1207 static void *
1208 logmsg(void *ap)
1209 {
1210         struct filed *f;
1211         int fac, prilev, flags, refcnt;
1212         int fake_shutdown, skip_shutdown;
1213         log_message_t *mp, *save_mp;
1214         pthread_t mythreadno;
1215 
1216         if (Debug) {
1217                 mythreadno = pthread_self();
1218         }
1219 
1220         DPRINT1(1, "logmsg(%u): msg dispatcher started\n", mythreadno);
1221 
1222         fake_shutdown = skip_shutdown = 0;
1223         save_mp = NULL;
1224         for (;;) {
1225                 if (save_mp) {
1226                         /*
1227                          * If we have set aside a message in order to fake a
1228                          * SHUTDOWN, use that message before picking from the
1229                          * queue again.
1230                          */
1231                         mp = save_mp;
1232                         save_mp = NULL;
1233                 } else {
1234                         (void) dataq_dequeue(&inputq, (void **)&mp, 0);
1235                 }
1236                 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*mp))
1237                 DPRINT3(5, "logmsg(%u): msg dispatcher dequeued %p from "
1238                     "queue %p\n", mythreadno, (void *)mp,
1239                     (void *)&inputq);
1240 
1241                 /*
1242                  * In most cases, if the message traffic is low, logmsg() wakes
1243                  * up when it receives the SHUTDOWN msg, and will sleep until
1244                  * HUP process is complete.  However, if the inputq is too
1245                  * long, logmsg() may not receive SHUTDOWN before reconfigure()
1246                  * releases the logger fds, filed and logit threads.  That, in
1247                  * turn, will cause logmsg to refer to invalid fileds.
1248                  *
1249                  * logmsg() needs to respond to the SHUTDOWN message within
1250                  * LOOP_INTERVAL seconds when reconfigure() enqueues it. It
1251                  * does so in most cases.  When it does not respond in time,
1252                  * logmsg() needs to be in suspended state immediately, since
1253                  * filed may have been invalidated. reconfigure() will set the
1254                  * HUP_SUSP_LOGMSG_REQD bit in hup_state and wait another
1255                  * LOOP_INTERVAL seconds before proceeding.
1256                  *
1257                  * When HUP_SUSP_LOGMSG_REQD is set, we will create a fake
1258                  * SHUTDOWN message, and dispatch it to the various logit
1259                  * threads, and logmsg() itself will suspend.  In order to
1260                  * ignore the real SHUTDOWN which will arrive later, we keep a
1261                  * counter (skip_shutdown) and decrement it when the SHUTDOWN
1262                  * message arrives.
1263                  */
1264                 if ((hup_state & HUP_SUSP_LOGMSG_REQD) &&
1265                     (mp->flags & SHUTDOWN) == 0) {
1266                         DPRINT1(3, "logmsg(%u): suspend request\n",
1267                             mythreadno);
1268 
1269                         save_mp = mp;
1270 
1271                         /* create a fake SHUTDOWN msg */
1272                         if ((mp = new_msg()) == NULL) {
1273                                 MALLOC_FAIL("dropping message");
1274                                 if (mp->flags & SHUTDOWN) {
1275                                         (void) logerror_to_console(1,
1276                                             "unable to shutdown "
1277                                             "logger thread");
1278                                 }
1279                                 continue;
1280                         }
1281                         mp->flags = SHUTDOWN;
1282                         mp->hlp = &LocalHostName;
1283                         fake_shutdown = 1;
1284                         skip_shutdown++;
1285                         DPRINT2(3, "logmsg(%u): pending SHUTDOWN %d\n",
1286                             mythreadno, skip_shutdown);
1287                 }
1288 
1289                 /*
1290                  * is it a shutdown or flush message ?
1291                  */
1292                 if ((mp->flags & SHUTDOWN) || (mp->flags & FLUSHMSG)) {
1293                         (void) pthread_mutex_lock(&mp->msg_mutex);
1294 
1295                         if ((mp->flags & SHUTDOWN) &&
1296                             !fake_shutdown && skip_shutdown > 0) {
1297                                 skip_shutdown--;
1298                                 (void) pthread_mutex_unlock(&mp->msg_mutex);
1299                                 free_msg(mp);
1300                                 DPRINT2(3, "logmsg(%u): released late "
1301                                     "arrived SHUTDOWN. pending %d\n",
1302                                     mythreadno, skip_shutdown);
1303                                 continue;
1304                         }
1305 
1306                         for (f = Files; f < &Files[nlogs]; f++) {
1307                                 (void) pthread_mutex_lock(&f->filed_mutex);
1308 
1309                                 if (f->f_type == F_UNUSED) {
1310                                         (void) pthread_mutex_unlock(
1311                                             &f->filed_mutex);
1312                                         continue;
1313                                 }
1314 
1315                                 f->f_queue_count++;
1316                                 mp->refcnt++;
1317 
1318                                 if (dataq_enqueue(&f->f_queue,
1319                                     (void *)mp) == -1) {
1320                                         f->f_queue_count--;
1321                                         mp->refcnt--;
1322                                         (void) pthread_mutex_unlock(
1323                                             &f->filed_mutex);
1324                                         MALLOC_FAIL("dropping message");
1325 
1326                                         if (mp->flags & SHUTDOWN) {
1327                                                 (void) logerror_to_console(1,
1328                                                     "unable to shutdown "
1329                                                     "logger thread");
1330                                         }
1331 
1332                                         continue;
1333                                 }
1334                                 DPRINT3(5, "logmsg(%u): enqueued msg %p "
1335                                     "on queue %p\n", mythreadno,
1336                                     (void *)mp, (void *)&f->f_queue);
1337                                 (void) pthread_mutex_unlock(&f->filed_mutex);
1338                         }
1339 
1340                         /*
1341                          * flags value needs to be saved because mp may
1342                          * have been freed before SHUTDOWN test below.
1343                          */
1344                         flags = mp->flags;
1345                         refcnt = mp->refcnt;
1346 
1347                         (void) pthread_mutex_unlock(&mp->msg_mutex);
1348                         if (refcnt == 0)
1349                                 free_msg(mp);
1350 
1351                         if (flags & SHUTDOWN) {
1352                                 (void) pthread_mutex_lock(&hup_lock);
1353                                 while (hup_state != HUP_COMPLETED) {
1354                                         hup_state |= HUP_LOGMSG_SUSPENDED;
1355                                         (void) pthread_cond_wait(&hup_done,
1356                                             &hup_lock);
1357                                         hup_state &= ~HUP_LOGMSG_SUSPENDED;
1358                                 }
1359                                 hup_state = HUP_ACCEPTABLE;
1360                                 (void) pthread_mutex_unlock(&hup_lock);
1361                                 fake_shutdown = 0;
1362                         }
1363                         continue;
1364                 }
1365 
1366                 /*
1367                  * Check to see if msg looks non-standard.
1368                  */
1369                 if ((int)strlen(mp->msg) < 16 || mp->msg[3] != ' ' ||
1370                     mp->msg[6] != ' ' || mp->msg[9] != ':' ||
1371                     mp->msg[12] != ':' || mp->msg[15] != ' ')
1372                         mp->flags |= ADDDATE;
1373 
1374                 /* extract facility and priority level */
1375                 fac = (mp->pri & LOG_FACMASK) >> 3;
1376                 if (mp->flags & MARK)
1377                         fac = LOG_NFACILITIES;
1378                 prilev = mp->pri & LOG_PRIMASK;
1379 
1380                 DPRINT3(3, "logmsg(%u): fac = %d, pri = %d\n",
1381                     mythreadno, fac, prilev);
1382 
1383                 /*
1384                  * Because different devices log at different speeds,
1385                  * it's important to hold the mutex for the current
1386                  * message until it's been enqueued to all log files,
1387                  * so the reference count is accurate before any
1388                  * of the log threads can decrement it.
1389                  */
1390                 _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(*mp))
1391                 _NOTE(COMPETING_THREADS_NOW)
1392                 (void) pthread_mutex_lock(&mp->msg_mutex);
1393 
1394                 for (f = Files; f < &Files[nlogs]; f++) {
1395                         /* skip messages that are incorrect priority */
1396                         if (f->f_pmask[fac] < (unsigned)prilev ||
1397                             f->f_pmask[fac] == NOPRI)
1398                                 continue;
1399                         if (f->f_queue_count > Q_HIGHWATER_MARK) {
1400                                 DPRINT4(5, "logmsg(%u): Dropping message "
1401                                     "%p on file %p, count = %d\n",
1402                                     mythreadno, (void *)mp, (void *)f,
1403                                     f->f_queue_count);
1404                                 continue;
1405                         }
1406 
1407                         /*
1408                          * Need to grab filed_mutex before testing the f_type.
1409                          * Otherwise logit() may set F_UNUSED after the test
1410                          * below, and start pulling out the pending messages.
1411                          */
1412 
1413                         (void) pthread_mutex_lock(&f->filed_mutex);
1414 
1415                         if (f->f_type == F_UNUSED ||
1416                             (f->f_type == F_FILE && (mp->flags & IGN_FILE)) ||
1417                             (f->f_type == F_CONSOLE &&
1418                             (mp->flags & IGN_CONS))) {
1419                                 (void) pthread_mutex_unlock(&f->filed_mutex);
1420                                 continue;
1421                         }
1422 
1423                         f->f_queue_count++;
1424                         mp->refcnt++;
1425 
1426                         if (dataq_enqueue(&f->f_queue, (void *)mp) == -1) {
1427                                 f->f_queue_count--;
1428                                 mp->refcnt--;
1429                                 (void) pthread_mutex_unlock(&f->filed_mutex);
1430                                 MALLOC_FAIL("dropping message");
1431                                 continue;
1432                         }
1433 
1434                         DPRINT3(5, "logmsg(%u): enqueued msg %p on queue "
1435                             "%p\n", mythreadno, (void *)mp,
1436                             (void *)&f->f_queue);
1437                         (void) pthread_mutex_unlock(&f->filed_mutex);
1438                 }
1439                 refcnt = mp->refcnt;
1440                 (void) pthread_mutex_unlock(&mp->msg_mutex);
1441                 if (refcnt == 0)
1442                         free_msg(mp);
1443         }
1444         /*NOTREACHED*/
1445         return (NULL);
1446 }
1447 
1448 /*
1449  * function to actually write the log message to the selected file.
1450  * each file has a logger thread that runs this routine. The function
1451  * is called with a pointer to its file structure.
1452  */
1453 static void *
1454 logit(void *ap)
1455 {
1456         struct filed *f = ap;
1457         log_message_t *mp;
1458         int forwardingloop = 0;
1459         const char *errmsg = "logit(%u): %s to %s forwarding loop detected\n";
1460         int i, currofst, prevofst, refcnt;
1461         host_list_t *hlp;
1462 
1463         assert(f != NULL);
1464 
1465         DPRINT4(5, "logit(%u): logger started for \"%s\" (queue %p, filed "
1466             "%p)\n", f->f_thread, f->f_un.f_fname, (void *)&f->f_queue,
1467             (void *)f);
1468         _NOTE(COMPETING_THREADS_NOW);
1469 
1470         while (f->f_type != F_UNUSED) {
1471                 (void) dataq_dequeue(&f->f_queue, (void **)&mp, 0);
1472                 DPRINT3(5, "logit(%u): logger dequeued msg %p from queue "
1473                     "%p\n", f->f_thread, (void *)mp, (void *)&f->f_queue);
1474                 (void) pthread_mutex_lock(&f->filed_mutex);
1475                 assert(f->f_queue_count > 0);
1476                 f->f_queue_count--;
1477                 (void) pthread_mutex_unlock(&f->filed_mutex);
1478                 assert(mp->refcnt > 0);
1479 
1480                 /*
1481                  * is it a shutdown message ?
1482                  */
1483                 if (mp->flags & SHUTDOWN) {
1484                         (void) pthread_mutex_lock(&mp->msg_mutex);
1485                         refcnt = --mp->refcnt;
1486                         (void) pthread_mutex_unlock(&mp->msg_mutex);
1487                         if (refcnt == 0)
1488                                 free_msg(mp);
1489                         break;
1490                 }
1491 
1492                 /*
1493                  * Is it a logsync message?
1494                  */
1495                 if ((mp->flags & (FLUSHMSG | LOGSYNC)) ==
1496                     (FLUSHMSG | LOGSYNC)) {
1497                         if (f->f_type != F_FILE)
1498                                 goto out;       /* nothing to do */
1499                         (void) close(f->f_file);
1500                         f->f_file = open64(f->f_un.f_fname,
1501                             O_WRONLY|O_APPEND|O_NOCTTY);
1502                         if (f->f_file < 0) {
1503                                 f->f_type = F_UNUSED;
1504                                 logerror(f->f_un.f_fname);
1505                                 f->f_stat.errs++;
1506                         }
1507                         goto out;
1508                 }
1509 
1510                 /*
1511                  * If the message flags include both flush and sync,
1512                  * then just sync the file out to disk if appropriate.
1513                  */
1514                 if ((mp->flags & (FLUSHMSG | SYNC_FILE)) ==
1515                     (FLUSHMSG | SYNC_FILE)) {
1516                         if (f->f_type == F_FILE) {
1517                                 DPRINT2(5, "logit(%u): got FLUSH|SYNC "
1518                                     "for filed %p\n", f->f_thread,
1519                                     (void *)f);
1520                                 (void) fsync(f->f_file);
1521                         }
1522                         goto out;
1523                 }
1524 
1525                 /*
1526                  * Otherwise if it's a standard flush message, write
1527                  * out any saved messages to the file.
1528                  */
1529                 if ((mp->flags & FLUSHMSG) && (f->f_prevcount > 0)) {
1530                         set_flush_msg(f);
1531                         writemsg(SAVED, f);
1532                         goto out;
1533                 }
1534 
1535                 (void) strlcpy(f->f_current.msg, mp->msg, MAXLINE+1);
1536                 (void) strlcpy(f->f_current.host, mp->hlp->hl_hosts[0],
1537                     SYS_NMLN);
1538                 f->f_current.pri = mp->pri;
1539                 f->f_current.flags = mp->flags;
1540                 f->f_current.time = mp->ts;
1541                 f->f_msgflag &= ~CURRENT_VALID;
1542                 hlp = mp->hlp;
1543 
1544                 prevofst = (f->f_prevmsg.flags & ADDDATE) ? 0 : 16;
1545                 currofst = (f->f_current.flags & ADDDATE) ? 0 : 16;
1546 
1547                 if (f->f_type == F_FORW) {
1548                         /*
1549                          * Should not forward MARK messages, as they are
1550                          * not defined outside of the current system.
1551                          */
1552 
1553                         if (mp->flags & MARK) {
1554                                 DPRINT1(1, "logit(%u): cannot forward "
1555                                     "Mark\n", f->f_thread);
1556                                 goto out;
1557                         }
1558 
1559                         /*
1560                          * can not forward message if we do
1561                          * not have a host to forward to
1562                          */
1563                         if (hlp == (host_list_t *)NULL)
1564                                 goto out;
1565                         /*
1566                          * a forwarding loop is created on machines
1567                          * with multiple interfaces because the
1568                          * network address of the sender is different
1569                          * to the receiver even though it is the
1570                          * same machine. Instead, if the
1571                          * hostname the source and target are
1572                          * the same the message if thrown away
1573                          */
1574                         forwardingloop = 0;
1575                         for (i = 0; i < hlp->hl_cnt; i++) {
1576                                 if (strcmp(hlp->hl_hosts[i],
1577                                     f->f_un.f_forw.f_hname) == 0) {
1578                                         DPRINT3(1, errmsg, f->f_thread,
1579                                             f->f_un.f_forw.f_hname,
1580                                             hlp->hl_hosts[i]);
1581                                         forwardingloop = 1;
1582                                         break;
1583                                 }
1584                         }
1585 
1586                         if (forwardingloop == 1) {
1587                                 f->f_stat.cantfwd++;
1588                                 goto out;
1589                         }
1590                 }
1591 
1592                 f->f_msgflag |= CURRENT_VALID;
1593 
1594                 /* check for dup message */
1595                 if (f->f_type != F_FORW &&
1596                     (f->f_msgflag & OLD_VALID) &&
1597                     prevofst == currofst &&
1598                     (strcmp(f->f_prevmsg.msg + prevofst,
1599                     f->f_current.msg + currofst) == 0) &&
1600                     (strcmp(f->f_prevmsg.host,
1601                     f->f_current.host) == 0)) {
1602                         /* a dup */
1603                         DPRINT2(2, "logit(%u): msg is dup - %p\n",
1604                             f->f_thread, (void *)mp);
1605                         if (currofst == 16) {
1606                                 (void) strncpy(f->f_prevmsg.msg,
1607                                     f->f_current.msg, 15); /* update time */
1608                         }
1609                         f->f_prevcount++;
1610                         f->f_stat.dups++;
1611                         f->f_stat.total++;
1612                         f->f_msgflag &= ~CURRENT_VALID;
1613                 } else {
1614                         /* new: mark or prior dups exist */
1615                         if (f->f_current.flags & MARK || f->f_prevcount > 0) {
1616                                 if (f->f_prevcount > 0 && f->f_type != F_FORW) {
1617                                         set_flush_msg(f);
1618                                         if (f->f_msgflag & OLD_VALID) {
1619                                                 writemsg(SAVED, f);
1620                                         }
1621                                 }
1622                                 if (f->f_msgflag & CURRENT_VALID)
1623                                         writemsg(CURRENT, f);
1624                                 if (!(mp->flags & NOCOPY))
1625                                         copy_msg(f);
1626                                 if (f->f_current.flags & MARK) {
1627                                         DPRINT2(2, "logit(%u): msg is "
1628                                             "mark - %p)\n", f->f_thread,
1629                                             (void *)mp);
1630                                         f->f_msgflag &= ~OLD_VALID;
1631                                 } else {
1632                                         DPRINT2(2, "logit(%u): saving "
1633                                             "message - %p\n", f->f_thread,
1634                                             (void *)mp);
1635                                 }
1636                                 f->f_stat.total++;
1637                         } else { /* new message */
1638                                 DPRINT2(2, "logit(%u): msg is new "
1639                                     "- %p\n", f->f_thread, (void *)mp);
1640                                 writemsg(CURRENT, f);
1641                                 if (!(mp->flags & NOCOPY))
1642                                         copy_msg(f);
1643                                 f->f_stat.total++;
1644                         }
1645                 }
1646                 /*
1647                  * if message refcnt goes to zero after we decrement
1648                  * it here, we are the last consumer of the message,
1649                  * and we should free it.  We need to hold the lock
1650                  * between decrementing the count and checking for
1651                  * zero so another thread doesn't beat us to it.
1652                  */
1653 out:
1654                 (void) pthread_mutex_lock(&mp->msg_mutex);
1655                 refcnt = --mp->refcnt;
1656                 (void) pthread_mutex_unlock(&mp->msg_mutex);
1657                 if (refcnt == 0)
1658                         free_msg(mp);
1659         }
1660         /* register our exit */
1661 
1662         /*
1663          * Pull out all pending messages, if they exist.
1664          */
1665 
1666         (void) pthread_mutex_lock(&f->filed_mutex);
1667 
1668         while (f->f_queue_count > 0) {
1669                 (void) dataq_dequeue(&f->f_queue, (void **)&mp, 0);
1670                 DPRINT3(5, "logit(%u): logger dequeued msg %p from queue "
1671                     "%p\n",
1672                     f->f_thread, (void *)mp, (void *)&f->f_queue);
1673                 (void) pthread_mutex_lock(&mp->msg_mutex);
1674                 refcnt = --mp->refcnt;
1675                 (void) pthread_mutex_unlock(&mp->msg_mutex);
1676                 if (refcnt == 0)
1677                         free_msg(mp);
1678                 f->f_queue_count--;
1679         }
1680 
1681         (void) pthread_mutex_unlock(&f->filed_mutex);
1682 
1683         if (f->f_type != F_USERS && f->f_type != F_WALL &&
1684             f->f_type != F_UNUSED) {
1685                 if (f->f_type == F_FORW)
1686                         (void) t_close(f->f_file);
1687                 else
1688                         (void) close(f->f_file);
1689         }
1690 
1691         /*
1692          * Since f_type may have been changed before this point, we need
1693          * to test orig_type.
1694          */
1695         if (f->f_orig_type == F_FORW) {
1696                 free(f->f_un.f_forw.f_addr.buf);
1697         }
1698 
1699         f->f_type = F_UNUSED;
1700         (void) pthread_mutex_lock(&cft);
1701         --conf_threads;
1702         (void) pthread_mutex_unlock(&cft);
1703         DPRINT1(5, "logit(%u): logging thread exited\n", f->f_thread);
1704         return (NULL);
1705 }
1706 
1707 /*
1708  * change the previous message to a flush message, stating how
1709  * many repeats occurred since the last flush
1710  */
1711 static void
1712 set_flush_msg(struct filed *f)
1713 {
1714         char tbuf[10];
1715         int prevofst = (f->f_prevmsg.flags & ADDDATE) ? 0 : 16;
1716 
1717         if (f->f_prevcount == 1)
1718                 (void) strncpy(tbuf, "time", sizeof (tbuf));
1719         else
1720                 (void) strncpy(tbuf, "times", sizeof (tbuf));
1721 
1722         (void) snprintf(f->f_prevmsg.msg+prevofst,
1723             sizeof (f->f_prevmsg.msg) - prevofst,
1724             "last message repeated %d %s", f->f_prevcount, tbuf);
1725         f->f_prevcount = 0;
1726         f->f_msgflag |= OLD_VALID;
1727 }
1728 
1729 
1730 /*
1731  * the actual writing of the message is broken into a separate function
1732  * because each file has a current and saved message associated with
1733  * it (for duplicate message detection). It is necessary to be able
1734  * to write either the saved message or the current message.
1735  */
1736 static void
1737 writemsg(int selection, struct filed *f)
1738 {
1739         char *cp, *p;
1740         int pri;
1741         int flags;
1742         int l;
1743         time_t ts;
1744         struct t_unitdata ud;
1745         char *eomp, *eomp2, *from, *text, *msg;
1746         char line[MAXLINE*2];
1747         char head[MAXLINE+1];
1748         char tmpbuf[MAXLINE+1];
1749         char cbuf[30];
1750         char *filtered;
1751         char *msgid_start, *msgid_end;
1752         pthread_t mythreadno;
1753         size_t  hlen, filter_len;
1754 
1755         if (Debug) {
1756                 mythreadno = pthread_self();
1757         }
1758 
1759         switch (selection) {
1760         default:
1761         case CURRENT:           /* print current message */
1762                 msg = f->f_current.msg;
1763                 from = f->f_current.host;
1764                 pri = f->f_current.pri;
1765                 flags = f->f_current.flags;
1766                 ts = f->f_current.time;
1767                 f->f_msgflag &= ~CURRENT_VALID;
1768                 break;
1769         case SAVED:             /* print saved message */
1770                 msg = f->f_prevmsg.msg;
1771                 from = f->f_prevmsg.host;
1772                 pri = f->f_prevmsg.pri;
1773                 flags = f->f_prevmsg.flags;
1774                 ts = f->f_prevmsg.time;
1775                 f->f_msgflag &= ~OLD_VALID;
1776                 break;
1777         }
1778 
1779         if (msg[0] == '\0')
1780                 return;
1781 
1782         cp = line;
1783 
1784         if (flags & ADDDATE)
1785                 (void) strncpy(cp, ctime_r(&ts, cbuf) + 4, 15);
1786         else
1787                 (void) strncpy(cp, msg, 15);
1788 
1789         line[15] = '\0';
1790         (void) strcat(cp, " ");
1791         (void) strcat(cp, from);
1792         (void) strcat(cp, " ");
1793         text = cp + strlen(cp);
1794 
1795         if (flags & ADDDATE)
1796                 (void) strcat(cp, msg);
1797         else
1798                 (void) strcat(cp, msg+16);
1799         DPRINT2(5, "writemsg(%u): text = \"%s\"\n", mythreadno, text);
1800 
1801         errno = 0;
1802         t_errno = 0;
1803         switch (f->f_type) {
1804         case F_UNUSED:
1805                 DPRINT1(1, "writemsg(%u): UNUSED\n", mythreadno);
1806                 break;
1807         case F_FORW:
1808                 DPRINT4(1, "writemsg(%u): Logging msg '%s' to %s %s\n",
1809                     mythreadno, msg, TypeNames[f->f_type],
1810                     f->f_un.f_forw.f_hname);
1811 
1812                 hlen = snprintf(head, sizeof (head),
1813                     "<%d>%.15s ", pri, cp);
1814 
1815                 DPRINT2(5, "writemsg(%u): head = \"%s\"\n", mythreadno, head);
1816                 DPRINT2(5, "writemsg(%u): hlen = %d\n", mythreadno, hlen);
1817 
1818                 l = strlen(text);
1819                 p = text;
1820 
1821                 DPRINT2(5, "writemsg(%u): text = \"%s\"\n", mythreadno, text);
1822                 DPRINT2(5, "writemsg(%u): strlen(text) = %d\n", mythreadno, l);
1823 
1824                 (void) strncpy(tmpbuf, head, hlen);
1825 
1826                 while (l > 0) {
1827                         size_t  len;
1828 
1829                         len = copy_frwd(tmpbuf + hlen, sizeof (tmpbuf) - hlen,
1830                             p, l);
1831 
1832                         DPRINT2(5, "writemsg(%u): tmpbuf = \"%s\"\n",
1833                             mythreadno, tmpbuf);
1834                         DPRINT2(5, "writemsg(%u): len = %d\n", mythreadno,
1835                             len);
1836                         DPRINT2(5, "writemsg(%u): strlen(tmpbuf) = %d\n",
1837                             mythreadno, strlen(tmpbuf));
1838 
1839                         ud.opt.buf = NULL;
1840                         ud.opt.len = 0;
1841                         ud.udata.buf = tmpbuf;
1842                         ud.udata.len = len + hlen;
1843                         ud.addr.maxlen = f->f_un.f_forw.f_addr.maxlen;
1844                         ud.addr.buf = f->f_un.f_forw.f_addr.buf;
1845                         ud.addr.len = f->f_un.f_forw.f_addr.len;
1846                         if (t_sndudata(f->f_file, &ud) < 0) {
1847                                 if ((hup_state & HUP_INPROGRESS) &&
1848                                     f->f_type == F_UNUSED) {
1849                                         break;
1850                                 }
1851                                 (void) t_close(f->f_file);
1852                                 f->f_type = F_UNUSED;
1853                                 logerror("t_sndudata");
1854 
1855                                 /*
1856                                  * Since it has already failed, it's not worth
1857                                  * continuing output from the middle of
1858                                  * message string.
1859                                  */
1860                                 break;
1861                         }
1862                         p += len;
1863                         l -= len;
1864                 }
1865                 break;
1866         case F_CONSOLE:
1867         case F_TTY:
1868         case F_FILE:
1869         case F_USERS:
1870         case F_WALL:
1871                 DPRINT4(1, "writemsg(%u): Logging msg '%s' to %s %s\n",
1872                     mythreadno, msg, TypeNames[f->f_type],
1873                     ((f->f_type == F_USERS) || (f->f_type == F_WALL)) ?
1874                     "" : f->f_un.f_fname);
1875                 /*
1876                  * filter the string in preparation for writing it
1877                  * save the original for possible forwarding.
1878                  * In case every byte in cp is a control character,
1879                  * allocates large enough buffer for filtered.
1880                  */
1881 
1882                 filter_len = strlen(cp) * 4 + 1;
1883                 filtered = (char *)malloc(filter_len);
1884                 if (!filtered) {
1885                         MALLOC_FAIL("dropping message");
1886                         /* seems we can just return */
1887                         return;
1888                 }
1889                 DPRINT3(5, "writemsg(%u): "
1890                     "filtered allocated (%p: %d bytes)\n",
1891                     mythreadno, (void *)filtered, filter_len);
1892                 /* -3 : we may add "\r\n" to ecomp(filtered) later */
1893                 filter_string(cp, filtered, filter_len - 3);
1894 
1895                 DPRINT2(5, "writemsg(%u): strlen(filtered) = %d\n",
1896                     mythreadno, strlen(filtered));
1897                 /*
1898                  * If we're writing to the console, strip out the message ID
1899                  * to reduce visual clutter.
1900                  */
1901                 if ((msgid_start = strstr(filtered, "[ID ")) != NULL &&
1902                     (msgid_end = strstr(msgid_start, "] ")) != NULL &&
1903                     f->f_type == F_CONSOLE)
1904                         (void) strcpy(msgid_start, msgid_end + 2);
1905 
1906                 eomp = filtered + strlen(filtered);
1907 
1908                 if ((f->f_type == F_USERS) || (f->f_type == F_WALL)) {
1909                         /* CSTYLED */
1910                         (void) strcat(eomp, "\r\n"); /*lint !e669*/
1911                         /*
1912                          * Since wallmsg messes with utmpx we need
1913                          * to guarantee single threadedness...
1914                          */
1915                         (void) pthread_mutex_lock(&wmp);
1916                         wallmsg(f, from, filtered);
1917                         (void) pthread_mutex_unlock(&wmp);
1918 
1919                         /*
1920                          * The contents of filtered have been copied
1921                          * out to the struct walldev. We should free it here.
1922                          */
1923 
1924                         free(filtered);
1925 
1926                         /* exiting the switch */
1927                         break;
1928                 } else if (f->f_type != F_FILE) {
1929                         /* CSTYLED */
1930                         (void) strncpy(eomp, "\r\n", 3); /*lint !e669*/
1931                 } else {
1932                         if ((eomp2 = strchr(filtered, '\r')) != NULL) {
1933                                 (void) strncpy(eomp2, "\n", 2);
1934                         } else {
1935                                 /* CSTYLED */
1936                                 (void) strncpy(eomp, "\n", 2); /*lint !e669*/
1937                         }
1938                 }
1939                 if (write(f->f_file, filtered, strlen(filtered)) < 0) {
1940                         int e = errno;
1941 
1942                         if ((hup_state & HUP_INPROGRESS) &&
1943                             f->f_type == F_UNUSED) {
1944                                 free(filtered);
1945                                 break;
1946                         }
1947                         (void) close(f->f_file);
1948                         /*
1949                          * Check for EBADF on TTY's due
1950                          * to vhangup() XXX
1951                          */
1952                         if (e == EBADF && f->f_type != F_FILE) {
1953                                 f->f_file = open(f->f_un.f_fname,
1954                                     O_WRONLY|O_APPEND|O_NOCTTY);
1955                                 if (f->f_file < 0) {
1956                                         f->f_type = F_UNUSED;
1957                                         logerror(f->f_un.f_fname);
1958                                         f->f_stat.errs++;
1959                                 }
1960                                 untty();
1961                         } else {
1962                                 f->f_type = F_UNUSED;
1963                                 f->f_stat.errs++;
1964                                 errno = e;
1965                                 logerror(f->f_un.f_fname);
1966                         }
1967                 } else if (flags & SYNC_FILE)
1968                         if (((pri & LOG_FACMASK) >> 3) == LOG_KERN)
1969                                 (void) fsync(f->f_file);
1970 
1971                 DPRINT2(5, "writemsg(%u): freeing filtered (%p)\n",
1972                     mythreadno, (void *)filtered);
1973 
1974                 free(filtered);
1975                 break;
1976         }
1977 }
1978 
1979 /*
1980  *  WALLMSG -- Write a message to the world at large
1981  *
1982  *      Write the specified message to either the entire
1983  *      world, or a list of approved users.
1984  */
1985 static void
1986 wallmsg(struct filed *f, char *from, char *msg)
1987 {
1988         int i;
1989         size_t  len, clen;
1990         char *buf = NULL;
1991         struct utmpx *utxp;
1992         time_t now;
1993         char line[512], dev[100];
1994         char cp[MAXLINE+1];
1995         struct stat statbuf;
1996         walldev_t *w;
1997         char cbuf[30];
1998         pthread_t mythreadno;
1999 
2000         if (Debug) {
2001                 mythreadno = pthread_self();
2002         }
2003 
2004         if (access(UTMPX_FILE, R_OK) != 0 || stat(UTMPX_FILE, &statbuf) != 0) {
2005                 logerror(UTMPX_FILE);
2006                 return;
2007         } else if (statbuf.st_uid != 0 || (statbuf.st_mode & 07777) != 0644) {
2008                 (void) snprintf(line, sizeof (line), "%s %s", UTMPX_FILE,
2009                     "not owned by root or not mode 644.\n"
2010                     "This file must be owned by root "
2011                     "and not writable by\n"
2012                     "anyone other than root.  This alert is being "
2013                     "dropped because of\n"
2014                     "this problem.");
2015                 logerror(line);
2016                 return;
2017         }
2018 
2019         if (f->f_type == F_WALL) {
2020                 (void) time(&now);
2021                 len = snprintf(line, sizeof (line),
2022                     "\r\n\7Message from syslogd@%s "
2023                     "at %.24s ...\r\n", from, ctime_r(&now, cbuf));
2024                 len += strlen(msg + 16);
2025                 buf = (char *)malloc(len + 1);
2026                 if (!buf) {
2027                         MALLOC_FAIL("dropping message");
2028                         return;
2029                 }
2030                 DPRINT3(5, "wallmsg(%u): buf allocated (%p: %d bytes)\n",
2031                     mythreadno, (void *)buf, len + 1);
2032                 (void) strcpy(buf, line);
2033                 (void) strcat(buf, msg + 16);
2034                 clen = copy_frwd(cp, sizeof (cp), buf, len);
2035                 DPRINT2(5, "wallmsg(%u): clen = %d\n",
2036                     mythreadno, clen);
2037                 DPRINT2(5, "wallmsg(%u): freeing buf (%p)\n",
2038                     mythreadno, (void *)buf);
2039                 free(buf);
2040         } else {
2041                 clen = copy_frwd(cp, sizeof (cp), msg, strlen(msg));
2042                 DPRINT2(5, "wallmsg(%u): clen = %d\n",
2043                     mythreadno, clen);
2044         }
2045         /* scan the user login file */
2046         setutxent();
2047         while ((utxp = getutxent()) != NULL) {
2048                 /* is this slot used? */
2049                 if (utxp->ut_name[0] == '\0' ||
2050                     utxp->ut_line[0] == '\0' ||
2051                     utxp->ut_type != USER_PROCESS)
2052                         continue;
2053                 /* should we send the message to this user? */
2054                 if (f->f_type == F_USERS) {
2055                         for (i = 0; i < MAXUNAMES; i++) {
2056                                 if (!f->f_un.f_uname[i][0]) {
2057                                         i = MAXUNAMES;
2058                                         break;
2059                                 }
2060                                 if (strncmp(f->f_un.f_uname[i],
2061                                     utxp->ut_name, UNAMESZ) == 0)
2062                                         break;
2063                         }
2064                         if (i >= MAXUNAMES)
2065                                 continue;
2066                 }
2067 
2068                 /* compute the device name */
2069                 if (utxp->ut_line[0] == '/') {
2070                         (void) strncpy(dev, utxp->ut_line, UDEVSZ);
2071                 } else {
2072                         (void) strcpy(dev, "/dev/");
2073                         (void) strncat(dev, utxp->ut_line, UDEVSZ);
2074                 }
2075                 DPRINT2(1, "wallmsg(%u): write to '%s'\n", mythreadno,
2076                     dev);
2077 
2078                 if ((w = malloc(sizeof (walldev_t))) != NULL) {
2079                         int rc;
2080                         (void) pthread_attr_init(&w->thread_attr);
2081                         (void) pthread_attr_setdetachstate(&w->thread_attr,
2082                             PTHREAD_CREATE_DETACHED);
2083                         (void) strncpy(w->dev, dev, PATH_MAX);
2084                         (void) strncpy(w->msg, cp, MAXLINE+1);
2085                         (void) strncpy(w->ut_name, utxp->ut_name,
2086                             sizeof (w->ut_name));
2087 
2088                         if ((rc = pthread_create(&w->thread, &w->thread_attr,
2089                             writetodev, (void *) w)) != 0) {
2090                                 DPRINT2(5, "wallmsg(%u): wallmsg thread "
2091                                     "create failed rc = %d\n",
2092                                     mythreadno, rc);
2093                                 free(w);
2094                                 break;
2095                         }
2096                 } else {
2097                         MALLOC_FAIL("dropping message to user");
2098                 }
2099         }
2100         /* close the user login file */
2101         endutxent();
2102 }
2103 
2104 /*
2105  * Each time we need to write to a tty device (a potentially expensive
2106  * or long-running operation) this routine gets called as a new
2107  * detached, unbound thread. This allows writes to many devices
2108  * to proceed nearly in parallel, without having to resort to
2109  * asynchronous I/O or forking.
2110  */
2111 static void *
2112 writetodev(void *ap)
2113 {
2114         walldev_t *w = ap;
2115         int ttyf;
2116         int len;
2117         struct stat statb;
2118         struct passwd pw, *pwp;
2119         char pwbuf[MAXLINE];
2120         pthread_t mythreadno;
2121 
2122         if (Debug) {
2123                 mythreadno = pthread_self();
2124         }
2125 
2126         DPRINT1(1, "writetodev(%u): Device writer thread started\n",
2127             mythreadno);
2128 
2129         len = strlen(w->msg);
2130 
2131         ttyf = open(w->dev, O_WRONLY|O_NOCTTY|O_NDELAY);
2132         if (ttyf >= 0) {
2133                 if (fstat(ttyf, &statb) != 0) {
2134                         DPRINT2(1, "writetodev(%u): Can't stat '%s'\n",
2135                             mythreadno, w->dev);
2136                         errno = 0;
2137                         logerror("Can't stat '%s'", w->dev);
2138                 } else if (!(statb.st_mode & S_IWRITE)) {
2139                         DPRINT2(1, "writetodev(%u): Can't write to "
2140                             "'%s'\n", mythreadno, w->dev);
2141                 } else if (!isatty(ttyf)) {
2142                         DPRINT2(1, "writetodev(%u): '%s' not a tty\n",
2143                             mythreadno, w->dev);
2144                         /*
2145                          * We might hit dtremote here. Don't generate
2146                          * error message.
2147                          */
2148                 } else if (getpwuid_r(statb.st_uid, &pw, pwbuf,
2149                     sizeof (pwbuf), &pwp) != 0) {
2150                         DPRINT2(1, "writetodev(%u): Can't determine owner "
2151                             "of '%s'\n", mythreadno, w->dev);
2152                         errno = 0;
2153                         logerror("Can't determine owner of '%s'", w->dev);
2154                 } else if (strncmp(pw.pw_name, w->ut_name, UNAMESZ) != 0) {
2155                         DPRINT2(1, "writetodev(%u): Bad terminal owner '%s'"
2156                             "\n", mythreadno, w->dev);
2157                         errno = 0;
2158                         logerror("%s %s owns '%s' %s %.*s",
2159                             "Bad terminal owner;", pw.pw_name, w->dev,
2160                             "but utmpx says", UNAMESZ, w->ut_name);
2161                 } else if (write(ttyf, w->msg, len) != len) {
2162                         DPRINT2(1, "writetodev(%u): Write failed to "
2163                             "'%s'\n", mythreadno, w->dev);
2164                         errno = 0;
2165                         logerror("Write failed to '%s'", w->dev);
2166                 }
2167 
2168                 DPRINT2(1, "writetodev(%u): write to '%s' succeeded\n",
2169                     mythreadno, w->dev);
2170 
2171                 (void) close(ttyf);
2172         } else {
2173                 DPRINT2(1, "writetodev(%u): Can't open '%s'\n",
2174                     mythreadno, w->dev);
2175         }
2176 
2177         (void) pthread_attr_destroy(&w->thread_attr);
2178         free(w);
2179 
2180         DPRINT1(1, "writetodev(%u): Device writer thread exiting\n",
2181             mythreadno);
2182 
2183         pthread_exit(0);
2184         return (NULL);
2185         /*NOTREACHED*/
2186 }
2187 
2188 /*
2189  * Return a printable representation of a host address. If unable to
2190  * look up hostname, format the numeric address for display instead.
2191  *
2192  * First calls hnc_lookup to see if there is valid cache entry for
2193  * given network address. If it failed, cvthname looks up hostname,
2194  * and push the results into the hostname cache.
2195  */
2196 static host_list_t *
2197 cvthname(struct netbuf *nbp, struct netconfig *ncp, char *failsafe_addr)
2198 {
2199         int i;
2200         host_list_t *h;
2201         struct nd_hostservlist *hsp;
2202         struct nd_hostserv *hspp;
2203         pthread_t mythreadno;
2204         int hindex;
2205         char *uap;
2206 
2207         if (Debug) {
2208                 mythreadno = pthread_self();
2209         }
2210 
2211         if (Debug)
2212                 uap = taddr2uaddr(ncp, nbp);
2213 
2214         DPRINT2(2, "cvthname(%u): looking up hostname for %s\n",
2215             mythreadno, uap ? uap : "<unknown>");
2216 
2217         if ((h = hnc_lookup(nbp, ncp, &hindex)) != NULL) {
2218                 DPRINT4(2, "cvthname(%u): Cache found %p for %s (%s)\n",
2219                     mythreadno, (void *)h, uap ? uap : "<unknown>",
2220                     h->hl_hosts[0]);
2221                 return (h);
2222         }
2223         DPRINT2(2, "cvthname(%u): No cache found for %s\n",
2224             mythreadno, uap ? uap : "<unknown>");
2225 
2226         if (Debug)
2227                 free(uap);
2228 
2229         if (ncp->nc_semantics != NC_TPI_CLTS) {
2230                 return (NULL);
2231         }
2232 
2233         /* memory allocation failure here is fatal */
2234         if ((h = malloc(sizeof (host_list_t))) == NULL) {
2235                 MALLOC_FAIL("host name conversion");
2236                 return (NULL);
2237         }
2238 
2239         if (netdir_getbyaddr(ncp, &hsp, nbp) == 0) {
2240                 if (hsp->h_cnt <= 0) {
2241 out:                    netdir_free((void *)hsp, ND_HOSTSERVLIST);
2242                         free(h);
2243                         return (NULL);
2244                 }
2245 
2246                 hspp = hsp->h_hostservs;
2247                 h->hl_cnt = hsp->h_cnt;
2248                 h->hl_hosts = (char **)malloc(sizeof (char *) * (h->hl_cnt));
2249                 if (h->hl_hosts == NULL) {
2250                         MALLOC_FAIL("host name conversion");
2251                         goto out;
2252                 }
2253 
2254                 DPRINT2(2, "cvthname(%u): Found %d hostnames\n",
2255                     mythreadno, h->hl_cnt);
2256                 for (i = 0; i < h->hl_cnt; i++) {
2257                         h->hl_hosts[i] = (char *)
2258                             malloc(sizeof (char) * (strlen(hspp->h_host) + 1));
2259                         if (h->hl_hosts[i] == NULL) {
2260                                 int j;
2261                                 for (j = 0; j < i; j++) {
2262                                         free(h->hl_hosts[j]);
2263                                 }
2264                                 free(h->hl_hosts);
2265                                 MALLOC_FAIL("host name conversion");
2266                                 goto out;
2267                         }
2268                         (void) strcpy(h->hl_hosts[i], hspp->h_host);
2269                         hspp++;
2270                 }
2271                 netdir_free((void *)hsp, ND_HOSTSERVLIST);
2272         } else { /* unknown address */
2273                 h->hl_cnt = 1;
2274                 h->hl_hosts = (char **)malloc(sizeof (char *));
2275                 if (h->hl_hosts == NULL) {
2276                         free(h);
2277                         MALLOC_FAIL("host name conversion");
2278                         return (NULL);
2279                 }
2280                 h->hl_hosts[0] = (char *)malloc(strlen(failsafe_addr) + 3);
2281                 if (h->hl_hosts[0] == NULL) {
2282                         free(h->hl_hosts);
2283                         free(h);
2284                         MALLOC_FAIL("host name conversion");
2285                         return (NULL);
2286                 }
2287                 /*LINTED*/
2288                 (void) sprintf(h->hl_hosts[0], "[%s]", failsafe_addr);
2289                 DPRINT2(1, "cvthname(%u): Hostname lookup failed "
2290                     "- using address %s instead\n",
2291                     mythreadno, h->hl_hosts[0]);
2292         }
2293 
2294         h->hl_refcnt = 1;
2295         if (pthread_mutex_init(&h->hl_mutex, NULL) != 0) {
2296                 logerror("pthread_mutex_init failed");
2297                 /* This host_list won't be shared by the cache. */
2298                 return (h);
2299         }
2300         hnc_register(nbp, ncp, h, hindex);
2301         DPRINT3(2, "cvthname(%u): returning %p for %s\n",
2302             mythreadno, (void *)h, h->hl_hosts[0]);
2303         return (h);
2304 }
2305 
2306 /*
2307  * Print syslogd errors some place. Need to be careful here, because
2308  * this routine is called at times when we're not initialized and
2309  * ready to log messages...in this case, fall back to using the console.
2310  */
2311 void
2312 logerror(const char *type, ...)
2313 {
2314         char buf[MAXLINE+1];
2315         pthread_t mythreadno;
2316         int flag;
2317         va_list ap;
2318 
2319         if (Debug) {
2320                 mythreadno = pthread_self();
2321         }
2322 
2323         va_start(ap, type);
2324         logerror_format(type, buf, ap);
2325         va_end(ap);
2326         DPRINT2(1, "logerror(%u): %s\n", mythreadno, buf);
2327 
2328         (void) pthread_mutex_lock(&logerror_lock);
2329         if (!interrorlog) {
2330                 flag = 0;
2331                 if (logerror_to_console(1, buf) == 0) {
2332                         /* has written to the console */
2333                         flag = IGN_CONS;
2334                 }
2335                 (void) logmymsg(LOG_SYSLOG|LOG_ERR, buf, ADDDATE|flag, 1);
2336         } else {
2337                 if (logmymsg(LOG_SYSLOG|LOG_ERR, buf, ADDDATE, 0) == -1) {
2338                         (void) logerror_to_console(1, buf);
2339                 }
2340         }
2341         (void) pthread_mutex_unlock(&logerror_lock);
2342 
2343         errno = 0;
2344         t_errno = 0;
2345 }
2346 
2347 static void
2348 logerror_format(const char *type, char *buf, va_list ap)
2349 {
2350         char tmpbuf[MAXLINE + 1];
2351         pthread_t mythreadno;
2352 
2353         if (Debug) {
2354                 mythreadno = pthread_self();
2355         }
2356 
2357         (void) vsnprintf(tmpbuf, MAXLINE, type, ap);
2358 
2359         if (t_errno == 0 || t_errno == TSYSERR) {
2360                 char *errstr;
2361 
2362                 if (errno == 0) {
2363                         (void) snprintf(buf, MAXLINE, "syslogd: %.*s",
2364                             MAXLINE, tmpbuf);
2365                 } else if ((errstr = strerror(errno)) == (char *)NULL) {
2366                         (void) snprintf(buf, MAXLINE, "syslogd: %s: error"
2367                             " %d", tmpbuf, errno);
2368                 } else {
2369                         (void) snprintf(buf, MAXLINE, "syslogd: %s: %s",
2370                             tmpbuf, errstr);
2371                 }
2372         } else {
2373                 if (t_errno > t_nerr) {
2374                         (void) snprintf(buf, MAXLINE, "syslogd: %s:"
2375                             " t_error %d", tmpbuf, t_errno);
2376                 } else {
2377                         (void) snprintf(buf, MAXLINE, "syslogd: %s: %s",
2378                             tmpbuf, t_errlist[t_errno]);
2379                 }
2380         }
2381 
2382         DPRINT2(5, "logerror_format(%u): out %s\n", mythreadno, buf);
2383 }
2384 
2385 static int
2386 logerror_to_console(int nonblock, const char *buf)
2387 {
2388         int cfd, modes;
2389         pthread_t mythreadno;
2390         int ret = 0, len;
2391         char tmpbuf[MAXLINE + 1];
2392 
2393         if (Debug) {
2394                 mythreadno = pthread_self();
2395         }
2396 
2397         DPRINT2(1, "logerror_to_console(%u): %s\n", mythreadno, buf);
2398 
2399         /*
2400          * must use open here instead of fopen, because
2401          * we need the O_NOCTTY behavior - otherwise we
2402          * could hang the console at boot time
2403          */
2404 
2405         modes = (nonblock) ?
2406             O_WRONLY|O_APPEND|O_NOCTTY|O_NONBLOCK :
2407             O_WRONLY|O_APPEND|O_NOCTTY;
2408 
2409         if (((cfd = open(sysmsg, modes)) >= 0) ||
2410             ((cfd = open(ctty, modes)) >= 0)) {
2411                 (void) snprintf(tmpbuf, MAXLINE, "%s\n", buf);
2412                 len = strlen(tmpbuf);
2413                 if (write(cfd, tmpbuf, len) != len) {
2414                         ret = 1;
2415                 }
2416                 (void) close(cfd);
2417         } else {
2418                 ret = 1;
2419 
2420                 /* punt */
2421                 DPRINT1(1, "logerror_console(%u): can't open console\n",
2422                     mythreadno);
2423         }
2424         return (ret);
2425 }
2426 
2427 /*
2428  * copy current message to saved message in filed structure.
2429  */
2430 static void
2431 copy_msg(struct filed *f)
2432 {
2433         (void) strlcpy(f->f_prevmsg.msg, f->f_current.msg, MAXLINE+1);
2434         (void) strlcpy(f->f_prevmsg.host, f->f_current.host, SYS_NMLN);
2435         f->f_prevmsg.pri = f->f_current.pri;
2436         f->f_prevmsg.flags = f->f_current.flags;
2437         f->f_prevmsg.time = f->f_current.time;
2438         f->f_msgflag |= OLD_VALID;
2439 }
2440 
2441 
2442 /*
2443  * function to free a host_list_t struct that was allocated
2444  * out of cvthname(). There is a special case where we don't
2445  * free the hostname list in LocalHostName, because that's
2446  * our own addresses, and we just want to have to look it
2447  * up once and save it.  Also don't free it if it's
2448  * NullHostName, because that's a special one we use if
2449  * name service lookup fails.
2450  *
2451  * By having hostname cache, now host_list_t will be shared
2452  * by messages and hostname cache. hl_refcnt is used for
2453  * the purpose.
2454  */
2455 static void
2456 freehl(host_list_t *h)
2457 {
2458         int i, refcnt;
2459         pthread_t mythreadno;
2460 
2461         if (Debug) {
2462                 mythreadno = pthread_self();
2463         }
2464 
2465         DPRINT2(2, "freehl(%u): releasing %p\n", mythreadno, (void *)h);
2466 
2467         if (h == NULL || h == &LocalHostName || h == &NullHostName) {
2468                 return;
2469         }
2470 
2471         (void) pthread_mutex_lock(&h->hl_mutex);
2472         refcnt = --h->hl_refcnt;
2473         (void) pthread_mutex_unlock(&h->hl_mutex);
2474 
2475         if (refcnt != 0) {
2476                 DPRINT3(5, "freehl(%u): %p has reference %d\n",
2477                     mythreadno, (void *)h, refcnt);
2478                 return;
2479         }
2480 
2481         (void) pthread_mutex_destroy(&h->hl_mutex);
2482 
2483         DPRINT2(5, "freehl(%u): freeing %p\n", mythreadno, (void *)h);
2484 
2485         for (i = 0; i < h->hl_cnt; i++) {
2486                 free(h->hl_hosts[i]);
2487         }
2488 
2489         free(h->hl_hosts);
2490         free(h);
2491 }
2492 
2493 /*
2494  * Create the door file and the pid file in /var/run.  If the filesystem
2495  * containing /etc is writable, create symlinks /etc/.syslog_door and
2496  * /etc/syslog.pid to them.  On systems that do not support /var/run, create
2497  * /etc/.syslog_door and /etc/syslog.pid directly.
2498  *
2499  * Note: it is not considered fatal to fail to create the pid file or its
2500  * symlink.  Attempts to use them in the usual way will fail, of course, but
2501  * syslogd will function nicely without it (not so for the door file).
2502  */
2503 
2504 static void
2505 open_door(void)
2506 {
2507         struct stat buf;
2508         door_info_t info;
2509         char line[MAXLINE+1];
2510         pthread_t mythreadno;
2511         int err;
2512 
2513         if (Debug) {
2514                 mythreadno = pthread_self();
2515         }
2516 
2517         /*
2518          * first see if another syslogd is running by trying
2519          * a door call - if it succeeds, there is already
2520          * a syslogd process active
2521          */
2522 
2523         if (!DoorCreated) {
2524                 int door;
2525 
2526                 if ((door = open(DoorFileName, O_RDONLY)) >= 0) {
2527                         DPRINT2(5, "open_door(%u): %s opened "
2528                             "successfully\n", mythreadno, DoorFileName);
2529 
2530                         if (door_info(door, &info) >= 0) {
2531                                 DPRINT2(5, "open_door(%u): "
2532                                     "door_info:info.di_target = %ld\n",
2533                                     mythreadno, info.di_target);
2534 
2535                                 if (info.di_target > 0) {
2536                                         (void) sprintf(line, "syslogd pid %ld"
2537                                             " already running. Cannot "
2538                                             "start another syslogd pid %ld",
2539                                             info.di_target, getpid());
2540                                         DPRINT2(5, "open_door(%u): error: "
2541                                             "%s\n", mythreadno, line);
2542                                         errno = 0;
2543                                         logerror(line);
2544                                         exit(1);
2545                                 }
2546                         }
2547 
2548                         (void) close(door);
2549                 } else {
2550                         if (lstat(DoorFileName, &buf) < 0) {
2551                                 err = errno;
2552 
2553                                 DPRINT3(5, "open_door(%u): lstat() of %s "
2554                                     "failed, errno=%d\n",
2555                                     mythreadno, DoorFileName, err);
2556 
2557                                 if ((door = creat(DoorFileName, 0644)) < 0) {
2558                                         err = errno;
2559                                         (void) snprintf(line, sizeof (line),
2560                                             "creat() of %s failed - fatal",
2561                                             DoorFileName);
2562                                         DPRINT3(1, "open_door(%u): error: %s, "
2563                                             "errno=%d\n", mythreadno, line,
2564                                             err);
2565                                         errno = err;
2566                                         logerror(line);
2567                                         delete_doorfiles();
2568                                         exit(1);
2569                                 }
2570 
2571                                 (void) fchmod(door,
2572                                     S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH);
2573 
2574                                 DPRINT2(5, "open_door(%u): creat() of %s "
2575                                     "succeeded\n", mythreadno,
2576                                     DoorFileName);
2577 
2578                                 (void) close(door);
2579                         }
2580                 }
2581 
2582                 if (strcmp(DoorFileName, DOORFILE) == 0) {
2583                         if (lstat(OLD_DOORFILE, &buf) == 0) {
2584                                 DPRINT2(5, "open_door(%u): lstat() of %s "
2585                                     "succeeded\n", mythreadno,
2586                                     OLD_DOORFILE);
2587 
2588                                 if (S_ISDIR(buf.st_mode)) {
2589                                         (void) snprintf(line, sizeof (line),
2590                                             "%s is a directory - fatal",
2591                                             OLD_DOORFILE);
2592                                         DPRINT2(1, "open_door(%u): error: "
2593                                             "%s\n", mythreadno, line);
2594                                         errno = 0;
2595                                         logerror(line);
2596                                         delete_doorfiles();
2597                                         exit(1);
2598                                 }
2599 
2600                                 DPRINT2(5, "open_door(%u): %s is not a "
2601                                     "directory\n",
2602                                     mythreadno, OLD_DOORFILE);
2603 
2604                                 if (unlink(OLD_DOORFILE) < 0) {
2605                                         err = errno;
2606                                         (void) snprintf(line, sizeof (line),
2607                                             "unlink() of %s failed",
2608                                             OLD_DOORFILE);
2609                                         DPRINT2(5, "open_door(%u): %s\n",
2610                                             mythreadno, line);
2611 
2612                                         if (err != EROFS) {
2613                                                 DPRINT3(1, "open_door(%u): "
2614                                                     "error: %s, "
2615                                                     "errno=%d\n",
2616                                                     mythreadno, line, err);
2617                                                 (void) strcat(line, " - fatal");
2618                                                 errno = err;
2619                                                 logerror(line);
2620                                                 delete_doorfiles();
2621                                                 exit(1);
2622                                         }
2623 
2624                                         DPRINT1(5, "open_door(%u): unlink "
2625                                             "failure OK on RO file "
2626                                             "system\n", mythreadno);
2627                                 }
2628                         } else {
2629                                 DPRINT2(5, "open_door(%u): file %s doesn't "
2630                                     "exist\n", mythreadno, OLD_DOORFILE);
2631                         }
2632 
2633                         if (symlink(RELATIVE_DOORFILE, OLD_DOORFILE) < 0) {
2634                                 err = errno;
2635                                 (void) snprintf(line, sizeof (line),
2636                                     "symlink %s -> %s failed", OLD_DOORFILE,
2637                                     RELATIVE_DOORFILE);
2638                                 DPRINT2(5, "open_door(%u): %s\n", mythreadno,
2639                                     line);
2640 
2641                                 if (err != EROFS) {
2642                                         DPRINT3(1, "open_door(%u): error: %s, "
2643                                             "errno=%d\n", mythreadno, line,
2644                                             err);
2645                                         errno = err;
2646                                         (void) strcat(line, " - fatal");
2647                                         logerror(line);
2648                                         delete_doorfiles();
2649                                         exit(1);
2650                                 }
2651 
2652                                 DPRINT1(5, "open_door(%u): symlink failure OK "
2653                                     "on RO file system\n", mythreadno);
2654                         } else {
2655                                 DPRINT3(5, "open_door(%u): symlink %s -> %s "
2656                                     "succeeded\n", mythreadno,
2657                                     OLD_DOORFILE, RELATIVE_DOORFILE);
2658                         }
2659                 }
2660 
2661                 if ((DoorFd = door_create(server, 0,
2662                     DOOR_REFUSE_DESC | DOOR_NO_CANCEL)) < 0) {
2663                         err = errno;
2664                         (void) sprintf(line, "door_create() failed - fatal");
2665                         DPRINT3(1, "open_door(%u): error: %s, errno=%d\n",
2666                             mythreadno, line, err);
2667                         errno = err;
2668                         logerror(line);
2669                         delete_doorfiles();
2670                         exit(1);
2671                 }
2672                 (void) door_setparam(DoorFd, DOOR_PARAM_DATA_MAX, 0);
2673                 DPRINT2(5, "open_door(%u): door_create() succeeded, "
2674                     "DoorFd=%d\n", mythreadno, DoorFd);
2675 
2676                 DoorCreated = 1;
2677         }
2678 
2679         (void) fdetach(DoorFileName);   /* just in case... */
2680 
2681         (void) door_server_create(door_server_pool);
2682 
2683         if (fattach(DoorFd, DoorFileName) < 0) {
2684                 err = errno;
2685                 (void) snprintf(line, sizeof (line), "fattach() of fd"
2686                     " %d to %s failed - fatal", DoorFd, DoorFileName);
2687                 DPRINT3(1, "open_door(%u): error: %s, errno=%d\n", mythreadno,
2688                     line, err);
2689                 errno = err;
2690                 logerror(line);
2691                 delete_doorfiles();
2692                 exit(1);
2693         }
2694 
2695         DPRINT2(5, "open_door(%u): attached server() to %s\n", mythreadno,
2696             DoorFileName);
2697 
2698         /*
2699          * create pidfile anyway, so those using it to control
2700          * syslogd (with kill `cat /etc/syslog.pid` perhaps)
2701          * don't get broken.
2702          */
2703 
2704         if (!PidfileCreated) {
2705                 int pidfd;
2706 
2707                 PidfileCreated = 1;
2708 
2709                 if ((pidfd = open(PidFileName, O_RDWR|O_CREAT|O_TRUNC, 0644))
2710                     < 0) {
2711                         err = errno;
2712                         (void) snprintf(line, sizeof (line),
2713                             "open() of %s failed", PidFileName);
2714                         DPRINT3(1, "open_door(%u): warning: %s, errno=%d\n",
2715                             mythreadno, line, err);
2716                         errno = err;
2717                         logerror(line);
2718                         return;
2719                 }
2720 
2721                 (void) fchmod(pidfd, S_IRUSR|S_IWUSR|S_IRGRP|S_IROTH);
2722                 (void) sprintf(line, "%ld\n", getpid());
2723 
2724                 if (write(pidfd, line, strlen(line)) < 0) {
2725                         err = errno;
2726                         (void) snprintf(line, sizeof (line),
2727                             "write to %s on fd %d failed", PidFileName, pidfd);
2728                         DPRINT3(1, "open_door(%u): warning: %s, errno=%d\n",
2729                             mythreadno, line, err);
2730                         errno = err;
2731                         logerror(line);
2732                         return;
2733                 }
2734 
2735                 (void) close(pidfd);
2736 
2737                 DPRINT2(5, "open_door(%u): %s created\n",
2738                     mythreadno, PidFileName);
2739 
2740                 if (strcmp(PidFileName, PIDFILE) == 0) {
2741                         if (lstat(OLD_PIDFILE, &buf) == 0) {
2742                                 DPRINT2(5, "open_door(%u): lstat() of %s "
2743                                     "succeded\n", mythreadno, OLD_PIDFILE);
2744 
2745                                 if (S_ISDIR(buf.st_mode)) {
2746                                         (void) snprintf(line, sizeof (line),
2747                                             "file %s is a directory",
2748                                             OLD_PIDFILE);
2749                                         DPRINT2(1, "open_door(%u): warning: "
2750                                             "%s\n", mythreadno, line);
2751                                         errno = 0;
2752                                         logerror(line);
2753                                         return;
2754                                 }
2755 
2756                                 if (unlink(OLD_PIDFILE) < 0) {
2757                                         err = errno;
2758                                         (void) snprintf(line, sizeof (line),
2759                                             "unlink() of %s failed",
2760                                             OLD_PIDFILE);
2761                                         DPRINT2(5, "open_door(%u): %s\n",
2762                                             mythreadno, line);
2763 
2764                                         if (err != EROFS) {
2765                                                 DPRINT3(1, "open_door (%u): "
2766                                                     "warning: %s, "
2767                                                     "errno=%d\n",
2768                                                     mythreadno, line, err);
2769                                                 errno = err;
2770                                                 logerror(line);
2771                                                 return;
2772                                         }
2773 
2774                                         DPRINT1(5, "open_door(%u): unlink "
2775                                             "failure OK on RO file "
2776                                             "system\n", mythreadno);
2777                                 }
2778                         } else {
2779                                 DPRINT2(5, "open_door(%u): file %s doesn't "
2780                                     "exist\n", mythreadno, OLD_PIDFILE);
2781                         }
2782 
2783                         if (symlink(RELATIVE_PIDFILE, OLD_PIDFILE) < 0) {
2784                                 err = errno;
2785                                 (void) snprintf(line, sizeof (line),
2786                                     "symlink %s -> %s failed", OLD_PIDFILE,
2787                                     RELATIVE_PIDFILE);
2788                                 DPRINT2(5, "open_door(%u): %s\n", mythreadno,
2789                                     line);
2790 
2791                                 if (err != EROFS) {
2792                                         DPRINT3(1, "open_door(%u): warning: "
2793                                             "%s, errno=%d\n", mythreadno,
2794                                             line, err);
2795                                         errno = err;
2796                                         logerror(line);
2797                                         return;
2798                                 }
2799 
2800                                 DPRINT1(5, "open_door(%u): symlink failure OK "
2801                                     "on RO file system\n", mythreadno);
2802                                 return;
2803                         }
2804 
2805                         DPRINT3(5, "open_door(%u): symlink %s -> %s "
2806                             "succeeded\n", mythreadno, OLD_PIDFILE,
2807                             RELATIVE_PIDFILE);
2808                 }
2809         }
2810 }
2811 
2812 /*
2813  * the 'server' function that we export via the door. It does
2814  * nothing but return.
2815  */
2816 /*ARGSUSED*/
2817 static void
2818 server(void *cookie, char *argp, size_t arg_size,
2819     door_desc_t *dp, uint_t n)
2820 {
2821         (void) door_return(NULL, 0, NULL, 0);
2822         /* NOTREACHED */
2823 }
2824 
2825 /*ARGSUSED*/
2826 static void *
2827 create_door_thr(void *arg)
2828 {
2829         (void) pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
2830         (void) door_return(NULL, 0, NULL, 0);
2831 
2832         /*
2833          * If there is an error in door_return(), it will return here and
2834          * the thread will exit. Hence we need to decrement door_server_cnt.
2835          */
2836         (void) pthread_mutex_lock(&door_server_cnt_lock);
2837         door_server_cnt--;
2838         (void) pthread_mutex_unlock(&door_server_cnt_lock);
2839         return (NULL);
2840 }
2841 
2842 /*
2843  * Max number of door server threads for syslogd. Since door is used
2844  * to check the health of syslogd, we don't need large number of
2845  * server threads.
2846  */
2847 #define MAX_DOOR_SERVER_THR     3
2848 
2849 /*
2850  * Manage door server thread pool.
2851  */
2852 /*ARGSUSED*/
2853 static void
2854 door_server_pool(door_info_t *dip)
2855 {
2856         (void) pthread_mutex_lock(&door_server_cnt_lock);
2857         if (door_server_cnt <= MAX_DOOR_SERVER_THR &&
2858             pthread_create(NULL, &door_thr_attr, create_door_thr, NULL) == 0) {
2859                 door_server_cnt++;
2860                 (void) pthread_mutex_unlock(&door_server_cnt_lock);
2861                 return;
2862         }
2863 
2864         (void) pthread_mutex_unlock(&door_server_cnt_lock);
2865 }
2866 
2867 /*
2868  * checkm4 - used to verify that the external utilities that
2869  * syslogd depends on are where we expect them to be.
2870  * Returns 0 if all utilities are found, > 0 if any are missing.
2871  * Also logs errors so user knows what's missing
2872  */
2873 static int
2874 checkm4(void)
2875 {
2876         int notfound = 0;
2877         int saverrno;
2878         pthread_t mythreadno;
2879 
2880         if (Debug) {
2881                 mythreadno = pthread_self();
2882         }
2883 
2884         if (access("/usr/ccs/bin/m4", X_OK) < 0) {
2885                 saverrno = errno;
2886                 logerror("/usr/ccs/bin/m4");
2887                 DPRINT2(1, "checkm4(%u): /usr/ccs/bin/m4 - access "
2888                     "returned %d\n", mythreadno, saverrno);
2889                 notfound++;
2890         }
2891 
2892         return (notfound);
2893 }
2894 
2895 /*
2896  *  INIT -- Initialize syslogd from configuration table, start up
2897  *  input and logger threads. This routine is called only once.
2898  */
2899 static void
2900 init(void)
2901 {
2902         struct utsname *up;
2903         pthread_attr_t sys_attr, net_attr, log_attr, hnl_attr;
2904         int nthread;
2905         pthread_t mythreadno;
2906 
2907         if (Debug) {
2908                 mythreadno = pthread_self();
2909         }
2910 
2911         DPRINT1(2, "init(%u): initializing\n", mythreadno);
2912 
2913         /* hand-craft a host_list_t entry for our local host name */
2914         if ((up = malloc(sizeof (struct utsname))) == NULL) {
2915                 MALLOC_FAIL_EXIT;
2916         }
2917         (void) uname(up);
2918         LocalHostName.hl_cnt = 1;
2919         if ((LocalHostName.hl_hosts = malloc(sizeof (char *))) == NULL) {
2920                 MALLOC_FAIL_EXIT;
2921         }
2922         if ((LocalHostName.hl_hosts[0] = strdup(up->nodename)) == NULL) {
2923                 free(LocalHostName.hl_hosts);
2924                 MALLOC_FAIL_EXIT;
2925         }
2926         free(up);
2927         /* also hand craft one for use if name resolution fails */
2928         NullHostName.hl_cnt = 1;
2929         if ((NullHostName.hl_hosts = malloc(sizeof (char *))) == NULL) {
2930                 MALLOC_FAIL_EXIT;
2931         }
2932         if ((NullHostName.hl_hosts[0] = strdup("name lookup failed")) == NULL) {
2933                 MALLOC_FAIL_EXIT;
2934         }
2935 
2936         hnc_init(0);
2937 
2938         /*
2939          * Note that getnets will allocate network resources, but won't be
2940          * binding UDP port. This is because, there could be a race
2941          * condition between door. If we bind here, one syslogd could grab
2942          * UDP port first, but later another syslogd could take over without
2943          * getting UDP port but grab the door file. The 2nd syslogd could
2944          * continue to run without listening network.
2945          * bindnet() will be called after door was successfully opened.
2946          */
2947         getnets();
2948 
2949         /*
2950          * Start up configured theads
2951          */
2952         conf_init();
2953 
2954         /*
2955          * allocate thread stacks for the persistant threads
2956          */
2957         nthread = (turnoff == 0) ? 4 : 2;
2958 
2959         if ((stack_ptr = alloc_stacks(nthread)) == NULL) {
2960                 logerror("alloc_stacks failed - fatal");
2961                 exit(1);
2962         }
2963 
2964         if (Debug) {
2965                 dumpstats(STDOUT_FILENO);
2966         }
2967 
2968         (void) dataq_init(&inputq); /* init the input queue */
2969 
2970         if (pthread_attr_init(&sys_attr) != 0 ||
2971             pthread_attr_init(&log_attr) != 0 ||
2972             pthread_attr_init(&net_attr) != 0 ||
2973             pthread_attr_init(&hnl_attr) != 0 ||
2974             pthread_attr_init(&door_thr_attr) != 0) {
2975                 logerror("pthread_attr_init failed - fatal");
2976                 exit(1);
2977         }
2978 
2979         (void) pthread_attr_setscope(&sys_attr, PTHREAD_SCOPE_PROCESS);
2980         (void) pthread_attr_setscope(&log_attr, PTHREAD_SCOPE_PROCESS);
2981         (void) pthread_attr_setscope(&net_attr, PTHREAD_SCOPE_PROCESS);
2982         (void) pthread_attr_setscope(&hnl_attr, PTHREAD_SCOPE_PROCESS);
2983         (void) pthread_attr_setscope(&door_thr_attr, PTHREAD_SCOPE_SYSTEM);
2984         (void) pthread_attr_setdetachstate(&door_thr_attr,
2985             PTHREAD_CREATE_DETACHED);
2986 
2987         /* 1: logmsg thread */
2988         (void) pthread_attr_setstacksize(&log_attr, stacksize);
2989         (void) pthread_attr_setstackaddr(&log_attr, stack_ptr);
2990         stack_ptr += stacksize + redzonesize;
2991         if (pthread_create(&log_thread, &log_attr, logmsg, NULL) != 0) {
2992                 logerror("pthread_create failed - fatal");
2993                 exit(1);
2994         }
2995 
2996         /*
2997          * open the log device, and pull up all pending message
2998          * from the log driver.
2999          */
3000         prepare_sys_poll();
3001 
3002         /*
3003          * Now we can deliver the pending internal error messages.
3004          */
3005         enable_errorlog();
3006 
3007         /* 2: sys_poll thread */
3008         (void) pthread_attr_setstacksize(&sys_attr, stacksize);
3009         (void) pthread_attr_setstackaddr(&sys_attr, stack_ptr);
3010         stack_ptr += stacksize + redzonesize;
3011         if (pthread_create(&sys_thread, &sys_attr, sys_poll, NULL) != 0) {
3012                 logerror("pthread_create failed - fatal");
3013                 exit(1);
3014         }
3015 
3016         /*
3017          * We've started the sys_poll() and logmsg() threads.  Now we are ready
3018          * to open the door.  This cannot happen before spawning sys_poll(),
3019          * because after opening the door, syslog() will no longer take care of
3020          * LOG_CONS.  Therefor, we should pull up all pending log messages and
3021          * activate sys_poll() before opening the door, so that log driver
3022          * won't drop messages.
3023          */
3024         open_door();
3025 
3026         DPRINT1(1, "init(%u): accepting messages from local system\n",
3027             mythreadno);
3028 
3029         if (turnoff == 0) {
3030                 /* init the hostname lookup queue */
3031                 (void) dataq_init(&hnlq);
3032 
3033                 /* 3: hostname lookup thread */
3034                 (void) pthread_attr_setstacksize(&hnl_attr, stacksize);
3035                 (void) pthread_attr_setstackaddr(&hnl_attr, stack_ptr);
3036                 stack_ptr += stacksize + redzonesize;
3037                 if (pthread_create(&hnl_thread, &hnl_attr,
3038                     hostname_lookup, NULL) != 0) {
3039                         logerror("pthread_create failed - fatal");
3040                         exit(1);
3041                 }
3042 
3043                 /* 4: net_poll thread */
3044                 (void) pthread_attr_setstacksize(&net_attr, stacksize);
3045                 (void) pthread_attr_setstackaddr(&net_attr, stack_ptr);
3046                 stack_ptr += stacksize + redzonesize;
3047 
3048                 /* grab UDP port */
3049                 bindnet();
3050 
3051                 if (pthread_create(&net_thread, &net_attr, net_poll,
3052                     NULL) != 0) {
3053                         logerror("pthread_create failed - fatal");
3054                         exit(1);
3055                 }
3056                 DPRINT1(1, "init(%u): accepting messages from remote\n",
3057                     mythreadno);
3058         }
3059 
3060         (void) pthread_attr_destroy(&sys_attr);
3061         (void) pthread_attr_destroy(&net_attr);
3062         (void) pthread_attr_destroy(&log_attr);
3063         (void) pthread_attr_destroy(&hnl_attr);
3064 
3065         curalarm = MarkInterval * 60 / MARKCOUNT;
3066         (void) alarm((unsigned)curalarm);
3067         DPRINT2(2, "init(%u): Next alarm in %d seconds\n",
3068             mythreadno, curalarm);
3069         DPRINT1(1, "init(%u): syslogd: started\n", mythreadno);
3070 }
3071 
3072 /*
3073  * will print a bunch of debugging stats on 'fd'
3074  */
3075 static void
3076 dumpstats(int fd)
3077 {
3078         FILE *out;
3079         struct filed *f;
3080         int i;
3081         char users[1024];
3082         char cbuf[30];
3083         char *dashes = "------------------------";
3084         static int conversion_printed;
3085 
3086         if ((out = fdopen(fd, "w+")) == NULL)
3087                 return;
3088 
3089         (void) fprintf(out, "\nSyslogd started: %s",
3090             ctime_r(&start_time, cbuf));
3091         (void) fprintf(out, "Input message count: system %d, network %d\n",
3092             sys_msg_count, net_msg_count);
3093         (void) fprintf(out, "# Outputs: %d\n\n", nlogs);
3094 
3095         (void) fprintf(out, "%s priority = [file, facility] %s\n\n",
3096             dashes, dashes);
3097 
3098         for (i = 0; i < LOG_NFACILITIES + 1; i++) {
3099                 (void) fprintf(out, "%d ", i / 10);
3100         }
3101         (void) fprintf(out, "\n");
3102         for (i = 0; i < LOG_NFACILITIES + 1; i++) {
3103                 (void) fprintf(out, "%d ", i % 10);
3104         }
3105         (void) fprintf(out, "\n");
3106         for (i = 0; i < LOG_NFACILITIES + 1; i++) {
3107                 (void) fprintf(out, "--");
3108         }
3109         (void) fprintf(out, "\n");
3110 
3111         for (f = Files; f < &Files[nlogs]; f++) {
3112                 for (i = 0; i < LOG_NFACILITIES + 1; i++) {
3113                         if (f->f_pmask[i] == NOPRI)
3114                                 (void) fprintf(out, "X ");
3115                         else
3116                                 (void) fprintf(out, "%d ",
3117                                     f->f_pmask[i]);
3118                 }
3119                 (void) fprintf(out, "%s: ", TypeNames[f->f_type]);
3120                 switch (f->f_type) {
3121                 case F_FILE:
3122                 case F_TTY:
3123                 case F_CONSOLE:
3124                         (void) fprintf(out, "%s", f->f_un.f_fname);
3125                         break;
3126                 case F_FORW:
3127                         (void) fprintf(out, "%s", f->f_un.f_forw.f_hname);
3128                         break;
3129                 case F_USERS:
3130                         for (i = 0; i < MAXUNAMES &&
3131                             *f->f_un.f_uname[i]; i++) {
3132                                 if (!i)
3133                                         (void) fprintf(out, "%s",
3134                                             f->f_un.f_uname[i]);
3135                                 else
3136                                         (void) fprintf(out, ", %s",
3137                                             f->f_un.f_uname[i]);
3138                         }
3139                         break;
3140                 }
3141                 (void) fprintf(out, "\n");
3142         }
3143 
3144         if (!conversion_printed) {
3145                 (void) fprintf(out, "\nFacilities:\n");
3146 
3147                 for (i = 0; FacNames[i].c_val != -1; i++) {
3148                         (void) fprintf(out, "  [%02d] %s: %3d\n", i,
3149                             FacNames[i].c_name, FacNames[i].c_val);
3150                 }
3151 
3152                 (void) fprintf(out, "\nPriorities:\n");
3153 
3154                 for (i = 0; PriNames[i].c_val != -1; i++) {
3155                         (void) fprintf(out, "  [%02d] %s: %3d\n", i,
3156                             PriNames[i].c_name, PriNames[i].c_val);
3157                 }
3158 
3159                 conversion_printed = 1;
3160         }
3161 
3162         (void) fprintf(out, "\n\n\n\t\tPer File Statistics\n");
3163         (void) fprintf(out, "%-24s\tTot\tDups\tNofwd\tErrs\n", "File");
3164         (void) fprintf(out, "%-24s\t---\t----\t-----\t----\n", "----");
3165         for (f = Files; f < &Files[nlogs]; f++) {
3166                 switch (f->f_type) {
3167                 case F_FILE:
3168                 case F_TTY:
3169                 case F_CONSOLE:
3170                         (void) fprintf(out, "%-24s", f->f_un.f_fname);
3171                         break;
3172                 case F_WALL:
3173                         (void) fprintf(out, "%-24s", TypeNames[f->f_type]);
3174                         break;
3175                 case F_FORW:
3176                         (void) fprintf(out, "%-24s", f->f_un.f_forw.f_hname);
3177                         break;
3178                 case F_USERS:
3179                         for (i = 0; i < MAXUNAMES &&
3180                             *f->f_un.f_uname[i]; i++) {
3181                                 if (!i)
3182                                         (void) strcpy(users,
3183                                             f->f_un.f_uname[i]);
3184                                 else {
3185                                         (void) strcat(users, ",");
3186                                         (void) strcat(users,
3187                                             f->f_un.f_uname[i]);
3188                                 }
3189                         }
3190                         (void) fprintf(out, "%-24s", users);
3191                         break;
3192                 }
3193                 (void) fprintf(out, "\t%d\t%d\t%d\t%d\n",
3194                     f->f_stat.total, f->f_stat.dups,
3195                     f->f_stat.cantfwd, f->f_stat.errs);
3196         }
3197         (void) fprintf(out, "\n\n");
3198         if (Debug && fd == 1)
3199                 return;
3200         (void) fclose(out);
3201 }
3202 
3203 /*
3204  * conf_init - This routine is code seperated from the
3205  * init routine in order to be re-callable when we get
3206  * a SIGHUP signal.
3207  */
3208 static void
3209 conf_init(void)
3210 {
3211         char *p;
3212         int i;
3213         struct filed *f;
3214         char *m4argv[4];
3215         int m4argc = 0;
3216         conf_t cf;
3217         pthread_t mythreadno;
3218 
3219         if (Debug) {
3220                 mythreadno = pthread_self();
3221         }
3222 
3223         DPRINT1(2, "conf_init(%u): starting logger threads\n",
3224             mythreadno);
3225 
3226         m4argv[m4argc++] = "m4";
3227 
3228         if (amiloghost() == 1) {
3229                 DPRINT1(1, "conf_init(%u): I am loghost\n", mythreadno);
3230                 m4argv[m4argc++] = "-DLOGHOST=1";
3231         }
3232 
3233         m4argv[m4argc++] = ConfFile;
3234         m4argv[m4argc] = NULL;
3235 
3236         /*
3237          * Make sure the configuration file and m4 exist, and then parse
3238          * the configuration file with m4.  If any of these fail, resort
3239          * to our hardcoded fallback configuration.
3240          */
3241 
3242         if (access(ConfFile, R_OK) == -1) {
3243                 DPRINT2(1, "conf_init(%u): %s does not exist\n", mythreadno,
3244                     ConfFile);
3245                 logerror("can't open configuration file");
3246                 /* CSTYLED */
3247                 Files = (struct filed *) &fallback; /*lint !e545 */
3248                 cfline("*.ERR\t/dev/sysmsg", 0, &Files[0]);
3249                 cfline("*.PANIC\t*", 0, &Files[1]);
3250                 nlogs = 2;
3251                 goto nofile;
3252         }
3253 
3254         if (checkm4() != 0 || conf_open(&cf, "/usr/ccs/bin/m4", m4argv) == -1) {
3255                 DPRINT2(1, "conf_init(%u): cannot open %s\n", mythreadno,
3256                     ConfFile);
3257                 /* CSTYLED */
3258                 Files = (struct filed *) &fallback; /*lint !e545 */
3259                 cfline("*.ERR\t/dev/sysmsg", 0, &Files[0]);
3260                 cfline("*.PANIC\t*", 0, &Files[1]);
3261                 nlogs = 2;
3262                 goto nofile;
3263         }
3264 
3265         /* Count the number of lines which are not blanks or comments */
3266         nlogs = 0;
3267         while ((p = conf_read(&cf)) != NULL) {
3268                 if (p[0] != '\0' && p[0] != '#')
3269                         nlogs++;
3270         }
3271 
3272         Files = (struct filed *)malloc(sizeof (struct filed) * nlogs);
3273 
3274         if (!Files) {
3275                 DPRINT1(1, "conf_init(%u): malloc failed - can't "
3276                     "allocate 'Files' array\n", mythreadno);
3277                 MALLOC_FAIL("loading minimum configuration");
3278                 /* CSTYLED */
3279                 Files = (struct filed *) &fallback; /*lint !e545 */
3280                 cfline("*.ERR\t/dev/sysmsg", 0, &Files[0]);
3281                 cfline("*.PANIC\t*", 0, &Files[1]);
3282                 nlogs = 2;
3283                 conf_close(&cf);
3284                 goto nofile;
3285         }
3286 
3287         /*
3288          *  Foreach line in the conf table, open that file.
3289          */
3290         conf_rewind(&cf);
3291         f = Files;
3292         i = 0;
3293         while (((p = conf_read(&cf)) != NULL) && (f < &Files[nlogs])) {
3294                 i++;
3295                 /* check for end-of-section */
3296                 if (p[0] == '\0' || p[0] == '#')
3297                         continue;
3298 
3299                 cfline(p, i, f);
3300                 if (f->f_type == F_UNUSED)
3301                         nlogs--;
3302                 else
3303                         f++;
3304         }
3305 
3306         conf_close(&cf);
3307 
3308         /*
3309          * See if marks are to be written to any files.  If so, set up a
3310          * timeout for marks.
3311          */
3312 nofile:
3313         Marking = 0;
3314 
3315         /*
3316          * allocate thread stacks - one for each logger thread.
3317          */
3318         if ((cstack_ptr = alloc_stacks(nlogs)) == NULL) {
3319                 logerror("alloc_stacks failed - fatal");
3320                 exit(1);
3321         }
3322 
3323         /* And now one thread for each configured file */
3324         for (f = Files; f < &Files[nlogs]; f++) {
3325                 if (filed_init(f) != 0) {
3326                         logerror("pthread_create failed - fatal");
3327                         exit(1);
3328                 }
3329 
3330                 (void) pthread_mutex_lock(&cft);
3331                 ++conf_threads;
3332                 (void) pthread_mutex_unlock(&cft);
3333 
3334                 if (f->f_type != F_UNUSED &&
3335                     f->f_pmask[LOG_NFACILITIES] != NOPRI)
3336                         Marking = 1;
3337         }
3338 }
3339 
3340 /*
3341  * filed init - initialize fields in a file descriptor struct
3342  * this is called before multiple threads are running, so no mutex
3343  * needs to be held at this time.
3344  */
3345 static int
3346 filed_init(struct filed *f)
3347 {
3348         pthread_attr_t stack_attr;
3349         pthread_t mythreadno;
3350 
3351         if (Debug) {
3352                 mythreadno = pthread_self();
3353         }
3354 
3355         if (pthread_mutex_init(&f->filed_mutex, NULL) != 0) {
3356                 logerror("pthread_mutex_init failed");
3357                 return (-1);
3358         }
3359 
3360         DPRINT2(5, "filed_init(%u): dataq_init for queue %p\n",
3361             mythreadno, (void *)&f->f_queue);
3362         (void) dataq_init(&f->f_queue);
3363 
3364         if (pthread_attr_init(&stack_attr) != 0) {
3365                 logerror("pthread_attr_init failed");
3366                 return (-1);
3367         }
3368 
3369         (void) pthread_attr_setstacksize(&stack_attr, stacksize);
3370         (void) pthread_attr_setstackaddr(&stack_attr, cstack_ptr);
3371         cstack_ptr += stacksize + redzonesize;
3372 
3373         f->f_msgflag = 0;
3374         f->f_prevmsg.msg[0] = '\0';
3375         f->f_prevmsg.flags = 0;
3376         f->f_prevmsg.pri = 0;
3377         f->f_prevmsg.host[0] = '\0';
3378 
3379         f->f_current.msg[0] = '\0';
3380         f->f_current.flags = 0;
3381         f->f_current.pri = 0;
3382         f->f_current.host[0] = '\0';
3383 
3384         f->f_prevcount = 0;
3385 
3386         f->f_stat.flag = 0;
3387         f->f_stat.total = 0;
3388         f->f_stat.dups = 0;
3389         f->f_stat.cantfwd = 0;
3390         f->f_stat.errs = 0;
3391 
3392         if (pthread_create(&f->f_thread, NULL, logit, (void *)f) != 0) {
3393                 logerror("pthread_create failed");
3394                 (void) pthread_attr_destroy(&stack_attr);
3395                 return (-1);
3396         }
3397 
3398         (void) pthread_attr_destroy(&stack_attr);
3399         return (0);
3400 }
3401 
3402 
3403 /*
3404  * Crack a configuration file line
3405  */
3406 static void
3407 cfline(char *line, int lineno, struct filed *f)
3408 {
3409         char *p;
3410         char *q;
3411         int i;
3412         char *bp;
3413         int pri;
3414         char buf[MAXLINE];
3415         char ebuf[SYS_NMLN+1+40];
3416         mode_t fmode, omode = O_WRONLY|O_APPEND|O_NOCTTY;
3417         struct stat64 sbuf;
3418         pthread_t mythreadno;
3419 
3420         if (Debug) {
3421                 mythreadno = pthread_self();
3422         }
3423 
3424         DPRINT2(1, "cfline(%u): (%s)\n", mythreadno, line);
3425 
3426         errno = 0;      /* keep errno related stuff out of logerror messages */
3427 
3428         /* clear out file entry */
3429         bzero((char *)f, sizeof (*f));
3430         for (i = 0; i <= LOG_NFACILITIES; i++)
3431                 f->f_pmask[i] = NOPRI;
3432 
3433         /* scan through the list of selectors */
3434         for (p = line; *p && *p != '\t'; ) {
3435 
3436                 /* find the end of this facility name list */
3437                 for (q = p; *q && *q != '\t' && *q++ != '.'; )
3438                         continue;
3439 
3440                 /* collect priority name */
3441                 for (bp = buf; *q && !strchr("\t,;", *q); )
3442                         *bp++ = *q++;
3443                 *bp = '\0';
3444 
3445                 /* skip cruft */
3446                 while (strchr(", ;", *q))
3447                         q++;
3448 
3449                 /* decode priority name */
3450                 pri = decode(buf, PriNames);
3451                 if (pri < 0) {
3452                         logerror("line %d: unknown priority name \"%s\"",
3453                             lineno, buf);
3454                         return;
3455                 }
3456 
3457                 /* scan facilities */
3458                 while (*p && !strchr("\t.;", *p)) {
3459                         for (bp = buf; *p && !strchr("\t,;.", *p); )
3460                                 *bp++ = *p++;
3461                         *bp = '\0';
3462                         if (*buf == '*')
3463                                 for (i = 0; i < LOG_NFACILITIES; i++)
3464                                         f->f_pmask[i] = (uchar_t)pri;
3465                         else {
3466                                 i = decode(buf, FacNames);
3467                                 if (i < 0) {
3468                                         logerror("line %d: unknown facility"
3469                                             " name \"%s\"", lineno, buf);
3470                                         return;
3471                                 }
3472                                 f->f_pmask[i >> 3] = (uchar_t)pri;
3473                         }
3474                         while (*p == ',' || *p == ' ')
3475                                 p++;
3476                 }
3477 
3478                 p = q;
3479         }
3480 
3481         /* skip to action part */
3482         while (*p == '\t' || *p == ' ')
3483                 p++;
3484 
3485         switch (*p) {
3486         case '\0':
3487                 errno = 0;
3488                 logerror("line %d: no action part", lineno);
3489                 break;
3490 
3491         case '@':
3492                 (void) strlcpy(f->f_un.f_forw.f_hname, ++p, SYS_NMLN);
3493                 if (logforward(f, ebuf, sizeof (ebuf)) != 0) {
3494                         logerror("line %d: %s", lineno, ebuf);
3495                         break;
3496                 }
3497                 f->f_type = F_FORW;
3498                 break;
3499 
3500         case '/':
3501                 (void) strlcpy(f->f_un.f_fname, p, MAXPATHLEN);
3502                 if (stat64(p, &sbuf) < 0) {
3503                         logerror(p);
3504                         break;
3505                 }
3506                 /*
3507                  * don't block trying to open a pipe
3508                  * with no reader on the other end
3509                  */
3510                 fmode = 0;      /* reset each pass */
3511                 if (S_ISFIFO(sbuf.st_mode))
3512                         fmode = O_NONBLOCK;
3513 
3514                 f->f_file = open64(p, omode|fmode);
3515                 if (f->f_file < 0) {
3516                         if (fmode && errno == ENXIO) {
3517                                 errno = 0;
3518                                 logerror("%s - no reader", p);
3519                         } else
3520                                 logerror(p);
3521                         break;
3522                 }
3523 
3524                 /*
3525                  * Fifos are initially opened NONBLOCK
3526                  * to insure we don't hang, but once
3527                  * we are open, we need to change the
3528                  * behavior back to blocking, otherwise
3529                  * we may get write errors, and the log
3530                  * will get closed down the line.
3531                  */
3532                 if (S_ISFIFO(sbuf.st_mode))
3533                         (void) fcntl(f->f_file, F_SETFL, omode);
3534 
3535                 if (isatty(f->f_file)) {
3536                         f->f_type = F_TTY;
3537                         untty();
3538                 } else
3539                         f->f_type = F_FILE;
3540 
3541                 if ((strcmp(p, ctty) == 0) || (strcmp(p, sysmsg) == 0))
3542                         f->f_type = F_CONSOLE;
3543                 break;
3544 
3545         case '*':
3546                 f->f_type = F_WALL;
3547                 break;
3548 
3549         default:
3550                 for (i = 0; i < MAXUNAMES && *p; i++) {
3551                         for (q = p; *q && *q != ','; )
3552                                 q++;
3553                         (void) strlcpy(f->f_un.f_uname[i], p, UNAMESZ);
3554                         if ((q - p) > UNAMESZ)
3555                                 f->f_un.f_uname[i][UNAMESZ] = '\0';
3556                         else
3557                                 f->f_un.f_uname[i][q - p] = '\0';
3558                         while (*q == ',' || *q == ' ')
3559                                 q++;
3560                         p = q;
3561                 }
3562                 f->f_type = F_USERS;
3563                 break;
3564         }
3565         f->f_orig_type = f->f_type;
3566 }
3567 
3568 
3569 /*
3570  *  Decode a symbolic name to a numeric value
3571  */
3572 static int
3573 decode(char *name, struct code *codetab)
3574 {
3575         struct code *c;
3576         char *p;
3577         char buf[40];
3578 
3579         if (isdigit(*name))
3580                 return (atoi(name));
3581 
3582         (void) strncpy(buf, name, sizeof (buf) - 1);
3583         for (p = buf; *p; p++)
3584                 if (isupper(*p))
3585                         *p = tolower(*p);
3586         for (c = codetab; c->c_name; c++)
3587                 if (!(strcmp(buf, c->c_name)))
3588                         return (c->c_val);
3589 
3590         return (-1);
3591 }
3592 
3593 static int
3594 ismyaddr(struct netbuf *nbp)
3595 {
3596         int i;
3597 
3598         if (nbp == NULL)
3599                 return (0);
3600 
3601         for (i = 1; i < Ninputs; i++) {
3602                 if (same_addr(nbp, Myaddrs[i]))
3603                         return (1);
3604         }
3605         return (0);
3606 }
3607 
3608 static void
3609 getnets(void)
3610 {
3611         struct nd_hostserv hs;
3612         struct netconfig *ncp;
3613         struct nd_addrlist *nap;
3614         struct netbuf *nbp;
3615         int i, inputs;
3616         void *handle;
3617         char *uap;
3618         pthread_t mythreadno;
3619 
3620         if (Debug) {
3621                 mythreadno = pthread_self();
3622         }
3623 
3624         if (turnoff) {
3625                 DPRINT1(1, "getnets(%u): network is being turned off\n",
3626                     mythreadno);
3627                 return;
3628         }
3629 
3630         hs.h_host = HOST_SELF;
3631         hs.h_serv = "syslog";
3632 
3633         if ((handle = setnetconfig()) == NULL) {
3634                 return;
3635         }
3636 
3637         while ((ncp = getnetconfig(handle)) != NULL) {
3638                 if (ncp->nc_semantics != NC_TPI_CLTS) {
3639                         continue;
3640                 }
3641 
3642                 if (netdir_getbyname(ncp, &hs, &nap) != 0) {
3643                         continue;
3644                 }
3645 
3646                 if (nap == NULL || nap->n_cnt <= 0) {
3647                         DPRINT1(1, "getnets(%u): found no address\n",
3648                             mythreadno);
3649                         netdir_free((void *)nap, ND_ADDRLIST);
3650                         continue;
3651                 }
3652 
3653                 if (Debug) {
3654                         DPRINT2(1, "getnets(%u): found %d addresses",
3655                             mythreadno, nap->n_cnt);
3656                         DPRINT0(1, ", they are: ");
3657                         nbp = nap->n_addrs;
3658 
3659                         for (i = 0; i < nap->n_cnt; i++) {
3660                                 if ((uap = taddr2uaddr(ncp, nbp)) != NULL) {
3661                                         DPRINT1(1, "%s ", uap);
3662                                         free(uap);
3663                                 }
3664                                 nbp++;
3665                         }
3666 
3667                         DPRINT0(1, "\n");
3668                 }
3669 
3670                 inputs = Ninputs + nap->n_cnt;
3671 
3672                 Nfd = realloc(Nfd, inputs * sizeof (struct pollfd));
3673                 Ncf = realloc(Ncf, inputs * sizeof (struct netconfig));
3674                 Myaddrs = realloc(Myaddrs, inputs * sizeof (struct netbuf *));
3675                 Udp = realloc(Udp, inputs * sizeof (struct t_unitdata *));
3676                 Errp = realloc(Errp, inputs * sizeof (struct t_uderr *));
3677 
3678                 /*
3679                  * all malloc failures here are fatal
3680                  */
3681                 if (Nfd == NULL || Ncf == NULL || Myaddrs == NULL ||
3682                     Udp == NULL || Errp == NULL) {
3683                         MALLOC_FAIL_EXIT;
3684                 }
3685 
3686                 nbp = nap->n_addrs;
3687 
3688                 for (i = 0; i < nap->n_cnt; i++, nbp++) {
3689                         char ebuf[128];
3690 
3691                         if (addnet(ncp, nbp) == 0) {
3692                                 /* no error */
3693                                 continue;
3694                         }
3695 
3696                         (void) strcpy(ebuf, "Unable to configure syslog port");
3697 
3698                         if ((uap = taddr2uaddr(ncp, nbp)) != NULL) {
3699                                 size_t l = strlen(ebuf);
3700                                 (void) snprintf(ebuf + l, sizeof (ebuf) - l,
3701                                     " for %s", uap);
3702                         }
3703 
3704                         DPRINT2(1, "getnets(%u): %s",
3705                             mythreadno, ebuf);
3706 
3707                         if (uap) {
3708                                 free(uap);
3709                         }
3710 
3711                         logerror(ebuf);
3712                         /*
3713                          * Here maybe syslogd can quit. However, syslogd
3714                          * has been ignoring this error and keep running.
3715                          * So we won't break it.
3716                          */
3717                 }
3718 
3719                 netdir_free((void *)nap, ND_ADDRLIST);
3720         }
3721 
3722         (void) endnetconfig(handle);
3723 }
3724 
3725 /*
3726  * Open the network device, and allocate necessary resources.
3727  * Myaddrs will also be filled, so that we can call ismyaddr() before
3728  * being bound to the network.
3729  */
3730 static int
3731 addnet(struct netconfig *ncp, struct netbuf *nbp)
3732 {
3733         int fd;
3734         struct netbuf *bp;
3735 
3736         fd = t_open(ncp->nc_device, O_RDWR, NULL);
3737 
3738         if (fd < 0) {
3739                 return (1);
3740         }
3741 
3742         (void) memcpy(&Ncf[Ninputs], ncp, sizeof (struct netconfig));
3743 
3744         /*LINTED*/
3745         Udp[Ninputs] = (struct t_unitdata *)t_alloc(fd, T_UNITDATA, T_ADDR);
3746 
3747         if (Udp[Ninputs] == NULL) {
3748                 (void) t_close(fd);
3749                 return (1);
3750         }
3751 
3752         /*LINTED*/
3753         Errp[Ninputs] = (struct t_uderr *)t_alloc(fd, T_UDERROR, T_ADDR);
3754 
3755         if (Errp[Ninputs] == NULL) {
3756                 (void) t_close(fd);
3757                 (void) t_free((char *)Udp[Ninputs], T_UNITDATA);
3758                 return (1);
3759         }
3760 
3761         if ((bp = malloc(sizeof (struct netbuf))) == NULL ||
3762             (bp->buf = malloc(nbp->len)) == NULL) {
3763                 MALLOC_FAIL("allocating address buffer");
3764                 (void) t_close(fd);
3765                 (void) t_free((char *)Udp[Ninputs], T_UNITDATA);
3766                 (void) t_free((char *)Errp[Ninputs], T_UDERROR);
3767 
3768                 if (bp) {
3769                         free(bp);
3770                 }
3771 
3772                 return (1);
3773         }
3774 
3775         bp->len = nbp->len;
3776         (void) memcpy(bp->buf, nbp->buf, nbp->len);
3777         Myaddrs[Ninputs] = bp;
3778 
3779         Nfd[Ninputs].fd = fd;
3780         Nfd[Ninputs].events = POLLIN;
3781         Ninputs++;
3782         return (0);
3783 }
3784 
3785 /*
3786  * Allocate UDP buffer to minimize packet loss.
3787  */
3788 static void
3789 set_udp_buffer(int fd)
3790 {
3791         struct t_optmgmt req, resp;
3792         struct opthdr *opt;
3793         size_t optsize, bsize = 256 * 1024;
3794         pthread_t mythreadno;
3795 
3796         if (Debug) {
3797                 mythreadno = pthread_self();
3798         }
3799 
3800         optsize = sizeof (struct opthdr) + sizeof (int);
3801         if ((opt = malloc(optsize)) == NULL) {
3802                 MALLOC_FAIL("will have no udp buffer");
3803                 return;
3804         }
3805         opt->level = SOL_SOCKET;
3806         opt->name = SO_RCVBUF;
3807         opt->len = sizeof (int);
3808         *(int *)(opt + 1) = bsize;
3809 
3810         req.flags = T_NEGOTIATE;
3811         req.opt.len = optsize;
3812         req.opt.buf = (char *)opt;
3813 
3814         resp.flags = 0;
3815         resp.opt.maxlen = optsize;
3816         resp.opt.buf = (char *)opt;
3817 
3818         while (t_optmgmt(fd, &req, &resp) == -1 || resp.flags != T_SUCCESS) {
3819                 if (t_errno != TSYSERR || errno != ENOBUFS) {
3820                         bsize = 0;
3821                         break;
3822                 }
3823                 bsize >>= 1;
3824                 if (bsize < 8192) {
3825                         break;
3826                 }
3827                 *(int *)(opt + 1) = bsize;
3828         }
3829         if (bsize == 0) {
3830                 logerror("failed to allocate UDP buffer");
3831         }
3832         DPRINT3(1, "set_udp_buffer(%u): allocate %d for fd %d\n",
3833             mythreadno, bsize, fd);
3834         free(opt);
3835 }
3836 
3837 /*
3838  * Attach the network, and allocate UDP buffer for the interface.
3839  */
3840 static void
3841 bindnet(void)
3842 {
3843         struct t_bind bind, *bound;
3844         int cnt, i;
3845         char *uap;
3846         pthread_t mythreadno;
3847 
3848         if (Debug) {
3849                 mythreadno = pthread_self();
3850         }
3851 
3852         cnt = 0;
3853 
3854         while (cnt < Ninputs) {
3855                 char ebuf[128];
3856 
3857                 /*LINTED*/
3858                 bound  = (struct t_bind *)t_alloc(Nfd[cnt].fd, T_BIND, T_ADDR);
3859                 bind.addr = *Myaddrs[cnt];
3860                 bind.qlen = 0;
3861 
3862                 if (t_bind(Nfd[cnt].fd, &bind, bound) == 0) {
3863                         if (same_addr(&bind.addr, &bound->addr)) {
3864                                 (void) t_free((char *)bound, T_BIND);
3865                                 set_udp_buffer(Nfd[cnt].fd);
3866                                 cnt++;
3867                                 continue;
3868                         }
3869                 }
3870 
3871                 /* failed to bind port */
3872                 (void) t_free((char *)bound, T_BIND);
3873 
3874                 (void) strcpy(ebuf, "Unable to bind syslog port");
3875 
3876                 uap = taddr2uaddr(&Ncf[cnt], Myaddrs[cnt]);
3877                 if (uap) {
3878                         i = strlen(ebuf);
3879                         (void) snprintf(ebuf + i, sizeof (ebuf) - i,
3880                             " for %s", uap);
3881                 }
3882 
3883                 DPRINT2(1, "bindnet(%u): failed to bind port (%s)\n",
3884                     mythreadno, uap ? uap : "<unknown>");
3885 
3886                 if (uap) {
3887                         free(uap);
3888                 }
3889 
3890                 errno = 0;
3891                 logerror(ebuf);
3892 
3893                 (void) t_close(Nfd[cnt].fd);
3894                 free(Myaddrs[cnt]->buf);
3895                 free(Myaddrs[cnt]);
3896                 (void) t_free((char *)Udp[cnt], T_UNITDATA);
3897                 (void) t_free((char *)Errp[cnt], T_UDERROR);
3898 
3899                 for (i = cnt; i < (Ninputs-1); i++) {
3900                         Nfd[i] = Nfd[i + 1];
3901                         Ncf[i] = Ncf[i + 1];
3902                         Myaddrs[i] = Myaddrs[i + 1];
3903                         Udp[i] = Udp[i + 1];
3904                         Errp[i] = Errp[i + 1];
3905                 }
3906 
3907                 Ninputs--;
3908         }
3909 }
3910 
3911 static int
3912 logforward(struct filed *f, char *ebuf, size_t elen)
3913 {
3914         struct nd_hostserv hs;
3915         struct netbuf *nbp;
3916         struct netconfig *ncp;
3917         struct nd_addrlist *nap;
3918         void *handle;
3919         char *hp;
3920 
3921         hp = f->f_un.f_forw.f_hname;
3922         hs.h_host = hp;
3923         hs.h_serv = "syslog";
3924 
3925         if ((handle = setnetconfig()) == NULL) {
3926                 (void) strlcpy(ebuf,
3927                     "unable to rewind the netconfig database", elen);
3928                 errno = 0;
3929                 return (-1);
3930         }
3931         nap = (struct nd_addrlist *)NULL;
3932         while ((ncp = getnetconfig(handle)) != NULL) {
3933                 if (ncp->nc_semantics == NC_TPI_CLTS) {
3934                         if (netdir_getbyname(ncp, &hs, &nap) == 0) {
3935                                 if (!nap)
3936                                         continue;
3937                                 nbp = nap->n_addrs;
3938                                 break;
3939                         }
3940                 }
3941         }
3942         if (ncp == NULL) {
3943                 (void) endnetconfig(handle);
3944                 (void) snprintf(ebuf, elen,
3945                     "WARNING: %s could not be resolved", hp);
3946                 errno = 0;
3947                 return (-1);
3948         }
3949         if (nap == (struct nd_addrlist *)NULL) {
3950                 (void) endnetconfig(handle);
3951                 (void) snprintf(ebuf, elen, "unknown host %s", hp);
3952                 errno = 0;
3953                 return (-1);
3954         }
3955         /* CSTYLED */
3956         if (ismyaddr(nbp)) { /*lint !e644 */
3957                 netdir_free((void *)nap, ND_ADDRLIST);
3958                 (void) endnetconfig(handle);
3959                 (void) snprintf(ebuf, elen,
3960                     "host %s is this host - logging loop", hp);
3961                 errno = 0;
3962                 return (-1);
3963         }
3964         f->f_un.f_forw.f_addr.buf = malloc(nbp->len);
3965         if (f->f_un.f_forw.f_addr.buf == NULL) {
3966                 netdir_free((void *)nap, ND_ADDRLIST);
3967                 (void) endnetconfig(handle);
3968                 (void) strlcpy(ebuf, "malloc failed", elen);
3969                 return (-1);
3970         }
3971         bcopy(nbp->buf, f->f_un.f_forw.f_addr.buf, nbp->len);
3972         f->f_un.f_forw.f_addr.len = nbp->len;
3973         f->f_file = t_open(ncp->nc_device, O_RDWR, NULL);
3974         if (f->f_file < 0) {
3975                 netdir_free((void *)nap, ND_ADDRLIST);
3976                 (void) endnetconfig(handle);
3977                 free(f->f_un.f_forw.f_addr.buf);
3978                 (void) strlcpy(ebuf, "t_open", elen);
3979                 return (-1);
3980         }
3981         netdir_free((void *)nap, ND_ADDRLIST);
3982         (void) endnetconfig(handle);
3983         if (t_bind(f->f_file, NULL, NULL) < 0) {
3984                 (void) strlcpy(ebuf, "t_bind", elen);
3985                 free(f->f_un.f_forw.f_addr.buf);
3986                 (void) t_close(f->f_file);
3987                 return (-1);
3988         }
3989         return (0);
3990 }
3991 
3992 static int
3993 amiloghost(void)
3994 {
3995         struct nd_hostserv hs;
3996         struct netconfig *ncp;
3997         struct nd_addrlist *nap;
3998         struct netbuf *nbp;
3999         int i, fd;
4000         void *handle;
4001         char *uap;
4002         struct t_bind bind, *bound;
4003         pthread_t mythreadno;
4004 
4005         if (Debug) {
4006                 mythreadno = pthread_self();
4007         }
4008 
4009         /*
4010          * we need to know if we are running on the loghost. This is
4011          * checked by binding to the address associated with "loghost"
4012          * and "syslogd" service over the connectionless transport
4013          */
4014         hs.h_host = "loghost";
4015         hs.h_serv = "syslog";
4016 
4017         if ((handle = setnetconfig()) == NULL) {
4018                 return (0);
4019         }
4020 
4021         while ((ncp = getnetconfig(handle)) != NULL) {
4022                 if (ncp->nc_semantics != NC_TPI_CLTS) {
4023                         continue;
4024                 }
4025 
4026                 if (netdir_getbyname(ncp, &hs, &nap) != 0) {
4027                         continue;
4028                 }
4029 
4030                 if (nap == NULL) {
4031                         continue;
4032                 }
4033 
4034                 nbp = nap->n_addrs;
4035 
4036                 for (i = 0; i < nap->n_cnt; i++) {
4037                         if ((uap = taddr2uaddr(ncp, nbp)) != (char *)NULL) {
4038                                 DPRINT2(1, "amiloghost(%u): testing %s\n",
4039                                     mythreadno, uap);
4040                         }
4041 
4042                         free(uap);
4043 
4044                         fd = t_open(ncp->nc_device, O_RDWR, NULL);
4045 
4046                         if (fd < 0) {
4047                                 netdir_free((void *)nap, ND_ADDRLIST);
4048                                 (void) endnetconfig(handle);
4049                                 return (0);
4050                         }
4051 
4052                         /*LINTED*/
4053                         bound = (struct t_bind *)t_alloc(fd, T_BIND, T_ADDR);
4054                         bind.addr = *nbp;
4055                         bind.qlen = 0;
4056 
4057                         if (t_bind(fd, &bind, bound) == 0) {
4058                                 (void) t_close(fd);
4059                                 (void) t_free((char *)bound, T_BIND);
4060                                 netdir_free((void *)nap, ND_ADDRLIST);
4061                                 (void) endnetconfig(handle);
4062                                 return (1);
4063                         } else {
4064                                 (void) t_close(fd);
4065                                 (void) t_free((char *)bound, T_BIND);
4066                         }
4067 
4068                         nbp++;
4069                 }
4070 
4071                 netdir_free((void *)nap, ND_ADDRLIST);
4072         }
4073 
4074         (void) endnetconfig(handle);
4075         return (0);
4076 }
4077 
4078 int
4079 same_addr(struct netbuf *na, struct netbuf *nb)
4080 {
4081         char *a, *b;
4082         size_t n;
4083 
4084         assert(na->buf != NULL && nb->buf != NULL);
4085 
4086         if (na->len != nb->len) {
4087                 return (0);
4088         }
4089 
4090         a = na->buf;
4091         b = nb->buf;
4092         n = nb->len;
4093 
4094         while (n-- > 0) {
4095                 if (*a++ != *b++) {
4096                         return (0);
4097                 }
4098         }
4099 
4100         return (1);
4101 }
4102 
4103 /*
4104  * allocates a new message structure, initializes it
4105  * and returns a pointer to it
4106  */
4107 static log_message_t *
4108 new_msg(void)
4109 {
4110         log_message_t *lm;
4111         pthread_t mythreadno;
4112 
4113         if (Debug) {
4114                 mythreadno = pthread_self();
4115         }
4116 
4117         if ((lm = malloc(sizeof (log_message_t))) == NULL)
4118                 return ((log_message_t *)NULL);
4119 
4120         _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*lm))
4121 
4122         if (pthread_mutex_init(&lm->msg_mutex, NULL) != 0)
4123                 return ((log_message_t *)NULL);
4124         lm->refcnt = 0;
4125         lm->pri = 0;
4126         lm->flags = 0;
4127         lm->hlp = NULL;
4128         lm->msg[0] = '\0';
4129         lm->ptr = NULL;
4130 
4131         DPRINT2(3, "new_msg(%u): creating msg %p\n", mythreadno, (void *)lm);
4132         return (lm);
4133 }
4134 
4135 /*
4136  * frees a message structure - should only be called if
4137  * the refcount is 0
4138  */
4139 static void
4140 free_msg(log_message_t *lm)
4141 {
4142         pthread_t mythreadno;
4143 
4144         if (Debug) {
4145                 mythreadno = pthread_self();
4146         }
4147 
4148         assert(lm != NULL && lm->refcnt == 0);
4149         if (lm->hlp != NULL)
4150                 freehl(lm->hlp);
4151         DPRINT2(3, "free_msg(%u): freeing msg %p\n", mythreadno, (void *)lm);
4152         free(lm);
4153 }
4154 
4155 /*
4156  *  Make sure that the message makes sense in the current locale, and
4157  *  does not contain stray control characters.
4158  */
4159 static void
4160 filter_string(char *mbstr, char *filtered, size_t max)
4161 {
4162         size_t  cs = 0;
4163         size_t  mb_cur_max;
4164         unsigned char   *p = (unsigned char *)mbstr;
4165         pthread_t mythreadno = 0;
4166 
4167         if (Debug) {
4168                 mythreadno = pthread_self();
4169         }
4170 
4171         assert(mbstr != NULL && filtered != NULL);
4172 
4173         /*
4174          * Since the access to MB_CUR_MAX is expensive (because
4175          * MB_CUR_MAX lives in a global area), it should be
4176          * restrained for the better performance.
4177          */
4178         mb_cur_max = (size_t)MB_CUR_MAX;
4179         if (mb_cur_max > 1) {
4180                 /* multibyte locale */
4181                 int     mlen;
4182                 wchar_t wc;
4183 
4184                 while (*p != '\0') {
4185                         if ((mlen = mbtowc(&wc, (char *)p,
4186                             mb_cur_max)) == -1) {
4187                                 /*
4188                                  * Invalid byte sequence found.
4189                                  *
4190                                  * try to print one byte
4191                                  * in ASCII format.
4192                                  */
4193                                 DPRINT2(9, "filter_string(%u): Invalid "
4194                                     "MB sequence: %ld\n", mythreadno,
4195                                     wc);
4196 
4197                                 if (!putctrlc(*p++, &filtered, &cs, max)) {
4198                                         /* not enough buffer */
4199                                         goto end;
4200                                 } else {
4201                                         continue;
4202                                 }
4203                         } else {
4204                                 /*
4205                                  * Since *p is not a null byte here,
4206                                  * mbtowc should have never returned 0.
4207                                  *
4208                                  * A valid wide character found.
4209                                  */
4210 
4211                                 if (wc != L'\t' && iswcntrl(wc)) {
4212                                         /*
4213                                          * non-tab, non-newline, and
4214                                          * control character found.
4215                                          *
4216                                          * try to print this wide character
4217                                          * in ASCII-format.
4218                                          */
4219                                         char    *q = filtered;
4220 
4221                                         DPRINT2(9, "filter_string(%u): MB"
4222                                             " control character: %ld\n",
4223                                             mythreadno, wc);
4224 
4225                                         while (mlen--) {
4226                                                 if (!putctrlc(*p++, &filtered,
4227                                                     &cs, max)) {
4228                                                         /*
4229                                                          * not enough buffer in
4230                                                          * filtered
4231                                                          *
4232                                                          * cancel already
4233                                                          * stored bytes in
4234                                                          * filtered for this
4235                                                          * wide character.
4236                                                          */
4237                                                         filtered = q;
4238                                                         goto end;
4239                                                 }
4240                                         }
4241                                         continue;
4242                                 } else {
4243                                         /*
4244                                          * tab, newline, or non-control
4245                                          * character found.
4246                                          */
4247                                         if (cs + mlen < max) {
4248                                                 /* enough buffer */
4249                                                 cs += mlen;
4250                                                 while (mlen--) {
4251                                                         *filtered++ = *p++;
4252                                                 }
4253                                                 continue;
4254                                         } else {
4255                                                 /* not enough buffer */
4256                                                 goto end;
4257                                         }
4258                                 }
4259                         }
4260                 }
4261         } else {
4262                 /* singlebyte locale */
4263 
4264                 while (*p != '\0') {
4265                         if (*p != '\t' && iscntrl(*p)) {
4266                                 /*
4267                                  * non-tab, non-newline,
4268                                  * and control character found.
4269                                  *
4270                                  * try to print this singlebyte character
4271                                  * in ASCII format.
4272                                  */
4273                                 DPRINT2(9, "filter_string(%u): control "
4274                                     "character: %d\n", mythreadno, *p);
4275 
4276                                 if (!putctrlc(*p++, &filtered, &cs, max)) {
4277                                         /* not enough buffer */
4278                                         goto end;
4279                                 } else {
4280                                         continue;
4281                                 }
4282                         } else if (*p != '\t' && !isprint(*p)) {
4283                                 /*
4284                                  * non-tab and non printable character found
4285                                  * this check is required for the C locale
4286                                  */
4287                                 DPRINT2(9, "filter_string(%u): non-printable "
4288                                     "character: %d\n", mythreadno, *p);
4289                                 if (!putctrlc(*p++, &filtered, &cs, max)) {
4290                                         /* not enough buffer */
4291                                         goto end;
4292                                 } else {
4293                                         continue;
4294                                 }
4295                         } else {
4296                                 /*
4297                                  * tab, newline, non-control character, or
4298                                  * printable found.
4299                                  */
4300                                 if (cs + 1 < max) {
4301                                         *filtered++ = *p++;
4302                                         cs++;
4303                                         continue;
4304                                 } else {
4305                                         /* not enough buffer */
4306                                         goto end;
4307                                 }
4308                         }
4309                 }
4310         }
4311 
4312 end:
4313         *filtered = '\0';
4314 
4315         if (cs >= 2 &&
4316             filtered[-2] == '\\' && filtered[-1] == 'n') {
4317                 filtered[-2] = '\0';
4318         }
4319 }
4320 
4321 static char *
4322 alloc_stacks(int numstacks)
4323 {
4324         size_t pagesize, mapsize;
4325         char *stack_top;
4326         char *addr;
4327         int i;
4328 
4329         pagesize = (size_t)sysconf(_SC_PAGESIZE);
4330         /*
4331          * stacksize and redzonesize are global so threads
4332          * can be created elsewhere and refer to the sizes
4333          */
4334         stacksize = (size_t)roundup(sysconf(_SC_THREAD_STACK_MIN) +
4335             DEFAULT_STACKSIZE, pagesize);
4336         redzonesize = (size_t)roundup(DEFAULT_REDZONESIZE, pagesize);
4337 
4338         /*
4339          * allocate an additional "redzonesize" chunk in addition
4340          * to what we require, so we can create a redzone at the
4341          * bottom of the last stack as well.
4342          */
4343         mapsize = redzonesize + numstacks * (stacksize + redzonesize);
4344         stack_top = mmap(NULL, mapsize, PROT_READ|PROT_WRITE,
4345             MAP_PRIVATE|MAP_ANON, -1, 0);
4346         if (stack_top == MAP_FAILED)
4347                 return (NULL);
4348 
4349         addr = stack_top;
4350         /*
4351          * this loop is intentionally <= instead of <, so we can
4352          * protect the redzone at the bottom of the last stack
4353          */
4354         for (i = 0; i <= numstacks; i++) {
4355                 (void) mprotect(addr, redzonesize, PROT_NONE);
4356                 addr += stacksize + redzonesize;
4357         }
4358         return ((char *)(stack_top + redzonesize));
4359 }
4360 
4361 static void
4362 dealloc_stacks(int numstacks)
4363 {
4364         size_t pagesize, mapsize;
4365 
4366         pagesize = (size_t)sysconf(_SC_PAGESIZE);
4367 
4368         stacksize = (size_t)roundup(sysconf(_SC_THREAD_STACK_MIN) +
4369             DEFAULT_STACKSIZE, pagesize);
4370 
4371         redzonesize = (size_t)roundup(DEFAULT_REDZONESIZE, pagesize);
4372 
4373         mapsize = redzonesize + numstacks * (stacksize + redzonesize);
4374         (void) munmap(cstack_ptr - mapsize, mapsize);
4375 }
4376 
4377 static void
4378 filed_destroy(struct filed *f)
4379 {
4380         (void) dataq_destroy(&f->f_queue);
4381         (void) pthread_mutex_destroy(&f->filed_mutex);
4382 }
4383 
4384 static void
4385 close_door(void)
4386 {
4387         pthread_t mythreadno;
4388 
4389         if (Debug) {
4390                 mythreadno = pthread_self();
4391         }
4392 
4393         (void) fdetach(DoorFileName);
4394 
4395         DPRINT2(5, "close_door(%u): detached server() from %s\n",
4396             mythreadno, DoorFileName);
4397 }
4398 
4399 static void
4400 delete_doorfiles(void)
4401 {
4402         pthread_t mythreadno;
4403         struct stat sb;
4404         int err;
4405         char line[MAXLINE+1];
4406 
4407         if (Debug) {
4408                 mythreadno = pthread_self();
4409         }
4410 
4411 
4412         if (lstat(DoorFileName, &sb) == 0 && !S_ISDIR(sb.st_mode)) {
4413                 if (unlink(DoorFileName) < 0) {
4414                         err = errno;
4415                         (void) snprintf(line, sizeof (line),
4416                             "unlink() of %s failed - fatal", DoorFileName);
4417                         errno = err;
4418                         logerror(line);
4419                         DPRINT3(1, "delete_doorfiles(%u): error: %s, "
4420                             "errno=%d\n", mythreadno, line, err);
4421                         exit(1);
4422                 }
4423 
4424                 DPRINT2(5, "delete_doorfiles(%u): deleted %s\n",
4425                     mythreadno, DoorFileName);
4426         }
4427 
4428         if (strcmp(DoorFileName, DOORFILE) == 0) {
4429                 if (lstat(OLD_DOORFILE, &sb) == 0 && !S_ISDIR(sb.st_mode)) {
4430                         if (unlink(OLD_DOORFILE) < 0) {
4431                                 err = errno;
4432                                 (void) snprintf(line, sizeof (line),
4433                                     "unlink() of %s failed", OLD_DOORFILE);
4434                                 DPRINT2(5, "delete_doorfiles(%u): %s\n",
4435                                     mythreadno, line);
4436 
4437                                 if (err != EROFS) {
4438                                         errno = err;
4439                                         (void) strlcat(line, " - fatal",
4440                                             sizeof (line));
4441                                         logerror(line);
4442                                         DPRINT3(1, "delete_doorfiles(%u): "
4443                                             "error: %s, errno=%d\n",
4444                                             mythreadno, line, err);
4445                                         exit(1);
4446                                 }
4447 
4448                                 DPRINT1(5, "delete_doorfiles(%u): unlink() "
4449                                     "failure OK on RO file system\n",
4450                                     mythreadno);
4451                         }
4452 
4453                         DPRINT2(5, "delete_doorfiles(%u): deleted %s\n",
4454                             mythreadno, OLD_DOORFILE);
4455                 }
4456         }
4457 
4458         if (lstat(PidFileName, &sb) == 0 && !S_ISDIR(sb.st_mode)) {
4459                 if (unlink(PidFileName) < 0) {
4460                         err = errno;
4461                         (void) snprintf(line, sizeof (line),
4462                             "unlink() of %s failed - fatal", PidFileName);
4463                         errno = err;
4464                         logerror(line);
4465                         DPRINT3(1, "delete_doorfiles(%u): error: %s, "
4466                             "errno=%d\n", mythreadno, line, err);
4467                         exit(1);
4468                 }
4469 
4470                 DPRINT2(5, "delete_doorfiles(%u): deleted %s\n", mythreadno,
4471                     PidFileName);
4472         }
4473 
4474         if (strcmp(PidFileName, PIDFILE) == 0) {
4475                 if (lstat(OLD_PIDFILE, &sb) == 0 && !S_ISDIR(sb.st_mode)) {
4476                         if (unlink(OLD_PIDFILE) < 0) {
4477                                 err = errno;
4478                                 (void) snprintf(line, sizeof (line),
4479                                     "unlink() of %s failed", OLD_PIDFILE);
4480                                 DPRINT2(5, "delete_doorfiles(%u): %s, \n",
4481                                     mythreadno, line);
4482 
4483                                 if (err != EROFS) {
4484                                         errno = err;
4485                                         (void) strlcat(line, " - fatal",
4486                                             sizeof (line));
4487                                         logerror(line);
4488                                         DPRINT3(1, "delete_doorfiles(%u): "
4489                                             "error: %s, errno=%d\n",
4490                                             mythreadno, line, err);
4491                                         exit(1);
4492                                 }
4493 
4494                                 DPRINT1(5, "delete_doorfiles(%u): unlink "
4495                                     "failure OK on RO file system\n",
4496                                     mythreadno);
4497                         }
4498 
4499                         DPRINT2(5, "delete_doorfiles(%u): deleted %s\n",
4500                             mythreadno, OLD_PIDFILE);
4501                 }
4502         }
4503 
4504         if (DoorFd != -1) {
4505                 (void) door_revoke(DoorFd);
4506         }
4507 
4508         DPRINT2(1, "delete_doorfiles(%u): revoked door: DoorFd=%d\n",
4509             mythreadno, DoorFd);
4510 }
4511 
4512 
4513 /*ARGSUSED*/
4514 static void
4515 signull(int sig, siginfo_t *sip, void *utp)
4516 {
4517         DPRINT1(1, "signull(%u): THIS CALL SHOULD NEVER HAPPEN\n",
4518             pthread_self());
4519         /*
4520          * Do nothing, as this is a place-holder used in conjunction with
4521          * sigaction()/sigwait() to ensure that the proper disposition is
4522          * given to the signals we handle in main().
4523          */
4524 }
4525 
4526 /*
4527  * putctrlc returns zero, if failed due to not enough buffer.
4528  * Otherwise, putctrlc returns non-zero.
4529  *
4530  * c:     a byte to print in ASCII format
4531  * **buf: a pointer to the pointer to the output buffer.
4532  * *cl:   current length of characters in the output buffer
4533  * max:   maximum length of the buffer
4534  */
4535 
4536 static int
4537 putctrlc(int c, char **buf, size_t *cl, size_t max)
4538 {
4539         char    *p = *buf;
4540 
4541         if (c == '\n') {
4542                 if (*cl + 2 < max) {
4543                         *p++ = '\\';
4544                         *p++ = 'n';
4545                         *cl += 2;
4546                         *buf = p;
4547                         return (2);
4548                 } else {
4549                         return (0);
4550                 }
4551         } else if (c < 0200) {
4552                 /* ascii control character */
4553                 if (*cl + 2 < max) {
4554                         *p++ = '^';
4555                         *p++ = c ^ 0100;
4556                         *cl += 2;
4557                         *buf = p;
4558                         return (2);
4559                 } else {
4560                         return (0);
4561                 }
4562         } else {
4563                 if (*cl + 4 < max) {
4564                         *p++ = '\\';
4565                         *p++ = ((c >> 6) & 07) + '0';
4566                         *p++ = ((c >> 3) & 07) + '0';
4567                         *p++ = (c & 07) + '0';
4568                         *cl += 4;
4569                         *buf = p;
4570                         return (4);
4571                 } else {
4572                         return (0);
4573                 }
4574         }
4575 }
4576 
4577 /*
4578  * findnl_bkwd:
4579  *      Scans each character in buf until it finds the last newline in buf,
4580  *      or the scanned character becomes the last COMPLETE character in buf.
4581  *      Returns the number of scanned bytes.
4582  *
4583  *      buf - pointer to a buffer containing the message string
4584  *      len - the length of the buffer
4585  */
4586 size_t
4587 findnl_bkwd(const char *buf, const size_t len)
4588 {
4589         const char *p;
4590         size_t  mb_cur_max;
4591         pthread_t mythreadno;
4592 
4593         if (Debug) {
4594                 mythreadno = pthread_self();
4595         }
4596 
4597         if (len == 0) {
4598                 return (0);
4599         }
4600 
4601         mb_cur_max = MB_CUR_MAX;
4602 
4603         if (mb_cur_max == 1) {
4604                 /* single-byte locale */
4605                 for (p = buf + len - 1; p != buf; p--) {
4606                         if (*p == '\n') {
4607                                 return ((size_t)(p - buf));
4608                         }
4609                 }
4610                 return ((size_t)len);
4611         } else {
4612                 /* multi-byte locale */
4613                 int mlen;
4614                 const char *nl;
4615                 size_t  rem;
4616 
4617                 p = buf;
4618                 nl = NULL;
4619                 for (rem = len; rem >= mb_cur_max; ) {
4620                         mlen = mblen(p, mb_cur_max);
4621                         if (mlen == -1) {
4622                                 /*
4623                                  * Invalid character found.
4624                                  */
4625                                 DPRINT1(9, "findnl_bkwd(%u): Invalid MB "
4626                                     "sequence\n", mythreadno);
4627                                 /*
4628                                  * handle as a single byte character.
4629                                  */
4630                                 p++;
4631                                 rem--;
4632                         } else {
4633                                 /*
4634                                  * It's guaranteed that *p points to
4635                                  * the 1st byte of a multibyte character.
4636                                  */
4637                                 if (*p == '\n') {
4638                                         nl = p;
4639                                 }
4640                                 p += mlen;
4641                                 rem -= mlen;
4642                         }
4643                 }
4644                 if (nl) {
4645                         return ((size_t)(nl - buf));
4646                 }
4647                 /*
4648                  * no newline nor null byte found.
4649                  * Also it's guaranteed that *p points to
4650                  * the 1st byte of a (multibyte) character
4651                  * at this point.
4652                  */
4653                 return (len - rem);
4654         }
4655 }
4656 
4657 /*
4658  * copynl_frwd:
4659  *      Scans each character in buf and copies the scanned character to obuf
4660  *      until it finds a null byte or a newline, or
4661  *      the number of the remaining bytes in obuf gets to exceed obuflen
4662  *      if copying the scanned character to obuf.
4663  *      Returns the number of scanned bytes.
4664  *
4665  *      obuf - buffer to be copied the scanned character
4666  *      obuflen - the size of obuf
4667  *      buf - pointer to a buffer containing the message string
4668  *      len - the length of the buffer
4669  */
4670 size_t
4671 copynl_frwd(char *obuf, const size_t obuflen,
4672             const char *buf, const size_t len)
4673 {
4674         const char *p;
4675         char    *q = obuf;
4676         size_t  olen = 0;
4677         size_t  mb_cur_max;
4678         pthread_t mythreadno;
4679 
4680         if (Debug) {
4681                 mythreadno = pthread_self();
4682         }
4683 
4684         if (len == 0) {
4685                 return (0);
4686         }
4687 
4688         mb_cur_max = MB_CUR_MAX;
4689 
4690         if (mb_cur_max == 1) {
4691                 /* single-byte locale */
4692                 for (p = buf; *p; ) {
4693                         if (obuflen > olen + 1) {
4694                                 if (*p != '\n') {
4695                                         *q++ = *p++;
4696                                         olen++;
4697                                 } else {
4698                                         *q = '\0';
4699                                         return ((size_t)(p - buf));
4700                                 }
4701                         } else {
4702                                 *q = '\0';
4703                                 return ((size_t)(p - buf));
4704                         }
4705                 }
4706                 *q = '\0';
4707                 return ((size_t)(p - buf));
4708         } else {
4709                 /* multi-byte locale */
4710                 int mlen;
4711 
4712                 for (p = buf; *p; ) {
4713                         mlen = mblen(p, mb_cur_max);
4714                         if (mlen == -1) {
4715                                 /*
4716                                  * Invalid character found.
4717                                  */
4718                                 DPRINT1(9, "copynl_frwd(%u): Invalid MB "
4719                                     "sequence\n", mythreadno);
4720                                 /*
4721                                  * handle as a single byte character.
4722                                  */
4723                                 if (obuflen > olen + 1) {
4724                                         *q++ = *p++;
4725                                         olen++;
4726                                 } else {
4727                                         *q = '\0';
4728                                         return ((size_t)(p - buf));
4729                                 }
4730                         } else {
4731                                 /*
4732                                  * It's guaranteed that *p points to
4733                                  * the 1st byte of a multibyte character.
4734                                  */
4735                                 if (*p == '\n') {
4736                                         *q = '\0';
4737                                         return ((size_t)(p - buf));
4738                                 }
4739                                 if (obuflen > olen + mlen) {
4740                                         int     n;
4741                                         for (n = 0; n < mlen; n++) {
4742                                                 *q++ = *p++;
4743                                         }
4744                                         olen += mlen;
4745                                 } else {
4746                                         *q = '\0';
4747                                         return ((size_t)(p - buf));
4748                                 }
4749                         }
4750                 }
4751                 /*
4752                  * no newline nor null byte found.
4753                  * Also it's guaranteed that *p points to
4754                  * the 1st byte of a (multibyte) character
4755                  * at this point.
4756                  */
4757                 *q = '\0';
4758                 return ((size_t)(p - buf));
4759         }
4760 }
4761 
4762 /*
4763  * copy_frwd:
4764  *      Scans each character in buf and copies the scanned character to obuf
4765  *      until the number of the remaining bytes in obuf gets to exceed obuflen
4766  *      if copying the scanned character to obuf.
4767  *      Returns the number of scanned (copied) bytes.
4768  *
4769  *      obuf - buffer to be copied the scanned character
4770  *      obuflen - the size of obuf
4771  *      buf - pointer to a buffer containing the message string
4772  *      len - the length of the buffer
4773  */
4774 size_t
4775 copy_frwd(char *obuf, const size_t obuflen,
4776         const char *buf, const size_t len)
4777 {
4778         const char *p;
4779         char    *q = obuf;
4780         size_t  olen = 0;
4781         size_t  mb_cur_max;
4782         pthread_t mythreadno;
4783 
4784         if (Debug) {
4785                 mythreadno = pthread_self();
4786         }
4787 
4788         if (len == 0) {
4789                 return (0);
4790         }
4791 
4792         mb_cur_max = MB_CUR_MAX;
4793 
4794         if (mb_cur_max == 1) {
4795                 /* single-byte locale */
4796                 if (obuflen > len) {
4797                         (void) memcpy(obuf, buf, len);
4798                         obuf[len] = '\0';
4799                         return ((size_t)len);
4800                 } else {
4801                         (void) memcpy(obuf, buf, obuflen - 1);
4802                         obuf[obuflen - 1] = '\0';
4803                         return (obuflen - 1);
4804                 }
4805         } else {
4806                 /* multi-byte locale */
4807                 int mlen;
4808 
4809                 for (p = buf; *p; ) {
4810                         mlen = mblen(p, mb_cur_max);
4811                         if (mlen == -1) {
4812                                 /*
4813                                  * Invalid character found.
4814                                  */
4815                                 DPRINT1(9, "copy_frwd(%u): Invalid MB "
4816                                     "sequence\n", mythreadno);
4817                                 /*
4818                                  * handle as a single byte character.
4819                                  */
4820                                 if (obuflen > olen + 1) {
4821                                         *q++ = *p++;
4822                                         olen++;
4823                                 } else {
4824                                         *q = '\0';
4825                                         return ((size_t)(p - buf));
4826                                 }
4827                         } else {
4828                                 if (obuflen > olen + mlen) {
4829                                         int     n;
4830                                         for (n = 0; n < mlen; n++) {
4831                                                 *q++ = *p++;
4832                                         }
4833                                         olen += mlen;
4834                                 } else {
4835                                         *q = '\0';
4836                                         return ((size_t)(p - buf));
4837                                 }
4838                         }
4839                 }
4840                 *q = '\0';
4841                 return ((size_t)(p - buf));
4842         }
4843 }
4844 
4845 /*
4846  * properties:
4847  *      Get properties from SMF framework.
4848  */
4849 static void
4850 properties(void)
4851 {
4852         scf_simple_prop_t *prop;
4853         uint8_t *bool;
4854 
4855         if ((prop = scf_simple_prop_get(NULL, NULL, "config",
4856             "log_from_remote")) != NULL) {
4857                 if ((bool = scf_simple_prop_next_boolean(prop)) != NULL) {
4858                         if (*bool == 0)
4859                                 turnoff = 1; /* log_from_remote = false */
4860                         else
4861                                 turnoff = 0; /* log_from_remote = true */
4862                 }
4863                 scf_simple_prop_free(prop);
4864                 DPRINT1(1, "properties: setting turnoff to %s\n",
4865                     turnoff ? "true" : "false");
4866         }
4867 }
4868 
4869 /*
4870  * close all the input devices.
4871  */
4872 static void
4873 shutdown_input(void)
4874 {
4875         int cnt;
4876 
4877         shutting_down = 1;
4878 
4879         for (cnt = 0; cnt < Ninputs; cnt++) {
4880                 (void) t_close(Nfd[cnt].fd);
4881         }
4882 
4883         (void) close(Pfd.fd);
4884 }
4885 
4886 /*
4887  * This is for the one thread that dedicates to resolve the
4888  * hostname. This will get the messages from net_poll() through
4889  * hnlq, and resolve the hostname, and push the messages back
4890  * into the inputq.
4891  */
4892 /*ARGSUSED*/
4893 static void *
4894 hostname_lookup(void *ap)
4895 {
4896         char *uap;
4897         log_message_t *mp;
4898         host_info_t *hip;
4899         char failsafe_addr[SYS_NMLN + 1];
4900         pthread_t mythreadno;
4901 
4902         if (Debug) {
4903                 mythreadno = pthread_self();
4904         }
4905 
4906         DPRINT1(1, "hostname_lookup(%u): hostname_lookup started\n",
4907             mythreadno);
4908 
4909         for (;;) {
4910                 (void) dataq_dequeue(&hnlq, (void **)&mp, 0);
4911 
4912                 DPRINT3(5, "hostname_lookup(%u): dequeued msg %p"
4913                     " from queue %p\n", mythreadno, (void *)mp,
4914                     (void *)&hnlq);
4915 
4916                 hip = (host_info_t *)mp->ptr;
4917                 if ((uap = taddr2uaddr(hip->ncp, &hip->addr)) != NULL) {
4918                         (void) strlcpy(failsafe_addr, uap, SYS_NMLN);
4919                         free(uap);
4920                 } else {
4921                         (void) strlcpy(failsafe_addr, "<unknown>", SYS_NMLN);
4922                 }
4923 
4924                 mp->hlp = cvthname(&hip->addr, hip->ncp, failsafe_addr);
4925 
4926                 if (mp->hlp == NULL) {
4927                         mp->hlp = &NullHostName;
4928                 }
4929 
4930                 free(hip->addr.buf);
4931                 free(hip);
4932                 mp->ptr = NULL;
4933 
4934                 if (dataq_enqueue(&inputq, (void *)mp) == -1) {
4935                         MALLOC_FAIL("dropping message from remote");
4936                         free_msg(mp);
4937                         continue;
4938                 }
4939 
4940                 DPRINT3(5, "hostname_lookup(%u): enqueued msg %p on queue "
4941                     "%p\n", mythreadno, (void *)mp, (void *)&inputq);
4942         }
4943 
4944         /*NOTREACHED*/
4945         return (NULL);
4946 }
4947 
4948 /*
4949  * Does all HUP(re-configuration) process.
4950  */
4951 static void
4952 reconfigure()
4953 {
4954         int cnt, loop, drops;
4955         int really_stuck;
4956         int console_stuck = 0;
4957         struct filed *f;
4958         char buf[LINE_MAX];
4959         struct utsname up;
4960         char cbuf[30];
4961         time_t tim;
4962         pthread_t mythreadno;
4963 
4964         if (Debug) {
4965                 mythreadno = pthread_self();
4966         }
4967 
4968         /* If we get here then we must need to regen */
4969         flushmsg(0);
4970 
4971         if (logmymsg(LOG_SYSLOG|LOG_INFO, "syslogd: configuration restart",
4972             ADDDATE, 0) == -1) {
4973                 MALLOC_FAIL("dropping message");
4974         }
4975 
4976         /*
4977          * make sure the logmsg thread is not in the waiting state.
4978          * Otherwise, changing hup_state will prevent the logmsg thread
4979          * getting out from the waiting loop.
4980          */
4981 
4982         if (Debug) {
4983                 tim = time(NULL);
4984                 DPRINT2(3, "reconfigure(%u): %.15s: awaiting logmsg()"
4985                     " moving to the safe place\n",
4986                     mythreadno, ctime_r(&tim, cbuf)+4);
4987         }
4988 
4989         for (loop = 0; loop < LOOP_MAX; loop++) {
4990                 /* we don't need the mutex to read */
4991                 if (hup_state == HUP_ACCEPTABLE)
4992                         break;
4993                 (void) sleep(1);
4994         }
4995         if (hup_state != HUP_ACCEPTABLE) {
4996                 goto thread_stuck;
4997         }
4998 
4999         if (Debug) {
5000                 tim = time(NULL);
5001                 DPRINT2(3, "reconfigure(%u): %.15s: logmsg() will accept HUP\n",
5002                     mythreadno, ctime_r(&tim, cbuf)+4);
5003         }
5004 
5005         /*
5006          * Prevent logging until we are truly done processing the HUP
5007          */
5008         (void) pthread_mutex_lock(&hup_lock);
5009         hup_state = HUP_INPROGRESS;
5010         (void) pthread_mutex_unlock(&hup_lock);
5011 
5012         /*
5013          * We will be going into a critical state. Any error message
5014          * from syslogd needs to be dumped to the console by default
5015          * immediately. Also, those error messages are quened in a temporary
5016          * queue to be able to post into the regular stream later.
5017          */
5018         disable_errorlog();
5019 
5020         if (Debug) {
5021                 tim = time(NULL);
5022                 DPRINT2(3, "reconfigure(%u): %.15s: sending SHUTDOWN\n",
5023                     mythreadno, ctime_r(&tim, cbuf)+4);
5024         }
5025 
5026         /* stop configured threads */
5027         if (shutdown_msg() == -1) {
5028                 /*
5029                  * No memory, message will be dumped to the console.
5030                  */
5031                 MALLOC_FAIL("unable to restart syslogd");
5032                 goto out;
5033         }
5034 
5035         /* make sure logmsg() is in suspended state */
5036         for (loop = 0; loop < LOOP_INTERVAL; loop++) {
5037                 if (hup_state & HUP_LOGMSG_SUSPENDED)
5038                         break;
5039                 (void) sleep(1);
5040         }
5041 
5042         if ((hup_state & HUP_LOGMSG_SUSPENDED) == 0) {
5043                 if (Debug) {
5044                         tim = time(NULL);
5045                         DPRINT2(3, "reconfigure(%u): %.15s: logmsg() does not "
5046                             "stop. enforcing\n",
5047                             mythreadno, ctime_r(&tim, cbuf)+4);
5048                 }
5049 
5050                 /* probably we have too long input queue, or really stuck */
5051                 (void) pthread_mutex_lock(&hup_lock);
5052                 hup_state |= HUP_SUSP_LOGMSG_REQD;
5053                 (void) pthread_mutex_unlock(&hup_lock);
5054 
5055                 for (loop = 0; loop < LOOP_MAX; loop++) {
5056                         if (hup_state & HUP_LOGMSG_SUSPENDED)
5057                                 break;
5058                         (void) sleep(1);
5059                 }
5060                 if ((hup_state & HUP_LOGMSG_SUSPENDED) == 0) {
5061                         if (Debug) {
5062                                 tim = time(NULL);
5063                                 DPRINT2(3, "reconfigure(%u): %.15s: logmsg()"
5064                                     " does not stop. give up\n",
5065                                     mythreadno, ctime_r(&tim, cbuf)+4);
5066                         }
5067                         logerror("could not suspend logmsg - fatal");
5068                         goto thread_stuck;
5069                 }
5070         }
5071 
5072         if (Debug) {
5073                 tim = time(NULL);
5074                 DPRINT2(3, "reconfigure(%u): %.15s: logmsg() suspended\n",
5075                     mythreadno, ctime_r(&tim, cbuf)+4);
5076         }
5077 
5078         /*
5079          * Will wait for LOOP_MAX secs with watching queue lengths for the
5080          * each logger threads. If they have backlogs, and no change in the
5081          * length of queue found in 30 seconds, those will be counted as
5082          * "really stuck".
5083          * If all running logger threads become "really stuck" state, there
5084          * should be no worth waiting for them to quit.
5085          * In that case, we will go ahead and close out file descriptors to
5086          * have them pull out from hanging system call, and give them a last
5087          * chance(LOOP_INTERVAL sec) to quit.
5088          */
5089 
5090         if (Debug) {
5091                 tim = time(NULL);
5092                 DPRINT2(3, "reconfigure(%u): %.15s: awaiting logit() to be"
5093                     " shutdown\n", mythreadno, ctime_r(&tim, cbuf)+4);
5094         }
5095 
5096         cnt = 0;
5097         really_stuck = 0;
5098         while (cnt < (LOOP_MAX/LOOP_INTERVAL) &&
5099             conf_threads > really_stuck) {
5100 
5101                 /* save initial queue count */
5102                 for (f = Files; f < &Files[nlogs]; f++) {
5103                         f->f_prev_queue_count = (f->f_type == F_UNUSED) ?
5104                             -1 : f->f_queue_count;
5105                 }
5106 
5107                 for (loop = 0; loop < LOOP_INTERVAL; loop++) {
5108                         if (conf_threads == 0)
5109                                 break;
5110                         (void) sleep(1);
5111                 }
5112 
5113                 if (conf_threads == 0)
5114                         break;
5115 
5116                 if (Debug) {
5117                         tim = time(NULL);
5118                         DPRINT3(3, "reconfigure(%u): %.15s: "
5119                             "%d threads are still alive.\n",
5120                             mythreadno, ctime_r(&tim, cbuf)+4,
5121                             conf_threads);
5122                 }
5123 
5124                 really_stuck = 0;
5125                 for (f = Files; f < &Files[nlogs]; f++) {
5126                         if (f->f_type == F_UNUSED) {
5127                                 f->f_prev_queue_count = -1;
5128                                 continue;
5129                         }
5130                         if (f->f_prev_queue_count == f->f_queue_count) {
5131                                 really_stuck++;
5132                                 f->f_prev_queue_count = 1;
5133                                 DPRINT2(3, "reconfigure(%u): "
5134                                     "tid=%d is really stuck.\n",
5135                                     mythreadno, f->f_thread);
5136                         } else {
5137                                 f->f_prev_queue_count = 0;
5138                                 DPRINT2(3, "reconfigure(%u): "
5139                                     "tid=%d is still active.\n",
5140                                     mythreadno, f->f_thread);
5141                         }
5142                 }
5143                 /*
5144                  * Here we have one of following values in the
5145                  * f_prev_queue_count:
5146                  *  0: logger thread is still actively working.
5147                  *  1: logger thread is really stuck.
5148                  * -1: logger thread has already died.
5149                  */
5150 
5151                 cnt++;
5152         }
5153 
5154         if (Debug) {
5155                 tim = time(NULL);
5156                 DPRINT2(3, "reconfigure(%u): %.15s:"
5157                     " complete awaiting logit()\n",
5158                     mythreadno, ctime_r(&tim, cbuf)+4);
5159                 DPRINT3(3, "reconfigure(%u): %d threads alive."
5160                     " %d threads stuck\n",
5161                     mythreadno, conf_threads, really_stuck);
5162         }
5163 
5164         /*
5165          * Still running? If so, mark it as UNUSED, and close
5166          * the fd so that logger threads can bail out from the loop.
5167          */
5168         drops = 0;
5169         if (conf_threads) {
5170                 for (f = Files; f < &Files[nlogs]; f++) {
5171                         if (f->f_type == F_CONSOLE &&
5172                             f->f_prev_queue_count == 1) {
5173                                 /* console is really stuck */
5174                                 console_stuck = 1;
5175                         }
5176                         if (f->f_type == F_USERS || f->f_type == F_WALL ||
5177                             f->f_type == F_UNUSED)
5178                                 continue;
5179                         cnt = f->f_queue_count;
5180                         drops += (cnt > 0) ? cnt - 1: 0;
5181                         f->f_type = F_UNUSED;
5182 
5183                         if (f->f_orig_type == F_FORW)
5184                                 (void) t_close(f->f_file);
5185                         else
5186                                 (void) close(f->f_file);
5187                 }
5188 
5189                 if (Debug) {
5190                         tim = time(NULL);
5191                         DPRINT1(3, "reconfigure(%u): terminating logit()\n",
5192                             mythreadno);
5193                 }
5194 
5195                 /* last chance to exit */
5196                 for (loop = 0; loop < LOOP_MAX; loop++) {
5197                         if (conf_threads == 0)
5198                                 break;
5199                         (void) sleep(1);
5200                 }
5201 
5202                 if (Debug) {
5203                         tim = time(NULL);
5204                         DPRINT3(3, "reconfigure(%u): %.15s: %d alive\n",
5205                             mythreadno, ctime_r(&tim, cbuf)+4,
5206                             conf_threads);
5207                 }
5208         }
5209 
5210         if (conf_threads == 0 && drops) {
5211                 errno = 0;
5212                 logerror("Could not completely output pending messages"
5213                     " while preparing re-configuration");
5214                 logerror("discarded %d messages and restart configuration.",
5215                     drops);
5216                 if (Debug) {
5217                         tim = time(NULL);
5218                         DPRINT3(3, "reconfigure(%u): %.15s: "
5219                             "discarded %d messages\n",
5220                             mythreadno, ctime_r(&tim, cbuf)+4, drops);
5221                 }
5222         }
5223 
5224         /*
5225          * If all threads still haven't exited
5226          * something is stuck or hosed. We just
5227          * have no option but to exit.
5228          */
5229         if (conf_threads) {
5230 thread_stuck:
5231                 if (Debug) {
5232                         tim = time(NULL);
5233                         DPRINT2(3, "reconfigure(%u): %.15s: really stuck\n",
5234                             mythreadno, ctime_r(&tim, cbuf)+4);
5235                 }
5236 
5237                 shutdown_input();
5238                 delete_doorfiles();
5239                 (void) uname(&up);
5240 
5241                 (void) snprintf(buf, sizeof (buf),
5242                     "syslogd(%s): some logger thread(s) "
5243                     "are stuck%s; syslogd is shutting down.",
5244                     up.nodename,
5245                     console_stuck ? " (including the console)" : "");
5246 
5247                 if (console_stuck) {
5248                         FILE *m = popen(MAILCMD, "w");
5249 
5250                         if (m != NULL) {
5251                                 (void) fprintf(m, "%s\n", buf);
5252                                 (void) pclose(m);
5253                         }
5254                 }
5255 
5256                 disable_errorlog();
5257                 logerror(buf);
5258                 exit(1);
5259         }
5260 
5261         /* Free up some resources */
5262         if (Files != (struct filed *)&fallback) {
5263                 for (f = Files; f < &Files[nlogs]; f++) {
5264                         (void) pthread_join(f->f_thread, NULL);
5265                         filed_destroy(f);
5266                 }
5267                 free(Files);
5268         }
5269 
5270         dealloc_stacks(nlogs);
5271 
5272         if (Debug) {
5273                 tim = time(NULL);
5274                 DPRINT2(3, "reconfigure(%u): %.15s: cleanup complete\n",
5275                     mythreadno, ctime_r(&tim, cbuf)+4);
5276         }
5277 
5278         hnc_init(1);    /* purge hostname cache */
5279         conf_init();    /* start reconfigure */
5280 
5281 out:;
5282         /* Now should be ready to dispatch error messages from syslogd. */
5283         enable_errorlog();
5284 
5285         /* Wake up the log thread */
5286 
5287         if (Debug) {
5288                 tim = time(NULL);
5289                 DPRINT2(3, "reconfigure(%u): %.15s: resuming logmsg()\n",
5290                     mythreadno, ctime_r(&tim, cbuf)+4);
5291         }
5292 
5293         (void) pthread_mutex_lock(&hup_lock);
5294         hup_state = HUP_COMPLETED;
5295         (void) pthread_cond_signal(&hup_done);
5296         (void) pthread_mutex_unlock(&hup_lock);
5297 }
5298 
5299 /*
5300  * The following function implements simple hostname cache mechanism.
5301  * Host name cache is implemented through hash table bucket chaining method.
5302  * Collisions are handled by bucket chaining.
5303  *
5304  * hnc_init():
5305  *      allocate and initialize the cache. If reinit is set,
5306  *      invalidate all cache entries.
5307  * hnc_look():
5308  *      It hashes the ipaddress gets the index and walks thru the
5309  *      single linked list. if cached entry was found, it will
5310  *      put in the head of the list, and return.While going through
5311  *      the entries, an entry which has already expired will be invalidated.
5312  * hnc_register():
5313  *      Hashes the ipaddress finds the index and puts current entry to the list.
5314  * hnc_unreg():
5315  *      invalidate the cachep.
5316  */
5317 
5318 static void
5319 hnc_init(int reinit)
5320 {
5321         struct hostname_cache **hpp;
5322         pthread_t mythreadno;
5323         int i;
5324 
5325         if (Debug) {
5326                 mythreadno = pthread_self();
5327         }
5328 
5329         if (reinit) {
5330                 (void) pthread_mutex_lock(&hnc_mutex);
5331 
5332                 for (i = 0; i < hnc_size; i++) {
5333                         for (hpp = &hnc_cache[i]; *hpp != NULL; ) {
5334                                 hnc_unreg(hpp);
5335                         }
5336                 }
5337 
5338                 (void) pthread_mutex_unlock(&hnc_mutex);
5339                 DPRINT1(2, "hnc_init(%u): hostname cache re-configured\n",
5340                     mythreadno);
5341         } else {
5342 
5343                 hnc_cache = calloc(hnc_size, sizeof (struct hostname_cache *));
5344 
5345                 if (hnc_cache == NULL) {
5346                         MALLOC_FAIL("hostname cache");
5347                         logerror("hostname cache disabled");
5348                         return;
5349                 }
5350 
5351                 DPRINT3(1, "hnc_init(%u): hostname cache configured %d entry"
5352                     " ttl:%d\n", mythreadno, hnc_size, hnc_ttl);
5353         }
5354 }
5355 
5356 static host_list_t *
5357 hnc_lookup(struct netbuf *nbp, struct netconfig *ncp, int *hindex)
5358 {
5359         struct hostname_cache **hpp, *hp;
5360         time_t now;
5361         pthread_t mythreadno;
5362         int index;
5363 
5364         if (Debug) {
5365                 mythreadno = pthread_self();
5366         }
5367 
5368         if (hnc_cache == NULL) {
5369                 return (NULL);
5370         }
5371 
5372         (void) pthread_mutex_lock(&hnc_mutex);
5373         now = time(0);
5374 
5375         *hindex = index = addr_hash(nbp);
5376 
5377         for (hpp = &hnc_cache[index]; (hp = *hpp) != NULL; ) {
5378                 DPRINT4(10, "hnc_lookup(%u): check %p on %p for %s\n",
5379                     mythreadno, (void *)hp->h, (void *)hp,
5380                     hp->h->hl_hosts[0]);
5381 
5382                 if (hp->expire < now) {
5383                         DPRINT2(9, "hnc_lookup(%u): purge %p\n",
5384                             mythreadno, (void *)hp);
5385                         hnc_unreg(hpp);
5386                         continue;
5387                 }
5388 
5389                 if (ncp == hp->ncp && same_addr(&hp->addr, nbp)) {
5390                         /*
5391                          * found!
5392                          * Put the entry at the top.
5393                          */
5394 
5395                         if (hp != hnc_cache[index]) {
5396                                 /* unlink from active list */
5397                                 *hpp = (*hpp)->next;
5398                                 /* push it onto the top */
5399                                 hp->next = hnc_cache[index];
5400                                 hnc_cache[index] = hp;
5401                         }
5402 
5403                         (void) pthread_mutex_lock(&hp->h->hl_mutex);
5404                         hp->h->hl_refcnt++;
5405                         (void) pthread_mutex_unlock(&hp->h->hl_mutex);
5406 
5407                         DPRINT4(9, "hnc_lookup(%u): found %p on %p for %s\n",
5408                             mythreadno, (void *)hp->h, (void *)hp,
5409                             hp->h->hl_hosts[0]);
5410 
5411                         (void) pthread_mutex_unlock(&hnc_mutex);
5412                         return (hp->h);
5413                 }
5414 
5415                 hpp = &hp->next;
5416         }
5417 
5418         (void) pthread_mutex_unlock(&hnc_mutex);
5419         return (NULL);
5420 }
5421 
5422 static void
5423 hnc_register(struct netbuf *nbp, struct netconfig *ncp,
5424                     host_list_t *h, int hindex)
5425 {
5426         struct hostname_cache **hpp, **tailp, *hp, *entry;
5427         void *addrbuf;
5428         time_t now;
5429         pthread_t mythreadno;
5430         int i;
5431 
5432         if (Debug) {
5433                 mythreadno = pthread_self();
5434         }
5435 
5436         if (hnc_cache == NULL) {
5437                 return;
5438         }
5439 
5440         if ((addrbuf = malloc(nbp->len)) == NULL) {
5441                 MALLOC_FAIL("pushing hostname cache");
5442                 return;
5443         }
5444 
5445         if ((entry = malloc(sizeof (struct hostname_cache))) == NULL) {
5446                 MALLOC_FAIL("pushing hostname entry");
5447                 free(addrbuf);
5448                 return;
5449         }
5450 
5451         (void) pthread_mutex_lock(&hnc_mutex);
5452 
5453         i = 0;
5454 
5455         now = time(0);
5456         /*
5457          * first go through active list, and discard the
5458          * caches which has been invalid. Count number of
5459          * non-expired buckets.
5460          */
5461 
5462         for (hpp = &hnc_cache[hindex]; (hp = *hpp) != NULL; ) {
5463                 tailp = hpp;
5464 
5465                 if (hp->expire < now) {
5466                         DPRINT2(9, "hnc_register(%u): discard %p\n",
5467                             mythreadno, (void *)hp);
5468                         hnc_unreg(hpp);
5469                 } else {
5470                         i++;
5471                         hpp = &hp->next;
5472                 }
5473         }
5474 
5475         /*
5476          * If max limit of chained hash buckets has been used up
5477          * delete the least active element in the chain.
5478          */
5479         if (i == MAX_BUCKETS) {
5480                 hnc_unreg(tailp);
5481         }
5482 
5483         (void) memcpy(addrbuf, nbp->buf, nbp->len);
5484         entry->addr.len = nbp->len;
5485         entry->addr.buf = addrbuf;
5486         entry->ncp = ncp;
5487         entry->h = h;
5488         entry->expire = time(NULL) + hnc_ttl;
5489 
5490         /* insert it at the top */
5491         entry->next = hnc_cache[hindex];
5492         hnc_cache[hindex] = entry;
5493 
5494         /*
5495          * As far as cache is valid, corresponding host_list must
5496          * also be valid. Increments the refcnt to avoid freeing
5497          * host_list.
5498          */
5499         h->hl_refcnt++;
5500         DPRINT4(9, "hnc_register(%u): reg %p onto %p for %s\n",
5501             mythreadno, (void *)entry->h, (void *)entry, entry->h->hl_hosts[0]);
5502         (void) pthread_mutex_unlock(&hnc_mutex);
5503 }
5504 
5505 static void
5506 hnc_unreg(struct hostname_cache **hpp)
5507 {
5508         struct hostname_cache *hp = *hpp;
5509         pthread_t mythreadno;
5510 
5511         if (Debug) {
5512                 mythreadno = pthread_self();
5513         }
5514 
5515         DPRINT4(9, "hnc_unreg(%u): unreg %p on %p for %s\n",
5516             mythreadno, (void *)hp->h, (void *)hp, hp->h->hl_hosts[0]);
5517         free(hp->addr.buf);
5518         freehl(hp->h);
5519 
5520         /* unlink from active list */
5521         *hpp = (*hpp)->next;
5522 
5523         free(hp);
5524 }
5525 
5526 /*
5527  * Once this is called, error messages through logerror() will go to
5528  * the console immediately. Also, messages are queued into the tmpq
5529  * to be able to later put them into inputq.
5530  */
5531 static void
5532 disable_errorlog()
5533 {
5534         (void) dataq_init(&tmpq);
5535 
5536         (void) pthread_mutex_lock(&logerror_lock);
5537         interrorlog = 0;
5538         (void) pthread_mutex_unlock(&logerror_lock);
5539 }
5540 
5541 /*
5542  * Turn internal error messages to regular input stream.
5543  * All pending messages are pulled and pushed into the regular
5544  * input queue.
5545  */
5546 static void
5547 enable_errorlog()
5548 {
5549         log_message_t *mp;
5550 
5551         (void) pthread_mutex_lock(&logerror_lock);
5552         interrorlog = 1;
5553         (void) pthread_mutex_unlock(&logerror_lock);
5554 
5555         /*
5556          * push all the pending messages into inputq.
5557          */
5558         while (dataq_dequeue(&tmpq, (void **)&mp, 1) == 0) {
5559                 (void) dataq_enqueue(&inputq, mp);
5560         }
5561         (void) dataq_destroy(&tmpq);
5562 }
5563 
5564 /*
5565  * Generate a hash value of the given address and derive
5566  * an index into the hnc_cache hashtable.
5567  * The hashing method is similar to what Java does for strings.
5568  */
5569 static int
5570 addr_hash(struct netbuf *nbp)
5571 {
5572         char *uap;
5573         int i;
5574         unsigned long hcode = 0;
5575 
5576         uap = nbp->buf;
5577 
5578         if (uap == NULL) {
5579                 return (0);
5580         }
5581 
5582         /*
5583          * Compute a hashcode of the address string
5584          */
5585         for (i = 0; i < nbp->len; i++)
5586                 hcode = (31 * hcode) + uap[i];
5587 
5588         /*
5589          * Scramble the hashcode for better distribution
5590          */
5591         hcode += ~(hcode << 9);
5592         hcode ^=  (hcode >> 14);
5593         hcode +=  (hcode << 4);
5594         hcode ^=  (hcode >> 10);
5595 
5596         return ((int)(hcode % hnc_size));
5597 }