Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 45 for NewBuffer (0.05 seconds)

  1. 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)
  2. 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;
        }
    
        @Test
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  3. 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;
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 04 15:39:10 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top