- Sort Score
- Num 10 results
- Language All
Results 171 - 180 of 263 for dispatch (0.08 seconds)
-
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) -
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) -
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) -
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 ftpDriverCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 14.3K bytes - Click Count (0) -
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) -
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) -
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) -
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) -
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) -
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)