L35:import org.codelibs.fess.crawler.client.http.form.FormScheme; L36:import org.codelibs.fess.crawler.client.http.impl.AuthenticationImpl; L37:import org.codelibs.fess.crawler.client.http.ntlm.JcifsEngine; L38:import org.codelibs.fess.crawler.exception.CrawlerSystemException; L39:import org.codelibs.fess.es.config.bsentity.BsWebAuthentication; L40:import org.codelibs.fess.es.config.exentity.CrawlingConfig.ConfigName; L41:import org.codelibs.fess.es.config.exentity.CrawlingConfig.Param.Config; L42:import...

org.codelibs.fess.app.web.admin.storage.AdminStorageAction.PathInfo; L33:import org.codelibs.fess.app.web.api.ApiResult; L34:import org.codelibs.fess.app.web.api.admin.FessApiAdminAction; L35:import org.codelibs.fess.exception.ResultOffsetExceededException; L36:import org.codelibs.fess.exception.StorageException; L37:import org.dbflute.optional.OptionalThing; L38:import org.lastaflute.web.Execute; L39:import org.lastaflute.web.response.JsonResponse; L40:import org.lastaflute.web.response.StreamResponse;...

latch = new CountDownLatch(2); L83: L84: new Thread( L85: new Runnable() { L86: @Override L87: public void run() { L88: try { L89: barrier.await(); L90: } catch (Exception e) { L91: throw new AssertionError(e); L92: } L93: L94: dispatcher.dispatch(2, integerSubscribers.iterator()); L95: latch.countDown(); L96: } L97: }) L98: ...

null, "" -> null L85: else -> protocol L86: } L87: } else { L88: super.getSelectedProtocol(sslSocket) L89: } L90: L91: companion object { L92: val isSupported: Boolean = L93: try { L94: // Trigger an early exception over a fatal error, prefer a RuntimeException over Error. L95: Class.forName("org.openjsse.net.ssl.OpenJSSE", false, javaClass.classLoader) L96: L97: true L98: } catch (_: ClassNotFoundException) { L99: false L100: ...

L50: @get:JvmName("charset") L51: val charset: Charset L52: get() { L53: val charset = authParams["charset"] L54: if (charset != null) { L55: try { L56: return Charset.forName(charset) L57: } catch (ignore: Exception) { L58: } L59: } L60: return ISO_8859_1 L61: } L62: L63: constructor(scheme: String, realm: String) : this(scheme, singletonMap("realm", realm)) L64: L65: init { L66: val newAuthParams = mutableMapOf<String?, String>() L67:...

L41: L42: @Override L43: public void execute(Runnable task) { L44: tasks.add(task); L45: } L46: L47: private void runNext() { L48: tasks.removeFirst().run(); L49: } L50: } L51: L52: public void testAsyncReload() throws Exception { L53: final AtomicInteger loadCount = new AtomicInteger(); L54: final AtomicInteger reloadCount = new AtomicInteger(); L55: final AtomicInteger loadAllCount = new AtomicInteger(); L56: L57: CacheLoader<Object, Object> baseLoader = L58:...

nonemacher L35: */ L36:@J2ktIncompatible // threads L37:@GwtIncompatible // threads L38:public class AtomicLongMapBasherTest extends TestCase { L39: private final Random random = new Random(301); L40: L41: public void testModify_basher() throws Exception { L42: int nTasks = 3000; L43: int nThreads = 100; L44: final int getsPerTask = 1000; L45: final int deltaRange = 10000; L46: final String key = "key"; L47: L48: final AtomicLongMap<String> map = AtomicLongMap.create(); L49: L50:...

static Path root() { L68: return FS.getRootDirectories().iterator().next(); L69: } L70: L71: private Path tempDir; L72: L73: @Override L74: protected void setUp() throws Exception { L75: tempDir = Files.createTempDirectory("MoreFilesTest"); L76: } L77: L78: @Override L79: protected void tearDown() throws Exception { L80: if (tempDir != null) { L81: // delete tempDir and its contents L82: Files.walkFileTree( L83: tempDir, L84: new SimpleFileVisitor<Path>()...

final int SMALL_MAX_SIZE = DRAIN_THRESHOLD * 5; L227: L228: TestLogHandler logHandler; L229: L230: @Override L231: public void setUp() throws Exception { L232: super.setUp(); L233: logHandler = new TestLogHandler(); L234: LocalCache.logger.addHandler(logHandler); L235: } L236: L237: @Override L238: public void tearDown() throws Exception { L239: super.tearDown(); L240: LocalCache.logger.removeHandler(logHandler); L241: } L242: L243: private Throwable popLoggedThrowable() {...

final int SMALL_MAX_SIZE = DRAIN_THRESHOLD * 5; L227: L228: TestLogHandler logHandler; L229: L230: @Override L231: public void setUp() throws Exception { L232: super.setUp(); L233: logHandler = new TestLogHandler(); L234: LocalCache.logger.addHandler(logHandler); L235: } L236: L237: @Override L238: public void tearDown() throws Exception { L239: super.tearDown(); L240: LocalCache.logger.removeHandler(logHandler); L241: } L242: L243: private Throwable popLoggedThrowable() {...