- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 250 for dispatch (0.04 sec)
-
guava/src/com/google/common/reflect/AbstractInvocationHandler.java
* <li>and {@link AbstractInvocationHandler#equals} returns true for the {@link * InvocationHandler} of {@code argument} * </ul> * <li>other method calls are dispatched to {@link #handleInvocation}. * </ul> */ @Override public final @Nullable Object invoke( Object proxy, Method method, @Nullable Object @Nullable [] args) throws Throwable { if (args == null) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 5.1K bytes - Viewed (0) -
cmd/bucket-handlers_test.go
<LocationConstraint xmlns="http://s3.amazonaws.com/doc/2006-03-01/"></LocationConstraint>`), errorResponse: APIErrorResponse{}, shouldPass: true, }, // Test case - 2. // Tests for signature mismatch error. { bucketName: bucketName, accessKey: "abcd", secretKey: "abcd", expectedRespStatus: http.StatusForbidden, locationResponse: []byte(""),Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 39.8K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
assertLockHeld() val routeUrl = route.address.url if (url.port != routeUrl.port) { return false // Port mismatch. } if (url.host == routeUrl.host) { return true // Host match. The URL is supported. } // We have a host mismatch. But if the certificate matches, we're still good. return !noCoalescedConnections && handshake != null && certificateSupportHost(url, handshake)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 14.6K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/ThreadInterruptTest.kt
call: Call, response: Response, ) { } }, ) // This should fail the Call, but not cause an unhandled Exception bubbling up client.dispatcher.executorService.shutdownNow() val exception = callFailure.get(5, TimeUnit.SECONDS) assertThat(exception.message) .isNotNull() .startsWith("canceled due to")Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Nov 04 18:33:48 UTC 2025 - 6.4K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/publicsuffix/PublicSuffixListGenerator.kt
val publicSuffixListGenerator = PublicSuffixListGenerator() try { publicSuffixListGenerator.import() } finally { publicSuffixListGenerator.client.run { connectionPool.evictAll() dispatcher.executorService.shutdownNow() } }
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Aug 06 05:33:11 UTC 2025 - 6.1K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/SMB1SigningDigestTest.java
when(readResponse.getOffset()).thenReturn(0); boolean result = digest.verify(data, 0, data.length, 0, readResponse); assertTrue(result); // Signature mismatch expected } @Test @DisplayName("Test verify method with invalid signature") void testVerifyWithInvalidSignature() { SMB1SigningDigest digest = new SMB1SigningDigest(testMacSigningKey);
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 18.1K bytes - Viewed (0) -
cmd/ftp-server-driver.go
return err } if prefix == "" { return clnt.MakeBucket(context.Background(), bucket, minio.MakeBucketOptions{Region: globalSite.Region()}) } dirPath := buildMinioDir(prefix) _, err = clnt.PutObject(context.Background(), bucket, dirPath, bytes.NewReader([]byte("")), 0, minio.PutObjectOptions{ DisableContentSha256: true, }) return err } // GetFile implements ftpDriverRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 14.3K bytes - Viewed (0) -
cmd/signature-v4-parser_test.go
func validateCredentialfields(t *testing.T, testNum int, expectedCredentials credentialHeader, actualCredential credentialHeader) { if expectedCredentials.accessKey != actualCredential.accessKey { t.Errorf("Test %d: AccessKey mismatch: Expected \"%s\", got \"%s\"", testNum, expectedCredentials.accessKey, actualCredential.accessKey) } if !expectedCredentials.scope.date.Equal(actualCredential.scope.date) {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 10 18:57:35 UTC 2025 - 27.8K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Init.java
ListPromptBuilder listPromptBuilder = promptBuilder .createListPrompt() .name("defaultDispatcher") .message("Which dispatcher you want to use as default?"); listPromptBuilder .newItem() .name(NONE) .text("None (disable MavenSecDispatcher)") .add();Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jun 11 13:14:09 UTC 2025 - 12K bytes - Viewed (0) -
okcurl/src/main/kotlin/okhttp3/curl/Main.kt
} return builder.build() } fun close() { val okHttpClient = client as OkHttpClient okHttpClient.connectionPool.evictAll() // Close any persistent connections. okHttpClient.dispatcher.executorService.shutdownNow() } companion object { internal const val NAME = "okcurl" internal const val DEFAULT_TIMEOUT = -1 private fun versionString(): String? {Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6K bytes - Viewed (0)