org.eclipse.osbp.ecview.jetty.manager/src/org/eclipse/osbp/ecview/jetty/manager/impl/JettyManager.java - osbp/org.eclipse.osbp.ecview.addons - Git at Google

 /*******************************************************************************
  * Copyright (c) 2007, 2013 IBM Corporation and others.
  * All rights reserved. This program and the accompanying materials
  * are made available under the terms of the Eclipse Public License 2.0
  * which accompanies this distribution, and is available at
  * https://www.eclipse.org/legal/epl-2.0/
  *
  * SPDX-License-Identifier: EPL-2.0
  *
  * Contributors:
  *     IBM Corporation - initial API and implementation
  *     Florian Pirchner - added to preview bundle
  *******************************************************************************/

 package org.eclipse.osbp.ecview.jetty.manager.impl;

 import java.io.File;
 import java.io.IOException;
 import java.util.Properties;

 import javax.servlet.Servlet;
 import javax.servlet.ServletConfig;
 import javax.servlet.ServletContext;
 import javax.servlet.ServletException;
 import javax.servlet.ServletRequest;
 import javax.servlet.ServletResponse;

 import org.eclipse.equinox.http.servlet.HttpServiceServlet;
 import org.eclipse.jetty.server.Connector;
 import org.eclipse.jetty.server.NetworkTrafficServerConnector;
 import org.eclipse.jetty.server.Server;
 import org.eclipse.jetty.server.handler.ContextHandlerCollection;
 import org.eclipse.jetty.server.session.SessionHandler;
 import org.eclipse.jetty.servlet.ServletContextHandler;
 import org.eclipse.jetty.servlet.ServletHolder;
 import org.eclipse.osbp.ecview.jetty.manager.IJettyManager;
 import org.osgi.framework.Constants;

 public class JettyManager implements IJettyManager {

 	public static final java.lang.String HTTP_PORT = "http.port";
 	public static final java.lang.String OTHER_INFO = "other.info";

 	public static final String CONTEXT_TEMPDIR = "javax.servlet.context.tempdir"; //$NON-NLS-1$
 	private static final String DIR_PREFIX = "application"; //$NON-NLS-1$
 	private static final String INTERNAL_CONTEXT_CLASSLOADER = "org.eclipse.equinox.http.jetty.internal.ContextClassLoader"; //$NON-NLS-1$

 	private Server server;
 	private File workDir;
 	private int port;
 	private String contextPath;

 	public JettyManager() {
 		try {
 			port = Integer.valueOf(System.getProperty(PROP_PORT, "8088"));
 		} catch (NumberFormatException e) {
 			port = 8080;
 		}

 		contextPath = System.getProperty(PROP_CONTEXT_PATH, "osbp");
 	}

 	/**
 	 * @return the port
 	 */
 	public int getPort() {
 		return port;
 	}

 	/**
 	 * @return the contextPath
 	 */
 	public String getContextPath() {
 		return contextPath;
 	}

 	/**
 	 * @return the contextPath
 	 */
 	public String getMobileContextPath() {
 		return contextPath + MOBILE_POSTFIX;
 	}

 	/**
 	 * @return the contextPath
 	 */
 	public String getDisplayContextPath() {
 		return contextPath + DISPLAY_PREFIX;
 	}

 	public synchronized void stop() {
 		if (server != null) {
 			try {
 				server.stop();
 			} catch (Exception e) {
 				// cleaning up
 				e.printStackTrace();
 			}
 			File contextWorkDir = new File(workDir, DIR_PREFIX);
 			deleteDirectory(contextWorkDir);
 		}
 	}

 	public String getName() {
 		return this.getClass().getName();
 	}

 	public synchronized void start(File workDir) {
 		this.workDir = workDir;

 		stop();
 		this.server = new Server();

 		Connector httpConnector = createHttpConnector();
 		server.addConnector(httpConnector);
 		server.addBean(new JettyErrorHandler());

 		ContextHandlerCollection handlers = new ContextHandlerCollection();
 		ServletContextHandler applicationContext = createServletContext(getContextPath(), SERVICE_TYPE__APPLICATION);
 		ServletContextHandler mobileContext = createServletContext(getMobileContextPath(), SERVICE_TYPE__MOBILE);
 		ServletContextHandler displayContext = createServletContext(getDisplayContextPath(), SERVICE_TYPE__DISPLAY);
 		handlers.addHandler(applicationContext);
 		handlers.addHandler(mobileContext);
 		handlers.addHandler(displayContext);

 		server.setHandler(handlers);
 		try {
 			server.start();
 		} catch (Exception e) {
 			throw new RuntimeException(e.getMessage(), e);
 		}
 	}

 	protected ServletContextHandler createServletContext(String contextPath, String serviceType) {
 		ServletHolder holder = new ServletHolder(new InternalHttpServiceServlet());
 		holder.setInitOrder(0);
 		holder.setInitParameter(Constants.SERVICE_VENDOR, "OSBP.org"); //$NON-NLS-1$
 		holder.setInitParameter(Constants.SERVICE_DESCRIPTION, "ECView" + contextPath); //$NON-NLS-1$
 		holder.setInitParameter(PROP_SERVICE_TYPE, serviceType);
 		holder.setInitParameter(HTTP_PORT, Integer.toString(port));
 		holder.setInitParameter(OTHER_INFO, contextPath);
 		ServletContextHandler httpContext = createHttpContext(contextPath);

 		httpContext.addServlet(holder, "/*"); //$NON-NLS-1$
 		return httpContext;
 	}

 	public synchronized void shutdown() throws Exception {
 		server.stop();
 		server = null;
 	}

 	private Connector createHttpConnector() {
 		NetworkTrafficServerConnector connector = new NetworkTrafficServerConnector(server);
 		connector.setPort(port);
 		return connector;
 	}

 	// private Boolean getDefaultNIOEnablement() {
 	// Properties systemProperties = System.getProperties();
 	// String javaVendor = systemProperties.getProperty("java.vendor", "");
 	// //$NON-NLS-1$ //$NON-NLS-2$
 	// if (javaVendor.equals("IBM Corporation")) { //$NON-NLS-1$
 	// String javaVersion = systemProperties.getProperty("java.version", "");
 	// //$NON-NLS-1$ //$NON-NLS-2$
 	// if (javaVersion.startsWith("1.4")) //$NON-NLS-1$
 	// return Boolean.FALSE;
 	// // Note: no problems currently logged with 1.5
 	// if (javaVersion.equals("1.6.0")) { //$NON-NLS-1$
 	// String jclVersion = systemProperties.getProperty("java.jcl.version", "");
 	// //$NON-NLS-1$ //$NON-NLS-2$
 	// if (jclVersion.startsWith("2007")) //$NON-NLS-1$
 	// return Boolean.FALSE;
 	// if (jclVersion.startsWith("2008") && !jclVersion.startsWith("200811")
 	// //$NON-NLS-1$ //$NON-NLS-2$
 	// && !jclVersion.startsWith("200812")) //$NON-NLS-1$
 	// return Boolean.FALSE;
 	// }
 	// }
 	// return Boolean.TRUE;
 	// }

 	private ServletContextHandler createHttpContext(String contextPath) {
 		ServletContextHandler httpContext = new ServletContextHandler();
 		// hack in the mime type for xsd until jetty fixes it (bug 393218)
 		httpContext.getMimeTypes().addMimeMapping("xsd", "application/xml"); //$NON-NLS-1$ //$NON-NLS-2$
 		httpContext.setAttribute(INTERNAL_CONTEXT_CLASSLOADER, Thread.currentThread().getContextClassLoader());
 		httpContext.setClassLoader(this.getClass().getClassLoader());
 		httpContext.setContextPath(contextPath);

 		File contextWorkDir = new File(workDir, DIR_PREFIX + contextPath);
 		contextWorkDir.mkdir();
 		httpContext.setAttribute(CONTEXT_TEMPDIR, contextWorkDir);

 		httpContext.setSessionHandler(new SessionHandler());

 		return httpContext;
 	}

 	public static class InternalHttpServiceServlet implements Servlet {
 		// private static final long serialVersionUID = 7477982882399972088L;
 		private Servlet httpServiceServlet = new HttpServiceServlet();
 		private ClassLoader contextLoader;

 		public void init(ServletConfig config) throws ServletException {
 			ServletContext context = config.getServletContext();
 			contextLoader = (ClassLoader) context.getAttribute(INTERNAL_CONTEXT_CLASSLOADER);

 			Thread thread = Thread.currentThread();
 			ClassLoader current = thread.getContextClassLoader();
 			thread.setContextClassLoader(contextLoader);
 			try {
 				httpServiceServlet.init(config);
 			} finally {
 				thread.setContextClassLoader(current);
 			}
 		}

 		public void destroy() {
 			Thread thread = Thread.currentThread();
 			ClassLoader current = thread.getContextClassLoader();
 			thread.setContextClassLoader(contextLoader);
 			try {
 				httpServiceServlet.destroy();
 			} finally {
 				thread.setContextClassLoader(current);
 			}
 			contextLoader = null;
 		}

 		public void service(ServletRequest req, ServletResponse res) throws ServletException, IOException {
 			Thread thread = Thread.currentThread();
 			ClassLoader current = thread.getContextClassLoader();
 			thread.setContextClassLoader(contextLoader);
 			try {
 				httpServiceServlet.service(req, res);
 			} finally {
 				thread.setContextClassLoader(current);
 			}
 		}

 		public ServletConfig getServletConfig() {
 			return httpServiceServlet.getServletConfig();
 		}

 		public String getServletInfo() {
 			return httpServiceServlet.getServletInfo();
 		}
 	}

 	// deleteDirectory is a convenience method to recursively delete a directory
 	private static boolean deleteDirectory(File directory) {
 		if (directory.exists() && directory.isDirectory()) {
 			File[] files = directory.listFiles();
 			for (int i = 0; i < files.length; i++) {
 				if (files[i].isDirectory()) {
 					deleteDirectory(files[i]);
 				} else {
 					files[i].delete();
 				}
 			}
 		}
 		return directory.delete();
 	}
 }
	/*******************************************************************************
	* Copyright (c) 2007, 2013 IBM Corporation and others.
	* All rights reserved. This program and the accompanying materials
	* are made available under the terms of the Eclipse Public License 2.0
	* which accompanies this distribution, and is available at
	* https://www.eclipse.org/legal/epl-2.0/
	*
	* SPDX-License-Identifier: EPL-2.0
	*
	* Contributors:
	* IBM Corporation - initial API and implementation
	* Florian Pirchner - added to preview bundle
	*******************************************************************************/

	package org.eclipse.osbp.ecview.jetty.manager.impl;

	import java.io.File;
	import java.io.IOException;
	import java.util.Properties;

	import javax.servlet.Servlet;
	import javax.servlet.ServletConfig;
	import javax.servlet.ServletContext;
	import javax.servlet.ServletException;
	import javax.servlet.ServletRequest;
	import javax.servlet.ServletResponse;

	import org.eclipse.equinox.http.servlet.HttpServiceServlet;
	import org.eclipse.jetty.server.Connector;
	import org.eclipse.jetty.server.NetworkTrafficServerConnector;
	import org.eclipse.jetty.server.Server;
	import org.eclipse.jetty.server.handler.ContextHandlerCollection;
	import org.eclipse.jetty.server.session.SessionHandler;
	import org.eclipse.jetty.servlet.ServletContextHandler;
	import org.eclipse.jetty.servlet.ServletHolder;
	import org.eclipse.osbp.ecview.jetty.manager.IJettyManager;
	import org.osgi.framework.Constants;

	public class JettyManager implements IJettyManager {

	public static final java.lang.String HTTP_PORT = "http.port";
	public static final java.lang.String OTHER_INFO = "other.info";

	public static final String CONTEXT_TEMPDIR = "javax.servlet.context.tempdir"; //$NON-NLS-1$
	private static final String DIR_PREFIX = "application"; //$NON-NLS-1$
	private static final String INTERNAL_CONTEXT_CLASSLOADER = "org.eclipse.equinox.http.jetty.internal.ContextClassLoader"; //$NON-NLS-1$

	private Server server;
	private File workDir;
	private int port;
	private String contextPath;

	public JettyManager() {
	try {
	port = Integer.valueOf(System.getProperty(PROP_PORT, "8088"));
	} catch (NumberFormatException e) {
	port = 8080;
	}

	contextPath = System.getProperty(PROP_CONTEXT_PATH, "osbp");
	}

	/**
	* @return the port
	*/
	public int getPort() {
	return port;
	}

	/**
	* @return the contextPath
	*/
	public String getContextPath() {
	return contextPath;
	}

	/**
	* @return the contextPath
	*/
	public String getMobileContextPath() {
	return contextPath + MOBILE_POSTFIX;
	}

	/**
	* @return the contextPath
	*/
	public String getDisplayContextPath() {
	return contextPath + DISPLAY_PREFIX;
	}

	public synchronized void stop() {
	if (server != null) {
	try {
	server.stop();
	} catch (Exception e) {
	// cleaning up
	e.printStackTrace();
	}
	File contextWorkDir = new File(workDir, DIR_PREFIX);
	deleteDirectory(contextWorkDir);
	}
	}

	public String getName() {
	return this.getClass().getName();
	}

	public synchronized void start(File workDir) {
	this.workDir = workDir;

	stop();
	this.server = new Server();

	Connector httpConnector = createHttpConnector();
	server.addConnector(httpConnector);
	server.addBean(new JettyErrorHandler());

	ContextHandlerCollection handlers = new ContextHandlerCollection();
	ServletContextHandler applicationContext = createServletContext(getContextPath(), SERVICE_TYPE__APPLICATION);
	ServletContextHandler mobileContext = createServletContext(getMobileContextPath(), SERVICE_TYPE__MOBILE);
	ServletContextHandler displayContext = createServletContext(getDisplayContextPath(), SERVICE_TYPE__DISPLAY);
	handlers.addHandler(applicationContext);
	handlers.addHandler(mobileContext);
	handlers.addHandler(displayContext);

	server.setHandler(handlers);
	try {
	server.start();
	} catch (Exception e) {
	throw new RuntimeException(e.getMessage(), e);
	}
	}

	protected ServletContextHandler createServletContext(String contextPath, String serviceType) {
	ServletHolder holder = new ServletHolder(new InternalHttpServiceServlet());
	holder.setInitOrder(0);
	holder.setInitParameter(Constants.SERVICE_VENDOR, "OSBP.org"); //$NON-NLS-1$
	holder.setInitParameter(Constants.SERVICE_DESCRIPTION, "ECView" + contextPath); //$NON-NLS-1$
	holder.setInitParameter(PROP_SERVICE_TYPE, serviceType);
	holder.setInitParameter(HTTP_PORT, Integer.toString(port));
	holder.setInitParameter(OTHER_INFO, contextPath);
	ServletContextHandler httpContext = createHttpContext(contextPath);

	httpContext.addServlet(holder, "/*"); //$NON-NLS-1$
	return httpContext;
	}

	public synchronized void shutdown() throws Exception {
	server.stop();
	server = null;
	}

	private Connector createHttpConnector() {
	NetworkTrafficServerConnector connector = new NetworkTrafficServerConnector(server);
	connector.setPort(port);
	return connector;
	}

	// private Boolean getDefaultNIOEnablement() {
	// Properties systemProperties = System.getProperties();
	// String javaVendor = systemProperties.getProperty("java.vendor", "");
	// //$NON-NLS-1$ //$NON-NLS-2$
	// if (javaVendor.equals("IBM Corporation")) { //$NON-NLS-1$
	// String javaVersion = systemProperties.getProperty("java.version", "");
	// //$NON-NLS-1$ //$NON-NLS-2$
	// if (javaVersion.startsWith("1.4")) //$NON-NLS-1$
	// return Boolean.FALSE;
	// // Note: no problems currently logged with 1.5
	// if (javaVersion.equals("1.6.0")) { //$NON-NLS-1$
	// String jclVersion = systemProperties.getProperty("java.jcl.version", "");
	// //$NON-NLS-1$ //$NON-NLS-2$
	// if (jclVersion.startsWith("2007")) //$NON-NLS-1$
	// return Boolean.FALSE;
	// if (jclVersion.startsWith("2008") && !jclVersion.startsWith("200811")
	// //$NON-NLS-1$ //$NON-NLS-2$
	// && !jclVersion.startsWith("200812")) //$NON-NLS-1$
	// return Boolean.FALSE;
	// }
	// }
	// return Boolean.TRUE;
	// }

	private ServletContextHandler createHttpContext(String contextPath) {
	ServletContextHandler httpContext = new ServletContextHandler();
	// hack in the mime type for xsd until jetty fixes it (bug 393218)
	httpContext.getMimeTypes().addMimeMapping("xsd", "application/xml"); //$NON-NLS-1$ //$NON-NLS-2$
	httpContext.setAttribute(INTERNAL_CONTEXT_CLASSLOADER, Thread.currentThread().getContextClassLoader());
	httpContext.setClassLoader(this.getClass().getClassLoader());
	httpContext.setContextPath(contextPath);

	File contextWorkDir = new File(workDir, DIR_PREFIX + contextPath);
	contextWorkDir.mkdir();
	httpContext.setAttribute(CONTEXT_TEMPDIR, contextWorkDir);

	httpContext.setSessionHandler(new SessionHandler());

	return httpContext;
	}

	public static class InternalHttpServiceServlet implements Servlet {
	// private static final long serialVersionUID = 7477982882399972088L;
	private Servlet httpServiceServlet = new HttpServiceServlet();
	private ClassLoader contextLoader;

	public void init(ServletConfig config) throws ServletException {
	ServletContext context = config.getServletContext();
	contextLoader = (ClassLoader) context.getAttribute(INTERNAL_CONTEXT_CLASSLOADER);

	Thread thread = Thread.currentThread();
	ClassLoader current = thread.getContextClassLoader();
	thread.setContextClassLoader(contextLoader);
	try {
	httpServiceServlet.init(config);
	} finally {
	thread.setContextClassLoader(current);
	}
	}

	public void destroy() {
	Thread thread = Thread.currentThread();
	ClassLoader current = thread.getContextClassLoader();
	thread.setContextClassLoader(contextLoader);
	try {
	httpServiceServlet.destroy();
	} finally {
	thread.setContextClassLoader(current);
	}
	contextLoader = null;
	}

	public void service(ServletRequest req, ServletResponse res) throws ServletException, IOException {
	Thread thread = Thread.currentThread();
	ClassLoader current = thread.getContextClassLoader();
	thread.setContextClassLoader(contextLoader);
	try {
	httpServiceServlet.service(req, res);
	} finally {
	thread.setContextClassLoader(current);
	}
	}

	public ServletConfig getServletConfig() {
	return httpServiceServlet.getServletConfig();
	}

	public String getServletInfo() {
	return httpServiceServlet.getServletInfo();
	}
	}

	// deleteDirectory is a convenience method to recursively delete a directory
	private static boolean deleteDirectory(File directory) {
	if (directory.exists() && directory.isDirectory()) {
	File[] files = directory.listFiles();
	for (int i = 0; i < files.length; i++) {
	if (files[i].isDirectory()) {
	deleteDirectory(files[i]);
	} else {
	files[i].delete();
	}
	}
	}
	return directory.delete();
	}
	}