/src/edu/ucsb/nceas/metacat/dataone/hazelcast/ObjectPathMap.java - Annotate - Metacat - Ecoinformatics Redmine

metacat/src/edu/ucsb/nceas/metacat/dataone/hazelcast/ObjectPathMap.java @ 6481

-            rnahf
+package edu.ucsb.nceas.metacat.dataone.hazelcast;
 import java.util.Collection;
-            jones
+import java.util.Collections;
 import java.util.HashSet;
-            rnahf
+import java.util.Hashtable;
-            jones
+import java.util.List;
-            rnahf
+import java.util.Map;
 import java.util.Set;
-            rnahf
+import org.dataone.service.types.v1.Identifier;
-            rnahf
+import com.hazelcast.core.MapLoader;
 import edu.ucsb.nceas.metacat.IdentifierManager;
 import edu.ucsb.nceas.metacat.McdbDocNotFoundException;
 import edu.ucsb.nceas.metacat.properties.PropertyService;
-            rnahf
+import edu.ucsb.nceas.metacat.shared.ServiceException;
-            rnahf
+import edu.ucsb.nceas.utilities.FileUtil;
 import edu.ucsb.nceas.utilities.PropertyNotFoundException;
 /**
-            rnahf
+ * MapLoader implementation for a hazelcast hzObjectPath.  This class is called
-            rnahf
+ * when the IMap get methods needs to refresh against the persistent data-store.
-            rnahf
+ * The use case for this class is to communicate the filepath between JVMs on
  * the same machine, specifically between the metacat instance and the d1_indexer.
             rnahf
-            rnahf
+ * d1_indexer will get Identifiers from elsewhere, but use this class to get
-            rnahf
+ * the paths to their associated files.  The getAllKeys() method will
  * return null in a live setting, to avoid possibly expensive preloading
             rnahf
-            rnahf
+ * @author rnahf
  */
-            rnahf
+public class ObjectPathMap implements MapLoader<Identifier, String> {
-            rnahf
+	private static IdentifierManager im;
 	private static String dataPath;
 	private static String metadataPath;
             rnahf
             rnahf
 	/**
-            rnahf
+	 * creates an ObjectPathMap
-            rnahf
+	 */
-            rnahf
+	public ObjectPathMap() {
-            rnahf
+		try {
 			PropertyService ps = PropertyService.getInstance();
 			dataPath = PropertyService.getProperty("application.datafilepath");
 			metadataPath = PropertyService.getProperty("application.documentfilepath");
 		} catch (PropertyNotFoundException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
 		} catch (ServiceException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
-            rnahf
+		im = IdentifierManager.getInstance();
+	}
 	/*
 	 * Metadata is stored in a different place on the filesystem than
 	 * the data.  The doctype value for metadata can vary, but for data
 	 * is always 'BIN', so using a simple if-then-else to separate
 	 */
-            rnahf
+	private String pathToDocid(String localid) throws McdbDocNotFoundException
+	{
 		Hashtable<String, Object> ht = im.getDocumentInfo(localid);
 		if (ht.get("doctype").equals("BIN")) {
 			return dataPath + FileUtil.getFS() + localid;
 		} else {
 			return metadataPath + FileUtil.getFS() + localid;
+		}
             rnahf
 	/**
 	 *  Implementation of hazelcast MapLoader interface method.
-            rnahf
+	 *  For the provided Identifier (as key), returns the path to the
 	 *  document on the local filesystem.  Returns null if it can't
 	 *  create the path.
-            rnahf
+	 */
-            jones
+	@Override
-            rnahf
+	public String load(Identifier key)
             rnahf
             rnahf
 		String docid = null;
 		String path = null;
 		try {
-            rnahf
+			docid = im.getLocalId(key.getValue());
-            rnahf
+			path = pathToDocid(docid);
 		} catch (McdbDocNotFoundException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
-            rnahf
+			return null;
+		}
-            rnahf
+		return path;
             rnahf
 	/**
-            rnahf
+	 *  Implementation of hazelcast MapLoader interface method.  This method loads
 	 *  mappings for all Identifiers in the parameters.  Any Identifier not found
 	 *  is not included in the resulting map.
-            rnahf
+	 */
-            jones
+	@Override
-            rnahf
+	public Map<Identifier, String> loadAll(Collection<Identifier> identifiers) {
             rnahf
             rnahf
-            rnahf
+		Hashtable<Identifier,String> map = new Hashtable<Identifier,String>();
 		for (Identifier id : identifiers) {
-            rnahf
+			try {
-            rnahf
+				String docid = im.getLocalId(id.getValue());
-            rnahf
+				map.put(id, pathToDocid(docid));
 			} catch (McdbDocNotFoundException e) {
 				// TODO should the map load an empty path instead of
 				// leaving out the entire entry?
 				e.printStackTrace();
             rnahf
+		}
-            rnahf
+		return map;
             rnahf
-            rnahf
+	/**
-            rnahf
+	 * Return the full set of guids in the local metacat repository as
 	 * dataone Identifiers.
+	 *
-            rnahf
+	 * (Hazelcast allows avoiding pre-loading by returning NULL, so will
 	 * do this to avoid pre-loading a very long list unnecessarily)
-            rnahf
+	 */
-            jones
+	@Override
-            rnahf
+	public Set<Identifier> loadAllKeys()
             rnahf
 		return null;
 //		List<String> guids = im.getAllGUIDs();
 //
-            rnahf
+//		Set<Identifier> set = Collections.synchronizedSet(new HashSet<Identifier>());
-            rnahf
+//		for (String guid : guids) {
-            rnahf
+//			Identifier id = new Identifier();
 //			id.setValue(guid);
 //			set.add(id);
-            rnahf
+//		}
 //		return set;
             rnahf
+}

Project

General

Profile

Metacat