[JBoss JIRA] (ISPN-7858) Investigate parallel processing of message batches
by Dan Berindei (JIRA)
[ https://issues.jboss.org/browse/ISPN-7858?page=com.atlassian.jira.plugin.... ]
Dan Berindei updated ISPN-7858:
-------------------------------
Status: Open (was: Pull Request Sent)
Git Pull Request: (was: https://github.com/infinispan/infinispan/pull/5184)
> Investigate parallel processing of message batches
> --------------------------------------------------
>
> Key: ISPN-7858
> URL: https://issues.jboss.org/browse/ISPN-7858
> Project: Infinispan
> Issue Type: Enhancement
> Components: Core
> Affects Versions: 9.0.1.Final
> Reporter: Dan Berindei
> Assignee: Dan Berindei
>
> Currently, message batches are handled _sequentially_ by Infinispan, ie. a batch of messages 1-5 processes message 1 first, then message 2 etc.
> This causes the processing of message 5 to start only when the 4 previous messages have been processed.
> Investigate parallelization of this processing. One possible implementation could be for example similar to the TriCache impl [4]:
> * Use _application batches_: multiple GET requests and/or GET responses could be wrapped into a single application batch
> * Have a separate thread pool with N threads (configurable) and a queue for PUTs and GET responses
> * Process the GET requests inline (in the same thread), and (in parallel) pass the application batch on to a thread pool for processing of GET responses and/or PUT requests.
> [1] https://github.com/belaban/IspnPerfTest/blob/master/src/org/cache/impl/tr...
--
This message was sent by Atlassian JIRA
(v7.2.3#72005)
8 years, 9 months
[JBoss JIRA] (ISPN-7918) Move Functional API to core
by Radim Vansa (JIRA)
Radim Vansa created ISPN-7918:
---------------------------------
Summary: Move Functional API to core
Key: ISPN-7918
URL: https://issues.jboss.org/browse/ISPN-7918
Project: Infinispan
Issue Type: Task
Components: Core
Affects Versions: 9.1.0.Alpha1
Reporter: Radim Vansa
Assignee: Radim Vansa
Move {{org.infinispan.commons.api.functional}} and all references to {{infinispan-core}}:{{org.infinispan.functional}}
--
This message was sent by Atlassian JIRA
(v7.2.3#72005)
8 years, 9 months
[JBoss JIRA] (ISPN-7911) Functional commands do not invalidate L1 cache
by Radim Vansa (JIRA)
[ https://issues.jboss.org/browse/ISPN-7911?page=com.atlassian.jira.plugin.... ]
Radim Vansa updated ISPN-7911:
------------------------------
Status: Open (was: New)
> Functional commands do not invalidate L1 cache
> ----------------------------------------------
>
> Key: ISPN-7911
> URL: https://issues.jboss.org/browse/ISPN-7911
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 9.1.0.Alpha1
> Reporter: Radim Vansa
> Assignee: Radim Vansa
>
> SSIA. Test that fails in {{DistSyncFuncTest}} courtesy of [~karesti]:
> {code:java}
> public void testEvalFromNonOwner() {
> initAndTest();
> Cache<Object, String> nonOwner = getFirstNonOwner("k1");
> FunctionalMapImpl<Object, String> objectStringFunctionalMap = FunctionalMapImpl.create(nonOwner.getAdvancedCache());
> FunctionalMap.ReadWriteMap<Object, String> functionalMap = ReadWriteMapImpl.create(objectStringFunctionalMap);
> SerializableFunction<EntryView.ReadWriteEntryView<Object, String>, Void> func = v -> {
> v.set("value2");
> return null;
> };
> try {
> functionalMap.eval("k1", func).get();
> assertOnAllCachesAndOwnership("k1", "value2");
> } catch (InterruptedException e) {
> e.printStackTrace();
> } catch (ExecutionException e) {
> e.printStackTrace();
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v7.2.3#72005)
8 years, 9 months
[JBoss JIRA] (ISPN-7911) Functional commands do not invalidate L1 cache
by Radim Vansa (JIRA)
[ https://issues.jboss.org/browse/ISPN-7911?page=com.atlassian.jira.plugin.... ]
Radim Vansa updated ISPN-7911:
------------------------------
Status: Pull Request Sent (was: Open)
Git Pull Request: https://github.com/infinispan/infinispan/pull/5197
> Functional commands do not invalidate L1 cache
> ----------------------------------------------
>
> Key: ISPN-7911
> URL: https://issues.jboss.org/browse/ISPN-7911
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 9.1.0.Alpha1
> Reporter: Radim Vansa
> Assignee: Radim Vansa
>
> SSIA. Test that fails in {{DistSyncFuncTest}} courtesy of [~karesti]:
> {code:java}
> public void testEvalFromNonOwner() {
> initAndTest();
> Cache<Object, String> nonOwner = getFirstNonOwner("k1");
> FunctionalMapImpl<Object, String> objectStringFunctionalMap = FunctionalMapImpl.create(nonOwner.getAdvancedCache());
> FunctionalMap.ReadWriteMap<Object, String> functionalMap = ReadWriteMapImpl.create(objectStringFunctionalMap);
> SerializableFunction<EntryView.ReadWriteEntryView<Object, String>, Void> func = v -> {
> v.set("value2");
> return null;
> };
> try {
> functionalMap.eval("k1", func).get();
> assertOnAllCachesAndOwnership("k1", "value2");
> } catch (InterruptedException e) {
> e.printStackTrace();
> } catch (ExecutionException e) {
> e.printStackTrace();
> }
> }
> {code}
--
This message was sent by Atlassian JIRA
(v7.2.3#72005)
8 years, 9 months