Metacat

import java.util.ArrayList;

   * @throws VersionMismatch

  	throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented, VersionMismatch {

	  	// The lock to be used for this identifier

		Lock lock = null;

		// get the subject

		Subject subject = session.getSubject();

		// are we allowed to do this?

		if (!isAdminAuthorized(session, pid, Permission.WRITE)) {

			if (!isAuthorized(session, pid, Permission.WRITE)) {

				throw new NotAuthorized("4881", Permission.WRITE

						+ " not allowed by " + subject.getValue() + " on "

						+ pid.getValue());

			}

		}

		SystemMetadata systemMetadata = null;

		try {

			lock = HazelcastService.getInstance().getLock(pid.getValue());

			lock.lock();

			logMetacat.debug("Locked identifier " + pid.getValue());

			try {

				if (HazelcastService.getInstance().getSystemMetadataMap().containsKey(pid)) {

					systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

				}

				// did we get it correctly?

				if (systemMetadata == null) {

					throw new NotFound("4884", "Couldn't find an object identified by " + pid.getValue());

				}

				// does the request have the most current system metadata?

				if (systemMetadata.getSerialVersion().longValue() != serialVersion) {

					String msg = "The requested system metadata version number "

							+ serialVersion

							+ " differs from the current version at "

							+ systemMetadata.getSerialVersion().longValue()

							+ ". Please get the latest copy in order to modify it.";

					throw new VersionMismatch("4886", msg);

				}

			} catch (RuntimeException e) { // Catch is generic since HZ throws RuntimeException

				throw new NotFound("4884", "No record found for: " + pid.getValue());

			}

			// check permissions

			// TODO: is this necessary?

			List<Node> nodeList = D1Client.getCN().listNodes().getNodeList();

			boolean isAllowed = ServiceMethodRestrictionUtil.isMethodAllowed(session.getSubject(), nodeList, "CNReplication", "deleteReplicationMetadata");

			if (isAllowed) {

				throw new NotAuthorized("4881", "Caller is not authorized to deleteReplicationMetadata");

			}

			// delete the replica from the given node

			D1Client.getMN(nodeId).delete(session, pid);

			// reflect that change in the system metadata

			List<Replica> updatedReplicas = new ArrayList<Replica>(systemMetadata.getReplicaList());

			for (Replica r: systemMetadata.getReplicaList()) {

				  if (r.getReplicaMemberNode().equals(nodeId)) {

					  updatedReplicas.remove(r);

					  break;

				  }

			}

			systemMetadata.setReplicaList(updatedReplicas);

			// update the metadata

			try {

				systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

				systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

				HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata);

			} catch (RuntimeException e) {

				throw new ServiceFailure("4882", e.getMessage());

			}

		} catch (RuntimeException e) {

			throw new ServiceFailure("4882", e.getMessage());

		} finally {

			lock.unlock();

			logMetacat.debug("Unlocked identifier " + pid.getValue());

		}

		return true;	  

  /**

   * Set the obsoletedBy attribute in System Metadata

   * @param session

   * @param pid

   * @param obsoletedByPid

   * @param serialVersion

   * @return

   * @throws NotImplemented

   * @throws NotFound

   * @throws NotAuthorized

   * @throws ServiceFailure

   * @throws InvalidRequest

   * @throws InvalidToken

   * @throws VersionMismatch

   */

  public boolean setObsoletedBy(Session session, Identifier pid,

			Identifier obsoletedByPid, long serialVersion)

			throws NotImplemented, NotFound, NotAuthorized, ServiceFailure,

			InvalidRequest, InvalidToken, VersionMismatch {

		// The lock to be used for this identifier

		Lock lock = null;

		// get the subject

		Subject subject = session.getSubject();

		// are we allowed to do this?

		if (!isAdminAuthorized(session, pid, Permission.WRITE)) {

			if (!isAuthorized(session, pid, Permission.WRITE)) {

				throw new NotAuthorized("4881", Permission.WRITE

						+ " not allowed by " + subject.getValue() + " on "

						+ pid.getValue());

			}

		}

		SystemMetadata systemMetadata = null;

		try {

			lock = HazelcastService.getInstance().getLock(pid.getValue());

			lock.lock();

			logMetacat.debug("Locked identifier " + pid.getValue());

			try {

				if (HazelcastService.getInstance().getSystemMetadataMap().containsKey(pid)) {

					systemMetadata = HazelcastService.getInstance().getSystemMetadataMap().get(pid);

				}

				// did we get it correctly?

				if (systemMetadata == null) {

					throw new NotFound("4884", "Couldn't find an object identified by " + pid.getValue());

				}

				// does the request have the most current system metadata?

				if (systemMetadata.getSerialVersion().longValue() != serialVersion) {

					String msg = "The requested system metadata version number "

							+ serialVersion

							+ " differs from the current version at "

							+ systemMetadata.getSerialVersion().longValue()

							+ ". Please get the latest copy in order to modify it.";

					throw new VersionMismatch("4886", msg);

				}

			} catch (RuntimeException e) { // Catch is generic since HZ throws RuntimeException

				throw new NotFound("4884", "No record found for: " + pid.getValue());

			}

			// set the new policy

			systemMetadata.setObsoletedBy(obsoletedByPid);

			// update the metadata

			try {

				systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE));

				systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime());

				HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata);

			} catch (RuntimeException e) {

				throw new ServiceFailure("4882", e.getMessage());

			}

		} catch (RuntimeException e) {

			throw new ServiceFailure("4882", e.getMessage());

		} finally {

			lock.unlock();

			logMetacat.debug("Unlocked identifier " + pid.getValue());

		}

		return true;

	}