[JBoss JIRA] (HRJS-78) Adding listener with unknown type succeeds
by Galder Zamarreño (Jira)
[ https://issues.jboss.org/browse/HRJS-78?page=com.atlassian.jira.plugin.sy... ]
Galder Zamarreño updated HRJS-78:
---------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> Adding listener with unknown type succeeds
> ------------------------------------------
>
> Key: HRJS-78
> URL: https://issues.jboss.org/browse/HRJS-78
> Project: Infinispan Javascript client
> Issue Type: Bug
> Reporter: Anna Manukyan
> Assignee: Anna Manukyan
> Priority: Major
> Fix For: 0.7.0
>
>
> When adding a new listener with unknown event type, nothing happens. From the logs I can see that the event was added successfully. See the logs below:
> {code}
> [2018-09-25T22:24:55.824] [DEBUG] client - Invoke addListener(msgId=460,event=barev,listenerId=listener_461,opts=undefined) remotely
> [2018-09-25T22:24:55.824] [TRACE] encoder - Encode operation with topology id 0
> [2018-09-25T22:24:55.825] [TRACE] listener - Create listener emitter for connection 127.0.0.1:11222@conn_15 and listener with listenerId=listener_461
> [2018-09-25T22:24:55.825] [TRACE] io_7 - Write buffer(msgId=460) to 127.0.0.1:11222@conn_15: A0CC031D2500000300010D00010D000C6C697374656E65725F343631000000000F
> [2018-09-25T22:24:55.827] [TRACE] decoder - Read header(msgId=460): opCode=38, status=0, hasNewTopology=0
> [2018-09-25T22:24:55.827] [TRACE] decoder - Call decode for request(msgId=460)
> [2018-09-25T22:24:55.827] [TRACE] io_7_conn_15 - Complete success for request(msgId=460) with true
> [2018-09-25T22:24:55.827] [TRACE] io_7_conn_15 - After decoding request(msgId=460), buffer size is 6, and offset 6
> {code}
> The code for this logs is given here:
> {code}
> ... code from spec...
> it('fails when wrong event name is passed', function(done) {
> client.then(t.on('barev', t.expectEvent('wrongNameCreate', done, true, 'value')))
> .then(t.assert(t.putIfAbsent('wrongNameCreate', 'value'), t.toBeTruthy))
> .catch(t.failed(done)).finally(done);
> });
> ...
> {code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 3 months
[JBoss JIRA] (ISPN-10089) Client Listeners should return the value on remove events
by Katia Aresti (Jira)
[ https://issues.jboss.org/browse/ISPN-10089?page=com.atlassian.jira.plugin... ]
Katia Aresti updated ISPN-10089:
--------------------------------
Sprint: DataGrid Sprint #29 (was: 2019 Week 29-31)
> Client Listeners should return the value on remove events
> ----------------------------------------------------------
>
> Key: ISPN-10089
> URL: https://issues.jboss.org/browse/ISPN-10089
> Project: Infinispan
> Issue Type: Feature Request
> Components: Listeners
> Reporter: Katia Aresti
> Assignee: Katia Aresti
> Priority: Major
>
> Client listeners return the key/value for added and updated values, but only return the key when we remove a value.
> Remove notifications should include the value. If we only want to know which are the keys or the values that have been added, updated or removed, this can be configured directly on the annotation.
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 3 months
[JBoss JIRA] (ISPN-10345) PutAll to register proto files hangs
by Gustavo Fernandes (Jira)
[ https://issues.jboss.org/browse/ISPN-10345?page=com.atlassian.jira.plugin... ]
Gustavo Fernandes updated ISPN-10345:
-------------------------------------
Status: Open (was: New)
> 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
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 3 months
[JBoss JIRA] (ISPN-10345) PutAll to register proto files hangs
by Gustavo Fernandes (Jira)
[ https://issues.jboss.org/browse/ISPN-10345?page=com.atlassian.jira.plugin... ]
Gustavo Fernandes updated ISPN-10345:
-------------------------------------
Status: Pull Request Sent (was: Open)
Git Pull Request: https://github.com/infinispan/infinispan/pull/7086
> 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
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 3 months
[JBoss JIRA] (ISPN-10345) PutAll to register proto files hangs
by Gustavo Fernandes (Jira)
[ https://issues.jboss.org/browse/ISPN-10345?page=com.atlassian.jira.plugin... ]
Gustavo Fernandes commented on ISPN-10345:
------------------------------------------
[~dan.berindei] This was introduced by ISPN-9871
> 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
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 3 months
[JBoss JIRA] (ISPN-10345) PutAll to register proto files hangs
by Gustavo Fernandes (Jira)
[ https://issues.jboss.org/browse/ISPN-10345?page=com.atlassian.jira.plugin... ]
Gustavo Fernandes commented on ISPN-10345:
------------------------------------------
[~anistor] A single {{PutAll}} timeouts in the the proto cache, it seems the {{ProtobufMetadataManagerInterceptor}} is doing something contentious when handling the command.
> 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
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 3 months