public void makeEmlFile(String fileName) {

        }

        @Override

        public String toHash() {

            return "mock-hash";

        }

        @Override
        public String toDisplay() {

            return "mock-display";

        }

        @Override
        public java.util.Map<String, java.util.Map<String, Object>> getOfficeManagedLoggingMap() {

    // 'swallowException' when the mock does not throw an exception.
    setupCloseable(false);
    doClose(mockCloseable, false, false);

    setupCloseable(false);
    doClose(mockCloseable, true, false);
  }

  public void testClose_closeableWithEatenException() throws IOException {
    // make sure that no exception is thrown if 'swallowException' is true
    // when the mock does throw an exception.
    setupCloseable(true);

 */
@ExtendWith(MockitoExtension.class)
@DisplayName("DcerpcHandle Test Suite")
class DcerpcHandleTest {

    @Mock
    private CIFSContext mockContext;

    @Mock
    private DcerpcBinding mockBinding;

    @Mock
    private BufferCache mockBufferCache;

    @Mock
    private DcerpcSecurityProvider mockSecurityProvider;

    // Concrete implementation of DcerpcHandle for testing

import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;

@ExtendWith(MockitoExtension.class)
public class SmbTransportTest {

    @Mock
    private SmbTransport smbTransport;

    @Mock
    private CIFSContext cifsContext;

    @Mock
    private Address remoteAddress;

    @BeforeEach
    void setUp() {

@GwtCompatible
@NullMarked
public class TearDownStack implements TearDownAccepter {
  private static final Logger logger = Logger.getLogger(TearDownStack.class.getName());

  @VisibleForTesting final Object lock = new Object();

  @GuardedBy("lock")
  final Deque<TearDown> stack = new ArrayDeque<>();

  private final boolean suppressThrows;

  public TearDownStack() {
    this.suppressThrows = false;
  }

@GwtCompatible
@NullMarked
public class TearDownStack implements TearDownAccepter {
  private static final Logger logger = Logger.getLogger(TearDownStack.class.getName());

  @VisibleForTesting final Object lock = new Object();

  @GuardedBy("lock")
  final Deque<TearDown> stack = new ArrayDeque<>();

  private final boolean suppressThrows;

  public TearDownStack() {
    this.suppressThrows = false;
  }

    }

    @Test
    @DisplayName("constructor with mock andx properly sets andx field")
    void constructorWithMockAndx() {
        // Create a mock ServerMessageBlock
        ServerMessageBlock mockAndx = mock(ServerMessageBlock.class);
        mockAndx.command = (byte) 0x2E; // Set a different command value (e.g., SMB_COM_READ_ANDX)

        // Create SmbComLogoffAndX with the mock
        SmbComLogoffAndX msg = new SmbComLogoffAndX(mockAndx);

                    // Mock implementation
                }
            };
            ComponentUtil.register(mockProperties, "systemProperties");

            // Register mock system helper
            SystemHelper mockSystemHelper = new SystemHelper() {
                @Override
                public void updateSystemProperties() {
                    // Mock implementation
                }

@ExtendWith(MockitoExtension.class)
@MockitoSettings(strictness = Strictness.LENIENT)
class ChannelManagerTest {

    @Mock
    private CIFSContext mockContext;

    @Mock
    private Configuration mockConfig;

    @Mock
    private SmbSession mockSession;

    @Mock
    private SmbTransport mockTransport;

    @Mock
    private CommonServerMessageBlock mockMessage;

    private ChannelManager channelManager;

	r  io.Reader
	mu sync.Mutex
}

func (d *disconnectReader) Read(p []byte) (n int, err error) {
	d.mu.Lock()
	defer d.mu.Unlock()
	if d.r != nil {
		return d.r.Read(p)
	}
	return 0, errors.New("reader closed")
}

func (d *disconnectReader) Close() error {
	d.mu.Lock()
	d.r = nil
	d.mu.Unlock()
	return nil
}