/ - Diff - Metacat - Ecoinformatics Redmine

          *            the server which notify local server the force replication
          *            command
          */
         public static String writeReplication(DBConnection conn, String xmlString,
         public static String writeReplication(DBConnection conn, String xmlString, byte[] xmlBytes,
                 String pub, Reader dtd, String action, String accnum, String user,
                 String[] groups, String homeServer, String notifyServer,
                 String ruleBase, boolean needValidation, String tableName,
-...
                     isRevision = true;
+                }
                 // detect encoding
                 XmlStreamReader xsr = new XmlStreamReader(new ByteArrayInputStream(xmlString.getBytes()));
                 //XmlStreamReader xsr = new XmlStreamReader(new ByteArrayInputStream(xmlString.getBytes()));
                 XmlStreamReader xsr = new XmlStreamReader(new ByteArrayInputStream(xmlBytes));
     	        String encoding = xsr.getEncoding();
     	        // no need to write the EML-contained access rules for replication
-...
                 conn.setAutoCommit(true);
                 // Write the file to disk
                 byte[] bytes = xmlString.getBytes(encoding);
             	writeToFileSystem(bytes, accnum);
                 //byte[] bytes = xmlString.getBytes(encoding);
             	writeToFileSystem(xmlBytes, accnum);
                 // write to xml_node complete. start the indexing thread.
                 // this only for xml_documents

     				ruleBase, needValidation, writeAccessRules, xmlBytes);
+    	}
     	public String writeReplication(DBConnection conn, String xml, String pub, Reader dtd,
     	public String writeReplication(DBConnection conn, String xml, byte[]xmlBytes, String pub, Reader dtd,
     			String action, String accnum, String user, String[] groups,
     			String homeServer, String notifyServer, Date createDate, Date updateDate)
     			throws Exception {
-...
     		// so rule base is null and need validation is false (first false)
     		// this method is for force replication. so the table name is xml_documents
     		// and timed replication is false (last false)
     		return DocumentImpl.writeReplication(conn, xml, pub, dtd, action, accnum, user,
     		return DocumentImpl.writeReplication(conn, xml, xmlBytes, pub, dtd, action, accnum, user,
     				groups, homeServer, notifyServer, ruleBase, false,
     				DocumentImpl.DOCUMENTTABLE, false, createDate, updateDate);
     		// last false means is not timed replication
-...
     	 * @return
     	 * @throws Exception
     	 */
     	public String writeReplication(DBConnection conn, String xml, String pub, Reader dtd,
     	public String writeReplication(DBConnection conn, String xml, byte[]xmlBytes, String pub, Reader dtd,
     			String action, String accnum, String user, String[] groups,
     			String homeServer, String notifyServer, String tableName,
     			boolean timedReplication, Date createDate, Date updateDate)
     			throws Exception {
     		//we don't need to check validation in replication
     		// so rule base is null and need validation is false
     		return DocumentImpl.writeReplication(conn, xml, pub, dtd, action, accnum, user,
     		return DocumentImpl.writeReplication(conn, xml, xmlBytes, pub, dtd, action, accnum, user,
     				groups, homeServer, notifyServer, ruleBase, false, tableName,
     				timedReplication, createDate, updateDate);
+    	}

           URL u = new URL(readDocURLString);
           // Get docid content
           String newxmldoc = ReplicationService.getURLContent(u);
           byte[] xmlBytes = ReplicationService.getURLBytes(u);
           String newxmldoc = new String(xmlBytes, "UTF-8");
           // If couldn't get skip it
           if ( newxmldoc.indexOf("<error>")!= -1 && newxmldoc.indexOf("</error>")!=-1)
+          {
-...
           // Write the document into local host
           DocumentImplWrapper wrapper = new DocumentImplWrapper(parserBase, false, false);
           String newDocid = wrapper.writeReplication(dbConn,
                                   newxmldoc,
                                   newxmldoc, xmlBytes,
                                   docinfoHash.get("public_access"),
                                   null,  /* the dtd text */
                                   actions,

     			URL u = new URL("https://" + server + "?server="
     					+ MetacatUtil.getLocalReplicationServerName() + "&action=read&docid="
     					+ docid);
     			String xmldoc = ReplicationService.getURLContent(u);
     			byte[] xmlBytes = ReplicationService.getURLBytes(u);
                 String xmldoc = new String(xmlBytes, "UTF-8");
     			// get the document info from server
     			URL docinfourl = new URL("https://" + server + "?server="
-...
     			DocumentImplWrapper wrapper = new DocumentImplWrapper(parserBase, false, false);
     			//try this independently so we can set access even if the update action is invalid (i.e docid has not changed)
     			try {
     				wrapper.writeReplication(dbConn, xmldoc, null, null,
     				wrapper.writeReplication(dbConn, xmldoc, xmlBytes, null, null,
     						dbaction, docid, null, null, homeServer, server, createdDate,
     						updatedDate);
     			} finally {
-...
     		// get the response content
     		InputStream input = getURLStream(u);
     		logReplication.info("ReplicationService.getURLContent - After getting response from: " + u.toString());
     		InputStreamReader istream = new InputStreamReader(input);
     		StringBuffer serverResponse = new StringBuffer();
     		while ((istreamInt = istream.read()) != -1) {
     			istreamChar = (char) istreamInt;
     			serverResponse.append(istreamChar);
+    		}
     		istream.close();
     		input.close();
     		return serverResponse.toString();
     		String content = IOUtils.toString(input, "UTF-8");
             return content;
+    	}
     	/**
-...
+    	}
     	/**
          * This method returns a byte array after opening a url
          * @param u the url to return the content from
          * @return a InputStream representing the content of the url
          * @throws java.io.IOException
          */
         public static byte[] getURLBytes(URL u) throws Exception {
             InputStream input = getURLStream(u);
             byte[] bytes = IOUtils.toByteArray(input);
             return bytes;
+        }
     	/**
     	 * Sets up an HttpClient with SSL connection.
     	 * Sends client certificate to the server when doing the request.
     	 * @return

Project

General

Profile

Metacat

Revision 8959

Added by Jing Tao over 9 years ago