Metacat

import edu.ucsb.nceas.metacat.util.MetaCatUtil;

import edu.ucsb.nceas.metacat.util.SessionData;

import edu.ucsb.nceas.metacat.util.SystemUtil;

import edu.ucsb.nceas.utilities.GeneralPropertyException;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

  private Date firstTime;

  private boolean timedReplicationIsOn = false;

  Timer replicationDaemon;

  private Thread lockThread = null;

  public static final String FORCEREPLICATEDELETE = "forcereplicatedelete";

  private static final String TIMEREPLICATION = "replication.timedreplication";

  {

    //PrintWriter out = response.getWriter();

    //ServletOutputStream outPut = response.getOutputStream();

   * servercontrol    delete               server

   * servercontrol    list

   */

                                          HttpServletResponse response)

  {

    String subaction = ((String[])params.get("subaction"))[0];

	 * to the requesting server (remote server) for the specified docid. Then

	 * store it in local database.

	 */

                                           HttpServletResponse response, HttpServletRequest request)

  {

    String server = ((String[])params.get("server"))[0]; // the server that

    String docid = ((String[])params.get("docid"))[0]; // sent the document

    String dbaction = "UPDATE"; // the default action is UPDATE

    DBConnection dbConn = null;

    int serialNumber = -1;

      DocInfoHandler dih = new DocInfoHandler();

      XMLReader docinfoParser = ReplicationHandler.initParser(dih);

      docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));

      // Get user owner of this docid

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

      }

      //process extra access rules before dealing with the write exception (doc exist already)

      if (accessControlList != null) {

    	  for (int i = 0; i < accessControlList.size(); i++) {

        	  AccessControlForSingleFile acfsf = (AccessControlForSingleFile) accessControlList.get(i);

 * when a forcereplication delete request comes in, local host will delete this

 * document

 */

                                         HttpServletResponse response, HttpServletRequest request)

{

  String server = ((String[])params.get("server"))[0]; // the server that

   * readdata request to the requesting server (remote server) for the specified

   * docid. Then store it in local database and file system

   */

  {

    //make sure there is some parameters

    }

    // Overide or not

    // dbaction - update or insert

    String dbaction=null;

      DocInfoHandler dih = new DocInfoHandler();

      XMLReader docinfoParser = ReplicationHandler.initParser(dih);

      docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));

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

      String docName = (String)docinfoHash.get("docname");

        	writeException = e;

		}

        //process extra access rules

        if (accessControlList != null) {

      	  for (int i = 0; i < accessControlList.size(); i++) {

          	  AccessControlForSingleFile acfsf = (AccessControlForSingleFile) accessControlList.get(i);

   * currentdate: the timestamp of the document on the remote server

   *

   */

                                    HttpServletResponse response)

  {

   *                  user_updated, home_server, public_access, rev)/>

   * all of the subelements of document info are #PCDATA

   */

                                        HttpServletResponse response)

  {

    String docid = ((String[])(params.get("docid")))[0];

      //permissions on the document

      PermissionController permController = new PermissionController(docid);

      sb.append("<accessControl>");

      for (int i = 0; i < accessControlList.size(); i++) {

    	  AccessControlForSingleFile acfsf = (AccessControlForSingleFile) accessControlList.get(i);

   * Sends a datafile to a remote host

   */

  private void handleGetDataFileRequest(OutputStream outPut,

  {

    // File path for data file

    try

    {

      filepath = PropertyService.getProperty("application.datafilepath");

      URL u = new URL("https://" + server + "?server="

                +MetaCatUtil.getLocalReplicationServerName()

                +"&action=test");

  /**

   * Sends a document to a remote host

   */

                                        HttpServletResponse response)

  {

    {

      //try to open a https stream to test if the request server's public key

      //in the key store, this is security issue

      URL u = new URL("https://" + server + "?server="

                +MetaCatUtil.getLocalReplicationServerName()

                +"&action=test");

        return;

      }

      DocumentImpl di = new DocumentImpl(docid);

      MetacatReplication.replLog("document " + docid + " sent");

    }

   * note that the rev in deletedDocument is always empty.  I just left

   * it in there to make the parser implementation easier.

   */

                                    HttpServletResponse response)

  {

    // Checked out DBConnection

      // Store the deleted docid list

      StringBuffer delsql = new StringBuffer();

      // Store the data set file

      // Append local server's name and replication servlet to doclist

      doclist.append("<?xml version=\"1.0\"?><replication>");

        while(tablehasrows)

        {

          String recordDoctype = rs.getString(3);

                                     PropertyService.getProperty("xml.packagedoctype"));

          //if this is a package file, put it at the end

          //because if a package file is read before all of the files it

          }//if packagedoctpes

          else

          { //the package files are saved to be put into the xml later.

          }//esle

          tablehasrows = rs.next();

        }//while

          String recordDoctype = rs.getString(3);

          if(!recordDoctype.equals("BIN"))

          { //don't replicate data files

                                     PropertyService.getProperty("xml.packagedoctype"));

            if(recordDoctype != null && !packagedoctypes.contains(recordDoctype))

            {   //if this is a package file, put it at the end

            }

            else

            { //the package files are saved to be put into the xml later.

            }

         }//if

         tablehasrows = rs.next();

      //now we can put the package files into the xml results

      for(int i=0; i<packageFiles.size(); i++)

      {

        doclist.append("<updatedDocument>");

        doclist.append("</docid><rev>");

        doclist.append("</rev>");

        doclist.append("</updatedDocument>");

      }

   * If printFlag == false then do not print to out.

   */

  private static String handleGetCatalogRequest(PrintWriter out,

                                                HttpServletResponse response,

                                                boolean printFlag)

  {

   * for replication gets rid of any problems with syncronizing clocks

   * because a time specific to a document is always kept on its home server.

   */

                                    HttpServletResponse response)

  {

    SimpleDateFormat formatter = new SimpleDateFormat ("MM/dd/yy HH:mm:ss");

   * Method to get a host server information for given docid

   * @param conn a connection to the database

   */

  {

    DBConnection dbConn = null;

    int serialNumber = -1;

    docId=MetaCatUtil.getDocIdFromString(docId);