[BACK]Return to send.pm CVS log [TXT][DIR] Up to [local] / wpscripts / ztransfer

Diff for /wpscripts/ztransfer/send.pm between version 1.1 and 1.5

version 1.1, 2011/06/03 09:28:47 version 1.5, 2011/08/30 08:30:42
Line 8 
Line 8 
 use warnings;  use warnings;
   
 # spool path constants (without leading slash)  # spool path constants (without leading slash)
 our $SPOOL_ZAYAVKI        = "/usr/backup/wp/zayavki";  our $SPOOL_ZAYAVKI        = "/mnt/archive/archive/wp/zayavki";
 our $SPOOL_PROBAS         = "/usr/backup/wp/proba";  our $SPOOL_PROBAS         = "/mnt/archive/archive/wp/proba";
 our $SPOOL_TMPDIR         = "/usr/backup/temp";  our $SPOOL_TT             = "/mnt/archive/archive/wp/tt";
   our $SPOOL_TMPDIR         = "/mnt/archive/archive/temp";
   
 # temp variables for map table lookup  # temp variables for map table lookup
 our $ret;  our $ret;
Line 85 
Line 86 
         else          else
         {          {
             # hardcoded              # hardcoded
             $remotepaths[$i] =~ s/V(1)/zV7/;              $remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/;
             $remotepaths[$i] =~ s/V(2)/zV8/;  
             $remotepaths[$i] =~ s/V(3)/zV6/;  
             $remotepaths[$i] =~ s/V(4)/zV7/;  
             $remotepaths[$i] =~ s/V(5)/zV7/;  
         }          }
   
         if(-e $remotepaths[$i] || -e $remotepaths[$i] . '.rar')          if(-e $remotepaths[$i] || -e $remotepaths[$i] . '.rar')
Line 114 
Line 111 
   
                  log::zayavki("compressing '$localpaths[$i]' -> '$spool/$curfile'");                   log::zayavki("compressing '$localpaths[$i]' -> '$spool/$curfile'");
   
                  `/usr/local/bin/rar a -rr10% -ep '$spool/$curfile' '$localpaths[$i]'`;                   `/usr/bin/rar a -rr10% -ep '$spool/$curfile' '$localpaths[$i]'`;
                  if( ($? >> 8) == 0)                   if( ($? >> 8) == 0)
                  {                   {
                     # rar exited successfully                      # rar exited successfully
Line 223 
Line 220 
   
   
   
 sub jpegs()  
 {  
     my @dbids;  
     my @localpaths;  
     my @remotepaths;  
     my $dbids_ref;  
     my $localpaths_ref;  
     my $i = 0;  
     my $okay = 0;  
   
     my $size_orig;  
   
     ($dbids_ref, $localpaths_ref) = fetch::jpegs_list();  
   
     @dbids = @$dbids_ref;  
     @localpaths = @$localpaths_ref;  
     log::main("Fetched " . scalar(@localpaths) . " jpegs from database");  
     log::jpegs("<<  Starting transfer process  >>");  
   
     @remotepaths = @localpaths;  # clone  
   
     while($localpaths[$i])  
     {  
         # lookup in table first  
         chomp( $tmpf = `basename $remotepaths[$i]` );  
         chomp( $_ = `dirname $remotepaths[$i]` );  
         $tmpd = hash::lookup($_);  
         if ( $tmpd ne '' )  
         {  
             $remotepaths[$i] =  $tmpd. "/". $tmpf;  
         }  
         else  
         {  
             # hardcoded  
             $remotepaths[$i] =~ s/V(1)/zV7/;  
             $remotepaths[$i] =~ s/V(2)/zV8/;  
             $remotepaths[$i] =~ s/V(3)/zV6/;  
             $remotepaths[$i] =~ s/V(4)/zV7/;  
             $remotepaths[$i] =~ s/V(5)/zV7/;  
         }  
   
         if(-e $remotepaths[$i])  
         {  
             log::error("Remote file $remotefile[$i] already exists");  
             db::change_status($dbids[$i], 1);  
         }  
         else  
         {  
             if( -e $localpaths[$i] )  
             {  
                 fileops::checkdir($remotepaths[$i]);  
                 # set $size_orig  
                 $size_orig = -s "$localpaths[$i]";  
   
                 log::jpegs("transferring $localpaths[$i] -> $remotepaths[$i]");  
                 if( system("cp '$localpaths[$i]' '$remotepaths[$i]'") == 0 )  
                 {  
                         log::jpegs("saved $localpaths[$i] -> $remotepaths[$i] [size_orig=$size_orig]");  
                         # update database  
                         db::change_status($dbids[$i], 1);  
                         db::write_size_orig($dbids[$i], $size_orig);  
   
                 #  
                 #       WE SHOULD NOT FILL ux_rpath FIELD FOR jpeg-types  
                 #  
                 #       db::write_ux_rpath($dbids[$i], "$remotepaths[$i]");  
   
                         $okay++;  
   
                 }  
                 else  
                 {  
                     # error in the copy process  
                     log::jpegs("error in copy process (see error log)");  
                     log::error("error in copy process: $?");  
                 }  
             }  
             else  
             {  
                 # error, local file doesn't exists  
                 log::error("Can not open local file $localpaths[$i]");  
                 log::jpegs("Can not open local file $localpaths[$i]");  
             }  
         }  
   
         # next iteration of 'while' and increment of $i  
         $i++;  
     }  
   
     log::main("Saved $okay jpegs on remote host");  
     log::jpegs("<<  End transfer process  >>");  
 }  
   
   
   
 sub probas()  sub probas()
 {  {
     my @dbids;      my @dbids;
Line 385 
Line 287 
         }          }
         else          else
         {          {
             # /V5/probas/* goes on /zV7/probas/              # /mnt/maket/proba/* goes on /mnt/rmt_maket/proba/
             substr($remotepaths[$i], 1, 2, 'zV7');  #           substr($remotepaths[$i], 1, 2, 'mnt/rmt_maket');
           $remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/;
         }          }
   
         if(-e $remotepaths[$i] || -e $remotepaths[$i] . '.rar')          if(-e $remotepaths[$i] || -e $remotepaths[$i] . '.rar')
Line 411 
Line 314 
   
                  log::probas("compressing '$localpaths[$i]' -> '$spool/$curfile'");                   log::probas("compressing '$localpaths[$i]' -> '$spool/$curfile'");
   
                 `/usr/local/bin/rar a -rr10% -ep '$spool/$curfile' '$localpaths[$i]'`;                  `/usr/bin/rar a -rr10% -ep '$spool/$curfile' '$localpaths[$i]'`;
                  if( ($? >> 8) == 0)                   if( ($? >> 8) == 0)
                  {                   {
                     # rar exited successfully                      # rar exited successfully
Line 501 
Line 404 
     log::probas("<<  End transfer process  >>");      log::probas("<<  End transfer process  >>");
 }  }
   
 sub tpps()  sub tt()
 {   {
     my @dbids;       my @dbids;
     my @localpaths;       my @localpaths;
     my @remotepaths;       my @remotepaths;
     my $dbids_ref;       my $dbids_ref;
     my $localpaths_ref;       my $localpaths_ref;
     my $i = 0;       my $i = 0;
     my $okay = 0;       my $okay = 0;
   
     my $size_orig;       my $size_orig;
   
     ($dbids_ref, $localpaths_ref) = fetch::tpps_list();       ($dbids_ref, $localpaths_ref) = fetch::tt_list();
   
     @dbids = @$dbids_ref;  
     @localpaths = @$localpaths_ref;  
     log::main("Fetched " . scalar(@localpaths) . " tpps from database");  
     log::tpps("<<  Starting transfer process  >>");  
   
     @remotepaths = @localpaths;  # clone       @dbids = @$dbids_ref;
        @localpaths = @$localpaths_ref;
     while($localpaths[$i])       log::main("Fetched " . scalar(@localpaths) . " tt from database");
     {       log::tt("<<  Starting transfer process  >>");
         # lookup in table first  
         chomp( $tmpf = `basename $remotepaths[$i]` );  
         chomp( $_ = `dirname $remotepaths[$i]` );  
         $tmpd = hash::lookup($_);  
         if ( $tmpd ne '' )  
         {  
             $remotepaths[$i] =  $tmpd. "/". $tmpf;  
         }  
         else  
         {  
             # hardcoded  
             $remotepaths[$i] =~ s/V(1)/zV7/;  
             $remotepaths[$i] =~ s/V(2)/zV8/;  
             $remotepaths[$i] =~ s/V(3)/zV6/;  
             $remotepaths[$i] =~ s/V(4)/zV7/;  
             $remotepaths[$i] =~ s/V(5)/zV7/;  
         }  
   
         if(-e $remotepaths[$i])  
         {  
             log::error("Remote file $remotefile[$i] already exists");  
             db::change_status($dbids[$i], 1);  
         }  
         else  
         {  
             if( -e $localpaths[$i] )  
             {  
                 fileops::checkdir($remotepaths[$i]);  
                 # set $size_orig  
                 $size_orig = -s "$localpaths[$i]";  
   
                 log::tpps("transferring $localpaths[$i] -> $remotepaths[$i]");  
                 if( system("cp '$localpaths[$i]' '$remotepaths[$i]'") == 0 )  
                 {  
                         log::tpps("saved $localpaths[$i] -> $remotepaths[$i] [size_orig=$size_orig]");  
                         # update database  
                         db::change_status($dbids[$i], 1);  
                         db::write_size_orig($dbids[$i], $size_orig);  
   
                 #  
                 #       WE SHOULD NOT FILL ux_rpath FIELD FOR tpp-types  
                 #  
                 #       XXX Please explain me why?  
                 #  
                 #       db::write_ux_rpath($dbids[$i], "$remotepaths[$i]");  
   
                         $okay++;  
   
                 }  
                 else  
                 {  
                     # error in the copy process  
                     log::tpps("error in copy process (see error log)");  
                     log::error("error in copy process: $?");  
                 }  
             }  
             else  
             {  
                 # error, local file doesn't exists  
                 log::error("Can not open local file $localpaths[$i]");  
                 log::tpps("Can not open local file $localpaths[$i]");  
             }  
         }  
   
         # next iteration of 'while' and increment of $i  
         $i++;  
     }  
   
     log::main("Saved $okay tpps on remote host");       @remotepaths = @localpaths;  # clone
     log::tpps("<<  End transfer process  >>");  
 }       while($localpaths[$i])
        {
            # lookup in table first
            chomp( $tmpf = `basename $remotepaths[$i]` );
            chomp( $_ = `dirname $remotepaths[$i]` );
            $tmpd = hash::lookup($_);
            if ( $tmpd ne '' )
            {
                $remotepaths[$i] =  $tmpd. "/". $tmpf;
            }
            else
            {
                # hardcoded
                $remotepaths[$i] =~ s/\/mnt\/maket/\/mnt\/rmt_maket/;
            }
   
            if(-e $remotepaths[$i])
            {
                log::error("Remote file $remotefile[$i] already exists");
                db::change_status($dbids[$i], 1);
            }
            else
            {
                if( -e $localpaths[$i] )
                {
                    fileops::checkdir($remotepaths[$i]);
                    # set $size_orig
                    $size_orig = -s "$localpaths[$i]";
   
                    log::tt("transferring $localpaths[$i] -> $remotepaths[$i]");
                    if( system("cp '$localpaths[$i]' '$remotepaths[$i]'") == 0 )
                    {
                            log::tt("saved $localpaths[$i] -> $remotepaths[$i] [size_orig=$size_orig]");
                            # update database
                            db::change_status($dbids[$i], 1);
                            db::write_size_orig($dbids[$i], $size_orig);
   
                    #
                    #       WE SHOULD NOT FILL ux_rpath FIELD FOR tpp-types
                    #
                    #       XXX Please explain me why?
                    #
                    #       db::write_ux_rpath($dbids[$i], "$remotepaths[$i]");
   
                            $okay++;
   
                    }
                    else
                    {
                        # error in the copy process
                        log::tt("error in copy process (see error log)");
                        log::error("error in copy process: $?");
                    }
                }
                else
                {
                    # error, local file doesn't exists
                    log::error("Can not open local file $localpaths[$i]");
                    log::tt("Can not open local file $localpaths[$i]");
                }
            }
   
            # next iteration of 'while' and increment of $i
            $i++;
        }
   
        log::main("Saved $okay tt on remote host");
        log::tt("<<  End transfer process  >>");
    }
   
 return(1);  return(1);
Legend:
Removed from v.1.1  
changed lines
  Added in v.1.5
CVSweb