import org.junit.jupiter.params.provider.ValueSource;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;

import jcifs.CIFSException;

@ExtendWith(MockitoExtension.class)
class SmbPipeOutputStreamTest {

    @Mock
    SmbPipeHandleImpl handle;

    @Mock
    SmbTreeHandleImpl tree;

    @Mock
    SmbNamedPipe pipe;

    @Mock
    SmbFileHandleImpl fileHandle;

        final int expectedNt = 0xc0000002;

        interface NtStatusConsumer {
            void consume(int ntStatus);
        }
        NtStatusConsumer mock = mock(NtStatusConsumer.class);
        findNtStatus(dosErr).ifPresent(mock::consume);
        verify(mock).consume(expectedNt);
    }

    @Test
    @DisplayName("DOS_ERROR_MESSAGES length matches expectations")
    void testMessageArrayLength() {

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

    @Mock
    CIFSContext ctx;

    @Mock
    Configuration config;

    @Mock
    Credentials credentials;

    @Mock
    DfsResolver dfsResolver;

    private SmbTreeConnection newConn() {
        return new SmbTreeConnection(ctx) {
        };
    }

    }

    @Test
    @DisplayName("Should create proper response object")
    void testCreateResponse() {
        // Given
        Configuration mockConfig = mock(Configuration.class);
        CIFSContext mockContext = mock(CIFSContext.class);
        when(mockContext.getConfig()).thenReturn(mockConfig);
        Smb2TreeDisconnectRequest request = new Smb2TreeDisconnectRequest(mockConfig);

        // When

     * always under a lock.
     */
    private static final class SupplantableFuture implements Cancellable {
      private final ReentrantLock lock;

      @GuardedBy("lock")
      private Future<@Nullable Void> currentFuture;

      SupplantableFuture(ReentrantLock lock, Future<@Nullable Void> currentFuture) {
        this.lock = lock;
        this.currentFuture = currentFuture;
      }

/**
 * Unit tests for DirectoryLeaseManager
 */
public class DirectoryLeaseManagerTest {

    @Mock
    private CIFSContext context;

    @Mock
    private Configuration config;

    @Mock
    private LeaseManager baseLeaseManager;

    @Mock
    private SmbFile mockFile1;

    @Mock
    private SmbFile mockFile2;

    private DirectoryLeaseManager directoryLeaseManager;

 * test with reference to the same "lock-like object", and then their interactions with that object
 * are choreographed via the various methods on this class.
 *
 * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
 * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a

    @Test
    void testLsarLookupSidsConstructorAndGetOpnum() {
        rpc.policy_handle mockHandle = mock(rpc.policy_handle.class);
        lsarpc.LsarSidArray mockSids = mock(lsarpc.LsarSidArray.class);
        lsarpc.LsarRefDomainList mockDomains = mock(lsarpc.LsarRefDomainList.class);
        lsarpc.LsarTransNameArray mockNames = mock(lsarpc.LsarTransNameArray.class);

class NameServiceClientImplTest {

    @Mock
    private CIFSContext mockContext;

    @Mock
    private Configuration mockConfig;

    @Mock
    private NetbiosAddress mockNetbiosAddress;

    @Mock
    private Address mockAddress;

    private NameServiceClientImpl nameServiceClient;

    @BeforeEach
    void setUp() throws UnknownHostException {
        // Configure mock context with fast timeouts

import static org.junit.jupiter.api.Assertions.assertNotNull;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;

import jcifs.dcerpc.rpc.policy_handle;

class MsrpcSamrCloseHandleTest {

    @Mock
    private policy_handle mockPolicyHandle;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
    }