项目:micrometer
文件:TomcatMetricsTest.java
@Test
void mbeansAvailableAfterBinder() throws LifecycleException,InterruptedException {
TomcatMetrics.monitor(registry,null);
CountDownLatch latch = new CountDownLatch(1);
registry.config().onMeteradded(m -> {
if(m.getId().getName().equals("tomcat.global.received"))
latch.countDown();
});
Tomcat server = new Tomcat();
try {
StandardHost host = new StandardHost();
host.setName("localhost");
server.setHost(host);
server.setPort(61000);
server.start();
assertthat(latch.await(10,TimeUnit.SECONDS)).isTrue();
assertthat(registry.find("tomcat.global.received").functionCounter()).isNotNull();
} finally {
server.stop();
server.destroy();
}
}
项目:micrometer
文件:TomcatMetricsTest.java
@Test
void mbeansAvailableBeforeBinder() throws LifecycleException {
Tomcat server = new Tomcat();
try {
StandardHost host = new StandardHost();
host.setName("localhost");
server.setHost(host);
server.setPort(61000);
server.start();
TomcatMetrics.monitor(registry,null);
assertthat(registry.find("tomcat.global.received").functionCounter()).isNotNull();
} finally {
server.stop();
server.destroy();
}
}
项目:tomcat7
文件:TestReplicatedContext.java
@Test
public void testBug57425() throws LifecycleException,IOException {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass(ReplicatedContext.class.getName());
}
File root = new File("test/webapp-3.0");
Context context = tomcat.addWebapp(host,"",root.getAbsolutePath());
Tomcat.addServlet(context,"test",new AccessContextServlet());
context.addServletMapping("/access","test");
tomcat.start();
ByteChunk result = getUrl("http://localhost:" + getPort() + "/access");
Assert.assertEquals("OK",result.toString());
}
项目:tomcat7
文件:TestTomcat.java
@Test
public void testGetbrokenContextPerAddWepapp() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass("InvalidContextClassName");
}
try {
File appFile = new File("test/deployment/context.war");
tomcat.addWebapp(null,"/test",appFile.getAbsolutePath());
fail();
} catch (IllegalArgumentException e) {
// OK
}
}
项目:tomcat7
文件:TestTomcat.java
@Test
public void testGetCustomContextPerAddWebappWithNullHost() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass(ReplicatedContext.class
.getName());
}
File appFile = new File("test/deployment/context.war");
Context context = tomcat.addWebapp(null,appFile.getAbsolutePath());
assertEquals(ReplicatedContext.class.getName(),context.getClass()
.getName());
}
项目:tomcat7
文件:TestTomcat.java
@Test
public void testGetCustomContextPerAddWebappWithHost() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass(ReplicatedContext.class
.getName());
}
File appFile = new File("test/deployment/context.war");
Context context = tomcat.addWebapp(host,context.getClass()
.getName());
}
项目:tomcat7
文件:TestTomcat.java
@Test
public void testGetbrokenContextPerAddContext() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass("InvalidContextClassName");
}
// No file system docBase required
try {
tomcat.addContext(null,null);
fail();
} catch (IllegalArgumentException e) {
// OK
}
}
private void doTestUnpackWAR(boolean unpackWARs,boolean unpackWAR,boolean external,boolean resultDir) throws Exception {
Tomcat tomcat = getTomcatInstance();
StandardHost host = (StandardHost) tomcat.getHost();
host.setUnpackWARs(unpackWARs);
tomcat.start();
File war;
if (unpackWAR) {
war = createWar(WAR_XML_UNPACKWAR_TRUE_SOURCE,!external);
} else {
war = createWar(WAR_XML_UNPACKWAR_FALSE_SOURCE,!external);
}
if (external) {
createXmlInConfigBaseForExternal(war);
}
host.backgroundProcess();
File dir = new File(host.getAppBase(),APP_NAME.getBaseName());
Assert.assertEquals(
Boolean.valueOf(resultDir),Boolean.valueOf(dir.isDirectory()));
}
private void testbrokenAppWithAntiLocking(boolean unpackWARs)
throws Exception {
Tomcat tomcat = getTomcatInstance();
StandardHost host = (StandardHost) tomcat.getHost();
host.setUnpackWARs(unpackWARs);
File war = createWar(WAR_broKEN_SOURCE,false);
createXmlInConfigBaseForExternal(war,true);
File dir = new File(getAppBaseFile(host),APP_NAME.getBaseName());
tomcat.start();
// Simulate deploy on start-up
tomcat.getHost().backgroundProcess();
Assert.assertTrue(war.isFile());
if (unpackWARs) {
Assert.assertTrue(dir.isDirectory());
}
}
@Test
public void testSetContextClassName() throws Exception {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
StandardHost standardHost = (StandardHost) host;
standardHost.setContextClass(TesterContext.class.getName());
}
// copy the WAR file
File war = new File(getAppBaseFile(host),APP_NAME.getBaseName() + ".war");
copy(WAR_XML_SOURCE,war);
// Deploy the copied war
tomcat.start();
host.backgroundProcess();
// Check the Context class
Context ctxt = (Context) host.findChild(APP_NAME.getName());
Assert.assertTrue(ctxt instanceof TesterContext);
}
项目:lams
文件:Tomcat.java
public StandardContext addWebapp(StandardHost host,String url,String path)
throws servletexception {
silence(url);
StandardContext ctx = new StandardContext();
ctx.setPath( url );
ctx.setDocBase(path);
if (defaultRealm == null) {
initSimpleAuth();
}
ctx.setRealm(defaultRealm);
initWebappDefaults(ctx);
ContextConfig ctxCfg = new ContextConfig();
ctx.addLifecycleListener( ctxCfg );
// prevent it from looking ( if it finds one - it'll have dup error )
ctxCfg.setDefaultWebXml("org/apache/catalin/startup/NO_DEFAULT_XML");
if (host == null) {
host = getHost();
}
host.addChild(ctx);
return ctx;
}
项目:lams
文件:StandardHostMBean.java
/**
* Return the MBean Names of the Valves assoicated with this Host
*
* @exception Exception if an MBean cannot be created or registered
*/
public String [] getValves()
throws Exception {
Registry registry = MBeanUtils.createRegistry();
StandardHost host = (StandardHost) this.resource;
String mname = MBeanUtils.createManagedname(host);
ManagedBean managed = registry.findManagedBean(mname);
String domain = null;
if (managed != null) {
domain = managed.getDomain();
}
if (domain == null)
domain = mserver.getDefaultDomain();
Valve [] valves = host.getValves();
String [] mbeanNames = new String[valves.length];
for (int i = 0; i < valves.length; i++) {
mbeanNames[i] =
MBeanUtils.createObjectName(domain,valves[i]).toString();
}
return mbeanNames;
}
项目:lams
文件:Mbeanfactory.java
/**
* Remove an existing Host.
*
* @param name MBean Name of the comonent to remove
*
* @exception Exception if a component cannot be removed
*/
public void removeHost(String name) throws Exception {
// Acquire a reference to the component to be removed
ObjectName oname = new ObjectName(name);
String hostName = oname.getKeyProperty("host");
Service service = getService(oname);
Engine engine = (Engine) service.getContainer();
Host host = (Host) engine.findChild(hostName);
// Remove this component from its parent component
if(host!=null) {
if(host instanceof StandardHost)
((StandardHost)host).destroy();
else
engine.removeChild(host);
}
}
项目:jerrydog
文件:StandardHostMBean.java
/**
* Return the MBean Names of the Valves assoicated with this Host
*
* @exception Exception if an MBean cannot be created or registered
*/
public String [] getValves()
throws Exception {
Registry registry = MBeanUtils.createRegistry();
StandardHost host = (StandardHost) this.resource;
String mname = MBeanUtils.createManagedname(host);
ManagedBean managed = registry.findManagedBean(mname);
String domain = null;
if (managed != null) {
domain = managed.getDomain();
}
if (domain == null)
domain = mserver.getDefaultDomain();
Valve [] valves = host.getValves();
String [] mbeanNames = new String[valves.length];
for (int i = 0; i < valves.length; i++) {
mbeanNames[i] =
MBeanUtils.createObjectName(domain,valves[i]).toString();
}
return mbeanNames;
}
项目:apache-tomcat-7.0.73-with-comment
文件:TestReplicatedContext.java
@Test
public void testBug57425() throws LifecycleException,result.toString());
}
项目:apache-tomcat-7.0.73-with-comment
文件:TestTomcat.java
@Test
public void testGetbrokenContextPerAddWepapp() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass("InvalidContextClassName");
}
try {
File appFile = new File("test/deployment/context.war");
tomcat.addWebapp(null,appFile.getAbsolutePath());
fail();
} catch (IllegalArgumentException e) {
// OK
}
}
项目:apache-tomcat-7.0.73-with-comment
文件:TestTomcat.java
@Test
public void testGetCustomContextPerAddWebappWithNullHost() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass(ReplicatedContext.class
.getName());
}
File appFile = new File("test/deployment/context.war");
Context context = tomcat.addWebapp(null,context.getClass()
.getName());
}
项目:apache-tomcat-7.0.73-with-comment
文件:TestTomcat.java
@Test
public void testGetCustomContextPerAddWebappWithHost() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass(ReplicatedContext.class
.getName());
}
File appFile = new File("test/deployment/context.war");
Context context = tomcat.addWebapp(host,context.getClass()
.getName());
}
项目:apache-tomcat-7.0.73-with-comment
文件:TestTomcat.java
@Test
public void testGetbrokenContextPerAddContext() {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
((StandardHost) host).setContextClass("InvalidContextClassName");
}
// No file system docBase required
try {
tomcat.addContext(null,null);
fail();
} catch (IllegalArgumentException e) {
// OK
}
}
private void doTestUnpackWAR(boolean unpackWARs,Boolean.valueOf(dir.isDirectory()));
}
private void testbrokenAppWithAntiLocking(boolean unpackWARs)
throws Exception {
Tomcat tomcat = getTomcatInstance();
StandardHost host = (StandardHost) tomcat.getHost();
host.setUnpackWARs(unpackWARs);
File war = createWar(WAR_broKEN_SOURCE,APP_NAME.getBaseName());
tomcat.start();
// Simulate deploy on start-up
tomcat.getHost().backgroundProcess();
Assert.assertTrue(war.isFile());
if (unpackWARs) {
Assert.assertTrue(dir.isDirectory());
}
}
@Test
public void testSetContextClassName() throws Exception {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
StandardHost standardHost = (StandardHost) host;
standardHost.setContextClass(TesterContext.class.getName());
}
// copy the WAR file
File war = new File(getAppBaseFile(host),war);
// Deploy the copied war
tomcat.start();
host.backgroundProcess();
// Check the Context class
Context ctxt = (Context) host.findChild(APP_NAME.getName());
Assert.assertTrue(ctxt instanceof TesterContext);
}
项目:lazycat
文件:ManagerServlet.java
/**
* Find potential memory leaks caused by web application reload.
*/
protected void findleaks(boolean statusLine,PrintWriter writer,StringManager smClient) {
if (!(host instanceof StandardHost)) {
writer.println(smClient.getString("managerServlet.findleaksFail"));
return;
}
String[] results = ((StandardHost) host).findReloadedContextMemoryLeaks();
if (results.length > 0) {
if (statusLine) {
writer.println(smClient.getString("managerServlet.findleaksList"));
}
for (String result : results) {
if ("".equals(result)) {
result = "/";
}
writer.println(result);
}
} else if (statusLine) {
writer.println(smClient.getString("managerServlet.findleaksNone"));
}
}
项目:lazycat
文件:CatalinaUtil.java
public static int getPort(Host h) {
int port = -1;
StandardHost host = (StandardHost) h;
CatalinaUtil.host = (StandardHost) h;
StandardEngine se = (StandardEngine) host.getParent();
StandardService ss = (StandardService) se.getService();
Connector[] cs = ss.findConnectors();
for (Connector c : cs) {
if (c.getProtocolHandlerClassName().contains("Http11Protocol"))
port = c.getPort();
}
return port;
}
项目:tomcat-extension-samlsso
文件:SSOUtilsTest.java
@Test(description = "Tests the construction of Application Server URL for a sample request")
public void testConstructionOfApplicationServerURL() {
Request request = new Request();
Connector connector = new Connector();
connector.setProtocol(TestConstants.SSL_PROTOCOL);
connector.setPort(TestConstants.SSL_PORT);
connector.setScheme(TestConstants.SSL_PROTOCOL);
Engine engine = new StandardEngine();
Service service = new StandardService();
engine.setService(service);
engine.getService().addConnector(connector);
Host host = new StandardHost();
host.setName(TestConstants.DEFAULT_TOMCAT_HOST);
request.getMappingData().host = host;
host.setParent(engine);
Optional<String> actual = SSOUtils.constructApplicationServerURL(request);
if (actual.isPresent()) {
Assert.assertEquals(actual.get(),TestConstants.DEFAULT_APPLICATION_SERVER_URL);
} else {
Assert.fail();
}
}
项目:tomcat-extension-samlsso
文件:SSOUtilsTest.java
@Test(description = "Tests the construction of Application Server URL for no SSL/TLS Connector")
public void testConstructionOfApplicationServerURLWithNoConnector() {
Request request = new Request();
Engine engine = new StandardEngine();
Service service = new StandardService();
engine.setService(service);
Host host = new StandardHost();
host.setName(TestConstants.DEFAULT_TOMCAT_HOST);
request.getMappingData().host = host;
host.setParent(engine);
Optional<String> actual = SSOUtils.constructApplicationServerURL(request);
Assert.assertTrue(!actual.isPresent());
}
项目:tomcat-extension-samlsso
文件:SAML2SSOManagerTest.java
private void prepareCatalinaComponents() {
engine = new StandardEngine();
host = new StandardHost();
fooContext = new StandardContext();
barContext = new StandardContext();
Connector connector = new Connector();
connector.setProtocol(TestConstants.SSL_PROTOCOL);
connector.setPort(TestConstants.SSL_PORT);
connector.setScheme(TestConstants.SSL_PROTOCOL);
Service service = new StandardService();
engine.setService(service);
engine.getService().addConnector(connector);
host.setAppBase(TestConstants.WEB_APP_BASE);
host.setName(TestConstants.DEFAULT_TOMCAT_HOST);
host.setParent(engine);
fooContext.setParent(host);
fooContext.setDocBase(TestConstants.FOO_CONTEXT);
barContext.setParent(host);
barContext.setDocBase(TestConstants.BAR_CONTEXT);
}
项目:elpi
文件:CatalinaContainer.java
protected Host createHost(Engine engine,String hostName) throws ContainerException {
Debug.logInfo("createHost(" + engine + "," + hostName + ")",module);
if (tomcat == null) {
throw new ContainerException("Cannot create Host without Tomcat instance!");
}
Host host = new StandardHost();
host.setAppBase(CATALINA_HOSTS_HOME);
host.setName(hostName);
host.setDeployOnStartup(false);
host.setBackgroundProcessorDelay(5);
host.setAutoDeploy(false);
host.setRealm(engine.getRealm());
hosts.put(engine.getName() + hostName,host);
return host;
}
项目:o3erp
文件:CatalinaContainer.java
protected Host createHost(Engine engine,host);
return host;
}
private void doTestUnpackWAR(boolean unpackWARs,Boolean.valueOf(dir.isDirectory()));
}
private void testbrokenAppWithAntiLocking(boolean unpackWARs)
throws Exception {
Tomcat tomcat = getTomcatInstance();
StandardHost host = (StandardHost) tomcat.getHost();
host.setUnpackWARs(unpackWARs);
File war = createWar(WAR_broKEN_SOURCE,APP_NAME.getBaseName());
tomcat.start();
// Simulate deploy on start-up
tomcat.getHost().backgroundProcess();
Assert.assertTrue(war.isFile());
if (unpackWARs) {
Assert.assertTrue(dir.isDirectory());
}
}
@Test
public void testSetContextClassName() throws Exception {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
StandardHost standardHost = (StandardHost) host;
standardHost.setContextClass(TesterContext.class.getName());
}
// copy the WAR file
File war = new File(getAppBaseFile(host),war);
// Deploy the copied war
tomcat.start();
host.backgroundProcess();
// Check the Context class
Context ctxt = (Context) host.findChild(APP_NAME.getName());
Assert.assertTrue(ctxt instanceof TesterContext);
}
private void doTestUnpackWAR(boolean unpackWARs,Boolean.valueOf(dir.isDirectory()));
}
private void testbrokenAppWithAntiLocking(boolean unpackWARs)
throws Exception {
Tomcat tomcat = getTomcatInstance();
StandardHost host = (StandardHost) tomcat.getHost();
host.setUnpackWARs(unpackWARs);
File war = createWar(WAR_broKEN_SOURCE,APP_NAME.getBaseName());
tomcat.start();
// Simulate deploy on start-up
tomcat.getHost().backgroundProcess();
Assert.assertTrue(war.isFile());
if (unpackWARs) {
Assert.assertTrue(dir.isDirectory());
}
}
@Test
public void testSetContextClassName() throws Exception {
Tomcat tomcat = getTomcatInstance();
Host host = tomcat.getHost();
if (host instanceof StandardHost) {
StandardHost standardHost = (StandardHost) host;
standardHost.setContextClass(TesterContext.class.getName());
}
// copy the WAR file
File war = new File(getAppBaseFile(host),war);
// Deploy the copied war
tomcat.start();
host.backgroundProcess();
// Check the Context class
Context ctxt = (Context) host.findChild(APP_NAME.getName());
Assert.assertTrue(ctxt instanceof TesterContext);
}
项目:carbon-commons
文件:HostUtil.java
/**
* add host to engine.
*
* @param hostName
* name of the host
* @return will return the added host of Engine
*/
public static Host addHostToEngine(String hostName) {
String hostBaseDir = CarbonUtils.getCarbonRepository() + "/"
+ UrlMapperConstants.HostProperties.WEB_APPS + "/";
CarbonTomcatService carbonTomcatService = DataHolder.getInstance().getCarbonTomcatService();
// adding virtual host to tomcat engine
Engine engine = carbonTomcatService.getTomcat().getEngine();
StandardHost host = new StandardHost();
host.setAppBase(hostBaseDir);
host.setName(hostName);
host.setUnpackWARs(false);
host.addValve(new CarbonContextCreatorValve());
host.addValve(new CompositeValve());
engine.addChild(host);
log.info("host added to the tomcat: " + host);
return host;
}
项目:product-as
文件:SSOUtilsTest.java
@Test(description = "Tests the construction of Application Server URL for a sample request")
public void testConstructionOfApplicationServerURL() {
Request request = new Request();
Connector connector = new Connector();
connector.setProtocol(TestConstants.SSL_PROTOCOL);
connector.setPort(TestConstants.SSL_PORT);
connector.setScheme(TestConstants.SSL_PROTOCOL);
Engine engine = new StandardEngine();
Service service = new StandardService();
engine.setService(service);
engine.getService().addConnector(connector);
Host host = new StandardHost();
host.setName(TestConstants.DEFAULT_TOMCAT_HOST);
request.getMappingData().host = host;
host.setParent(engine);
Optional<String> actual = SSOUtils.constructApplicationServerURL(request);
if (actual.isPresent()) {
Assert.assertEquals(actual.get(),TestConstants.DEFAULT_APPLICATION_SERVER_URL);
} else {
Assert.fail();
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。