[JBoss JIRA] (ISPN-1974) Add <T> Future<T> submit(Address target, Callable<T> task) at least to DefaultExecutorService
by Thomas Fromm (JIRA)
Thomas Fromm created ISPN-1974:
----------------------------------
Summary: Add <T> Future<T> submit(Address target, Callable<T> task) at least to DefaultExecutorService
Key: ISPN-1974
URL: https://issues.jboss.org/browse/ISPN-1974
Project: Infinispan
Issue Type: Enhancement
Components: Core API
Affects Versions: 5.1.3.FINAL
Reporter: Thomas Fromm
Assignee: Manik Surtani
To easy execute tasks on specific nodes I'd like to have an additional method at DefaultExecutorService:
{code}
public <T> Future<T> submit(Address target, Callable<T> task){
if (task == null) throw new NullPointerException();
if (target == null) throw new NullPointerException();
List<Address> members = rpc.getTransport().getMembers();
if(!members.contains(target)){
throw new IllegalArgumentException("Unknown node "+target.toString());
}
Address me = rpc.getAddress();
DistributedExecuteCommand<T> c = null;
if(target.equals(me)){
c = factory.buildDistributedExecuteCommand(clone(task), me, null);
} else {
c = factory.buildDistributedExecuteCommand(task, me, null);
}
DistributedRunnableFuture<T> f = new DistributedRunnableFuture<T>(c);
executeFuture(target, f);
return f;
}
{code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 4 months
[JBoss JIRA] (ISPN-2039) Iteration in DistributedTaskLifecycleService using ServiceLoader fails
by Vladimir Blagojevic (JIRA)
Vladimir Blagojevic created ISPN-2039:
-----------------------------------------
Summary: Iteration in DistributedTaskLifecycleService using ServiceLoader fails
Key: ISPN-2039
URL: https://issues.jboss.org/browse/ISPN-2039
Project: Infinispan
Issue Type: Bug
Components: Distributed Cache
Affects Versions: 5.1.4.FINAL
Environment: This problem has been observed in AS 7 environment rather than Infinispan standalone
Reporter: Ales Justin
Assignee: Vladimir Blagojevic
Priority: Minor
Fix For: 5.2.0.ALPHA1, 5.2.0.FINAL
For some unknown reason iteration over available DistributedTaskLifecycle services in DistributedTaskLifecycleService fails, and it fails only in AS environment:
Caused by: java.util.NoSuchElementException
at java.util.AbstractList$Itr.next(AbstractList.java:350) [classes.jar:1.6.0_31]
at java.util.Collections$1.nextElement(Collections.java:3389) [classes.jar:1.6.0_31]
at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:332) [classes.jar:1.6.0_31]
at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:415) [classes.jar:1.6.0_31]
at org.infinispan.distexec.spi.DistributedTaskLifecycleService.onPreExecute(DistributedTaskLifecycleService.java:50) [infinispan-core-5.2.0-SNAPSHOT.jar:5.2.0-SNAPSHOT]
public <T> void onPreExecute(Callable<T> task) {
try {
Iterator<DistributedTaskLifecycle> i = loader.iterator();
while (i.hasNext()) { // <------------------------------------------------- we CHECK before
DistributedTaskLifecycle cl = i.next();
cl.onPreExecute(task);
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 4 months
[JBoss JIRA] Created: (ISPN-78) Large object support
by Manik Surtani (JIRA)
Large object support
--------------------
Key: ISPN-78
URL: https://jira.jboss.org/jira/browse/ISPN-78
Project: Infinispan
Issue Type: Feature Request
Components: Core API
Reporter: Manik Surtani
Assignee: Manik Surtani
Fix For: 5.0.0.GA
if each VM is allocated a 2GB heap and you have a 100 nodes in a grid with 1 redundant copy for each key, you have a theoretical addressable heap of 100GB. But you are limited by (half) the heap of a single VM per entry, since entries are stored whole.
E.g., cache.put(k, my2GBObject) will fail since you need at least 2GB for the object + another 2GB for its serialized form.
This gets worse when you try cache.put(k, my10GBObject). This *should* be possible if we have a theoretical 100GB heap.
Potential solutions here are to fragment large objects, and store each fragment under separate keys. Another approach would be to directly stream objects to disk. etc. Needs thought and design, possibly a separate API to prevent 'pollution" of the more simplistic API. (JumboCache?)
Re: fragmenting, issues to overcome:
How many chunks to fragment into? Max size of each key could be configured, but how do we determine the size of an Object? VM instrumentation? Or perhaps the JumboCache only stores byte[]'s?
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators: https://jira.jboss.org/jira/secure/Administrators.jspa
-
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 4 months
[JBoss JIRA] (ISPN-1865) Update indexes only when needed
by Mathieu Lachance (JIRA)
Mathieu Lachance created ISPN-1865:
--------------------------------------
Summary: Update indexes only when needed
Key: ISPN-1865
URL: https://issues.jboss.org/browse/ISPN-1865
Project: Infinispan
Issue Type: Enhancement
Components: Querying
Affects Versions: 5.1.1.FINAL
Reporter: Mathieu Lachance
Assignee: Sanne Grinovero
// put in cache a value with 2 field, one indexed and one not indexed.
Value value = new Value();
value.setNonIndexedFieldValue(123);
value.setIndexedFieldValue(456);
cache.put("key", value);
// later...
// get back value from cache and update the not indexed field
Value value = cache.get("key");
value.setNonIndexedFieldValue(789);
cache.put("key", value);
The second put operation will trigger index to update even tough it hasn't changed.
Sanne suggested :
" Thinking about it, there might be some situations in which we can detect it, for example if the put is going to carry a valid return value then we could compare values in string form.. nice, please open an improvement request on JIRA!"
See https://community.jboss.org/thread/195303 for complete reference
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 4 months
[JBoss JIRA] (ISPN-2022) Make MarshalledValues immutable
by Manik Surtani (JIRA)
Manik Surtani created ISPN-2022:
-----------------------------------
Summary: Make MarshalledValues immutable
Key: ISPN-2022
URL: https://issues.jboss.org/browse/ISPN-2022
Project: Infinispan
Issue Type: Feature Request
Components: Marshalling
Affects Versions: 5.1.4.FINAL
Reporter: Manik Surtani
Assignee: Galder Zamarreño
Fix For: 5.1.x, 5.2.0.ALPHA1, 5.2.0.FINAL
MarshalledValues are not currently reused, so the containers could be made immutable. Different subtypes would be needed as well, i.e., {{InstanceBaisedMarshalledValue}}, where {{instance}} is {{final}} and {{raw}} then need not be volatile. {{RawBiasedMarshalledValue}}, where {{raw}} is {{final}} and {{instance}} then need not be volatile. {{serialisedSize}} and {{equalityPreferenceForInstance}} would be unnecessary.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
12 years, 4 months