Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for DecodeMsg (0.04 sec)

  1. cmd/storage-rest-client.go

    	if err != nil {
    		return fi, err
    	}
    	defer xhttp.DrainBody(respBody)
    
    	dec := msgpNewReader(respBody)
    	defer readMsgpReaderPoolPut(dec)
    
    	err = fi.DecodeMsg(dec)
    	return fi, err
    }
    
    // ReadXL - reads all contents of xl.meta of a file.
    func (client *storageRESTClient) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_test.go

    	msgp.Encode(&buf, &v)
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkDecodeDiskInfoMsgp(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    		Free:      1000,
    		Used:      1000,
    		FSType:    "xfs",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  3. cmd/data-usage-cache.go

    	}
    	return dataUsageHash(path.Clean(data))
    }
    
    //msgp:ignore dataUsageHashMap
    type dataUsageHashMap map[string]struct{}
    
    // DecodeMsg implements msgp.Decodable
    func (z *dataUsageHashMap) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0002 uint32
    	zb0002, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if zb0002 == 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    		}
    
    		// OK, parse data.
    		// ignore any parsing errors, we do not care this file is generated again anyways.
    		re.DecodeMsg(msgp.NewReader(rc))
    
    		return re, nil
    	}
    
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
Back to top