Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 171 - 180 of 263 for dispatch (0.08 seconds)

  1. utils/utils_test.go

    	return got, want
    }
    
    func TestFileWithLineNumWrappedCallRegression(t *testing.T) {
    	got, want := fileWithLineNumWrappedOuterForTest()
    	if got != want {
    		t.Fatalf("FileWithLineNum wrapped caller mismatch, got %s, want %s", got, want)
    	}
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:31:30 GMT 2026
    - 5.5K bytes
    - Click Count (0)
  2. 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) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 10 18:57:35 GMT 2025
    - 27.8K bytes
    - Click Count (0)
  3. 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? {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 6K bytes
    - Click Count (0)
  4. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  5. internal/hash/crc.go

    		if vec&1 != 0 {
    			sum ^= mat[0]
    		}
    		vec >>= 1
    		mat = mat[1:]
    	}
    	return sum
    }
    
    func gf2MatrixSquare(square, mat []uint64) {
    	if len(square) != len(mat) {
    		panic("square matrix size mismatch")
    	}
    	for n := range mat {
    		square[n] = gf2MatrixTimes(mat, mat[n])
    	}
    }
    
    // crc32Combine returns the combined CRC-32 hash value of the two passed CRC-32
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb1/smb1/Trans2FindNext2Test.java

            // filename bytes, then null terminator
            byte[] nameBytes = name.getBytes();
            for (int i = 0; i < nameBytes.length; i++) {
                assertEquals(nameBytes[i], dst[12 + i], "Filename byte mismatch at index " + i);
            }
            assertEquals((byte) 0x00, dst[12 + nameBytes.length], "Filename must be null-terminated");
        }
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 6.9K bytes
    - Click Count (0)
  7. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/scopes/Maven4ScopeManagerConfiguration.java

            // == sanity check
            if (result.size() != org.apache.maven.api.DependencyScope.values().length - 1) { // sans "undefined"
                throw new IllegalStateException("Maven4 API dependency scope mismatch");
            }
    
            return result;
        }
    
        @Override
        public Collection<org.eclipse.aether.scope.ResolutionScope> buildResolutionScopes(
                InternalScopeManager internalScopeManager) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 9.2K bytes
    - Click Count (0)
  8. 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();
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jun 11 13:14:09 GMT 2025
    - 12K bytes
    - Click Count (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/InterceptorTest.kt

        addInterceptor(network) { chain: Interceptor.Chain? -> throw boom }
        val executor = ExceptionCatchingExecutor()
        client =
          client
            .newBuilder()
            .dispatcher(Dispatcher(executor))
            .build()
        val request =
          Request
            .Builder()
            .url(server.url("/"))
            .build()
        val call = client.newCall(request)
        call.enqueue(callback)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 16:11:23 GMT 2025
    - 28.2K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/WinErrorTest.java

            assertNotNull(WinError.WINERR_MESSAGES, "WINERR_MESSAGES should not be null");
            assertEquals(WinError.WINERR_CODES.length, WinError.WINERR_MESSAGES.length, "Codes/messages length mismatch");
    
            // Exact content check to guard against accidental reordering or drift
            assertArrayEquals(
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 8.4K bytes
    - Click Count (0)
Back to Top