completed.assertCompletionExpected();
      assertEquals(Thread.State.TERMINATED, thread.getState());
    }

    void joinSuccessfully(long timeoutMillis) {
      Uninterruptibles.joinUninterruptibly(thread, timeoutMillis, MILLISECONDS);
      completed.assertCompletionExpected();
      assertEquals(Thread.State.TERMINATED, thread.getState());
    }

    void joinUnsuccessfully(long timeoutMillis) {

        // Default constructor - initialization handled by field defaults and clear() method
    }

    /**
     * Clears all pager data and resets to default values.
     * This method resets pagination state and clears all request header fields.
     */
    public void clear() {
        allRecordCount = 0;
        allPageCount = 0;
        existPrePage = false;
        existNextPage = false;

        // in test environments, we test that the method exists and can be invoked
        // without throwing unexpected exceptions
        try {
            // Create a new instance to ensure clean state
            SystemMonitorTarget testTarget = new SystemMonitorTarget();

            // Try to call the expired method
            // Note: This method may fail in test environments due to system dependencies

        // When
        request.setFileId(testFileId);

        // Then - verify through internal state (would need getter or reflection in real scenario)
        // Since we can't directly verify the internal state, we create a new request to test
        Smb2CloseRequest newRequest = new Smb2CloseRequest(mockConfig, testFileId);

    }

    // Ensures a default-constructed blob starts empty and stable across APIs
    @Test
    @DisplayName("Default constructor yields empty state")
    void defaultConstructor_initialState() {
        // Arrange & Act
        SecurityBlob blob = new SecurityBlob();

        // Assert

/** See newDirectExecutorService javadoc for behavioral notes. */
@J2ktIncompatible // Emulated
@GwtIncompatible
final class DirectExecutorService extends AbstractListeningExecutorService {

  /** Lock used whenever accessing the state variables (runningTasks, shutdown) of the executor */
  private final Object lock = new Object();

  /*
   * Conceptually, these two variables describe the executor being in
   * one of three states:

        if (v1 != null) {
            return v1.getLeaseKey();
        }
        return null;
    }

    /**
     * Get the lease state from the response
     * @return the lease state or 0 if no lease was granted
     */
    public int getLeaseState() {
        LeaseV2CreateContextResponse v2 = getLeaseV2Context();
        if (v2 != null) {

        assertEquals(expected, flags);
    }

    @Test
    @DisplayName("isEstablished reflects underlying context state")
    void isEstablished_behavior() throws Exception {
        when(gssContext.isEstablished()).thenReturn(true);
        assertTrue(ctx.isEstablished());

        // When gssContext is null, isEstablished returns false

    void defaultConstructor_behavesAsExpected() {
        // Arrange & Act
        SMBProtocolDecodingException ex = new SMBProtocolDecodingException();

        // Assert state
        assertNull(ex.getMessage(), "Default constructor should have null message");
        assertNull(ex.getCause(), "Default constructor should have null cause");

        assertEquals(24, written);
        assertEquals(combinedFlags, SMBUtil.readInt2(buffer, 2));
    }

    @Test
    @DisplayName("Test request state after multiple operations")
    void testRequestStateAfterMultipleOperations() throws Exception {
        // Set initial values
        request.setCloseFlags(0x0001);

        // Change file ID