Changeset cd267643a706fc823f4192cf5614208bf5bf33c2 in xas-spooler


Ignore:
Timestamp:
11/09/15 16:28:35 (4 years ago)
Author:
Kevin L. Esteb <kevin@…>
Branches:
master
Children:
d5863e7221a302322c8481e6cee3bb3575232bae
Parents:
1fe514e4f263a663bdf9d40db5bfb9e6c2534eaa
git-author:
Kevin L. Esteb <kevin@…> (11/09/15 16:28:35)
git-committer:
Kevin L. Esteb <kevin@…> (11/09/15 16:28:35)
Message:

Fixes for windows

Location:
trunk/lib/XAS
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/lib/XAS/Apps/Spooler/Process.pm

    r1fe514e4f263a663bdf9d40db5bfb9e6c2534eaa rcd267643a706fc823f4192cf5614208bf5bf33c2  
    2828 
    2929    my @sections = $self->cfg->Sections(); 
     30    my $connector = XAS::Spooler::Connector->new( 
     31        -alias           => 'connector', 
     32        -host            => $self->host, 
     33        -port            => $self->port, 
     34        -tcp_keepalive   => 1, 
     35        -retry_reconnect => 1, 
     36        -hostname        => $self->env->host, 
     37    ); 
     38 
     39    $self->service->register('connector'); 
    3040 
    3141    foreach my $section (@sections) { 
     
    5767    $self->setup(); 
    5868 
    59     my $connector = XAS::Spooler::Connector->new( 
    60         -alias           => 'connector', 
    61         -host            => $self->host, 
    62         -port            => $self->port, 
    63         -tcp_keepalive   => 1, 
    64         -retry_reconnect => 1, 
    65         -hostname        => $self->env->host, 
    66     ); 
    67  
    6869    $self->log->info_msg('startup'); 
    6970 
    70     $self->service->register('connector'); 
    7171    $self->service->run(); 
    7272 
  • trunk/lib/XAS/Spooler/Connector.pm

    r1fe514e4f263a663bdf9d40db5bfb9e6c2534eaa rcd267643a706fc823f4192cf5614208bf5bf33c2  
    11package XAS::Spooler::Connector; 
    22 
    3 our $VERSION = '0.01'; 
     3our $VERSION = '0.02'; 
    44 
    55use POE; 
     
    3636    $self->log->debug("$alias: alias = $palias, file = $filename"); 
    3737 
    38     $poe_kernel->post($palias, 'unlink_file', File($filename)); 
     38    $poe_kernel->post($palias, 'unlink_file', $filename); 
    3939 
    4040} 
     
    8989            -destination => $queue,  
    9090            -message     => $packet,  
    91             -receipt     => sprintf("%s;%s", $palias, $file), 
     91            -receipt     => sprintf("%s;%s", $palias, $file->name), 
    9292            -persistent  => 'true' 
    9393        ); 
     
    104104        $self->log->debug("$alias: alias = $palias, file = $file"); 
    105105 
    106         $poe_kernel->post($palias, 'unlink_file', File($file)); 
     106        $poe_kernel->post($palias, 'unlink_file', $file); 
    107107 
    108108    }; 
  • trunk/lib/XAS/Spooler/Processor.pm

    r1fe514e4f263a663bdf9d40db5bfb9e6c2534eaa rcd267643a706fc823f4192cf5614208bf5bf33c2  
    11package XAS::Spooler::Processor; 
    22 
    3 our $VERSION = '0.01'; 
     3our $VERSION = '0.02'; 
    44 
    55use POE; 
     
    7373    try { 
    7474 
    75         if (my $file = $dh->read()) { 
    76  
    77             my $temp = File($self->spooldir->path, $file); 
    78  
    79             if ($temp->path =~ /$pattern/) { 
    80  
    81                 push(@{$self->{'files'}}, $temp); 
     75        unless ($self->paused) { 
     76 
     77            if (my $file = $dh->read()) { 
     78 
     79                my $temp = File($self->spooldir->path, $file); 
     80 
     81                if ($temp->path =~ /$pattern/) { 
     82 
     83                    push(@{$self->{'files'}}, $temp); 
     84 
     85                } 
     86 
     87                $poe_kernel->post($alias, 'scan_dir', $dh); 
     88 
     89            } else { 
     90 
     91                $poe_kernel->post($alias, 'scan_dir_stop', $dh); 
    8292 
    8393            } 
    84  
    85             $poe_kernel->post($alias, 'scan_dir', $dh); 
    8694 
    8795        } else { 
     
    135143    try { 
    136144 
    137         $self->log->info_msg('spooler_unlinking', $alias, $file); 
    138         $self->spooler->delete($file); 
     145        my $path = File($self->spooldir, $file); 
     146        $self->log->info_msg('spooler_unlinking', $alias, $path); 
     147        $self->spooler->delete($path); 
    139148         
    140149    } catch { 
     
    176185 
    177186                    $self->log->info_msg('spooler_found', $alias, $file->path); 
    178                     $poe_kernel->post($connector, 'send_packet', $alias, $type, $queue, $data, $file->path); 
     187                    $poe_kernel->post($connector, 'send_packet', $alias, $type, $queue, $data, $file); 
    179188 
    180189                } 
Note: See TracChangeset for help on using the changeset viewer.