X-Git-Url: https://git.dogcows.com/gitweb?a=blobdiff_plain;f=src%2Fbuffer.c;h=e4225fe1e72e0a2739c93a3af6016c8f1953cd85;hb=263604c2ec4703cc7381899b3ad015b79f6d0d41;hp=0d142f7907e29909c7b61718bff8dc4995ee00fa;hpb=4674867a23ed4b42b0a84102331d369f6fc7e467;p=chaz%2Ftar diff --git a/src/buffer.c b/src/buffer.c index 0d142f7..e4225fe 100644 --- a/src/buffer.c +++ b/src/buffer.c @@ -1,7 +1,7 @@ /* Buffer management for tar. Copyright (C) 1988, 1992, 1993, 1994, 1996, 1997, 1999, 2000, 2001, - 2003, 2004 Free Software Foundation, Inc. + 2003, 2004, 2005 Free Software Foundation, Inc. Written by John Gilmore, on 1985-08-25. @@ -159,17 +159,17 @@ enum compress_type { struct zip_magic { enum compress_type type; - unsigned char *magic; size_t length; - char *program; - char *option; + char magic[sizeof "BZh" - 1]; + char program[sizeof "compress"]; + char option[sizeof "-Z"]; }; -static struct zip_magic magic[] = { +static struct zip_magic const magic[] = { { ct_none, }, - { ct_compress, "\037\235", 2, "compress", "-Z" }, - { ct_gzip, "\037\213", 2, "gzip", "-z" }, - { ct_bzip2, "BZh", 3, "bzip2", "-j" }, + { ct_compress, 2, "\037\235", "compress", "-Z" }, + { ct_gzip, 2, "\037\213", "gzip", "-z" }, + { ct_bzip2, 3, "BZh", "bzip2", "-j" }, }; #define NMAGIC (sizeof(magic)/sizeof(magic[0])) @@ -177,34 +177,35 @@ static struct zip_magic magic[] = { #define compress_option(t) magic[t].option #define compress_program(t) magic[t].program -/* Check if the file FD is a compressed archive. FD is guaranteed to - represent a local file */ -enum compress_type -check_compressed_archive (int fd) +/* Check if the file ARCHIVE is a compressed archive. */ +enum compress_type +check_compressed_archive () { - struct zip_magic *p; - size_t status; - union block buf; - - status = read (fd, &buf, sizeof buf); - if (status != sizeof buf) - { - archive_read_error (); - FATAL_ERROR ((0, 0, _("Quitting now."))); - } - - lseek (fd, 0, SEEK_SET); /* This will fail if fd==0, but that does not - matter, since we do not handle compressed - stdin anyway */ - - if (tar_checksum (&buf) == HEADER_SUCCESS) + struct zip_magic const *p; + bool sfr, srp; + + /* Prepare global data needed for find_next_block: */ + record_end = record_start; /* set up for 1st record = # 0 */ + sfr = read_full_records; + read_full_records = true; /* Suppress fatal error on reading a partial + record */ + srp = reading_from_pipe; + reading_from_pipe = true; /* Suppress warning message on reading a partial + record */ + find_next_block (); + + /* Restore global values */ + read_full_records = sfr; + reading_from_pipe = srp; + + if (tar_checksum (record_start, true) == HEADER_SUCCESS) /* Probably a valid header */ return ct_none; for (p = magic + 1; p < magic + NMAGIC; p++) - if (memcmp (buf.buffer, p->magic, p->length) == 0) + if (memcmp (record_start->buffer, p->magic, p->length) == 0) return p->type; - + return ct_none; } @@ -214,33 +215,32 @@ check_compressed_archive (int fd) int open_compressed_archive () { - enum compress_type type; - int fd = rmtopen (archive_name_array[0], O_RDONLY | O_BINARY, - MODE_RW, rsh_command_option); - if (fd == -1 || _isrmt (fd)) - return fd; - - type = check_compressed_archive (fd); - - if (type == ct_none) + archive = rmtopen (archive_name_array[0], O_RDONLY | O_BINARY, + MODE_RW, rsh_command_option); + if (archive == -1) + return archive; + + if (!multi_volume_option) { - if (rmtlseek (fd, (off_t) 0, SEEK_CUR) != 0) - { - /* Archive may be not seekable. Reopen it. */ - rmtclose (fd); - fd = rmtopen (archive_name_array[0], O_RDONLY | O_BINARY, - MODE_RW, rsh_command_option); - } - return fd; - } + enum compress_type type = check_compressed_archive (); + + if (type == ct_none) + return archive; - /* FD is not needed any more */ - rmtclose (fd); + /* FD is not needed any more */ + rmtclose (archive); + + hit_eof = false; /* It might have been set by find_next_block in + check_compressed_archive */ + + /* Open compressed archive */ + use_compress_program_option = compress_program (type); + child_pid = sys_child_open_for_uncompress (); + read_full_records = reading_from_pipe = true; + } - /* Open compressed archive */ - use_compress_program_option = compress_program (type); - child_pid = sys_child_open_for_uncompress (); - read_full_records = reading_from_pipe = true; + records_read = 0; + record_end = record_start; /* set up for 1st record = # 0 */ return archive; } @@ -253,7 +253,7 @@ print_total_written (void) char bytes[sizeof (tarlong) * CHAR_BIT]; char abbr[LONGEST_HUMAN_READABLE + 1]; char rate[LONGEST_HUMAN_READABLE + 1]; - + int human_opts = human_autoscale | human_base_1024 | human_SI | human_B; sprintf (bytes, TARLONG_FORMAT, written); @@ -407,7 +407,9 @@ open_archive (enum access_mode wanted_access) read_full_records = read_full_records_option; reading_from_pipe = false; - + + records_read = 0; + if (use_compress_program_option) { switch (wanted_access) @@ -415,6 +417,7 @@ open_archive (enum access_mode wanted_access) case ACCESS_READ: child_pid = sys_child_open_for_uncompress (); read_full_records = reading_from_pipe = true; + record_end = record_start; /* set up for 1st record = # 0 */ break; case ACCESS_WRITE: @@ -441,7 +444,7 @@ open_archive (enum access_mode wanted_access) case ACCESS_READ: { enum compress_type type; - + archive = STDIN_FILENO; type = check_compressed_archive (archive); @@ -509,9 +512,9 @@ open_archive (enum access_mode wanted_access) { case ACCESS_UPDATE: records_written = 0; - case ACCESS_READ: - records_read = 0; record_end = record_start; /* set up for 1st record = # 0 */ + + case ACCESS_READ: find_next_block (); /* read it in, check for EOF */ if (volume_label_option) @@ -560,6 +563,10 @@ flush_write (void) ssize_t status; if (checkpoint_option && !(++checkpoint % 10)) + /* TRANSLATORS: This is a ``checkpoint of write operation'', + *not* ``Writing a checkpoint''. + E.g. in Spanish ``Punto de comprobaci@'on de escritura'', + *not* ``Escribiendo un punto de comprobaci@'on'' */ WARN ((0, 0, _("Write checkpoint %d"), checkpoint)); if (tape_length_option && tape_length_option <= bytes_written) @@ -649,7 +656,7 @@ flush_write (void) FATAL_ERROR ((0, 0, _("%s: file name too long to be stored in a GNU multivolume header"), quotearg_colon (real_s_name))); - + memset (record_start, 0, BLOCKSIZE); /* FIXME: Michael P Urban writes: [a long name file] is being written @@ -662,7 +669,7 @@ flush_write (void) OFF_TO_CHARS (real_s_sizeleft, record_start->header.size); OFF_TO_CHARS (real_s_totsize - real_s_sizeleft, record_start->oldgnu_header.offset); - + tmp = verbose_option; verbose_option = 0; finish_header (¤t_stat_info, record_start, -1); @@ -758,7 +765,10 @@ short_read (size_t status) { char buf[UINTMAX_STRSIZE_BOUND]; - WARN((0, 0, _("Read %s bytes from %s"), + WARN((0, 0, + ngettext ("Read %s byte from %s", + "Read %s bytes from %s", + record_size - left), STRINGIFY_BIGINT (record_size - left, buf), *archive_name_cursor)); } @@ -807,6 +817,10 @@ flush_read (void) size_t status; /* result from system call */ if (checkpoint_option && !(++checkpoint % 10)) + /* TRANSLATORS: This is a ``checkpoint of read operation'', + *not* ``Reading a checkpoint''. + E.g. in Spanish ``Punto de comprobaci@'on de lectura'', + *not* ``Leyendo un punto de comprobaci@'on'' */ WARN ((0, 0, _("Read checkpoint %d"), checkpoint)); /* Clear the count of errors. This only applies to a single call to @@ -1036,13 +1050,13 @@ seek_archive (off_t size) off_t offset; off_t nrec, nblk; off_t skipped = (blocking_factor - (current_block - record_start)); - + size -= skipped * BLOCKSIZE; - + if (size < record_size) return 0; /* FIXME: flush? */ - + /* Compute number of records to skip */ nrec = size / record_size; offset = rmtlseek (archive, nrec * record_size, SEEK_CUR); @@ -1061,7 +1075,7 @@ seek_archive (off_t size) records_read += nblk / blocking_factor; record_start_block = offset - blocking_factor; current_block = record_end; - + return nblk; } @@ -1075,7 +1089,7 @@ close_archive (void) sys_drain_input_pipe (); compute_duration (); - if (verify_option) + if (verify_option) verify_volume (); if (rmtclose (archive) != 0) @@ -1172,7 +1186,8 @@ new_volume (enum access_mode mode) if (volno_file_option) closeout_volume_number (); if (system (info_script_option) != 0) - FATAL_ERROR ((0, 0, _("`%s' command failed"), info_script_option)); + FATAL_ERROR ((0, 0, _("%s command failed"), + quote (info_script_option))); } else while (1) @@ -1295,4 +1310,3 @@ new_volume (enum access_mode mode) return true; } -