Package org.infinispan.distribution

Examples of org.infinispan.distribution.DistributionManager

368
369
370
371
372
373
374
375
376
377
378
      DistributionManager distributionManager = getDistributionManager();
      ConsistentHash hash = distributionManager.getConsistentHash();
      return hash.getCaches().contains(address);
   }
   private DistributionManager getDistributionManager() {
      DistributionManager distributionManager = cache.getAdvancedCache().getDistributionManager();
      if (distributionManager == null) {
         throw new IllegalStateException("Null distribution manager. Is this an distributed(v.s. replicated) cache?");
      }
      return distributionManager;
   }
View Full Code Here
459
460
461
462
463
464
465
466
467
    * @see org.jboss.web.tomcat.service.session.distributedcache.spi.DistributedCacheManager#isLocal(java.lang.String)
    */
   @Override
   public boolean isLocal(String realId)
   {
      DistributionManager manager = this.sessionCache.getAdvancedCache().getDistributionManager();
     
      return (manager != null) ? manager.isLocal(realId) : true;
   }
View Full Code Here
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
    */
   @Override
   public String locate(String sessionId)
   {
      AdvancedCache<?, ?> cache = this.sessionCache.getAdvancedCache();
      DistributionManager manager = cache.getDistributionManager();
     
      if ((manager != null) && !manager.isRehashInProgress())
      {
         EmbeddedCacheManager container = (EmbeddedCacheManager) cache.getCacheManager();
         Cache<Address, String> jvmRouteCache = this.getJvmRouteCache(container);
        
         for (Address address: manager.locate(sessionId))
         {
            String jvmRoute = jvmRouteCache.get(address);
           
            if (jvmRoute != null)
            {
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
138
139
140
         byte[] key = generateKey(i);
         TcpTransport transport = (TcpTransport) tcpConnectionFactory.getTransport(key);
         SocketAddress serverAddress = transport.getServerAddress();
         CacheContainer cacheContainer = hrServ2CacheManager.get(serverAddress);
         assertNotNull("For server address " + serverAddress + " found " + cacheContainer + ". Map is: " + hrServ2CacheManager, cacheContainer);
         DistributionManager distributionManager = cacheContainer.getCache().getAdvancedCache().getDistributionManager();
         Address clusterAddress = cacheContainer.getCache().getAdvancedCache().getRpcManager().getAddress();

         ConsistentHash serverCh = distributionManager.getReadConsistentHash();
         int numSegments = serverCh.getNumSegments();
         int keySegment = serverCh.getSegment(key);
         Address serverOwner = serverCh.locatePrimaryOwnerForSegment(keySegment);
         Address serverPreviousOwner = serverCh.locatePrimaryOwnerForSegment((keySegment - 1 + numSegments) % numSegments);
         assert clusterAddress.equals(serverOwner) || clusterAddress.equals(serverPreviousOwner);
View Full Code Here
75
76
77
78
79
80
81
82
      return ((DefaultCacheManager) cacheManager).getCacheManagerConfiguration().globalJmxStatistics().domain();
   }

   @Override
   protected String getKeyInfo(AdvancedCache cache, Object key) {
      DistributionManager dm = cache.getDistributionManager();
      return super.getKeyInfo(cache, key) + ", segmentId=" + dm.getConsistentHash().getSegment(key);
   }
View Full Code Here
110
111
112
113
114
115
116
117
118
119
120
121
122
      return consistentHash.getMembers().size();
   }

   @Override
   protected boolean isJoinComplete(Cache<?, ?> cache) {
      DistributionManager dm = cache.getAdvancedCache().getDistributionManager();
      boolean joinComplete = dm.isJoinComplete();
      Set<Integer> ownedSegments = dm.getReadConsistentHash().getSegmentsForOwner(cache.getCacheManager().getAddress());
      if (log.isTraceEnabled()) {
         log.trace("joinComplete=" + joinComplete + ", ownedSegments=" + ownedSegments + ", " + getCHInfo(dm));
      }
      return joinComplete && !ownedSegments.isEmpty();
   }
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
133
134
135
         }
      }

      @Override
      public void debugInfo() {
         DistributionManager dm = cache.getDistributionManager();
         DataContainer container = cache.getDataContainer();
         StringBuilder sb = new StringBuilder(256);
         sb.append("Debug info for ").append(cache.getName()).append(": joinComplete=").append(dm.isJoinComplete());
         sb.append(", rehashInProgress=").append(dm.isRehashInProgress());
         sb.append(", numEntries=").append(container.size());
         sb.append(service.getCHInfo(dm));
         log.debug(sb.toString());
      }
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
      }
      throw new IllegalStateException();
   }

   protected String getKeyInfo(AdvancedCache cache, Object key) {
      DistributionManager dm = cache.getDistributionManager();
      DataContainer container = cache.getDataContainer();
      StringBuilder sb = new StringBuilder(256);
      sb.append("Debug info for key ").append(cache.getName()).append(' ').append(key).append(": owners=");
      for (Address owner : dm.locate(key)) {
         sb.append(owner).append(", ");
      }
      DataLocality locality = dm.getLocality(key);
      sb.append("local=").append(locality.isLocal()).append(", uncertain=").append(locality.isUncertain());
      sb.append(", container.").append(key).append('=').append(toString(container.get(key)));
      return sb.toString();
   }
View Full Code Here
465
466
467
468
469
470
471
472
473
474
475
476
477
     *
     * @see org.jboss.web.tomcat.service.session.distributedcache.spi.DistributedCacheManager#isLocal(java.lang.String)
     */
    @Override
    public boolean isLocal(String sessionId) {
        DistributionManager manager = this.sessionCache.getAdvancedCache().getDistributionManager();

        if (manager == null) return true;

        DataLocality locality = manager.getLocality(sessionId);

        return locality.isLocal() || locality.isUncertain();
    }
View Full Code Here
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
     */
    @Override
    public String locate(String sessionId) {
        if (this.jvmRouteHandler != null) {
            AdvancedCache<?, ?> cache = this.sessionCache.getAdvancedCache();
            DistributionManager manager = cache.getDistributionManager();

            // If rehash is in progress, just use our jvm route - don't hold up the request
            if ((manager != null) && !manager.isRehashInProgress()) {
                List<Address> addresses = manager.locate(sessionId);

                EmbeddedCacheManager container = (EmbeddedCacheManager) this.sessionCache.getCacheManager();

                // Prefer this node, if session happens to hash here
                if (!addresses.contains(container.getAddress())) {
View Full Code Here
TOP

Related Classes of org.infinispan.distribution.DistributionManager

  • org.exoplatform.services.cache.impl.infinispan.distributed.TestDistributedExoCache
  • org.infinispan.affinity.impl.KeyAffinityServiceImpl
  • org.infinispan.affinity.KeyAffinityServiceImpl
  • org.infinispan.cli.interpreter.statement.LocateStatement
  • org.infinispan.client.hotrod.CSAIntegrationTest
  • org.infinispan.distexec.DefaultExecutorService
  • org.infinispan.distexec.mapreduce.MapReduceManagerImpl
  • org.infinispan.distexec.mapreduce.MapReduceTask
  • org.infinispan.distribution.rehash.RehashAfterJoinWithPreloadTest
  • org.infinispan.distribution.rehash.RehashCompletedOnJoinTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.