$CLEAROPTS{CLEAREXEC_MULTITHREADED} = $ENV{CLEAREXEC_MULTITHREADED}
if $ENV{CLEAREXEC_MULTITHREADED};
-sub new () {
+sub new() {
my ($class) = @_;
my $clearadm = bless {}, $class;
return $clearadm;
} # new
-sub _tag ($) {
+sub _tag($) {
my ($self, $msg) = @_;
my $tag = YMDHMS;
return "$tag$msg";
} # _tag
-sub _verbose ($) {
+sub _verbose($) {
my ($self, $msg) = @_;
verbose $self->_tag ($msg);
return;
} # _verbose
-sub _debug ($) {
+sub _debug($) {
my ($self, $msg) = @_;
debug $self->_tag ($msg);
return;
} # _debug
-sub _log ($) {
+sub _log($) {
my ($self, $msg) = @_;
display $self->_tag ($msg);
return;
} # log
-sub _endServer () {
+sub _endServer() {
display "Clearexec V$VERSION shutdown at " . localtime;
# Kill process group
# Wait for all children to die
while (wait != -1) {
-
# do nothing
} # while
exit;
} # _endServer
-sub _restartServer () {
+sub _restartServer() {
# Not sure what to do on a restart server
display 'Entered _restartServer';
return;
} # _restartServer
-sub setMultithreaded ($) {
+sub setMultithreaded($) {
my ($self, $value) = @_;
my $oldValue = $self->{multithreaded};
return $oldValue;
} # setMultithreaded
-sub getMultithreaded () {
+sub getMultithreaded() {
my ($self) = @_;
return $self->{multithreaded};
} # getMultithreaded
-sub connectToServer (;$$) {
+sub connectToServer(;$$) {
my ($self, $host, $port) = @_;
$host ||= $CLEAROPTS{CLEAREXEC_HOST};
return unless $self->{socket};
- $self->{socket}->autoflush
- if $self->{socket};
+ $self->{socket}->autoflush if $self->{socket};
$self->{host} = $host;
$self->{port} = $port;
return;
} # connectToServer
-sub disconnectFromServer () {
+sub disconnectFromServer() {
my ($self) = @_;
undef $self->{socket};
return;
} # disconnectFromServer
-sub execute ($) {
+sub execute($) {
my ($self, $cmd) = @_;
- return (-1, 'Unable to talk to server')
- unless $self->{socket};
+ return (-1, 'Unable to talk to server') unless $self->{socket};
my ($status, $statusLine, @output) = (-1, '', ());
return ($status, @output);
} # execute
-sub _serviceClient ($$) {
+sub _serviceClient($$) {
my ($self, $host, $client) = @_;
$self->_verbose ("Serving requests from $host");
# Set autoflush for client
- $client->autoflush
- if $client;
+ $client->autoflush if $client;
while () {
# Read command from client
$self->_debug ("Returning 0, undef");
} else {
# Combines STDERR -> STDOUT if not already specified
- $cmd .= ' 2>&1'
- unless $cmd =~ /2>&1/;
+ $cmd .= ' 2>&1' unless $cmd =~ /2>&1/;
$self->_debug ("Executing $cmd");
($status, @output) = Execute $cmd;
return;
} # _serviceClient
-sub startServer (;$) {
+sub startServer(;$) {
my ($self, $port) = @_;
$port ||= $CLEAROPTS{CLEAREXEC_PORT};
Reuse => 1
);
- error "Could not create socket - $!", 1
- unless $self->{socket};
+ error "Could not create socket - $!", 1 unless $self->{socket};
# Announce ourselves
$self->_log ("Clearexec V$VERSION accepting clients at " . localtime);