[jira] [Updated] (IGNITE-15358) Client node can't reconnect to cluster with security enabled.

["Nikolay Izhikov (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/IGNITE-15358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Nikolay Izhikov updated IGNITE-15358:
-------------------------------------
    Priority: Blocker  (was: Major)

> Client node can't reconnect to cluster with security enabled.
> -------------------------------------------------------------
>
>                 Key: IGNITE-15358
>                 URL: https://issues.apache.org/jira/browse/IGNITE-15358
>             Project: Ignite
>          Issue Type: Bug
>            Reporter: Nikolay Izhikov
>            Priority: Blocker
>
> After IGNITE-15101 client node can't reconnect to the cluster because node id changed on the disconnect but security processor continues to use old node id.
> {code:java}
> public class ClientReconnectTest extends GridCommonAbstractTest {
>     /** {@inheritDoc} */
>     @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception {
>         return super.getConfiguration(igniteInstanceName).setPluginProviders(new TestReconnectSecurityPluginProvider() {
>             /** {@inheritDoc} */
>             @Override protected GridSecurityProcessor securityProcessor(GridKernalContext ctx) {
>                 return new TestReconnectProcessor(ctx) {
>                     @Override public SecurityContext securityContext(UUID subjId) {
>                         if (ctx.localNodeId().equals(subjId))
>                             return ctx.security().securityContext();
>                         throw new IgniteException(
>                             "Unexpected subjId[subjId=" + subjId + ",localNodeId=" + ctx.localNodeId() + ']'
>                         );
>                     }
>                     @Override public SecurityContext authenticateNode(ClusterNode node, SecurityCredentials cred) {
>                         return new TestSecurityContext(new TestSecuritySubject(node.id()));
>                     }
>                 };
>             }
>         });
>     }
>     /** {@inheritDoc} */
>     @Override protected void beforeTest() throws Exception {
>         super.beforeTest();
>         cleanPersistenceDir();
>     }
>     /** */
>     @Test
>     public void testClientNodeReconnected() throws Exception {
>         IgniteEx ignite = startGrids(2);
>         ignite.cluster().state(ClusterState.ACTIVE);
>         int clientIdx = 2;
>         IgniteEx ex = startClientGrid(clientIdx);
>         CountDownLatch latch = new CountDownLatch(1);
>         ex.events().localListen(evt -> {
>             latch.countDown();
>             return true;
>         }, EVT_CLIENT_NODE_RECONNECTED);
>         DiscoverySpi discoverySpi = ignite(0).configuration().getDiscoverySpi();
>         discoverySpi.failNode(nodeId(clientIdx), null);
>         assertTrue(latch.await(getTestTimeout(), TimeUnit.MILLISECONDS));
>     }
> }
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)