- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for decReader (0.33 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)