Metacat

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import edu.ucsb.nceas.metacat.admin.AdminException;

			NumberFormatException, AccessionNumberException, SQLException,

			Exception {

			logMetacat.debug("Will sync access policies to CN id: " + cn.getNodeId() + " with info: " + cn.toString());

			logMetacat

					.error("Unable to get Coordinating node name for this MN");

			throw new AccessControlException(

					"Unable to get Coordinating node name for this MN");

			logMetacat.debug("Getting SM for pid: " + pid.getValue() + " i: "

					+ i);

			logMetacat

					.debug("Getting access policy for pid: " + pid.getValue());

					logMetacat

							.debug("Requesting CN to set access policy for pid: "

									+ pid.getValue()

									+ ", serial version: "

									+ serialVersion.toString());

					// throw na;

					// throw sf;

					// throw e;

			logMetacat.debug("Done syncing access policy for pid: "

					+ pid.getValue());

		int count = 0; // guidsToSync.size();

	/**

	 * For all guids for which current MN is authoritative, check that access

	 * policy is synced with CN.

	 * 

	 * @return void

	 */

	public void syncAll() throws ServiceFailure, InvalidToken, NotAuthorized,

			NotFound, NotImplemented, McdbDocNotFoundException, InvalidRequest,

			VersionMismatch, NumberFormatException, AccessionNumberException,

			SQLException, PropertyNotFoundException, ServiceException,

			Exception {

		SyncTask st = new SyncTask();

		// Create a single thread to run the sync of all guids in

		ExecutorService executor = Executors.newSingleThreadExecutor();

		logMetacat.debug("syncAll starting thread");

		executor.execute(st);

		// Only one task will run on this thread

		executor.shutdown();

		// return syncedIds;

	}

	/**

	 * Perform syncAll in a single thread.

	 * 

	 * @return void

	 */

	private class SyncTask implements Runnable {

		@Override

		public void run() {

			// For the following query parameters - null indicates that the

			// query

			// will not be

			// constrained by the parameter.

			Date startTime = null;

			Date endTime = null;

			ObjectFormatIdentifier objectFormatId = null;

			Boolean replicaStatus = false; // return only pids for which this mn

											// is

			ObjectList objsToSync = null;

			Integer count = 0;

			Integer start = 0;

			Integer total = 0;

			List<Identifier> tmpIds = null;

			List<Identifier> syncedIds = new ArrayList<Identifier>();

			try {

				count = Integer.valueOf(PropertyService

						.getProperty("database.webResultsetSize"));

			} catch (NumberFormatException e1) {

				logMetacat

						.error("Error in  propery file for format of database.webResultsetSize, will use 1000");

				e1.printStackTrace();

				count = 1000;

			} catch (PropertyNotFoundException e1) {

				logMetacat

						.error("Error reading propery file for database.webResultsetSize, will use 1000");

				e1.printStackTrace();

				count = 1000;

			}

			// Get the total count of guids before we start syncing

			try {

				objsToSync = IdentifierManager.getInstance()

						.querySystemMetadata(startTime, endTime,

								objectFormatId, replicaStatus, start, count);

				logMetacat.debug("syncTask total # of guids: "

						+ objsToSync.getTotal() + ", count for this page: " + objsToSync.getCount());

			} catch (Exception e) {

				logMetacat.error("Error syncing ids");

			}

			total = objsToSync.getTotal();

			// The first loop might have fewer results than the requested count value from the properties file,

			// so in this case use count returned from IdentiferManger for the loop count/increment (loop will only execute once).

			if (objsToSync.getCount() < count) count = objsToSync.getCount();

			for (int i = 0; (i + count -1) < total; i += count) {

				try {

					logMetacat.debug("syncTask # requested: " + count

							+ ", start: " + start + ", total: " + total

							+ ", count: " + objsToSync.getCount());

					tmpIds = sync(objsToSync);

					syncedIds.addAll(tmpIds);

					// Set start for the next db retrieval, loop interation

					start += objsToSync.getCount();

					if (start >= total) break;

					objsToSync = IdentifierManager

							.getInstance()

							.querySystemMetadata(startTime, endTime,

									objectFormatId, replicaStatus, start, count);

				} catch (Exception e) {

					logMetacat.error("Error syncing ids");

					break;

				}

			}

			logMetacat

					.debug("syncTask thread completed. Number of guids synced: "

							+ syncedIds.size());

		}

	 * @return boolean - true if access policies are equivalent

		// then consider them not equal, without performing diff of each access

		// rule.

		// Now perform the comparison of each access rule of access policy 1 to

		// ap 2.

		// This test assumes that the mn perms are more complete than the cn

		// perms.

			logMetacat

					.debug("Checking access policy of user: " + s1.getValue());

	 * Run pid synch script on the given pids Each argument is an individual pid

	 * because pids cannot contain whitespace.

	 * 

		SortedProperties testProperties = new SortedProperties(

				"test/test.properties");

		String metacatContextDir = testProperties

				.getProperty("metacat.contextDir");

				logMetacat.warn("Trying to syncing access policy for "

						+ args.length + " pids");

				logMetacat.warn("Sunk access policies for "

						+ synchedPids.size() + " pids");

				logMetacat.error(

						"Error syncing pids, message: " + e.getMessage(), e);

					logMetacat.debug("Request to sync all access policies has been submitted.");

						out.write("<html><body>Request to sync all access policies has been submitted.</body></html>");