- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 52 for storeerr (0.12 sec)
-
src/internal/runtime/atomic/types.go
// on this thread can be observed to occur after it. // // WARNING: Use sparingly and with great care. // //go:nosplit func (u *Uint32) StoreRelease(value uint32) { StoreRel(&u.value, value) } // CompareAndSwap atomically compares u's value with old, // and if they're equal, swaps u's value with new. // It reports whether the swap ran. // //go:nosplit
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 14.2K bytes - Viewed (0) -
cmd/data-usage-cache.go
case ObjectNotFound, BucketNotFound: return false, nil case InsufficientReadQuorum, StorageErr: return true, nil } return false, err } err = d.deserialize(r) r.Close() return err != nil, nil case InsufficientReadQuorum, StorageErr: return true, nil } return false, err } err = d.deserialize(r) r.Close()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 10 14:49:50 UTC 2024 - 42.8K bytes - Viewed (0) -
cmd/storage-rest-client.go
case strings.Contains(err.Error(), "server closed idle connection"): return true } return false } // Converts network error to storageErr. This function is // written so that the storageAPI errors are consistent // across network disks. func toStorageErr(err error) error { if err == nil { return nil } if isNetworkError(err) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go
t.Errorf("rotateDEKOnKeyIDChange() error = %v, wantErr %v", err, tt.wantErr) } // if the old or new state is valid, we should be able to use it if _, stateErr := h.getCurrentState(); stateErr == nil || err == nil { transformer := envelopekmsv2.NewEnvelopeTransformer( &testKMSv2EnvelopeService{err: fmt.Errorf("broken")}, // not called "panda", h.getCurrentState,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 72.3K bytes - Viewed (0) -
cmd/common-main.go
if !t.IsZero() { globalVersionUnix = uint64(t.Unix()) } globalIsCICD = env.Get("MINIO_CI_CD", "") != "" || env.Get("CI", "") != "" console.SetColor("Debug", fcolor.New()) gob.Register(StorageErr("")) gob.Register(madmin.TimeInfo{}) gob.Register(madmin.XFSErrorConfigs{}) gob.Register(map[string]string{}) gob.Register(map[string]interface{}{})
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 11:58:12 UTC 2024 - 31.5K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
// Example: // // v33 = ArgIntReg <uintptr> {foo+0} [0] : AX (foo) // v34 = ArgIntReg <uintptr> {bar+0} [0] : BX (bar) // ... // v77 = StoreReg <unsafe.Pointer> v67 : ctx+8[unsafe.Pointer] // v78 = StoreReg <unsafe.Pointer> v68 : ctx[unsafe.Pointer] // v79 = Arg <*uint8> {args} : args[*uint8] (args[*uint8]) // v80 = Arg <int> {args} [8] : args+8[int] (args+8[int]) // ...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/expand_calls.go
n := a.Aux.(*ir.Name) if n.Class == ir.PPARAM && n.FrameOffset()+x.f.Config.ctxt.Arch.FixedFrameSize == aOffset { continue } } if x.debug > 1 { x.Printf("...storeArg %s, %v, %d\n", a.LongString(), aType, aOffset) } rc.init(aRegs, aux.abiInfo, result, sp, aOffset) mem = x.decomposeAsNecessary(v.Pos, v.Block, a, mem, rc) } var preArgStore [2]*Value
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 28 05:13:40 UTC 2023 - 31.9K bytes - Viewed (0) -
cmd/storage-rest-server.go
opts := DeleteOptions{} errs := s.getStorage().DeleteVersions(r.Context(), volume, versions, opts) done(nil) for idx := range versions { if errs[idx] != nil { dErrsResp.Errs[idx] = StorageErr(errs[idx].Error()) } } encoder.Encode(dErrsResp) } // RenameDataHandler - renames a meta object and data dir to destination.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 44.8K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/_gen/genericOps.go
// semantically identical to OpCopy; they do not take/return // stores like regular memory ops do. We can get away without memory // args because we know there is no aliasing of spill slots on the stack. {name: "StoreReg", argLength: 1}, {name: "LoadReg", argLength: 1}, // Used during ssa construction. Like Copy, but the arg has not been specified yet. {name: "FwdRef", aux: "Sym", symEffect: "None"},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 15:49:20 UTC 2024 - 42.6K bytes - Viewed (0) -
src/runtime/proc.go
} retry: h := atomic.LoadAcq(&pp.runqhead) // load-acquire, synchronize with consumers t := pp.runqtail if t-h < uint32(len(pp.runq)) { pp.runq[t%uint32(len(pp.runq))].set(gp) atomic.StoreRel(&pp.runqtail, t+1) // store-release, makes the item available for consumption return } if runqputslow(pp, gp, h, t) { return } // the queue is not full, now the put above must succeed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 207.5K bytes - Viewed (0)