/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 6459

Added by ben leinfelder about 13 years ago

lookup latest system metadata update date for use in synchronizing CN-CN when an offline nodes comes back online

     package edu.ucsb.nceas.metacat.dataone.hazelcast;
     import java.util.Collection;
     import java.util.Date;
     import org.apache.log4j.Logger;
     import org.dataone.service.types.v1.Identifier;
     import org.dataone.service.types.v1.Node;
-...
     import com.hazelcast.core.Member;
     import com.hazelcast.partition.Partition;
     import com.hazelcast.partition.PartitionService;
     import com.hazelcast.query.EntryObject;
     import com.hazelcast.query.Predicate;
     import com.hazelcast.query.PredicateBuilder;
     import edu.ucsb.nceas.metacat.IdentifierManager;
     import edu.ucsb.nceas.metacat.McdbDocNotFoundException;
-...
     public class HazelcastService extends BaseService
       implements InstanceListener, EntryListener<Identifier, SystemMetadata> {
       /* The instance of the logging class */
       private static final String SINCE_PROPERTY = "dateSysMetaModified";
     /* The instance of the logging class */
       private static Logger logMetacat = Logger.getLogger(HazelcastService.class);
       /* The singleton instance of the hazelcast service */
-...
           logMetacat.error(msg);
+        }
         // make sure we have all metadata locally
         try {
     	    // add index for resynch() method
     	    systemMetadata.addIndex(SINCE_PROPERTY, true);
     		resynch();
     	} catch (Exception e) {
     		String msg = "Problem synchronizing system metadata. " + e.getMessage();
     		logMetacat.error(msg, e);
+    	}
+      }
-...
     			Member ownerMember = partition.getOwner();
     			if (!ownerMember.localMember()) {
     				// need to pull the entry into the local store
     				logMetacat.debug("Saving entry locally: " + event.getKey().getValue());
     				try {
     					if (!IdentifierManager.getInstance().systemMetadataExists(event.getKey().getValue())) {
     						IdentifierManager.getInstance().createSystemMetadata(event.getValue());
     					} else {
     						IdentifierManager.getInstance().updateSystemMetadata(event.getValue());
+    					}
     				} catch (McdbDocNotFoundException e) {
     					logMetacat.error(
     							"Could not save System Metadata to local store.", e);
+    				}
     				saveLocally(event.getValue());
+    			}
     			// TODO evaluate the type of system metadata change, decide if it
-...
     			// TODO: do we need to do anything explicit here?
+    	}
     	/**
     	 * Save SystemMetadata to local store if needed
     	 * @param sm
     	 */
     	private void saveLocally(SystemMetadata sm) {
     		logMetacat.debug("Saving entry locally: " + sm.getIdentifier().getValue());
     		try {
     			if (!IdentifierManager.getInstance().systemMetadataExists(sm.getIdentifier().getValue())) {
     				IdentifierManager.getInstance().createSystemMetadata(sm);
     			} else {
     				IdentifierManager.getInstance().updateSystemMetadata(sm);
+    			}
     		} catch (McdbDocNotFoundException e) {
     			logMetacat.error(
     					"Could not save System Metadata to local store.", e);
+    		}
+    	}
     	public void resynch() throws Exception {
     		// get the CN that is online
     		// TODO: do we even need to use a specific CN?
     		// All the System Metadata records should be available via the shared map
     //		NodeList allNodes = CNodeService.getInstance().listNodes();
     //		Node onlineCN = null;
     //		for (Node node: allNodes.getNodeList()) {
     //			if (node.getType().equals(NodeType.CN)) {
     //				if (node.getState().equals(NodeState.UP)) {
     //					onlineCN = node;
     //					break;
     //				}
     //			}
     //		}
     		// get the list of items that have changed since X
     		Date since = IdentifierManager.getInstance().getLastModifiedDate();
     		EntryObject e = new PredicateBuilder().getEntryObject();
     		Predicate predicate = e.get(SINCE_PROPERTY).greaterEqual(since);
     		Collection<SystemMetadata> updatedSystemMetadata = getSystemMetadataMap().values(predicate);
     		for (SystemMetadata sm: updatedSystemMetadata) {
     			saveLocally(sm);
+    		}
+    	}
+    }

             return ids;
+        }
         /**
          * returns a list of system metadata-only guids since the given date
          * @return a list of system ids in metacat that do not correspond to objects
          * TODO: need to check which server they are on
          */
         public Date getLastModifiedDate() throws Exception {
             Date maxDate = null;
             List<String> ids = new Vector<String>();
             String sql =
             	"select max(date_modified) from " + TYPE_SYSTEM_METADATA;
             DBConnection dbConn = null;
             int serialNumber = -1;
             try
+            {
                 // Get a database connection from the pool
                 dbConn = DBConnectionPool.getDBConnection("IdentifierManager.getLastModifiedDate");
                 serialNumber = dbConn.getCheckOutSerialNumber();
                 // Execute the insert statement
                 PreparedStatement stmt = dbConn.prepareStatement(sql);
                 ResultSet rs = stmt.executeQuery();
                 if (rs.next()) {
                 	maxDate = rs.getDate(1);
+                }
                 stmt.close();
+            }
             catch (SQLException e)
+            {
                 logMetacat.error("Error while looking up the latest update date: "
                         + e.getMessage());
+            }
             finally
+            {
                 // Return database connection to the pool
                 DBConnectionPool.returnDBConnection(dbConn, serialNumber);
+            }
             return maxDate;
+        }
         /**
          * Determine if an identifier exists already, returning true if so.

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 6459

Added by ben leinfelder about 13 years ago