Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for readMsgpReaderPoolPut (0.19 sec)

  1. cmd/storage-rest-client.go

    // The reader will be buffered.
    // Return with readMsgpReaderPoolPut when done.
    func msgpNewReader(r io.Reader) *msgp.Reader {
    	p := readMsgpReaderPool.Get().(*msgp.Reader)
    	if p.R == nil {
    		p.R = xbufio.NewReaderSize(r, 32<<10)
    	} else {
    		p.R.Reset(r)
    	}
    	return p
    }
    
    // readMsgpReaderPoolPut can be used to reuse a *msgp.Reader.
    func readMsgpReaderPoolPut(r *msgp.Reader) {
    	if r != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. cmd/storage-rest-server.go

    	if err != nil {
    		s.writeErrorResponse(w, err)
    		return
    	}
    
    	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
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  3. cmd/metacache-stream.go

    	dec := s2DecPool.Get().(*s2.Reader)
    	dec.Reset(r)
    	mr := msgpNewReader(dec)
    	return &metacacheReader{
    		mr: mr,
    		closer: func() {
    			dec.Reset(nil)
    			s2DecPool.Put(dec)
    			readMsgpReaderPoolPut(mr)
    		},
    		creator: func() error {
    			v, err := mr.ReadByte()
    			if err != nil {
    				return err
    			}
    			switch v {
    			case 1, 2:
    			default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
Back to top