Lines Matching refs:fh
71 my $fh = $fhlist[0];
72 <$fh>;
75 my $fh = $fhlist[0];
81 for my $fh (@fhlist) {
82 my $line = <$fh>;
99 for my $fh (@fhlist) {
156 unlink $job->fh(2,"name");
159 unlink $job->fh(1,"name");
210 my ($buf_ref, $fh) = @_;
216 while(read($fh,substr($$buf_ref,length $$buf_ref,0),$opt::blocksize)) {
245 my $fh = ::open_or_exit($file);
249 seek($fh, $pos, 0) || die;
250 while(read($fh,substr($buf,length $buf,0),$dd_block_size)) {
273 close $fh;
406 close $job->fh(0,"w");
560 close $job->fh(0,"w");
563 close $job->fh(0,"w");
1553 my $fh;
1556 if(open($fh,">&=$fdno")) {
1557 $Global::fd{$fdno}=$fh;
1577 my %fh;
1584 $enough_filehandles &&= open($fh{$i}, "<", "/dev/null");
1586 for (values %fh) { close $_; }
1612 my $fh = gensym;
1613 if(not open($fh, "<", $file)) {
1617 return $fh;
1880 close $job->fh(0,"w");
2430 my ($fh, $tmpfile) = ::tmpfile(SUFFIX => ".ssh");
2431 print $fh @cores, @cpus, @maxline, @echo;
2432 close $fh;
2555 my ($fh, $tmpfile) = ::tmpfile(SUFFIX => ".log");
2556 close $fh;
2566 for my $fh (@fhlist) {
2568 print $outfh (<$fh>);
2638 open(my $fh, "<", $joblog) || ::die_bug("Cannot open tmp joblog $joblog");
2640 <$fh>;
2641 print $Global::joblog (<$fh>);
2642 close $fh;
2893 my $fh = $Global::original_stderr || *STDERR;
2895 print $fh $prog, ": Warning: ", @w;
2901 my $fh = $Global::original_stderr || *STDERR;
2903 print $fh $prog, ": Error: ", @w;
2974 open (my $fh, ">", $ENV{'HOME'}."/.parallel/will-cite")
2976 close $fh;
3309 my $fh = FileHandle->new("</proc/$pid/stat");
3311 my $data = <$fh>;
3313 $fh->close;
3915 my %fh;
3923 open($fh{"init-$i"}, "<", "/dev/null");
3985 $more_filehandles = open($fh{$system_limit*10}, "<", "/dev/null")
3986 && open($fh{$system_limit*10+2}, "<", "/dev/null")
3987 && open($fh{$system_limit*10+3}, "<", "/dev/null")
3988 && open($fh{$system_limit*10+4}, "<", "/dev/null");
4022 for (values %fh) { close $_ }
5072 $self->fh($fdno,'name')) || die $?;
5077 $self->fh($fdno,'name'),$self->fh($fdno,'unlink')) || die $?;
5087 open(my $fdr,"<", $self->fh($fdno,'name')) ||
5088 ::die_bug("fdr: Cannot open ".$self->fh($fdno,'name'));
5091 $Global::debug or unlink $self->fh($fdno,"unlink");
5098 my $fdr = $self->fh($fdno,'r');
5142 my ($self, $fd_no, $key, $fh) = @_;
5143 $self->{'fd'}{$fd_no,$key} = $fh;
5146 sub fh { subroutine
5155 my $stdin_fh = $self->fh(0,"w");
5201 my $in = $self->fh(0,"w");
5855 my($stdout_fh,$stderr_fh) = ($job->fh(1,"w"),$job->fh(2,"w"));
5945 my ($fh, $tmpfile) = ::tmpfile(SUFFIX => ".tmx");
5947 close $fh;
6034 unlink $self->fh(1,"name");
6069 my $in_fh = $self->fh($fdno,"r");
6076 ::debug("print", "File descriptor $fdno (", $self->fh($fdno,"name"), "):");
6079 close $self->fh($fdno,"w");
6085 unlink $self->fh($fdno,"name");
6086 unlink $self->fh($fdno,"unlink");
6088 } elsif($fdno == 1 and $self->fh($fdno,"name")) {
6089 print $out_fd $self->fh($fdno,"name"),"\n";
6096 close $self->fh($fdno,"w");
6144 close $self->fh($fdno,"w");
6149 my $fdr = $self->fh($fdno,'r');
6202 if($self->fh($fdno,"rpid") and CORE::kill 0, $self->fh($fdno,"rpid")) {
7073 open(my $fh, "<", $len_cache) || ::die_bug("Cannot read $len_cache");
7074 $cached_limit = <$fh>;
7075 close $fh;
7081 open(my $fh, ">", $len_cache);
7082 print $fh $cached_limit;
7083 close $fh;
7271 for my $fh (@$fhs) {
7272 if(-t $fh) {
7304 for my $fh (@{$self->{'fhs'}}) {
7305 $empty &&= eof($fh);
7319 for my $fh (@{$self->{'fhs'}}) {
7320 my $arg = read_arg_from_fh($fh);
7323 push @{$self->{'arg_matrix'}{$fh}}, $arg;
7329 push @{$self->{'arg_matrix'}{$fh}}, shift @{$self->{'arg_matrix'}{$fh}};
7331 push @record, @{$self->{'arg_matrix'}{$fh}}[-1];
7423 my $fh = shift;
7428 if(not ($arg = <$fh>)) {
7441 close $fh;
7756 open (my $fh, ">", $self->{'idfile'}) or
7758 close $fh;
7791 open (my $fh, ">", $self->{'idfile'}) or
7793 print $fh "#"x$nlinks;
7794 close $fh;
7812 open (my $fh, ">", $self->{'idfile'}) or
7814 close $fh;
7833 open (my $fh, ">", $self->{'idfile'}) or
7835 close $fh;
7837 open (my $fh, ">", $self->{'idfile'}) or
7839 print $fh "#"x$nlinks;
7840 close $fh;