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 <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/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 <peppe...@apache.org> Authored: Mon Apr 9 15:20:38 2018 +0200 Committer: Jonas Pfefferle <peppe...@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;
