}
$self->disconnect;
- $logger->transport( "AppSession killing self: " . $self->session_id(), DEBUG );
+ $logger->transport(sub{return "AppSession killing self: " . $self->session_id() }, DEBUG );
delete $_CACHE{$self->session_id};
delete($$self{$_}) for (keys %$self);
}
push @doc, $msg;
- $logger->debug( "AppSession sending ".$msg->type." to ".$self->remote_id.
- " with threadTrace [".$msg->threadTrace."]");
+ $logger->debug(sub{return "AppSession sending ".$msg->type." to ".$self->remote_id.
+ " with threadTrace [".$msg->threadTrace."]" });
}
}
}
- #$logger->debug( ref($self). " recv_queue before wait: " . $self->_print_queue(), INTERNAL );
+ #$logger->debug(sub{return ref($self). " recv_queue before wait: " . $self->_print_queue() }, INTERNAL );
if( exists( $args{timeout} ) ) {
$args{timeout} = int($args{timeout});
last if (scalar(@list) >= $args{count});
}
- $logger->debug( "Number of matched responses: " . @list, DEBUG );
+ $logger->debug(sub{return "Number of matched responses: " . @list }, DEBUG );
$self->queue_wait(0); # check for statuses
return $list[0] if (!wantarray);
sub flush_resend {
my $self = shift;
- $logger->debug( "Resending..." . @_RESEND_QUEUE, INTERNAL );
+ $logger->debug(sub{return "Resending..." . @_RESEND_QUEUE }, INTERNAL );
while ( my $req = shift @OpenSRF::AppSession::_RESEND_QUEUE ) {
$req->resend unless $req->complete;
}
sub resend {
my $self = shift;
return unless ($self and $self->session and !$self->complete);
- OpenSRF::Utils::Logger->debug( "I'm resending the request for threadTrace ". $self->threadTrace, DEBUG);
+ OpenSRF::Utils::Logger->debug(sub{return "I'm resending the request for threadTrace ". $self->threadTrace }, DEBUG);
return $self->session->send('REQUEST', $self->payload, $self->threadTrace );
}
$appreq->max_bundle_count( $coderef->max_bundle_count );
$appreq->max_chunk_size( $coderef->max_chunk_size );
- $log->debug( "in_request = $in_request : [" . $appreq->threadTrace."]", INTERNAL );
+ $log->debug(sub{return "in_request = $in_request : [" . $appreq->threadTrace."]" }, INTERNAL );
if( $in_request ) {
- $log->debug( "Pushing onto pending requests: " . $appreq->threadTrace, DEBUG );
+ $log->debug(sub{return "Pushing onto pending requests: " . $appreq->threadTrace }, DEBUG );
push @pending_requests, [ $appreq, \@args, $coderef ];
return 1;
}
$in_request--;
- $log->debug( "Pending Requests: " . scalar(@pending_requests), INTERNAL );
+ $log->debug(sub{return "Pending Requests: " . scalar(@pending_requests) }, INTERNAL );
# cycle through queued requests
while( my $aref = shift @pending_requests ) {
my $start = time;
my $response = $aref->[2]->run( $aref->[0], @{$aref->[1]} );
my $time = sprintf '%.3f', time - $start;
- $log->debug( "Method duration for [".$aref->[2]->api_name." -> ".join(', ',@{$aref->[1]}).']: '.$time, DEBUG );
+ $log->debug(sub{return "Method duration for [".$aref->[2]->api_name." -> ".join(', ',@{$aref->[1]}).']: '.$time }, DEBUG );
$appreq = $aref->[0];
$appreq->respond_complete( $response );
- $log->debug( "Executed: " . $appreq->threadTrace, INTERNAL );
+ $log->debug(sub{return "Executed: " . $appreq->threadTrace }, INTERNAL );
} catch Error with {
my $e = shift;
my $class = ref($self) || $self;
$log->debug("Lookup of [$method] by [$class] in api_level [$proto]", DEBUG);
- $log->debug("Available methods\n\t".join("\n\t", keys %{ $_METHODS[$proto] }), INTERNAL);
+ $log->debug(sub{return "Available methods\n\t".join("\n\t", keys %{ $_METHODS[$proto] }) }, INTERNAL);
my $meth;
if (__PACKAGE__->thunk) {
}
- $log->debug("Coderef for [$$self{package}::$$self{method}] has been run", DEBUG);
+ $log->debug(sub{return "Coderef for [$$self{package}::$$self{method}] has been run" }, DEBUG);
if ( ref($req) and UNIVERSAL::isa($req, 'OpenSRF::AppSubrequest') and !$req->respond_directly ) {
$req->respond($resp) if (defined $resp);
- $log->debug("SubRequest object is responding with : " . join(" ",$req->responses), DEBUG);
+ $log->debug(sub{return "SubRequest object is responding with : " . join(" ",$req->responses) }, DEBUG);
return $req->responses;
} else {
$log->debug("A top level Request object is responding $resp", DEBUG) if (defined $resp);
$session->finish();
}
- $log->debug( "Remote Subrequest Responses " . join(" ", $req->responses), INTERNAL );
+ $log->debug(sub{return "Remote Subrequest Responses " . join(" ", $req->responses) }, INTERNAL );
return $req->responses;
}
$session->last_threadTrace($tT);
$session->session_locale($locale);
- $log->debug(" Received api_level => [$api_level], MType => [$mtype], ".
- "from [".$session->remote_id."], threadTrace[".$self->threadTrace."]");
+ $log->debug(sub{return " Received api_level => [$api_level], MType => [$mtype], ".
+ "from [".$session->remote_id."], threadTrace[".$self->threadTrace."]" });
my $val;
if ( $session->endpoint == $session->SERVER() ) {
if ($self->payload->statusCode == STATUS_OK) {
$session->state($session->CONNECTED);
- $log->debug("We connected successfully to ".$session->app);
+ $log->debug(sub{return "We connected successfully to ".$session->app });
return 0;
}
}
}
- $log->debug("oilsMessage passing to Application: " . $self->type." : ".$session->remote_id );
+ $log->debug(sub{return "oilsMessage passing to Application: " . $self->type." : ".$session->remote_id });
return 1;
$self->class->isa( "OpenSRF::EX::NOTICE" ) ||
$self->class->isa( "OpenSRF::EX::WARN" ) ) {
- $log->debug( $self->stringify(), $log->DEBUG );
+ $log->debug(sub{return $self->stringify() }, $log->DEBUG );
}
- else{ $log->debug( $self->stringify(), $log->ERROR ); }
+ else{ $log->debug(sub{return $self->stringify() }, $log->ERROR ); }
$self->SUPER::throw;
}
1
);
#print "Creating connection ".$self->{sessions}->[-1]->session_id." ...\n";
- $log->debug("Creating connection ".$self->{sessions}->[-1]->session_id." ...");
+ $log->debug(sub{return "Creating connection ".$self->{sessions}->[-1]->session_id." ..." });
}
return $self;
params => [@params]
};
- $log->debug("Making request [$method] ".$self->running."...");
+ $log->debug(sub{return "Making request [$method] ".$self->running."..." });
return $req;
} elsif (!$self->adaptive) {
push @done, $req;
} else {
- #$log->debug("Still running ".$req->{meth}." in session ".$req->{req}->session->session_id);
+ #$log->debug(sub{return "Still running ".$req->{meth}." in session ".$req->{req}->session->session_id });
push @running, $req;
}
}
sub perform_idle_maintenance {
my $self = shift;
- $chatty and $logger->internal(
+ $chatty and $logger->internal(sub{return
sprintf(
"server: %d idle, %d active, %d min_spare, %d max_spare in idle maintenance",
scalar(@{$self->{idle_list}}),
$self->{min_spare_children},
$self->{max_spare_children}
)
- );
+ });
# spawn 1 spare child per maintenance loop if necessary
if( $self->{min_spare_children} and
return unless @pids;
- $chatty and $logger->internal("server: ".scalar(@pids)." children reporting for duty: (@pids)");
+ $chatty and $logger->internal(sub{return "server: ".scalar(@pids)." children reporting for duty: (@pids)" });
my $child;
my @new_actives;
$self->{active_list} = [@new_actives];
- $chatty and $logger->internal(sprintf(
+ $chatty and $logger->internal(sub{return sprintf(
"server: %d idle and %d active children after status update",
- scalar(@{$self->{idle_list}}), scalar(@{$self->{active_list}})));
+ scalar(@{$self->{idle_list}}), scalar(@{$self->{active_list}})) });
# some children just went from active to idle. let's see
# if any of them need to be killed from a previous sighup.
$self->spawn_children unless $shutdown;
- $chatty and $logger->internal(sprintf(
+ $chatty and $logger->internal(sub{return sprintf(
"server: %d idle and %d active children after reap_children",
- scalar(@{$self->{idle_list}}), scalar(@{$self->{active_list}})));
+ scalar(@{$self->{idle_list}}), scalar(@{$self->{active_list}})) });
}
# ----------------------------------------------------------------
push(@{$self->{idle_list}}, $child);
}
- $chatty and $logger->internal("server: server spawned child $child with ".$self->{num_children}." total children");
+ $chatty and $logger->internal(sub{return "server: server spawned child $child with ".$self->{num_children}." total children" });
return $child;
if($self->{stderr_log}) {
- $chatty and $logger->internal("server: redirecting STDERR to " . $self->{stderr_log});
+ $chatty and $logger->internal(sub{return "server: redirecting STDERR to " . $self->{stderr_log} });
close STDERR;
unless( open(STDERR, '>>' . $self->{stderr_log}) ) {
} else {
if( ! $msg->handler( $app_session ) ) { return 0; }
- $logger->debug(sprintf("Response processing duration: %.3f", (time() - $start_time)));
+ $logger->debug(sub{return sprintf("Response processing duration: %.3f", (time() - $start_time)) });
}
}
unless ( $self->reader->connected );
$self->xmpp_id("$username\@$host/$resource");
- $logger->debug("Created XMPP connection " . $self->xmpp_id);
+ $logger->debug(sub{return "Created XMPP connection " . $self->xmpp_id });
return $self;
}