- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 214 for IMMEDIATE (0.2 sec)
-
cmd/xl-storage_test.go
Recursive: false, Immediate: false, }); err != errFileAccessDenied { t.Errorf("expected: %s, got: %s", errFileAccessDenied, err) } } // TestXLStorage for delete on an removed disk. // should fail with disk not found. err = xlStorageDeletedStorage.Delete(context.Background(), "del-vol", "my-file", DeleteOptions{ Recursive: false, Immediate: false, }) if err != errDiskNotFound {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 11 17:45:28 UTC 2024 - 66.7K bytes - Viewed (0) -
tests/integration/security/sds_ingress/util/util.go
// Delete Kubernetes secret for ingress gateway c := t.Clusters().Default() var immediate int64 err := c.Kube().CoreV1().Secrets(systemNS.Name()).Delete(context.TODO(), credName, metav1.DeleteOptions{GracePeriodSeconds: &immediate}) if err != nil && !errors.IsNotFound(err) { t.Fatalf("Failed to delete secret (error: %s)", err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 25 05:12:36 UTC 2023 - 20.2K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/mips.s
// { // outcode(int($1), &$2, int($4), &$6); // } SLL $4, R1, R2 // LSHW imm ',' rreg // { // outcode(int($1), &$2, 0, &$4); // } SLL $4, R1 // // move immediate: macro for lui+or, addi, addis, and other combinations // // LMOVW imm ',' rreg // { // outcode(int($1), &$2, 0, &$4); // } MOVW $1, R1 MOVW $1, R1 // LMOVW ximm ',' rreg // {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 08 12:17:12 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/envoy/proxy.go
if network.AllIPv6(e.NodeIPs) { proxyLocalAddressType = "v6" } startupArgs := []string{ "-c", fname, "--drain-time-s", fmt.Sprint(int(e.DrainDuration.AsDuration().Seconds())), "--drain-strategy", "immediate", // Clients are notified as soon as the drain process starts. "--local-address-ip-version", proxyLocalAddressType, // Reduce default flush interval from 10s to 1s. The access log buffer size is 64k and each log is ~256 bytes
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 10:02:56 UTC 2024 - 6.9K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/op.go
auxS390XCCMask // aux is a s390x 4-bit condition code mask auxS390XCCMaskInt8 // aux is a s390x 4-bit condition code mask, auxInt is an int8 immediate auxS390XCCMaskUint8 // aux is a s390x 4-bit condition code mask, auxInt is a uint8 immediate ) // A SymEffect describes the effect that an SSA Value has on the variable // identified by the symbol in its Aux field. type SymEffect int8 const (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 15:29:10 UTC 2024 - 18.7K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueService.java
bulkBuilder.add(c.prepareDelete().setIndex(index).setId(uq.getId())); } return bulkBuilder.setRefreshPolicy(RefreshPolicy.IMMEDIATE).execute(); }); if (response.hasFailures()) { logger.warn(response.buildFailureMessage()); }
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 12.9K bytes - Viewed (0) -
src/runtime/mwbbuf.go
func (b *wbBuf) reset() { start := uintptr(unsafe.Pointer(&b.buf[0])) b.next = start if testSmallBuf { // For testing, make the buffer smaller but more than // 1 write barrier's worth, so it tests both the // immediate flush and delayed flush cases. b.end = uintptr(unsafe.Pointer(&b.buf[wbMaxEntriesPerCall+1])) } else { b.end = start + uintptr(len(b.buf))*unsafe.Sizeof(b.buf[0]) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
return } // CheckVolumeBindingPred fails if pod has unbound immediate PVCs. If these // PVCs have specified StorageClass name, creating StorageClass objects // with late binding will cause predicates to pass, so we need to move pods // to active queue. // We don't need to invalidate cached results because results will not be // cached for pod that has unbound immediate PVCs.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
// appears in outDatedDisks. tamperedIndex = index dErr := erasureDisks[index].Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{ Recursive: false, Immediate: false, }) if dErr != nil { t.Fatalf("Failed to delete %s - %v", filepath.Join(object, "part.1"), dErr) } break } case corruptPart: for index, err := range test.errs {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 23K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java
* <li>when the contended action finishes, i.e. the lock has been released, all Lock Requesters will get another message * to trigger an immediate retry</li> * </ul> * <p> * If this is the Lock Requester: * the message is interpreted as confirmation and stored. No further messages are sent to the Lock Owner via
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 12.4K bytes - Viewed (0)