You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/10/09 14:48:37 UTC
[42/50] [abbrv] ignite git commit: IGNITE-6574 Remove pending
requests in case STATUS_AUTH_FAILURE && credentials == null.
IGNITE-6574 Remove pending requests in case STATUS_AUTH_FAILURE && credentials == null.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/85261a34
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/85261a34
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/85261a34
Branch: refs/heads/ignite-6305
Commit: 85261a341936547693aaed2105dc504fda2a9bf7
Parents: 35589a7
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Sat Oct 7 01:10:08 2017 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Sat Oct 7 01:10:08 2017 +0700
----------------------------------------------------------------------
.../client/impl/connection/GridClientNioTcpConnection.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/85261a34/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientNioTcpConnection.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientNioTcpConnection.java b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientNioTcpConnection.java
index f72a009..3bedd5f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientNioTcpConnection.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientNioTcpConnection.java
@@ -575,6 +575,8 @@ public class GridClientNioTcpConnection extends GridClientConnection {
"(client has no credentials) [clientId=" + clientId +
", srvAddr=" + serverAddress() + ", errMsg=" + resp.errorMessage() +']'));
+ removePending(resp.requestId());
+
return;
}