Metacat

  /**

   * Full replacement of replication metadata in the system metadata for the 

   * specified object, changes date system metadata modified

   * 

   * @param session - the Session object containing the credentials for the Subject

   * @param pid - the object identifier for the given object to apply the policy

   * @param replica - the replica to be updated

   * @return

   * @throws NotImplemented

   * @throws NotAuthorized

   * @throws ServiceFailure

   * @throws InvalidRequest

   * @throws NotFound

   */

  public boolean updateReplicationMetadata(Session session, Identifier pid,

      Replica replica) 

      throws NotImplemented, NotAuthorized, ServiceFailure, InvalidRequest,

      NotFound {

      // get the subject

      Subject subject = session.getSubject();

      // are we allowed to do this?

      try {

        // what is the controlling permission?

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

            throw new NotAuthorized("4851", "not allowed by " + subject.getValue() + 

            " on " + pid.getValue());  

        }

      } catch (InvalidToken e) {

          throw new NotAuthorized("4851", "not allowed by " + subject.getValue() + 

                  " on " + pid.getValue());  

      }

      SystemMetadata systemMetadata = null;

      try {      

          HazelcastService.getInstance().getSystemMetadataMap().lock(pid);

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

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

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

            " : " + e.getMessage());

      }

      // set the status for the replica

      List<Replica> replicas = systemMetadata.getReplicaList();

      NodeReference replicaNode = replica.getReplicaMemberNode();

      int index = 0;

      for (Replica listedReplica: replicas) {

          // remove the replica that we are replacing

          if ( replicaNode.getValue().equals(listedReplica.getReplicaMemberNode().getValue())) {

              replicas.remove(index);

              break;

          }

          index++;

      }

      // add the new replica item

      replicas.add(replica);

      systemMetadata.setReplicaList(replicas);

      // update the metadata

      try {

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

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

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

          HazelcastService.getInstance().getSystemMetadataMap().unlock(systemMetadata.getIdentifier());

      } catch (Exception e) {

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

      } finally {

          HazelcastService.getInstance().getSystemMetadataMap().unlock(systemMetadata.getIdentifier());

      }

      return true;

  }