diff --git a/modules/dcache/src/main/java/org/dcache/pool/classic/PoolV4.java b/modules/dcache/src/main/java/org/dcache/pool/classic/PoolV4.java index ef6f2cde897..367afe10585 100644 --- a/modules/dcache/src/main/java/org/dcache/pool/classic/PoolV4.java +++ b/modules/dcache/src/main/java/org/dcache/pool/classic/PoolV4.java @@ -752,8 +752,9 @@ private int queueIoRequest(CellMessage envelope, PoolIoFileMessage message) private void ioFile(CellMessage envelope, PoolIoFileMessage message) { try { message.setMoverId(queueIoRequest(envelope, message)); - LOGGER.debug("moverId {} received request for pnfsId {}", message.getMoverId(), - message.getPnfsId()); + LOGGER.debug("moverId {} received request for pnfsId {}, hotfile replication is {}", + message.getMoverId(), message.getPnfsId(), _hotFileReplicationEnabled + ? "enabled" : "disabled"); if (_hotFileReplicationEnabled) { _fileRequestMonitor.reportFileRequest(message.getPnfsId(), _ioQueue.numberOfRequestsFor(message.getPnfsId()), diff --git a/modules/dcache/src/main/java/org/dcache/pool/migration/MigrationModule.java b/modules/dcache/src/main/java/org/dcache/pool/migration/MigrationModule.java index d0b2d1c66a9..87fd4ba8f8e 100644 --- a/modules/dcache/src/main/java/org/dcache/pool/migration/MigrationModule.java +++ b/modules/dcache/src/main/java/org/dcache/pool/migration/MigrationModule.java @@ -1252,12 +1252,15 @@ public Object messageArrived(CellMessage envelope, PoolMigrationJobCancelMessage public synchronized void reportFileRequest(PnfsId pnfsId, long numberOfRequests, ProtocolInfo protocolInfo) { if (numberOfRequests < hotFileThreshold) { + LOGGER.debug("hotfile replication : conditions not satisfied numberOfRequests {} < hotFileThreshold {}", + numberOfRequests, hotFileThreshold); return; } String jobId = "hotfile-" + pnfsId; try { Job job = _jobs.get(jobId); if (job != null) { + LOGGER.debug("hotfile replication : found job with jobid {} in state {}", jobId, job.getState()); switch (job.getState()) { case FINISHED: case CANCELLED: