You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Vladimir Steshin (Jira)" <ji...@apache.org> on 2024/02/26 17:14:00 UTC
[jira] [Updated] (IGNITE-21603) Incorrect backward connection check with loopback address.
[ https://issues.apache.org/jira/browse/IGNITE-21603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Vladimir Steshin updated IGNITE-21603:
--------------------------------------
Summary: Incorrect backward connection check with loopback address. (was: Incorrect backward connection chech with loopback address.)
> Incorrect backward connection check with loopback address.
> ----------------------------------------------------------
>
> Key: IGNITE-21603
> URL: https://issues.apache.org/jira/browse/IGNITE-21603
> Project: Ignite
> Issue Type: Bug
> Reporter: Vladimir Steshin
> Assignee: Vladimir Steshin
> Priority: Minor
> Labels: ise
> Time Spent: 10m
> Remaining Estimate: 0h
>
> We may skip backward connection check to a previous node if it has the same loopback address as the current node.
> Consider:
> # Neither _IgniteConfiguration#setLocalHost()_ or _TcpDiscoverySpi#setLocalAddress()_ is set. Or the localhost parameter is set to "_0.0.0.0_".
> # Nodes start on different hosts. All the available host addresses are resolved and
> # Among the other addresses, all nodes get the loopback address "127.0.0.1:47500" (47500 is the default tcp discovery port).
> # Cluster starts and works. But
> # Some node N (A) decides the connection to node N+1 (B) is lost and tries to connect to node N+2 (C) and sends _TcpDiscoveryHandshakeRequest_.
> # Before C accepts incoming A's connection, it decides to check B and pings it with _ServerImpl#checkConnection(List<InetSocketAddress> addrs, int timeout)_
> # Around here, the network is restored, and A can now connect to B anew.
> # "_127.0.0.1:47500_" is last in _List<InetSocketAddress>_ addrs by _IgniteUtils#inetAddressesComparator(boolean sameHost)_. But the connect attempts in _checkConnection(...)_ are parallel. "_127.0.0.1:47500_" answers first.
> # C sees it can connect to "_127.0.0.1:47500_" and chooses it as the alive address of B. Other pings to rest of B's addresses are ignored.
> # But "_127.0.0.1:47500_" is one of C's addresses. C realizes it pinged itself and decides that B is not reachable:
> {code:java}
> // If local node was able to connect to previous, confirm that it's alive.
> ok = liveAddr != null && (!liveAddr.getAddress().isLoopbackAddress() || !locNode.socketAddresses().contains(liveAddr));
> {code}
> # C accepts connection from A and answers with _TcpDiscoveryHandshakeResponse#previousNodeAlive() == false_
> # But B is ok now. But A connects to C and B is kicked from the ring.
> The problem is that C ping itself by B's address "_127.0.0.1:47500_"
--
This message was sent by Atlassian Jira
(v8.20.10#820010)