Hi Strahinja,
Glad to hear that you're using Infinispan in your master thesis :)
I have some reservations about adding these methods.
You can create a custom distributed callable, so why not pass in this info on construction
of the callable, and make sure it's serialized so these parameters are available when
these classes are sent to other nodes?
Cheers,
On May 27, 2013, at 6:51 PM, Strahinja Lazetic <lazetics(a)yahoo.com> wrote:
Hi,
I am currently using Infinispan Distributed Execution Framework for my Master thesis
project and I am wondering if it is possible that a DistributedCallable receives some
custom parameters from the framework upon a failover, besides Cache instance and Set of
keys passed in the setEnvironment method. As a simplified example, a DistributedCallable
wants to know whether it was restarted or freshly started. If this is not possible, does
it make sense to add a new method to the DistributedTaskFailoverPolicy which will return a
user supplied parameters Map and then read it from the setEnvironment method in the
DistributedCallable? Here are the signatures of the methods I was thinking off:
In the DistributedTaskFailoverPolicy class:
Map<Object, Object> getEnvironmentParameters()
In the DistributedCallable class:
setEnvironment(Cache<K, V> cache, Set<K> inputKeys, Map<Object, Object>
params)
I was free to try to implement this and did not take to much time, so now I am wondering
if there was already a way to do something like this in the Infinispan DEF.
Thank you in advance for your comments and suggestions.
Strahinja Lazetic
_______________________________________________
infinispan-dev mailing list
infinispan-dev(a)lists.jboss.org
https://lists.jboss.org/mailman/listinfo/infinispan-dev
--
Galder Zamarreño
galder(a)redhat.com
twitter.com/galderz
Project Lead, Escalante
http://escalante.io
Engineer, Infinispan
http://infinispan.org