org.infinispan.distribution

Class TriangleOrderManager

java.lang.Object

org.infinispan.distribution.TriangleOrderManager

public class TriangleOrderManager
extends Object

It manages the order of updates from the primary owner to backup owner.

It depends on the cache topology id. The primary owner assigns the sequence number to the backup command and then sends it to the backup owner. In the backup owner, the command awaits until it is its turn to be executed.

If the command topology id does not match, it throws an OutdatedTopologyException.

The sequence order starts with 1 and it is per segment based. This allows segments to be updated concurrently.

Since:

9.0

Author:

Pedro Ruivo

Constructor Summary

Constructors

Constructor and Description
TriangleOrderManager(int segments)

Method Summary

Modifier and Type	Method and Description
boolean	isNext(int segmentId, long sequenceNumber, int commandTopologyId)
void	markDelivered(int segmentId, long sequenceNumber, int commandTopologyId)
long	next(int segmentId, int commandTopologyId)
void	updateCacheTopology(CacheTopology newCacheTopology)

Methods inherited from class java.lang.Object

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

Constructor Detail

TriangleOrderManager

public TriangleOrderManager(int segments)

Method Detail

next

public long next(int segmentId,
                 int commandTopologyId)

isNext

public boolean isNext(int segmentId,
                      long sequenceNumber,
                      int commandTopologyId)

markDelivered

public void markDelivered(int segmentId,
                          long sequenceNumber,
                          int commandTopologyId)

updateCacheTopology

public void updateCacheTopology(CacheTopology newCacheTopology)