Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 52 for storeerr (0.13 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top