NVMf: staging buffer cache clear buffer Clear buffer position and limit when getting the buffer of the free queue since position and limit might have been modified before.
https://issues.apache.org/jira/browse/CRAIL-31 Signed-off-by: Jonas Pfefferle <peppe...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/incubator-crail/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-crail/commit/524ead0f Tree: http://git-wip-us.apache.org/repos/asf/incubator-crail/tree/524ead0f Diff: http://git-wip-us.apache.org/repos/asf/incubator-crail/diff/524ead0f Branch: refs/heads/master Commit: 524ead0f74514e0496c6ecf06a24d88ab334d6e4 Parents: 671b635 Author: Jonas Pfefferle <peppe...@apache.org> Authored: Thu May 3 13:38:00 2018 +0200 Committer: Jonas Pfefferle <peppe...@apache.org> Committed: Thu May 3 13:50:31 2018 +0200 ---------------------------------------------------------------------- .../apache/crail/storage/nvmf/client/NvmfStagingBufferCache.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-crail/blob/524ead0f/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStagingBufferCache.java ---------------------------------------------------------------------- diff --git a/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStagingBufferCache.java b/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStagingBufferCache.java index 64a8857..09d6315 100644 --- a/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStagingBufferCache.java +++ b/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStagingBufferCache.java @@ -141,6 +141,7 @@ public class NvmfStagingBufferCache { allocateFreeBuffers(); } } while (buffer == null); + buffer.clear(); BufferCacheEntry entry = new BufferCacheEntry(buffer); BufferCacheEntry prevEntry = remoteAddressMap.putIfAbsent(alignedRemoteAddress, entry);
