object SequencerUtils
- Alphabetic
- By Inheritance
- SequencerUtils
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def maxSequencingTimeUpperBoundAt(timestamp: CantonTimestamp, parameterChanges: Seq[DynamicSynchronizerParametersWithValidity]): CantonTimestamp
This method computes how far in the future the maximum sequencing time at a given timestamp is allowed to be based on the
sequencerAggregateSubmissionTimeoutin the dynamic synchronizer parameters.This method computes how far in the future the maximum sequencing time at a given timestamp is allowed to be based on the
sequencerAggregateSubmissionTimeoutin the dynamic synchronizer parameters. This is required due to a possibility of:- timeout being long, say 10000 seconds and submissions being accepted with it (e.g. MST=10001)
- timeout being shortened, say to 100 seconds
- submissions being accepted with the new timeout have a tighter bound (e.g. MST=701) than the ones accepted with the old timeout (still MST=10001)
In practice these timeouts should be short to keep the sequencer memory footprint low, but we take into account the changes in this method to provide full correctness.
- timestamp
a sequencing timestamp where a submission was sequenced
- parameterChanges
all known changes of synchronizer parameters (i.e. output of
listDynamicSynchronizerParametersChanges)
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def timeOffsetPastSynchronizerUpgrade(upgradeTime: CantonTimestamp, parameterChanges: Seq[DynamicSynchronizerParametersWithValidity]): NonNegativeFiniteDuration
Computes the offset that the sequencer will add to all events (effectively only timeproofs are allowed) past the synchronizer upgrade time to immediately time out the in-flight requests in the participants and mediators.
Computes the offset that the sequencer will add to all events (effectively only timeproofs are allowed) past the synchronizer upgrade time to immediately time out the in-flight requests in the participants and mediators. The base of the calculation is the max possible decision time that can exists in the participant, namely sequencing time + mediator reaction timeout + confirmation response timeout (at that sequencing time).
- upgradeTime
The actual upgrade time, as in Successor.upgradeTime
- parameterChanges
List of synchronizer parameter changes at the effective time of the upgrade announcement.
- returns
an offset that will time out all in-flight requests in the participants and mediators
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])