Bell 32V release

[unix-history] / usr / src / cmd / paste.c

#
/* paste: concatenate corresponding lines of each file in parallel(GWRL) */
/*      (-s option: serial concatenation like old (127's) paste command */
/* make :  cc paste.c -lS */
# include <stdio.h>
# define MAXOPNF 12     /* maximal no. of open files (not with -s option) */
# define MAXLINE 512    /* maximal line length */
#define RUB  '\177'
       char del[MAXLINE] = {"\t"};
 
main(argc, argv)
int argc;
char ** argv;
{
       int i, j, k, eofcount, nfiles;
       int delcount = { 1 } ;
       int onefile  = { 0 } ;
       char outbuf[MAXLINE], c, l ;
       register char *p;
       FILE *inptr[MAXOPNF];
 
       while (argc > 1 && argv[1][0] == '-' && (c = argv[1][1]) != '\0'){
               switch (c) {
                       case 's' :  onefile++;
                               c = argv[1][2];
                               argv[1]++;
                               break ;
                       case 'd' : argv[1] += 2;
                               if((delcount = move(argv[1], &del[0])) == 0) diag("no delimiters\n",1);;
                               break;
                       default :
                               diag("Usage: paste [-s] [-d<delimiterstring>] file1 file2 ...", 1);
                               break;
               }
               --argc;
               ++argv;
       } /* end options */
       --argc;

       if ( ! onefile) {       /* not -s option: parallel line merging */
               for (i = 0; argc >0 && i < MAXOPNF; i++) {
                       if (argv[i + 1][0] == '-') {
                               inptr[i] = stdin;
                       } else inptr[i] = fopen(argv[i + 1], "r");
                       if (inptr[i] == NULL) {
                               diag(argv[i + 1], 0);
                               diag(" : cannot open\n", 1);
                       }
               argc--;
               }
               if (argc > 0) diag("too many files\n",1);
               nfiles = i;
 
               do {
                       p = &outbuf[0];
                       eofcount = 0;
                       j = k = 0;
                       for (i = 0; i < nfiles; i++) {
                               while((c = getc(inptr[i])) != '\n' && c != EOF)   {
                                       if (++j <= MAXLINE - 2) *p++ = c ;
                                       else {
                                       diag("line too long\n",1);
                                       }
                               }
                               if ( (l = del[k]) != RUB) *p++ = l;
                               k = (k + 1) % delcount;
                               if( c == EOF) eofcount++;
                       }
                       if (l != RUB) *--p = '\n'; else  *p = '\n';
                       *++p = 0;
                       if (eofcount < nfiles) fputs(outbuf, stdout);
               }while (eofcount < nfiles);
 
       } else {        /* -s option: serial file pasting (old 127 paste command) */
               p = &outbuf[0];
               j = 0;
               k = 0;
               for (i = 1; i <= argc; i++) {
                       if (argv[i][0] == '-') {
                               inptr[0] = stdin;
                       } else inptr[0] = fopen(argv[i], "r");
                       if (inptr[0] == NULL) {
                               diag(argv[i], 0);
                               diag(" : cannot open\n", 1);
                       }
         
                       while((c = getc(inptr[0])) != EOF)   {
                               if(c != '\n') {
                                       if (++j <= MAXLINE - 2) *p++ = c ;
                                       else diag("line too long\n",1);
                               } else {
                                       l = del[k];
                                       if (l != RUB) *p++ = l ;
                                       k = (k + 1) % delcount;
                                       *p = 0;
                                       fputs(outbuf, stdout);
                                       p = &outbuf[0];
                                       j = 0;
                               }
                       }
               }
               if (l != '\n') fputs("\n", stdout);
       }
}
diag(s,r)
char *s;
int r;
{
       write(2, "paste : ", 8);
       while(*s)write(2,s++,1);
       if(r != 0) exit(r);
}
 
move(from, to)
char *from, *to;
{
int c, i;
       i = 0;
       do {
               c = *from++;
               i++;
               if (c != '\\') *to++ = c;
               else { c = *from++;
                       switch (c) {
                               case '0' : *to++ = RUB;
                                               break;
                               case 't' : *to++ = '\t';
                                               break;
                               case 'n' : *to++ = '\n';
                                               break;
                               default  : *to++ = c;
                                               break;
                       }
               }
       } while (c) ;
return(--i);
}