import java.io.IOException;
import java.io.InputStreamReader;
import org.jspecify.annotations.NullUnmarked;

/**
 * @author Colin Decker
 */
@NullUnmarked
public class TestReader extends FilterReader {

  private final TestInputStream in;

  public TestReader(TestOption... options) throws IOException {
    this(new TestInputStream(new ByteArrayInputStream(new byte[10]), options));
  }

  public TestReader(TestInputStream in) {

              @Override
              public ListIterator<?> apply(ListIterator delegate) {
                return wrap((ListIterator<?>) delegate);
              }
            });
  }

  private static <T> ListIterator<T> wrap(ListIterator<T> delegate) {
    return new ForwardingListIterator<T>() {
      @Override
      protected ListIterator<T> delegate() {
        return delegate;
      }
    };
  }

import java.util.Random;
import org.jspecify.annotations.NullUnmarked;

/** Returns a random portion of the requested bytes on each call. */
@NullUnmarked
class RandomAmountInputStream extends FilterInputStream {
  private final Random random;

  public RandomAmountInputStream(InputStream in, Random random) {
    super(checkNotNull(in));
    this.random = checkNotNull(random);
  }

  @Override

import java.io.IOException;
import java.io.InputStreamReader;
import org.jspecify.annotations.NullUnmarked;

/**
 * @author Colin Decker
 */
@NullUnmarked
public class TestReader extends FilterReader {

  private final TestInputStream in;

  public TestReader(TestOption... options) throws IOException {
    this(new TestInputStream(new ByteArrayInputStream(new byte[10]), options));
  }

  public TestReader(TestInputStream in) {

 * @author shinsuke
 */
public class IllegalBlockSizeRuntimeException extends ClRuntimeException {

    private static final long serialVersionUID = 1L;

    /**
     * Creates a new {@link IllegalBlockSizeRuntimeException} with the specified cause.
     *
     * @param cause
     *            the cause
     */

import org.junit.jupiter.api.Test;

import jcifs.dcerpc.DcerpcConstants;
import jcifs.dcerpc.rpc.policy_handle;

/**
 * Tests for the {@link MsrpcLsarClose} class.
 */
class MsrpcLsarCloseTest {

    private policy_handle mockHandle;

    @BeforeEach
    void setUp() {
        // Create a mock policy_handle for each test
        mockHandle = mock(policy_handle.class);
    }

    /**

import jakarta.annotation.Resource;

/**
 * API action for admin scheduler management.
 */
public class ApiAdminSchedulerAction extends FessApiAdminAction {

    /** The logger for this class. */
    private static final Logger logger = LogManager.getLogger(ApiAdminSchedulerAction.class);

    // ===================================================================================

    //                                                                           Singleton
    //                                                                           =========
    private static final FileAuthenticationDbm _instance = new FileAuthenticationDbm();

    private FileAuthenticationDbm() {
    }

    public static FileAuthenticationDbm getInstance() {
        return _instance;
    }

 * This class contains NDR (Network Data Representation) encodable/decodable structures
 * used in DCE/RPC communications.
 */
public class rpc {

    /**
     * Private constructor to prevent instantiation of utility class.
     */
    private rpc() {
        // Utility class
    }

    /**
     * UUID (Universally Unique Identifier) structure for DCE/RPC.

/**
 * Test class for Smb2SetInfoResponse functionality
 */
@DisplayName("Smb2SetInfoResponse Tests")
@MockitoSettings(strictness = Strictness.LENIENT)
class Smb2SetInfoResponseTest {

    private Configuration mockConfig;
    private Smb2SetInfoResponse response;

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        response = new Smb2SetInfoResponse(mockConfig);
    }

    @Test