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

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 Affects Versions: 9.4.15.Final 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