PrimitiveSink primitiveSink = mock(PrimitiveSink.class);
    Funnels.byteArrayFunnel().funnel(new byte[] {4, 3, 2, 1}, primitiveSink);
    verify(primitiveSink).putBytes(new byte[] {4, 3, 2, 1});
  }

  public void testForBytes_null() {
    assertNullsThrowException(Funnels.byteArrayFunnel());
  }

  public void testForStrings() {
    PrimitiveSink primitiveSink = mock(PrimitiveSink.class);

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

import jcifs.CIFSContext;
import jcifs.Configuration;

/**
 * Integration tests for witness protocol implementation.
 * Uses mock services to simulate witness behavior.
 */
@ExtendWith(MockitoExtension.class)
public class WitnessIntegrationTest {

    @Mock
    private CIFSContext mockContext;

    @Mock

@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;

    }

    @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);

@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;
  }

  /**
   * The current state of the service. This should be written with the lock held but can be read
   * without it because it is an immutable object in a volatile field. This is desirable so that
   * methods like {@link #state}, {@link #failureCause} and notably {@link #toString} can be run
   * without grabbing the lock.
   *
   * <p>To update this field correctly the lock must be held to guarantee that the state is
   * consistent.
   */

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

class SmbComSessionSetupAndXTest {

    @Mock
    private SmbSession mockSession;
    @Mock
    private SmbTransport mockTransport;
    @Mock
    private ServerMessageBlock mockAndx;
    @Mock
    private NtlmPasswordAuthentication mockAuth;

    private SmbComSessionSetupAndX setupAndX;

						</c:set>
						<la:password property="password" class="form-control"
							placeholder="${ph_new_password}" />
						<div class="input-group-append">
							<span class="input-group-text">
								<i class="fa fa-lock fa-fw" aria-hidden="true"></i>
							</span>
						</div>
					</div>
					<div class="input-group mb-3">
						<c:set var="ph_confirm_password">
							<la:message key="labels.login.placeholder_confirm_new_password" />

@ExtendWith(MockitoExtension.class)
public class NtlmSspTest {

    @Mock
    private CIFSContext mockCifsContext;

    @Mock
    private Configuration mockConfig;

    @Mock
    private NameServiceClient mockNameServiceClient;

    @Mock
    private NetbiosAddress mockAddress;

    @Mock
    private HttpServletRequest mockRequest;

    @Mock
    private HttpServletResponse mockResponse;