Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 250 for dispatch (0.72 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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 ftpDriver
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.3K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top