} catch (InterruptedException e) {
                        throw new InterruptedIOException(e.toString());
                    }
                    return FileVisitResult.TERMINATE;
                } else {
                    return FileVisitResult.CONTINUE;
                }
            }

            @Override

        // Test the writing of bytes to a byte array
        byte[] dst = new byte[100];
        int bytesWritten = smbComDelete.writeBytesWireFormat(dst, 0);

        // Expected format: buffer format (1 byte) + file name (null-terminated)
        int expectedLength = 1 + TEST_FILE_NAME.length() + 1;
        assertEquals(expectedLength, bytesWritten);
        assertEquals(0x04, dst[0]); // Buffer format

        }
        return crawlerContext.sessionId;
    }

    /**
     * Waits for the crawling process to terminate indefinitely.
     */
    public void awaitTermination() {
        awaitTermination(0);
    }

    /**
     * Waits for the crawling process to terminate for a specified duration.
     * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely.
     */

import jcifs.Configuration;
import jcifs.internal.smb1.AndXServerMessageBlock;
import jcifs.internal.smb1.ServerMessageBlock;

/**
 * SMB1 Logoff AndX request message.
 *
 * This command is used to terminate a user session that was
 * previously established with a Session Setup AndX command.
 */
public class SmbComLogoffAndX extends AndXServerMessageBlock {

    /**

        String testPath = "\\server\\share";
        byte[] pathBytes = testPath.getBytes(java.nio.charset.StandardCharsets.UTF_16LE);
        int bufferSize = stringDataStart + pathBytes.length + 2; // +2 for null terminator
        byte[] buffer = new byte[bufferSize];

        // Path consumed (2 bytes) - value: 10 * 2 = 20
        SMBUtil.writeInt2(20, buffer, 0);

        // Number of referrals (2 bytes) - value: 1

        thumbnailJob.timeout = 120; // Set timeout
        thumbnailJob.processTimeout = true;

        testProcessHelper.exitValue = -1;
        testProcessHelper.processOutput = "Process terminated";

        String result = thumbnailJob.execute();

        assertNotNull(result);
        assertNotNull(thumbnailJob.sessionId);
        assertTrue(result.contains("Session Id: " + thumbnailJob.sessionId));

            }
            if (exitValue != 0) {
                final StringBuilder out = new StringBuilder();
                if (processTimeout) {
                    out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                }
                out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());

	if atEOF && len(data) == 0 {
		return 0, nil, nil
	}
	if i := bytes.IndexByte(data, '\n'); i >= 0 {
		// We have a full newline-terminated line.
		return i + 1, dropCR(data[0:i]), nil
	}
	// If we're at EOF, we have a final, non-terminated line. Return it.
	if atEOF {
		return len(data), dropCR(data), nil
	}
	// Request more data.
	return 0, nil, nil
}

import jcifs.Configuration;
import jcifs.internal.smb2.ServerMessageBlock2Request;
import jcifs.internal.smb2.Smb2Constants;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Logoff request message. This command is used to terminate an SMB2 session.
 *
 * @author mbechler
 *
 */
public class Smb2LogoffRequest extends ServerMessageBlock2Request<Smb2LogoffResponse> {

    /**

        buffer[10 + stringBytes.length] = 0; // null terminator

        // Use reflection to call protected readString method
        Method readStringMethod = getReadStringMethod();
        String result = (String) readStringMethod.invoke(response, buffer, 10, 128, false);

        assertEquals(testString, result);
    }

    @Test
    @DisplayName("Test readString with null terminator in middle")