[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-6771?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes updated ISPN-6771:
------------------------------------
Status: Open (was: New)
> HotRod Client - TcpTransportFactory - update topology issue with multiple caches
> --------------------------------------------------------------------------------
>
> Key: ISPN-6771
> URL: https://issues.jboss.org/browse/ISPN-6771
> Project: Infinispan
> Issue Type: Bug
> Components: Remote Protocols
> Affects Versions: 9.0.0.Alpha2, 8.2.2.Final
> Environment: Infinispan server 8.2.2.Final
> Hot rod client (Java) : 8.2.2.Final
> Reporter: Jean-Francois LARTAUD
>
> After debugging :
> In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
> * For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
> ** The new servers list is returned only if servers have been added.
> ** As this list is not empty, the balancy strategy for the first cache is updated.
> * For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
> ** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
> ** The associated balancing strategies are not updated.
> {code}
> public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
> synchronized (lock) {
> Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
> if (!servers.isEmpty()) {
> FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
> balancer.setServers(servers);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-6771?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes reassigned ISPN-6771:
---------------------------------------
Assignee: Gustavo Fernandes
> HotRod Client - TcpTransportFactory - update topology issue with multiple caches
> --------------------------------------------------------------------------------
>
> Key: ISPN-6771
> URL: https://issues.jboss.org/browse/ISPN-6771
> Project: Infinispan
> Issue Type: Bug
> Components: Remote Protocols
> Affects Versions: 9.0.0.Alpha2, 8.2.2.Final
> Environment: Infinispan server 8.2.2.Final
> Hot rod client (Java) : 8.2.2.Final
> Reporter: Jean-Francois LARTAUD
> Assignee: Gustavo Fernandes
>
> After debugging :
> In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
> * For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
> ** The new servers list is returned only if servers have been added.
> ** As this list is not empty, the balancy strategy for the first cache is updated.
> * For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
> ** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
> ** The associated balancing strategies are not updated.
> {code}
> public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
> synchronized (lock) {
> Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
> if (!servers.isEmpty()) {
> FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
> balancer.setServers(servers);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-6771?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes updated ISPN-6771:
------------------------------------
Component/s: Remote Protocols
(was: hot)
> HotRod Client - TcpTransportFactory - update topology issue with multiple caches
> --------------------------------------------------------------------------------
>
> Key: ISPN-6771
> URL: https://issues.jboss.org/browse/ISPN-6771
> Project: Infinispan
> Issue Type: Bug
> Components: Remote Protocols
> Affects Versions: 9.0.0.Alpha2, 8.2.2.Final
> Environment: Infinispan server 8.2.2.Final
> Hot rod client (Java) : 8.2.2.Final
> Reporter: Jean-Francois LARTAUD
>
> After debugging :
> In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
> * For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
> ** The new servers list is returned only if servers have been added.
> ** As this list is not empty, the balancy strategy for the first cache is updated.
> * For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
> ** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
> ** The associated balancing strategies are not updated.
> {code}
> public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
> synchronized (lock) {
> Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
> if (!servers.isEmpty()) {
> FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
> balancer.setServers(servers);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Jean-Francois LARTAUD (JIRA)
[ https://issues.jboss.org/browse/ISPN-6771?page=com.atlassian.jira.plugin.... ]
Jean-Francois LARTAUD updated ISPN-6771:
----------------------------------------
Description:
After debugging :
In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
* For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
** The new servers list is returned only if servers have been added.
** As this list is not empty, the balancy strategy for the first cache is updated.
* For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
** The associated balancing strategies are not updated.
{code}
public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
synchronized (lock) {
Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
if (!servers.isEmpty()) {
FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
balancer.setServers(servers);
}
}
}
{code}
was:
After debugging :
In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
* For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
** The new servers list is returned only if servers have been added.
** As this list is not empty, the balancy strategy for the first cache is updated.
* For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
** The associated balancing strategies are not updated.
{code}
public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
synchronized (lock) {
Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
//
if (!servers.isEmpty()) {
FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
balancer.setServers(servers);
}
}
}
{code}
> HotRod Client - TcpTransportFactory - update topology issue with multiple caches
> --------------------------------------------------------------------------------
>
> Key: ISPN-6771
> URL: https://issues.jboss.org/browse/ISPN-6771
> Project: Infinispan
> Issue Type: Bug
> Components: hot
> Affects Versions: 9.0.0.Alpha2, 8.2.2.Final
> Environment: Infinispan server 8.2.2.Final
> Hot rod client (Java) : 8.2.2.Final
> Reporter: Jean-Francois LARTAUD
>
> After debugging :
> In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
> * For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
> ** The new servers list is returned only if servers have been added.
> ** As this list is not empty, the balancy strategy for the first cache is updated.
> * For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
> ** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
> ** The associated balancing strategies are not updated.
> {code}
> public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
> synchronized (lock) {
> Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
> if (!servers.isEmpty()) {
> FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
> balancer.setServers(servers);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Jean-Francois LARTAUD (JIRA)
[ https://issues.jboss.org/browse/ISPN-6771?page=com.atlassian.jira.plugin.... ]
Jean-Francois LARTAUD updated ISPN-6771:
----------------------------------------
Steps to Reproduce:
Configuration :
* Server side :
** 3 distributed-cache into a cache container
** 3 nodes (nodeA, nodeB, nodeC).
* Client side :
** 1 remote cache manager with TcpTransportFactory and RoundRobinBalancingStrategy.
** 2 infinispan-server nodes (nodeA, nodeB) configured into the server list
Everything is running except nodeC
1. I start a new infinispan-server (nodeC)
2. Only the RoundRobingBalancingStrategy associated with the 1st cache declared is updated with the new infinispan-server nodeC
3. I stop the nodeB
4. Only the RoundRobinBalancingStrategy associated with the first cache declared is updated
5. The RoundRobinStrategies associated with the 2nd and 3rd are not updated. When quering on these cache, the nodeB is "excluded" and it remains only one node (nodeA).
6. I stop nodeA
7. When quering the 1st cache, the nodeC is requested. When querying the 2nd and the 3rd caches, I got "org.infinispan.client.hotrod.exceptions.TransportException:: Could not fetch transport"
was:
Configuration :
* Server side :
** 3 distributed-cache into a cache container
** 3 nodes (nodeA, nodeB, nodeC).
* Client side :
** 1 remote cache manager with TcpTransportFactory and RoundRobinBalancingStrategy.
** 2 infinispan-server nodes (nodeA, nodeB) configured into the server list
Everything is running except nodeC
1. I start a new infinispan-server (nodeC)
2. Only the RoundRobingBalancingStrategy associated with the 1st cache declared is updated with the new infinispan-server
3. I stop the nodeB
4. Only the RoundRobinBalancingStrategy associated with the first cache declared is updated
5. The RoundRobinStrategy assciated with the 2nd and 3rd are not updated. When quering on these cache, the nodeB is "excluded" and it remains only one node (nodeA).
6. I stop nodeA
7. When quering the 1st cache, the nodeC is requested. When querying the 2nd and the 3rd caches, I got "org.infinispan.client.hotrod.exceptions.TransportException:: Could not fetch transport"
> HotRod Client - TcpTransportFactory - update topology issue with multiple caches
> --------------------------------------------------------------------------------
>
> Key: ISPN-6771
> URL: https://issues.jboss.org/browse/ISPN-6771
> Project: Infinispan
> Issue Type: Bug
> Components: hot
> Affects Versions: 9.0.0.Alpha2, 8.2.2.Final
> Environment: Infinispan server 8.2.2.Final
> Hot rod client (Java) : 8.2.2.Final
> Reporter: Jean-Francois LARTAUD
>
> After debugging :
> In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
> * For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
> ** The new servers list is returned only if servers have been added.
> ** As this list is not empty, the balancy strategy for the first cache is updated.
> * For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
> ** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
> ** The associated balancing strategies are not updated.
> {code}
> public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
> synchronized (lock) {
> Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
> //
> if (!servers.isEmpty()) {
> FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
> balancer.setServers(servers);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Jean-Francois LARTAUD (JIRA)
[ https://issues.jboss.org/browse/ISPN-6771?page=com.atlassian.jira.plugin.... ]
Jean-Francois LARTAUD updated ISPN-6771:
----------------------------------------
Steps to Reproduce:
Configuration :
* Server side :
** 3 distributed-cache into a cache container
** 3 nodes (nodeA, nodeB, nodeC).
* Client side :
** 1 remote cache manager with TcpTransportFactory and RoundRobinBalancingStrategy.
** 2 infinispan-server nodes (nodeA, nodeB) configured into the server list
Everything is running except nodeC
1. I start a new infinispan-server (nodeC)
2. Only the RoundRobingBalancingStrategy associated with the 1st cache declared is updated with the new infinispan-server
3. I stop the nodeB
4. Only the RoundRobinBalancingStrategy associated with the first cache declared is updated
5. The RoundRobinStrategy assciated with the 2nd and 3rd are not updated. When quering on these cache, the nodeB is "excluded" and it remains only one node (nodeA).
6. I stop nodeA
7. When quering the 1st cache, the nodeC is requested. When querying the 2nd and the 3rd caches, I got "org.infinispan.client.hotrod.exceptions.TransportException:: Could not fetch transport"
was:
Configuration :
* Server side :
** 3 distributed-cache into a cache container
* Client side :
** 1 remote cache manager with TcpTransportFactory and RoundRobinBalancingStrategy.
** 2 infinispan-server nodes (nodeA, nodeB) configured into the server list
Everything is running.
1. I start a new infinispan-server (nodeC)
2. Only the RoundRobingBalancingStrategy associated with the 1st cache declared is updated with the new infinispan-server
3. I stop the nodeB
4. Only the RoundRobinBalancingStrategy associated with the first cache declared is updated
5. The RoundRobinStrategy assciated with the 2nd and 3rd are not updated. When quering on these cache, the nodeB is "excluded" and it remains only one node (nodeA).
6. I stop nodeA
7. When quering the 1st cache, the nodeC is requested. When querying the 2nd and the 3rd caches, I got "org.infinispan.client.hotrod.exceptions.TransportException:: Could not fetch transport"
> HotRod Client - TcpTransportFactory - update topology issue with multiple caches
> --------------------------------------------------------------------------------
>
> Key: ISPN-6771
> URL: https://issues.jboss.org/browse/ISPN-6771
> Project: Infinispan
> Issue Type: Bug
> Components: hot
> Affects Versions: 9.0.0.Alpha2, 8.2.2.Final
> Environment: Infinispan server 8.2.2.Final
> Hot rod client (Java) : 8.2.2.Final
> Reporter: Jean-Francois LARTAUD
>
> After debugging :
> In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
> * For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
> ** The new servers list is returned only if servers have been added.
> ** As this list is not empty, the balancy strategy for the first cache is updated.
> * For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
> ** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
> ** The associated balancing strategies are not updated.
> {code}
> public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
> synchronized (lock) {
> Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
> //
> if (!servers.isEmpty()) {
> FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
> balancer.setServers(servers);
> }
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months
[JBoss JIRA] (ISPN-6771) HotRod Client - TcpTransportFactory - update topology issue with multiple caches
by Jean-Francois LARTAUD (JIRA)
Jean-Francois LARTAUD created ISPN-6771:
-------------------------------------------
Summary: HotRod Client - TcpTransportFactory - update topology issue with multiple caches
Key: ISPN-6771
URL: https://issues.jboss.org/browse/ISPN-6771
Project: Infinispan
Issue Type: Bug
Components: hot
Affects Versions: 8.2.2.Final, 9.0.0.Alpha2
Environment: Infinispan server 8.2.2.Final
Hot rod client (Java) : 8.2.2.Final
Reporter: Jean-Francois LARTAUD
After debugging :
In TcpTransportFactory, the topologyInfo is global (whatever the number of caches), the balancing strategies are defined by cache.
* For the 1st cache, the servers list is updated (org.infinispan.client.hotrod.impl.transport.tcp.TcpTransportFactory#updateServers(java.util.Collection<java.net.SocketAddress>, byte[], boolean), the topologyInfo is updated.
** The new servers list is returned only if servers have been added.
** As this list is not empty, the balancy strategy for the first cache is updated.
* For the other caches, the server list is updated by calling the same "updateServers" method, the "updateTopologyInfo" method is called
** But as the topologyInfo has been already updated for the 1st cache, it returns "Collections.emptyList();"
** The associated balancing strategies are not updated.
{code}
public void updateServers(Collection<SocketAddress> newServers, byte[] cacheName, boolean quiet) {
synchronized (lock) {
Collection<SocketAddress> servers = updateTopologyInfo(newServers, quiet);
//
if (!servers.isEmpty()) {
FailoverRequestBalancingStrategy balancer = getOrCreateIfAbsentBalancer(cacheName);
balancer.setServers(servers);
}
}
}
{code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
9 years, 10 months