}

    @Test
    @DisplayName("Should read multiple notifications from wire format")
    void testReadMultipleNotifications() throws Exception {
        // Given
        byte[] buffer = new byte[1024];
        int offset = 0;

        // Set header start position
        setHeaderStart(response, 64);

        // Write structure header
        SMBUtil.writeInt2(9, buffer, offset);

        when(mockDelegate.getTransactionBufferSize()).thenReturn(65024);
        when(mockDelegate.getBufferCacheSize()).thenReturn(16);
        when(mockDelegate.getNotifyBufferSize()).thenReturn(1024);

        // When
        int sendBufferSize = delegatingConfig.getSendBufferSize();
        int receiveBufferSize = delegatingConfig.getReceiveBufferSize();

                if ((getPipeType() & SmbPipeResource.PIPE_TYPE_DCE_TRANSACT) == SmbPipeResource.PIPE_TYPE_DCE_TRANSACT) {
                    req.setMaxDataCount(1024);
                }
                th.send(req, resp, RequestParam.NO_RETRY);
                return resp.getResponseLength();
            }
            if (this.call) {

            "64, FILE_NOTIFY_CHANGE_CREATION", "128, FILE_NOTIFY_CHANGE_EA", "256, FILE_NOTIFY_CHANGE_SECURITY",
            "512, FILE_NOTIFY_CHANGE_STREAM_NAME", "1024, FILE_NOTIFY_CHANGE_STREAM_SIZE", "2048, FILE_NOTIFY_CHANGE_STREAM_WRITE" })
    void testCompletionFilterConstants(int value, String description) {
        // Given & When
        request.setCompletionFilter(value);

        when(tree.send(any(Smb2IoctlRequest.class), any())).thenReturn(resp);

        byte[] out = new byte[10];
        int read = target.sendrecv(new byte[] { 9, 8, 7 }, 0, 3, out, 1024);
        assertEquals(42, read);

        // Verify we issued an SMB2 IOCTL
        ArgumentCaptor<Smb2IoctlRequest> captor = ArgumentCaptor.forClass(Smb2IoctlRequest.class);

	sizeLessThan100MiB
	sizeLessThan1GiB
	sizeGreaterThan1GiB
	// Add new entries here

	sizeLastElemMarker
)

// sizeToTag converts a size to a tag.
func sizeToTag(size int64) int {
	switch {
	case size < 1024:
		return sizeLessThan1KiB
	case size < 1024*1024:
		return sizeLessThan1MiB
	case size < 10*1024*1024:
		return sizeLessThan10MiB
	case size < 100*1024*1024:
		return sizeLessThan100MiB

@ExtendWith(MockitoExtension.class)
@DisplayName("EncryptionNegotiateContext Tests")
class EncryptionNegotiateContextTest {

    @Mock
    private Configuration mockConfig;

    private static final int BUFFER_SIZE = 1024;
    private byte[] buffer;

    @BeforeEach
    void setUp() {
        buffer = new byte[BUFFER_SIZE];
    }

    @Nested
    @DisplayName("Constructor Tests")
    class ConstructorTests {

    }

    @Test
    @DisplayName("Test buffer management")
    void testBufferManagement() {
        // Test buffer setting and releasing
        byte[] testBuffer = new byte[1024];
        response.setBuffer(testBuffer);

        byte[] releasedBuffer = response.releaseBuffer();
        assertSame(testBuffer, releasedBuffer);

        // After release, the buffer should be null

   * underlying hash functions together. This can be useful if you need to generate hash codes of a
   * specific length.
   *
   * <p>For example, if you need 1024-bit hash codes, you could join two {@link Hashing#sha512} hash
   * functions together: {@code Hashing.concatenating(Hashing.sha512(), Hashing.sha512())}.
   *
   * @since 19.0
   */

        makeLocalCache(createCacheBuilder().concurrencyLevel(1).initialCapacity(1));
    Segment<Object, Object> segment = map.segments[0];
    assertEquals(1, segment.table.length());

    int count = 1024;
    for (int i = 0; i < count; i++) {
      Object key = new Object();
      Object value = new Object();
      int hash = map.hash(key);
      assertNull(segment.put(key, hash, value, false));