Metacat

//				dbaction = "update";

				dbaction = null;

			// in case we have a write exception, we still want to track access and sysmeta

			Exception writeException = null;

			// do we need the object content?

			if (dbaction != null && (dbaction.equals("insert") || dbaction.equals("update"))) {

			// process the real owner and updater

			DBConnection dbConn = DBConnectionPool.getDBConnection("ReplicationService.handleForceDataFileRequest");

	        int serialNumber = dbConn.getCheckOutSerialNumber();

	        dbConn.setAutoCommit(false);

			String user = (String) docinfoHash.get("user_owner");

			String updated = (String) docinfoHash.get("user_updated");

	        updateUserOwner(dbConn, docid, user, updated);

	        DBConnectionPool.returnDBConnection(dbConn, serialNumber);

			// process system metadata

	        if (systemMetadataXML != null) {

	      	  SystemMetadata sysMeta = 

	      		TypeMarshaller.unmarshalTypeFromStream(

	      				  SystemMetadata.class, 

	      				  new ByteArrayInputStream(systemMetadataXML.getBytes("UTF-8")));

	      	  // need the guid-to-docid mapping

	      	  boolean mappingExists = true;

	      	  mappingExists = IdentifierManager.getInstance().identifierExists(sysMeta.getIdentifier().getValue());

	      	  if (!mappingExists) {

	      		  IdentifierManager.getInstance().createMapping(sysMeta.getIdentifier().getValue(), docid);

	      	  }

	      	  // save the system metadata

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

	        }

	        // process the access control

	        Vector<XMLAccessDAO> accessControlList = dih.getAccessControlList();

	        if (accessControlList != null) {

	        	AccessControlForSingleFile acfsf = new AccessControlForSingleFile(docid);

	        	for (XMLAccessDAO xmlAccessDAO : accessControlList) {

	        		if (!acfsf.accessControlExists(xmlAccessDAO)) {

	        			acfsf.insertPermissions(xmlAccessDAO);

						logReplication.info("ReplicationService.handleForceReplicateRequest - document " + docid

								+ " permissions added to DB");

	        		}

	            }

	        }

	        // throw the write exception now -- this happens when access changes on an object

			if (writeException != null) {

				throw writeException;

			}

			logReplication.info("ReplicationService.handleForceReplicateDataFileRequest - datafile " + docid + " added to DB with "

					+ "action " + dbaction);

			EventLog.getInstance().log(request.getRemoteAddr(), request.getHeader("User-Agent"), REPLICATIONUSER,

					docid, dbaction);