Uploaded image for project: 'Infinispan'
  1. Infinispan
  2. ISPN-1513

Enhance distributed executor framework to be more topology aware

XMLWordPrintable

    • Icon: Enhancement Enhancement
    • Resolution: Done
    • Icon: Minor Minor
    • 5.2.0.Final
    • 5.0.1.FINAL
    • Clustered Executor
    • None

      Our environment has 2 local infinispan/jgroups clusters with a jgroups relay cluster to handle geographic failover. Our sites are geographically distant over a WAN. Currently DistributedExecutorService's submitEverywhere() sends Callables to every node in both local clusters. We would rather have additional methods provided to DistributedExecutorService to constrain submission on Callables to the same/local site.

      Currently I have extended DefaultExecutorService with my own TopologyAwareExecutorService and added a submitSameSite() method using the TopologyAwareAddress.isSameSite(). I did need to patch DistributedRunnableFuture in DefaultExecutorService to mark it protected vs. private.

      This could be extended to also provide submitSameRack() & submitSameMachine() though currently we don't have a use case for that.

            vblagoje Vladimir Blagojevic (Inactive)
            dsb_jira David B (Inactive)
            Votes:
            1 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: