Package com._1c.g5.v8.internal.derived

Class DerivedDataManager

java.lang.Object
com._1c.g5.v8.internal.derived.DerivedDataManager
All Implemented Interfaces:
IContextActivationCallback, IDerivedDataManager, IScopeTrackerController, IComputationTaskManager, IDerivedDataTaskSupplier
public final class DerivedDataManager extends Object implements IDerivedDataManager, IComputationTaskManager, IDerivedDataTaskSupplier, IScopeTrackerController, IContextActivationCallback
Standard implementation of IDerivedDataManager interface and IComputationTaskManager mix-in.

  • Constructor Details

  • Method Details

    • addObjectStatusListener

      public void addObjectStatusListener(IDerivedDataObjectStatusListener listener, long bmObjectId, String... segments)
      Description copied from interface: IDerivedDataManager
      Adds listener for DD status changes of the given object and set of tracked DD segments.
      Specified by:
      addObjectStatusListener in interface IDerivedDataManager
      Parameters:
      listener - The listener instance. Cannot be null. One can re-use the same instance of the listener to subscribe for different sets of objects and segments, but in this case the call to the IDerivedDataManager.removeObjectStatusListener(com._1c.g5.v8.derived.IDerivedDataObjectStatusListener) will remove all subscriptions.
      bmObjectId - The identifier of the object which DD changes are being notified via the supplied listener. Cannot be null or empty due to performance reasons. To track down computation of the entire DD segment use IDerivedDataManager#addStatusListener(IDerivedDataStatusListener) instead}.
      segments - DD segment filter allows to subscribe for specific segments of DD. Cannot be null

    • addObjectStatusListener

      public void addObjectStatusListener(IDerivedDataObjectStatusListener listener, Map<Long,Collection<String>> scope)
      Description copied from interface: IDerivedDataManager
      Adds listener for DD status changes of the given DD change scope. The scope is defined as a map of BM object identifiers to the respective traked DD segments.
      Specified by:
      addObjectStatusListener in interface IDerivedDataManager
      Parameters:
      listener - The listener instance. Cannot be null. One can re-use the same instance of the listener to subscribe for different sets of objects and segments, but in this case the call to the IDerivedDataManager.removeObjectStatusListener(com._1c.g5.v8.derived.IDerivedDataObjectStatusListener) will remove all subscriptions.
      scope - Tracked DD segments mapped to corresponding BM object ids. Cannot be null. Scope entries cannot contain null or empty sets of tracked DD segments.

    • addStatusListener

      public void addStatusListener(IDerivedDataStatusListener listener)
      Description copied from interface: IDerivedDataManager
      Adds listener that will be notified about derived data status changes.
      Specified by:
      addStatusListener in interface IDerivedDataManager
      Parameters:
      listener - the listener that should be notified

    • blockAsyncPipeline

      public void blockAsyncPipeline(boolean forcedStop)
      Description copied from interface: IDerivedDataManager
      Blocks the async. processing pipeline. This methods waits until all current DD operations are finished before return from the call.
      Specified by:
      blockAsyncPipeline in interface IDerivedDataManager
      Parameters:
      forcedStop - Locks pipeline in forced mode. In case if true, could be unlocked only with corresponding value of the flag. Forced lock is being used to prevent file sycnhronization opearions/etc to remove manually defined locks.

    • blockAsyncPipeline

      public void blockAsyncPipeline(boolean forcedStop, boolean wait)
      Description copied from interface: IDerivedDataManager
      Blocks the async. processing pipeline
      Specified by:
      blockAsyncPipeline in interface IDerivedDataManager
      Parameters:
      forcedStop - Locks pipeline in forced mode. In case if true, could be unlocked only with corresponding value of the flag. Forced lock is being used to prevent file sycnhronization opearions/etc to remove manually defined locks.
      wait - Wait until all running operations in the current pipeline are completed

    • prepareForClose

      public void prepareForClose()
      Description copied from interface: IDerivedDataManager
      Prepares the async. computation facility for closing. Blocks all unnecessary data computations and scheduled operations and waits until all required computations are done
      Specified by:
      prepareForClose in interface IDerivedDataManager

    • disableImplicitWaiting

      public void disableImplicitWaiting()
      Description copied from interface: IDerivedDataManager
      Disables implicit waiting of the DD independenly of the current system status. Used during the explicitely managed operations, like merging, etc.
      Specified by:
      disableImplicitWaiting in interface IDerivedDataManager

    • enableImplicitWaiting

      public void enableImplicitWaiting()
      Description copied from interface: IDerivedDataManager
      Enables implicit waiting of the DD independenly of the current system status. Used during the explicitely managed operations, like merging, etc.
      Specified by:
      enableImplicitWaiting in interface IDerivedDataManager

    • getAsyncPipelineStatus

      public PipelineStatus getAsyncPipelineStatus()
      Gets the current pipeline status of the async. pipeline.
      Specified by:
      getAsyncPipelineStatus in interface IComputationTaskManager
      Returns:
      The status of the pipeline.

    • getAvailableTaskStatus

      public IDerivedDataTaskSupplier.TaskStatus getAvailableTaskStatus()
      Description copied from interface: IDerivedDataTaskSupplier
      Gets the information on the next available task (if any).
      Specified by:
      getAvailableTaskStatus in interface IDerivedDataTaskSupplier
      Returns:
      The task status for a next available task. Never null

    • getDerivedDataStatus

      public DerivedDataStatus getDerivedDataStatus()
      Description copied from interface: IDerivedDataManager
      Gets the current status of DD for the corresponding BM model.
      Specified by:
      getDerivedDataStatus in interface IDerivedDataManager
      Returns:
      The overall status of the DD facility.

    • isIdle

      public boolean isIdle()
      Description copied from interface: IDerivedDataManager
      Checks if the computation pipeline is idle
      Specified by:
      isIdle in interface IDerivedDataManager
      Returns:
      True if no computations are done/possible at the moment

    • getActiveNonPriorityTasksResetRequiredStage

      public DerivedDataSegmentBucket getActiveNonPriorityTasksResetRequiredStage()
      Description copied from interface: IDerivedDataTaskSupplier
      Checks if a supplier requests a reset of currently computed non-priority tasks (e.g. due to more prioritable operation is appeared)
      Specified by:
      getActiveNonPriorityTasksResetRequiredStage in interface IDerivedDataTaskSupplier
      Returns:
      Stage to reset non-priority tasks (if any). null if not reset is required

    • getMultithreadingPolicy

      public IDerivedDataTaskSupplier.MultithreadingPolicy getMultithreadingPolicy()
      Description copied from interface: IDerivedDataTaskSupplier
      Gets the current desired multithreading policy for current set of tasks of this supplier.
      Specified by:
      getMultithreadingPolicy in interface IDerivedDataTaskSupplier
      Returns:
      Gets the current policy. Cannot be null

    • getNextTask

      public DerivedDataComputationTask getNextTask()
      Description copied from interface: IDerivedDataTaskSupplier
      Gets the next task for the processing. It's not required(yet recommended) for implementations to ensure the integrity of the task info request and task request. So it's possible for the task to disappear or change the priority during the call of the IDerivedDataTaskSupplier.getAvailableTaskStatus() and subsequent call of this method
      Specified by:
      getNextTask in interface IDerivedDataTaskSupplier
      Returns:
      The next task if available. Can be null in case if the state was changed since the last call of the IDerivedDataTaskSupplier.getAvailableTaskStatus()

    • getSegmentName

      public String getSegmentName(String segmentId)
      Description copied from interface: IComputationTaskManager
      Gets the human-readable segment name for the given pipeline segment.
      Specified by:
      getSegmentName in interface IComputationTaskManager
      Parameters:
      segmentId - The identifier of the target segment.
      Returns:
      The the name of the segment.

    • getSupplierId

      public String getSupplierId()
      Description copied from interface: IDerivedDataTaskSupplier
      Gets the supplier id for easier discrimination by the scheduling facility. The identifier should be unique in the current session of the EDT
      Specified by:
      getSupplierId in interface IDerivedDataTaskSupplier
      Returns:
      The supplier identifier. Cannot be null

    • getTaskProcessor

      public ITaskProcessor getTaskProcessor(DerivedDataComputationTask computationTask)
      Description copied from interface: IDerivedDataTaskSupplier
      Gets the processing logic for the given task. It's up to this logic to perform any processing/notifications during the DD computation process
      Specified by:
      getTaskProcessor in interface IDerivedDataTaskSupplier
      Parameters:
      computationTask - The computation task, cannot be null
      Returns:
      The ITaskProcessor which is able to perform the DD computation for this task. Cannot be null

    • isAllComputed

      public boolean isAllComputed()
      Description copied from interface: IDerivedDataManager
      Checks if all derived data parts are computed.
      Specified by:
      isAllComputed in interface IDerivedDataManager
      Returns:
      true if computed, false otherwise

    • isComputed

      public boolean isComputed(Collection<String> segmentIds)
      Description copied from interface: IDerivedDataManager
      Checks if the given parts are computed (if applicable) for all the BM objects.
      Specified by:
      isComputed in interface IDerivedDataManager
      Returns:
      true if computed, false otherwise

    • isComputed

      public boolean isComputed(long bmObjectId, Collection<String> segmentIds)
      Checks if the given parts are computed for the given BM object.
      Specified by:
      isComputed in interface IDerivedDataManager
      Parameters:
      bmObjectId - the ID of the BM object to check
      Returns:
      true if computed, false otherwise

    • isComputed

      public boolean isComputed(long bmObjectId, String segmentId)
      Description copied from interface: IDerivedDataManager
      Checks if the given part is computed for the given BM object.
      Specified by:
      isComputed in interface IDerivedDataManager
      Parameters:
      bmObjectId - the ID of the BM object to check
      segmentId - the ID of the part to check
      Returns:
      true if computed, false otherwise

    • isComputed

      public boolean isComputed(long bmObjectId, String partId, boolean strict)
      Description copied from interface: IDerivedDataManager
      Checks if the given part is computed for the given BM object.
      Specified by:
      isComputed in interface IDerivedDataManager
      Parameters:
      bmObjectId - the ID of the BM object to check
      partId - the ID of the part to check
      strict - In strict mode caller expecting, that part must be calculated. In case if part is still not indicated, the method will return false
      Returns:
      true if computed, false otherwise

    • isComputed

      public boolean isComputed(String... segmentIds)
      Description copied from interface: IDerivedDataManager
      Checks if the given DD segments are computed (if applicable) for all the BM objects.
      Specified by:
      isComputed in interface IDerivedDataManager
      Parameters:
      segmentIds - Array of the DD segment Ids to check
      Returns:
      true if computed, false otherwise

    • isLongRunningSegment

      public boolean isLongRunningSegment(String segmentId)
      Description copied from interface: IComputationTaskManager
      Checks if the given async. DD segment is a long-running one.
      Specified by:
      isLongRunningSegment in interface IComputationTaskManager
      Parameters:
      segmentId - The target segment identifier.
      Returns:
      True if the segment is long-running one; false otherwise.

    • notifyContextsAreScheduled

      public void notifyContextsAreScheduled(boolean notifyListeners)
      Description copied from interface: IComputationTaskManager
      Notifies the task manager about finishing of the computation or new DD part scheduling.
      Specified by:
      notifyContextsAreScheduled in interface IComputationTaskManager
      Parameters:
      notifyListeners - Notify task listeners.

    • processUnfinishedCommits

      public void processUnfinishedCommits(List<IBmUnfinishedCommitInfo> commitInfo)
      Processes unfinished commits in case of EDT failure restoration.
      Parameters:
      commitInfo - The list of commit data records that need to be processed. Cannot be null

    • applyForcedUpdates

      public void applyForcedUpdates()
      Description copied from interface: IDerivedDataManager
      Applies all forced updates provided by IDerivedDataConfigurationContributor's
      Specified by:
      applyForcedUpdates in interface IDerivedDataManager

    • recomputeAll

      public void recomputeAll()
      Description copied from interface: IDerivedDataManager
      Forces the DD mechanism to recompute all the known parts of all the known objects.
      Specified by:
      recomputeAll in interface IDerivedDataManager

    • registerNotificationCallback

      public void registerNotificationCallback(ISchedulerNotificationCallback notificationCallback)
      Description copied from interface: IDerivedDataTaskSupplier
      DerivedDataTaskScheduler registers a notification callback on start by calling this method. The provided callback should be used to notify scheduler about the availability of a new task. This API is used to increase the operativeness of the DD computations during the normal interractions with the EDT. Provided callback is fully controlled by the dispatcher, the clinet shouldn't pay any specific attention to its lifecycle
      Specified by:
      registerNotificationCallback in interface IDerivedDataTaskSupplier
      Parameters:
      notificationCallback - The callback from the DerivedDataTaskScheduler, cannot be null

    • removeObjectStatusListener

      public void removeObjectStatusListener(IDerivedDataObjectStatusListener listener)
      Description copied from interface: IDerivedDataManager
      Removes specific DD object status listener instance from the notification chain. All subscriptions of the given listener instance will be removed as a result.
      Specified by:
      removeObjectStatusListener in interface IDerivedDataManager
      Parameters:
      listener - The listener that should be removed. Cannot be null.

    • removeStatusListener

      public void removeStatusListener(IDerivedDataStatusListener listener)
      Description copied from interface: IDerivedDataManager
      Removes listener that will be notified about derived data status changes.
      Specified by:
      removeStatusListener in interface IDerivedDataManager
      Parameters:
      listener - the listener that should be removed.

    • renderStatusText

      public String renderStatusText(String segmentId)
      Renders human-readable status of the given async. DD pipeline segment.
      Specified by:
      renderStatusText in interface IComputationTaskManager
      Parameters:
      segmentId - The identifier of the taget segment.
      Returns:
      The rendered status of the pipeline segment.

    • start

      public void start(IBmModel bmModel, BiConsumer<BmEvent,Boolean> bmEventConsumer)
      Starts task preparation process.
      Parameters:
      bmModel -
      bmRawEventHandler -

    • stop

      public void stop()
      Stops task preparation process.

    • unblockAsyncPipeline

      public void unblockAsyncPipeline(boolean forcedStop)
      Description copied from interface: IDerivedDataManager
      Force unblocking of the async. pipeline. Could stay blocked after the call of this method if async. DD computation prerequisites are not met yet.
      Specified by:
      unblockAsyncPipeline in interface IDerivedDataManager
      Parameters:
      forcedStop - Unblocks the forced block in case if true. Unblocks usual lock instead.

    • updateDerviedData

      public boolean updateDerviedData(IDerivedDataUpdate update, long waitTimeout)
      Description copied from interface: IDerivedDataManager
      Updates derivided data using the provided IDerivedDataUpdate update
      Specified by:
      updateDerviedData in interface IDerivedDataManager
      Parameters:
      update - The update to perform
      waitTimeout - Waiting time (in milliseconds) for the updated DD to be re-computed; 0 means no wait
      Returns:
      True if the requested DD were computed until the end of the waiting period; false otherwise

    • updateDerivedData

      public boolean updateDerivedData(IDerivedDataUpdate update, long waitTimeout, Object computationCause)
      Description copied from interface: IDerivedDataManager
      Updates derivided data using the provided IDerivedDataUpdate update
      Specified by:
      updateDerivedData in interface IDerivedDataManager
      Parameters:
      update - The update to perform
      waitTimeout - Waiting time (in milliseconds) for the updated DD to be scheduled in the pipeline
      computationCause - The designator of operation or service which caused the update. May be null
      Returns:
      True if the requested DD were computed until the end of the waiting period; false otherwise

    • supplyImplicitOperationContextIfApplicable

      public void supplyImplicitOperationContextIfApplicable(Object computationCause, Runnable asyncEventScheduler) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Computes synchronous derived data pending for the current session (if any). The computation is synchronous.
      Specified by:
      supplyImplicitOperationContextIfApplicable in interface IDerivedDataManager
      Parameters:
      computationCause - The object bound to the computation context and used to track computations. Can be null
      Throws:
      InterruptedException

    • implicitDerivedDataWait

      public void implicitDerivedDataWait(Object computationCause) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits for the derived data computation from the BM task that is wrapped by the implicit/explicit orchestrated operation
      Specified by:
      implicitDerivedDataWait in interface IDerivedDataManager
      Parameters:
      computationCause - The cause of the computation. May not be NullPointerException
      Throws:
      InterruptedException

    • waitAllComputations

      public boolean waitAllComputations(long timeout) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Wait till all computations are finished or waiting time exceeds the specified value.
      Specified by:
      waitAllComputations in interface IDerivedDataManager
      Parameters:
      timeout - the maximum time to wait in milliseconds
      Returns:
      true if all derived data has been computed by the time this method returns, false otherwise
      Throws:
      InterruptedException - if any thread interrupted the current thread before or while the current thread was waiting for the computations.

    • waitComputation

      public boolean waitComputation(long timeout, boolean priority, String... scope) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits completion of the given scope
      Specified by:
      waitComputation in interface IDerivedDataManager
      Parameters:
      timeout - The wait timeout
      priority - The data that is being waited are priority computations
      scope - The scope (parts) to wait
      Returns:
      True if the wait was successful; false if it was timed out
      Throws:
      InterruptedException

    • waitComputation

      public void waitComputation(Map<Long,Collection<String>> scope) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits till the given scope of computations is finished.
      Specified by:
      waitComputation in interface IDerivedDataManager
      Parameters:
      scope - the scope of computations to wait for. The scope is a map, where the keys are BM objects whose derived data parts must be computed and the values are collections of the part IDs
      Throws:
      InterruptedException - if any thread interrupted the current thread before or while the current thread was waiting for the computation

    • waitComputation

      public boolean waitComputation(Map<Long,Collection<String>> scope, long timeout) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits till the given scope of computations is finished or waiting time exceeds the specified value.
      Specified by:
      waitComputation in interface IDerivedDataManager
      Parameters:
      scope - the scope of computations to wait for. The scope is a map, where the keys are BM objects whose derived data parts must be computed and the values are collections of the part IDs
      timeout - the maximum time to wait in milliseconds
      Returns:
      true if the given scope has been computed by the time this method returns, false otherwise
      Throws:
      InterruptedException - if any thread interrupted the current thread before or while the current thread was waiting for the computation.

    • waitOperationComputation

      public boolean waitOperationComputation(Object handle, long timeout) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits the given operation computation
      Specified by:
      waitOperationComputation in interface IDerivedDataManager
      Parameters:
      handle - The operation computation handle. May not be NullPointerException
      timeout - the maximum time to wait in milliseconds
      Returns:
      true if the given scope has been computed by the time this method returns, false otherwise
      Throws:
      InterruptedException - if any thread interrupted the current thread before or while the current thread was waiting for the computation.

    • waitComputationExt

      public boolean waitComputationExt(Map<Object,Collection<String>> scope, long timeout) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits till the given scope of computations is finished or waiting time exceeds the specified value.
      Specified by:
      waitComputationExt in interface IDerivedDataManager
      Parameters:
      scope - the scope of computations to wait for. The scope is a map, where the keys are BM objects whose derived data parts must be computed and the values are collections of the part IDs
      timeout - the maximum time to wait in milliseconds
      Returns:
      true if the given scope has been computed by the time this method returns, false otherwise
      Throws:
      InterruptedException - if any thread interrupted the current thread before or while the current thread was waiting for the computation.

    • waitImportantDataComputations

      public boolean waitImportantDataComputations(long timeout) throws InterruptedException
      Description copied from interface: IDerivedDataManager
      Waits all important DD's to be computed. The rule to select important DD's is the following:
      Specified by:
      waitImportantDataComputations in interface IDerivedDataManager
      Parameters:
      timeout - the maximum time to wait in milliseconds
      Returns:
      true if all derived data has been computed by the time this method returns, false otherwise
      Throws:
      InterruptedException - if any thread interrupted the current thread before or while the current thread was waiting for the computations.

    • processAccumulatedContexts

      public void processAccumulatedContexts()
      Description copied from interface: IDerivedDataTaskSupplier
      Processes accumulated DD contexts and update the DD pipeline. This method is not thread safe, the caller should guarantee the calls synchronization to ensure the propert order of accumulated context application
      Specified by:
      processAccumulatedContexts in interface IDerivedDataTaskSupplier

    • checkStatusChange

      public boolean checkStatusChange()
      Description copied from interface: IDerivedDataTaskSupplier
      Checks if the supplier has a status change since the last call of this method. The call should reset the change status of the supplier.\n The status change is used to re-check blocked suppliers, as they could be unblocked as a result of this status change
      Specified by:
      checkStatusChange in interface IDerivedDataTaskSupplier
      Returns:
      True if there is a status change since the last call of this method

    • tryToUnblock

      public void tryToUnblock()
      Description copied from interface: IDerivedDataTaskSupplier
      Tries to unblock the supplier, if blocked
      Specified by:
      tryToUnblock in interface IDerivedDataTaskSupplier

    • startMassiveComputing

      public void startMassiveComputing()
      Description copied from interface: IDerivedDataManager
      Enables the massive computing mode for the DD pipeline. The mode is being desingaged after computing of all registered important tasks
      Specified by:
      startMassiveComputing in interface IDerivedDataManager

    • scheduleOperation

      public Object scheduleOperation(Consumer<org.eclipse.core.runtime.IProgressMonitor> operation, OperationType operationType, boolean important, DerivedDataSegmentBucket stage)
      Description copied from interface: IDerivedDataManager
      Schedules the orchestrated operation.
      Specified by:
      scheduleOperation in interface IDerivedDataManager
      Parameters:
      operation - The operation logic to schedule. May not be null
      operationType - The type of the operation. May not be null
      important - The designator of an important operation. The system waits for important operations computation during closing of projects, etc
      stage - The target stage for the scheduling. May not be null
      Returns:
      The operation handle for external operation referencing, may not be null

    • scheduleModalOperation

      public Object scheduleModalOperation(Consumer<org.eclipse.core.runtime.IProgressMonitor> operation, DerivedDataSegmentBucket stage, IModalOperationController modalOperationController)
      Description copied from interface: IDerivedDataManager
      Schedules the orchestrated modal operation. See OperationType.MODAL for details
      Specified by:
      scheduleModalOperation in interface IDerivedDataManager
      Parameters:
      operation - The operation logic to schedule. May not be null
      stage - The target stage for the scheduling. May not be null
      modalOperationController - The modal operation controller. May not be null
      Returns:
      The operation handle for external operation referencing, may not be null

    • setStageLock

      public StageLockRequestResult setStageLock(DerivedDataSegmentBucket stage, boolean allowDataComputing)
      Description copied from interface: IDerivedDataManager
      Locks the async. pipeline stage (to support manual operations with external pipeline state control). Locked bucket tasks are being computed yet the pipeline can't switch to the next stage. The pre-set lock is being activated only after switching of the pipeline to the target stage. Before the activation the lock doesn't affect the computation.
      Specified by:
      setStageLock in interface IDerivedDataManager
      Parameters:
      stage - The stage to lock. May not be null
      Returns:
      The status of a target stage at the moment of a lock call. May not be null

    • resetStageLock

      public void resetStageLock(DerivedDataSegmentBucket stage)
      Description copied from interface: IDerivedDataManager
      Resets the lock being set earlier
      Specified by:
      resetStageLock in interface IDerivedDataManager
      Parameters:
      stage - The stage to re-set the bucket. May not be null. If block isn't set - does nothing.

    • removeOperation

      public void removeOperation(Object handle)
      Description copied from interface: IDerivedDataManager
      Removes the previously scheduled operation. Does nothing if the operation is already removed/computed
      Specified by:
      removeOperation in interface IDerivedDataManager
      Parameters:
      handle - The operation handle taken from the IDerivedDataManager#scheduleOperation(Consumer, OperationType, DerivedDataSegmentBucket) call. May not be null.

    • markAsModalOperationParticipant

      public void markAsModalOperationParticipant()
      Description copied from interface: IDerivedDataManager
      Marks a current thread as a current modal operation participant. The mark is removed automatically on the completion of the corresponding modal operation
      Specified by:
      markAsModalOperationParticipant in interface IDerivedDataManager

    • startWrappingOperationIfNesessary

      public void startWrappingOperationIfNesessary(Object bmOperationHandle)
      Description copied from interface: IDerivedDataManager
      Starts implicit wrapping operation for the specified IBmTask in this thread in case if no operation is manually started already
      Specified by:
      startWrappingOperationIfNesessary in interface IDerivedDataManager
      Parameters:
      bmOperationHandle - The BM operation handle to wrap with the orchestrated operation. May not be null

    • completeWrappingOperationIfApplicable

      public void completeWrappingOperationIfApplicable(Object bmOperationHandle)
      Description copied from interface: IDerivedDataManager
      Complete implicit wrapping operation if the implicit wrapping operation were started earlier in this thread
      Specified by:
      completeWrappingOperationIfApplicable in interface IDerivedDataManager
      Parameters:
      bmOperationHandle - The BM operation handle to wrap with the orchestrated operation. May not be null

    • resetActiveWrappingOperationContext

      public void resetActiveWrappingOperationContext(OperationContext operationContext)
      Description copied from interface: IDerivedDataManager
      Resets the active wrapping operation context associated with the current thread.
      Specified by:
      resetActiveWrappingOperationContext in interface IDerivedDataManager
      Parameters:
      operationContext - The context to reset. May not be null

    • getEventConsumer

      public BiConsumer<BmEvent,Boolean> getEventConsumer()
      Description copied from interface: IDerivedDataManager
      Gets the sync event consumer for the integration with the event processing flow of IBmModel. Also it's possible to supply BM events directly to the consumer in complex scenarios of managed data updates
      Specified by:
      getEventConsumer in interface IDerivedDataManager
      Returns:
      The DD BmEvent consumer. May not be null

    • disableAutoWrapping

      public void disableAutoWrapping()
      Description copied from interface: IDerivedDataManager
      Disables auto-wrapping of BM tasks with orchestrator operations for the current thread. Used for async data computations being controlled directly by the async pipeline. The disablement stays on during the whole thread lifecycle
      Specified by:
      disableAutoWrapping in interface IDerivedDataManager

    • enableAutoWrapping

      public void enableAutoWrapping()
      Description copied from interface: IDerivedDataManager
      Enables an auto-wrapping of BM tasks with orchestrator operations for the current thread. Used to restore an auto-wrapping being disabled previously
      Specified by:
      enableAutoWrapping in interface IDerivedDataManager

    • isScopeTrackingActive

      public boolean isScopeTrackingActive()
      Description copied from interface: IScopeTrackerController
      Checks if the scope tracking is active
      Specified by:
      isScopeTrackingActive in interface IScopeTrackerController
      Returns:
      True if the scope tracking is active

    • deactivateContexts

      public void deactivateContexts(String segmentId)
      Description copied from interface: IContextActivationCallback
      Deactivates collected async computing contexts for a specified segment
      Specified by:
      deactivateContexts in interface IContextActivationCallback
      Parameters:
      segmentId - The async computing pipeline segment. Cannot be null

    • activateContexts

      public void activateContexts(String segmentId)
      Description copied from interface: IContextActivationCallback
      Reactivates collected async computing contexts for a specified segment. Do nothing if contexts were not deactivated earlier
      Specified by:
      activateContexts in interface IContextActivationCallback
      Parameters:
      segmentId - The async computing pipeline segment. Cannot be null

    • dumpPipeline

      public void dumpPipeline()
      Description copied from interface: IDerivedDataManager
      Dumps current pipeline state
      Specified by:
      dumpPipeline in interface IDerivedDataManager