#include "system.h"
#include "common.h"
extern union block *current_block;
int time_to_start_writing = 0;
char *output_start;
static void
append_file (char *path)
{
int handle;
struct stat stat_data;
off_t bytes_left;
if (stat (path, &stat_data) != 0
|| (handle = open (path, O_RDONLY | O_BINARY), handle < 0))
{
ERROR ((0, errno, _("Cannot open file %s"), path));
return;
}
bytes_left = stat_data.st_size;
while (bytes_left > 0)
{
union block *start = find_next_block ();
size_t buffer_size = available_space_after (start);
ssize_t status;
if (bytes_left < buffer_size)
{
buffer_size = bytes_left;
status = buffer_size % BLOCKSIZE;
if (status)
memset (start->buffer + bytes_left, 0,
(size_t) (BLOCKSIZE - status));
}
status = safe_read (handle, start->buffer, buffer_size);
if (status < 0)
{
char buf[UINTMAX_STRSIZE_BOUND];
FATAL_ERROR ((0, errno,
_("Read error at byte %s reading %lu bytes in file %s"),
STRINGIFY_BIGINT (stat_data.st_size - bytes_left, buf),
(unsigned long) buffer_size, path));
}
bytes_left -= status;
set_next_block_after (start + (status - 1) / BLOCKSIZE);
if (status != buffer_size)
{
char buf[UINTMAX_STRSIZE_BOUND];
FATAL_ERROR ((0, 0, _("%s: File shrunk by %s bytes, (yark!)"),
path, STRINGIFY_BIGINT (bytes_left, buf)));
}
}
close (handle);
}
void
update_archive (void)
{
enum read_header previous_status = HEADER_STILL_UNREAD;
int found_end = 0;
name_gather ();
if (subcommand_option == UPDATE_SUBCOMMAND)
name_expand ();
open_archive (ACCESS_UPDATE);
while (!found_end)
{
enum read_header status = read_header ();
switch (status)
{
case HEADER_STILL_UNREAD:
abort ();
case HEADER_SUCCESS:
{
struct name *name;
if (subcommand_option == UPDATE_SUBCOMMAND
&& (name = name_scan (current_file_name), name))
{
struct stat stat_data;
enum archive_format unused;
decode_header (current_header, ¤t_stat, &unused, 0);
if (stat (current_file_name, &stat_data) < 0)
ERROR ((0, errno, _("Cannot stat %s"), current_file_name));
else if (current_stat.st_mtime >= stat_data.st_mtime)
name->found = 1;
}
set_next_block_after (current_header);
if (current_header->oldgnu_header.isextended)
skip_extended_headers ();
skip_file (current_stat.st_size);
break;
}
case HEADER_ZERO_BLOCK:
current_block = current_header;
found_end = 1;
break;
case HEADER_END_OF_FILE:
found_end = 1;
break;
case HEADER_FAILURE:
set_next_block_after (current_header);
switch (previous_status)
{
case HEADER_STILL_UNREAD:
WARN ((0, 0, _("This does not look like a tar archive")));
case HEADER_SUCCESS:
case HEADER_ZERO_BLOCK:
ERROR ((0, 0, _("Skipping to next header")));
case HEADER_FAILURE:
break;
case HEADER_END_OF_FILE:
abort ();
}
break;
}
previous_status = status;
}
reset_eof ();
time_to_start_writing = 1;
output_start = current_block->buffer;
{
char *path;
while (path = name_from_list (), path)
{
if (interactive_option && !confirm ("add", path))
continue;
if (subcommand_option == CAT_SUBCOMMAND)
append_file (path);
else
dump_file (path, (dev_t) -1, 1);
}
}
write_eot ();
close_archive ();
names_notfound ();
}