- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 523 for kuwait (0.04 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
lock.lock(); try { locked.countDown(); finishLatch.await(1, MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, MINUTES); } void releaseLockAndFinish() throws InterruptedException {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
lock.lock(); try { locked.countDown(); finishLatch.await(1, MINUTES); } catch (InterruptedException e) { fail(e.toString()); } finally { lock.unlock(); } } void waitUntilHoldingLock() throws InterruptedException { locked.await(1, MINUTES); } void releaseLockAndFinish() throws InterruptedException {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 16.2K bytes - Viewed (0) -
tests/prepared_stmt_test.go
if lens == 0 { // If the number is 0, it means there are no statements stored in the LRU cache. // The test fails and an error message is output. t.Fatalf("lru should not be empty") } // Wait for 40 seconds to give the statements in the cache enough time to expire. time.Sleep(time.Second * 40) // Assert whether the connection pool of tx is successfully converted to the *gorm.PreparedStmtDB type.
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 8K bytes - Viewed (0) -
fuzzing/fuzzingserver-test.sh
fi which jq if [ $? != 0 ]; then echo "Run 'brew install jq'" exit 1 fi trap 'kill $(jobs -pr)' SIGINT SIGTERM EXIT set -ex wstest -m fuzzingserver -s fuzzingserver-config.json & sleep 2 # wait for wstest to start java -jar target/okhttp-tests-*-jar-with-dependencies.jar jq '.[] as $in | $in | keys[] | . + " " + $in[.].behavior' target/fuzzingserver-report/index.json > target/fuzzingserver-actual.txt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Mar 26 02:01:32 UTC 2019 - 673 bytes - Viewed (0) -
cmd/format-erasure.go
if formats[index] == nil { return errDiskNotFound } return saveFormatErasure(storageDisks[index], formats[index], "") }, index) } // Wait for the routines to finish. return reduceWriteQuorumErrs(ctx, g.Wait(), nil, len(storageDisks)) } // relinquishes the underlying connection for all storage disks. func closeStorageDisks(storageDisks ...StorageAPI) { var wg sync.WaitGroup
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 23.1K bytes - Viewed (0) -
docs/es/docs/tutorial/background-tasks.md
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 4.9K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
fail("could not start job."); } protected static void waitJob(final String namePrefix) { Boolean isRunning = false; int count = 0; while (count < 300 && !isRunning) { // Wait until the crawler starts ThreadUtil.sleep(500); count++; final Map<String, Object> scheduler = getSchedulerItem(namePrefix); assertTrue(scheduler.containsKey("running"));
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 10K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java
doNothing().when(mockChannelManager).performChannelBinding(any()); IOException error = new IOException("Connection failed"); failover.handleFailure(failedChannel, error); // Wait a bit for recovery attempt Thread.sleep(100); verify(mockChannelManager).createTransport(failedChannel.getLocalInterface(), failedChannel.getRemoteInterface()); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt
} } /** * Like [Object.wait], but throws an [InterruptedIOException] when interrupted instead of the more * awkward [InterruptedException]. */ @Throws(InterruptedIOException::class) internal fun waitForIo() { try { wait() } catch (_: InterruptedException) { Thread.currentThread().interrupt() // Retain interrupted status.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 18:57:05 UTC 2025 - 22.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb2/lease/DirectoryCacheEntryTest.java
public void testExpiration() { // Set a very short max age entry.setMaxAge(100); // 100ms assertFalse(entry.isExpired()); assertFalse(entry.needsRefresh()); // Wait for expiration try { Thread.sleep(150); } catch (InterruptedException e) { // Ignore } assertTrue(entry.isExpired());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 23 01:47:47 UTC 2025 - 8.4K bytes - Viewed (0)