src/parallel: Check for disk full by appending 8kbytes (> 1 page frame).

This commit is contained in:
Ole Tange 2013-12-01 13:57:45 +01:00
parent 8e8ffb898f
commit e817c6d7f5
2 changed files with 15 additions and 1 deletions

View file

@ -208,6 +208,10 @@ available for download at: http://ftp.gnu.org/gnu/parallel/
New in this release: New in this release:
* Mon make à moi (French)
http://www.slideshare.net/lindenb/mon-make-moi-tout-sauf-galaxy
* Parallel xz compression * Parallel xz compression
http://anthon.home.xs4all.nl/rants/2013/parallel_xz/ http://anthon.home.xs4all.nl/rants/2013/parallel_xz/

View file

@ -2347,7 +2347,7 @@ sub citation_notice {
# skip # skip
} else { } else {
print $Global::original_stderr print $Global::original_stderr
("When using GNU Parallel to process data for publication please cite:\n", ("When using programs that use GNU Parallel to process data for publication please cite:\n",
"\n", "\n",
" O. Tange (2011): GNU Parallel - The Command-Line Power Tool,\n", " O. Tange (2011): GNU Parallel - The Command-Line Power Tool,\n",
" ;login: The USENIX Magazine, February 2011:42-47.\n", " ;login: The USENIX Magazine, February 2011:42-47.\n",
@ -4922,8 +4922,18 @@ sub print {
# Put STDIN file handle back # Put STDIN file handle back
open(STDIN, "<&", $stdin_copy) or ::die_bug("Can't dup STDIN: $!"); open(STDIN, "<&", $stdin_copy) or ::die_bug("Can't dup STDIN: $!");
} else { } else {
# Check for disk full by appending 8kbytes (> 1 page frame).
seek $in_fd, 0, 2;
my $pos = tell $in_fd;
print $in_fd "x"x8193;
if(tell $in_fd == $pos) {
::error("Cannot append to buffer file in \$TMPDIR. Disk full?\n");
}
truncate $in_fd, $pos;
# Seek to start
seek $in_fd, 0, 0; seek $in_fd, 0, 0;
} }
# $in_fd is now ready for reading at position 0
if($opt::tag or defined $opt::tagstring) { if($opt::tag or defined $opt::tagstring) {
my $tag = $self->tag(); my $tag = $self->tag();
if($fdno == 2) { if($fdno == 2) {