Thanks for the quick reply! Oh man that is an excellent idea. I wasn't aware that accept() worked like that, will try it and update with results.
Will also definitely take a look at that module, Net::Server. We are hesitant to move to completely different way of handling everything as we've invested a lot of time on our current implementation, but if we cant work out this issue may have to...REALLY regretting not having found that module when we first started, at first glance it looks pretty nice.
| [reply] |
sub process_request {
my $self = shift;
my $fh = $self->{server}->{client};
my $select = IO::Select->new();
$select->add($fh);
my $last = 1;
while ($last) {
my $subroutineCall;
my $command;
my $completeLine = "";
# check if anything is ready to be received from client
my @ready = $select->can_read(.1);
next unless (@ready);
# loop while receiving from the client untill a full msg has b
+een received as identified by our flags
while ( defined( my $line = <$fh> ) ) {
if ( $line =~ /\*\*\* CLOSE_CONNECTION_CLIENT \*\*\*\n$/ )
+ {
$logger->info("Client closed connection to the server"
+);
$last = 0;
$selSock->remove($fh);
shutdown( $fh, 2 );
close $fh;
last;
}
$completeLine .= $line;
if ( $completeLine
=~ /(.+) \*\*\* COMMAND_INPUT \*\*\* (.+) \*\*\* COMMA
+ND_INPUT_END \*\*\*\n$/is
)
{
$subroutineCall = $1;
$command = $2;
$logger->info( "Processing message \"" . $command . "\
+"" );
last;
}
}
if ($last) {
#checking if the subroutine call is defined, if not, it kills that cli
+ent connection (for cases of closing out of a client window and it se
+nding the empty string )
if ( defined($subroutineCall) )
{
$logger->debug("Calling subroutine '${subroutineCa
+ll}'");
my ($string) = executeCommand(
subCall => $subroutineCall,
command => $command
);
send( $fh, "$string\n*** ZERO_BYTES_LEFT ***", 0 )
+;
}
else {
$logger->info(
"Undefined subroutine passed, closing client c
+onnection."
);
$last = 0;
$selSock->remove($fh);
shutdown( $fh, 2 );
close $fh;
last;
}
}
}
}
- Ant
- Some of my
best work - (1 2 3)
| [reply] [d/l] |