X-Git-Url: https://mattmccutchen.net/rsync/rsync.git/blobdiff_plain/a261989cda6f671352e6323f11d2d98e923c622e..67684d038de4c18431af0ccc17f55efbf4f20eb8:/match.c diff --git a/match.c b/match.c index adc298e7..292c537e 100644 --- a/match.c +++ b/match.c @@ -90,6 +90,18 @@ static void build_hash_table(struct sum_struct *s) static OFF_T last_match; +/** + * Transmit a literal and/or match token. + * + * This delightfully-named function is called either when we find a + * match and need to transmit all the unmatched data leading up to it, + * or when we get bored of accumulating literal data and just need to + * transmit it. As a result of this second case, it is called even if + * we have not matched at all! + * + * @param i If >0, the number of a matched token. If 0, indicates we + * have only literal data. + **/ static void matched(int f,struct sum_struct *s,struct map_struct *buf, OFF_T offset,int i) { @@ -246,7 +258,8 @@ static void hash_search(int f,struct sum_struct *s, match. The 3 reads are caused by the running match, the checksum update and the literal send. */ - if (offset-last_match >= CHUNK_SIZE+s->n && + if (offset > last_match && + offset-last_match >= CHUNK_SIZE+s->n && (end-offset > CHUNK_SIZE)) { matched(f,s,buf,offset - s->n, -2); } @@ -257,7 +270,21 @@ static void hash_search(int f,struct sum_struct *s, } -void match_sums(int f,struct sum_struct *s,struct map_struct *buf,OFF_T len) +/** + * Scan through a origin file, looking for sections that match + * checksums from the generator, and transmit either literal or token + * data. + * + * Also calculates the MD4 checksum of the whole file, using the md + * accumulator. This is transmitted with the file as protection + * against corruption on the wire. + * + * @param s Checksums received from the generator. If s->count == + * 0, then there are actually no checksums for this file. + * + * @param len Length of the file to send. + **/ +void match_sums(int f, struct sum_struct *s, struct map_struct *buf, OFF_T len) { char file_sum[MD4_SUM_LENGTH]; extern int write_batch; /* dw */