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: * Exception while accessing a file. L20: * L21: * @author shinsuke L22: * L23: */ L24:public class FileAccessException extends ClRuntimeException { L25: L26: private static final long serialVersionUID = 1L; L27: L28: public FileAccessException(final...

L31: * L32: * @author Nishant Thakkar L33: * @author Sven Mawson L34: */ L35:public class ExecutionListTest extends TestCase { L36: L37: private final ExecutionList list = new ExecutionList(); L38: L39: public void testRunOnPopulatedList() throws Exception { L40: Executor exec = Executors.newCachedThreadPool(); L41: CountDownLatch countDownLatch = new CountDownLatch(3); L42: list.add(new MockRunnable(countDownLatch), exec); L43: list.add(new MockRunnable(countDownLatch), exec); L44: ...

headerList = new ArrayList<>(); L171: } L172: headerList.add(new String[] { key, value }); L173: return this; L174: } L175: L176: public void connect(final Consumer<HttpURLConnection> actionListener, final Consumer<Exception> exceptionListener) { L177: final Runnable task = () -> { L178: if (paramList != null) { L179: char sp; L180: if (url.indexOf('?') == -1) { L181: sp = '?'; L182: }...

which L111: * should cause {@link #run()} to return. L112: */ L113: protected abstract void run() throws Exception; L114: L115: /** L116: * Stop the service. This method is invoked on the execution thread. L117: * L118: * <p>By default this method does nothing. L119: */ L120: // TODO: consider supporting a TearDownTestCase-like API L121: protected void shutDown() throws Exception {} L122: L123: /** L124: * Invoked to request the service to stop. L125: * L126: * <p>By default this...

try { L310: final byte[] buf = new byte[1024]; L311: while ((is.read(buf)) != -1) {} L312: } catch (final Exception ignored) {} finally { L313: try { L314: is.close(); L315: } catch (final Exception ignored) {} L316: } L317: } catch (final Exception ignored) {} L318: } L319: L320: protected void handleFileUploadException(final FileUploadException e) throws ServletException { L321: ...

listener.onOpen(this, response) L78: while (!canceled && reader.processNextEvent()) { L79: } L80: } L81: } catch (e: Exception) { L82: val exception = L83: when { L84: canceled -> IOException("canceled", e) L85: else -> e L86: } L87: listener.onFailure(this, exception, response) L88: return L89: } L90: if (canceled) { L91: listener.onFailure(this, IOException("canceled"), response) L92: ...

logged by the code under test. Example: L30: * L31: * <pre> L32: * TestLogHandler handler; L33: * L34: * protected void setUp() throws Exception { L35: * super.setUp(); L36: * handler = new TestLogHandler(); L37: * SomeClass.logger.addHandler(handler); L38: * addTearDown(new TearDown() { L39: * public void tearDown() throws Exception { L40: * SomeClass.logger.removeHandler(handler); L41: * } L42: * }); L43: * } L44: * L45: * public void test() { L46:...

@AndroidIncompatible // no FpUtils and no Math.nextDown in old versions L36: public void testNextDown() throws Exception { L37: Method jdkNextDown = getJdkNextDown(); L38: for (double d : FINITE_DOUBLE_CANDIDATES) { L39: assertEquals(jdkNextDown.invoke(null, d), DoubleUtils.nextDown(d)); L40: } L41: } L42: L43: private static Method getJdkNextDown() throws Exception { L44: try { L45: return Math.class.getMethod("nextDown", double.class); L46: } catch (NoSuchMethodException...

ultList; L39:import org.codelibs.fess.es.client.SearchEngineClient; L40:import org.codelibs.fess.es.log.exbhv.ClickLogBhv; L41:import org.codelibs.fess.es.log.exbhv.FavoriteLogBhv; L42:import org.codelibs.fess.exception.ContainerNotAvailableException; L43:import org.codelibs.fess.exception.FessSystemException; L44:import org.codelibs.fess.helper.IndexingHelper; L45:import org.codelibs.fess.helper.IntervalControlHelper; L46:import org.codelibs.fess.helper.SearchLogHelper; L47:import org.codelibs....

bucket: {}", fessConfig.getStorageBucket()); L304: } catch (final Exception e1) { L305: logger.warn("Failed to create bucket: {}", fessConfig.getStorageBucket(), e1); L306: } L307: } else if (logger.isDebugEnabled()) { L308: logger.debug("Failed to access {}", fessConfig.getStorageEndpoint(), e); L309: } L310: } catch (final Exception e) { L311: if (logger.isDebugEnabled()) { L312: logger.debug("Failed...