Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/storage-datatypes_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BaseOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    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)
  2. 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) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    	}
    
    	versions := make([]FileInfoVersions, totalVersions)
    	decoder := msgpNewReader(r.Body)
    	defer readMsgpReaderPoolPut(decoder)
    	for i := 0; i < totalVersions; i++ {
    		dst := &versions[i]
    		if err := dst.DecodeMsg(decoder); err != nil {
    			s.writeErrorResponse(w, err)
    			return
    		}
    	}
    
    	dErrsResp := &DeleteVersionsErrsResp{Errs: make([]error, totalVersions)}
    
    	setEventStreamHeaders(w)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 44.8K 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(globalLocalDrives)
    	globalLocalDrivesMu.RUnlock()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top