[infinispan-commits] Infinispan SVN: r1124 - in trunk/demos/ec2/src/main/java/org/infinispan/ec2demo: web and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: noelo
Date: 2009-11-11 01:45:17 -0500 (Wed, 11 Nov 2009)
New Revision: 1124

Added:
   trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/
   trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheSearchServlet.java
   trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheServletListener.java
Log:
Initial addition to SVN


Added: trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheSearchServlet.java
===================================================================
--- trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheSearchServlet.java	                        (rev 0)
+++ trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheSearchServlet.java	2009-11-11 06:45:17 UTC (rev 1124)
@@ -0,0 +1,99 @@
+package org.infinispan.ec2demo.web;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.servlet.RequestDispatcher;
+import javax.servlet.ServletConfig;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.apache.log4j.*;
+
+import org.infinispan.Cache;
+import org.infinispan.ec2demo.CacheBuilder;
+import org.infinispan.ec2demo.Influenza_N_P_CR_Element;
+import org.infinispan.ec2demo.Nucleotide_Protein_Element;
+import org.infinispan.remoting.transport.Address;
+
+/**
+ * Servlet implementation class CacheSearchServlet
+ */
+public class CacheSearchServlet extends HttpServlet {
+	private Logger myLogger = Logger.getLogger(CacheSearchServlet.class);
+	private static final long serialVersionUID = 1L;
+	private Cache<String, Influenza_N_P_CR_Element> influenzaCache;
+	private Cache<String, Nucleotide_Protein_Element> proteinCache;
+	private Cache<String, Nucleotide_Protein_Element> nucleiodCache;
+
+	/**
+	 * @see HttpServlet#HttpServlet()
+	 */
+	public CacheSearchServlet() {
+		super();
+		// TODO Auto-generated constructor stub
+	}
+
+	/**
+	 * @see Servlet#init(ServletConfig)
+	 */
+	public void init(ServletConfig config) throws ServletException {
+		super.init(config);
+		CacheBuilder cacheBuilder = (CacheBuilder) getServletContext().getAttribute("cacheBuilder");
+		influenzaCache = cacheBuilder.getCacheManager().getCache("InfluenzaCache");
+		proteinCache = cacheBuilder.getCacheManager().getCache("ProteinCache");
+		nucleiodCache = cacheBuilder.getCacheManager().getCache("NucleotideCache");
+	}
+
+	/**
+	 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
+	 *      response)
+	 */
+	protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+		RequestDispatcher dispatcher = getServletContext().getRequestDispatcher("/jsp/displayVirusDetails.jsp");
+		dispatcher.forward(request, response);
+	}
+
+	public void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+		CacheBuilder cacheBuilder = (CacheBuilder) getServletContext().getAttribute("cacheBuilder");
+		String searchGBAN = request.getParameter("vGBAN");
+		request.setAttribute("total", searchGBAN);
+		
+		//check the influenza cache first
+		Influenza_N_P_CR_Element myRec = influenzaCache.get(searchGBAN);
+		
+		if (myRec != null) {
+			myLogger.trace("Searching nucleiodCache for " + myRec.getGanNucleoid());
+			Nucleotide_Protein_Element nucldet = nucleiodCache.get(myRec.getGanNucleoid());			
+			request.setAttribute("Nucleotide", nucldet);
+
+			// Display the protein details
+			Map<String, String> myProt = myRec.getProtein_Data();
+			Map<String, String> myMap = new HashMap<String, String>();
+			for (String x : myProt.keySet()) {
+				myLogger.trace("Searching proteinCache for " + x);
+				Nucleotide_Protein_Element myProtdet = proteinCache.get(x);
+				String protein_CR = myProt.get(x);		
+				myMap.put(myProtdet.getGenbankAccessionNumber(), protein_CR);
+			}
+			request.setAttribute("PMap", myMap);
+		} 
+
+
+
+		//Retrieve the cache cluster memebers
+		List<Address> myList = cacheBuilder.getCacheManager().getMembers();
+		List<String> k = new ArrayList<String>();
+		for (Address ad : myList)
+			k.add(ad.toString());
+		request.setAttribute("CMap", k);
+
+		RequestDispatcher dispatcher = getServletContext().getRequestDispatcher("/jsp/VirusDetails.jsp");
+		dispatcher.forward(request, response);
+	}
+
+}


Property changes on: trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheSearchServlet.java
___________________________________________________________________
Name: svn:keywords
   + Id Revision
Name: svn:eol-style
   + LF

Added: trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheServletListener.java
===================================================================
--- trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheServletListener.java	                        (rev 0)
+++ trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheServletListener.java	2009-11-11 06:45:17 UTC (rev 1124)
@@ -0,0 +1,50 @@
+/**
+ * 
+ */
+package org.infinispan.ec2demo.web;
+
+import java.io.IOException;
+
+import javax.servlet.ServletContext;
+import javax.servlet.ServletContextEvent;
+import javax.servlet.ServletContextListener;
+import org.infinispan.ec2demo.CacheBuilder;
+
+/**
+ * @author noconnor at redhat.com
+ *
+ */
+public class CacheServletListener implements ServletContextListener {
+	private CacheBuilder currCacheBuilder;
+	private ServletContext context = null;
+
+	/* (non-Javadoc)
+	 * @see javax.servlet.ServletContextListener#contextDestroyed(javax.servlet.ServletContextEvent)
+	 */
+	@Override
+	public void contextDestroyed(ServletContextEvent arg0) {
+		currCacheBuilder.getCacheManager().stop();
+	}
+
+	/* (non-Javadoc)
+	 * @see javax.servlet.ServletContextListener#contextInitialized(javax.servlet.ServletContextEvent)
+	 */
+	@Override
+	public void contextInitialized(ServletContextEvent arg0) {
+		System.out.println("in CacheServletListener");
+		try {
+			this.context = arg0.getServletContext();
+			String x = arg0.getServletContext().getInitParameter("jgroups_file");
+			currCacheBuilder =  new CacheBuilder(x);
+			System.out.println("in CacheServletListener...starting cache");
+			currCacheBuilder.getCacheManager().start();
+			System.out.println("in CacheServletListener...starting cache...done");
+			context.setAttribute("cacheBuilder", currCacheBuilder);
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		System.out.println("in CacheServletListener...exit");
+	}
+
+}


Property changes on: trunk/demos/ec2/src/main/java/org/infinispan/ec2demo/web/CacheServletListener.java
___________________________________________________________________
Name: svn:keywords
   + Id Revision
Name: svn:eol-style
   + LF