You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crail.apache.org by pe...@apache.org on 2018/05/07 10:59:00 UTC
[2/3] incubator-crail git commit: NVMf: staging buffer cache clear
buffer
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 <pe...@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 <pe...@apache.org>
Authored: Thu May 3 13:38:00 2018 +0200
Committer: Jonas Pfefferle <pe...@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);