Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 38 for caps (0.13 sec)

  1. cmd/tier.go

    func (config *TierConfigMgr) Add(ctx context.Context, tier madmin.TierConfig, ignoreInUse bool) error {
    	config.Lock()
    	defer config.Unlock()
    
    	// check if tier name is in all caps
    	tierName := tier.Name
    	if tierName != strings.ToUpper(tierName) {
    		return errTierNameNotUppercase
    	}
    
    	// check if tier name already in use
    	if _, exists := config.isTierNameInUse(tierName); exists {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2_gen.go

    				return
    			}
    		case "EcDist":
    			var zb0003 uint32
    			zb0003, err = dc.ReadArrayHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "ErasureDist")
    				return
    			}
    			if cap(z.ErasureDist) >= int(zb0003) {
    				z.ErasureDist = (z.ErasureDist)[:zb0003]
    			} else {
    				z.ErasureDist = make([]uint8, zb0003)
    			}
    			for za0003 := range z.ErasureDist {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:43:43 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  3. internal/grid/types.go

    			PutByteBuffer(*b)
    		}
    		*b = nil
    		return bytes, nil
    	}
    	val, bytes, err := msgp.ReadBytesZC(bytes)
    	if err != nil {
    		return bytes, err
    	}
    	if cap(*b) >= len(val) {
    		*b = (*b)[:len(val)]
    		copy(*b, val)
    	} else {
    		if cap(*b) == 0 && len(val) <= maxBufferSize {
    			*b = GetByteBufferCap(len(val))
    		} else {
    			PutByteBuffer(*b)
    			*b = make([]byte, 0, len(val))
    		}
    		in := *b
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 01 23:42:09 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  4. cmd/untar.go

    			name = pathJoin(o.prefixAll, name)
    		}
    
    		// Do small files async
    		n++
    		if header.Size <= smallFileThreshold {
    			asyncWriters <- struct{}{}
    			b := poolBuf128k.Get().([]byte)
    			if cap(b) < int(header.Size) {
    				b = make([]byte, smallFileThreshold)
    			}
    			b = b[:header.Size]
    			if _, err := io.ReadFull(tarReader, b); err != nil {
    				return err
    			}
    			wg.Add(1)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  5. cmd/iam.go

    	regUser
    	stsUser
    	svcUser
    )
    
    // LoadGroup - loads a specific group from storage, and updates the
    // memberships cache. If the specified group does not exist in
    // storage, it is removed from in-memory maps as well - this
    // simplifies the implementation for group removal. This is called
    // only via IAM notifications.
    func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  6. cmd/data-usage-cache_gen.go

    			}
    		case "cycleCompleted":
    			var zb0002 uint32
    			zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "cycleCompleted")
    				return
    			}
    			if cap(z.cycleCompleted) >= int(zb0002) {
    				z.cycleCompleted = (z.cycleCompleted)[:zb0002]
    			} else {
    				z.cycleCompleted = make([]time.Time, zb0002)
    			}
    			for za0001 := range z.cycleCompleted {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 100.8K bytes
    - Viewed (0)
  7. internal/bpool/bpool.go

    		w:    width,
    		wcap: capwidth,
    	}
    }
    
    // Populate - populates and pre-warms the byte pool, this function is non-blocking.
    func (bp *BytePoolCap) Populate() {
    	for _, buf := range reedsolomon.AllocAligned(cap(bp.c), bp.wcap) {
    		bp.Put(buf[:bp.w])
    	}
    }
    
    // Get gets a []byte from the BytePool, or creates a new one if none are
    // available in the pool.
    func (bp *BytePoolCap) Get() (b []byte) {
    	if bp == nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 2.6K bytes
    - Viewed (0)
  8. cmd/erasure-metadata.go

    		fi.TransitionedObjName != ofi.TransitionedObjName,
    		fi.TransitionVersionID != ofi.TransitionVersionID:
    		return false
    	}
    	return true
    }
    
    // MetadataEquals returns true if FileInfos Metadata maps are equal, false otherwise.
    func (fi FileInfo) MetadataEquals(ofi FileInfo) bool {
    	if len(fi.Metadata) != len(ofi.Metadata) {
    		return false
    	}
    	for k, v := range fi.Metadata {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
  9. cmd/storage-datatypes_gen.go

    			return
    		}
    		z.Metadata[za0001] = za0002
    	}
    	var zb0003 uint32
    	zb0003, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err, "Parts")
    		return
    	}
    	if cap(z.Parts) >= int(zb0003) {
    		z.Parts = (z.Parts)[:zb0003]
    	} else {
    		z.Parts = make([]ObjectPartInfo, zb0003)
    	}
    	for za0003 := range z.Parts {
    		err = z.Parts[za0003].DecodeMsg(dc)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 127.5K bytes
    - Viewed (0)
  10. internal/grid/connection.go

    					}
    					continue
    				}
    				if int64(cap(dst)) < hdr.Length+1 {
    					dst = make([]byte, 0, hdr.Length+hdr.Length>>3)
    				}
    				return readAllInto(dst[:0], &wsReader)
    			}
    		}
    
    		// Keep reusing the same buffer.
    		var msg []byte
    		for {
    			if atomic.LoadUint32((*uint32)(&c.state)) != StateConnected {
    				cancel(ErrDisconnected)
    				return
    			}
    			if cap(msg) > readBufferSize*4 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
Back to top