"AS IS" BASIS, L12: * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, L13: * either express or implied. See the License for the specific language L14: * governing permissions and limitations under the License. L15: */ L16:package org.codelibs.core.exception; L17: L18:/** L19: * Wrapped InterruptedException. L20: * L21: * @author shinsuke L22: * L23: */ L24:public class InterruptedRuntimeException extends RuntimeException { L25: L26: private static final long serialVersionUID = 1L; L27: L28: public...

after close`() { L110: val deflater = MessageDeflater(true) L111: deflater.close() L112: L113: assertFailsWith<Exception> { L114: deflater.deflate("Hello deflate!".encodeUtf8()) L115: } L116: } L117: L118: @Test fun `inflate after close`() { L119: val inflater = MessageInflater(false) L120: L121: inflater.close() L122: L123: assertFailsWith<Exception> { L124: inflater.inflate("f240e30300".decodeHex()) L125: } L126: } L127: L128: /** L129: * Test for an [EOFException]...

getFileConfig(form).ifPresent(entity -> { L226: try { L227: fileConfigService.store(entity); L228: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L229: } catch (final Exception e) { L230: logger.warn("Failed to process a request.", e); L231: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L232: this::asEditHtml);...

getWebConfig(form).ifPresent(entity -> { L234: try { L235: webConfigService.store(entity); L236: saveInfo(messages -> messages.addSuccessCrudCreateCrudTable(GLOBAL)); L237: } catch (final Exception e) { L238: logger.warn("Failed to process a request.", e); L239: throwValidationError(messages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, buildThrowableMessage(e)), L240: this::asEditHtml);...

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",...

irection.FessConfig; L25:import org.codelibs.fess.unit.UnitFessTestCase; L26:import org.codelibs.fess.util.ComponentUtil; L27: L28:public class LdapManagerTest extends UnitFessTestCase { L29: L30: @Override L31: public void setUp() throws Exception { L32: super.setUp(); L33: ComponentUtil.register(new SystemHelper(), "systemHelper"); L34: } L35: L36: @SuppressWarnings("serial") L37: public void test_getSearchRoleName() { L38: ComponentUtil.setFessConfig(new Fe...

org.apache.lucene.search.Query; L22:import org.apache.lucene.search.TermRangeQuery; L23:import org.apache.lucene.util.BytesRef; L24:import org.codelibs.fess.Constants; L25:import org.codelibs.fess.entity.QueryContext; L26:import org.codelibs.fess.exception.InvalidQueryException; L27:import org.codelibs.fess.mylasta.direction.FessConfig; L28:import org.codelibs.fess.util.ComponentUtil; L29:import org.lastaflute.core.message.UserMessages; L30:import org.opensearch.index.query.QueryBuilder; L31:import...

limitations under the License. L15: */ L16:package org.codelibs.fess.api; L17: L18:import java.io.IOException; L19:import java.io.OutputStreamWriter; L20:import java.io.PrintWriter; L21:import java.util.Locale; L22: L23:import org.codelibs.core.exception.IORuntimeException; L24:import org.codelibs.fess.Constants; L25:import org.lastaflute.web.util.LaRequestUtil; L26:import org.lastaflute.web.util.LaResponseUtil; L27: L28:import jakarta.servlet.http.HttpServletRequest; L29:import jakarta.servlet....

/** Guarded by this. */ L43: private final Map<ByteString, Listener> listeners = new LinkedHashMap<>(); L44: L45: public OAuthSessionFactory(SlackApi slackApi) { L46: this.slackApi = slackApi; L47: } L48: L49: public void start() throws Exception { L50: if (mockWebServer != null) throw new IllegalStateException(); L51: L52: mockWebServer = new MockWebServer(); L53: mockWebServer.setDispatcher(this); L54: mockWebServer.start(slackApi.port); L55: } L56: L57: public HttpUrl ne...

; L92: final Thread interruptingThread = new Thread(interruptingTask); L93: interruptingThread.start(); L94: tearDownAccepter.addTearDown( L95: new TearDown() { L96: @Override L97: public void tearDown() throws Exception { L98: interruptingTask.stopInterrupting(); L99: interruptingThread.interrupt(); L100: joinUninterruptibly(interruptingThread, 2500, MILLISECONDS); L101: Thread.interrupted(); L102: if (inte...