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/04/10 11:19:46 UTC
[07/16] incubator-crail git commit: NvmfStorageEndpoint: too many
outstanding requests
NvmfStorageEndpoint: too many outstanding requests
Fix bug were there could be too many outstanding requests posted
on the NVMf SQ.
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/50cf2683
Tree: http://git-wip-us.apache.org/repos/asf/incubator-crail/tree/50cf2683
Diff: http://git-wip-us.apache.org/repos/asf/incubator-crail/diff/50cf2683
Branch: refs/heads/master
Commit: 50cf26837db41534c39ea75bd7a361e22d7648b8
Parents: feb765c
Author: Jonas Pfefferle <pe...@apache.org>
Authored: Mon Apr 9 15:20:38 2018 +0200
Committer: Jonas Pfefferle <pe...@apache.org>
Committed: Tue Apr 10 13:19:02 2018 +0200
----------------------------------------------------------------------
.../org/apache/crail/storage/nvmf/client/NvmfStorageEndpoint.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-crail/blob/50cf2683/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStorageEndpoint.java
----------------------------------------------------------------------
diff --git a/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStorageEndpoint.java b/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStorageEndpoint.java
index c9b17de..8188d82 100644
--- a/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStorageEndpoint.java
+++ b/storage-nvmf/src/main/java/org/apache/crail/storage/nvmf/client/NvmfStorageEndpoint.java
@@ -144,7 +144,7 @@ public class NvmfStorageEndpoint implements StorageEndpoint {
private boolean tryGetOperation() {
int outstandingOperationsOld = outstandingOperations.get();
- if (outstandingOperationsOld != NvmfStorageConstants.QUEUE_SIZE) {
+ if (outstandingOperationsOld < NvmfStorageConstants.QUEUE_SIZE) {
return outstandingOperations.compareAndSet(outstandingOperationsOld, outstandingOperationsOld + 1);
}
return false;