[JBoss JIRA] (ISPN-9923) Reactive basic API
by Katia Aresti (Jira)
[ https://issues.jboss.org/browse/ISPN-9923?page=com.atlassian.jira.plugin.... ]
Katia Aresti updated ISPN-9923:
-------------------------------
Description:
Create a first *ReactiveCache* api based in reactive streams standard
{code:java}
public interface ReactiveCache<K, V> {
CompletionStage<V> get(K key);
CompletionStage<Void> put(K key, V value);
CompletionStage<V> getAndPut(K key, V value);
CompletionStage<Void> remove(K key);
CompletionStage<Boolean> remove(K key, V value);
CompletionStage<V> getAndRemove(K key);
CompletionStage<Void> putMany(Publisher<Map.Entry<K, V>> pairs);
Publisher<K> getKeys();
Publisher<V> getValues();
CompletionStage<Long> size();
}
{code}
was:
Create a first *ReactiveCache* api based in reactive streams standard
{code title=ReactiveCache.java}
public interface ReactiveCache<K, V> {
CompletionStage<V> get(K key);
CompletionStage<Void> put(K key, V value);
CompletionStage<V> getAndPut(K key, V value);
CompletionStage<Void> remove(K key);
CompletionStage<Boolean> remove(K key, V value);
CompletionStage<V> getAndRemove(K key);
CompletionStage<Void> putMany(Publisher<Map.Entry<K, V>> pairs);
Publisher<K> getKeys();
Publisher<V> getValues();
CompletionStage<Long> size();
}
{code}
> Reactive basic API
> ------------------
>
> Key: ISPN-9923
> URL: https://issues.jboss.org/browse/ISPN-9923
> Project: Infinispan
> Issue Type: Sub-task
> Components: API
> Reporter: Katia Aresti
> Assignee: Katia Aresti
> Priority: Major
>
> Create a first *ReactiveCache* api based in reactive streams standard
> {code:java}
> public interface ReactiveCache<K, V> {
> CompletionStage<V> get(K key);
> CompletionStage<Void> put(K key, V value);
> CompletionStage<V> getAndPut(K key, V value);
> CompletionStage<Void> remove(K key);
> CompletionStage<Boolean> remove(K key, V value);
> CompletionStage<V> getAndRemove(K key);
> CompletionStage<Void> putMany(Publisher<Map.Entry<K, V>> pairs);
> Publisher<K> getKeys();
> Publisher<V> getValues();
> CompletionStage<Long> size();
> }
> {code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months
[JBoss JIRA] (ISPN-9923) Reactive basic API
by Katia Aresti (Jira)
[ https://issues.jboss.org/browse/ISPN-9923?page=com.atlassian.jira.plugin.... ]
Katia Aresti reassigned ISPN-9923:
----------------------------------
Assignee: Katia Aresti
> Reactive basic API
> ------------------
>
> Key: ISPN-9923
> URL: https://issues.jboss.org/browse/ISPN-9923
> Project: Infinispan
> Issue Type: Sub-task
> Components: API
> Reporter: Katia Aresti
> Assignee: Katia Aresti
> Priority: Major
>
> Create a first *ReactiveCache* api based in reactive streams standard
> {code title=ReactiveCache.java}
> public interface ReactiveCache<K, V> {
> CompletionStage<V> get(K key);
> CompletionStage<Void> put(K key, V value);
> CompletionStage<V> getAndPut(K key, V value);
> CompletionStage<Void> remove(K key);
> CompletionStage<Boolean> remove(K key, V value);
> CompletionStage<V> getAndRemove(K key);
> CompletionStage<Void> putMany(Publisher<Map.Entry<K, V>> pairs);
> Publisher<K> getKeys();
> Publisher<V> getValues();
> CompletionStage<Long> size();
> }
> {code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months
[JBoss JIRA] (ISPN-9923) Reactive basic API
by Katia Aresti (Jira)
Katia Aresti created ISPN-9923:
----------------------------------
Summary: Reactive basic API
Key: ISPN-9923
URL: https://issues.jboss.org/browse/ISPN-9923
Project: Infinispan
Issue Type: Sub-task
Components: API
Reporter: Katia Aresti
Create a first *ReactiveCache* api based in reactive streams standard
{code title=ReactiveCache.java}
public interface ReactiveCache<K, V> {
CompletionStage<V> get(K key);
CompletionStage<Void> put(K key, V value);
CompletionStage<V> getAndPut(K key, V value);
CompletionStage<Void> remove(K key);
CompletionStage<Boolean> remove(K key, V value);
CompletionStage<V> getAndRemove(K key);
CompletionStage<Void> putMany(Publisher<Map.Entry<K, V>> pairs);
Publisher<K> getKeys();
Publisher<V> getValues();
CompletionStage<Long> size();
}
{code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months
[JBoss JIRA] (ISPN-9922) Create infinispan-api and hotrod-client reactive module
by Katia Aresti (Jira)
[ https://issues.jboss.org/browse/ISPN-9922?page=com.atlassian.jira.plugin.... ]
Katia Aresti reassigned ISPN-9922:
----------------------------------
Assignee: Katia Aresti
> Create infinispan-api and hotrod-client reactive module
> -------------------------------------------------------
>
> Key: ISPN-9922
> URL: https://issues.jboss.org/browse/ISPN-9922
> Project: Infinispan
> Issue Type: Sub-task
> Components: API
> Affects Versions: 10.0.0.Alpha3
> Reporter: Katia Aresti
> Assignee: Katia Aresti
> Priority: Major
>
> Two new dependencies will be used for this API
> * infinispan-api
> * infinispan-client-hotrod-reactive
> Infinispan API will be the new API entry point for embedded and clien/server mode functionalities. It will have a logical dependency with the implementing dependencies.
> Infinispan Client Hotrod Reactive will be the dependency users will need to import to use Infinispan Reactive
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months
[JBoss JIRA] (ISPN-9922) Create infinispan-api and hotrod-client reactive module
by Katia Aresti (Jira)
Katia Aresti created ISPN-9922:
----------------------------------
Summary: Create infinispan-api and hotrod-client reactive module
Key: ISPN-9922
URL: https://issues.jboss.org/browse/ISPN-9922
Project: Infinispan
Issue Type: Sub-task
Components: API
Affects Versions: 10.0.0.Alpha3
Reporter: Katia Aresti
Two new dependencies will be used for this API
* infinispan-api
* infinispan-client-hotrod-reactive
Infinispan API will be the new API entry point for embedded and clien/server mode functionalities. It will have a logical dependency with the implementing dependencies.
Infinispan Client Hotrod Reactive will be the dependency users will need to import to use Infinispan Reactive
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months
[JBoss JIRA] (IPROTO-84) ProtoSchemaBuilder does not detect duplicated enum constant names
by Adrian Nistor (Jira)
[ https://issues.jboss.org/browse/IPROTO-84?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated IPROTO-84:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
Integrated in master and 4.2.x
> ProtoSchemaBuilder does not detect duplicated enum constant names
> -----------------------------------------------------------------
>
> Key: IPROTO-84
> URL: https://issues.jboss.org/browse/IPROTO-84
> Project: Infinispan ProtoStream
> Issue Type: Bug
> Affects Versions: 4.2.0.Final
> Reporter: Adrian Nistor
> Assignee: Adrian Nistor
> Priority: Major
> Fix For: 4.3.0.Alpha1, 4.2.3.Final
>
>
> The duplication is eventually detected later by the proto schema parser, but at this moment the broken schema is already registered and its status is ERROR. Would be better to detect this early during the analysis of the annotations.
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months
[JBoss JIRA] (ISPN-9908) Cache startup failure with insufficient segments
by Hiroki Daicho (Jira)
[ https://issues.jboss.org/browse/ISPN-9908?page=com.atlassian.jira.plugin.... ]
Hiroki Daicho updated ISPN-9908:
--------------------------------
Description:
When setting small segment to a cache and using server hinting, node can't start with the following error[1].
It can be reproduced with RHDG 7.2.3 and 7.3 ER2.
[1]
{code}
ERROR [org.jboss.msc.service.fail] (MSC service thread 1-4) MSC000001: Failed to start service jboss.datagrid-infinispan.clustered.test: org.jboss.msc.service.StartException in service jboss.datagrid-infinispan.clustered.test: Failed to start service
...
Caused by: org.infinispan.commons.CacheException: Unable to invoke method public void org.infinispan.statetransfer.StateTransferManagerImpl.start() throws java.lang.Exception on object of type StateTransferManagerImpl
...
Caused by: org.infinispan.util.concurrent.TimeoutException: Replication timeout for svr01 (flags=0), site-id=site1, rack-id=rack1, machine-id=machine1)
at org.infinispan.remoting.transport.jgroups.JGroupsTransport.checkRsp(JGroupsTransport.java:916)
...
{code}
For example, 3rd node will fail to start with the following setting in 3 nodes cluster.
When set the segments to 20 (6.6.2 default), 6th node will fail to start with the above timeout.
Nodes seems to not be able to finish the initial state transfer and start up fails if the segments are set insufficiently against the number of nodes,
{code}
<distributed-cache name="default" segments="1" />
...
<stack name="udp">
<transport type="UDP" socket-binding="jgroups-udp" machine="${jboss.jgroups.transport.machine:machine1}" rack="${jboss.jgroups.transport.rack:rack1}" site="${jboss.jgroups.transport.site:site1}" />
</stack>
{code}
was:
When setting small segment to a cache and using server hinting, node can't start with the following error[1].
It can be reproduced with RHDG 7.2.3 and 7.3 ER2.
[1]
{code}
ERROR [org.jboss.msc.service.fail] (MSC service thread 1-4) MSC000001: Failed to start service jboss.datagrid-infinispan.clustered.test: org.jboss.msc.service.StartException in service jboss.datagrid-infinispan.clustered.test: Failed to start service
...
Caused by: org.infinispan.commons.CacheException: Unable to invoke method public void org.infinispan.statetransfer.StateTransferManagerImpl.start() throws java.lang.Exception on object of type StateTransferManagerImpl
...
Caused by: org.infinispan.util.concurrent.TimeoutException: Replication timeout for svr01 (flags=0), site-id=site1, rack-id=rack1, machine-id=machine1)
at org.infinispan.remoting.transport.jgroups.JGroupsTransport.checkRsp(JGroupsTransport.java:916)
...
{code}
For example, 3rd node will fail to start with the following setting in 3 nodes cluster.
When set the segments to 20 (6.6.2 default), 6nd node will fail to start with the above timeout.
Nodes seems to not be able to finish the initial state transfer and start up fails if the segments are set insufficiently against the number of nodes,
{code}
<distributed-cache name="default" segments="1" />
...
<stack name="udp">
<transport type="UDP" socket-binding="jgroups-udp" machine="${jboss.jgroups.transport.machine:machine1}" rack="${jboss.jgroups.transport.rack:rack1}" site="${jboss.jgroups.transport.site:site1}" />
</stack>
{code}
> Cache startup failure with insufficient segments
> ------------------------------------------------
>
> Key: ISPN-9908
> URL: https://issues.jboss.org/browse/ISPN-9908
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 9.4.6.Final
> Reporter: Hiroki Daicho
> Assignee: Dan Berindei
> Priority: Major
> Attachments: logs.zip
>
>
> When setting small segment to a cache and using server hinting, node can't start with the following error[1].
> It can be reproduced with RHDG 7.2.3 and 7.3 ER2.
> [1]
> {code}
> ERROR [org.jboss.msc.service.fail] (MSC service thread 1-4) MSC000001: Failed to start service jboss.datagrid-infinispan.clustered.test: org.jboss.msc.service.StartException in service jboss.datagrid-infinispan.clustered.test: Failed to start service
> ...
> Caused by: org.infinispan.commons.CacheException: Unable to invoke method public void org.infinispan.statetransfer.StateTransferManagerImpl.start() throws java.lang.Exception on object of type StateTransferManagerImpl
> ...
> Caused by: org.infinispan.util.concurrent.TimeoutException: Replication timeout for svr01 (flags=0), site-id=site1, rack-id=rack1, machine-id=machine1)
> at org.infinispan.remoting.transport.jgroups.JGroupsTransport.checkRsp(JGroupsTransport.java:916)
> ...
> {code}
> For example, 3rd node will fail to start with the following setting in 3 nodes cluster.
> When set the segments to 20 (6.6.2 default), 6th node will fail to start with the above timeout.
> Nodes seems to not be able to finish the initial state transfer and start up fails if the segments are set insufficiently against the number of nodes,
> {code}
> <distributed-cache name="default" segments="1" />
> ...
> <stack name="udp">
> <transport type="UDP" socket-binding="jgroups-udp" machine="${jboss.jgroups.transport.machine:machine1}" rack="${jboss.jgroups.transport.rack:rack1}" site="${jboss.jgroups.transport.site:site1}" />
> </stack>
> {code}
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
6 years, 8 months