test_class.declarator: timeoutExecutor
test_class.modifier: private static
test_class.original_string: private static ScheduledExecutorService timeoutExecutor;
test_class.type: ScheduledExecutorService
test_class.var_name: timeoutExecutor
test_class.declarator: tracker
test_class.modifier: private
test_class.original_string: private LocalPendingTransactionsTracker tracker;
test_class.type: LocalPendingTransactionsTracker
test_class.var_name: tracker
test_class.file: modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/LocalPendingTransactionsTrackerTest.java
test_class.identifier: LocalPendingTransactionsTrackerTest
test_case.body: @Test
      public void testCurrentlyPreparedTxs() {
          txPrepare(1);
          txKeyWrite(1, 10);
          txKeyWrite(1, 11);
  
          txPrepare(2);
          txKeyWrite(2, 20);
          txKeyWrite(2, 21);
          txKeyWrite(2, 22);
  
          txPrepare(3);
          txKeyWrite(3, 30);
  
          txCommit(2);
  
          tracker.writeLockState();
  
          try {
              Set<GridCacheVersion> currentlyPreparedTxs = tracker.currentlyPreparedTxs();
  
              assertEquals(2, currentlyPreparedTxs.size());
              assertTrue(currentlyPreparedTxs.contains(nearXidVersion(1)));
              assertTrue(currentlyPreparedTxs.contains(nearXidVersion(3)));
          }
          finally {
              tracker.writeUnlockState();
          }
  
          txKeyWrite(3, 31);
          txCommit(3);
  
          tracker.writeLockState();
  
          try {
              Set<GridCacheVersion> currentlyPreparedTxs = tracker.currentlyPreparedTxs();
  
              assertEquals(1, currentlyPreparedTxs.size());
              assertTrue(currentlyPreparedTxs.contains(nearXidVersion(1)));
          }
          finally {
              tracker.writeUnlockState();
          }
      }
test_case.class_method_signature: LocalPendingTransactionsTrackerTest.testCurrentlyPreparedTxs()
test_case.full_signature: @Test public void testCurrentlyPreparedTxs()
test_case.identifier: testCurrentlyPreparedTxs
test_case.invocations: txPrepare txKeyWrite txKeyWrite txPrepare txKeyWrite txKeyWrite txKeyWrite txPrepare txKeyWrite txCommit writeLockState currentlyPreparedTxs assertEquals size assertTrue contains nearXidVersion assertTrue contains nearXidVersion writeUnlockState txKeyWrite txCommit writeLockState currentlyPreparedTxs assertEquals size assertTrue contains nearXidVersion writeUnlockState
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCurrentlyPreparedTxs()
focal_class.declarator: cctx
focal_class.modifier: private final
focal_class.original_string: private final GridCacheSharedContext<?, ?> cctx;
focal_class.type: GridCacheSharedContext<?, ?>
focal_class.var_name: cctx
focal_class.declarator: log
focal_class.modifier: private final
focal_class.original_string: private final IgniteLogger log;
focal_class.type: IgniteLogger
focal_class.var_name: log
focal_class.declarator: currentlyCommittingTxs = U.newConcurrentHashSet()
focal_class.modifier: private final
focal_class.original_string: private final Set<GridCacheVersion> currentlyCommittingTxs = U.newConcurrentHashSet();
focal_class.type: Set<GridCacheVersion>
focal_class.var_name: currentlyCommittingTxs
focal_class.declarator: enabled = IgniteSystemProperties.getBoolean(IGNITE_PENDING_TX_TRACKER_ENABLED, false)
focal_class.modifier: private volatile
focal_class.original_string: private volatile boolean enabled = IgniteSystemProperties.getBoolean(IGNITE_PENDING_TX_TRACKER_ENABLED, false);
focal_class.type: boolean
focal_class.var_name: enabled
focal_class.declarator: preparedCommittedTxsCounters = new ConcurrentHashMap<>()
focal_class.modifier: private final
focal_class.original_string: private final ConcurrentHashMap<GridCacheVersion, Integer> preparedCommittedTxsCounters = new ConcurrentHashMap<>();
focal_class.type: ConcurrentHashMap<GridCacheVersion, Integer>
focal_class.var_name: preparedCommittedTxsCounters
focal_class.declarator: trackedPreparedTxs = new GridConcurrentHashSet<>()
focal_class.modifier: private volatile
focal_class.original_string: private volatile GridConcurrentHashSet<GridCacheVersion> trackedPreparedTxs = new GridConcurrentHashSet<>();
focal_class.type: GridConcurrentHashSet<GridCacheVersion>
focal_class.var_name: trackedPreparedTxs
focal_class.declarator: trackedCommittedTxs = new GridConcurrentHashSet<>()
focal_class.modifier: private volatile
focal_class.original_string: private volatile GridConcurrentHashSet<GridCacheVersion> trackedCommittedTxs = new GridConcurrentHashSet<>();
focal_class.type: GridConcurrentHashSet<GridCacheVersion>
focal_class.var_name: trackedCommittedTxs
focal_class.declarator: writtenKeysToNearXidVer = new ConcurrentHashMap<>()
focal_class.modifier: private volatile
focal_class.original_string: private volatile ConcurrentHashMap<KeyCacheObject, Set<GridCacheVersion>> writtenKeysToNearXidVer = new ConcurrentHashMap<>();
focal_class.type: ConcurrentHashMap<KeyCacheObject, Set<GridCacheVersion>>
focal_class.var_name: writtenKeysToNearXidVer
focal_class.declarator: dependentTransactionsGraph = new ConcurrentHashMap<>()
focal_class.modifier: private volatile
focal_class.original_string: private volatile ConcurrentHashMap<GridCacheVersion, Set<GridCacheVersion>> dependentTransactionsGraph = new ConcurrentHashMap<>();
focal_class.type: ConcurrentHashMap<GridCacheVersion, Set<GridCacheVersion>>
focal_class.var_name: dependentTransactionsGraph
focal_class.declarator: stateLock = new ReentrantReadWriteLock()
focal_class.modifier: private final
focal_class.original_string: private final ReentrantReadWriteLock stateLock = new ReentrantReadWriteLock();
focal_class.type: ReentrantReadWriteLock
focal_class.var_name: stateLock
focal_class.declarator: trackPrepared = new AtomicBoolean(false)
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean trackPrepared = new AtomicBoolean(false);
focal_class.type: AtomicBoolean
focal_class.var_name: trackPrepared
focal_class.declarator: trackCommitted = new AtomicBoolean(false)
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean trackCommitted = new AtomicBoolean(false);
focal_class.type: AtomicBoolean
focal_class.var_name: trackCommitted
focal_class.declarator: txFinishAwaiting
focal_class.modifier: private volatile
focal_class.original_string: private volatile TxFinishAwaiting txFinishAwaiting;
focal_class.type: TxFinishAwaiting
focal_class.var_name: txFinishAwaiting
focal_class.file: modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/LocalPendingTransactionsTracker.java
focal_class.identifier: LocalPendingTransactionsTracker
focal_class.class_method_signature: LocalPendingTransactionsTracker.LocalPendingTransactionsTracker(GridCacheSharedContext<?, ?> cctx)
focal_class.full_signature: public  LocalPendingTransactionsTracker(GridCacheSharedContext<?, ?> cctx)
focal_class.identifier: LocalPendingTransactionsTracker
focal_class.modifiers: public
focal_class.parameters: (GridCacheSharedContext<?, ?> cctx)
focal_class.signature:  LocalPendingTransactionsTracker(GridCacheSharedContext<?, ?> cctx)
focal_class.class_method_signature: LocalPendingTransactionsTracker.enable()
focal_class.full_signature:  void enable()
focal_class.identifier: enable
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void enable()
focal_class.class_method_signature: LocalPendingTransactionsTracker.enabled()
focal_class.full_signature: public boolean enabled()
focal_class.identifier: enabled
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean enabled()
focal_class.class_method_signature: LocalPendingTransactionsTracker.currentlyPreparedTxs()
focal_class.full_signature: public Set<GridCacheVersion> currentlyPreparedTxs()
focal_class.identifier: currentlyPreparedTxs
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<GridCacheVersion>
focal_class.signature: Set<GridCacheVersion> currentlyPreparedTxs()
focal_class.class_method_signature: LocalPendingTransactionsTracker.startTrackingPrepared()
focal_class.full_signature: public void startTrackingPrepared()
focal_class.identifier: startTrackingPrepared
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void startTrackingPrepared()
focal_class.class_method_signature: LocalPendingTransactionsTracker.stopTrackingPrepared()
focal_class.full_signature: public Set<GridCacheVersion> stopTrackingPrepared()
focal_class.identifier: stopTrackingPrepared
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Set<GridCacheVersion>
focal_class.signature: Set<GridCacheVersion> stopTrackingPrepared()
focal_class.class_method_signature: LocalPendingTransactionsTracker.startTrackingCommitted()
focal_class.full_signature: public void startTrackingCommitted()
focal_class.identifier: startTrackingCommitted
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void startTrackingCommitted()
focal_class.class_method_signature: LocalPendingTransactionsTracker.stopTrackingCommitted()
focal_class.full_signature: public TrackCommittedResult stopTrackingCommitted()
focal_class.identifier: stopTrackingCommitted
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: TrackCommittedResult
focal_class.signature: TrackCommittedResult stopTrackingCommitted()
focal_class.class_method_signature: LocalPendingTransactionsTracker.startTxFinishAwaiting(
          long preparedTxsTimeout, long committingTxsTimeout)
focal_class.full_signature: public Set<GridCacheVersion> startTxFinishAwaiting(
          long preparedTxsTimeout, long committingTxsTimeout)
focal_class.identifier: startTxFinishAwaiting
focal_class.modifiers: public
focal_class.parameters: (
          long preparedTxsTimeout, long committingTxsTimeout)
focal_class.return: Set<GridCacheVersion>
focal_class.signature: Set<GridCacheVersion> startTxFinishAwaiting(
          long preparedTxsTimeout, long committingTxsTimeout)
focal_class.class_method_signature: LocalPendingTransactionsTracker.awaitPendingTxsFinished(
          Set<GridCacheVersion> globalCommittingTxs
      )
focal_class.full_signature: public IgniteInternalFuture<Set<GridCacheVersion>> awaitPendingTxsFinished(
          Set<GridCacheVersion> globalCommittingTxs
      )
focal_class.identifier: awaitPendingTxsFinished
focal_class.modifiers: public
focal_class.parameters: (
          Set<GridCacheVersion> globalCommittingTxs
      )
focal_class.return: IgniteInternalFuture<Set<GridCacheVersion>>
focal_class.signature: IgniteInternalFuture<Set<GridCacheVersion>> awaitPendingTxsFinished(
          Set<GridCacheVersion> globalCommittingTxs
      )
focal_class.class_method_signature: LocalPendingTransactionsTracker.writeLockState()
focal_class.full_signature: public void writeLockState()
focal_class.identifier: writeLockState
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void writeLockState()
focal_class.class_method_signature: LocalPendingTransactionsTracker.writeUnlockState()
focal_class.full_signature: public void writeUnlockState()
focal_class.identifier: writeUnlockState
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void writeUnlockState()
focal_class.class_method_signature: LocalPendingTransactionsTracker.onTxPrepared(GridCacheVersion nearXidVer)
focal_class.full_signature: public void onTxPrepared(GridCacheVersion nearXidVer)
focal_class.identifier: onTxPrepared
focal_class.modifiers: public
focal_class.parameters: (GridCacheVersion nearXidVer)
focal_class.return: void
focal_class.signature: void onTxPrepared(GridCacheVersion nearXidVer)
focal_class.class_method_signature: LocalPendingTransactionsTracker.onTxCommitted(GridCacheVersion nearXidVer)
focal_class.full_signature: public void onTxCommitted(GridCacheVersion nearXidVer)
focal_class.identifier: onTxCommitted
focal_class.modifiers: public
focal_class.parameters: (GridCacheVersion nearXidVer)
focal_class.return: void
focal_class.signature: void onTxCommitted(GridCacheVersion nearXidVer)
focal_class.class_method_signature: LocalPendingTransactionsTracker.onTxRolledBack(GridCacheVersion nearXidVer)
focal_class.full_signature: public void onTxRolledBack(GridCacheVersion nearXidVer)
focal_class.identifier: onTxRolledBack
focal_class.modifiers: public
focal_class.parameters: (GridCacheVersion nearXidVer)
focal_class.return: void
focal_class.signature: void onTxRolledBack(GridCacheVersion nearXidVer)
focal_class.class_method_signature: LocalPendingTransactionsTracker.onKeysWritten(GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.full_signature: public void onKeysWritten(GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.identifier: onKeysWritten
focal_class.modifiers: public
focal_class.parameters: (GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.return: void
focal_class.signature: void onKeysWritten(GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.class_method_signature: LocalPendingTransactionsTracker.onKeysRead(GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.full_signature: public void onKeysRead(GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.identifier: onKeysRead
focal_class.modifiers: public
focal_class.parameters: (GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.return: void
focal_class.signature: void onKeysRead(GridCacheVersion nearXidVer, List<KeyCacheObject> keys)
focal_class.class_method_signature: LocalPendingTransactionsTracker.reset()
focal_class.full_signature: public void reset()
focal_class.identifier: reset
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void reset()
focal_class.class_method_signature: LocalPendingTransactionsTracker.checkTxFinishFutureDone(GridCacheVersion nearXidVer)
focal_class.full_signature: private void checkTxFinishFutureDone(GridCacheVersion nearXidVer)
focal_class.identifier: checkTxFinishFutureDone
focal_class.modifiers: private
focal_class.parameters: (GridCacheVersion nearXidVer)
focal_class.return: void
focal_class.signature: void checkTxFinishFutureDone(GridCacheVersion nearXidVer)
focal_method.body: public Set<GridCacheVersion> currentlyPreparedTxs() {
          assert stateLock.writeLock().isHeldByCurrentThread();
  
          return U.sealSet(preparedCommittedTxsCounters.keySet());
      }
focal_method.class_method_signature: LocalPendingTransactionsTracker.currentlyPreparedTxs()
focal_method.full_signature: public Set<GridCacheVersion> currentlyPreparedTxs()
focal_method.identifier: currentlyPreparedTxs
focal_method.invocations: isHeldByCurrentThread writeLock sealSet keySet
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: Set<GridCacheVersion>
focal_method.signature: Set<GridCacheVersion> currentlyPreparedTxs()