import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;
import org.lastaflute.job.LaCron;

public class JobHelperTest extends UnitFessTestCase {

    private JobHelper jobHelper;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        jobHelper = new JobHelper();
        ComponentUtil.register(new SystemHelper(), "systemHelper");

@Tag("it")
public class MappingTests extends DictCrudTestBase {

    private static final String NAME_PREFIX = "mappingTest_";
    private static final String API_PATH = "/api/admin/dict/mapping";
    private static final String LIST_ENDPOINT_SUFFIX = "settings";
    private static final String ITEM_ENDPOINT_SUFFIX = "setting";
    private static final String DICT_TYPE = "mapping";

    private static final String KEY_PROPERTY = "inputs";

    @Override

public class ProtwordsTests extends DictCrudTestBase {

    private static final String NAME_PREFIX = "protwordsTest_";
    private static final String API_PATH = "/api/admin/dict/protwords";
    private static final String LIST_ENDPOINT_SUFFIX = "settings";
    private static final String ITEM_ENDPOINT_SUFFIX = "setting";
    private static final String DICT_TYPE = "protwords";

    private static final String KEY_PROPERTY = "input";

    @Override

        private String provides;

        private ExactMatcher(String provides) {
            this.provides = provides;
        }

        @Override
        public boolean matches(String requirement) {
            return provides.equalsIgnoreCase(requirement);
        }

        @Override
        public String toString() {
            return provides;
        }
    }

    private String netbiosName = null;

    private CIFSContext transportContext;

    private CredentialsInternal credentials;
    private byte[] sessionKey;
    private boolean extendedSecurity;

    private final AtomicLong usageCount = new AtomicLong(1);
    private final AtomicBoolean transportAcquired = new AtomicBoolean(true);

    private long sessionId;

    private SMBSigningDigest digest;

 */
@NullUnmarked
public final class HostSpecifierTest extends TestCase {

  private static final ImmutableList<String> GOOD_IPS =
      ImmutableList.of("1.2.3.4", "2001:db8::1", "[2001:db8::1]");

  private static final ImmutableList<String> BAD_IPS =
      ImmutableList.of("1.2.3", "2001:db8::1::::::0", "[2001:db8::1", "[::]:80");

  private static final ImmutableList<String> GOOD_DOMAINS =

          '^'.code,
          '`'.code,
          '{'.code,
          '|'.code,
          '}'.code,
        )
  }

private class UrlComponentEncodingTesterJvmPlatform : UrlComponentEncodingTester.Platform() {
  private val uriEscapedCodePoints = StringBuilder()
  private val uriStrippedCodePoints = StringBuilder()

  /**
   * Configure code points to be escaped for conversion to `java.net.URI`. That class is more

@RunWith(JUnit4.class)

@NullUnmarked
public final class GraphMutationTest {
  private static final int NUM_TRIALS = 50;
  private static final int NUM_NODES = 100;
  private static final int NUM_EDGES = 1000;
  private static final int NODE_POOL_SIZE = 1000; // must be >> NUM_NODES

  @Test
  public void directedGraph() {
    testGraphMutation(GraphBuilder.directed());

public class RdmaBufferManager implements AutoCloseable {

    private static final Logger log = LoggerFactory.getLogger(RdmaBufferManager.class);

    private final RdmaProvider provider;
    private final ConcurrentLinkedQueue<RdmaMemoryRegion> availableSendRegions;
    private final ConcurrentLinkedQueue<RdmaMemoryRegion> availableReceiveRegions;
    private final AtomicLong totalAllocated;
    private final AtomicLong totalReleased;

import okio.buffer
import okio.source

/** A basic HTTP/2 server that serves the contents of a local directory.  */
class Http2Server(
  private val baseDirectory: File,
  private val sslSocketFactory: SSLSocketFactory,
) : Http2Connection.Listener() {
  private fun run() {
    val serverSocket = ServerSocket(8888)
    serverSocket.reuseAddress = true
    while (true) {
      var socket: Socket? = null
      try {