when(mockCtx.supportsIntegrity()).thenReturn(true);
            when(mockCtx.calculateMIC(any(byte[].class))).thenReturn(new byte[] { 42 });
            // verifyMIC returns void; no stubbing needed
            when(mockCtx.isMICAvailable()).thenReturn(true);

            // Act
            useContext(mockCtx);

        request.setGlobalToolchainsSource(new StringSource(""));
        ToolchainsParseException parseException = new ToolchainsParseException("MESSAGE", 4, 2);
        doThrow(parseException).when(toolchainsReader).read(any(InputStream.class), ArgumentMatchers.anyMap());

        try {
            toolchainBuilder.build(request);

    void byteArrayConstructor_topLevelNotSequence_throws() throws Exception {
        // Arrange: Encoded INTEGER instead of SEQUENCE
        byte[] notASequence = new ASN1Integer(42).getEncoded();

        // Act + Assert
        assertThrows(PACDecodingException.class, () -> new KerberosApRequest(notASequence, null));
    }

    @Test

        }

        @Test
        @DisplayName("Should initialize with correct command and MID")
        void testConstructorInitialization() throws Exception {
            // Given
            int testMid = 42;

            // When
            Constructor<SmbComNtCancel> constructor = SmbComNtCancel.class.getDeclaredConstructor(Configuration.class, int.class);
            constructor.setAccessible(true);

        buffer[38] = 0x00;

        // Parameter count (2 bytes)
        buffer[39] = 0x00;
        buffer[40] = 0x00;

        // Parameter offset (2 bytes)
        buffer[41] = 0x00;
        buffer[42] = 0x00;

        // Parameter displacement (2 bytes)
        buffer[43] = 0x00;
        buffer[44] = 0x00;

        // Data count (2 bytes)
        buffer[45] = 0x00;
        buffer[46] = 0x00;

            int[] ciphers = new int[cipherCount];
            EncryptionNegotiateContext context = new EncryptionNegotiateContext(mockConfig, ciphers);

            assertEquals(4 + (2 * cipherCount), context.size());
        }
    }

    @Nested
    @DisplayName("Round-trip Tests")
    class RoundTripTests {

        @Test

    }

    @Test
    @DisplayName("Test setTid sets tree ID")
    void testSetTid() {
        // Given
        Smb2CancelRequest request = new Smb2CancelRequest(mockConfig, 1L, 0L);
        int treeId = 42;

        // When
        request.setTid(treeId);

        // Then
        assertEquals(treeId, request.getTreeId(), "Tree ID should be set correctly");
    }

    @Test

}

// Borrowed from rwmutex_test.go
func TestParallelReaders(t *testing.T) {
	defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(-1))
	doTestParallelReaders(1, 4)
	doTestParallelReaders(3, 4)
	doTestParallelReaders(4, 2)
}

// Borrowed from rwmutex_test.go
func reader(rwm *LRWMutex, numIterations int, activity *int32, cdone chan bool) {
	for range numIterations {
		if rwm.GetRLock(context.Background(), "", "", time.Second) {

        when(resp.isReceived()).thenReturn(true);
        when(resp.getErrorCode()).thenReturn(0x10B);
        when(resp.getNotifyInformation()).thenReturn(new ArrayList<>());
        setupSmb1(resp, 42);
        SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0xFF, false);

        List<FileNotifyInformation> result = sut.watch();

        assertNotNull(result);
        verify(handle, times(1)).markClosed();

                }
              }
            ]
          }
        ]
      },
      "gridPos": {
        "h": 6,
        "w": 6,
        "x": 0,
        "y": 42
      },
      "id": 76,
      "options": {
        "legend": {
          "calcs": [],
          "displayMode": "list",
          "placement": "bottom",
          "showLegend": true
        },