- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 105 for bufr (0.03 sec)
-
src/compress/gzip/gzip_test.go
} } func TestWriterReset(t *testing.T) { buf := new(bytes.Buffer) buf2 := new(bytes.Buffer) z := NewWriter(buf) msg := []byte("hello world") z.Write(msg) z.Close() z.Reset(buf2) z.Write(msg) z.Close() if buf.String() != buf2.String() { t.Errorf("buf2 %q != original buf of %q", buf2.String(), buf.String()) } } type limitedWriter struct { N int }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 17:10:06 UTC 2024 - 6K bytes - Viewed (0) -
pkg/hbone/util.go
buf1 := bufferPoolCopy.Get().([]byte) // nolint: staticcheck defer bufferPoolCopy.Put(buf1) bufCap := cap(buf1) buf := buf1[0:bufCap:bufCap] // For netstack: src is a gonet.Conn, doesn't implement WriterTo. Dst is a net.TcpConn - and implements ReadFrom. // CopyBuffered is the actual implementation of Copy and CopyBuffer. // if buf is nil, one is allocated. // Duplicated from io
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.4K bytes - Viewed (0) -
src/os/dir_windows.go
type dirInfo struct { mu sync.Mutex // buf is a slice pointer so the slice header // does not escape to the heap when returning // buf to dirBufPool. buf *[]byte // buffer for directory I/O bufp int // location of next record in buf h syscall.Handle vol uint32 class uint32 // type of entries in buf
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 20:52:06 UTC 2024 - 7.7K bytes - Viewed (0) -
tools/proto/buf.golang.yaml
John Howard <******@****.***> 1646536079 -0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Mar 06 03:07:59 UTC 2022 - 136 bytes - Viewed (0) -
src/compress/lzw/reader_test.go
func BenchmarkDecoder(b *testing.B) { buf, err := os.ReadFile("../testdata/e.txt") if err != nil { b.Fatal(err) } if len(buf) == 0 { b.Fatalf("test file has no data") } getInputBuf := func(buf []byte, n int) []byte { compressed := new(bytes.Buffer) w := NewWriter(compressed, LSB, 8) for i := 0; i < n; i += len(buf) { if len(buf) > n-i { buf = buf[:n-i] } w.Write(buf) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 18 16:57:58 UTC 2024 - 7.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/ztypes_freebsd_amd64.go
SizeofBpfZbufHeader = 0x20 ) type BpfVersion struct { Major uint16 Minor uint16 } type BpfStat struct { Recv uint32 Drop uint32 } type BpfZbuf struct { Bufa *byte Bufb *byte Buflen uint64 } type BpfProgram struct { Len uint32 Insns *BpfInsn } type BpfInsn struct { Code uint16 Jt uint8 Jf uint8 K uint32 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 9.7K bytes - Viewed (0) -
src/cmd/internal/buildid/buildid_test.go
} } for bufSize := len(id); bufSize <= len(buf); bufSize++ { for j := range buf { for k := 0; k < 2*len(id) && j+k < len(buf); k++ { for i := range buf { buf[i] = 1 } copy(buf[j:], id) copy(buf[j+k:], id) var m []int64 if j+len(id) <= j+k { m = append(m, int64(j)) } if j+k+len(id) <= len(buf) { m = append(m, int64(j+k)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:31:28 UTC 2024 - 6.6K bytes - Viewed (0) -
src/compress/zlib/writer_test.go
t.Errorf("%s (level=%d): %v", fn, level, err) return } out := buf.String() // Reset and compress again. buf2 := new(bytes.Buffer) zlibw.Reset(buf2) _, err = zlibw.Write(b0) if err == nil { err = zlibw.Close() } if err != nil { t.Errorf("%s (level=%d): %v", fn, level, err) return } out2 := buf2.String() if out2 != out {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Dec 09 19:12:23 UTC 2020 - 5.7K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
byte[] buf = new byte[min(bufSize, MAX_ARRAY_LEN - totalLen)]; bufs.add(buf); int off = 0; while (off < buf.length) { // always OK to fill buf; its size plus the rest of bufs is never more than MAX_ARRAY_LEN int r = in.read(buf, off, buf.length - off); if (r == -1) { return combineBuffers(bufs, totalLen); } off += r;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Jan 17 18:59:58 UTC 2024 - 29.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/spdy/upgrade.go
w.Header().Add(httpstream.HeaderUpgrade, HeaderSpdy31) w.WriteHeader(http.StatusSwitchingProtocols) conn, bufrw, err := hijacker.Hijack() if err != nil { runtime.HandleError(fmt.Errorf("unable to upgrade: error hijacking response: %v", err)) return nil } connWithBuf := &connWrapper{Conn: conn, bufReader: bufrw.Reader} spdyConn, err := NewServerConnectionWithPings(connWithBuf, newStreamHandler, u.pingPeriod) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 28 08:02:09 UTC 2022 - 4K bytes - Viewed (0)