L74: try { L75: doc = searchHelper.getDocumentByDocId(form.docId, L76: new String[] { fessConfig.getIndexFieldUrl(), fessConfig.getIndexFieldConfigId() }, getUserBean()).orElse(null); L77: } catch (final Exception e) { L78: logger.warn("Failed to request: {}", form.docId, e); L79: } L80: if (doc == null) { L81: saveError(messages -> messages.addErrorsDocidNotFound(GLOBAL, form.docId)); L82: return redirect(ErrorAction.class);...

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: ...

assertEquals("<% a", AdminDesignAction.decodeJsp("<% a")); L27: assertEquals("<%= a", AdminDesignAction.decodeJsp("<%= a")); L28: assertEquals("<% try{ %>", AdminDesignAction.decodeJsp("<!--TRY-->")); L29: assertEquals("<% }catch(Exception e){session.invalidate();} %>", L30: AdminDesignAction.decodeJsp("<!--CACHE_AND_SESSION_INVALIDATE-->")); L31: assertEquals("&lt;% a %&gt; %>", AdminDesignAction.decodeJsp("<% a %> %>")); L32: assertEquals("&lt;% a %&gt;...

lness.qual.Nullable; L22: L23:/** L24: * Basic sanity tests for the entire package. L25: * L26: * @author Ben Yu L27: */ L28: L29:public class PackageSanityTests extends AbstractPackageSanityTests { L30: L31: public PackageSanityTests() throws Exception { L32: DummySubscriber dummySubscriber = new DummySubscriber(); L33: setDefault(Subscriber.class, dummySubscriber.toSubscriber()); L34: setDefault(Method.class, DummySubscriber.subscriberMethod()); L35: setDefault(SubscriberExceptionContext.class,...

FuturesTransformTest extends AbstractChainedListenableFutureTest<String> { L31: private static final String RESULT_DATA = "SUCCESS"; L32: private static final UndeclaredThrowableException WRAPPED_EXCEPTION = L33: new UndeclaredThrowableException(EXCEPTION); L34: L35: @Override L36: protected ListenableFuture<String> buildChainingFuture(ListenableFuture<Integer> inputFuture) { L37: return transform(inputFuture, new ComposeFunction(), directExecutor()); L38: } L39: L40: @Override L41: protected...

* Future} need not be {@linkplain Future#isDone done}, making {@code AsyncFunction} suitable for L35: * asynchronous derivations. L36: * L37: * <p>Throwing an exception from this method is equivalent to returning a failing {@code Future}. L38: */ L39: ListenableFuture<O> apply(@ParametricNullness I input) throws Exception; L40:}...

assertEquals("7f8005ff0e", HashCode.fromBytes(data).toString()); L174: assertEquals("7f8005ff0e", base16().lowerCase().encode(data)); L175: } L176: L177: public void testHashCode_nulls() throws Exception { L178: sanityTester().testNulls(); L179: } L180: L181: public void testHashCode_equalsAndSerializable() throws Exception { L182: sanityTester().testEqualsAndSerializable(); L183: } L184: L185: public void testRoundTripHashCodeUsingBaseEncoding() { L186: HashCode hash1 = Hashing.sha1().hashString("foo",...

n(e.getCause().getMessage(), e.getCause()); L181: } L182: /* L183: * If some other exception happened, we just propagate the wrapper L184: * UncheckedExecutionException, which has the stack trace from this thread and which has its L185: * cause set to the underlying exception (which may be from another thread). If we someday L186: * learn that some other exception besides IllegalArgumentException is common, then we could L187: * add another special case to...

L303: * Releases resources held with the request or response of [exchange]. This should be called when L304: * the request completes normally or when it fails due to an exception, in which case [e] should L305: * be non-null. L306: * L307: * If the exchange was canceled or timed out, this will wrap [e] in an exception that provides L308: * that additional context. Otherwise [e] is returned as-is. L309: */ L310: internal fun <E : IOException?> messageDone( L311: exchange: Exchange,...

L32: @Override L33: protected boolean isSuppressTestCaseTransaction() { L34: return true; L35: } L36: L37: @Override L38: public void setUp() throws Exception { L39: super.setUp(); L40: groovyEngine = new GroovyEngine(); L41: } L42: L43: @Override L44: public void tearDown() throws Exception { L45: ComponentUtil.setFessConfig(null); L46: super.tearDown(); L47: } L48: L49: public void test_evaluate() { L50: final Map<String, Object>...