|
@@ -969,6 +969,7 @@ implements ByteBufferReadable, CanSetDropBehind, CanSetReadahead,
|
|
// The encryption key used is invalid.
|
|
// The encryption key used is invalid.
|
|
refetchEncryptionKey--;
|
|
refetchEncryptionKey--;
|
|
dfsClient.clearDataEncryptionKey();
|
|
dfsClient.clearDataEncryptionKey();
|
|
|
|
+ continue;
|
|
} else if (refetchToken > 0 && tokenRefetchNeeded(e, targetAddr)) {
|
|
} else if (refetchToken > 0 && tokenRefetchNeeded(e, targetAddr)) {
|
|
refetchToken--;
|
|
refetchToken--;
|
|
fetchBlockAt(block.getStartOffset());
|
|
fetchBlockAt(block.getStartOffset());
|