/*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
*
* Copyright 1997-2007 Sun Microsystems, Inc. All rights reserved.
*
* Portions Copyright Apache Software Foundation.
*
* The contents of this file are subject to the terms of either the GNU
* General Public License Version 2 only ("GPL") or the Common Development
* and Distribution License("CDDL") (collectively, the "License"). You
* may not use this file except in compliance with the License. You can obtain
* a copy of the License at https://glassfish.dev.java.net/public/CDDL+GPL.html
* or glassfish/bootstrap/legal/LICENSE.txt. See the License for the specific
* language governing permissions and limitations under the License.
*
* When distributing the software, include this License Header Notice in each
* file and include the License file at glassfish/bootstrap/legal/LICENSE.txt.
* Sun designates this particular file as subject to the "Classpath" exception
* as provided by Sun in the GPL Version 2 section of the License file that
* accompanied this code. If applicable, add the following below the License
* Header, with the fields enclosed by brackets [] replaced by your own
* identifying information: "Portions Copyrighted [year]
* [name of copyright owner]"
*
* Contributor(s):
*
* If you wish your version of this file to be governed by only the CDDL or
* only the GPL Version 2, indicate your decision by adding "[Contributor]
* elects to include this software in this distribution under the [CDDL or GPL
* Version 2] license." If you don't indicate a single choice of license, a
* recipient has the option to distribute your version of this file under
* either the CDDL, the GPL Version 2 or to extend the choice of license to
* its licensees as provided above. However, if you add GPL Version 2 code
* and therefore, elected the GPL Version 2 license, then the option applies
* only if the new code is made subject to such option by the copyright
* holder.
*/
package org.apache.coyote.tomcat5;
import java.util.Iterator;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import javax.management.MBeanServer;
import javax.management.MBeanServerNotification;
// START SJSAS 6290785
import javax.management.MBeanAttributeInfo;
import javax.management.MBeanInfo;
// END SJSAS 6290785
import javax.management.Notification;
import javax.management.NotificationListener;
// START SJSAS 6313044
import javax.management.NotificationFilter;
// END SJSAS 6313044
import javax.management.ObjectInstance;
import javax.management.ObjectName;
import com.sun.org.apache.commons.logging.Log;
import com.sun.org.apache.commons.logging.LogFactory;
import com.sun.org.apache.commons.modeler.Registry;
import org.apache.catalina.Host;
import org.apache.catalina.core.StandardContext;
import org.apache.catalina.core.StandardHost;
import org.apache.catalina.core.StandardWrapper;
import org.apache.catalina.util.RequestUtil;
import org.apache.tomcat.util.http.mapper.Mapper;
import org.apache.tomcat.util.res.StringManager;
/**
* Mapper listener.
*
* @author Remy Maucherat
* @author Costin Manolache
*/
public class MapperListener
/* SJSAS 6313044
implements NotificationListener
*/
// START SJSAS 6313044
implements NotificationListener, NotificationFilter
// END SJSAS 6313044
{
private static Log log = LogFactory.getLog(MapperListener.class);
// ----------------------------------------------------- Instance Variables
/**
* Associated mapper.
*/
protected Mapper mapper = null;
/**
* MBean server.
*/
protected MBeanServer mBeanServer = null;
/**
* The string manager for this package.
*/
private StringManager sm =
StringManager.getManager(Constants.Package);
// It should be null - and fail if not set
private String domain="*";
private String engine="*";
// BEGIN S1AS 5000999
private int port;
private String defaultHost;
private ConcurrentHashMap<ObjectName,int[]> virtualServerPorts;
// END S1AS 5000999
// START SJSAS 6313044
private String myInstance;
// END SJSAS 6313044
// ----------------------------------------------------------- Constructors
/**
* Create mapper listener.
*/
public MapperListener(Mapper mapper) {
this.mapper = mapper;
virtualServerPorts = new ConcurrentHashMap<ObjectName,int[]>();
}
// --------------------------------------------------------- Public Methods
public String getDomain() {
return domain;
}
public void setDomain(String domain) {
this.domain = domain;
}
public String getEngine() {
return engine;
}
public void setEngine(String engine) {
this.engine = engine;
}
// BEGIN S1AS 5000999
public int getPort() {
return port;
}
public void setPort(int port) {
this.port = port;
}
public String getDefaultHost() {
return defaultHost;
}
public void setDefaultHost(String defaultHost) {
this.defaultHost = defaultHost;
}
// END S1AS 5000999
/**
* Initialize associated mapper.
*/
public void init() {
// START SJSAS 6313044
myInstance = System.getProperty("com.sun.aas.instanceName");
// END SJSAS 6313044
if (defaultHost != null) {
mapper.setDefaultHostName(defaultHost);
}
try {
mBeanServer = Registry.getServer();
// Query hosts
String onStr = domain + ":type=Host,*";
ObjectName objectName = new ObjectName(onStr);
Set set = mBeanServer.queryMBeans(objectName, null);
Iterator iterator = set.iterator();
while (iterator.hasNext()) {
ObjectInstance oi = (ObjectInstance) iterator.next();
registerHost(oi.getObjectName());
}
// Query contexts
onStr = domain + ":j2eeType=WebModule,*";
objectName = new ObjectName(onStr);
set = mBeanServer.queryMBeans(objectName, null);
iterator = set.iterator();
while (iterator.hasNext()) {
ObjectInstance oi = (ObjectInstance) iterator.next();
registerContext(oi.getObjectName());
}
// Query wrappers
onStr = domain + ":j2eeType=Servlet,*";
objectName = new ObjectName(onStr);
set = mBeanServer.queryMBeans(objectName, null);
iterator = set.iterator();
while (iterator.hasNext()) {
ObjectInstance oi = (ObjectInstance) iterator.next();
registerWrapper(oi.getObjectName());
}
onStr = "JMImplementation:type=MBeanServerDelegate";
objectName = new ObjectName(onStr);
/* SJSAS 6313044
mBeanServer.addNotificationListener(objectName, this, null, null);
*/
// START SJSAS 6313044
mBeanServer.addNotificationListener(objectName, this, this, null);
// END SJSAS 6313044
} catch (Exception e) {
log.warn("Error registering contexts",e);
}
}
// START SJSAS 6313044
// ------------------------------------------ NotificationFilter Methods
/**
* Filters out any notifications corresponding to MBeans belonging to
* a different server instance than the server instance on which this
* MapperListener is running.
*
* @param notification The notification to be examined
*
* @return true if the notification needs to be sent to this
* MapperListener, false otherwise.
*/
public boolean isNotificationEnabled(Notification notification) {
if (notification instanceof MBeanServerNotification) {
ObjectName objectName =
((MBeanServerNotification) notification).getMBeanName();
String otherDomain = objectName.getDomain();
if (this.domain != null && !(this.domain.equals(otherDomain))) {
return false;
}
String otherInstance = objectName.getKeyProperty("J2EEServer");
if (myInstance != null && otherInstance != null
&& !otherInstance.equals(myInstance)) {
return false;
}
}
return true;
}
// END SJSAS 6313044
// ------------------------------------------- NotificationListener Methods
public void handleNotification(Notification notification,
java.lang.Object handback) {
if (notification instanceof MBeanServerNotification) {
ObjectName objectName =
((MBeanServerNotification) notification).getMBeanName();
String j2eeType = objectName.getKeyProperty("j2eeType");
String engineName = null;
if (j2eeType != null) {
if ((j2eeType.equals("WebModule")) ||
(j2eeType.equals("Servlet"))) {
if (mBeanServer.isRegistered(objectName)) {
/* SJSAS 6290785
try {
engineName = (String)
mBeanServer.getAttribute(objectName, "engineName");
} catch (Exception e) {
// Ignore
}
*/
// START SJSAS 6290785
MBeanInfo info = null;
try {
info = mBeanServer.getMBeanInfo(objectName);
} catch (Exception e) {
// Ignore
}
if (info != null) {
boolean hasEngineNameAttribute = false;
MBeanAttributeInfo[] attrInfo = info.getAttributes();
if (attrInfo != null) {
for (int i=0; i<attrInfo.length; i++) {
if ("engineName".equals(
attrInfo[i].getName())) {
hasEngineNameAttribute = true;
break;
}
}
}
if (hasEngineNameAttribute) {
try {
engineName = (String)
mBeanServer.getAttribute(objectName,
"engineName");
} catch (Exception e) {
// Ignore
}
}
}
// END SJSAS 6290785
}
}
}
// At deployment time, engineName is always = null.
if ( (!"*".equals(domain)) &&
( !domain.equals(objectName.getDomain()) ) &&
( (!domain.equals(engineName) ) &&
(engineName != null) ) ) {
return;
}
if (log.isDebugEnabled()) {
log.debug( "Handle " + objectName );
}
if (notification.getType().equals
(MBeanServerNotification.REGISTRATION_NOTIFICATION)) {
String type=objectName.getKeyProperty("type");
if( "Host".equals( type )) {
try {
registerHost(objectName);
} catch (Exception e) {
log.warn("Error registering Host " + objectName, e);
}
}
if (j2eeType != null) {
if (j2eeType.equals("WebModule")) {
try {
registerContext(objectName);
} catch (Throwable t) {
log.warn("Error registering Context " + objectName,t);
}
} else if (j2eeType.equals("Servlet")) {
try {
registerWrapper(objectName);
} catch (Throwable t) {
log.warn("Error registering Wrapper " + objectName,t);
}
}
}
} else if (notification.getType().equals
(MBeanServerNotification.UNREGISTRATION_NOTIFICATION)) {
String type=objectName.getKeyProperty("type");
if( "Host".equals( type )) {
try {
unregisterHost(objectName);
} catch (Exception e) {
log.warn("Error unregistering Host " + objectName,e);
}
}
if (j2eeType != null) {
if (j2eeType.equals("WebModule")) {
try {
unregisterContext(objectName);
} catch (Throwable t) {
log.warn("Error unregistering webapp " + objectName,t);
}
}
}
}
}
}
// ------------------------------------------------------ Protected Methods
private void registerEngine()
throws Exception
{
ObjectName engineName = new ObjectName
(domain + ":type=Engine");
if ( ! mBeanServer.isRegistered(engineName)) return;
// BEGIN S1AS 5000999
/*
String defaultHost =
(String) mBeanServer.getAttribute(engineName, "defaultHost");
*/
if (defaultHost == null) {
defaultHost =
(String) mBeanServer.getAttribute(engineName, "defaultHost");
}
// END S1AS 5000999
ObjectName hostName = new ObjectName
(domain + ":type=Host," + "host=" + defaultHost);
if (!mBeanServer.isRegistered(hostName)) {
// Get the hosts' list
String onStr = domain + ":type=Host,*";
ObjectName objectName = new ObjectName(onStr);
Set set = mBeanServer.queryMBeans(objectName, null);
Iterator iterator = set.iterator();
String[] aliases;
boolean isRegisteredWithAlias = false;
while (iterator.hasNext()) {
if (isRegisteredWithAlias) break;
ObjectInstance oi = (ObjectInstance) iterator.next();
hostName = oi.getObjectName();
aliases = (String[])
mBeanServer.invoke(hostName, "findAliases", null, null);
for (int i=0; i < aliases.length; i++){
if (aliases[i].equalsIgnoreCase(defaultHost)){
isRegisteredWithAlias = true;
break;
}
}
}
if (!isRegisteredWithAlias)
log.warn("Unknown default host: " + defaultHost);
}
// This should probably be called later
if( defaultHost != null ) {
mapper.setDefaultHostName(defaultHost);
}
}
/**
* Register host.
*/
public void registerHost(ObjectName objectName)
throws Exception {
String name=objectName.getKeyProperty("host");
if( name != null ) {
Host host = (Host) mBeanServer.invoke(objectName,
"findMappingObject",
null,
null);
if (host == null) {
throw new Exception("No host registered for " + objectName);
}
// BEGIN S1AS 5000999
/*
* Register the given Host only if one of its associated port
* numbers matches the port number of this MapperListener
*/
int[] ports = ((StandardHost) host).findPorts();
boolean portMatch = false;
if (ports != null) {
for (int i=0; i<ports.length; i++) {
if (ports[i] == this.port) {
portMatch = true;
break;
}
}
}
if (!portMatch) {
if (log.isDebugEnabled()) {
log.debug("HTTP listener with port " + port
+ " ignoring registration of host with object "
+ "name " + objectName + ", because none of the "
+ "host's associated HTTP listeners matches "
+ "this port");
}
return;
}
if (ports != null) {
virtualServerPorts.put(objectName, ports);
}
// END S1AS 5000999
String[] aliases = host.findAliases();
mapper.addHost(name, aliases, host);
}
}
/**
* Unregister host.
*/
public void unregisterHost(ObjectName objectName)
throws Exception {
String name=objectName.getKeyProperty("host");
// BEGIN S1AS 5000999
if (name != null) {
int[] ports = virtualServerPorts.get(objectName);
boolean portMatch = false;
if (ports != null) {
virtualServerPorts.remove(objectName);
for (int i=0; i<ports.length; i++) {
if (ports[i] == this.port) {
portMatch = true;
break;
}
}
}
if (!portMatch) {
return;
}
}
// END S1AS 5000999
mapper.removeHost(name);
}
/**
* Register context.
*/
private void registerContext(ObjectName objectName)
throws Exception {
StandardContext context = (StandardContext)
mBeanServer.invoke(objectName, "findMappingObject", null, null);
if (context == null) {
throw new Exception("No context registered for " + objectName);
}
String name = objectName.getKeyProperty("name");
// If the domain is the same with ours or the engine
// name attribute is the same... - then it's ours
String targetDomain=objectName.getDomain();
if( ! domain.equals( targetDomain )) {
targetDomain = context.getEngineName();
if( ! domain.equals( targetDomain )) {
// not ours
return;
}
}
String hostName = null;
String contextName = null;
if (name.startsWith("//")) {
name = name.substring(2);
}
int slash = name.indexOf("/");
if (slash != -1) {
hostName = name.substring(0, slash);
contextName = name.substring(slash);
contextName = RequestUtil.URLDecode(contextName , "UTF-8");
} else {
return;
}
// Special case for the root context
if (contextName.equals("/")) {
contextName = "";
}
if (log.isDebugEnabled()) {
log.debug(sm.getString("mapperListener.registerContext",
contextName));
}
javax.naming.Context resources = context.findStaticResources();
String[] welcomeFiles = context.getWelcomeFiles();
mapper.addContext(hostName, contextName, context,
welcomeFiles, resources);
}
/**
* Unregister context.
*/
private void unregisterContext(ObjectName objectName)
throws Exception {
String name = objectName.getKeyProperty("name");
String hostName = null;
String contextName = null;
if (name.startsWith("//")) {
name = name.substring(2);
}
int slash = name.indexOf("/");
if (slash != -1) {
hostName = name.substring(0, slash);
contextName = name.substring(slash);
contextName = RequestUtil.URLDecode(contextName , "UTF-8");
} else {
return;
}
// Special case for the root context
if (contextName.equals("/")) {
contextName = "";
}
if (log.isDebugEnabled()) {
log.debug(sm.getString("mapperListener.unregisterContext",
contextName));
}
mapper.removeContext(hostName, contextName);
}
/**
* Register wrapper.
*/
private void registerWrapper(ObjectName objectName)
throws Exception {
StandardWrapper wrapper = (StandardWrapper)
mBeanServer.invoke(objectName, "findMappingObject", null, null);
if (wrapper == null) {
throw new Exception("No wrapper registered for " + objectName);
}
// If the domain is the same with ours or the engine
// name attribute is the same... - then it's ours
String targetDomain=objectName.getDomain();
if( ! domain.equals( targetDomain )) {
targetDomain= wrapper.getEngineName();
if( ! domain.equals( targetDomain )) {
// not ours
return;
}
}
String wrapperName = objectName.getKeyProperty("name");
String name = objectName.getKeyProperty("WebModule");
String hostName = null;
String contextName = null;
if (name.startsWith("//")) {
name = name.substring(2);
}
int slash = name.indexOf("/");
if (slash != -1) {
hostName = name.substring(0, slash);
contextName = name.substring(slash);
contextName = RequestUtil.URLDecode(contextName , "UTF-8");
} else {
return;
}
// Special case for the root context
if (contextName.equals("/")) {
contextName = "";
}
if (log.isDebugEnabled()) {
log.debug(sm.getString("mapperListener.registerWrapper",
wrapperName, contextName));
}
String[] mappings = wrapper.findMappings();
for (int i = 0; i < mappings.length; i++) {
boolean jspWildCard = (wrapperName.equals("jsp")
&& mappings[i].endsWith("/*"));
mapper.addWrapper(hostName, contextName, mappings[i], wrapper,
jspWildCard);
}
}
}
|
