Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 231 - 240 of 263 for dispatch (0.05 seconds)

  1. tests/generics_test.go

    	u, err := gorm.G[User](DB).Where("name = ?", name).First(ctx)
    	if err != nil {
    		t.Fatalf("failed to find created user: %v", err)
    	}
    	if u.ID == 0 || u.Name != name || u.Age != age {
    		t.Fatalf("created user mismatch, got %+v", u)
    	}
    }
    
    func TestGenericsSetUpdate(t *testing.T) {
    	ctx := context.Background()
    
    	// prepare
    	u := User{Name: "GenericsSetUpdate_Before", Age: 30}
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Tue Dec 30 08:11:14 GMT 2025
    - 34.9K bytes
    - Click Count (0)
  2. cmd/erasure-healing-common_test.go

    			t.Errorf("Drive erroneously filtered, driveIndex: %d", diskIndex)
    		}
    	}
    	partsMetadata[1] = partsMetadataBackup // Revert before going to the next test
    
    	// Test 4: key = disk index, value = part name with hash mismatch
    	erasureDisks = s.getDisks()
    	diskFailures := make(map[int]string)
    	diskFailures[0] = "part.1"
    	diskFailures[3] = "part.1"
    	diskFailures[15] = "part.1"
    
    	for diskIndex, partName := range diskFailures {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  3. compat/maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java

        // Helper method for containsExactlyInAnyOrder assertion
        private static <T> void assertContainsExactlyInAnyOrder(Collection<T> actual, T... expected) {
            assertEquals(expected.length, actual.size(), "Collection size mismatch");
            for (T item : expected) {
                assertTrue(actual.contains(item), "Collection should contain: " + item);
            }
        }
    
        @Test
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 30.9K bytes
    - Click Count (0)
  4. android-test/src/androidDeviceTest/java/okhttp/android/test/OkHttpTest.kt

        try {
          InetAddress.getByName("www.google.com")
        } catch (uhe: UnknownHostException) {
          throw TestAbortedException(uhe.message, uhe)
        }
      }
    
      fun OkHttpClient.close() {
        dispatcher.executorService.shutdown()
        connectionPool.evictAll()
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 29.9K bytes
    - Click Count (0)
  5. cmd/object-api-multipart_test.go

    		{bucketName: bucket, objName: "none-object", uploadID: uploadID, PartID: 1, expectedError: fmt.Errorf("%s", "Invalid upload id "+uploadID)},
    		// Test case - 12.
    		// Input to replicate Md5 mismatch.
    		{
    			bucketName: bucket, objName: object, uploadID: uploadID, PartID: 1, inputMd5: "d41d8cd98f00b204e9800998ecf8427f",
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  6. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/InferenceStrategyTest.java

                assertNotNull(DomUtils.findChildElement(dependency, "version"));
            }
    
            @Test
            @DisplayName("should keep dependency version when version mismatch")
            void shouldKeepDependencyVersionWhenVersionMismatch() throws Exception {
                String moduleAPomXml = PomBuilder.create()
                        .namespace("http://maven.apache.org/POM/4.1.0")
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 35.2K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/hash/BloomFilterTest.java

            bf.writeTo(out);
            int actualSize = out.size();
            assertThat(bf.serializedSize()).isEqualTo(actualSize);
    
            assertWithMessage(
                    "Serialization size mismatch for expectedInsertions=%s, fpp=%s",
                    expectedInsertions, fpp)
                .that(actualSize)
                .isEqualTo(predictedSize);
          }
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 23K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

          if (windowSize != DEFAULT_INITIAL_WINDOW_SIZE) {
            writer.windowUpdate(0, (windowSize - DEFAULT_INITIAL_WINDOW_SIZE).toLong())
          }
        }
        // Thread doesn't use client Dispatcher, since it is scoped potentially across clients via
        // ConnectionPool.
        taskRunner.newQueue().execute(name = connectionName, block = readerRunnable)
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 31.9K bytes
    - Click Count (0)
  9. cmd/storage-rest-server.go

    	}
    	volume := params.Get(storageRESTVolume)
    	dirPath := params.Get(storageRESTDirPath)
    	origvolume := params.Get(storageRESTOrigVolume)
    	count, err := strconv.Atoi(params.Get(storageRESTCount))
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    
    	entries, err := s.getStorage().ListDir(ctx, origvolume, volume, dirPath, count)
    	if err != nil {
    		return grid.NewRemoteErr(err)
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  10. cmd/object-api-putobject_test.go

    		// Valid object and bucket names but non-existent bucket.
    		5: {bucketName: "abc", objName: "def", inputData: []byte(""), expectedError: BucketNotFound{Bucket: "abc"}},
    
    		// Input to replicate Md5 mismatch.
    		6: {
    			bucketName: bucket, objName: object, inputData: []byte(""),
    			inputMeta:     map[string]string{"etag": "d41d8cd98f00b204e9800998ecf8427f"},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 25.8K bytes
    - Click Count (0)
Back to Top