[infinispan-issues] [JBoss JIRA] (ISPN-10345) PutAll to register proto files hangs

[Gustavo Fernandes (Jira)]

     [ https://issues.jboss.org/browse/ISPN-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Gustavo Fernandes deleted ISPN-10345:
-------------------------------------


> PutAll to register proto files hangs
> ------------------------------------
>
>                 Key: ISPN-10345
>                 URL: https://issues.jboss.org/browse/ISPN-10345
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Core, Remote Querying
>            Reporter: Gustavo Fernandes
>            Priority: Major
>
> PutAll to register protofiles causes the operation to fail with timeout. Simple reproducer:
> {code:java}
> package org.infinispan.client.hotrod;
> import static org.infinispan.query.remote.client.ProtobufMetadataManagerConstants.PROTOBUF_METADATA_CACHE_NAME;
> import static org.infinispan.server.hotrod.test.HotRodTestingUtil.hotRodCacheConfiguration;
> import static org.testng.AssertJUnit.assertEquals;
> import java.util.HashMap;
> import java.util.Map;
> import org.infinispan.client.hotrod.test.MultiHotRodServersTest;
> import org.infinispan.configuration.cache.CacheMode;
> import org.infinispan.configuration.cache.ConfigurationBuilder;
> import org.testng.annotations.Test;
> @Test(groups = "functional", testName = "client.hotrod.PutAllProtoRegistration")
> public class PutAllProtoRegistration extends MultiHotRodServersTest {
>    private static final int CLUSTER_SIZE = 2;
>    @Override
>    protected void createCacheManagers() throws Throwable {
>       ConfigurationBuilder cfgBuilder = hotRodCacheConfiguration(getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, false));
>       createHotRodServers(CLUSTER_SIZE, cfgBuilder);
>       waitForClusterToForm();
>    }
>    @Test
>    public void testBatchProtoRegistration() {
>       String protoName = "test.proto";
>       String protoValue = "message Test {}";
>       Map<String, String> value = new HashMap<>();
>       value.put(protoName, protoValue);
>       RemoteCache<String, String> metadataCache = client(0).getCache(PROTOBUF_METADATA_CACHE_NAME);
>       metadataCache.putAll(value);
>       assertEquals(metadataCache.get(protoName), protoValue);
>    }
> }
> {code}
> The test passes with CLUSTER_SIZE = 1



--
This message was sent by Atlassian Jira
(v7.12.1#712002)