Metacat

              int count = 0;

              // was there a failure? log it

                 String msg = "The replication request of the object identified by " + 

                     pid.getValue() + " failed.  The error message was " +

                     failure.getMessage() + ".";

              if (replicas.size() > 0 && replicas != null) {

                  // find the target replica index in the replica list

                  for (Replica replica : replicas) {

                      String targetNodeStr = targetNode.getValue();

                      if (replicaNodeStr.equals(targetNodeStr)) {

                          replicaEntryIndex = count;

              for ( Node node : nodes ) {

                  NodeReference nodeReference = node.getIdentifier();

                  // allow target MN certs

                      List<Subject> nodeSubjects = node.getSubjectList();

                      // check if the session subject is in the node subject list

                              // lastly limit to COMPLETED, INVALIDATED,

                              // and FAILED status updates from MNs only

                                  allowed = true;

                                  break;

              // don't allow status to change from COMPLETED to anything other

              // than INVALIDATED: prevents overwrites from race conditions

            	  throw new InvalidRequest("4730", "Status state change from " +

            			  targetReplica.getReplicationStatus() + " to " +

            			  status.toString() + "is prohibited for identifier " +

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

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

                logMetacat.trace("METRICS:\tREPLICATION:\tEND REQUEST:\tPID:\t" + pid.getValue() + 

                          "\tNODE:\t" + targetNode.getValue() + 

                          "\tSIZE:\t" + systemMetadata.getSize().intValue());

              }

                  logMetacat.warn("Replication failed for identifier " + pid.getValue() +

                      " on target node " + targetNode + ". The exception was: " +

                      failure.getMessage());

              }

			  // update the replica nodes about the completed replica when complete

				broadcastSystemMetadataChange(systemMetadata);

			}

		    NodeReference nodeId = replica.getReplicaMemberNode();

		    try {

		        for (Node node : nodes) {

		      		        MNode replicaNode = D1Client.getMN(nodeId);

		      		        // call MN.systemMetadataChanged();

		      		        replicaNode.systemMetadataChanged(null, 

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

                      // don't allow status to change from COMPLETED to anything other

                      // than INVALIDATED: prevents overwrites from race conditions

                	  throw new InvalidRequest("4853", "Status state change from " +

                			  listedReplica.getReplicationStatus() + " to " +

                			  replicaStatus.toString() + "is prohibited for identifier " +

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

              // inform replica nodes of the change if the status is complete

            	  broadcastSystemMetadataChange(systemMetadata);

              }