/ - Diff - Metacat - Ecoinformatics Redmine

        */
       private Identifier archiveCNObjectWithNotificationReplica(Session session, Identifier pid, SystemMetadata sysMeta, boolean needModifyDate)
                       throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented {
               archiveCNObject(session, pid, sysMeta, needModifyDate);
               boolean logArchive = true;
               archiveCNObject(logArchive, session, pid, sysMeta, needModifyDate);
               // notify the replicas
               notifyReplicaNodes(sysMeta);
               return pid;

           // do the actual update
           if(sysmeta.getArchived() != null && sysmeta.getArchived() == true &&
                      ((currentSysmeta.getArchived() != null && currentSysmeta.getArchived() == false ) || currentSysmeta.getArchived() == null)) {
               boolean logArchive = false;//we log it as the update system metadata event. So don't log it again.
               if(fromCN) {
                   logMetacat.debug("D1Node.update - this is to archive a cn object "+pid.getValue());
                   try {
                       archiveCNObject(session, pid, sysmeta, needUpdateModificationDate);
                       archiveCNObject(logArchive, session, pid, sysmeta, needUpdateModificationDate);
                   } catch (NotFound e) {
                       throw new InvalidRequest("4869", "Can't find the pid "+pid.getValue()+" for archive.");
+                  }
               } else {
                   logMetacat.debug("D1Node.update - this is to archive a MN object "+pid.getValue());
                   try {
                       archiveObject(session, pid, sysmeta, needUpdateModificationDate);
                       archiveObject(logArchive, session, pid, sysmeta, needUpdateModificationDate);
                   } catch (NotFound e) {
                       throw new InvalidRequest("4869", "Can't find the pid "+pid.getValue()+" for archive.");
+                  }
-...
        * @throws NotImplemented
        * @throws InvalidRequest
        */
       protected Identifier archiveObject(Session session, Identifier pid, SystemMetadata sysMeta, boolean needModifyDate)
       protected Identifier archiveObject(boolean log, Session session, Identifier pid, SystemMetadata sysMeta, boolean needModifyDate)
           throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented {
           String localId = null;
-...
               try {
                   // archive the document
                   DocumentImpl.delete(localId, null, null, null, false);
                   try {
                       EventLog.getInstance().log(request.getRemoteAddr(), request.getHeader("User-Agent"), username, localId, Event.DELETE.xmlValue());
                   } catch (Exception e) {
                       logMetacat.warn("D1NodeService.archiveObject - can't log the delete event since "+e.getMessage());
                   if(log) {
                        try {
                           EventLog.getInstance().log(request.getRemoteAddr(), request.getHeader("User-Agent"), username, localId, Event.DELETE.xmlValue());
                        } catch (Exception e) {
                           logMetacat.warn("D1NodeService.archiveObject - can't log the delete event since "+e.getMessage());
+                       }
+                  }
                   // archive it
                   sysMeta.setArchived(true);
-...
        * @throws NotFound
        * @throws NotImplemented
        */
       protected void archiveCNObject(Session session, Identifier pid, SystemMetadata sysMeta, boolean needModifyDate)
       protected void archiveCNObject(boolean log, Session session, Identifier pid, SystemMetadata sysMeta, boolean needModifyDate)
               throws InvalidToken, ServiceFailure, NotAuthorized, NotFound, NotImplemented {
               String localId = null; // The corresponding docid for this pid
-...
               // Check for the existing identifier
               try {
                   localId = IdentifierManager.getInstance().getLocalId(pid.getValue());
                   archiveObject(session, pid, sysMeta, needModifyDate);
                   archiveObject(log, session, pid, sysMeta, needModifyDate);
               } catch (McdbDocNotFoundException e) {
                   // This object is not registered in the identifier table. Assume it is of formatType DATA,

     	             logMetacat.debug("MNodeService.archive - lock the identifier "+pid.getValue()+" in the system metadata map.");
     	             SystemMetadata sysmeta = HazelcastService.getInstance().getSystemMetadataMap().get(pid);
     	             boolean needModifyDate = true;
     	             super.archiveObject(session, pid, sysmeta, needModifyDate);
     	             boolean logArchive = true;
     	             super.archiveObject(logArchive, session, pid, sysmeta, needModifyDate);
     	         } finally {
     	             HazelcastService.getInstance().getSystemMetadataMap().unlock(pid);
     	             logMetacat.debug("MNodeService.archive - unlock the identifier "+pid.getValue()+" in the system metadata map.");

Project

General

Profile

Metacat

Revision 9373

Added by Jing Tao about 9 years ago