Repository: asterixdb Updated Branches: refs/heads/master ad13fc646 -> a7094732b
[NO ISSUE][NET] Set Handle State on Connect Failure - user model changes: no - storage format changes: no - interface changes: no Details: - Update the handle state to CLOSED when the handle is closed after failure to connect attempt. Change-Id: I866ba42f5433e1d9d312b6c0ab19296cad4d20f3 Reviewed-on: https://asterix-gerrit.ics.uci.edu/2838 Sonar-Qube: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> Contrib: Jenkins <[email protected]> Integration-Tests: Jenkins <[email protected]> Reviewed-by: Dmitry Lychagin <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/a7094732 Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/a7094732 Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/a7094732 Branch: refs/heads/master Commit: a7094732bd76095ac39e826e2da61b3a4261e21b Parents: ad13fc6 Author: Murtadha Hubail <[email protected]> Authored: Thu Aug 2 14:28:02 2018 -0700 Committer: Murtadha Hubail <[email protected]> Committed: Thu Aug 2 17:09:01 2018 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/hyracks/ipc/impl/IPCConnectionManager.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a7094732/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/IPCConnectionManager.java ---------------------------------------------------------------------- diff --git a/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/IPCConnectionManager.java b/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/IPCConnectionManager.java index cde26d5..b191bd3 100644 --- a/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/IPCConnectionManager.java +++ b/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/impl/IPCConnectionManager.java @@ -286,6 +286,7 @@ public class IPCConnectionManager { } catch (IOException e) { LOGGER.error("Failed to accept channel ", e); close(channelKey, channel); + handle.setState(HandleState.CLOSED); } } workingPendingConnections.clear();
