Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 113 for readAll (0.07 seconds)

  1. cmd/bucket-stats_gen.go

    			z.CurrentBandwidthInBytesPerSecond, err = dc.ReadFloat64()
    			if err != nil {
    				err = msgp.WrapError(err, "CurrentBandwidthInBytesPerSecond")
    				return
    			}
    		case "lt":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "XferRateLrg")
    					return
    				}
    				z.XferRateLrg = nil
    			} else {
    				if z.XferRateLrg == nil {
    					z.XferRateLrg = new(XferStats)
    				}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 57.3K bytes
    - Click Count (0)
  2. cmd/erasure-heal_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		data := make([]byte, test.size)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to create random test data: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    		writers := make([]io.Writer, len(disks))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  3. cmd/xl-storage-format-v2.go

    	hasFull := true
    	if initial > metaDataReadDefault {
    		initial = metaDataReadDefault
    		hasFull = false
    	}
    
    	buf := metaDataPoolGet()[:initial]
    	_, err := io.ReadFull(r, buf)
    	if err != nil {
    		return nil, fmt.Errorf("readXLMetaNoData(io.ReadFull): %w", err)
    	}
    	readMore := func(n int64) error {
    		has := int64(len(buf))
    		if has >= n {
    			return nil
    		}
    		if hasFull || n > size {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  4. cmd/local-locker_gen.go

    		case "LocksAbandoned":
    			z.LocksAbandoned, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "LocksAbandoned")
    				return
    			}
    		case "LastCleanup":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "LastCleanup")
    					return
    				}
    				z.LastCleanup = nil
    			} else {
    				if z.LastCleanup == nil {
    					z.LastCleanup = new(time.Time)
    				}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  5. cmd/erasure-encode_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    
    		data := make([]byte, test.data)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  6. cmd/batch-expire_gen.go

    		case "OlderThan":
    			err = z.OlderThan.DecodeMsg(dc)
    			if err != nil {
    				err = msgp.WrapError(err, "OlderThan")
    				return
    			}
    		case "CreatedBefore":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "CreatedBefore")
    					return
    				}
    				z.CreatedBefore = nil
    			} else {
    				if z.CreatedBefore == nil {
    					z.CreatedBefore = new(time.Time)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 19.9K bytes
    - Click Count (0)
  7. cmd/site-replication-metrics_gen.go

    				var za0001 string
    				za0001, err = dc.ReadString()
    				if err != nil {
    					err = msgp.WrapError(err, "M")
    					return
    				}
    				var za0002 *SRStatus
    				if dc.IsNil() {
    					err = dc.ReadNil()
    					if err != nil {
    						err = msgp.WrapError(err, "M", za0001)
    						return
    					}
    					za0002 = nil
    				} else {
    					if za0002 == nil {
    						za0002 = new(SRStatus)
    					}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 40.3K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool-rebalance_gen.go

    				z.PoolStats = (z.PoolStats)[:zb0002]
    			} else {
    				z.PoolStats = make([]*rebalanceStats, zb0002)
    			}
    			for za0001 := range z.PoolStats {
    				if dc.IsNil() {
    					err = dc.ReadNil()
    					if err != nil {
    						err = msgp.WrapError(err, "PoolStats", za0001)
    						return
    					}
    					z.PoolStats[za0001] = nil
    				} else {
    					if z.PoolStats[za0001] == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  9. src/bufio/bufio.go

    // Read reads data into p.
    // It returns the number of bytes read into p.
    // The bytes are taken from at most one Read on the underlying [Reader],
    // hence n may be less than len(p).
    // To read exactly len(p) bytes, use io.ReadFull(b, p).
    // If the underlying [Reader] can return a non-zero count with io.EOF,
    // then this Read method can do so as well; see the [io.Reader] docs.
    func (b *Reader) Read(p []byte) (n int, err error) {
    	n = len(p)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Sep 03 14:04:47 GMT 2025
    - 22K bytes
    - Click Count (0)
  10. cmd/erasure-server-pool-decom_gen.go

    				return
    			}
    		case "lu":
    			z.LastUpdate, err = dc.ReadTime()
    			if err != nil {
    				err = msgp.WrapError(err, "LastUpdate")
    				return
    			}
    		case "dec":
    			if dc.IsNil() {
    				err = dc.ReadNil()
    				if err != nil {
    					err = msgp.WrapError(err, "Decommission")
    					return
    				}
    				z.Decommission = nil
    			} else {
    				if z.Decommission == nil {
    					z.Decommission = new(PoolDecommissionInfo)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.7K bytes
    - Click Count (0)
Back to Top