- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 139 for buf1 (0.02 sec)
-
guava-tests/test/com/google/common/io/CharSequenceReaderTest.java
assertEquals(expected, buf2.toString()); assertFullyRead(reader); // read in chunks to fixed CharBuffer reader = new CharSequenceReader(charSequence); buf2 = CharBuffer.allocate(5); builder = new StringBuilder(); while (reader.read(buf2) != -1) { Java8Compatibility.flip(buf2); builder.append(buf2); Java8Compatibility.clear(buf2); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.5K bytes - Viewed (0) -
cmd/erasure-decode.go
startBlock := int64(0) endBlock := totalLength / e.blockSize if totalLength%e.blockSize != 0 { endBlock++ } var bufs [][]byte for block := startBlock; block < endBlock; block++ { var err error bufs, err = reader.Read(bufs) if len(bufs) > 0 { if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) { if derr == nil { derr = err } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
internal/handlers/forwarder.go
type bufPool struct { sz int pool sync.Pool } func (b *bufPool) Put(buf []byte) { if cap(buf) < b.sz || cap(buf) > b.sz*2 { // Buffer too small or will likely leak memory after being expanded. // Drop it. return } b.pool.Put(&buf) } func (b *bufPool) Get() []byte { bufp := b.pool.Get().(*[]byte) return (*bufp)[:b.sz] } func newBufPool(sz int) httputil.BufferPool {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
cmd/os_unix.go
} } defer syscall.Close(fd) bufp := direntPool.Get().(*[]byte) defer direntPool.Put(bufp) buf := *bufp boff := 0 // starting read position in buf nbuf := 0 // end valid data in buf for { if boff >= nbuf { boff = 0 stop := globalOSMetrics.time(osMetricReadDirent) nbuf, err = syscall.ReadDirent(fd, buf) stop() if err != nil { if isSysErrNotDir(err) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.3K bytes - Viewed (0) -
internal/ioutil/ioutil_test.go
t.Errorf("Error creating tmp file: %v", err) } defer f.Close() defer os.Remove(f.Name()) r := strings.NewReader("hello world") bufp := ODirectPoolSmall.Get().(*[]byte) defer ODirectPoolSmall.Put(bufp) written, err := CopyAligned(f, io.LimitReader(r, 5), *bufp, r.Size(), f) if !errors.Is(err, io.ErrUnexpectedEOF) { t.Errorf("Expected io.ErrUnexpectedEOF, but got %v", err) } if written != 5 {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
src/main/java/jcifs/dcerpc/DcerpcMessage.java
void encode_header ( NdrBuffer buf ) { buf.enc_ndr_small(5); /* RPC version */ buf.enc_ndr_small(0); /* minor version */ buf.enc_ndr_small(this.ptype); buf.enc_ndr_small(this.flags); buf.enc_ndr_long(0x00000010); /* Little-endian / ASCII / IEEE */ buf.enc_ndr_short(this.length); buf.enc_ndr_short(0); /* length of auth_value */ buf.enc_ndr_long(this.call_id); }
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 5K bytes - Viewed (0) -
cmd/batch-handlers_gen_test.go
v := BatchJobPrefix{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeBatchJobPrefix Msgsize() is inaccurate") } vn := BatchJobPrefix{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 01 12:53:30 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/local-locker_gen_test.go
v := localLockMap{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodelocalLockMap Msgsize() is inaccurate") } vn := localLockMap{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/storage-rest-common_gen_test.go
v := nsScannerOptions{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodensScannerOptions Msgsize() is inaccurate") } vn := nsScannerOptions{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v) err = msgp.NewReader(&buf).Skip() if err != nil { t.Error(err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 4.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/dcerpc/DcerpcBind.java
} public void encode_in(NdrBuffer buf) throws NdrException { buf.enc_ndr_short(max_xmit); buf.enc_ndr_short(max_recv); buf.enc_ndr_long(0); /* assoc. group */ buf.enc_ndr_small(1); /* num context items */ buf.enc_ndr_small(0); /* reserved */ buf.enc_ndr_short(0); /* reserved2 */ buf.enc_ndr_short(0); /* context id */ buf.enc_ndr_small(1); /* number of items */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 3.2K bytes - Viewed (0)