1 files changed, 103 insertions, 0 deletions
diff --git a/bundles/org.eclipse.equinox.p2.testserver/src/org/eclipse/equinox/p2/testserver/Activator.java b/bundles/org.eclipse.equinox.p2.testserver/src/org/eclipse/equinox/p2/testserver/Activator.java
new file mode 100644
index 000000000..03e935b69
--- /dev/null
+++ b/bundles/org.eclipse.equinox.p2.testserver/src/org/eclipse/equinox/p2/testserver/Activator.java
@@ -0,0 +1,103 @@
+/*******************************************************************************
+ * Copyright (c) 2009, Cloudsmith Inc and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ *     Cloudsmith Inc. - initial API and implementation
+ *******************************************************************************/
+
+package org.eclipse.equinox.p2.testserver;
+
+import java.net.URI;
+import javax.servlet.ServletException;
+import org.eclipse.equinox.p2.testserver.servlets.BasicResourceDelivery;
+import org.eclipse.equinox.p2.testserver.servlets.ChopAndDelay;
+import org.eclipse.equinox.p2.testserver.servlets.FileMolester;
+import org.eclipse.equinox.p2.testserver.servlets.Truncator;
+import org.osgi.framework.BundleActivator;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceReference;
+import org.osgi.service.http.HttpService;
+import org.osgi.service.http.NamespaceException;
+import org.osgi.util.tracker.ServiceTracker;
+import org.osgi.util.tracker.ServiceTrackerCustomizer;
+
+public class Activator implements BundleActivator, ServiceTrackerCustomizer {
+	private static BundleContext context;
+	private ServiceTracker httpTracker;
+	private SecureContext secureHttpContext;
+	private static Activator instance;
+	private HttpService httpService;
+	private AlwaysFailContext alwaysFail;
+	private FlipFlopFailContext flipFlop;
+
+	private static final String SITE = "http://download.eclipse.org/eclipse/updates/3.4"; //$NON-NLS-1$
+
+	public void start(BundleContext aContext) throws Exception {
+		context = aContext;
+
+		httpTracker = new ServiceTracker(context, HttpService.class.getName(), this);
+		httpTracker.open();
+		instance = this;
+	}
+
+	public void stop(BundleContext aContext) throws Exception {
+		httpTracker.close();
+		context = null;
+	}
+
+	public Object addingService(ServiceReference reference) {
+		httpService = (HttpService) context.getService(reference);
+		secureHttpContext = new SecureContext(httpService.createDefaultHttpContext());
+		alwaysFail = new AlwaysFailContext(httpService.createDefaultHttpContext());
+		flipFlop = new FlipFlopFailContext(httpService.createDefaultHttpContext());
+
+		try {
+			httpService.registerResources("/public", "/webfiles", null); //$NON-NLS-1$ //$NON-NLS-2$
+			httpService.registerResources("/private", "/webfiles", secureHttpContext); //$NON-NLS-1$ //$NON-NLS-2$
+			httpService.registerResources("/never", "/webfiles", alwaysFail); //$NON-NLS-1$ //$NON-NLS-2$
+			httpService.registerResources("/flipflop", "/webfiles", flipFlop); //$NON-NLS-1$ //$NON-NLS-2$
+			httpService.registerServlet("/truncated", new Truncator("/truncated", URI.create("/webfiles"), 50), null, null); //$NON-NLS-1$//$NON-NLS-2$//$NON-NLS-3$
+			httpService.registerServlet("/molested", new FileMolester("/molested", URI.create("/webfiles"), 40), null, null); //$NON-NLS-1$//$NON-NLS-2$//$NON-NLS-3$
+			// 8 bytes at a time, delay from 0 to 100 ms, in steps of 5
+			httpService.registerServlet("/decelerate", new ChopAndDelay("/decelerate", URI.create("/webfiles"), 3, new LinearChange(0, 5, 100, 0)), null, null); //$NON-NLS-1$//$NON-NLS-2$//$NON-NLS-3$
+
+			httpService.registerServlet("/proxy/truncated", new Truncator("/proxy/truncated", URI.create(SITE), 50), null, null); //$NON-NLS-1$//$NON-NLS-2$
+			httpService.registerServlet("/proxy/private", new BasicResourceDelivery("/proxy/private", URI.create(SITE)), null, secureHttpContext); //$NON-NLS-1$//$NON-NLS-2$
+			httpService.registerServlet("/proxy/never", new BasicResourceDelivery("/proxy/private", URI.create(SITE)), null, alwaysFail); //$NON-NLS-1$//$NON-NLS-2$
+			httpService.registerServlet("/proxy/flipFlop", new BasicResourceDelivery("/proxy/private", URI.create(SITE)), null, flipFlop); //$NON-NLS-1$//$NON-NLS-2$
+			httpService.registerServlet("/proxy/molested", new FileMolester("/proxy/molested", URI.create(SITE), 40), null, null); //$NON-NLS-1$//$NON-NLS-2$
+			httpService.registerServlet("/proxy/decelerate", new ChopAndDelay("/proxy/decelerate", URI.create(SITE), 3, new LinearChange(0, 5, 100, 0)), null, null); //$NON-NLS-1$//$NON-NLS-2$
+
+		} catch (NamespaceException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		} catch (ServletException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return httpService;
+	}
+
+	public static Activator getInstance() {
+		return instance;
+	}
+
+	public HttpService getHttp() {
+		return httpService;
+	}
+
+	public void modifiedService(ServiceReference reference, Object service) {
+		// do nothing 
+	}
+
+	public void removedService(ServiceReference reference, Object service) {
+		httpService = (HttpService) service;
+		httpService.unregister("/public"); //$NON-NLS-1$
+		httpService.unregister("/private"); //$NON-NLS-1$
+	}
+
+}