- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for testObj (0.3 sec)
-
pkg/kubelet/util/cache/object_cache_test.go
} value, err := objectCache.Get(testObj.key) if err != nil { t.Errorf("Unable to get obj %#v by key: %s", testObj, testObj.key) } if value.(string) != testObj.val { t.Errorf("Expected to get cached value: %#v, but got: %s", testObj.val, value.(string)) } } func TestExpirationBasic(t *testing.T) { unexpectedVal := "bar" expectedVal := "bar2" testObj := testObject{ key: "foo",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 2.6K bytes - Viewed (0) -
buildscripts/heal-inconsistent-versions.sh
for i in $(seq 1 4); do "${PWD}/mc" cp /etc/hosts minio/bucket/testobj sudo chown -R root. "${WORK_DIR}/disk${i}" "${PWD}/mc" cp /etc/hosts minio/bucket/testobj sudo chown -R ${USER}. "${WORK_DIR}/disk${i}" done for vid in $("${PWD}/mc" ls --json --versions minio/bucket/testobj | jq -r .versionId); do "${PWD}/mc" cat --vid "${vid}" minio/bucket/testobj | md5sum done pkill minio sleep 3 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 26 05:07:25 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/serialization/src/test/groovy/org/gradle/internal/serialize/DefaultSerializerTest.groovy
DefaultSerializer serializer = new DefaultSerializer(classLoader) Class cl = classLoader.parseClass('package org.gradle.cache; class TestObj implements Serializable { }') Object o = cl.newInstance(new Object[0]) when: def r = serialize(o, serializer) then: cl.isInstance(r) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 15 16:06:56 UTC 2024 - 1.5K bytes - Viewed (0) -
buildscripts/resolve-right-versions.sh
sleep 5 if ! ps -p ${pid} 1>&2 >/dev/null; then echo "server1 log:" cat "${WORK_DIR}/server1.log" echo "FAILED" purge "$WORK_DIR" exit 1 fi "${WORK_DIR}/mc" stat minio/bucket/testobj pkill minio sleep 3 } function main() { start_port=$(shuf -i 10000-65000 -n 1) start_minio_5drive ${start_port} } function purge() { rm -rf "$1" } (main "$@") rv=$?
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Aug 16 14:51:33 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/MethodInvocationSerializerTest.groovy
result[2].arguments == [4, 5] as Object[] } def "uses provided ClassLoader to locate incoming method invocation"() { Class cl = classLoader.parseClass('package org.gradle.test; class TestObj { void doStuff() { } }') def method = cl.getMethod("doStuff") def invocation = new MethodInvocation(method, [] as Object[]) when: def serialized = serialize(invocation)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 5K bytes - Viewed (0) -
subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildMinimalConfigurationIntegrationTest.groovy
dependency "org.test:b1:1.0" includeBuild buildB when: buildB.buildFile << """ println 'Configured buildB' """ then: resolvedGraph { edge("org.test:buildB:1.0", ":buildB", "org.test:buildB:2.0") { compositeSubstitute() } edge("org.test:b1:1.0", ":buildB:b1", "org.test:b1:2.0") {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 01 20:36:42 UTC 2022 - 6.4K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/execution/DefaultBuildResumptionAnalyzerTest.java
Optional<BuildResumptionData> result = analyzer.determineBuildResumptionData(executionResult); assertThat(result.isPresent(), is(true)); assertThat(result.get().getRemainingProjects(), is(asList("test:B"))); } @Test void resumeFromIsIgnoredWhenFirstProjectFails() { MavenProject projectA = createFailedMavenProject("A"); MavenProject projectB = createMavenProject("B");
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Apr 15 17:24:20 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/capabilities/CapabilitiesConflictResolutionIntegrationTest.groovy
edge('org:testA:1.0', 'org:testB:1.0') .byConflictResolution("On capability org.test:cap we like testB better") module('org:testB:1.0') } } where: rule << [ "select(candidates.find { it.id.module == 'testB'})", "select('org:testB:1.0')", "select('org:testB:1.1')", // we are lenient wrt to the version number
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 07:37:10 UTC 2024 - 8.4K bytes - Viewed (0) -
cmd/warm-backend-s3.go
object = params[0] } return ErrorRespToObjectError(err, s3.Bucket, s3.getDest(object)) } func (s3 *warmBackendS3) getDest(object string) string { destObj := object if s3.Prefix != "" { destObj = fmt.Sprintf("%s/%s", s3.Prefix, object) } return destObj } func (s3 *warmBackendS3) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.5K bytes - Viewed (0) -
cmd/warm-backend-gcs.go
client *storage.Client Bucket string Prefix string StorageClass string } func (gcs *warmBackendGCS) getDest(object string) string { destObj := object if gcs.Prefix != "" { destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object) } return destObj } // FIXME: add support for remote version ID in GCS remote tier and remove this. // Currently it's a no-op.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Apr 21 11:43:18 UTC 2024 - 5.9K bytes - Viewed (0)