[BACK]Return to join.c CVS log [TXT][DIR] Up to [local] / src / usr.bin / join

Diff for /src/usr.bin/join/join.c between version 1.28 and 1.29

version 1.28, 2018/07/18 17:20:54 version 1.29, 2018/10/18 09:36:48
Line 53 
Line 53 
         char **fields;                  /* line field(s) */          char **fields;                  /* line field(s) */
         u_long fieldcnt;                /* line field(s) count */          u_long fieldcnt;                /* line field(s) count */
         u_long fieldalloc;              /* line field(s) allocated count */          u_long fieldalloc;              /* line field(s) allocated count */
         u_long cfieldc;                 /* current field count */  
         long     fpos;                  /* fpos of start of field */  
 } LINE;  } LINE;
   
 typedef struct {  typedef struct {
Line 67 
Line 65 
         u_long pushback;                /* line on the stack */          u_long pushback;                /* line on the stack */
         u_long setcnt;                  /* set count */          u_long setcnt;                  /* set count */
         u_long setalloc;                /* set allocated count */          u_long setalloc;                /* set allocated count */
         u_long setusedc;                /* sets used  */  
 } INPUT;  } INPUT;
 INPUT input1 = { NULL, 0, 0, 1, NULL, 0, 0, 0, 0, 0 },  INPUT input1 = { NULL, 0, 0, 1, NULL, 0, 0, 0, 0 },
       input2 = { NULL, 0, 0, 2, NULL, 0, 0, 0, 0, 0 };        input2 = { NULL, 0, 0, 2, NULL, 0, 0, 0, 0 };
   
 typedef struct {  typedef struct {
         u_long  filenum;        /* file number */          u_long  filenum;        /* file number */
Line 214 
Line 211 
         if (pledge("stdio", NULL) == -1)          if (pledge("stdio", NULL) == -1)
                 err(1, "pledge");                  err(1, "pledge");
   
         F1->setusedc = 0;  
         F2->setusedc = 0;  
         slurp(F1);          slurp(F1);
         slurp(F2);          slurp(F2);
         F1->set->cfieldc = 0;  
         F2->set->cfieldc = 0;  
   
         /*          /*
          * We try to let the files have the same field value, advancing           * We try to let the files have the same field value, advancing
Line 234 
Line 227 
                                 joinlines(F1, F2);                                  joinlines(F1, F2);
                         slurp(F1);                          slurp(F1);
                         slurp(F2);                          slurp(F2);
                 }                  } else if (cval < 0) {
                 else {                          /* File 1 takes the lead... */
                         if (F1->unpair                          if (F1->unpair)
                         && (cval < 0 || F2->set->cfieldc == F2->setusedc -1)) {  
                                 joinlines(F1, NULL);                                  joinlines(F1, NULL);
                                 slurp(F1);                          slurp(F1);
                         }                  } else {
                         else if (cval < 0)                          /* File 2 takes the lead... */
                                 /* File 1 takes the lead... */                          if (F2->unpair)
                                 slurp(F1);  
                         if (F2->unpair  
                         && (cval > 0 || F1->set->cfieldc == F1->setusedc -1)) {  
                                 joinlines(F2, NULL);                                  joinlines(F2, NULL);
                                 slurp(F2);                          slurp(F2);
                         }  
                         else if (cval > 0)  
                                 /* File 2 takes the lead... */  
                                 slurp(F2);  
                 }                  }
         }          }
   
Line 273 
Line 258 
         return 0;          return 0;
 }  }
   
 /* wrapper around slurpit() to keep track of what field we are on */  
 void slurp(INPUT *F)  
 {  
         long fpos;  
         u_long cfieldc;  
   
         if (F->set == NULL) {  
                 fpos = 0;  
                 cfieldc = 0;  
         }  
         else {  
                 fpos = F->set->fpos;  
                 cfieldc = F->set->cfieldc;  
         }  
         slurpit(F);  
         if (F->set == NULL)  
                 return;  
         else if (fpos != F->set->fpos)  
                 F->set->cfieldc = cfieldc+1;  
 }  
   
 void  void
 slurpit(INPUT *F)  slurp(INPUT *F)
 {  {
         LINE *lp, *lastlp, tmp;          LINE *lp, *lastlp, tmp;
         ssize_t len;          ssize_t len;
         size_t linesize;          size_t linesize;
         u_long cnt;          u_long cnt;
         char *bp, *fieldp, *line;          char *bp, *fieldp, *line;
         long fpos;  
         /*          /*
          * Read all of the lines from an input file that have the same           * Read all of the lines from an input file that have the same
          * join field.           * join field.
Line 311 
Line 275 
         F->setcnt = 0;          F->setcnt = 0;
         line = NULL;          line = NULL;
         linesize = 0;          linesize = 0;
         for (lastlp = NULL; ; ++F->setcnt, lastlp = lp) {          for (lastlp = NULL; ; ++F->setcnt) {
                 /*                  /*
                  * If we're out of space to hold line structures, allocate                   * If we're out of space to hold line structures, allocate
                  * more.  Initialize the structure so that we know that this                   * more.  Initialize the structure so that we know that this
Line 339 
Line 303 
                  * level of indirection, but it's probably okay as is.                   * level of indirection, but it's probably okay as is.
                  */                   */
                 lp = &F->set[F->setcnt];                  lp = &F->set[F->setcnt];
                   if (F->setcnt)
                           lastlp = &F->set[F->setcnt - 1];
                 if (F->pushbool) {                  if (F->pushbool) {
                         tmp = F->set[F->setcnt];                          tmp = F->set[F->setcnt];
                         F->set[F->setcnt] = F->set[F->pushback];                          F->set[F->setcnt] = F->set[F->pushback];
Line 348 
Line 314 
                 }                  }
                 if ((len = getline(&line, &linesize, F->fp)) == -1)                  if ((len = getline(&line, &linesize, F->fp)) == -1)
                         break;                          break;
                 /*  
                  * we depend on knowing on what field we are, one safe way is  
                  * the file position.  
                 */  
                 fpos = ftell(F->fp) - len;  
   
                 /* Remove trailing newline, if it exists, and copy line. */                  /* Remove trailing newline, if it exists, and copy line. */
                 if (line[len - 1] == '\n')                  if (line[len - 1] == '\n')
Line 366 
Line 327 
                         lp->line = p;                          lp->line = p;
                         lp->linealloc = newsize;                          lp->linealloc = newsize;
                 }                  }
                 F->setusedc++;  
                 memcpy(lp->line, line, len);                  memcpy(lp->line, line, len);
                 lp->line[len] = '\0';                  lp->line[len] = '\0';
                 lp->fpos = fpos;  
   
                 /* Split the line into fields, allocate space as necessary. */                  /* Split the line into fields, allocate space as necessary. */
                 lp->fieldcnt = 0;                  lp->fieldcnt = 0;
Legend:
Removed from v.1.28  
changed lines
  Added in v.1.29