Changeset a04c3b855f4ac4809a3dce3bc57149866918f8b9 in xas


Ignore:
Timestamp:
11/24/14 09:14:56 (5 years ago)
Author:
Kevin L. Esteb <kevin@…>
Branches:
master
Children:
923373f451ff8825cb260356023de52919dadd40
Parents:
25ca773a7bed52abaa65a1759ae36c4673684f38
git-author:
Kevin L. Esteb <kevin@…> (11/24/14 09:14:56)
git-committer:
Kevin L. Esteb <kevin@…> (11/24/14 09:14:56)
Message:

Fixed some logic errors

Location:
trunk/lib/XAS/Lib
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/lib/XAS/Lib/App/Daemon.pm

    ra4057fa6cfc06414b67428e5d02487354c0ddfcf ra04c3b855f4ac4809a3dce3bc57149866918f8b9  
    115115    my $rc = $self->SUPER::run(); 
    116116 
    117     $self->pid->remove(); 
     117    $self->pid->remove() if ($self->env->pidfile->exists); 
    118118 
    119119    return $rc; 
  • trunk/lib/XAS/Lib/Net/Server.pm

    rc5596c0d76dbacce5903e2d68a28b383557884c6 ra04c3b855f4ac4809a3dce3bc57149866918f8b9  
    319319    $self->log->debug("$alias: _client_output()"); 
    320320 
    321     if (defined($wheel)) { 
    322  
    323         # emulate IO::Socket connected() method. this method 
    324         # calls getpeername(). getpeername() returns undef when 
    325         # the network stack can't validate the socket.  
    326  
    327         if (getpeername($self->{clients}->{$wheel}->{socket})) { 
    328  
    329             push(@buffer, $data); 
    330             $self->{clients}->{$wheel}->{client}->put(@buffer); 
     321    try { 
     322 
     323        if (defined($wheel)) { 
     324 
     325            # emulate IO::Socket connected() method. this method 
     326            # calls getpeername(). getpeername() returns undef when 
     327            # the network stack can't validate the socket.  
     328 
     329            if (getpeername($self->{clients}->{$wheel}->{socket})) { 
     330 
     331                push(@buffer, $data); 
     332                $self->{clients}->{$wheel}->{client}->put(@buffer); 
     333 
     334            } else { 
     335 
     336                $self->log->error_msg( 
     337                    'client_nosocket',  
     338                    $alias,  
     339                    $self->peerhist($wheel),  
     340                    $self->peerport($wheel) 
     341                ); 
     342                delete $self->{clients}->{$wheel}; 
     343 
     344            } 
    331345 
    332346        } else { 
    333347 
    334             $self->log->error_msg( 
    335                 'client_nosocket',  
    336                 $alias,  
    337                 $self->peerhist($wheel),  
    338                 $self->peerport($wheel) 
    339             ); 
    340             delete $self->{clients}->{$wheel}; 
     348            $self->log->error_msg('client_nowheel', $alias); 
    341349 
    342350        } 
    343351 
    344     } else { 
    345  
    346         $self->log->error_msg('client_nowheel', $alias); 
    347  
    348     } 
     352    } catch { 
     353 
     354        my $ex = $_; 
     355 
     356        $self->exception_handler($ex); 
     357 
     358        delete $self->{clients}->{$wheel}; 
     359 
     360    }; 
    349361 
    350362} 
  • trunk/lib/XAS/Lib/Services.pm

    r155a54291962610cdf37a0f2dcd11461c25cfd7a ra04c3b855f4ac4809a3dce3bc57149866918f8b9  
    116116    my $class = shift; 
    117117 
     118    $poe_kernel->run(); # this only initializes POE 
     119 
    118120    my $self = $class->SUPER::init(@_); 
    119121 
Note: See TracChangeset for help on using the changeset viewer.