Add trace logging before sending single shard requests
This commit is contained in:
parent
28970e7d54
commit
cf539a2158
|
@ -210,6 +210,14 @@ public abstract class TransportSingleShardAction<Request extends SingleShardRequ
|
||||||
onFailure(shardRouting, new NoShardAvailableActionException(shardRouting.shardId()));
|
onFailure(shardRouting, new NoShardAvailableActionException(shardRouting.shardId()));
|
||||||
} else {
|
} else {
|
||||||
internalRequest.request().internalShardId = shardRouting.shardId();
|
internalRequest.request().internalShardId = shardRouting.shardId();
|
||||||
|
if (logger.isTraceEnabled()) {
|
||||||
|
logger.trace(
|
||||||
|
"sending request [{}] to shard [{}] on node [{}]",
|
||||||
|
internalRequest.request(),
|
||||||
|
internalRequest.request().internalShardId,
|
||||||
|
node
|
||||||
|
);
|
||||||
|
}
|
||||||
transportService.sendRequest(node, transportShardAction, internalRequest.request(), new BaseTransportResponseHandler<Response>() {
|
transportService.sendRequest(node, transportShardAction, internalRequest.request(), new BaseTransportResponseHandler<Response>() {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue