Metacat

/**

 *  '$RCSfile$'

 *    Purpose: A class to asyncronously force the replication of each server

 *             that has an entry in the xml_replication table.  When run,

 *             this thread communicates with each server in the list and

 *             solicites a read of an updated or newly inserted document

 *             with a certain docid.

 *  Copyright: 2000 Regents of the University of California and the

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Chad Berkley

 *

 *   '$Author: daigle $'

 *     '$Date: 2009-08-24 13:34:17 -0800 (Mon, 24 Aug 2009) $'

 * '$Revision: 5030 $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacat.replication;

import java.net.URL;

import org.apache.log4j.Logger;

import edu.ucsb.nceas.metacat.properties.PropertyService;

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

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 * A class to asyncronously force the replication of each server

 * that has an entry in the xml_replication table.  When run,

 * this thread communicates with each server in the list and

 * forces replication of system metadata

 */

public class ForceReplicationSystemMetadataHandler implements Runnable

{

  private Thread btThread;

  private String guid;

  private ReplicationServerList serverLists = null;

  private String notificationServer = null;

  private static Logger logReplication = Logger.getLogger("ReplicationLogging");

  private static Logger logMetacat = Logger.getLogger(ForceReplicationSystemMetadataHandler.class);

  /**

   * Use this constructor when the action is implied.

   */

  public ForceReplicationSystemMetadataHandler(String guid, String myNotificationServer )

  {

    this.guid = guid;

    // Build a severLists from xml_replication table

    this.serverLists = new ReplicationServerList();

    // Get notification server

    this.notificationServer = myNotificationServer;

    btThread = new Thread(this);

    btThread.setPriority(Thread.MIN_PRIORITY);

    btThread.start();

  }

  /**

   * Method to send force replication command to other server to get

   * a new or updated docid

   */

  public void run()

  {

	    // URL for notification

	    URL comeAndGetIt = null;

		// If no server in xml_replication table we are done

		if (serverLists.isEmpty()) {

			return;

		}

		// Thread sleeping for some seconds to make sure the document was insert

		// into the database before we send force replication request

		int sleepTime;

		try {

			sleepTime = Integer.parseInt(PropertyService.getProperty("replication.forcereplicationwaitingtime"));

			Thread.sleep(sleepTime);

		} catch (PropertyNotFoundException pnfe) {

	    	logMetacat.error(ReplicationService.METACAT_REPL_ERROR_MSG);

			logReplication.error("Property error: " + pnfe.getMessage());

		} catch (InterruptedException ie) {

	    	logMetacat.error(ReplicationService.METACAT_REPL_ERROR_MSG);

			logReplication.error("Thread sleep error: " + ie.getMessage());

		}

		logReplication.info("Notification server:" + notificationServer);

		// Check every server in the serverlists

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

			//Set comeAndGetIt null

			comeAndGetIt = null;

			// Get ReplicationServer object in index i

			ReplicationServer replicationServer = serverLists.serverAt(i);

			// Get this ReplicationServer 's name

			String server = replicationServer.getServerName();

			try {

				// If the server is the notification server, we don't notify it back

				// again, if server is null we don't replicate to

				if (server != null && !server.equals(notificationServer)) {

					if (replicationServer.isSystemMetadataReplication()) {

						comeAndGetIt = new URL("https://" + server

								+ "?action=forcereplicatesystemmetadata"

								+ "&guid=" + guid + "&server="

								+ MetacatUtil.getLocalReplicationServerName());

						logReplication.warn("Sending message: " + comeAndGetIt.toString());

						String message = ReplicationService.getURLContent(comeAndGetIt);

					}

				}

			} catch (Exception e) {

		    	logMetacat.error(ReplicationService.METACAT_REPL_ERROR_MSG, e);

				logReplication.error("Error forcing System Metadata replication");

			}

		}

		logReplication.warn("Exiting Forced System Metadata Thread");

	}

}

/*

 * Replication changes to support DataONE System Metadata replication

 */

ALTER TABLE xml_replication ADD COLUMN systemmetadatareplicate NUMBER(1);

  systemmetadatareplicate NUMBER(1),

INSERT INTO xml_replication (server, replicate, datareplicate, systemmetadatareplicate, hub)

 VALUES ('localhost', '0', '0', '0', '0');

/*

 * Replication changes to support DataONE System Metadata replication

 */

ALTER TABLE xml_replication ADD COLUMN systemmetadatareplicate INT8;

  systemmetadatareplicate INT8,

INSERT INTO xml_replication (server, replicate, datareplicate, systemmetadatareplicate, hub) VALUES ('localhost', '0', '0', '0', '0');

/*

 * ALTER TABLE xml_replication ADD COLUMN systemmetadatareplicate INT8;

 */

  private boolean systemMetadataReplication = false; //replicate system metadata or not

  public boolean isSystemMetadataReplication() {

	return systemMetadataReplication;

}

public void setSystemMetadataReplication(boolean systemMetadataReplication) {

	this.systemMetadataReplication = systemMetadataReplication;

}

		String systemMetadataReplicate = null;

				//Get system metadata replication value

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

						+ "(server, last_checked, replicate, datareplicate, systemmetadatareplicate, hub) "

						+ "VALUES (?,?,?,?,?,?)";

				pstmt.setInt(5, Integer.parseInt(systemMetadataReplicate));

				pstmt.setInt(6, Integer.parseInt(hub));

				out.write("<td><b>systemmetadatareplicate</b></td>");

				pstmt = dbConn.prepareStatement("SELECT serverid, server, last_checked, replicate, datareplicate, systemmetadatareplicate, hub FROM xml_replication");

					out.write(rs.getString(6) + "</td><td>");

					out.write(rs.getString(7) + "</td></tr>");

				out.write("<td><b>systemmetadatareplicate</b></td>");

				pstmt = dbConn.prepareStatement("SELECT serverid, server, last_checked, replicate, datareplicate, systemmetadatareplicate, hub FROM xml_replication");

					out.write(rs.getString(6) + "</td><td>");

					out.write(rs.getString(7) + "</td></tr>");

				out.write("<td><b>systemmetadatareplicate</b></td>");

				pstmt = dbConn.prepareStatement("SELECT serverid, server, last_checked, replicate, datareplicate, systemmetadatareplicate, hub FROM xml_replication");

					out.write(rs.getString(6) + "</td><td>");

					out.write(rs.getString(7) + "</td></tr>");

			// add the system metadata entries if configured to replicate them

			boolean replicateSystemMetadata = serverList.getSystemMetadataReplicationValue(server);

			if (replicateSystemMetadata) {

				Date since = new Date(System.currentTimeMillis());

				since = serverList.getLastCheckedDate(server);

				List<String> systemMetadataEntries = 

					IdentifierManager.getInstance().getUpdatedSystemMetadataIds(since);

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

					String guid = systemMetadataEntries.get(i);

					doclist.append("<updatedSystemMetadata>");

					doclist.append("<guid>");

					doclist.append(guid);

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

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

				}

			}

                    " datareplicate, systemmetadatareplicate, hub from xml_replication");

        //Data replication value

        int systemMetadataReplication = rs.getInt(5);

        logMetacat.info("DataReplication value: "+dataReplication);

        int hubValue = rs.getInt(6);

          if (systemMetadataReplication == 1) {

        	  hasSystemMetadataReplication = true;

          }

          server.setSystemMetadataReplication(hasSystemMetadataReplication);

  /**

   * To a given server name, try to get its data file replciation option

   * If couldn't find the server in the server list, false will return

   * @param givenServerName, the server's name which we want to get data file 

   * replication value

   */

  public synchronized boolean getSystemMetadataReplicationValue(String givenServerName)

  {

    int index = -1;//Variable to store the index

    ReplicationServer server = null;//Variable for replication server

    //Get the server's index in server list

    index = findIndexInServerList(givenServerName);

    //If index = -1, couldn't find this server, null will return

    if (index == -1)

    {

      return false;

    }//if

    //Get Replication server object

    server = (ReplicationServer) serverList.elementAt(index);

    //Return this object's data replication value

    return server.isSystemMetadataReplication();

  }