$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;
}