Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for decReader (0.12 sec)

  1. cmd/object-api-utils.go

    						cFns[i]()
    					}
    					return nil, err
    				}
    			}
    
    			decReader := io.LimitReader(s2Reader, decLength)
    			if decLength > compReadAheadSize {
    				rah, err := readahead.NewReaderSize(decReader, compReadAheadBuffers, compReadAheadBufSize)
    				if err == nil {
    					decReader = rah
    					cFns = append([]func(){func() {
    						rah.Close()
    					}}, cFns...)
    				}
    			}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 36.3K bytes
    - Viewed (0)
  2. src/cmd/vendor/golang.org/x/telemetry/internal/counter/counter.go

    func (b counterStateBits) extra() uint64 { return uint64(b&stateExtra) >> stateExtraShift }
    
    func (b counterStateBits) incReader() counterStateBits    { return b + 1 }
    func (b counterStateBits) decReader() counterStateBits    { return b - 1 }
    func (b counterStateBits) setLocked() counterStateBits    { return b | stateLocked }
    func (b counterStateBits) clearLocked() counterStateBits  { return b &^ stateLocked }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  3. src/encoding/base32/base32_test.go

    				encoded = strings.ReplaceAll(encoded, "=", "")
    			}
    
    			decReader, err := io.ReadAll(NewDecoder(encoding, strings.NewReader(encoded)))
    			if err != nil {
    				t.Errorf("NewDecoder error: %v", err)
    			}
    
    			if pair.decoded != string(decReader) {
    				t.Errorf("Expected %s got %s; Encoding %d", pair.decoded, decReader, encIndex)
    			}
    		}
    	}
    }
    
    func TestDecodeSmallBuffer(t *testing.T) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 14 16:25:54 UTC 2024
    - 26K bytes
    - Viewed (0)
  4. src/go/internal/gcimporter/iimport.go

    	n, err := binary.ReadVarint(&r.declReader)
    	if err != nil {
    		errorf("readVarint: %v", err)
    	}
    	return n
    }
    
    func (r *importReader) uint64() uint64 {
    	n, err := binary.ReadUvarint(&r.declReader)
    	if err != nil {
    		errorf("readUvarint: %v", err)
    	}
    	return n
    }
    
    func (r *importReader) byte() byte {
    	x, err := r.declReader.ReadByte()
    	if err != nil {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  5. src/time/zoneinfo_read.go

    	if err != nil {
    		return nil, err
    	}
    	defer closefd(fd)
    
    	const (
    		zecheader = 0x06054b50
    		zcheader  = 0x02014b50
    		ztailsize = 22
    
    		zheadersize = 30
    		zheader     = 0x04034b50
    	)
    
    	buf := make([]byte, ztailsize)
    	if err := preadn(fd, buf, -ztailsize); err != nil || get4(buf) != zecheader {
    		return nil, errors.New("corrupt zip file " + zipfile)
    	}
    	n := get2(buf[10:])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  6. src/net/http/server.go

    			te, w.contentLength)
    		delHeader("Content-Length")
    		hasCL = false
    	}
    
    	if w.req.Method == "HEAD" || !bodyAllowedForStatus(code) || code == StatusNoContent {
    		// Response has no body.
    		delHeader("Transfer-Encoding")
    	} else if hasCL {
    		// Content-Length has been provided, so no chunking is to be done.
    		delHeader("Transfer-Encoding")
    	} else if w.req.ProtoAtLeast(1, 1) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 17:57:01 UTC 2024
    - 123.4K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/sys/unix/syscall_zos_s390x.go

    	if returnCode != 0 || request.header.outputDesc.offset == 0 {
    		return nil, errnoErr(EINVAL)
    	}
    
    	// Check that EZBNMIF4 returned a nwmRecHeader
    	recHeader := (*nwmRecHeader)(unsafe.Pointer(&responseBuffer[request.header.outputDesc.offset]))
    	if recHeader.ident != nwmRecHeaderIdentifier {
    		return nil, errnoErr(EINVAL)
    	}
    
    	// Parse nwmTriplets to get offsets of returned entries
    	var sections []*uint64
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 16:12:58 UTC 2024
    - 84.4K bytes
    - Viewed (0)
Back to top