- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 501 for Runnable (0.12 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/platform/Jdk9Platform.kt
null } override fun trustManager(sslSocketFactory: SSLSocketFactory): X509TrustManager? { // Not supported due to access checks on JDK 9+: // java.lang.reflect.InaccessibleObjectException: Unable to make member of class // sun.security.ssl.SSLSocketFactoryImpl accessible: module java.base does not export // sun.security.ssl to unnamed module @xxx throw UnsupportedOperationException(Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 3.6K bytes - Click Count (0) -
internal/store/store.go
defer retryTicker.Stop() send := func(key Key) bool { for { err := target.SendFromStore(key) if err == nil { break } logger( context.Background(), fmt.Errorf("unable to send log entry to '%s' err '%w'", target.Name(), err), target.Name(), ) select { // Retrying after 3secs back-off case <-retryTicker.C: case <-doneCh: return false }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 4.2K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10000 scheduled after 100 µs: task", "FINE: Q10000 starting : task", "FINE: Q10000 finished run in 0 µs: task", ) } /** Inspect how many runnables have been enqueued. If none then we're truly sequential. */ @Test fun singleQueueIsSerial() { redQueue.execute("task one", 100.µs) { log += "one:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}" }
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 23K bytes - Click Count (0) -
cmd/lock-rest-server-common_test.go
obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil { t.Fatalf("unable initialize config file, %s", err) } locker := &lockRESTServer{ ll: &localLocker{ mutex: sync.Mutex{}, lockMap: make(map[string][]lockRequesterInfo), }, } creds := globalActiveCred
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Apr 09 14:28:39 GMT 2025 - 3.2K bytes - Click Count (0) -
android-test/src/test/kotlin/okhttp/android/test/DisabledInitialiserTest.kt
PlatformRegistry.applicationContext = null } @Test fun testWithoutContext() { val httpUrl = "https://www.google.co.uk".toHttpUrl() assertFailure { httpUrl.topPrivateDomain() }.all { hasMessage("Unable to load PublicSuffixDatabase.list resource.") cause().isNotNull().all { hasMessage( "Platform applicationContext not initialized. " + "Startup Initializer possibly disabled, " +
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sat Aug 30 16:25:39 GMT 2025 - 2.1K bytes - Click Count (0) -
cmd/erasure-metadata_test.go
{3, 2}, // Replace existing part. {4, 3}, // Missing part. {6, -1}, } // Setup. fi := newFileInfo("test-object", 8, 8) fi.Erasure.Index = 1 if !fi.IsValid() { t.Fatalf("unable to get xl meta") } // Test them. for _, testCase := range testCases { if testCase.expectedIndex > -1 { partNumString := strconv.Itoa(testCase.partNum)Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt
Thread.currentThread().interrupt() // Retain interrupted status. } } if (!::bytes.isInitialized) { // May have failed with an IOException throw IllegalStateException("Unable to load $path resource.").apply { initCause(readFailure) } } } abstract val path: Any /**
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jul 28 07:33:49 GMT 2025 - 3.6K bytes - Click Count (0) -
android/guava/src/com/google/common/io/InsecureRecursiveDeleteException.java
@IgnoreJRERequirement public final class InsecureRecursiveDeleteException extends FileSystemException { public InsecureRecursiveDeleteException(@Nullable String file) { super(file, null, "unable to guarantee security of recursive delete"); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.9K bytes - Click Count (0) -
build-tools-internal/src/main/java/org/elasticsearch/gradle/internal/precommit/FilePermissionsTask.java
|| permissions.contains(PosixFilePermission.OWNER_EXECUTE) || permissions.contains(PosixFilePermission.GROUP_EXECUTE); } catch (IOException e) { throw new IllegalStateException("unable to read the file " + file + " attributes", e); } } /** * Returns the files this task will check */ @InputFiles @SkipWhenEmpty public FileCollection getFiles() {
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 3.9K bytes - Click Count (0) -
cmd/callhome.go
auditOptions := AuditLogOptions{Event: "callhome:diagnostics"} // Received all data. Send to SUBNET and return err := sendHealthInfo(ctx, healthInfo) if err != nil { internalLogIf(ctx, fmt.Errorf("Unable to perform callhome: %w", err)) auditOptions.Error = err.Error() } auditLogInternal(ctx, auditOptions) return } healthInfo = hi case <-healthCtx.Done(): return } }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.3K bytes - Click Count (0)