import org.mockito.ArgumentCaptor;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.mockito.junit.jupiter.MockitoExtension;

import jcifs.dcerpc.DcerpcHandle;
import jcifs.dcerpc.rpc;
import jcifs.smb.SmbException;

@ExtendWith(MockitoExtension.class)
class SamrDomainHandleTest {

    @Mock
    private DcerpcHandle mockDcerpcHandle;
    @Mock
    private SamrPolicyHandle mockPolicyHandle;
    @Mock

    private CIFSContext mockContext;
    private Smb2SetInfoRequest request;
    private byte[] testFileId;

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        mockContext = mock(CIFSContext.class);
        when(mockContext.getConfig()).thenReturn(mockConfig);

        testFileId = new byte[16];
        for (int i = 0; i < 16; i++) {
            testFileId[i] = (byte) i;

import org.mockito.InOrder;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;

import jcifs.CIFSException;
import jcifs.SmbSession;

/**
 * Tests for SmbTreeHandleInternal interface using Mockito to verify
 * interactions and observable behavior of collaborators.
 */
@ExtendWith(MockitoExtension.class)
public class SmbTreeHandleInternalTest {

    @Mock
    private SmbTreeHandleInternal handle;

   * needed.
   *
   * A single spinlock ("busy") is used for initializing and
   * resizing the table, as well as populating slots with new Cells.
   * There is no need for a blocking lock; when the lock is not
   * available, threads try other slots (or the base).  During these
   * retries, there is increased contention and reduced locality,
   * which is still better than alternatives.
   *

     */
    @Test
    void testGetGroupMemberSids() throws IOException, SmbException {
        CIFSContext mockContext = mock(CIFSContext.class);
        SidResolver mockResolver = mock(SidResolver.class);
        when(mockContext.getSIDResolver()).thenReturn(mockResolver);

        // Create a mock RPC SID to simulate a domain group SID
        rpc.sid_t rpcSid = new rpc.sid_t();
        rpcSid.revision = 1;

    private byte[] fileId;
    private final Smb2Lock[] locks;

    /**
     * Constructs an SMB2 lock request with the specified parameters.
     *
     * @param config the configuration for this request
     * @param fileId the file identifier for the file to lock
     * @param locks the array of lock elements to apply
     */
    public Smb2LockRequest(final Configuration config, final byte[] fileId, final Smb2Lock[] locks) {

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

/**
 * Comprehensive test suite for Address interface.
 * Tests the contract and behavior of Address implementations.
 */
@DisplayName("Address Interface Tests")
class AddressTest extends BaseTest {

    @Mock
    private CIFSContext mockContext;

    @Mock
    private Address mockAddress;

    @Test

    private Configuration mockConfig;

    @BeforeEach
    void setUp() {
        // Mock the Configuration object
        mockConfig = mock(Configuration.class);
        // Define behavior for the OEM encoding, which is used by writeString
        when(mockConfig.getOemEncoding()).thenReturn(StandardCharsets.UTF_8.name());
    }

    @Test
    void testConstructor() {

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

import jcifs.smb1.dcerpc.DcerpcHandle;
import jcifs.smb1.smb1.SmbException;

@ExtendWith(MockitoExtension.class)
class LsaPolicyHandleTest {

    @Mock
    private DcerpcHandle mockDcerpcHandle;

    @BeforeEach
    void setUp() {

	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
}