[3] | 1 | # |
---|
| 2 | # Copyright (c) 2004-2007 - Consultas, PKG.fr |
---|
| 3 | # |
---|
| 4 | # This file is part of A2P. |
---|
| 5 | # |
---|
| 6 | # A2P is free software; you can redistribute it and/or modify |
---|
| 7 | # it under the terms of the GNU General Public License as published by |
---|
| 8 | # the Free Software Foundation; either version 2 of the License, or |
---|
| 9 | # (at your option) any later version. |
---|
| 10 | # |
---|
| 11 | # A2P is distributed in the hope that it will be useful, |
---|
| 12 | # but WITHOUT ANY WARRANTY; without even the implied warranty of |
---|
| 13 | # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
---|
| 14 | # GNU General Public License for more details. |
---|
| 15 | # |
---|
| 16 | # You should have received a copy of the GNU General Public License |
---|
| 17 | # along with A2P; if not, write to the Free Software |
---|
| 18 | # Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA |
---|
| 19 | # |
---|
| 20 | # $Id: afpds2tex.pm 3 2007-10-18 16:20:19Z root $ |
---|
| 21 | # |
---|
| 22 | |
---|
| 23 | package AFPDS::afpds2tex; |
---|
| 24 | |
---|
| 25 | use strict ; |
---|
| 26 | use Encode 'from_to' ; |
---|
| 27 | use Time::HiRes qw( gettimeofday tv_interval usleep ); |
---|
| 28 | use File::stat ; |
---|
| 29 | use A2P::Globals ; |
---|
| 30 | use A2P::Syslog ; |
---|
| 31 | use A2P::Common ; |
---|
| 32 | use A2P::Com qw( GetCom comINF comREQ comFILE ); |
---|
| 33 | use A2P::Tools qw( debugbuffer compute mychomp myreadline ) ; |
---|
| 34 | use AFPDS::Flux ; |
---|
| 35 | use AFPDS::ControlRecord ; |
---|
| 36 | use A2P::XML ; |
---|
| 37 | use A2P::JobStatus 'a2pjobstate' ; |
---|
| 38 | |
---|
| 39 | BEGIN { |
---|
| 40 | our $VERSION = sprintf "%s", q$Rev: 1023 $ =~ /([0-9.]+)\s+/ ; |
---|
| 41 | } |
---|
| 42 | our $VERSION ; |
---|
| 43 | |
---|
| 44 | # Files handles & generation flag |
---|
| 45 | my ( $TexFile, $ArchFile, $AfpFile, $LCKNAME, $AFPDSFILE ); |
---|
| 46 | my $GenFlag = 0 ; |
---|
| 47 | my $ErrFlag = 0 ; |
---|
| 48 | my $AfpName = ""; |
---|
| 49 | my $Job = ""; |
---|
| 50 | my $self = 0 ; |
---|
| 51 | my $file = 0 ; |
---|
| 52 | my $mtime = 0 ; |
---|
| 53 | |
---|
| 54 | # @skip will be used to continue an afp job when an error occurs on a sub job |
---|
| 55 | # It should be reset to () at each new job |
---|
| 56 | my @skip = () ; |
---|
| 57 | |
---|
| 58 | my $RateTimer = [] ; |
---|
| 59 | my $afpbuffer = "" ; |
---|
| 60 | |
---|
| 61 | my $min_conv_time = 0 ; |
---|
| 62 | |
---|
| 63 | sub _job_tag { |
---|
| 64 | return $Job ? "$Job".($file?"-$file":"").": " : "" |
---|
| 65 | } |
---|
| 66 | |
---|
| 67 | # Function to open TeX file and his shell environment file for writing |
---|
| 68 | sub OpenFiles { |
---|
| 69 | my $filename = $_[1] ; |
---|
| 70 | |
---|
| 71 | open($TexFile, ">$filename.tex") |
---|
| 72 | or &Abort(107, "$filename.tex", "$!"), return 0; |
---|
| 73 | |
---|
| 74 | $LCKNAME = "$filename.tex.LCK" ; |
---|
| 75 | open(LCK, ">$LCKNAME") |
---|
| 76 | or &Abort(107, $LCKNAME, "$!"), return 0; |
---|
| 77 | |
---|
| 78 | open($ArchFile, ">$filename.arch") |
---|
| 79 | or &Abort(107, "$filename.arch", "$!"), return 0; |
---|
| 80 | |
---|
| 81 | return 1 unless ( $PARALLELE_VALIDATION or $KEEP_AFPJOB ); |
---|
| 82 | |
---|
| 83 | open($AfpFile, ">$filename.afp") |
---|
| 84 | or &Abort(107, "$filename.afp" , "$!"), return 0; |
---|
| 85 | |
---|
| 86 | return 1 ; |
---|
| 87 | } |
---|
| 88 | |
---|
| 89 | # Function to close TeX file and his shell environment file |
---|
| 90 | sub CloseFiles { |
---|
| 91 | close($TexFile) if (defined($TexFile)); |
---|
| 92 | close($ArchFile) if (defined($ArchFile)); |
---|
| 93 | close($AfpFile) if (defined($AfpFile)); |
---|
| 94 | if (defined($LCKNAME) and -e $LCKNAME) { |
---|
| 95 | close(LCK); |
---|
| 96 | unlink $LCKNAME ; |
---|
| 97 | } |
---|
| 98 | $GenFlag = 0 ; |
---|
| 99 | } |
---|
| 100 | |
---|
| 101 | # Arguments: |
---|
| 102 | # 1 - The texname to process |
---|
| 103 | # 2 - AFPDS file to process |
---|
| 104 | sub ConvertFile { |
---|
| 105 | $self = shift ; |
---|
| 106 | my $texbase = shift ; |
---|
| 107 | my $afpdsfile = shift ; |
---|
| 108 | $Job = shift ; # Current job name for queueing announcement |
---|
| 109 | my $startpos = shift || 0 ; # The start position in AFP file for splitting |
---|
| 110 | |
---|
| 111 | # Forget any previous status |
---|
| 112 | $ErrFlag = 0 ; |
---|
| 113 | @skip = () ; |
---|
| 114 | |
---|
| 115 | # Same computation as in SpoolManager module |
---|
| 116 | ( $AfpName ) = $afpdsfile =~ $AFPNAME_REGEX ; |
---|
| 117 | &Debug("Afpname set to '$AfpName' from Texbase '$afpdsfile'"); |
---|
| 118 | |
---|
| 119 | # First job state update in spool |
---|
| 120 | &a2pjobstate( $Job , 2 , '.', { JOBID => $Job } ) |
---|
| 121 | or &Info("Can't initialize job status at step 2 with JOBID $Job"); |
---|
| 122 | |
---|
| 123 | $afpdsfile = $AFPSPOOL . '/' . $afpdsfile |
---|
| 124 | unless ( -e $afpdsfile ); |
---|
| 125 | |
---|
| 126 | # Provided texbase must not be an existing folder |
---|
| 127 | return &Abort( 119, $texbase) if ( -d $texbase ); |
---|
| 128 | |
---|
| 129 | # Create texbase as folder |
---|
| 130 | mkdir $texbase , 0775 |
---|
| 131 | or return &Abort( 106, $texbase, "$!"); |
---|
| 132 | |
---|
| 133 | # Here, texbase will be a folder to delete, so inform JobManager of it |
---|
| 134 | $self->Return( $Job , $texbase ); |
---|
| 135 | |
---|
| 136 | # Opening files for reading |
---|
| 137 | open($AFPDSFILE, "<", "$afpdsfile") |
---|
| 138 | or return &Abort( 107, $afpdsfile, "$!"); |
---|
| 139 | |
---|
| 140 | # Read AFPDS files in binary mode |
---|
| 141 | binmode($AFPDSFILE) |
---|
| 142 | or return &Abort( 108, $afpdsfile, "$!"); |
---|
| 143 | |
---|
| 144 | &Debug("Starting AFPDS conversion of $afpdsfile to $texbase folder"); |
---|
| 145 | |
---|
| 146 | ############################################################################ |
---|
| 147 | # Check if records are terminated by CR-LF: |
---|
| 148 | # search for pattern 0x0D0A in the last 10 chars of afpds file |
---|
| 149 | ############################################################################ |
---|
| 150 | my ( $readmode , $buffer , $EOF , $inXML ) = ( 0 , "" , 0 , 0 ) ; |
---|
| 151 | { |
---|
| 152 | my ( $EOL , $offset ) = ( 0 , 9 ); |
---|
| 153 | |
---|
| 154 | # 1. Check file contents greater than 7 chars, or this is probably |
---|
| 155 | # a corrupted file |
---|
| 156 | seek $AFPDSFILE , 0 , 2 ; |
---|
| 157 | return &Abort(124, $afpdsfile) if ( tell($AFPDSFILE) <= 7 ); |
---|
| 158 | |
---|
| 159 | # 2. Load the last 10 chars in the buffer |
---|
| 160 | seek $AFPDSFILE , -10 , 2 ; |
---|
| 161 | return &Abort(109, $afpdsfile, "$!") |
---|
| 162 | if ( read($AFPDSFILE , $buffer , 10) != 10); |
---|
| 163 | |
---|
| 164 | # 3. Scan loaded buffer for 0x0D0A string starting from offset 8 |
---|
| 165 | # in the buffer |
---|
| 166 | while ( $offset-- > 0 ) { |
---|
| 167 | $EOL = &compute( \$buffer , $offset , 2 ); |
---|
| 168 | $readmode += 2 , last if ( $EOL == 0x0D0A ); |
---|
| 169 | } |
---|
| 170 | |
---|
| 171 | &Debug(sprintf( |
---|
| 172 | "Readmode is $readmode as found CRLF=0x%04x at offset %d", |
---|
| 173 | $EOL,$offset)); |
---|
| 174 | |
---|
| 175 | # Keep End of File information |
---|
| 176 | $EOF = tell($AFPDSFILE); |
---|
| 177 | } |
---|
| 178 | |
---|
| 179 | # Get file time creation |
---|
| 180 | my $stat = stat($afpdsfile); |
---|
| 181 | $mtime = $stat->mtime() ; |
---|
| 182 | |
---|
| 183 | ############################################################################ |
---|
| 184 | # Rewind file to startpos (beginning by default) |
---|
| 185 | seek $AFPDSFILE , $startpos , 0 ; |
---|
| 186 | |
---|
| 187 | ############################################################################ |
---|
| 188 | # |
---|
| 189 | # Read the AFPDS file |
---|
| 190 | # |
---|
| 191 | ############################################################################ |
---|
| 192 | my ( $long , $char , $cctrl , $tmp , $maxrepeat ); |
---|
| 193 | $file = 1 ; |
---|
| 194 | $afpbuffer = "" ; |
---|
| 195 | |
---|
| 196 | # Timer to get a chrono on the current conversion |
---|
| 197 | $RateTimer = [ &gettimeofday() ] ; |
---|
| 198 | |
---|
| 199 | # Set minimum conversion time (used for big jobs to limit convertion rate) |
---|
| 200 | $min_conv_time = $USLEEP ; |
---|
| 201 | # MAX_CONV_RATE is a maximum sub-job number to generate by seconds |
---|
| 202 | $min_conv_time = 1_000_000 / $MAX_CONV_RATE |
---|
| 203 | if ($MAX_CONV_RATE); |
---|
| 204 | |
---|
| 205 | # Set chrono to return progression status when required |
---|
| 206 | my @StartTime = &gettimeofday(); |
---|
| 207 | my $tv_timing = $CONV_STATUS_TIMING ; |
---|
| 208 | |
---|
| 209 | $buffer = getc( $AFPDSFILE ) ; |
---|
| 210 | while ( defined( $buffer ) and ! eof($AFPDSFILE) ) { |
---|
| 211 | |
---|
| 212 | # Update afpbuffer |
---|
| 213 | $afpbuffer .= $buffer ; |
---|
| 214 | |
---|
| 215 | # Manage the 0x5A char |
---|
| 216 | if ( ord( $buffer ) == 0x5A and ! $inXML ) { |
---|
| 217 | |
---|
| 218 | # Read the field length |
---|
| 219 | read $AFPDSFILE , $buffer , 8 ; |
---|
| 220 | $long = &compute( \$buffer , 0 , 2 ) ; |
---|
| 221 | |
---|
| 222 | # Update afpbuffer |
---|
| 223 | $afpbuffer .= $buffer ; |
---|
| 224 | |
---|
| 225 | # Keep preamble for debugging |
---|
| 226 | my $preamble = $buffer ; |
---|
| 227 | |
---|
| 228 | # Abort if field is too short |
---|
| 229 | &Abort(114,$long) if ( $long < 8 ); |
---|
| 230 | |
---|
| 231 | # Compute other attributes |
---|
| 232 | |
---|
| 233 | # cf doc IBM AFP - programming guide and line data ref - 54438842 |
---|
| 234 | my $ident = &compute( \$buffer , 2 , 3 ) ; |
---|
| 235 | my $flag = &compute( \$buffer , 5 , 1 ) ; |
---|
| 236 | my $reserved = &compute( \$buffer , 6 , 2 ) ; |
---|
| 237 | |
---|
| 238 | # In case file is line delimited, then $readmode = 2, so we |
---|
| 239 | # need to check and found 2 more chars to be CRLF |
---|
| 240 | $long -= 8 - $readmode ; |
---|
| 241 | |
---|
| 242 | &Debug(sprintf("Long is %d, Ident is 0x%x and Flag is 0x%x", |
---|
| 243 | $long, $ident, $flag )); |
---|
| 244 | |
---|
| 245 | if ( $long > 0 ) { |
---|
| 246 | # Read the value of $ident |
---|
| 247 | read $AFPDSFILE , $buffer , $long ; |
---|
| 248 | |
---|
| 249 | # Update afpbuffer |
---|
| 250 | $afpbuffer .= $buffer ; |
---|
| 251 | |
---|
| 252 | # Some lines are full filled with spaces... |
---|
| 253 | if ( $readmode > 0 ) { |
---|
| 254 | # The value should end with 0x0D0A, |
---|
| 255 | # else read until end of line... |
---|
| 256 | $tmp = &compute( \$buffer , -2 , 2 ); |
---|
| 257 | if ( $tmp != 0x0D0A ) { |
---|
| 258 | |
---|
| 259 | # Read till the real end of line |
---|
| 260 | my $plus = &myreadline( \*$AFPDSFILE , \$buffer ); |
---|
| 261 | |
---|
| 262 | # Update afpbuffer |
---|
| 263 | $afpbuffer .= substr($buffer,-$plus) if $plus ; |
---|
| 264 | |
---|
| 265 | $long += $plus ; |
---|
| 266 | |
---|
| 267 | # Definitive check |
---|
| 268 | $tmp = &compute( \$buffer , -2 , 2 ); |
---|
| 269 | if ( $tmp != 0x0D0A ) { |
---|
| 270 | &debugbuffer( $preamble . $buffer ); |
---|
| 271 | &Abort(110,$tmp); |
---|
| 272 | } |
---|
| 273 | } |
---|
| 274 | |
---|
| 275 | $long -= &mychomp( \$buffer, 'keep spaces' ) ; |
---|
| 276 | } |
---|
| 277 | |
---|
| 278 | # Check we read as byte as we need |
---|
| 279 | if ( length($buffer) != $long ) { |
---|
| 280 | &debugbuffer($preamble . $buffer); |
---|
| 281 | &Abort(111,length($buffer),$long); |
---|
| 282 | } |
---|
| 283 | |
---|
| 284 | } else { |
---|
| 285 | # Reset the buffer if nothing has been needed to read |
---|
| 286 | $buffer = "" ; |
---|
| 287 | } |
---|
| 288 | |
---|
| 289 | if (defined($self->{AFPDS})) { |
---|
| 290 | &debugbuffer( $preamble . $buffer ); |
---|
| 291 | |
---|
| 292 | my @params = ( $ident, $flag, $reserved, $long, $buffer, |
---|
| 293 | $texbase ); |
---|
| 294 | # Don't try to analyse 5A record if @skip is not empty |
---|
| 295 | &Abort( 200, $self->{AFPDS}->geterror() ) |
---|
| 296 | if ( ! @skip and $self->{AFPDS}->got5Achar(@params) < 0 ); |
---|
| 297 | |
---|
| 298 | } else { |
---|
| 299 | # Rise abort if we got 0x5A AFP record without AFPDS Flux |
---|
| 300 | # Object initialization |
---|
| 301 | &Abort(3); |
---|
| 302 | } |
---|
| 303 | |
---|
| 304 | # Check got5Achar didn't rise an error |
---|
| 305 | &Abort( 118, $ident, $flag, $reserved, $long, |
---|
| 306 | join('',map { sprintf("%X",$_) } split(//,$buffer) )) |
---|
| 307 | unless (defined($self->{AFPDS})); |
---|
| 308 | |
---|
| 309 | ######################################################################## |
---|
| 310 | ## Manage the 0x7B char '#' for C930 control record (or RC) ## |
---|
| 311 | ######################################################################## |
---|
| 312 | } elsif ( ord( $buffer ) == 0x7B or $inXML ) { |
---|
| 313 | |
---|
| 314 | my ( $begin , $Type ) = ( $buffer , "" ); |
---|
| 315 | read( $AFPDSFILE , $Type , 3 ) ; |
---|
| 316 | |
---|
| 317 | # And check this is really a numbered RC |
---|
| 318 | read( $AFPDSFILE , $buffer , 1 ) ; |
---|
| 319 | |
---|
| 320 | # Update begin to later update afpbuffer |
---|
| 321 | my $rawtype = $Type . $buffer ; |
---|
| 322 | |
---|
| 323 | # Must found another '#' as format validation if not in XML reading |
---|
| 324 | &Abort(112,$Type) |
---|
| 325 | unless ( $inXML or ord( $buffer ) == 0x7B ); |
---|
| 326 | |
---|
| 327 | &from_to( $Type , $FROM_CONVERT , $TO_CONVERT ) if ($DO_CONVERT); |
---|
| 328 | |
---|
| 329 | my $afpds = $self->{AFPDS} ; |
---|
| 330 | |
---|
| 331 | # Generate a print if still after the first print analysis |
---|
| 332 | if ( ! $inXML and $GenFlag |
---|
| 333 | and ( $Type eq '001' or $Type eq '100' )) { |
---|
| 334 | if (defined($afpds)) { |
---|
| 335 | &Debug("File#${file}: Start TeX file generation"); |
---|
| 336 | |
---|
| 337 | # Output this TeX file or rise an ABTERM |
---|
| 338 | unless ( @skip or &generateTeX ) { |
---|
| 339 | &Abort(103, $file, defined($self->{RC}->{$Type}) ? |
---|
| 340 | $self->{RC}->{$Type}->getoutfile() |
---|
| 341 | : |
---|
| 342 | "with undefined '$Type' RC" |
---|
| 343 | ); |
---|
| 344 | } |
---|
| 345 | |
---|
| 346 | # Increment file index |
---|
| 347 | $file ++ ; |
---|
| 348 | |
---|
| 349 | } else { |
---|
| 350 | # Abort if AFPDS object has vanished |
---|
| 351 | &Abort(4) ; |
---|
| 352 | } |
---|
| 353 | } |
---|
| 354 | |
---|
| 355 | # Initialise a new AFPDS flux only on record Type 001 or 100 |
---|
| 356 | if (! $inXML and ( $Type eq '001' or $Type eq '100' )) { |
---|
| 357 | &UPSTAT('GETNEWJOB'); |
---|
| 358 | |
---|
| 359 | # Reset skipping array to try another document |
---|
| 360 | if (@skip) { |
---|
| 361 | # Starting new job after ABTERM |
---|
| 362 | &Abort(500,$file); # Warn we are trying to start a new job |
---|
| 363 | @skip = () ; |
---|
| 364 | } |
---|
| 365 | |
---|
| 366 | # Destroy last afpds object if needed and create new one |
---|
| 367 | delete $self->{AFPDS} if (defined($afpds)); |
---|
| 368 | undef $afpds ; |
---|
| 369 | |
---|
| 370 | &Debug("Initializing AFPDS objects"); |
---|
| 371 | $afpds = new AFPDS::Flux( $afpdsfile , $self , $Job ); |
---|
| 372 | |
---|
| 373 | # And don't forget to keep a copy |
---|
| 374 | $self->{AFPDS} = $afpds ; |
---|
| 375 | } |
---|
| 376 | |
---|
| 377 | # Update job index in flux in case it has changed |
---|
| 378 | $afpds->setjobindex( $file ); |
---|
| 379 | |
---|
| 380 | # Still check AFPDS Flux object exists |
---|
| 381 | &Abort(117,$Type) unless (defined($afpds)); |
---|
| 382 | |
---|
| 383 | my $RC ; |
---|
| 384 | my ( $tA , $tB ) = ( ord($begin) == 0x7B , ord($buffer) == 0x7B ) ; |
---|
| 385 | |
---|
| 386 | # Continue last not sized RC unless it is the stop one |
---|
| 387 | if ( $inXML and |
---|
| 388 | (( $inXML eq '200' and ! ( $Type eq '201' and $tA and $tB )) or |
---|
| 389 | ( $inXML eq '201' and ! ( $Type eq '202' and $tA and $tB )))) |
---|
| 390 | { |
---|
| 391 | &Debug("In XML $inXML: Type would be '" . ( $tA ? '#' : '.' ) . |
---|
| 392 | $Type . ( $tB ? '#' : '.' ) . "'"); |
---|
| 393 | |
---|
| 394 | # Still reading an XML, seek to beginning of line to avoid |
---|
| 395 | # missing an EOL if the begin string |
---|
| 396 | seek $AFPDSFILE, -5 , 1 ; |
---|
| 397 | |
---|
| 398 | # Type has been saved in inXML |
---|
| 399 | $Type = $inXML ; |
---|
| 400 | |
---|
| 401 | # Get last created RC |
---|
| 402 | $RC = $self->{RC}->{$Type} ; |
---|
| 403 | |
---|
| 404 | } else { |
---|
| 405 | # Update afpbuffer |
---|
| 406 | $afpbuffer .= $rawtype ; |
---|
| 407 | |
---|
| 408 | # Destroy last control record if needed and create new one |
---|
| 409 | delete $self->{RC}->{$Type} if (defined($self->{RC}->{$Type})); |
---|
| 410 | |
---|
| 411 | # Get new RC object |
---|
| 412 | $RC = new AFPDS::ControlRecord( $Type,$texbase,$AfpName,$file ); |
---|
| 413 | |
---|
| 414 | &Debug("Found a control record type '$Type'"); |
---|
| 415 | } |
---|
| 416 | |
---|
| 417 | # Check object creation |
---|
| 418 | &Abort(115, $file, $Type , $texbase ) unless (defined($RC)); |
---|
| 419 | |
---|
| 420 | $buffer = "" ; |
---|
| 421 | |
---|
| 422 | # Initialization should return the length of the record control |
---|
| 423 | # Else it should return 0 to stop reading as record type is unknown |
---|
| 424 | $tmp = defined($RC) ? $RC->get_required_size() + $readmode : 0 ; |
---|
| 425 | &Abort(113,$tmp,$Type) unless ($tmp); |
---|
| 426 | |
---|
| 427 | # Read now ControlRecord and analyse it |
---|
| 428 | if ( $tmp > 0 and read( $AFPDSFILE, $buffer, $tmp ) == $tmp ) { |
---|
| 429 | |
---|
| 430 | &debugbuffer($buffer); |
---|
| 431 | &Abort(300,$Type,$RC->geterror()) |
---|
| 432 | if ( defined($RC) and $RC->init( $buffer ) < 0 ); |
---|
| 433 | |
---|
| 434 | # Check initialization is done |
---|
| 435 | &Abort( 116, $Type, sprintf( "%02X" x length($buffer), |
---|
| 436 | map { ord } split( //, $buffer ) ) ) |
---|
| 437 | unless (defined($RC)); |
---|
| 438 | |
---|
| 439 | # Set job_tag for this RC library |
---|
| 440 | $RC->job_tag($Job); |
---|
| 441 | |
---|
| 442 | # Check if we have reached a afpds splitting event |
---|
| 443 | if ( ! @skip and $RC->can_split_job() ) { |
---|
| 444 | # Compute the pos in file for the next job to convert |
---|
| 445 | my $pos = tell($AFPDSFILE) - length($afpbuffer) |
---|
| 446 | - length($buffer); |
---|
| 447 | |
---|
| 448 | # Get a tag |
---|
| 449 | my @split_tags = $RC->get_split_tags ; |
---|
| 450 | |
---|
| 451 | # Set this job is the last of a split event |
---|
| 452 | $afpds->updateEnv( { |
---|
| 453 | # Set SPLIT_FILE with first position in file and length |
---|
| 454 | SPLIT_FILE => $startpos . ':' . $pos, |
---|
| 455 | SPLIT_TAG => $split_tags[0], |
---|
| 456 | SPLIT_TAG2 => $split_tags[1] |
---|
| 457 | } ); |
---|
| 458 | |
---|
| 459 | # Skip the rest to leave as a splitting event |
---|
| 460 | push @skip, 'splitted' ; |
---|
| 461 | |
---|
| 462 | # Finish that job |
---|
| 463 | last ; |
---|
| 464 | } |
---|
| 465 | |
---|
| 466 | if ( ! @skip and ($Type eq '001' or $Type eq '100')) { |
---|
| 467 | |
---|
| 468 | my $pagedef = $RC->getpagedef() ; |
---|
| 469 | |
---|
| 470 | &UPSTAT('USEPAGEDEF_' . $pagedef ); |
---|
| 471 | |
---|
| 472 | # Load the perl Library for the PAGEDEF only on record |
---|
| 473 | # Type 001 or 100 |
---|
| 474 | my $loadlib = "perllib::p1" . lc( $pagedef ); |
---|
| 475 | |
---|
| 476 | # Abort if we won't be able to load perl module |
---|
| 477 | if ($pagedef) { |
---|
| 478 | &Abort(104,$pagedef,$loadlib) |
---|
| 479 | unless ( grep { |
---|
| 480 | -s $_ . '/perllib/p1' . lc( $pagedef ) . '.pm' |
---|
| 481 | } @INC ); |
---|
| 482 | |
---|
| 483 | } else { |
---|
| 484 | &Abort(6); |
---|
| 485 | } |
---|
| 486 | |
---|
| 487 | unless (@skip) { |
---|
| 488 | &Debug("Loading library with '$loadlib' evaluation"); |
---|
| 489 | eval "use " . $loadlib ; |
---|
| 490 | |
---|
| 491 | $afpds->setpagedef( $pagedef ); |
---|
| 492 | $afpds->setpclcond( $RC->ispcloutput() ); |
---|
| 493 | $afpds->setformdef( $RC->getformdef() ); |
---|
| 494 | $afpds->setoutfile( $RC->getoutfile() ); |
---|
| 495 | $afpds->setTRCforTeX( $RC->getTRCforTeX()); |
---|
| 496 | |
---|
| 497 | &Debug("Perl library loaded"); |
---|
| 498 | } |
---|
| 499 | |
---|
| 500 | # Close previous file handles if it's not the first job |
---|
| 501 | $self->CloseFiles if ($GenFlag); |
---|
| 502 | $GenFlag = $self->OpenFiles( $RC->getoutfile() ); |
---|
| 503 | } |
---|
| 504 | |
---|
| 505 | unless (@skip) { |
---|
| 506 | # Env is updated in Flux and will be returned to JobManager |
---|
| 507 | # when completly analysed |
---|
| 508 | $afpds->updateEnv( $RC->getenv() ); |
---|
| 509 | |
---|
| 510 | # Update ArchFile with RECORD content when necessary |
---|
| 511 | local $\ = "\n" ; |
---|
| 512 | print $ArchFile $RC->getRecord |
---|
| 513 | if (defined($ArchFile) and $RC->getRecord()); |
---|
| 514 | |
---|
| 515 | # Keep a record copy in our RC hash |
---|
| 516 | $self->{RC}->{$Type} = $RC ; |
---|
| 517 | } |
---|
| 518 | |
---|
| 519 | # Handle not sized Control Record type 200-202 |
---|
| 520 | } elsif ($tmp < 0 and $Type =~ /^20[0-2]$/) { |
---|
| 521 | |
---|
| 522 | my $line = "" ; |
---|
| 523 | # Read till the end of line |
---|
| 524 | &myreadline( \*$AFPDSFILE , \$line ); |
---|
| 525 | |
---|
| 526 | # Update afpbuffer (first char always added at loop begining) |
---|
| 527 | $afpbuffer .= substr($line,($inXML and $Type eq '201')?1:0) ; |
---|
| 528 | |
---|
| 529 | &mychomp( \$line ); |
---|
| 530 | |
---|
| 531 | # Check record |
---|
| 532 | if ( $Type eq '202' ) { |
---|
| 533 | # Stopping an input |
---|
| 534 | |
---|
| 535 | # Forget any information just behind RC 202 string |
---|
| 536 | if ($line !~ /^$/) { |
---|
| 537 | &from_to( $line , $FROM_CONVERT , $TO_CONVERT ) |
---|
| 538 | if ($DO_CONVERT); |
---|
| 539 | &Info(_job_tag."RC 202 tagged with '$line'"); |
---|
| 540 | } |
---|
| 541 | |
---|
| 542 | # Check last record 100 to set the PDF name and service flag |
---|
| 543 | &Abort(120, $Type , 100) |
---|
| 544 | unless (defined($self->{RC}->{100})); |
---|
| 545 | |
---|
| 546 | # Check last record 200 to get the working folder |
---|
| 547 | &Abort(120, $Type , 200) |
---|
| 548 | unless (defined($self->{RC}->{200})); |
---|
| 549 | |
---|
| 550 | # Check base directory availability for pdf file |
---|
| 551 | my $base = @skip ? undef : $self->{RC}->{100}->getbase ; |
---|
| 552 | &Abort(122, $base) |
---|
| 553 | unless ( defined($base) and $base and -d $base ); |
---|
| 554 | |
---|
| 555 | my $outbase = $base . '/' . $LOCKID . '_' . $Job ; |
---|
| 556 | my $env = { |
---|
| 557 | 'PDFFILE' => $outbase . "-$file.pdf", |
---|
| 558 | 'XML_A2P' => $outbase . "_a2p-$file.xml", |
---|
| 559 | 'XML_CONTENT' => $outbase . "_service-$file.xml" |
---|
| 560 | } ; |
---|
| 561 | |
---|
| 562 | # Update a2p xml attributs before saving |
---|
| 563 | my @attribut = ( pdf => $env->{PDFFILE} ); |
---|
| 564 | unless (@skip) { |
---|
| 565 | $self->{RC}->{200}->set_a2p_attribut(@attribut) |
---|
| 566 | or &Abort(123 , @attribut); |
---|
| 567 | } |
---|
| 568 | |
---|
| 569 | @attribut = ( file => $env->{XML_CONTENT} ); |
---|
| 570 | unless (@skip) { |
---|
| 571 | $self->{RC}->{200}->set_a2p_attribut(@attribut) |
---|
| 572 | or &Abort(123 , @attribut); |
---|
| 573 | } |
---|
| 574 | |
---|
| 575 | # Save A2P xml |
---|
| 576 | unless (@skip) { |
---|
| 577 | $self->{RC}->{200}->save_a2pxml_file($env->{XML_A2P}) |
---|
| 578 | or &Abort(121 , 200, $env->{XML_A2P}); |
---|
| 579 | } |
---|
| 580 | |
---|
| 581 | # Check last record 201 to save the content |
---|
| 582 | &Abort(120, $Type , 201) |
---|
| 583 | unless (defined($self->{RC}->{201})); |
---|
| 584 | |
---|
| 585 | # Save RC 201 content |
---|
| 586 | unless (@skip) { |
---|
| 587 | my $content = $env->{XML_CONTENT} ; |
---|
| 588 | $self->{RC}->{201}->save_a2pxml_file($content) |
---|
| 589 | or &Abort( 121 , 201, $content ); |
---|
| 590 | } |
---|
| 591 | |
---|
| 592 | # Tag Flux as e-service and not arch |
---|
| 593 | &Debug("Updating env to handle content and a2p xml files"); |
---|
| 594 | $afpds->updateEnv( $env ) |
---|
| 595 | unless (@skip); |
---|
| 596 | |
---|
| 597 | &Debug("Service is ready to handle E-Service request"); |
---|
| 598 | # Release inXML flag |
---|
| 599 | $inXML = 0 ; |
---|
| 600 | |
---|
| 601 | } elsif ( $Type eq '201' ) { |
---|
| 602 | if ($inXML) { |
---|
| 603 | |
---|
| 604 | &from_to( $line , $FROM_CONVERT , $TO_CONVERT ) |
---|
| 605 | if ($CONVERT_CONTENT_FILE and $DO_CONVERT); |
---|
| 606 | |
---|
| 607 | # Add EOL to line |
---|
| 608 | $line .= "\n" ; |
---|
| 609 | |
---|
| 610 | # Add the complete line to content |
---|
| 611 | $RC->addcontentref( \$line ) unless (@skip); |
---|
| 612 | &Debug("Added '$line' to content file"); |
---|
| 613 | |
---|
| 614 | } else { |
---|
| 615 | # Forget any information just behind RC 201 string |
---|
| 616 | if ($line !~ /^$/) { |
---|
| 617 | &from_to( $line , $FROM_CONVERT , $TO_CONVERT ) |
---|
| 618 | if ($DO_CONVERT); |
---|
| 619 | &Info(_job_tag."RC 201 tagged with '$line'"); |
---|
| 620 | } |
---|
| 621 | |
---|
| 622 | # Flag we are inXML handling |
---|
| 623 | $inXML = $Type ; |
---|
| 624 | } |
---|
| 625 | |
---|
| 626 | } elsif ( $Type eq '200' ) { |
---|
| 627 | # Check last record 100 to get the working folder |
---|
| 628 | &Abort(120, $Type , 100) |
---|
| 629 | unless (defined($self->{RC}->{100})); |
---|
| 630 | |
---|
| 631 | unless (@skip) { |
---|
| 632 | my $basefile = $self->{RC}->{100}->getoutfile() ; |
---|
| 633 | |
---|
| 634 | # Update |
---|
| 635 | $line = $begin . $line if $inXML ; |
---|
| 636 | &from_to( $line , $FROM_CONVERT , $TO_CONVERT ) |
---|
| 637 | if ($DO_CONVERT); |
---|
| 638 | |
---|
| 639 | $RC->seta2pxml( $line , $basefile ); |
---|
| 640 | |
---|
| 641 | # Tag Flux as e-service |
---|
| 642 | unless ($inXML) { |
---|
| 643 | &Debug("Updating env with expected values"); |
---|
| 644 | $afpds->updateEnv( { |
---|
| 645 | DO_ESERVICE => 'yes', |
---|
| 646 | DO_PDF => 'yes', |
---|
| 647 | } ); |
---|
| 648 | } |
---|
| 649 | |
---|
| 650 | # Flag we are inXML handling if not complete and valid |
---|
| 651 | $inXML = $RC->a2pxml_is_valid() || $Type ; |
---|
| 652 | |
---|
| 653 | # Remark: service name '200' is an error as prohibited |
---|
| 654 | # (checked in XML.pm) |
---|
| 655 | if ($inXML and $inXML ne $Type) { |
---|
| 656 | &Debug("Updating env with requested service"); |
---|
| 657 | $afpds->updateEnv( { |
---|
| 658 | E_SERVICE => $inXML |
---|
| 659 | } ); |
---|
| 660 | |
---|
| 661 | # Release inXML flag |
---|
| 662 | $inXML = 0 ; |
---|
| 663 | } |
---|
| 664 | } |
---|
| 665 | } |
---|
| 666 | |
---|
| 667 | # Keep a record copy in our RC hash |
---|
| 668 | $self->{RC}->{$Type} = $RC unless (@skip); |
---|
| 669 | |
---|
| 670 | } else { |
---|
| 671 | # Bad length read for that record |
---|
| 672 | &debugbuffer($buffer); |
---|
| 673 | &Abort(102,$Type); |
---|
| 674 | } |
---|
| 675 | |
---|
| 676 | # Update afpbuffer |
---|
| 677 | $afpbuffer .= $buffer ; |
---|
| 678 | |
---|
| 679 | # End of ControlRecord management |
---|
| 680 | |
---|
| 681 | } else { |
---|
| 682 | # This is a standard line, first char is the control char |
---|
| 683 | $cctrl = $buffer ; |
---|
| 684 | &from_to( $cctrl , $FROM_CONVERT , $TO_CONVERT ) if ($DO_CONVERT); |
---|
| 685 | &Debug("Found standard line with control char <$cctrl>"); |
---|
| 686 | |
---|
| 687 | # The next char is used to select TRC font |
---|
| 688 | read( $AFPDSFILE , $char , 1 ); |
---|
| 689 | |
---|
| 690 | # Update afpbuffer |
---|
| 691 | $afpbuffer .= $char ; |
---|
| 692 | |
---|
| 693 | # Check AFPDS Flux is defined |
---|
| 694 | if (defined($self->{AFPDS})) { |
---|
| 695 | |
---|
| 696 | # ErFo001 Fix: Select TRC font |
---|
| 697 | $self->{AFPDS}->selectTRCfont( ord($char) ) |
---|
| 698 | unless (@skip); |
---|
| 699 | |
---|
| 700 | # Read the rest of the line |
---|
| 701 | $buffer = ""; |
---|
| 702 | $long = &myreadline( \*$AFPDSFILE , \$buffer ); |
---|
| 703 | |
---|
| 704 | # Update afpbuffer |
---|
| 705 | $afpbuffer .= $buffer ; |
---|
| 706 | |
---|
| 707 | $tmp = &compute( \$buffer , -2 , 2 ); |
---|
| 708 | if ( $tmp != 0x0D0A ) { # Buffer must end with 0x0D0A |
---|
| 709 | &debugbuffer( $buffer ); |
---|
| 710 | &Abort(101,$tmp); |
---|
| 711 | } |
---|
| 712 | |
---|
| 713 | } else { |
---|
| 714 | &Abort(5); |
---|
| 715 | } |
---|
| 716 | |
---|
| 717 | &mychomp( \$buffer ); |
---|
| 718 | $long = length( $buffer ) ; |
---|
| 719 | |
---|
| 720 | &from_to( $buffer , $FROM_CONVERT , $TO_CONVERT ) if ($DO_CONVERT); |
---|
| 721 | |
---|
| 722 | # Compute the new AFP line |
---|
| 723 | $self->{AFPDS}->afpline( $cctrl , $buffer ) |
---|
| 724 | unless (@skip); |
---|
| 725 | } |
---|
| 726 | |
---|
| 727 | my $currentpos = tell($AFPDSFILE) ; |
---|
| 728 | my $currenttime = &tv_interval(\@StartTime) ; |
---|
| 729 | |
---|
| 730 | # Return convertion status after required timing |
---|
| 731 | if ( $currenttime >= $tv_timing ) { |
---|
| 732 | my $fileratio = $currentpos/$EOF ; |
---|
| 733 | |
---|
| 734 | # Compute convertion ratio |
---|
| 735 | my $ratio = sprintf("%d",$fileratio*100); |
---|
| 736 | |
---|
| 737 | # Compute termination estimation |
---|
| 738 | my $remain = sprintf("%.1f",$currenttime/$fileratio-$currenttime); |
---|
| 739 | &Debug("Convertion done at $ratio%, should finish in $remain s"); |
---|
| 740 | |
---|
| 741 | # Return information to JobManager |
---|
| 742 | $self->Return( $Job => &GetCom( comINF , |
---|
| 743 | 'AFP2TeX Conversion status' => |
---|
| 744 | "$ratio% done, $remain sec remaining" )); |
---|
| 745 | |
---|
| 746 | # Update job state in spool |
---|
| 747 | &a2pjobstate( $Job, 2, '.' , { STATUS => $ratio.'%' }) |
---|
| 748 | or &Info("Can't update status conversion progress to $ratio%"); |
---|
| 749 | |
---|
| 750 | # Update next timing report |
---|
| 751 | $tv_timing += $CONV_STATUS_TIMING ; |
---|
| 752 | } |
---|
| 753 | |
---|
| 754 | &Debug("Loop at AFPDS file off-set " . sprintf("%Xh",$currentpos) . |
---|
| 755 | ($inXML?" in not sized RC '$inXML'":"")); |
---|
| 756 | |
---|
| 757 | $buffer = getc( $AFPDSFILE ) ; |
---|
| 758 | |
---|
| 759 | } # End while read file |
---|
| 760 | |
---|
| 761 | &Debug("File#" . $file . ": Last TeX file generation"); |
---|
| 762 | |
---|
| 763 | # Output last converted TeX file |
---|
| 764 | &Abort(2) unless ( @skip or &generateTeX ); |
---|
| 765 | |
---|
| 766 | # Keep stats on conversion rate |
---|
| 767 | my $tv_interval = &tv_interval($RateTimer) ; |
---|
| 768 | &MAXSTAT('CONV-RATE',int( 100 * $file / $tv_interval ) / 100) |
---|
| 769 | if ($tv_interval); |
---|
| 770 | |
---|
| 771 | ABORTED_FILE: |
---|
| 772 | # Freeing objects |
---|
| 773 | delete $self->{AFPDS} |
---|
| 774 | if (defined($self->{AFPDS}) and ! $self->{AFPDS}->issplitted()); |
---|
| 775 | delete $self->{RC} if ( defined($self->{RC}) ); |
---|
| 776 | |
---|
| 777 | # Reset vars |
---|
| 778 | $file = 0 ; |
---|
| 779 | |
---|
| 780 | return $ErrFlag ? &End($ErrFlag) : &End(0, "Conversion done" ); |
---|
| 781 | } |
---|
| 782 | |
---|
| 783 | my ( $conv_time , $conv_count ) = ( 0, 0 ); |
---|
| 784 | sub generateTeX { |
---|
| 785 | my $afpds = $self->{AFPDS} ; |
---|
| 786 | |
---|
| 787 | # Check few things on RC |
---|
| 788 | # At least a RC 001 or a RC 100 must have been provided |
---|
| 789 | return &Error(_job_tag."No RC 001 or RC 100 defined") |
---|
| 790 | unless (defined($self->{RC}->{'001'}) or defined($self->{RC}->{'100'})); |
---|
| 791 | # If a RC 200 has been provided, we must also have a RC 201 and a RC 202 |
---|
| 792 | return &Error(_job_tag."Found wrong combination of record 200-202") |
---|
| 793 | if (defined($self->{RC}->{'200'}) and |
---|
| 794 | $self->{RC}->{'200'}->a2pxml_is_valid and |
---|
| 795 | !(defined($self->{RC}->{'201'}) and defined($self->{RC}->{'202'}))); |
---|
| 796 | |
---|
| 797 | # Output the convertex TeX file |
---|
| 798 | return &Error(_job_tag."Error while generating TeX file") |
---|
| 799 | unless ($afpds->gentex( $TexFile )); |
---|
| 800 | |
---|
| 801 | # Output to AfpFile and check TeX convertion rate |
---|
| 802 | if (defined($afpbuffer) and length($afpbuffer)) { |
---|
| 803 | |
---|
| 804 | # 1. Output to AfpFile |
---|
| 805 | if (eof($AFPDSFILE)) { |
---|
| 806 | print $AfpFile $afpbuffer if (defined($AfpFile)); |
---|
| 807 | |
---|
| 808 | } else { |
---|
| 809 | # Output AfpFile without the last char '#' |
---|
| 810 | print $AfpFile substr($afpbuffer,0,-1) |
---|
| 811 | if (defined($AfpFile)); |
---|
| 812 | |
---|
| 813 | # And reset afpbuffer with only char '#' ( in ebcdic) |
---|
| 814 | $afpbuffer = chr(0x7B); |
---|
| 815 | } |
---|
| 816 | |
---|
| 817 | # 2. Wait a little to match required TeX convertion rate |
---|
| 818 | # essentially on big job |
---|
| 819 | if ( $MAX_CONV_RATE and $file > $MAX_CONV_RATE ) { |
---|
| 820 | my $prev_conv_time = $conv_time ; # Default to zero |
---|
| 821 | |
---|
| 822 | # Still sleep a little if we can |
---|
| 823 | if ( $conv_time ) { |
---|
| 824 | &MAXSTAT('CONV-RATE-PRE-SLEEP-TIME',$conv_time); |
---|
| 825 | usleep $conv_time ; |
---|
| 826 | } |
---|
| 827 | |
---|
| 828 | # Get the delay since the beginning of that conversion |
---|
| 829 | $conv_time = &tv_interval($RateTimer) * 1_000_000 ; |
---|
| 830 | |
---|
| 831 | # min_conv_time is the time by conversion to reach computed before |
---|
| 832 | # each conversion start |
---|
| 833 | my $diff = $conv_time - $file * $min_conv_time ; |
---|
| 834 | my $count = $file > $conv_count ? $file - $conv_count : 1 ; |
---|
| 835 | if ( $diff < 0 ) { |
---|
| 836 | # Get the time we should have sleep to reach max_conv_rate |
---|
| 837 | my $usleep = abs($diff) ; |
---|
| 838 | |
---|
| 839 | # Really not sleep if time to sleep is too short |
---|
| 840 | unless ( $usleep < $USLEEP ) { |
---|
| 841 | &UPSTAT('CONV-RATE-SLEEPING'); |
---|
| 842 | &MAXSTAT('CONV-RATE-SLEEP-TIME',$usleep); |
---|
| 843 | &Debug("Waiting $usleep ms to lower speed as " . |
---|
| 844 | $MAX_CONV_RATE . " Max conversion rate was reached"); |
---|
| 845 | usleep $usleep ; |
---|
| 846 | } |
---|
| 847 | $conv_time = $usleep / $count ; |
---|
| 848 | |
---|
| 849 | } elsif ($prev_conv_time) { |
---|
| 850 | &UPSTAT('CONV-RATE-SLEPT-TOO-MUCH'); |
---|
| 851 | # diff is the excess time we have slept |
---|
| 852 | my $correction = $count > 0 ? $diff / $count : 0 ; |
---|
| 853 | |
---|
| 854 | # Always reset $conv_time to keep the sleep next time |
---|
| 855 | if ( $correction > 0 and $correction < $prev_conv_time |
---|
| 856 | and $conv_time > $USLEEP ) { |
---|
| 857 | # Adjust conv_time to sleep less next time |
---|
| 858 | $conv_time = $prev_conv_time - $correction ; |
---|
| 859 | |
---|
| 860 | } else { |
---|
| 861 | $conv_time = $prev_conv_time ; |
---|
| 862 | } |
---|
| 863 | } |
---|
| 864 | |
---|
| 865 | # Remember conversion count |
---|
| 866 | $conv_count = $file ; |
---|
| 867 | } |
---|
| 868 | } |
---|
| 869 | |
---|
| 870 | # Return the job environment to JobManager |
---|
| 871 | &Debug("File#" . $file . ": Shell env file generation"); |
---|
| 872 | |
---|
| 873 | # Set MTIME job env to file mtime |
---|
| 874 | $afpds->updateEnv( { MTIME => $mtime } ); |
---|
| 875 | |
---|
| 876 | # Announce last job to master thread |
---|
| 877 | $self->Return( $Job , $afpds->getEnv() ); |
---|
| 878 | |
---|
| 879 | # And keep some stats |
---|
| 880 | $self->KeepStats( $Job, $afpds->getstat() ); |
---|
| 881 | |
---|
| 882 | # Update job state in spool |
---|
| 883 | &a2pjobstate( $Job, 2, 'o' ) |
---|
| 884 | or &Info(_job_tag."Can't update status to step 2 done"); |
---|
| 885 | |
---|
| 886 | # Return true |
---|
| 887 | 1 ; |
---|
| 888 | } |
---|
| 889 | |
---|
| 890 | |
---|
| 891 | ################################################################################ |
---|
| 892 | sub End { |
---|
| 893 | # End jobs here as it closes properly any opened file |
---|
| 894 | my $ret = shift || 0 ; |
---|
| 895 | my $msg = shift || ""; |
---|
| 896 | |
---|
| 897 | if (defined($msg)) { |
---|
| 898 | $ret and $msg ? &Error($msg) : &Debug($msg) ; |
---|
| 899 | } |
---|
| 900 | |
---|
| 901 | # Now clean everything |
---|
| 902 | &Debug("Closing files"); |
---|
| 903 | |
---|
| 904 | &CloseFiles(); |
---|
| 905 | close($AFPDSFILE) if (defined($AFPDSFILE)); |
---|
| 906 | |
---|
| 907 | return $ErrFlag ? $ErrFlag : $ret ; |
---|
| 908 | } |
---|
| 909 | |
---|
| 910 | our $AbortMessages = { |
---|
| 911 | 0 => "Unknown error", |
---|
| 912 | 1 => "Last TeX file not generated", |
---|
| 913 | 2 => "Can't generate TeX file", |
---|
| 914 | 3 => "Can't handle RC 5A without AFPDS flux defined", |
---|
| 915 | 4 => "Expected defined AFPDS flux here", |
---|
| 916 | 5 => "Can't processing standard AFP line without AFPDS Flux defined", |
---|
| 917 | 6 => "Can't load PAGEDEF as it isn't defined", |
---|
| 918 | 100 => "Can't use not defined '%s' controlrecord", |
---|
| 919 | 101 => "Found AFPDS text line with bad end of line <0x%04X>", |
---|
| 920 | 102 => "Unknown control record '%s'", |
---|
| 921 | 103 => "File#%s: Bad TeX file generation for print %s", |
---|
| 922 | 104 => "Unable to load PAGEDEF %s as Perl module %s not found", |
---|
| 923 | 105 => "freed error number", |
---|
| 924 | 106 => "Can't create %s folder: %s", |
---|
| 925 | 107 => "Can't open %s: %s", |
---|
| 926 | 108 => "Can't process %s in binary mode: %s", |
---|
| 927 | 109 => "Can't read last 10 chars of %s: %s", |
---|
| 928 | 110 => "Found AFPDS Field with bad end of line <0x%04X>", |
---|
| 929 | 111 => "Found AFPDS Field with bad length: %s vs %s", |
---|
| 930 | 112 => "Bad control record type format found for record type '%s'", |
---|
| 931 | 113 => "Bad control record length (%s) for record type '%s'", |
---|
| 932 | 114 => "Got bad AFPDS format as RC 5A is too short (%s < 8)", |
---|
| 933 | 115 => "Can't create RC object %d of type '%s' with TEXBASE '%s'", |
---|
| 934 | 116 => "Can't initialize RC type '%s' with buffer '%s'", |
---|
| 935 | 117 => "Can't use RC type '%s' on with no AFPDS Flux defined", |
---|
| 936 | 118 => "AFP error on RC 5A with ident %6X, flag %08b, reserved 0x%04X, ". |
---|
| 937 | "long %d and buffer %s", |
---|
| 938 | 119 => "Can't use existing folder '%s' to compute AFPDS file", |
---|
| 939 | 120 => "Can't use RC type %d without previously defined RC type %d", |
---|
| 940 | 121 => "Can't save XML content for RC type %d in %s", |
---|
| 941 | 122 => "Folder '%s' not available", |
---|
| 942 | 123 => "Can't update '%s' attribut with value '%s' in A2P XML", |
---|
| 943 | 124 => "File '%s' is too short or corrupted", |
---|
| 944 | 200 => "Got RC 5A error %d, %s", |
---|
| 945 | 300 => "Got RC #%s# init error %d, %s", |
---|
| 946 | 500 => "trying to convert job %d after errors" |
---|
| 947 | }; |
---|
| 948 | |
---|
| 949 | my @AbortErrors = ( |
---|
| 950 | 0, 2, 3, 4, 5, 106, 107, 108, 109, 119, 122 |
---|
| 951 | ); |
---|
| 952 | |
---|
| 953 | # Must be called with number identifying message and then abort processing |
---|
| 954 | sub Abort { |
---|
| 955 | $ErrFlag = shift || 0 ; |
---|
| 956 | |
---|
| 957 | unless ( defined($skip[$ErrFlag]) and $skip[$ErrFlag]++ ) { |
---|
| 958 | @AbortTime = &gettimeofday(); |
---|
| 959 | |
---|
| 960 | my $file_offset = sprintf("AFPDS file off-set %Xh",tell($AFPDSFILE)) ; |
---|
| 961 | |
---|
| 962 | my @ERR = $ErrFlag >= 500 ? |
---|
| 963 | () : ( _job_tag . "Aborting at $file_offset" ) ; |
---|
| 964 | my $msg = $ErrFlag >= 500 ? $file_offset.": " : "" ; |
---|
| 965 | $msg .= _job_tag . $AbortMessages->{$ErrFlag} ; |
---|
| 966 | |
---|
| 967 | my $ABTERM = $ErrFlag < 100 ? |
---|
| 968 | $msg." (Err$ErrFlag)" : sprintf( $msg." (Err%d)" , @_, $ErrFlag ) ; |
---|
| 969 | |
---|
| 970 | # Still return the ABTERM message to JobManager |
---|
| 971 | $self->Return( $Job => &GetCom( comINF , 'ABTERM '.$ErrFlag, $ABTERM )); |
---|
| 972 | |
---|
| 973 | push @ERR, $ABTERM ; |
---|
| 974 | $ErrFlag < 500 ? &Error( @ERR ) : &Warn( @ERR ); |
---|
| 975 | |
---|
| 976 | # Return information to JobManager |
---|
| 977 | map { $self->Return( $Job => &GetCom( comINF , 'ERROR' , $_ )) } @ERR ; |
---|
| 978 | |
---|
| 979 | # Update status for afpjob |
---|
| 980 | map { &a2pjobstate( $Job, 2, 'A', { ABTERM => "$_" } ) } @ERR ; |
---|
| 981 | |
---|
| 982 | # Keep the ABTERM on the current JID if really started |
---|
| 983 | if ( $file ) { |
---|
| 984 | # Update status for subjob designed by JID key in %Infos |
---|
| 985 | my $Infos = { JID => $Job . "-" . $file } ; |
---|
| 986 | $Infos->{STATUS} = 'ABTERM' if ( $ErrFlag < 500 ); |
---|
| 987 | map { |
---|
| 988 | $Infos->{ERRORS} = "$_" ; |
---|
| 989 | &a2pjobstate( $Job, 2, 'A', $Infos ); |
---|
| 990 | } @ERR |
---|
| 991 | } |
---|
| 992 | } |
---|
| 993 | |
---|
| 994 | if (grep { $_ == $ErrFlag } @AbortErrors) { |
---|
| 995 | goto ABORTED_FILE ; |
---|
| 996 | |
---|
| 997 | } else { |
---|
| 998 | # Don't Abort file conversion to try next sub jobs |
---|
| 999 | return $ErrFlag ; |
---|
| 1000 | } |
---|
| 1001 | } |
---|
| 1002 | |
---|
| 1003 | END { |
---|
| 1004 | if ($ErrFlag and @AbortTime) { |
---|
| 1005 | my $time = sprintf("%.2f sec",&tv_interval(\@AbortTime)); |
---|
| 1006 | &Error("Last conversion aborted $time ago with $ErrFlag abort number"); |
---|
| 1007 | } |
---|
| 1008 | } |
---|
| 1009 | |
---|
| 1010 | &Debug("Module " . __PACKAGE__ . " v$VERSION loaded"); |
---|
| 1011 | |
---|
| 1012 | 1; |
---|