byte[] buffer = new byte[512];

            int bytesWritten = req.writeBytesWireFormat(buffer, 0);

            assertEquals(48, SMBUtil.readInt2(buffer, 0)); // Structure size
            assertEquals(3, SMBUtil.readInt2(buffer, 2)); // Lock count
            assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, 8, 24));

            // Each lock is 24 bytes

  /** Number of (unsynchronized) retries in the containsValue method. */
  static final int CONTAINS_VALUE_RETRIES = 3;

  /**
   * Number of cache access operations that can be buffered per segment before the cache's recency
   * ordering information is updated. This is used to avoid lock contention by recording a memento

            NdrShort ndrShort = new NdrShort(50);
            NdrBuffer buffer1 = mock(NdrBuffer.class);
            NdrBuffer buffer2 = mock(NdrBuffer.class);
            when(buffer2.dec_ndr_short()).thenReturn(75);

            // When: Performing multiple operations
            ndrShort.encode(buffer1);
            ndrShort.decode(buffer2);

            // Then: Should handle both operations correctly

* Fixed potential deadlock when deleting CustomResourceDefinition for custom resources with finalizers. ([#60542](https://github.com/kubernetes/kubernetes/pull/60542), [@liggitt](https://github.com/liggitt))

* A buffered audit backend can be used with other audit backends. ([#60076](https://github.com/kubernetes/kubernetes/pull/60076), [@crassirostris](https://github.com/crassirostris))

        @Test
        @DisplayName("Should not modify buffer during write")
        void testWriteDoesNotModifyBuffer() {
            byte[] buffer = new byte[64];
            Arrays.fill(buffer, (byte) 0xAA);
            byte[] originalBuffer = buffer.clone();

            notification.writeBytesWireFormat(buffer, 0);

            assertArrayEquals(originalBuffer, buffer);
        }
    }

    @Nested

        );
        when(mockNdrBuffer.dec_ndr_small()).thenReturn(4, 5);
        when(mockDeferredNdrBuffer.dec_ndr_long()).thenReturn(5, 0, 5, // name buffer: buffers, 0, bufferl
                6, 0, 6, // dns_domain buffer: buffers, 0, bufferl
                7, 0, 7 // dns_forest buffer: buffers, 0, bufferl
        );
        when(mockDeferredNdrBuffer.dec_ndr_short()).thenReturn((int) (short) 'a', (int) (int) (short) 'b', (int) (int) (short) 'c',

        assertThrows(Exception.class, () -> new Pac(pacData, keys));
    }

    @Test
    void testZeroBufferCount() throws IOException {
        // Test PAC with zero buffers (missing required buffers)
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        writeLittleEndianInt(baos, 0); // bufferCount = 0
        writeLittleEndianInt(baos, PacConstants.PAC_VERSION); // valid version

        // compute number of bytes still unhashed; ie. present in buffer
        int bufferNdx = (int) (count % BLOCK_LENGTH);
        count += len; // update number of bytes
        final int partLen = BLOCK_LENGTH - bufferNdx;
        int i = 0;
        if (len >= partLen) {
            System.arraycopy(input, offset, buffer, bufferNdx, partLen);

            transform(buffer, 0);

const (
	// minBufferSize is the minimum buffer size.
	// Buffers below this is not reused.
	minBufferSize = 1 << 10

	// defaultBufferSize is the default buffer allocation size.
	defaultBufferSize = 4 << 10

	// maxBufferSize is the maximum buffer size.
	// Buffers larger than this is not reused.
	maxBufferSize = 96 << 10

	// This is the assumed size of bigger buffers and allocation size.
	biggerBufMin = 32 << 10

	go func() {
		for {
			rb.Read(buf)
		}
	}()

	for b.Loop() {
		rb.Write(data)
	}
}

func BenchmarkRingBuffer_AsyncReadBlocking(b *testing.B) {
	const sz = 512
	const buffers = 10
	rb := New(sz * buffers)
	rb.SetBlocking(true)
	data := []byte(strings.Repeat("a", sz))
	buf := make([]byte, sz)

	go func() {
		for {
			rb.Read(buf)
		}
	}()

	for b.Loop() {
		rb.Write(data)
	}