com.digitalasset.canton.participant.store.db
DbInFlightSubmissionStore
Companion object DbInFlightSubmissionStore
class DbInFlightSubmissionStore extends InFlightSubmissionStore with DbStore
- Alphabetic
- By Inheritance
- DbInFlightSubmissionStore
- DbStore
- HasCloseContext
- NamedLogging
- FlagCloseable
- InFlightSubmissionStore
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DbInFlightSubmissionStore(storage: DbStorage, maxItemsInSqlInClause: PositiveNumeric[Int], registerBatchAggregatorConfig: BatchAggregatorConfig, timeouts: ProcessingTimeout, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)
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]) @native() @HotSpotIntrinsicCandidate()
- final def close(): Unit
Blocks until all earlier tasks have completed and then prevents further tasks from being run.
Blocks until all earlier tasks have completed and then prevents further tasks from being run.
- Definition Classes
- FlagCloseable → AutoCloseable
- Annotations
- @SuppressWarnings()
- implicit val closeContext: CloseContext
- Definition Classes
- HasCloseContext
- def closingTimeout: FiniteDuration
- Attributes
- protected
- Definition Classes
- FlagCloseable
- def delete(submissions: Seq[InFlightReference])(implicit traceContext: TraceContext): Future[Unit]
Deletes the referred to in-flight submissions if there are any.
Deletes the referred to in-flight submissions if there are any.
If the com.digitalasset.canton.sequencing.protocol.MessageId in com.digitalasset.canton.participant.store.InFlightSubmissionStore.InFlightByMessageId is not a UUID, there cannot be a matching in-flight submission because register forces a UUID for the message ID.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- 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
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def internalPerformUnlessClosingF[A](f: => Future[A])(implicit ec: ExecutionContext, traceContext: TraceContext): UnlessShutdown[Future[A]]
- Attributes
- protected
- Definition Classes
- FlagCloseable
- def isClosing: Boolean
Check whether we're closing.
Check whether we're closing. Susceptible to race conditions; unless you're using using this as a flag to the retry lib or you really know what you're doing, prefer performUnlessClosing and friends.
- Definition Classes
- FlagCloseable
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def keepTrackOfOpenFutures: Boolean
track running futures on shutdown
track running futures on shutdown
set to true to get detailed information about all futures that did not complete during shutdown. if set to false, we don't do anything.
- Attributes
- protected
- Definition Classes
- FlagCloseable
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- DbInFlightSubmissionStore → NamedLogging
- implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- def lookup(changeIdHash: ChangeIdHash)(implicit traceContext: TraceContext): OptionT[Future, InFlightSubmission[SubmissionSequencingInfo]]
Retrieves the in-flight submission for the given com.daml.ledger.participant.state.v2.ChangeId if one exists.
Retrieves the in-flight submission for the given com.daml.ledger.participant.state.v2.ChangeId if one exists.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- def lookupEarliest(domainId: DomainId)(implicit traceContext: TraceContext): Future[Option[CantonTimestamp]]
Returns the earliest com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout or com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime in the store, if any, for the given domain.
Returns the earliest com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout or com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime in the store, if any, for the given domain.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- def lookupSequencedUptoUnordered(domainId: DomainId, sequencingTimeInclusive: CantonTimestamp)(implicit traceContext: TraceContext): Future[Seq[InFlightSubmission[SequencedSubmission]]]
Returns all sequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime is no later than
sequencingTimeInclusive
.Returns all sequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime is no later than
sequencingTimeInclusive
.The in-flight submissions are not returned in any specific order.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- def lookupSomeMessageId(domainId: DomainId, messageId: MessageId)(implicit traceContext: TraceContext): Future[Option[InFlightSubmission[SubmissionSequencingInfo]]]
Returns one of the in-flight submissions with the given com.digitalasset.canton.topology.DomainId and com.digitalasset.canton.sequencing.protocol.MessageId, if any.
Returns one of the in-flight submissions with the given com.digitalasset.canton.topology.DomainId and com.digitalasset.canton.sequencing.protocol.MessageId, if any.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- def lookupUnsequencedUptoUnordered(domainId: DomainId, observedSequencingTime: CantonTimestamp)(implicit traceContext: TraceContext): Future[Seq[InFlightSubmission[UnsequencedSubmission]]]
Returns all unsequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is no later than
observedSequencingTime
.Returns all unsequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is no later than
observedSequencingTime
.The in-flight submissions are not returned in any specific order.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def observeSequencing(domainId: DomainId, submissions: Map[MessageId, SequencedSubmission])(implicit traceContext: TraceContext): Future[Unit]
Moves the submissions to the given domain with the given com.digitalasset.canton.sequencing.protocol.MessageIds from com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission to com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.
Moves the submissions to the given domain with the given com.digitalasset.canton.sequencing.protocol.MessageIds from com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission to com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- def onClosed(): Unit
- Attributes
- protected
- Definition Classes
- FlagCloseable
- def performUnlessClosing[A](f: => A)(implicit traceContext: TraceContext): UnlessShutdown[A]
Performs the task given by
f
unless a shutdown has been initiated.Performs the task given by
f
unless a shutdown has been initiated. The shutdown will only begin afterf
completes, but other tasks may execute concurrently withf
, if started using this function, or one of the other variants (performUnlessClosingF and performUnlessClosingEitherT). The tasks are assumed to take less than closingTimeout to complete.- f
The task to perform
- returns
scala.None$ if a shutdown has been initiated. Otherwise the result of the task.
- Definition Classes
- FlagCloseable
- def performUnlessClosingEitherT[E, R](onClosing: => E)(etf: => EitherT[Future, E, R])(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[Future, E, R]
Performs the EitherT[Future] given by
etf
unless a shutdown has been initiated, in which case the provided error is returned instead.Performs the EitherT[Future] given by
etf
unless a shutdown has been initiated, in which case the provided error is returned instead. Bothetf
and the error are lazy;etf
is only evaluated if there is no shutdown, the error only if we're shutting down. The shutdown will only begin afteretf
completes, but other tasks may execute concurrently withetf
, if started using this function, or one of the other variants (performUnlessClosing and performUnlessClosingF). The tasks are assumed to take less than closingTimeout to complete.- etf
The task to perform
- Definition Classes
- FlagCloseable
- def performUnlessClosingEitherTF[E, R](onClosing: => E)(etf: => EitherT[Future, E, Future[R]])(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[Future, E, Future[R]]
- Definition Classes
- FlagCloseable
- def performUnlessClosingF[A](f: => Future[A])(implicit ec: ExecutionContext, traceContext: TraceContext): FutureUnlessShutdown[A]
Performs the Future given by
f
unless a shutdown has been initiated.Performs the Future given by
f
unless a shutdown has been initiated. The future is lazy and not evaluated during shutdown. The shutdown will only begin afterf
completes, but other tasks may execute concurrently withf
, if started using this function, or one of the other variants (performUnlessClosing and performUnlessClosingEitherT). The tasks are assumed to take less than closingTimeout to complete.- f
The task to perform
- returns
The future completes with com.digitalasset.canton.lifecycle.UnlessShutdown.AbortedDueToShutdown if a shutdown has been initiated. Otherwise the result of the task wrapped in com.digitalasset.canton.lifecycle.UnlessShutdown.Outcome.
- Definition Classes
- FlagCloseable
- def register(submission: InFlightSubmission[UnsequencedSubmission]): EitherT[FutureUnlessShutdown, InFlightSubmission[SubmissionSequencingInfo], Unit]
Registers the given submission as being in flight and unsequenced unless there already is an in-flight submission for the same change ID.
Registers the given submission as being in flight and unsequenced unless there already is an in-flight submission for the same change ID.
This method MUST NOT run concurrently with a delete query for the same change ID and message ID. When this method fails with an exception, it is unknown whether the submission was registered.
- returns
A scala.Left$ of the existing in-flight submission with the same change ID and a different com.digitalasset.canton.sequencing.protocol.MessageId if there is any.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- def runOnShutdown[T](task: RunOnShutdown)(implicit traceContext: TraceContext): Unit
Register a task that will run onClose after all "performUnlessShutdown" tasks have finished
Register a task that will run onClose after all "performUnlessShutdown" tasks have finished
- Definition Classes
- FlagCloseable
- def runStateChanged(waitingState: Boolean = false): Unit
- Attributes
- protected
- Definition Classes
- FlagCloseable
- Annotations
- @VisibleForTesting()
- def sleepMillis: Long
- Attributes
- protected
- Definition Classes
- FlagCloseable
- val storage: DbStorage
- Attributes
- protected
- Definition Classes
- DbInFlightSubmissionStore → DbStore
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val timeouts: ProcessingTimeout
- Attributes
- protected
- Definition Classes
- DbInFlightSubmissionStore → FlagCloseable
- def toString(): String
- Definition Classes
- AnyRef → Any
- def updateUnsequenced(changeIdHash: ChangeIdHash, submissionDomain: DomainId, messageId: MessageId, newSequencingInfo: UnsequencedSubmission)(implicit traceContext: TraceContext): Future[Unit]
Update the in-flight submission identified by the given
changeId
ifsubmissionDomain
andmessageId
match and it is unsequenced and the existing com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is not earlier than thenewSequencingInfo
's com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout.Update the in-flight submission identified by the given
changeId
ifsubmissionDomain
andmessageId
match and it is unsequenced and the existing com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is not earlier than thenewSequencingInfo
's com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout. Only the field com.digitalasset.canton.participant.protocol.submission.InFlightSubmission.sequencingInfo is updated.This is useful to change when and how a rejection is reported, e.g., if the submission logic decided to not send the com.digitalasset.canton.sequencing.protocol.SubmissionRequest to the sequencer after all.
- Definition Classes
- DbInFlightSubmissionStore → InFlightSubmissionStore
- 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]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])