| /dports/multimedia/libbluray/libbluray-1.3.0/src/libbluray/bdj/java/org/videolan/backdoor/ |
| H A D | System.java | 28 private static final Object syncBarrier = new Object(); field in System
31 synchronized (syncBarrier) { in currentTimeMillisSynced()
|
| /dports/multimedia/handbrake/libbluray-1.3.0/src/libbluray/bdj/java/org/videolan/backdoor/ |
| H A D | System.java | 28 private static final Object syncBarrier = new Object(); field in System
31 synchronized (syncBarrier) { in currentTimeMillisSynced()
|
| /dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.SqlClient/tests/ManualTests/SQL/ConnectionPoolTest/ |
| H A D | ConnectionPoolTest.cs | 173 Barrier syncBarrier = new Barrier(tasks.Length); in ReplacementConnectionUsesSemaphoreTest()
174 …r> taskFunction = (() => ReplacementConnectionUsesSemaphoreTask(newConnectionString, syncBarrier)); in ReplacementConnectionUsesSemaphoreTest()
221 …nectionWrapper ReplacementConnectionUsesSemaphoreTask(string connectionString, Barrier syncBarrier) in ReplacementConnectionUsesSemaphoreTask() argument
234 syncBarrier.SignalAndWait(); in ReplacementConnectionUsesSemaphoreTask()
238 syncBarrier.SignalAndWait(); in ReplacementConnectionUsesSemaphoreTask()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/job/impl/ |
| H A D | TestJobImpl.java | 167 CyclicBarrier syncBarrier = new CyclicBarrier(2); in testCommitJobFailsJob() local
179 syncBarrier.await(); in testCommitJobFailsJob()
192 CyclicBarrier syncBarrier = new CyclicBarrier(2); in testCheckJobCompleteSuccess() local
204 syncBarrier.await(); in testCheckJobCompleteSuccess()
284 syncBarrier.await(); in testRebootedDuringCommit()
351 syncBarrier.await(); in testKilledDuringCommit()
998 CyclicBarrier syncBarrier; field in TestJobImpl.TestingOutputCommitter
1004 this.syncBarrier = syncBarrier; in TestingOutputCommitter()
1011 syncBarrier.await(); in commitJob()
1025 super(syncBarrier, shouldSucceed); in WaitingOutputCommitter()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/ |
| H A D | TestNodeManagerResync.java | 85 private CyclicBarrier syncBarrier; field in TestNodeManagerResync
99 syncBarrier = new CyclicBarrier(2); in setup()
144 syncBarrier.await(); in testContainerPreservationOnResyncImpl()
180 syncBarrier.await(); in testBlockNewContainerRequestsOnStartAndResync()
302 syncBarrier.await(); in testNMSentContainerStatusOnResync()
320 syncBarrier.await(); in rebootNodeStatusUpdaterAndRegisterWithRM()
410 syncBarrier.await(); in rebootNodeStatusUpdaterAndRegisterWithRM()
492 syncBarrier.await();
|
| H A D | TestNodeStatusUpdater.java | 455 private CyclicBarrier syncBarrier; field in TestNodeStatusUpdater.MyNodeManager2
458 public MyNodeManager2 (CyclicBarrier syncBarrier, Configuration conf) { in MyNodeManager2() argument
459 this.syncBarrier = syncBarrier; in MyNodeManager2()
482 syncBarrier.await(10000, TimeUnit.MILLISECONDS); in serviceStop()
1436 CyclicBarrier syncBarrier = new CyclicBarrier(2);
1437 nm = new MyNodeManager2(syncBarrier, conf);
1447 syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ |
| H A D | TestZKRMStateStoreZKClientConnections.java | 76 CyclicBarrier syncBarrier = new CyclicBarrier(2); field in TestZKRMStateStoreZKClientConnections.TestZKClient
106 syncBarrier.await(); in processWatchEvent()
240 zkClientTester.syncBarrier.await(); in testZKSessionTimeout()
|
| /dports/math/ogdf/OGDF/src/ogdf/energybased/fast_multipole_embedder/ |
| H A D | FMEThread.cpp | 81 m_pThreadPool->syncBarrier()->threadSync(); in sync()
|
| /dports/math/ogdf/OGDF/include/ogdf/energybased/fast_multipole_embedder/ |
| H A D | FMEThread.h | 146 inline Barrier *syncBarrier() const { return m_pSyncBarrier; } in syncBarrier() function
|