- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for tcCall (0.31 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
_, _, err := registry.Delete(testContext, podA.Name, rest.ValidateAllObjectFunc, nil) if !errors.IsNotFound(err) { t.Errorf("Unexpected error: %v", err) } if afterWasCalled { t.Errorf("Unexpected call to AfterDelete") } // create pod _, err = registry.Create(testContext, podA, rest.ValidateAllObjectFunc, &metav1.CreateOptions{}) if err != nil { t.Errorf("Unexpected error: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
cmd/object-handlers.go
w.Header().Del(xhttp.ContentType) if _, ok := opts.ObjectAttributes[xhttp.Checksum]; ok { chkSums := objInfo.decryptChecksums(0, r.Header) // AWS does not appear to append part number on this API call. switch { case chkSums["CRC32"] != "": OA.Checksum = new(objectAttributesChecksum) OA.Checksum.ChecksumCRC32 = strings.Split(chkSums["CRC32"], "-")[0] case chkSums["CRC32C"] != "":
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 14 13:28:35 UTC 2024 - 124.2K bytes - Viewed (0) -
cmd/metrics-v2.go
defer wg.Done() for metric := range in { labels, values := getOrderedLabelValueArrays(metric.VariableLabels) collectMetric(metric, labels, values, "bucket", out) } } // Call peer api to fetch metrics wg.Add(2) go publish(ReportMetrics(GlobalContext, c.metricsGroups)) go publish(globalNotificationSys.GetBucketMetrics(GlobalContext)) wg.Wait() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:54 UTC 2024 - 131.9K bytes - Viewed (0) -
src/cmd/internal/obj/arm64/asm7.go
rel.Siz = 4 rel.Sym = p.To.Sym rel.Add = p.To.Offset rel.Type = objabi.R_CALLARM64 case 6: /* b ,O(R); bl ,O(R) */ o1 = c.opbrr(p, p.As) o1 |= uint32(p.To.Reg&31) << 5 if p.As == obj.ACALL { rel := obj.Addrel(c.cursym) rel.Off = int32(c.pc) rel.Siz = 0 rel.Type = objabi.R_CALLIND } case 7: /* beq s */ o1 = c.opbra(p, p.As)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:44:14 UTC 2024 - 201.1K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
}, "suspending a job with unsatisfied expectations": { // Unlike the previous test, we expect the controller to NOT suspend the // Job in the syncJob call because the controller will wait for // expectations to be satisfied first. The next syncJob call (not tested // here) will be the same as the previous test. suspend: true, parallelism: 2,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
cmd/server_test.go
for _, expectedStr := range testCase.expectedStrings { c.Assert(strings.Contains(string(getContent), expectedStr), true) } } } // TestListObjectsV2HadoopUAHandler - Test ListObjectsV2 call with max-keys=2 and Hadoop User-Agent func (s *TestSuiteCommon) TestListObjectsV2HadoopUAHandler(c *check) { // generate a random bucket name. bucketName := getRandomBucketName() // HTTP request to create the bucket.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 115.3K bytes - Viewed (0) -
pkg/printers/internalversion/printers_test.go
} } } func TestTranslateTimestampUntil(t *testing.T) { // Since this method compares the time with time.Now() internally, // small buffers of 0.1 seconds are added on comparing times to consider method call overhead. // Otherwise, the output strings become shorter than expected. const buf = 1e8 tl := stringTestList{ {"a while ago", translateTimestampUntil(metav1.Time{Time: time.Now().Add(-2.1e9)}), "<invalid>"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0)