- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 45 for NewBuffer (0.05 seconds)
-
src/bytes/buffer_test.go
} s += string(fub) check(t, testname+" (fill 4)", buf, s) } return s } func TestNewBuffer(t *testing.T) { buf := NewBuffer(testBytes) check(t, "NewBuffer", buf, testString) } var buf Buffer // Calling NewBuffer and immediately shallow copying the Buffer struct // should not result in any allocations. // This can be used to reset the underlying []byte of an existing Buffer.
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Nov 14 19:01:17 GMT 2025 - 19.4K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/Trans2QueryFSInformationTest.java
class Trans2QueryFSInformationTest { /** Small helper to create a byte buffer larger than the maximum expected * wire format so that we can observe only the bytes written by a method. */ private static byte[] newBuffer(int length) { // initialise with distinct pattern to detect unused trailing bytes byte[] buf = new byte[length]; Arrays.fill(buf, (byte) 0xFF); return buf; } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 4.5K bytes - Click Count (0) -
android/guava/src/com/google/common/hash/AbstractNonStreamingHashFunction.java
ByteBuffer newBuffer = ByteBuffer.allocate(newCapacity).order(ByteOrder.LITTLE_ENDIAN); // We must switch the old buffer to read mode to extract data Java8Compatibility.flip(buffer); newBuffer.put(buffer); // Swap references, newBuffer is already in write mode at the correct position this.buffer = newBuffer; } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 04 15:39:10 GMT 2025 - 4.8K bytes - Click Count (0) -
src/test/java/jcifs/smb1/smb1/BufferCacheSecurityTest.java
BufferCache.releaseBuffer(buffer); } // Then - Should be able to get buffers again byte[] newBuffer = BufferCache.getBuffer(); assertNotNull(newBuffer, "Should be able to get buffer after release"); assertEquals(SmbComTransaction.TRANSACTION_BUF_SIZE, newBuffer.length, "Buffer should have correct size"); } /** * Test that invalid buffer sizes are rejected during release.
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 9.6K bytes - Click Count (0) -
internal/ringbuffer/README.md
fmt.Println(rb.Length()) fmt.Println(rb.Free()) // read buf := make([]byte, 4) rb.Read(buf) fmt.Println(string(buf)) } ``` It is possible to use an existing buffer with by replacing `New` with `NewBuffer`. # Blocking vs Non-blocking The default behavior of the ring buffer is non-blocking, meaning that reads and writes will return immediately with an error if the operation cannot be completed.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed May 15 00:11:04 GMT 2024 - 2.1K bytes - Click Count (0) -
src/bytes/buffer.go
slice, err := b.readSlice(delim) return string(slice), err } // NewBuffer creates and initializes a new [Buffer] using buf as its // initial contents. The new [Buffer] takes ownership of buf, and the // caller should not use buf after this call. NewBuffer is intended to // prepare a [Buffer] to read existing data. It can also be used to set
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Nov 14 19:01:17 GMT 2025 - 16.5K bytes - Click Count (0) -
internal/ringbuffer/ring_buffer.go
// New returns a new RingBuffer whose buffer has the given size. func New(size int) *RingBuffer { return &RingBuffer{ buf: make([]byte, size), size: size, } } // NewBuffer returns a new RingBuffer whose buffer is provided. func NewBuffer(b []byte) *RingBuffer { return &RingBuffer{ buf: b, size: len(b), } } // SetBlocking sets the blocking mode of the ring buffer.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.3K bytes - Click Count (0) -
src/bytes/reader_test.go
} tt.f(reader) err := reader.UnreadRune() if err == nil { t.Errorf("Unreading after %s: expected error", tt.name) } } } func TestReaderDoubleUnreadRune(t *testing.T) { buf := NewBuffer([]byte("groucho")) if _, _, err := buf.ReadRune(); err != nil { // should not happen t.Fatal(err) } if err := buf.UnreadByte(); err != nil { // should not happen t.Fatal(err) }
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Click Count (0) -
src/archive/tar/fuzz_test.go
if err != nil { return } buf := bytes.NewBuffer(nil) if _, err := io.Copy(buf, r); err != nil { continue } files = append(files, file{header: hdr, content: buf.Bytes()}) } // If we were unable to read anything out of the archive don't // bother trying to roundtrip it. if len(files) == 0 { return } out := bytes.NewBuffer(nil) w := NewWriter(out) for _, f := range files {Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Jan 13 18:06:33 GMT 2022 - 2.2K bytes - Click Count (0) -
internal/ioutil/ioutil_test.go
src io.Reader skipLen int64 expected string }{ {bytes.NewBuffer([]byte("")), 0, ""}, {bytes.NewBuffer([]byte("")), 1, ""}, {bytes.NewBuffer([]byte("abc")), 0, "abc"}, {bytes.NewBuffer([]byte("abc")), 1, "bc"}, {bytes.NewBuffer([]byte("abc")), 2, "c"}, {bytes.NewBuffer([]byte("abc")), 3, ""}, {bytes.NewBuffer([]byte("abc")), 4, ""}, } for i, testCase := range testCases {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 5.6K bytes - Click Count (0)