X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=unpack-objects.c;h=5c5cb12f6fa2a9a8fe061c2e75380c8b9e7ebaf1;hb=975b31dc6e12fba8f7b067ddbe32230995e05400;hp=355889f65bef73e512cf4c053493ae25c6a77b96;hpb=d36f7b805eccaf702c0be1c00d034711d0da1f77;p=git.git diff --git a/unpack-objects.c b/unpack-objects.c index 355889f6..5c5cb12f 100644 --- a/unpack-objects.c +++ b/unpack-objects.c @@ -6,7 +6,7 @@ #include static int dry_run, quiet; -static const char unpack_usage[] = "git-unpack-objects < pack-file"; +static const char unpack_usage[] = "git-unpack-objects [-n] [-q] < pack-file"; /* We always read in 4kB chunks. */ static unsigned char buffer[4096]; @@ -31,12 +31,10 @@ static void * fill(int min) offset = 0; } do { - int ret = read(0, buffer + len, sizeof(buffer) - len); + int ret = xread(0, buffer + len, sizeof(buffer) - len); if (ret <= 0) { if (!ret) die("early EOF"); - if (errno == EAGAIN || errno == EINTR) - continue; die("read error on input: %s", strerror(errno)); } len += ret; @@ -75,6 +73,7 @@ static void *get_data(unsigned long size) stream.next_in = fill(1); stream.avail_in = len; } + inflateEnd(&stream); return buf; } @@ -167,6 +166,7 @@ static int unpack_delta_entry(unsigned long delta_size) unsigned long base_size; char type[20]; unsigned char base_sha1[20]; + int result; memcpy(base_sha1, fill(20), 20); use(20); @@ -184,7 +184,9 @@ static int unpack_delta_entry(unsigned long delta_size) base = read_sha1_file(base_sha1, type, &base_size); if (!base) die("failed to read delta-pack base object %s", sha1_to_hex(base_sha1)); - return resolve_delta(type, base, base_size, delta_data, delta_size); + result = resolve_delta(type, base, base_size, delta_data, delta_size); + free(base); + return result; } static void unpack_one(unsigned nr, unsigned total) @@ -211,7 +213,7 @@ static void unpack_one(unsigned nr, unsigned total) static unsigned long last_sec; static unsigned last_percent; struct timeval now; - unsigned percentage = ((1+nr) * 100) / total; + unsigned percentage = (nr * 100) / total; gettimeofday(&now, NULL); if (percentage != last_percent || now.tv_sec != last_sec) { @@ -255,7 +257,7 @@ static void unpack_all(void) use(sizeof(struct pack_header)); for (i = 0; i < nr_objects; i++) - unpack_one(i, nr_objects); + unpack_one(i+1, nr_objects); if (delta_list) die("unresolved deltas left after unpacking"); } @@ -265,6 +267,8 @@ int main(int argc, char **argv) int i; unsigned char sha1[20]; + setup_git_directory(); + for (i = 1 ; i < argc; i++) { const char *arg = argv[i]; @@ -293,14 +297,9 @@ int main(int argc, char **argv) /* Write the last part of the buffer to stdout */ while (len) { - int ret = write(1, buffer + offset, len); - if (!ret) + int ret = xwrite(1, buffer + offset, len); + if (ret <= 0) break; - if (ret < 0) { - if (errno == EAGAIN || errno == EINTR) - continue; - break; - } len -= ret; offset += ret; }