preauthService.initializeSession(sessionId, salt, PreauthIntegrityService.HASH_ALGO_SHA512);

        // Simulate message exchange
        preauthService.updatePreauthHash(sessionId, "Message1".getBytes());
        preauthService.updatePreauthHash(sessionId, "Message2".getBytes());

        byte[] expectedHash = preauthService.getCurrentPreauthHash(sessionId);

        // Validation should pass with correct hash

            executor.submit(() -> {
                try {
                    startLatch.await();
                    Method updateMethod = findMethod(transport.getClass(), "updatePreauthHash", byte[].class);
                    updateMethod.setAccessible(true);
                    updateMethod.invoke(transport, testData);
                } catch (Exception e) {

     *
     * @param sessionId the session identifier
     * @param messageData the message data to include in hash
     * @throws CIFSException if update fails
     */
    public void updatePreauthHash(String sessionId, byte[] messageData) throws CIFSException {
        PreauthIntegrityContext context = sessionContexts.get(sessionId);
        if (context == null) {
            if (enforceIntegrity) {

        this.negotiated = resp.getResponse();
        if (resp.getResponse().getSelectedDialect().atLeast(DialectVersion.SMB311)) {
            updatePreauthHash(resp.getRequestRaw());
            updatePreauthHash(resp.getResponseRaw());
            if (log.isDebugEnabled()) {
                log.debug("Preauth hash after negotiate " + Hexdump.toHexString(this.preauthIntegrityHash));
            }