source: trunk/athena/bin/lpr/common.c @ 10545

/*
 * Copyright (c) 1983 Regents of the University of California.
 * All rights reserved.  The Berkeley software License Agreement
 * specifies the terms and conditions for redistribution.
 */

#ifndef lint
static char sccsid[] = "@(#)common.c    5.2 (Berkeley) 5/6/86";
#endif /* not lint */

/*
 * Routines and data common to all the line printer functions.
 */

#include "lp.h"
#ifdef POSIX
#include <stdlib.h>
#endif
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/param.h>
#include <string.h>


int     DU;             /* daeomon user-id */
int     MX;             /* maximum number of blocks to copy */
int     MC;             /* maximum number of copies allowed */
char    *LP;            /* line printer device name */
char    *RM;            /* remote machine name */
char    *RP;            /* remote printer name */
char    *LO;            /* lock file name */
char    *ST;            /* status file name */
char    *SD;            /* spool directory */
char    *AF;            /* accounting file */
char    *LF;            /* log file for error messages */
char    *OF;            /* name of output filter (created once) */
char    *IF;            /* name of input filter (created per job) */
char    *RF;            /* name of fortran text filter (per job) */
char    *TF;            /* name of troff filter (per job) */
char    *NF;            /* name of ditroff filter (per job) */
char    *DF;            /* name of tex filter (per job) */
char    *GF;            /* name of graph(1G) filter (per job) */
char    *VF;            /* name of vplot filter (per job) */
char    *CF;            /* name of cifplot filter (per job) */
char    *PF;            /* name of vrast filter (per job) */
char    *FF;            /* form feed string */
char    *TR;            /* trailer string to be output when Q empties */
char    *MS;            /* list of tty modes to set or clear */
short   SC;             /* suppress multiple copies */
short   SF;             /* suppress FF on each print job */
short   SH;             /* suppress header page */
short   SB;             /* short banner instead of normal header */
short   HL;             /* print header last */
short   RW;             /* open LP for reading and writing */
short   PW;             /* page width */
short   PL;             /* page length */
short   PX;             /* page width in pixels */
short   PY;             /* page length in pixels */
short   BR;             /* baud rate if lp is a tty */
int     FC;             /* flags to clear if lp is a tty */
int     FS;             /* flags to set if lp is a tty */
int     XC;             /* flags to clear for local mode */
int     XS;             /* flags to set for local mode */
short   RS;             /* restricted to those with local accounts */
#ifdef PQUOTA
char    *RQ;            /* Name of remote quota server */
int     CP;             /* Cost per page */
char    *QS;            /* Quota service for printer */
#endif /* PQUOTA */
#ifdef LACL
char    *AC;            /* Local ACL file to use */
short   PA;             /* ACL file used as positive ACL */
short   RA;             /* Restricted host access */
#endif /* LACL */

char    line[BUFSIZ];
char    pbuf[BUFSIZ * 16];      /* buffer for printcap strings */
char    *bp = pbuf;     /* pointer into pbuf for pgetent() */
char    *name;          /* program name */
char    *printer;       /* printer name */
char    host[MAXHOSTNAMELEN + 1]="";    /* host machine name */
char    *from = host;   /* client's machine name */
#ifdef HESIOD
char    alibuf[BUFSIZ/2];       /* buffer for printer alias */
#endif

#ifdef SOLARIS
/*
 * The DIRSIZ macro is the minimum record length which will hold the directory
 * entry. sizeof(dirent) includes a byte for the null termination, so 1 need
 * not be added to the strlen().
 */
#undef DIRSIZ
#define DIRSIZ(dp) ((sizeof (struct dirent)) + strlen(dp->d_name))

int
scandir(dirname, namelist, select, dcomp)
        char *dirname;
        struct dirent ***namelist;
        int (*select)(), (*dcomp)();
{
        register struct dirent *d, *p, **names;
        register size_t nitems;
        struct stat stb;
        long arraysz;
        DIR *dirp;

        if ((dirp = opendir(dirname)) == NULL)
                return(-1);
        if (fstat(dirp->dd_fd, &stb) < 0)
                return(-1);

        /*
         * estimate the array size by taking the size of the directory file
         * and dividing it by a multiple of the minimum size entry. 
         */
        arraysz = (stb.st_size / 24);
        names = (struct dirent **)malloc(arraysz * sizeof(struct dirent *));
        if (names == NULL)
                return(-1);

        nitems = 0;
        while ((d = readdir(dirp)) != NULL) {
                if (select != NULL && !(*select)(d))
                        continue;       /* just selected names */
                /*
                 * Make a minimum size copy of the data
                 */
                p = (struct dirent *)malloc(DIRSIZ(d));
                if (p == NULL)
                        return(-1);
                p->d_ino = d->d_ino;
                p->d_reclen = d->d_reclen;
/*              p->d_namlen = d->d_namlen; */
                memcpy(p->d_name, d->d_name, strlen(d->d_name)+1 );
                /*
                 * Check to make sure the array has space left and
                 * realloc the maximum size.
                 */
                if (++nitems >= arraysz) {
                        if (fstat(dirp->dd_fd, &stb) < 0)
                                return(-1);     /* just might have grown */
                        arraysz = stb.st_size / 12;
                        names = (struct dirent **)realloc((char *)names,
                                arraysz * sizeof(struct dirent *));
                        if (names == NULL)
                                return(-1);
                }
                names[nitems-1] = p;
        }
        closedir(dirp);
        if (nitems && dcomp != NULL)
                qsort(names, nitems, sizeof(struct dirent *), dcomp);
        *namelist = names;
        return(nitems);
}


/*
 * Alphabetic order comparison routine for those who want it.
 */
int
alphasort(d1, d2)
        void *d1;
        void *d2;
{
        return(strcmp((*(struct dirent **)d1)->d_name,
            (*(struct dirent **)d2)->d_name));
}
/*
 * File locking is not available via flock() but we can make one
 */
#define   LOCK_SH   1    /* shared lock */
#define   LOCK_EX   2    /* exclusive lock */
#define   LOCK_NB   4    /* don't block when locking */
#define   LOCK_UN   8    /* unlock */

#include <fcntl.h>
#include <stdio.h>      /* SEEK_SET */

int
flock(int fd, int operation)
{
   struct flock lock;

   lock.l_type = F_RDLCK;
   if (operation & LOCK_EX) lock.l_type = F_WRLCK;
   else if (operation & LOCK_UN) lock.l_type = F_UNLCK;

   lock.l_start = lock.l_len = 0;
   lock.l_whence = SEEK_SET;
   return fcntl(fd, operation & LOCK_NB? F_SETLK: F_SETLKW, &lock);
}
#endif /* SOLARIS */

#if defined(POSIX) && !defined(ultrix) 
#include <signal.h>
typedef void    Sigfunc(int);   /* for signal handlers */

                /* 4.3BSD Reno <signal.h> doesn't define SIG_ERR */
#if     defined(SIG_IGN) && !defined(SIG_ERR)
#define SIG_ERR ((Sigfunc *)-1)
#endif

/* Reliable signal()s (Stevens: Advanced UNIX PRG, pp. 298) */

Sigfunc *
signal(int signo, Sigfunc *func)
{
   struct sigaction act, oact;

   act.sa_handler = func;
   sigemptyset(&act.sa_mask);
   act.sa_flags = 0;
   if (signo == SIGALRM) {
#ifdef SA_INTERRUPT
      act.sa_flags |= SA_INTERRUPT;     /* SunOS */
#endif
   }
   else {
#ifdef SA_RESTART
      act.sa_flags |= SA_RESTART;       /* SVR4, 4.3+BSD */
#endif
   }
   if (sigaction(signo, &act, &oact) < 0)
      return SIG_ERR;
   return oact.sa_handler;
}

#endif /* POSIX !ultrix  */
/*
 * Compare modification times.
 */
static
compar(p1, p2)
        register struct queue_ **p1, **p2;
{
        if ((*p1)->q_time < (*p2)->q_time)
                return(-1);
        if ((*p1)->q_time > (*p2)->q_time)
                return(1);
        return(0);
}

/*
 * Create a connection to the remote printer server.
 * Most of this code comes from rcmd.c.
 */
getport(rhost)
        char *rhost;
{
        struct hostent *hp;
        struct servent *sp;
        struct sockaddr_in sin;
        int s, timo = 1, lport = IPPORT_RESERVED - 1;
        int err;

        /*
         * Get the host address and port number to connect to.
         */
        if (rhost == NULL)
                fatal("no remote host to connect to");
        hp = gethostbyname(rhost);
        if (hp == NULL)
                fatal("unknown host %s", rhost);
        sp = getservbyname("printer", "tcp");
        if (sp == NULL)
                fatal("printer/tcp: unknown service");
        memset((char *)&sin, 0, sizeof(sin));
        memcpy((caddr_t)&sin.sin_addr, hp->h_addr, sizeof(sin.sin_addr));
        sin.sin_family = hp->h_addrtype;
        sin.sin_port = sp->s_port;

        /*
         * Try connecting to the server.
         */
retry:
        s = rresvport(&lport);

        if (s < 0)
                return(-1);
        if (connect(s, (struct sockaddr *)&sin, sizeof(sin)) < 0) {

                err = errno;
                (void) close(s);
                errno = err;
                if (errno == EADDRINUSE) {
                        lport--;
                        goto retry;
                }
                if (errno == ECONNREFUSED && timo <= 8) {
                        sleep(timo);
                        timo *= 2;
                        goto retry;
                }
                return(-1);
        }
        return(s);
}

/*
 * Getline reads a line from the control file cfp, removes tabs, converts
 *  new-line to null and leaves it in line.
 * Returns 0 at EOF or the number of characters read.
 */
getline(cfp)
        FILE *cfp;
{
        register int linel = 0;
        register char *lp = line;
        register c;

        while ((c = getc(cfp)) != '\n' && linel < BUFSIZ-8) {
                if (c == EOF)
                        return(0);
                if (c == '\t') {
                        do {
                                *lp++ = ' ';
                                linel++;
                        } while ((linel & 07) != 0);
                        continue;
                }
                *lp++ = c;
                linel++;
        }
        *lp++ = '\0';
        return(linel);
}

/*
 * Scan the current directory and make a list of daemon files sorted by
 * creation time.
 * Return the number of entries and a pointer to the list.
 */
getq_(namelist)
        struct queue_ *(*namelist[]);
{
#ifdef POSIX
        register struct dirent *d;
#else
        register struct direct *d;
#endif
        register struct queue_ *q, **queue;
        register int nitems;
        struct stat stbuf;
        int arraysz, compar();
        DIR *dirp;

        if ((dirp = opendir(SD)) == NULL) 
                return(-1);

        if (fstat(dirp->dd_fd, &stbuf) < 0) 
                goto errdone;

        /*
         * Estimate the array size by taking the size of the directory file
         * and dividing it by a multiple of the minimum size entry. 
         */
        arraysz = (stbuf.st_size / 24);
        queue = (struct queue_ **)malloc(arraysz * sizeof(struct queue_ *));
        if (queue == NULL)
                goto errdone;

        nitems = 0;

        while ((d = readdir(dirp)) != NULL) {

                if (d->d_name[0] != 'c' || d->d_name[1] != 'f') 
                        continue;       /* daemon control files only */

                if (stat(d->d_name, &stbuf) < 0) 
                        continue;       /* Doesn't exist */


                q = (struct queue_ *)malloc(sizeof(time_t)+strlen(d->d_name)+1);
                if (q == NULL)
                        goto errdone;
                q->q_time = stbuf.st_mtime;
                strcpy(q->q_name, d->d_name);

                /*
                 * Check to make sure the array has space left and
                 * realloc the maximum size.
                 */
                if (++nitems > arraysz) {
                        queue = (struct queue_ **)realloc((char *)queue,
                                (stbuf.st_size/12) * sizeof(struct queue_ *));
                        if (queue == NULL)
                                goto errdone;
                }
                queue[nitems-1] = q;
        }
        closedir(dirp);
        if (nitems)
                qsort(queue, nitems, sizeof(struct queue_ *), compar);
        *namelist = queue;
        return(nitems);

errdone:
        closedir(dirp);
        return(-1);
}


/*VARARGS1*/
fatal(msg, a1, a2, a3)
        char *msg;
{
        if (from != host)
                printf("%s: ", host);
        printf("%s: ", name);
        if (printer)
                printf("%s: ", printer);
        printf(msg, a1, a2, a3);
        syslog(LOG_ERR, msg, a1, a2, a3);
        putchar('\n');
        exit(1);
}

#ifdef KERBEROS
/* Form a complete string name consisting of principal, 
 * instance and realm 
 */
make_kname(principal, instance, realm, out_name)
char *principal, *instance, *realm, *out_name;
{
        if ((instance[0] == '\0') && (realm[0] == '\0'))
                strcpy(out_name, principal);
        else {
                if (realm[0] == '\0')
                        sprintf(out_name, "%s.%s", principal, instance);
                else {
                        if (instance[0] == '\0')
                                sprintf(out_name, "%s@%s", principal, realm);
                        else
                                sprintf(out_name, "%s.%s@%s", principal, 
                                        instance, realm);
                }
        }
}
#endif /* KERBEROS */