L18:import java.util.Locale; L19: L20:import junit.framework.TestCase; L21: L22:/** L23: * @author higa L24: * L25: */ L26:public class DecimalFormatUtilTest extends TestCase { L27: L28: /** L29: * @throws Exception L30: */ L31: public void testNormalize() throws Exception { L32: assertEquals("1", "1000.00", DecimalFormatUtil.normalize("1,000.00", Locale.JAPAN)); L33: assertEquals("2", "1000", DecimalFormatUtil.normalize("1,000", Locale.JAPAN)); L34: assertEquals("3",...

extends TestCase { L48: L49: public void testAddAndRemove_concurrentHashMap() throws Exception { L50: testAddAndRemove(new ConcurrentHashMap<String, AtomicInteger>()); L51: } L52: L53: public void testAddAndRemove_concurrentSkipListMap() throws Exception { L54: testAddAndRemove(new ConcurrentSkipListMap<String, AtomicInteger>()); L55: } L56: L57: public void testAddAndRemove_mapMakerMap() throws Exception { L58: MapMaker mapMaker = new MapMaker(); L59: // force MapMaker to use its own...

a tiny bit more testing, see {@link FileBackedOutputStreamAndroidIncompatibleTest}. L38: * L39: * @author Chris Nokleberg L40: */ L41:public class FileBackedOutputStreamTest extends IoTestCase { L42: L43: L44: public void testThreshold() throws Exception { L45: testThreshold(0, 100, true, false); L46: testThreshold(10, 100, true, false); L47: testThreshold(100, 100, true, false); L48: testThreshold(1000, 100, true, false); L49: testThreshold(0, 100, false, false); L50: testThreshold(10,...

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

is L40: * recursively bounded. L41: */ L42: public void testRecursiveWildcardSubtypeBug() throws Exception { L43: Exception e = L44: assertThrows( L45: Exception.class, () -> new RecursiveTypeBoundBugExample<>().testAllDeclarations()); L46: assertThat(e).hasCauseThat().isInstanceOf(AssertionError.class); L47: } L48: L49: @SuppressWarnings("RestrictedApiChecker") // crashes under JDK8, which EP no longer supports L50: public void testSubtypeOfInnerClass_nonStaticAnonymousClass()...

L44: @Param({"0", "1", "5", "10"}) L45: int numListeners; L46: L47: @Param({"0", "1", "5", "10"}) L48: int numThreads; L49: L50: private final Set<Thread> blockedThreads = new HashSet<>(); L51: L52: @BeforeExperiment L53: void setUp() throws Exception { L54: if (state != State.NOT_DONE && (numListeners != 0 || numThreads != 0)) { L55: throw new SkipThisScenarioException(); L56: } L57: } L58: L59: // This exclusion doesn't exclude the TOMBSTONE objects we set. So 'done' NEW futures...

UnixSocketChannel channel = serverSocketChannel.accept(); L84: return new TunnelingUnixSocket(path, channel, endpoint); L85: } catch (ClosedChannelException e) { L86: SocketException exception = new SocketException(); L87: exception.initCause(e); L88: throw exception; L89: } L90: } L91: L92: @Override public void close() throws IOException { L93: serverSocketChannel.close(); L94: } L95: } L96:}...

org.junit.Assert.assertThat; L20: L21:import java.util.Set; L22: L23:import org.junit.Test; L24: L25:/** L26: * @author higa L27: */ L28:public class CaseInsensitiveSetTest { L29: L30: /** L31: * @throws Exception L32: */ L33: @Test L34: public void testContains() throws Exception { L35: final Set<String> set = new CaseInsensitiveSet(); L36: set.add("one"); L37: assertThat(set.contains("ONE"), is(true)); L38: } L39: L40:}...

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.timer.SystemMonitorTarget; L35:import org.codelibs.fess.util.ComponentUtil; L36:import org.codelibs.fess.util.SystemUtil; L37:import org.kohsuke.args4j.CmdLineException; L38:import org...

"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.fess.exception; L17: L18:public class WebApiException extends FessSystemException { L19: L20: private static final long serialVersionUID = 1L; L21: L22: private final int statusCode; L23: L24: public int getStatusCode() { L25: return statusCode;...