162 |
file_copy( '<:gzip', $path, '>', $tmp ); |
file_copy( '<:gzip', $path, '>', $tmp ); |
163 |
$path = $tmp; |
$path = $tmp; |
164 |
} |
} |
|
warn "<<< open abs path: $path [", -e $path ? -s $path : 'new' , "]\n"; |
|
|
return -$! unless sysopen($fh , $path, $mode); |
|
|
close($fh); |
|
165 |
|
|
166 |
$pending->{$file}->{path} = $path; |
if ( sysopen($fh , $path, $mode) ) { |
167 |
return 0; |
close($fh) || confess "can't close $path: $!"; |
168 |
|
warn "<<< open $path [", -e $path ? -s $path : 'new' , "]\n"; |
169 |
|
$pending->{$file}->{path} = $path; |
170 |
|
return 0; |
171 |
|
} else { |
172 |
|
warn "ERROR: can't open $path : $!"; |
173 |
|
return -$!; |
174 |
|
} |
175 |
|
|
176 |
} |
} |
177 |
|
|
178 |
sub x_read { |
sub x_read { |
279 |
$no_gz =~ s/\.gz$//; |
$no_gz =~ s/\.gz$//; |
280 |
rename $path, $no_gz || confess "can't rename $path -> $no_gz: $!"; |
rename $path, $no_gz || confess "can't rename $path -> $no_gz: $!"; |
281 |
} |
} |
282 |
warn "## truncate( $file $size ) $path [", -s $path, "]\n"; |
warn "## truncate( $file $size ) $path [", -s $path, "] = $rv\n" if $debug; |
283 |
$pending->{$file}->{write}++; |
$pending->{$file}->{write}++; |
284 |
return $rv; |
return $rv; |
285 |
} |
} |