outManager; L29:import org.codelibs.core.timer.TimeoutTask; L30:import org.codelibs.fess.Constants; L31:import org.codelibs.fess.crawler.client.FesenClient; L32:import org.codelibs.fess.es.client.SearchEngineClient; L33:import org.codelibs.fess.exception.ContainerNotAvailableException; L34:import org.codelibs.fess.helper.SuggestHelper; L35:import org.codelibs.fess.timer.SystemMonitorTarget; L36:import org.codelibs.fess.util.ComponentUtil; L37:import org.codelibs.fess.util.SystemUtil; L38:import ...

+ e.getClass() L115: + " without a cause"); L116: } L117: } catch (Throwable t) { // this includes CancellationException and sneaky checked exception L118: throwable = t; L119: } L120: L121: if (throwable == null) { L122: /* L123: * The cast is safe: There was no exception, so the assignment from getDone must have L124: * succeeded. L125: */ L126: set(uncheckedCastNullableTToT(sourceResult)); L127: return; L128: } L129:...

cost during experiment. */ L70: Map<Element, Element> map; L71: L72: CollectionBenchmarkSampleData elems; L73: L74: @Param({"0", "1", "100", "10000"}) L75: int elements; L76: L77: @BeforeExperiment L78: public void prepareContents() throws Exception { L79: mapsImpl = mapEnums.get(implName); L80: elems = new CollectionBenchmarkSampleData(elements); L81: contents = Maps.newHashMap(); L82: for (Element key : elems.getValuesInSet()) { L83: contents.put(key, key); L84: } L85:...

L30: L31: public SlackClient(SlackApi slackApi) { L32: this.slackApi = slackApi; L33: } L34: L35: /** Shows a browser URL to authorize this app to act as this user. */ L36: public void requestOauthSession(String scopes, String team) throws Exception { L37: if (sessionFactory == null) { L38: sessionFactory = new OAuthSessionFactory(slackApi); L39: sessionFactory.start(); L40: } L41: L42: HttpUrl authorizeUrl = sessionFactory.newAuthorizeUrl(scopes, team, session -> { L43: ...

L32: @Override L33: protected void setUp() throws Exception { L34: file1 = File.createTempFile("kuromoji_", ".txt"); L35: FileUtil.write( L36: file1.getAbsolutePath(), L37: "token1,seg1,reading1,pos1\ntoken2,seg2,reading2,pos2\ntoken3,seg3,reading3,pos3" L38: .getBytes(Constants.UTF_8)); L39: } L40: L41: @Override L42: protected void tearDown() throws Exception { L43: file1.delete(); L44: } L45: */ L46:...

stuck busy waiting for the task to L32: // transition to DONE L33: public void testInterruptThrows() throws Exception { L34: final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); L35: InterruptibleTask<@Nullable Void> task = L36: new InterruptibleTask<@Nullable Void>() { L37: @Override L38: @Nullable Void runInterruptibly() throws Exception { L39: BrokenChannel bc = new BrokenChannel(); L40: bc.doBegin(); L41: isIn...

L34:import org.codelibs.fess.crawler.client.CrawlerClientFactory; L35:import org.codelibs.fess.crawler.entity.ResponseData; L36:import org.codelibs.fess.crawler.exception.CrawlingAccessException; L37:import org.codelibs.fess.es.client.SearchEngineClient; L38:import org.codelibs.fess.es.config.exentity.CrawlingConfig; L39:import org.codelibs.fess.exception.ThumbnailGenerationException; L40:import org.codelibs.fess.helper.CrawlingConfigHelper; L41:import org.codelibs.fess.helper.IndexingHelper; L42:import ...

be called on the {@link Listener}. L252: * L253: * @param from The previous state that is being transitioned from. Failure can occur in any L254: * state with the exception of {@linkplain State#NEW NEW} or {@linkplain State#TERMINATED L255: * TERMINATED}. L256: * @param failure The exception that caused the failure. L257: */ L258: public void failed(State from, Throwable failure) {} L259: } L260:}...

Random(RANDOM_SEED).nextBytes(testBytes); L52: } L53: L54: // CRC32 L55: L56: @Benchmark L57: byte crc32HashFunction(int reps) { L58: return runHashFunction(reps, Hashing.crc32()); L59: } L60: L61: @Benchmark L62: byte crc32Checksum(int reps) throws Exception { L63: byte result = 0x01; L64: for (int i = 0; i < reps; i++) { L65: CRC32 checksum = new CRC32(); L66: checksum.update(testBytes, 0, testBytes.length); L67: result = (byte) (result ^ checksum.getValue()); L68: } L69: ...

ALLOWS_NULL_KEY_QUERIES) L70: public void testRemove_nullKeyQueriesUnsupported() { L71: try { L72: assertFalse(getMap().remove(null, v3())); L73: } catch (NullPointerException tolerated) { L74: // since the operation would be a no-op, the exception is not required L75: } L76: expectUnchanged(); L77: } L78: L79: @MapFeature.Require(value = SUPPORTS_REMOVE, absent = ALLOWS_NULL_VALUE_QUERIES) L80: public void testRemove_nullValueQueriesUnsupported() { L81: try { L82: assertF...