generateContents(tempDir, count);

            return tempDir;
        } catch (final Exception e) {
            throw new CrawlerSystemException(e);
        }
    }

    private static void generateContents(final File dir, final int count) throws Exception {
        if (count <= 0) {
            return;
        }

        final String content = getHtmlContent(count);

  @J2ktIncompatible
  @GwtIncompatible // reflection
  public void testParse_useConstants() throws Exception {
    for (MediaType constant : getConstants()) {
      assertSame(constant, MediaType.parse(constant.toString()));
    }
  }

  @J2ktIncompatible
  @GwtIncompatible // reflection
  public void testCreate_useConstants() throws Exception {
    for (MediaType constant : getConstants()) {
      assertSame(
          constant,

import org.dbflute.optional.OptionalThing;

public class LdapUserTest extends UnitFessTestCase {

    private LdapUser ldapUser;
    private Hashtable<String, String> testEnv;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        testEnv = new Hashtable<>();
        testEnv.put("test.key", "test.value");
        ldapUser = new LdapUser(testEnv, "testuser");

/**
 * @author Charles Fry
 */
@GwtCompatible
@J2ktIncompatible // MapMaker
@NullUnmarked
public class MapMakerTest extends TestCase {
  @GwtIncompatible // NullPointerTester
  public void testNullParameters() throws Exception {
    NullPointerTester tester = new NullPointerTester();
    tester.testAllPublicInstanceMethods(new MapMaker());
  }

  @GwtIncompatible // threads

    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.Decodable#decode(byte[], int, int)
     */
    @Override
    public int decode(final byte[] buffer, int bufferIndex, final int len) throws SMBProtocolDecodingException {
        final int start = bufferIndex;
        this.alloc = SMBUtil.readInt8(buffer, bufferIndex);
        bufferIndex += 8;

        this.free = SMBUtil.readInt8(buffer, bufferIndex);

    void testConstructorWithInvalidInformationLevel() {
        // The exception is thrown during writeParametersWireFormat when mapInformationLevel is called
        Trans2QueryFSInformation trans2 = new Trans2QueryFSInformation(config, 99);
        assertNotNull(trans2);

        // Exception should be thrown when trying to write parameters
        byte[] buffer = new byte[256];

     * @param query the Lucene query to convert (must be a FuzzyQuery)
     * @param boost the boost factor to apply to the query
     * @return OpenSearch QueryBuilder for fuzzy matching
     * @throws InvalidQueryException if the query is not a FuzzyQuery
     */
    @Override
    public QueryBuilder execute(final QueryContext context, final Query query, final float boost) {

        return this.major;
    }

    /**
     * @return the minor
     */
    int getMinor() {
        return this.minor;
    }

    void setOption(final String key, final Object val) throws DcerpcException {
        if (key.equals("endpoint")) {
            this.endpoint = val.toString();
            final String lep = this.endpoint.toLowerCase(Locale.ENGLISH);
            if (lep.startsWith("\\pipe\\")) {

    private long lastModified = 1L;
    private int alt;

    /**
     * This is really just for {@link jcifs.netbios.UniAddress}. It does
     * not throw an {@link java.net.UnknownHostException} because this
     * is queried frequently and exceptions would be rather costly to
     * throw on a regular basis here.
     *
     * @param host the hostname to resolve
     * @param tc the CIFS context
     * @return resolved name, null if not found

 * [enqueue].
 */
public open class QueueDispatcher : Dispatcher() {
  protected val responseQueue: BlockingQueue<MockResponse> = LinkedBlockingQueue()
  private var failFastResponse: MockResponse? = null

  @Throws(InterruptedException::class)
  override fun dispatch(request: RecordedRequest): MockResponse {
    // To permit interactive/browser testing, ignore requests for favicons.
    val requestLine = request.requestLine