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

Annotation of src/usr.bin/cvs/diff3.c, Revision 1.45

1.45    ! joris       1: /*     $OpenBSD: diff3.c,v 1.44 2008/02/29 21:43:57 joris Exp $        */
1.1       joris       2:
                      3: /*
                      4:  * Copyright (C) Caldera International Inc.  2001-2002.
                      5:  * All rights reserved.
                      6:  *
                      7:  * Redistribution and use in source and binary forms, with or without
                      8:  * modification, are permitted provided that the following conditions
                      9:  * are met:
                     10:  * 1. Redistributions of source code and documentation must retain the above
                     11:  *    copyright notice, this list of conditions and the following disclaimer.
                     12:  * 2. Redistributions in binary form must reproduce the above copyright
                     13:  *    notice, this list of conditions and the following disclaimer in the
                     14:  *    documentation and/or other materials provided with the distribution.
                     15:  * 3. All advertising materials mentioning features or use of this software
                     16:  *    must display the following acknowledgement:
                     17:  *     This product includes software developed or owned by Caldera
                     18:  *     International, Inc.
                     19:  * 4. Neither the name of Caldera International, Inc. nor the names of other
                     20:  *    contributors may be used to endorse or promote products derived from
                     21:  *    this software without specific prior written permission.
                     22:  *
                     23:  * USE OF THE SOFTWARE PROVIDED FOR UNDER THIS LICENSE BY CALDERA
                     24:  * INTERNATIONAL, INC. AND CONTRIBUTORS ``AS IS'' AND ANY EXPRESS OR
                     25:  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
                     26:  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
                     27:  * IN NO EVENT SHALL CALDERA INTERNATIONAL, INC. BE LIABLE FOR ANY DIRECT,
                     28:  * INDIRECT INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
                     29:  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
                     30:  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
                     31:  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
                     32:  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING
                     33:  * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
                     34:  * POSSIBILITY OF SUCH DAMAGE.
                     35:  */
                     36: /*-
                     37:  * Copyright (c) 1991, 1993
                     38:  *     The Regents of the University of California.  All rights reserved.
                     39:  *
                     40:  * Redistribution and use in source and binary forms, with or without
                     41:  * modification, are permitted provided that the following conditions
                     42:  * are met:
                     43:  * 1. Redistributions of source code must retain the above copyright
                     44:  *    notice, this list of conditions and the following disclaimer.
                     45:  * 2. Redistributions in binary form must reproduce the above copyright
                     46:  *    notice, this list of conditions and the following disclaimer in the
                     47:  *    documentation and/or other materials provided with the distribution.
                     48:  * 3. Neither the name of the University nor the names of its contributors
                     49:  *    may be used to endorse or promote products derived from this software
                     50:  *    without specific prior written permission.
                     51:  *
                     52:  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
                     53:  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
                     54:  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
                     55:  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
                     56:  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
                     57:  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
                     58:  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
                     59:  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
                     60:  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
                     61:  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
                     62:  * SUCH DAMAGE.
                     63:  *
                     64:  *     @(#)diff3.c     8.1 (Berkeley) 6/6/93
                     65:  */
                     66:
                     67: #ifndef lint
                     68: static const char copyright[] =
                     69: "@(#) Copyright (c) 1991, 1993\n\
                     70:        The Regents of the University of California.  All rights reserved.\n";
                     71: #endif /* not lint */
                     72:
                     73: #ifndef lint
1.11      reyk       74: static const char rcsid[] =
1.45    ! joris      75:     "$OpenBSD: diff3.c,v 1.44 2008/02/29 21:43:57 joris Exp $";
1.1       joris      76: #endif /* not lint */
                     77:
1.35      otto       78: #include <ctype.h>
                     79: #include <errno.h>
                     80: #include <fcntl.h>
1.38      tobias     81: #include <stdio.h>
1.35      otto       82: #include <stdlib.h>
                     83: #include <string.h>
                     84: #include <unistd.h>
1.1       joris      85:
1.39      tobias     86: #include "atomicio.h"
1.1       joris      87: #include "cvs.h"
                     88: #include "diff.h"
                     89:
                     90: /* diff3 - 3-way differential file comparison */
                     91:
                     92: /* diff3 [-ex3EX] d13 d23 f1 f2 f3 [m1 m3]
                     93:  *
                     94:  * d13 = diff report on f1 vs f3
                     95:  * d23 = diff report on f2 vs f3
                     96:  * f1, f2, f3 the 3 files
                     97:  * if changes in f1 overlap with changes in f3, m1 and m3 are used
                     98:  * to mark the overlaps; otherwise, the file names f1 and f3 are used
                     99:  * (only for options E and X).
                    100:  */
                    101:
                    102: /*
                    103:  * "from" is first in range of changed lines; "to" is last+1
                    104:  * from=to=line after point of insertion for added lines.
                    105:  */
                    106: struct range {
                    107:        int from;
                    108:        int to;
                    109: };
                    110:
                    111: struct diff {
                    112:        struct range old;
                    113:        struct range new;
                    114: };
                    115:
                    116: static size_t szchanges;
                    117:
                    118: static struct diff *d13;
                    119: static struct diff *d23;
                    120:
                    121: /*
                    122:  * "de" is used to gather editing scripts.  These are later spewed out in
                    123:  * reverse order.  Its first element must be all zero, the "new" component
                    124:  * of "de" contains line positions or byte positions depending on when you
                    125:  * look (!?).  Array overlap indicates which sections in "de" correspond to
                    126:  * lines that are different in all three files.
                    127:  */
                    128: static struct diff *de;
                    129: static char *overlap;
1.2       joris     130: static int overlapcnt = 0;
1.1       joris     131: static FILE *fp[3];
                    132: static int cline[3];           /* # of the last-read line in each file (0-2) */
                    133:
                    134: /*
                    135:  * the latest known correspondence between line numbers of the 3 files
                    136:  * is stored in last[1-3];
                    137:  */
                    138: static int last[4];
                    139: static int eflag;
                    140: static int oflag;              /* indicates whether to mark overlaps (-E or -X)*/
                    141: static int debug  = 0;
1.33      joris     142: static char f1mark[MAXPATHLEN], f3mark[MAXPATHLEN];    /* markers for -E and -X */
1.1       joris     143:
                    144: static int duplicate(struct range *, struct range *);
                    145: static int edit(struct diff *, int, int);
                    146: static char *getchange(FILE *);
                    147: static char *getline(FILE *, size_t *);
                    148: static int number(char **);
1.42      joris     149: static size_t readin(int, struct diff **);
1.1       joris     150: static int skip(int, int, char *);
                    151: static int edscript(int);
1.20      ray       152: static int merge(size_t, size_t);
1.1       joris     153: static void change(int, struct range *, int);
                    154: static void keep(int, struct range *);
                    155: static void prange(struct range *);
                    156: static void repos(int);
                    157: static void separate(const char *);
                    158: static void increase(void);
                    159: static int diff3_internal(int, char **, const char *, const char *);
                    160:
1.5       xsa       161: int diff3_conflicts = 0;
1.4       joris     162:
1.42      joris     163: static int fds[5];
                    164:
1.33      joris     165: void
                    166: cvs_merge_file(struct cvs_file *cf, int verbose)
1.1       joris     167: {
1.42      joris     168:        int i, argc;
1.1       joris     169:        char *data, *patch;
1.37      xsa       170:        char *argv[5], r1[CVS_REV_BUFSZ], r2[CVS_REV_BUFSZ];
1.28      xsa       171:        char *dp13, *dp23, *path1, *path2, *path3;
1.1       joris     172:        BUF *b1, *b2, *b3, *d1, *d2, *diffb;
1.30      niallo    173:        size_t dlen, plen;
1.33      joris     174:        struct cvs_line *lp;
                    175:        struct cvs_lines *dlines, *plines;
1.1       joris     176:
1.41      joris     177:        overlapcnt = 0;
1.1       joris     178:        b1 = b2 = b3 = d1 = d2 = diffb = NULL;
1.33      joris     179:        rcsnum_tostr(cf->file_ent->ce_rev, r1, sizeof(r1));
                    180:        rcsnum_tostr(cf->file_rcsrev, r2, sizeof(r2));
1.1       joris     181:
1.40      tobias    182:        b1 = cvs_buf_load_fd(cf->fd);
                    183:        d1 = cvs_buf_alloc(128);
                    184:        d2 = cvs_buf_alloc(128);
                    185:        diffb = cvs_buf_alloc(128);
1.1       joris     186:
1.28      xsa       187:        (void)xasprintf(&path1, "%s/diff1.XXXXXXXXXX", cvs_tmpdir);
                    188:        (void)xasprintf(&path2, "%s/diff2.XXXXXXXXXX", cvs_tmpdir);
                    189:        (void)xasprintf(&path3, "%s/diff3.XXXXXXXXXX", cvs_tmpdir);
                    190:
1.42      joris     191:        fds[2] = cvs_buf_write_stmp(b1, path1, NULL);
1.32      niallo    192:        if (verbose == 1)
                    193:                cvs_printf("Retrieving revision %s\n", r1);
1.42      joris     194:        fds[3] = rcs_rev_write_stmp(cf->file_rcs, cf->file_ent->ce_rev,
                    195:            path2, 0);
1.32      niallo    196:        if (verbose == 1)
                    197:                cvs_printf("Retrieving revision %s\n", r2);
1.42      joris     198:        fds[4] = rcs_rev_write_stmp(cf->file_rcs, cf->file_rcsrev, path3, 0);
1.1       joris     199:
1.42      joris     200:        cvs_diffreg(path1, path3, fds[2], fds[4], d1);
                    201:        cvs_diffreg(path2, path3, fds[3], fds[4], d2);
1.1       joris     202:
1.28      xsa       203:        (void)xasprintf(&dp13, "%s/d13.XXXXXXXXXX", cvs_tmpdir);
1.42      joris     204:        fds[0] = cvs_buf_write_stmp(d1, dp13, NULL);
1.1       joris     205:        cvs_buf_free(d1);
                    206:
1.28      xsa       207:        (void)xasprintf(&dp23, "%s/d23.XXXXXXXXXX", cvs_tmpdir);
1.42      joris     208:        fds[1] = cvs_buf_write_stmp(d2, dp23, NULL);
1.1       joris     209:        cvs_buf_free(d2);
                    210:
                    211:        argc = 0;
                    212:        diffbuf = diffb;
                    213:        argv[argc++] = dp13;
                    214:        argv[argc++] = dp23;
                    215:        argv[argc++] = path1;
                    216:        argv[argc++] = path2;
                    217:        argv[argc++] = path3;
1.7       joris     218:
1.42      joris     219:        if (lseek(fds[2], SEEK_SET, 0) < 0)
                    220:                fatal("cvs_merge_file: lseek fds[2]: %s", strerror(errno));
                    221:        if (lseek(fds[3], SEEK_SET, 0) < 0)
                    222:                fatal("cvs_merge_file: lseek fds[3]: %s", strerror(errno));
                    223:        if (lseek(fds[4], SEEK_SET, 0) < 0)
                    224:                fatal("cvs_merge_file: lseek fds[4]: %s", strerror(errno));
                    225:
1.33      joris     226:        diff3_conflicts = diff3_internal(argc, argv, cf->file_path, r2);
                    227:        if (diff3_conflicts < 0)
                    228:                fatal("cvs_merge_file: merging failed for an unknown reason");
1.1       joris     229:
1.30      niallo    230:        plen = cvs_buf_len(diffb);
1.1       joris     231:        patch = cvs_buf_release(diffb);
1.30      niallo    232:        dlen = cvs_buf_len(b1);
1.1       joris     233:        data = cvs_buf_release(b1);
                    234:
1.33      joris     235:        cvs_printf("Merging differences between %s and %s into `%s'\n",
                    236:            r1, r2, cf->file_path);
                    237:
                    238:        dlines = cvs_splitlines(data, dlen);
                    239:        plines = cvs_splitlines(patch, plen);
                    240:        ed_patch_lines(dlines, plines);
                    241:        cvs_freelines(plines);
1.7       joris     242:
1.23      deraadt   243:        if (verbose == 1 && diff3_conflicts != 0) {
1.24      joris     244:                cvs_log(LP_ERR, "%d conflict%s found during merge, "
1.16      xsa       245:                    "please correct.", diff3_conflicts,
1.11      reyk      246:                    (diff3_conflicts > 1) ? "s" : "");
1.7       joris     247:        }
1.1       joris     248:
1.42      joris     249:        (void)close(cf->fd);
1.45    ! joris     250:        cf->fd = open(cf->file_path, O_CREAT | O_RDWR | O_TRUNC, 0644);
1.42      joris     251:        if (cf->fd == -1) {
                    252:                fatal("cvs_merge_file: failed to reopen fd for writing: %s",
                    253:                    strerror(errno));
                    254:        }
                    255:
1.33      joris     256:        TAILQ_FOREACH(lp, &(dlines->l_lines), l_list) {
                    257:                if (lp->l_line == NULL)
                    258:                        continue;
                    259:
1.39      tobias    260:                if (atomicio(vwrite, cf->fd, lp->l_line, lp->l_len) !=
                    261:                    lp->l_len)
1.33      joris     262:                        fatal("cvs_merge_file: %s", strerror(errno));
                    263:        }
                    264:
                    265:        cvs_freelines(dlines);
                    266:
                    267:        if (data != NULL)
                    268:                xfree(data);
1.8       joris     269:        xfree(patch);
1.1       joris     270:
1.42      joris     271:        for (i = 0; i < 3; i++)
                    272:                fclose(fp[i]);
                    273:
1.1       joris     274:        (void)unlink(path1);
                    275:        (void)unlink(path2);
                    276:        (void)unlink(path3);
                    277:        (void)unlink(dp13);
                    278:        (void)unlink(dp23);
1.28      xsa       279:
1.33      joris     280:        xfree(path1);
                    281:        xfree(path2);
                    282:        xfree(path3);
                    283:        xfree(dp13);
                    284:        xfree(dp23);
1.1       joris     285: }
                    286:
                    287: static int
                    288: diff3_internal(int argc, char **argv, const char *fmark, const char *rmark)
                    289: {
1.20      ray       290:        size_t m, n;
                    291:        int i;
1.1       joris     292:
                    293:        /* XXX */
                    294:        eflag = 3;
                    295:        oflag = 1;
                    296:
                    297:        if (argc < 5)
                    298:                return (-1);
                    299:
1.34      xsa       300:        (void)xsnprintf(f1mark, sizeof(f1mark), "<<<<<<< %s", fmark);
                    301:        (void)xsnprintf(f3mark, sizeof(f3mark), ">>>>>>> %s", rmark);
1.1       joris     302:
                    303:        increase();
1.42      joris     304:
                    305:        /* fds[0] and fds[1] are closed in readin() */
                    306:        m = readin(fds[0], &d13);
                    307:        n = readin(fds[1], &d23);
1.1       joris     308:
                    309:        for (i = 0; i <= 2; i++) {
1.42      joris     310:                if ((fp[i] = fdopen(fds[i + 2], "r")) == NULL) {
1.24      joris     311:                        cvs_log(LP_ERR, "%s", argv[i + 2]);
1.1       joris     312:                        return (-1);
                    313:                }
                    314:        }
                    315:
                    316:        return (merge(m, n));
                    317: }
                    318:
                    319: int
                    320: ed_patch_lines(struct cvs_lines *dlines, struct cvs_lines *plines)
                    321: {
                    322:        char op, *ep;
1.29      xsa       323:        struct cvs_line *sort, *lp, *dlp, *ndlp, *insert_after;
1.19      xsa       324:        int start, end, i, lineno;
1.30      niallo    325:        u_char tmp;
1.1       joris     326:
                    327:        dlp = TAILQ_FIRST(&(dlines->l_lines));
                    328:        lp = TAILQ_FIRST(&(plines->l_lines));
                    329:
1.19      xsa       330:        end = 0;
1.1       joris     331:        for (lp = TAILQ_NEXT(lp, l_list); lp != NULL;
                    332:            lp = TAILQ_NEXT(lp, l_list)) {
1.30      niallo    333:                /* Skip blank lines */
                    334:                if (lp->l_len < 2)
                    335:                        continue;
                    336:                /* NUL-terminate line buffer for strtol() safety. */
                    337:                tmp = lp->l_line[lp->l_len - 1];
                    338:                lp->l_line[lp->l_len - 1] = '\0';
                    339:                /* len - 1 is NUL terminator so we use len - 2 for 'op' */
1.1       joris     340:                op = lp->l_line[strlen(lp->l_line) - 1];
                    341:                start = (int)strtol(lp->l_line, &ep, 10);
1.30      niallo    342:                /* Restore the last byte of the buffer */
                    343:                lp->l_line[lp->l_len - 1] = tmp;
1.1       joris     344:                if (op == 'a') {
1.23      deraadt   345:                        if (start > dlines->l_nblines ||
                    346:                            start < 0 || *ep != 'a')
1.15      niallo    347:                                fatal("ed_patch_lines");
1.1       joris     348:                } else if (op == 'c') {
1.23      deraadt   349:                        if (start > dlines->l_nblines ||
                    350:                            start < 0 || (*ep != ',' && *ep != 'c'))
1.15      niallo    351:                                fatal("ed_patch_lines");
1.1       joris     352:
1.2       joris     353:                        if (*ep == ',') {
                    354:                                ep++;
                    355:                                end = (int)strtol(ep, &ep, 10);
1.23      deraadt   356:                                if (end < 0 || *ep != 'c')
1.15      niallo    357:                                        fatal("ed_patch_lines");
1.2       joris     358:                        } else {
                    359:                                end = start;
                    360:                        }
1.1       joris     361:                }
                    362:
1.2       joris     363:
1.1       joris     364:                for (;;) {
                    365:                        if (dlp == NULL)
                    366:                                break;
                    367:                        if (dlp->l_lineno == start)
                    368:                                break;
                    369:                        if (dlp->l_lineno > start) {
                    370:                                dlp = TAILQ_PREV(dlp, cvs_tqh, l_list);
                    371:                        } else if (dlp->l_lineno < start) {
                    372:                                ndlp = TAILQ_NEXT(dlp, l_list);
                    373:                                if (ndlp->l_lineno > start)
                    374:                                        break;
                    375:                                dlp = ndlp;
                    376:                        }
                    377:                }
                    378:
                    379:                if (dlp == NULL)
1.15      niallo    380:                        fatal("ed_patch_lines");
1.1       joris     381:
1.2       joris     382:
1.1       joris     383:                if (op == 'c') {
1.29      xsa       384:                        insert_after = TAILQ_PREV(dlp, cvs_tqh, l_list);
1.2       joris     385:                        for (i = 0; i <= (end - start); i++) {
1.1       joris     386:                                ndlp = TAILQ_NEXT(dlp, l_list);
                    387:                                TAILQ_REMOVE(&(dlines->l_lines), dlp, l_list);
                    388:                                dlp = ndlp;
                    389:                        }
1.29      xsa       390:                        dlp = insert_after;
1.1       joris     391:                }
                    392:
                    393:                if (op == 'a' || op == 'c') {
                    394:                        for (;;) {
                    395:                                ndlp = lp;
                    396:                                lp = TAILQ_NEXT(lp, l_list);
                    397:                                if (lp == NULL)
1.15      niallo    398:                                        fatal("ed_patch_lines");
1.1       joris     399:
1.30      niallo    400:                                if (!memcmp(lp->l_line, ".", 1))
1.1       joris     401:                                        break;
                    402:
                    403:                                TAILQ_REMOVE(&(plines->l_lines), lp, l_list);
                    404:                                TAILQ_INSERT_AFTER(&(dlines->l_lines), dlp,
                    405:                                    lp, l_list);
                    406:                                dlp = lp;
                    407:
                    408:                                lp->l_lineno = start;
                    409:                                lp = ndlp;
                    410:                        }
                    411:                }
                    412:
                    413:                /*
                    414:                 * always resort lines as the markers might be put at the
                    415:                 * same line as we first started editing.
                    416:                 */
                    417:                lineno = 0;
                    418:                TAILQ_FOREACH(sort, &(dlines->l_lines), l_list)
                    419:                        sort->l_lineno = lineno++;
                    420:                dlines->l_nblines = lineno - 1;
                    421:        }
                    422:
                    423:        return (0);
                    424: }
                    425:
                    426: /*
                    427:  * Pick up the line numbers of all changes from one change file.
                    428:  * (This puts the numbers in a vector, which is not strictly necessary,
                    429:  * since the vector is processed in one sequential pass.
                    430:  * The vector could be optimized out of existence)
                    431:  */
1.20      ray       432: static size_t
1.42      joris     433: readin(int fd, struct diff **dd)
1.1       joris     434: {
                    435:        int a, b, c, d;
                    436:        char kind, *p;
                    437:        size_t i;
                    438:
1.42      joris     439:        fp[0] = fdopen(fd, "r");
                    440:        if (fp[0] == NULL)
                    441:                fatal("readin: fdopen: %s", strerror(errno));
                    442:
1.1       joris     443:        for (i = 0; (p = getchange(fp[0])); i++) {
                    444:                if (i >= szchanges - 1)
                    445:                        increase();
                    446:                a = b = number(&p);
                    447:                if (*p == ',') {
                    448:                        p++;
                    449:                        b = number(&p);
                    450:                }
                    451:                kind = *p++;
                    452:                c = d = number(&p);
                    453:                if (*p==',') {
                    454:                        p++;
                    455:                        d = number(&p);
                    456:                }
                    457:                if (kind == 'a')
                    458:                        a++;
                    459:                if (kind == 'd')
                    460:                        c++;
                    461:                b++;
                    462:                d++;
                    463:                (*dd)[i].old.from = a;
                    464:                (*dd)[i].old.to = b;
                    465:                (*dd)[i].new.from = c;
                    466:                (*dd)[i].new.to = d;
                    467:        }
                    468:
1.14      xsa       469:        if (i) {
                    470:                (*dd)[i].old.from = (*dd)[i-1].old.to;
                    471:                (*dd)[i].new.from = (*dd)[i-1].new.to;
                    472:        }
1.42      joris     473:
1.1       joris     474:        (void)fclose(fp[0]);
                    475:
                    476:        return (i);
                    477: }
                    478:
                    479: static int
                    480: number(char **lc)
                    481: {
                    482:        int nn;
                    483:
                    484:        nn = 0;
                    485:        while (isdigit((unsigned char)(**lc)))
                    486:                nn = nn*10 + *(*lc)++ - '0';
                    487:
                    488:        return (nn);
                    489: }
                    490:
                    491: static char *
                    492: getchange(FILE *b)
                    493: {
                    494:        char *line;
                    495:
                    496:        while ((line = getline(b, NULL))) {
                    497:                if (isdigit((unsigned char)line[0]))
                    498:                        return (line);
                    499:        }
                    500:
                    501:        return (NULL);
                    502: }
                    503:
                    504: static char *
                    505: getline(FILE *b, size_t *n)
                    506: {
                    507:        char *cp;
                    508:        size_t len;
                    509:        static char *buf;
                    510:        static size_t bufsize;
                    511:
                    512:        if ((cp = fgetln(b, &len)) == NULL)
                    513:                return (NULL);
                    514:
                    515:        if (cp[len - 1] != '\n')
                    516:                len++;
                    517:        if (len + 1 > bufsize) {
                    518:                do {
                    519:                        bufsize += 1024;
                    520:                } while (len + 1 > bufsize);
1.36      ray       521:                buf = xrealloc(buf, 1, bufsize);
1.1       joris     522:        }
                    523:        memcpy(buf, cp, len - 1);
                    524:        buf[len - 1] = '\n';
                    525:        buf[len] = '\0';
                    526:        if (n != NULL)
                    527:                *n = len;
                    528:
                    529:        return (buf);
                    530: }
                    531:
                    532: static int
1.20      ray       533: merge(size_t m1, size_t m2)
1.1       joris     534: {
                    535:        struct diff *d1, *d2, *d3;
                    536:        int dpl, j, t1, t2;
                    537:
                    538:        d1 = d13;
                    539:        d2 = d23;
                    540:        j = 0;
                    541:        while ((t1 = d1 < d13 + m1) | (t2 = d2 < d23 + m2)) {
                    542:                if (debug) {
                    543:                        printf("%d,%d=%d,%d %d,%d=%d,%d\n",
1.20      ray       544:                        d1->old.from, d1->old.to,
                    545:                        d1->new.from, d1->new.to,
                    546:                        d2->old.from, d2->old.to,
                    547:                        d2->new.from, d2->new.to);
1.1       joris     548:                }
                    549:
                    550:                /* first file is different from others */
                    551:                if (!t2 || (t1 && d1->new.to < d2->new.from)) {
                    552:                        /* stuff peculiar to 1st file */
                    553:                        if (eflag==0) {
                    554:                                separate("1");
                    555:                                change(1, &d1->old, 0);
                    556:                                keep(2, &d1->new);
                    557:                                change(3, &d1->new, 0);
                    558:                        }
                    559:                        d1++;
                    560:                        continue;
                    561:                }
                    562:
                    563:                /* second file is different from others */
                    564:                if (!t1 || (t2 && d2->new.to < d1->new.from)) {
                    565:                        if (eflag==0) {
                    566:                                separate("2");
                    567:                                keep(1, &d2->new);
                    568:                                change(2, &d2->old, 0);
                    569:                                change(3, &d2->new, 0);
                    570:                        }
                    571:                        d2++;
                    572:                        continue;
                    573:                }
                    574:
                    575:                /*
                    576:                 * Merge overlapping changes in first file
                    577:                 * this happens after extension (see below).
                    578:                 */
                    579:                if (d1 + 1 < d13 + m1 && d1->new.to >= d1[1].new.from) {
                    580:                        d1[1].old.from = d1->old.from;
                    581:                        d1[1].new.from = d1->new.from;
                    582:                        d1++;
                    583:                        continue;
                    584:                }
                    585:
                    586:                /* merge overlapping changes in second */
                    587:                if (d2 + 1 < d23 + m2 && d2->new.to >= d2[1].new.from) {
                    588:                        d2[1].old.from = d2->old.from;
                    589:                        d2[1].new.from = d2->new.from;
                    590:                        d2++;
                    591:                        continue;
                    592:                }
                    593:                /* stuff peculiar to third file or different in all */
                    594:                if (d1->new.from == d2->new.from && d1->new.to == d2->new.to) {
                    595:                        dpl = duplicate(&d1->old,&d2->old);
                    596:                        if (dpl == -1)
                    597:                                return (-1);
                    598:
                    599:                        /*
                    600:                         * dpl = 0 means all files differ
                    601:                         * dpl = 1 means files 1 and 2 identical
                    602:                         */
                    603:                        if (eflag==0) {
                    604:                                separate(dpl ? "3" : "");
                    605:                                change(1, &d1->old, dpl);
                    606:                                change(2, &d2->old, 0);
                    607:                                d3 = d1->old.to > d1->old.from ? d1 : d2;
                    608:                                change(3, &d3->new, 0);
                    609:                        } else
                    610:                                j = edit(d1, dpl, j);
                    611:                        d1++;
                    612:                        d2++;
                    613:                        continue;
                    614:                }
                    615:
                    616:                /*
                    617:                 * Overlapping changes from file 1 and 2; extend changes
                    618:                 * appropriately to make them coincide.
                    619:                 */
                    620:                if (d1->new.from < d2->new.from) {
                    621:                        d2->old.from -= d2->new.from-d1->new.from;
                    622:                        d2->new.from = d1->new.from;
                    623:                } else if (d2->new.from < d1->new.from) {
                    624:                        d1->old.from -= d1->new.from-d2->new.from;
                    625:                        d1->new.from = d2->new.from;
                    626:                }
                    627:                if (d1->new.to > d2->new.to) {
                    628:                        d2->old.to += d1->new.to - d2->new.to;
                    629:                        d2->new.to = d1->new.to;
                    630:                } else if (d2->new.to > d1->new.to) {
                    631:                        d1->old.to += d2->new.to - d1->new.to;
                    632:                        d1->new.to = d2->new.to;
                    633:                }
                    634:        }
                    635:
                    636:        return (edscript(j));
                    637: }
                    638:
                    639: static void
                    640: separate(const char *s)
                    641: {
                    642:        diff_output("====%s\n", s);
                    643: }
                    644:
                    645: /*
                    646:  * The range of lines rold.from thru rold.to in file i is to be changed.
                    647:  * It is to be printed only if it does not duplicate something to be
                    648:  * printed later.
                    649:  */
                    650: static void
                    651: change(int i, struct range *rold, int fdup)
                    652: {
                    653:        diff_output("%d:", i);
                    654:        last[i] = rold->to;
                    655:        prange(rold);
                    656:        if (fdup || debug)
                    657:                return;
                    658:        i--;
                    659:        (void)skip(i, rold->from, NULL);
                    660:        (void)skip(i, rold->to, "  ");
                    661: }
                    662:
                    663: /*
                    664:  * print the range of line numbers, rold.from thru rold.to, as n1,n2 or n1
                    665:  */
                    666: static void
                    667: prange(struct range *rold)
                    668: {
                    669:        if (rold->to <= rold->from)
                    670:                diff_output("%da\n", rold->from - 1);
                    671:        else {
                    672:                diff_output("%d", rold->from);
                    673:                if (rold->to > rold->from+1)
                    674:                        diff_output(",%d", rold->to - 1);
                    675:                diff_output("c\n");
                    676:        }
                    677: }
                    678:
                    679: /*
                    680:  * No difference was reported by diff between file 1 (or 2) and file 3,
                    681:  * and an artificial dummy difference (trange) must be ginned up to
                    682:  * correspond to the change reported in the other file.
                    683:  */
                    684: static void
                    685: keep(int i, struct range *rnew)
                    686: {
                    687:        int delta;
                    688:        struct range trange;
                    689:
                    690:        delta = last[3] - last[i];
                    691:        trange.from = rnew->from - delta;
                    692:        trange.to = rnew->to - delta;
                    693:        change(i, &trange, 1);
                    694: }
                    695:
                    696: /*
                    697:  * skip to just before line number from in file "i".  If "pr" is non-NULL,
                    698:  * print all skipped stuff with string pr as a prefix.
                    699:  */
                    700: static int
                    701: skip(int i, int from, char *pr)
                    702: {
                    703:        size_t j, n;
                    704:        char *line;
                    705:
                    706:        for (n = 0; cline[i] < from - 1; n += j) {
                    707:                if ((line = getline(fp[i], &j)) == NULL)
                    708:                        return (-1);
                    709:                if (pr != NULL)
                    710:                        diff_output("%s%s", pr, line);
                    711:                cline[i]++;
                    712:        }
                    713:        return ((int) n);
                    714: }
                    715:
                    716: /*
                    717:  * Return 1 or 0 according as the old range (in file 1) contains exactly
                    718:  * the same data as the new range (in file 2).
                    719:  */
                    720: static int
                    721: duplicate(struct range *r1, struct range *r2)
                    722: {
                    723:        int c,d;
                    724:        int nchar;
                    725:        int nline;
                    726:
                    727:        if (r1->to-r1->from != r2->to-r2->from)
                    728:                return (0);
                    729:        (void)skip(0, r1->from, NULL);
                    730:        (void)skip(1, r2->from, NULL);
                    731:        nchar = 0;
                    732:        for (nline=0; nline < r1->to - r1->from; nline++) {
                    733:                do {
                    734:                        c = getc(fp[0]);
                    735:                        d = getc(fp[1]);
                    736:                        if (c == -1 || d== -1)
                    737:                                return (-1);
                    738:                        nchar++;
                    739:                        if (c != d) {
                    740:                                repos(nchar);
                    741:                                return (0);
                    742:                        }
                    743:                } while (c != '\n');
                    744:        }
                    745:        repos(nchar);
                    746:        return (1);
                    747: }
                    748:
                    749: static void
                    750: repos(int nchar)
                    751: {
                    752:        int i;
                    753:
                    754:        for (i = 0; i < 2; i++)
1.38      tobias    755:                (void)fseek(fp[i], (long)-nchar, SEEK_CUR);
1.1       joris     756: }
                    757:
                    758: /*
                    759:  * collect an editing script for later regurgitation
                    760:  */
                    761: static int
                    762: edit(struct diff *diff, int fdup, int j)
                    763: {
                    764:        if (((fdup + 1) & eflag) == 0)
                    765:                return (j);
                    766:        j++;
                    767:        overlap[j] = !fdup;
                    768:        if (!fdup)
                    769:                overlapcnt++;
                    770:        de[j].old.from = diff->old.from;
                    771:        de[j].old.to = diff->old.to;
                    772:        de[j].new.from = de[j-1].new.to + skip(2, diff->new.from, NULL);
                    773:        de[j].new.to = de[j].new.from + skip(2, diff->new.to, NULL);
                    774:        return (j);
                    775: }
                    776:
                    777: /* regurgitate */
                    778: static int
                    779: edscript(int n)
                    780: {
                    781:        int j, k;
1.2       joris     782:        char block[BUFSIZ+1];
1.1       joris     783:
                    784:        for (n = n; n > 0; n--) {
                    785:                if (!oflag || !overlap[n])
                    786:                        prange(&de[n].old);
                    787:                else
                    788:                        diff_output("%da\n=======\n", de[n].old.to -1);
1.38      tobias    789:                (void)fseek(fp[2], (long)de[n].new.from, SEEK_SET);
1.1       joris     790:                for (k = de[n].new.to-de[n].new.from; k > 0; k-= j) {
                    791:                        j = k > BUFSIZ ? BUFSIZ : k;
1.11      reyk      792:                        if (fread(block, (size_t)1, (size_t)j,
                    793:                            fp[2]) != (size_t)j)
1.1       joris     794:                                return (-1);
                    795:                        block[j] = '\0';
                    796:                        diff_output("%s", block);
                    797:                }
1.2       joris     798:
1.1       joris     799:                if (!oflag || !overlap[n])
                    800:                        diff_output(".\n");
                    801:                else {
                    802:                        diff_output("%s\n.\n", f3mark);
                    803:                        diff_output("%da\n%s\n.\n", de[n].old.from - 1, f1mark);
                    804:                }
                    805:        }
                    806:
                    807:        return (overlapcnt);
                    808: }
                    809:
                    810: static void
                    811: increase(void)
                    812: {
                    813:        size_t newsz, incr;
                    814:
                    815:        /* are the memset(3) calls needed? */
                    816:        newsz = szchanges == 0 ? 64 : 2 * szchanges;
                    817:        incr = newsz - szchanges;
                    818:
1.36      ray       819:        d13 = xrealloc(d13, newsz, sizeof(*d13));
                    820:        memset(d13 + szchanges, 0, incr * sizeof(*d13));
                    821:        d23 = xrealloc(d23, newsz, sizeof(*d23));
                    822:        memset(d23 + szchanges, 0, incr * sizeof(*d23));
                    823:        de = xrealloc(de, newsz, sizeof(*de));
                    824:        memset(de + szchanges, 0, incr * sizeof(*de));
                    825:        overlap = xrealloc(overlap, newsz, sizeof(*overlap));
                    826:        memset(overlap + szchanges, 0, incr * sizeof(*overlap));
1.1       joris     827:        szchanges = newsz;
                    828: }