Searched defs:syncBarrier (Results 1 – 8 of 8) sorted by relevance
28 private static final Object syncBarrier = new Object(); field in System
167 CyclicBarrier syncBarrier = new CyclicBarrier(2); in testCommitJobFailsJob() local192 CyclicBarrier syncBarrier = new CyclicBarrier(2); in testCheckJobCompleteSuccess() local270 CyclicBarrier syncBarrier = new CyclicBarrier(2); in testRebootedDuringCommit() local340 CyclicBarrier syncBarrier = new CyclicBarrier(2); in testKilledDuringCommit() local998 CyclicBarrier syncBarrier; field in TestJobImpl.TestingOutputCommitter1001 public TestingOutputCommitter(CyclicBarrier syncBarrier, in TestingOutputCommitter()1023 public WaitingOutputCommitter(CyclicBarrier syncBarrier, in WaitingOutputCommitter()
221 …nectionWrapper ReplacementConnectionUsesSemaphoreTask(string connectionString, Barrier syncBarrier) in ReplacementConnectionUsesSemaphoreTask()
146 inline Barrier *syncBarrier() const { return m_pSyncBarrier; } in syncBarrier() function
76 CyclicBarrier syncBarrier = new CyclicBarrier(2); field in TestZKRMStateStoreZKClientConnections.TestZKClient
85 private CyclicBarrier syncBarrier; field in TestNodeManagerResync
455 private CyclicBarrier syncBarrier; field in TestNodeStatusUpdater.MyNodeManager2458 public MyNodeManager2 (CyclicBarrier syncBarrier, Configuration conf) { in MyNodeManager2()