diff --git a/modules/dcache-dcap/src/main/java/org/dcache/pool/movers/DCapProtocol_3_nio.java b/modules/dcache-dcap/src/main/java/org/dcache/pool/movers/DCapProtocol_3_nio.java index aa93f307ed2..b3503b5086d 100644 --- a/modules/dcache-dcap/src/main/java/org/dcache/pool/movers/DCapProtocol_3_nio.java +++ b/modules/dcache-dcap/src/main/java/org/dcache/pool/movers/DCapProtocol_3_nio.java @@ -17,6 +17,7 @@ import dmg.cells.nucleus.CellPath; import java.io.EOFException; import java.io.IOException; +import java.io.InterruptedIOException; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Socket; @@ -730,7 +731,7 @@ private void doTheReadv(RepositoryChannel fileChannel, DCapOutputByteBuffer cntO if (rc <= 0) { break; } - } catch (ClosedByInterruptException ee) { + } catch (ClosedByInterruptException | InterruptedIOException ee) { // clear interrupted state Thread.interrupted(); throw new InterruptedException(ee.getMessage()); @@ -924,7 +925,7 @@ private void doTheWrite(RepositoryChannel fileChannel, _bigBuffer.flip(); bytesAdded += fileChannel.write(_bigBuffer); - } catch (ClosedByInterruptException ee) { + } catch (ClosedByInterruptException | InterruptedIOException ee) { // clear interrupted state Thread.interrupted(); throw new InterruptedException(ee.getMessage());