X-Git-Url: https://git.dogcows.com/gitweb?a=blobdiff_plain;f=src%2Fsystem.c;h=aa3ede42d429c5b0dfa526d7608cae7dd47ffb8b;hb=2433f6813ec6a0c00e6c49b8f38725cd4a78c66c;hp=5cb086f5de02ac45d46202b5f62d98d29e6cae1c;hpb=d4e70d365615e56cadd4093aaa5c0046cf2c9c95;p=chaz%2Ftar diff --git a/src/system.c b/src/system.c index 5cb086f..aa3ede4 100644 --- a/src/system.c +++ b/src/system.c @@ -1,6 +1,6 @@ /* System-dependent calls for tar. - Copyright (C) 2003 Free Software Foundation, Inc. + Copyright (C) 2003, 2004 Free Software Foundation, Inc. This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the @@ -16,16 +16,40 @@ with this program; if not, write to the Free Software Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. */ -#include "system.h" +#include #include "common.h" -#include "rmt.h" +#include #include +void +sys_stat_nanoseconds (struct tar_stat_info *st) +{ +#if defined(HAVE_STRUCT_STAT_ST_SPARE1) + st->atime_nsec = st->stat.st_spare1 * 1000; + st->mtime_nsec = st->stat.st_spare2 * 1000; + st->ctime_nsec = st->stat.st_spare3 * 1000; +#elif defined(HAVE_STRUCT_STAT_ST_ATIM_TV_NSEC) + st->atime_nsec = st->stat.st_atim.tv_nsec; + st->mtime_nsec = st->stat.st_mtim.tv_nsec; + st->ctime_nsec = st->stat.st_ctim.tv_nsec; +#elif defined(HAVE_STRUCT_STAT_ST_ATIMESPEC_TV_NSEC) + st->atime_nsec = st->stat.st_atimespec.tv_nsec; + st->mtime_nsec = st->stat.st_mtimespec.tv_nsec; + st->ctime_nsec = st->stat.st_ctimespec.tv_nsec; +#elif defined(HAVE_STRUCT_STAT_ST_ATIMENSEC) + st->atime_nsec = st->stat.st_atimensec; + st->mtime_nsec = st->stat.st_mtimensec; + st->ctime_nsec = st->stat.st_ctimensec; +#else + st->atime_nsec = st->mtime_nsec = st->ctime_nsec = 0; +#endif +} + #if MSDOS bool -sys_get_archive_stat () +sys_get_archive_stat (void) { return 0; } @@ -37,12 +61,12 @@ sys_file_is_archive (struct tar_stat_info *p) } void -sys_save_archive_dev_ino () +sys_save_archive_dev_ino (void) { } void -sys_detect_dev_null_output () +sys_detect_dev_null_output (void) { static char const dev_null[] = "nul"; @@ -51,7 +75,7 @@ sys_detect_dev_null_output () } void -sys_drain_input_pipe () +sys_drain_input_pipe (void) { } @@ -61,7 +85,7 @@ sys_wait_for_child (pid_t child_pid) } void -sys_spawn_shell () +sys_spawn_shell (void) { spawnl (P_WAIT, getenv ("COMSPEC"), "-", 0); } @@ -94,26 +118,10 @@ sys_truncate (int fd) return write (fd, "", 0); } -void -sys_reset_uid_gid () -{ -} - -ssize_t +size_t sys_write_archive_buffer (void) { - ssize_t status; - ssize_t written = 0; - - while (0 <= (status = full_write (archive, record_start->buffer + written, - record_size - written))) - { - written += status; - if (written == record_size) - break; - } - - return written ? written : status; + return full_write (archive, record_start->buffer, record_size); } /* Set ARCHIVE for writing, then compressing an archive. */ @@ -137,11 +145,11 @@ extern union block *record_start; /* FIXME */ static struct stat archive_stat; /* stat block for archive file */ bool -sys_get_archive_stat () +sys_get_archive_stat (void) { return fstat (archive, &archive_stat) == 0; } - + bool sys_file_is_archive (struct tar_stat_info *p) { @@ -150,7 +158,7 @@ sys_file_is_archive (struct tar_stat_info *p) /* Save archive file inode and device numbers */ void -sys_save_archive_dev_ino () +sys_save_archive_dev_ino (void) { if (!_isrmt (archive) && S_ISREG (archive_stat.st_mode)) { @@ -163,7 +171,7 @@ sys_save_archive_dev_ino () /* Detect if outputting to "/dev/null". */ void -sys_detect_dev_null_output () +sys_detect_dev_null_output (void) { static char const dev_null[] = "/dev/null"; struct stat dev_null_stat; @@ -182,12 +190,15 @@ sys_detect_dev_null_output () work to do, we might have to revise this area in such time. */ void -sys_drain_input_pipe () +sys_drain_input_pipe (void) { + size_t r; + if (access_mode == ACCESS_READ && ! _isrmt (archive) && (S_ISFIFO (archive_stat.st_mode) || S_ISSOCK (archive_stat.st_mode))) - while (rmtread (archive, record_start->buffer, record_size) > 0) + while ((r = rmtread (archive, record_start->buffer, record_size)) != 0 + && r != SAFE_READ_ERROR) continue; } @@ -215,7 +226,7 @@ sys_wait_for_child (pid_t child_pid) } void -sys_spawn_shell () +sys_spawn_shell (void) { pid_t child; const char *shell = getenv ("SHELL"); @@ -265,13 +276,6 @@ sys_truncate (int fd) return pos < 0 ? -1 : ftruncate (fd, pos); } -void -sys_reset_uid_gid () -{ - setuid (getuid ()); - setgid (getgid ()); -} - /* Return nonzero if NAME is the name of a regular file, or if the file does not exist (so it would be created as a regular file). */ static int @@ -285,24 +289,10 @@ is_regular_file (const char *name) return errno == ENOENT; } -ssize_t +size_t sys_write_archive_buffer (void) { - ssize_t status; - ssize_t written = 0; - - while (0 <= (status = rmtwrite (archive, record_start->buffer + written, - record_size - written))) - { - written += status; - if (written == record_size - || _isrmt (archive) - || ! (S_ISFIFO (archive_stat.st_mode) - || S_ISSOCK (archive_stat.st_mode))) - break; - } - - return written ? written : status; + return rmtwrite (archive, record_start->buffer, record_size); } #define PREAD 0 /* read file descriptor from pipe() */ @@ -434,7 +424,7 @@ sys_child_open_for_compress (void) while (1) { - ssize_t status = 0; + size_t status = 0; char *cursor; size_t length; @@ -447,13 +437,12 @@ sys_child_open_for_compress (void) size_t size = record_size - length; status = safe_read (STDIN_FILENO, cursor, size); - if (status <= 0) + if (status == SAFE_READ_ERROR) + read_fatal (use_compress_program_option); + if (status == 0) break; } - if (status < 0) - read_fatal (use_compress_program_option); - /* Copy the record. */ if (status == 0) @@ -516,7 +505,6 @@ sys_child_open_for_uncompress (void) { /* The parent tar is still here! Just clean up. */ - read_full_records_option = 1; archive = parent_pipe[PREAD]; xclose (parent_pipe[PWRITE]); return child_pid; @@ -591,13 +579,13 @@ sys_child_open_for_uncompress (void) char *cursor; size_t maximum; size_t count; - ssize_t status; + size_t status; clear_read_error_count (); error_loop: status = rmtread (archive, record_start->buffer, record_size); - if (status < 0) + if (status == SAFE_READ_ERROR) { archive_read_error (); goto error_loop;