Package org.infinispan.distribution.ch.impl

Class TopologyAwareSyncConsistentHashFactory.Builder

java.lang.Object

org.infinispan.distribution.ch.impl.SyncConsistentHashFactory.Builder

org.infinispan.distribution.ch.impl.TopologyAwareSyncConsistentHashFactory.Builder

Enclosing class:

TopologyAwareSyncConsistentHashFactory

protected static class TopologyAwareSyncConsistentHashFactory.Builder
extends SyncConsistentHashFactory.Builder

Field Summary

Fields

Modifier and Type	Field	Description
protected TopologyLevel	currentLevel
protected TopologyInfo	topologyInfo

Fields inherited from class org.infinispan.distribution.ch.impl.SyncConsistentHashFactory.Builder

actualNumOwners, capacityFactors, hashFunction, ignoreMaxSegments, numOwners, numSegments, segmentOwners, segmentSize, sortedMembers, stats

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Builder(org.infinispan.commons.hash.Hash hashFunction, int numOwners, int numSegments, List<Address> members, Map<Address,Float> capacityFactors)

Method Summary

Modifier and Type	Method	Description
protected boolean	addBackupOwner(int segment, Address candidate)
protected boolean	canAddOwners(List<Address> owners)
protected void	copyOwners()
protected double	getExpectedOwnedSegments(Address node)
protected double	getExpectedPrimarySegments(Address node)
protected void	populateExtraOwners(int numSegments)

Methods inherited from class org.infinispan.distribution.ch.impl.SyncConsistentHashFactory.Builder

addOwnerNoCheck, addPrimaryOwner, computeTotalCapacity, doCopyOwners, nextSegment, normalizedHash, populateOwners, sort

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

topologyInfo

protected final TopologyInfo topologyInfo

currentLevel

protected TopologyLevel currentLevel

Constructor Detail

Builder

protected Builder(org.infinispan.commons.hash.Hash hashFunction,
                  int numOwners,
                  int numSegments,
                  List<Address> members,
                  Map<Address,Float> capacityFactors)

Method Detail

copyOwners

protected void copyOwners()

Overrides:

copyOwners in class SyncConsistentHashFactory.Builder

addBackupOwner

protected boolean addBackupOwner(int segment,
                                 Address candidate)

Overrides:

addBackupOwner in class SyncConsistentHashFactory.Builder

canAddOwners

protected boolean canAddOwners(List<Address> owners)

Overrides:

canAddOwners in class SyncConsistentHashFactory.Builder

populateExtraOwners

protected void populateExtraOwners(int numSegments)

Overrides:

populateExtraOwners in class SyncConsistentHashFactory.Builder

getExpectedPrimarySegments

protected double getExpectedPrimarySegments(Address node)

Overrides:

getExpectedPrimarySegments in class SyncConsistentHashFactory.Builder

getExpectedOwnedSegments

protected double getExpectedOwnedSegments(Address node)

Overrides:

getExpectedOwnedSegments in class SyncConsistentHashFactory.Builder