/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 5755

Added by ben leinfelder almost 14 years ago

only call response.getWriter() when we are about to send text/xml to the client, otherwise we end of calling both getWriter() and getOutputStream() - resulting in an illegal state.

     package edu.ucsb.nceas.metacat.replication;
     import java.util.*;
     import java.io.BufferedInputStream;
     import java.io.BufferedOutputStream;
     import java.io.File;
     import java.io.FileInputStream;
     import java.io.FileNotFoundException;
     import java.io.FileOutputStream;
     import java.io.IOException;
     import java.io.InputStream;
     import java.io.InputStreamReader;
     import java.io.OutputStream;
     import java.io.StringReader;
     import java.io.Writer;
     import java.net.MalformedURLException;
     import java.net.URL;
     import java.sql.PreparedStatement;
     import java.sql.ResultSet;
     import java.sql.SQLException;
     import java.text.SimpleDateFormat;
     import java.util.Date;
     import java.io.*;
     import java.sql.*;
     import java.net.*;
     import java.text.*;
     import java.util.Hashtable;
     import java.util.Timer;
     import java.util.Vector;
     import javax.servlet.ServletOutputStream;
     import javax.servlet.http.*;
     import javax.servlet.http.HttpServletRequest;
     import javax.servlet.http.HttpServletResponse;
     import org.apache.log4j.Logger;
     import org.xml.sax.InputSource;
     import org.xml.sax.SAXException;
     import org.xml.sax.XMLReader;
     import edu.ucsb.nceas.metacat.DocInfoHandler;
     import edu.ucsb.nceas.metacat.DocumentImpl;
     import edu.ucsb.nceas.metacat.DocumentImplWrapper;
     import edu.ucsb.nceas.metacat.EventLog;
     import edu.ucsb.nceas.metacat.IdentifierManager;
     import edu.ucsb.nceas.metacat.McdbDocNotFoundException;
     import edu.ucsb.nceas.metacat.McdbException;
     import edu.ucsb.nceas.metacat.accesscontrol.AccessControlException;
     import edu.ucsb.nceas.metacat.accesscontrol.AccessControlForSingleFile;
-...
     import edu.ucsb.nceas.metacat.util.DocumentUtil;
     import edu.ucsb.nceas.metacat.util.MetacatUtil;
     import edu.ucsb.nceas.metacat.util.SystemUtil;
     import edu.ucsb.nceas.metacat.IdentifierManager;
     import edu.ucsb.nceas.metacat.McdbDocNotFoundException;
     import edu.ucsb.nceas.utilities.FileUtil;
     import edu.ucsb.nceas.utilities.GeneralPropertyException;
     import edu.ucsb.nceas.utilities.PropertyNotFoundException;
     import org.apache.log4j.Logger;
     import org.xml.sax.*;
     public class ReplicationService extends BaseService {
     	private static ReplicationService replicationService = null;
-...
     	 * servercontrol    delete               server
     	 * servercontrol    list
     	 */
     	protected static void handleServerControlRequest(PrintWriter out,
     	protected static void handleServerControlRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response) {
     		String subaction = ((String[]) params.get("subaction"))[0];
     		DBConnection dbConn = null;
-...
     		String server = null;
     		String dataReplicate = null;
     		String hub = null;
     		Writer out = null;
     		try {
     			response.setContentType("text/xml");
     			out = response.getWriter();
     			//conn = util.openDBConnection();
     			dbConn = DBConnectionPool
     					.getDBConnection("MetacatReplication.handleServerControlRequest");
-...
     				pstmt.execute();
     				pstmt.close();
     				dbConn.commit();
     				out.println("Server " + server + " added");
     				out.write("Server " + server + " added");
     				response.setContentType("text/html");
     				out.println("<html><body><table border=\"1\">");
     				out.println("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
     				out.println("<b>replicate</b></td>");
     				out.println("<td><b>datareplicate</b></td>");
     				out.println("<td><b>hub</b></td></tr>");
     				out.write("<html><body><table border=\"1\">");
     				out.write("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
     				out.write("<b>replicate</b></td>");
     				out.write("<td><b>datareplicate</b></td>");
     				out.write("<td><b>hub</b></td></tr>");
     				pstmt = dbConn.prepareStatement("SELECT * FROM xml_replication");
     				//increase dbconnection usage
     				dbConn.increaseUsageCount(1);
-...
     				ResultSet rs = pstmt.getResultSet();
     				boolean tablehasrows = rs.next();
     				while (tablehasrows) {
     					out.println("<tr><td>" + rs.getString(2) + "</td><td>");
     					out.println(rs.getString(3) + "</td><td>");
     					out.println(rs.getString(4) + "</td><td>");
     					out.println(rs.getString(5) + "</td><td>");
     					out.println(rs.getString(6) + "</td></tr>");
     					out.write("<tr><td>" + rs.getString(2) + "</td><td>");
     					out.write(rs.getString(3) + "</td><td>");
     					out.write(rs.getString(4) + "</td><td>");
     					out.write(rs.getString(5) + "</td><td>");
     					out.write(rs.getString(6) + "</td></tr>");
     					tablehasrows = rs.next();
+    				}
     				out.println("</table></body></html>");
     				out.write("</table></body></html>");
     				// download certificate with the public key on this server
     				// and import it as a trusted certificate
-...
     				pstmt.execute();
     				pstmt.close();
     				dbConn.commit();
     				out.println("Server " + server + " deleted");
     				out.write("Server " + server + " deleted");
     				response.setContentType("text/html");
     				out.println("<html><body><table border=\"1\">");
     				out.println("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
     				out.println("<b>replicate</b></td>");
     				out.println("<td><b>datareplicate</b></td>");
     				out.println("<td><b>hub</b></td></tr>");
     				out.write("<html><body><table border=\"1\">");
     				out.write("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
     				out.write("<b>replicate</b></td>");
     				out.write("<td><b>datareplicate</b></td>");
     				out.write("<td><b>hub</b></td></tr>");
     				pstmt = dbConn.prepareStatement("SELECT * FROM xml_replication");
     				//increase dbconnection usage
-...
     				ResultSet rs = pstmt.getResultSet();
     				boolean tablehasrows = rs.next();
     				while (tablehasrows) {
     					out.println("<tr><td>" + rs.getString(2) + "</td><td>");
     					out.println(rs.getString(3) + "</td><td>");
     					out.println(rs.getString(4) + "</td><td>");
     					out.println(rs.getString(5) + "</td><td>");
     					out.println(rs.getString(6) + "</td></tr>");
     					out.write("<tr><td>" + rs.getString(2) + "</td><td>");
     					out.write(rs.getString(3) + "</td><td>");
     					out.write(rs.getString(4) + "</td><td>");
     					out.write(rs.getString(5) + "</td><td>");
     					out.write(rs.getString(6) + "</td></tr>");
     					tablehasrows = rs.next();
+    				}
     				out.println("</table></body></html>");
     				out.write("</table></body></html>");
     				// list servers in server list
     			} else if (subaction.equals("list")) {
     				response.setContentType("text/html");
     				out.println("<html><body><table border=\"1\">");
     				out.println("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
     				out.println("<b>replicate</b></td>");
     				out.println("<td><b>datareplicate</b></td>");
     				out.println("<td><b>hub</b></td></tr>");
     				out.write("<html><body><table border=\"1\">");
     				out.write("<tr><td><b>server</b></td><td><b>last_checked</b></td><td>");
     				out.write("<b>replicate</b></td>");
     				out.write("<td><b>datareplicate</b></td>");
     				out.write("<td><b>hub</b></td></tr>");
     				pstmt = dbConn.prepareStatement("SELECT * FROM xml_replication");
     				pstmt.execute();
     				ResultSet rs = pstmt.getResultSet();
     				boolean tablehasrows = rs.next();
     				while (tablehasrows) {
     					out.println("<tr><td>" + rs.getString(2) + "</td><td>");
     					out.println(rs.getString(3) + "</td><td>");
     					out.println(rs.getString(4) + "</td><td>");
     					out.println(rs.getString(5) + "</td><td>");
     					out.println(rs.getString(6) + "</td></tr>");
     					out.write("<tr><td>" + rs.getString(2) + "</td><td>");
     					out.write(rs.getString(3) + "</td><td>");
     					out.write(rs.getString(4) + "</td><td>");
     					out.write(rs.getString(5) + "</td><td>");
     					out.write(rs.getString(6) + "</td></tr>");
     					tablehasrows = rs.next();
+    				}
     				out.println("</table></body></html>");
     				out.write("</table></body></html>");
     			} else {
     				out.println("<error>Unkonwn subaction</error>");
     				out.write("<error>Unkonwn subaction</error>");
+    			}
     			pstmt.close();
-...
     			finally {
     				DBConnectionPool.returnDBConnection(dbConn, serialNumber);
     			}//finally
     			if (out != null) {
     				try {
     					out.close();
     				} catch (IOException e) {
     					logMetacat.error(e.getMessage(), e);
+    				}
+    			}
     		}//finally
+    	}
-...
     	 * to the requesting server (remote server) for the specified docid. Then
     	 * store it in local database.
     	 */
     	protected static void handleForceReplicateRequest(PrintWriter out,
     	protected static void handleForceReplicateRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response,
     			HttpServletRequest request) {
     		String server = ((String[]) params.get("server"))[0]; // the server that
-...
     	 * when a forcereplication delete request comes in, local host will delete this
     	 * document
     	 */
     	protected static void handleForceReplicateDeleteRequest(PrintWriter out,
     	protected static void handleForceReplicateDeleteRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response,
     			HttpServletRequest request) {
     		String server = ((String[]) params.get("server"))[0]; // the server that
-...
     	 * currentdate: the timestamp of the document on the remote server
+    	 *
     	 */
     	protected static void handleGetLockRequest(PrintWriter out,
     	protected static void handleGetLockRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response) {
     		try {
-...
     			int localRevInt = requestDoc.getRev();
     			int remoteRevInt = Integer.parseInt(remoteRev);
     			// get a writer for sending back to response
     			response.setContentType("text/xml");
     			Writer out = response.getWriter();
     			if (remoteRevInt >= localRevInt) {
     				if (!fileLocks.contains(docid)) { //grant the lock if it is not already locked
     					fileLocks.add(0, docid); //insert at the beginning of the queue Vector
     					//send a message back to the the remote host authorizing the insert
     					out
     							.println("<lockgranted><docid>" + docid
     					out.write("<lockgranted><docid>" + docid
     									+ "</docid></lockgranted>");
     					//          lockThread = new Thread(this);
     					//          lockThread.setPriority(Thread.MIN_PRIORITY);
     					//          lockThread.start();
     					logReplication.info("ReplicationService.handleGetLockRequest - lock granted for " + docid);
     				} else { //deny the lock
     					out.println("<filelocked><docid>" + docid + "</docid></filelocked>");
     					out.write("<filelocked><docid>" + docid + "</docid></filelocked>");
     					logReplication.info("ReplicationService.handleGetLockRequest - lock denied for " + docid
     							+ "reason: file already locked");
+    				}
     			} else {//deny the lock.
     				out.println("<outdatedfile><docid>" + docid + "</docid></filelocked>");
     				out.write("<outdatedfile><docid>" + docid + "</docid></filelocked>");
     				logReplication.info("ReplicationService.handleGetLockRequest - lock denied for " + docid
     						+ "reason: client has outdated file");
+    			}
     			out.close();
     			//conn.close();
     		} catch (Exception e) {
     			logMetacat.error("ReplicationService.handleGetLockRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);
-...
     	 *                  user_updated, home_server, public_access, rev)/>
     	 * all of the subelements of document info are #PCDATA
     	 */
     	protected static void handleGetDocumentInfoRequest(PrintWriter out,
     	protected static void handleGetDocumentInfoRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response) {
     		String docid = ((String[]) (params.get("docid")))[0];
     		StringBuffer sb = new StringBuffer();
-...
     			sb.append("</accessControl>");
     			sb.append("</documentinfo>");
     			// get a writer for sending back to response
     			response.setContentType("text/xml");
     			out.println(sb.toString());
     			Writer out = response.getWriter();
     			out.write(sb.toString());
     			out.close();
     		} catch (Exception e) {
     			logMetacat.error("ReplicationService.handleGetDocumentInfoRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);
-...
     	/**
     	 * Sends a document to a remote host
     	 */
     	protected static void handleGetDocumentRequest(PrintWriter out,
     	protected static void handleGetDocumentRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response) {
     		String urlString = null;
     		String documentPath = null;
     		String errorMsg = null;
     		try {
     			// try to open a https stream to test if the request server's public
     			// key
-...
     			// couldn't pass the test
     			if (test.indexOf("successfully") == -1) {
     				response.setContentType("text/xml");
     				out.println("<error>Couldn't pass the trust test " + test + " </error>");
     				Writer out = response.getWriter();
     				out.write("<error>Couldn't pass the trust test " + test + " </error>");
     				out.close();
     				return;
+    			}
-...
     			OutputStream outputStream = response.getOutputStream();
     			di.readFromFileSystem(outputStream, null, null, documentPath);
     			// response.setContentType("text/xml");
     			// out.print(di.toString(null, null, true));
     			logReplication.info("ReplicationService.handleGetDocumentRequest - document " + docid + " sent");
     			// return to avoid continuing to the error reporting section at the end
     			return;
     		} catch (MalformedURLException mue) {
     			logMetacat.error("ReplicationService.handleGetDocumentRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);
     			logReplication.error("ReplicationService.handleGetDocumentRequest - Url error when getting document from MetacatReplication."
     					+ "handlGetDocumentRequest for url: " + urlString + " : "
     					+ mue.getMessage());
     			// e.printStackTrace(System.out);
     			response.setContentType("text/xml");
     			out.println("<error>" + mue.getMessage() + "</error>");
     		} catch (IOException ioe) {
     			logMetacat.error("ReplicationService.handleGetDocumentRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);
     			logReplication.error("ReplicationService.handleGetDocumentRequest - I/O error when getting document from MetacatReplication."
     					+ "handlGetDocumentRequest for file: " + documentPath + " : "
     					+ ioe.getMessage());
     			// e.printStackTrace(System.out);
     			response.setContentType("text/xml");
     			out.println("<error>" + ioe.getMessage() + "</error>");
     			errorMsg = ioe.getMessage();
     		} catch (PropertyNotFoundException pnfe) {
     			logMetacat.error("ReplicationService.handleGetDocumentRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);
     			logReplication
-...
     							+ " : "
     							+ pnfe.getMessage());
     			// e.printStackTrace(System.out);
     			response.setContentType("text/xml");
     			out.println("<error>" + pnfe.getMessage() + "</error>");
     			errorMsg = pnfe.getMessage();
     		} catch (McdbException me) {
     			logReplication
     					.error("ReplicationService.handleGetDocumentRequest - Document implementation error  getting property when getting document from MetacatReplication."
-...
     							+ " : "
     							+ me.getMessage());
     			// e.printStackTrace(System.out);
     			response.setContentType("text/xml");
     			out.println("<error>" + me.getMessage() + "</error>");
     			errorMsg = me.getMessage();
+    		}
     		// report any errors if we got here
     		response.setContentType("text/xml");
     		Writer out = null;
     		try {
     			response.getWriter();
     			out = response.getWriter();
     			out.write("<error>" + errorMsg + "</error>");
     		} catch (Exception e) {
     			logMetacat.error(e.getMessage(), e);
     		} finally {
     			try {
     				out.close();
     			} catch (IOException e) {
     				logMetacat.error(e.getMessage(), e);
+    			}
+    		}
+    	}
-...
     	 * in deletedDocument is always empty. I just left it in there to make the
     	 * parser implementation easier.
     	 */
     	protected static void handleUpdateRequest(PrintWriter out, Hashtable<String, String[]> params,
     	protected static void handleUpdateRequest(Hashtable<String, String[]> params,
     			HttpServletResponse response) {
     		// Checked out DBConnection
     		DBConnection dbConn = null;
-...
     		PreparedStatement pstmt = null;
     		// Server list to store server info of xml_replication table
     		ReplicationServerList serverList = null;
     		// a writer for response
     		Writer out = null;
     		try {
     			// get writer, TODO: encoding?
     			response.setContentType("text/xml");
     			out = response.getWriter();
     			// Check out a DBConnection from pool
     			dbConn = DBConnectionPool
     					.getDBConnection("MetacatReplication.handleUpdateRequest");
-...
     			String server = ((String[]) params.get("server"))[0];
     			// If no servr name in param, return a error
     			if (server == null || server.equals("")) {
     				response.setContentType("text/xml");
     				out.println("<error>Request didn't specify server name</error>");
     				out.write("<error>Request didn't specify server name</error>");
     				out.close();
     				return;
     			}//if
-...
     			//couldn't pass the test
     			if (test.indexOf("successfully") == -1) {
     			    logReplication.error("Trust test failed.");
     				response.setContentType("text/xml");
     				out.println("<error>Couldn't pass the trust test</error>");
     				out.write("<error>Couldn't pass the trust test</error>");
     				out.close();
     				return;
+    			}
-...
     			// Check if local host configure to replicate xml documents to remote
     			// server. If not send back a error message
     			if (!serverList.getReplicationValue(server)) {
     				response.setContentType("text/xml");
     				out
     						.println("<error>Configuration not allow to replicate document to you</error>");
     				out.write("<error>Configuration not allow to replicate document to you</error>");
     				out.close();
     				return;
     			}//if
-...
     			logReplication.info("ReplicationService.handleUpdateRequest - doclist: " + doclist.toString());
     			pstmt.close();
     			//conn.close();
     			response.setContentType("text/xml");
     			out.println(doclist.toString());
     			out.write(doclist.toString());
     		} catch (Exception e) {
     			logMetacat.error("ReplicationService.handleUpdateRequest - " + ReplicationService.METACAT_REPL_ERROR_MSG);
     			logReplication.error("ReplicationService.handleUpdateRequest - error in MetacatReplication." + "handleupdaterequest: "
     					+ e.getMessage());
     			//e.printStackTrace(System.out);
     			response.setContentType("text/xml");
     			out.println("<error>" + e.getMessage() + "</error>");
     			try {
     				out.write("<error>" + e.getMessage() + "</error>");
     			} catch (IOException e1) {
     				logMetacat.error(e1.getMessage(), e1);
+    			}
     		} finally {
     			try {
     				pstmt.close();
-...
     			finally {
     				DBConnectionPool.returnDBConnection(dbConn, serialNumber);
     			}//finally
     			try {
     				out.close();
     			} catch (IOException e) {
     				logMetacat.error(e.getMessage(), e);
+    			}
     		}//finally
     	}//handlUpdateRequest
-...
     	 * Returns the xml_catalog table encoded in xml
     	 */
     	public static String getCatalogXML() {
     		return handleGetCatalogRequest(null, null, null, false);
     		return handleGetCatalogRequest(null, null, false);
+    	}
     	/**
-...
     	 * If printFlag == false then do not print to out.
     	 */
     	protected static String handleGetCatalogRequest(PrintWriter out,
     	protected static String handleGetCatalogRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response,
     			boolean printFlag) {
     		DBConnection dbConn = null;
     		int serialNumber = -1;
     		PreparedStatement pstmt = null;
     		Writer out = null;
     		try {
     			// get writer, TODO: encoding?
     			response.setContentType("text/xml");
     			out = response.getWriter();
     			/*conn = MetacatReplication.getDBConnection("MetacatReplication." +
     			                                          "handleGetCatalogRequest");*/
     			dbConn = DBConnectionPool
-...
     			//conn.close();
     			if (printFlag) {
     				response.setContentType("text/xml");
     				out.println(sb.toString());
     				out.write(sb.toString());
+    			}
     			pstmt.close();
     			return sb.toString();
-...
     					+ e.getMessage());
     			e.printStackTrace(System.out);
     			if (printFlag) {
     				out.println("<error>" + e.getMessage() + "</error>");
     				try {
     					out.write("<error>" + e.getMessage() + "</error>");
     				} catch (IOException e1) {
     					logMetacat.error(e1.getMessage(), e1);
+    				}
+    			}
     		} finally {
     			try {
-...
     			finally {
     				DBConnectionPool.returnDBConnection(dbConn, serialNumber);
     			}//finally
     			if (out != null) {
     				try {
     					out.close();
     				} catch (IOException e1) {
     					logMetacat.error(e1.getMessage(), e1);
+    				}
+    			}
     		}//finally
     		return null;
-...
     	 * for replication gets rid of any problems with syncronizing clocks
     	 * because a time specific to a document is always kept on its home server.
     	 */
     	protected static void handleGetTimeRequest(PrintWriter out,
     	protected static void handleGetTimeRequest(
     			Hashtable<String, String[]> params, HttpServletResponse response) {
     		SimpleDateFormat formatter = new SimpleDateFormat("MM/dd/yy HH:mm:ss");
     		java.util.Date localtime = new java.util.Date();
     		String dateString = formatter.format(localtime);
     		// get a writer for sending back to response
     		response.setContentType("text/xml");
     		out.println("<timestamp>" + dateString + "</timestamp>");
     		Writer out = null;
     		try {
     			out = response.getWriter();
     			out.write("<timestamp>" + dateString + "</timestamp>");
     			out.close();
     		} catch (IOException e) {
     			logMetacat.error(e.getMessage(), e);
+    		}
+    	}
     	/**

     package edu.ucsb.nceas.metacat.replication;
     import java.util.*;
     import java.io.*;
     import java.io.IOException;
     import java.io.OutputStream;
     import java.io.PrintWriter;
     import java.util.Enumeration;
     import java.util.Hashtable;
     import javax.servlet.*;
     import javax.servlet.http.*;
     import javax.servlet.ServletConfig;
     import javax.servlet.ServletException;
     import javax.servlet.http.HttpServlet;
     import javax.servlet.http.HttpServletRequest;
     import javax.servlet.http.HttpServletResponse;
     import javax.servlet.http.HttpSession;
     import org.apache.log4j.Logger;
     import edu.ucsb.nceas.metacat.service.ServiceService;
     import edu.ucsb.nceas.metacat.service.SessionService;
     import edu.ucsb.nceas.metacat.shared.MetacatUtilException;
-...
     import edu.ucsb.nceas.metacat.util.AuthUtil;
     import edu.ucsb.nceas.metacat.util.SessionData;
     import org.apache.log4j.Logger;
     public class ReplicationServlet extends HttpServlet {
     	private static final long serialVersionUID = -2898600143193513155L;
-...
     	private void handleGetOrPost(HttpServletRequest request, HttpServletResponse response)
     			throws ServletException, IOException {
     		PrintWriter out = response.getWriter();
     		PrintWriter out = null;
     		Hashtable<String, String[]> params = new Hashtable<String, String[]>();
     		Enumeration<String> paramlist = request.getParameterNames();
-...
     			} else if (action.equals("stop")) {
     				// stop the replication server
     				ReplicationService.getInstance().stopReplication();
     				out = response.getWriter();
     				out.println("Replication Handler Stopped");
     			} else if (action.equals("start")) {
     				ReplicationService.getInstance().startReplication(params);
     				out = response.getWriter();
     				out.println("Replication Handler Started");
     			} else if (action.equals("getall")) {
     				ReplicationService.getInstance().runOnce();
     				response.setContentType("text/html");
     				out = response.getWriter();
     				out.println("<html><body>\"Get All\" Done</body></html>");
     			} else if (action.equals("forcereplicate")) {
     				// read a specific docid from remote host, and store it into
     				// local host
     				ReplicationService.handleForceReplicateRequest(out, params, response,
     				ReplicationService.handleForceReplicateRequest(params, response,
     						request);
     			} else if (action.equals("forcereplicatedelete")) {
     				// read a specific docid from remote host, and store it into
     				// local host
     				ReplicationService.handleForceReplicateDeleteRequest(out, params,
     				ReplicationService.handleForceReplicateDeleteRequest(params,
     						response, request);
     			} else if (action.equals("update")) {
     				// request an update list from the server
     				ReplicationService.handleUpdateRequest(out, params, response);
     				ReplicationService.handleUpdateRequest(params, response);
     			} else if (action.equals("read")) {
     				// request a specific document from the server
     				// note that this could be replaced by a call to metacatServlet
     				// handleGetDocumentAction().
     				ReplicationService.handleGetDocumentRequest(out, params, response);
     				ReplicationService.handleGetDocumentRequest(params, response);
     			} else if (action.equals("getlock")) {
     				ReplicationService.handleGetLockRequest(out, params, response);
     				ReplicationService.handleGetLockRequest(params, response);
     			} else if (action.equals("getdocumentinfo")) {
     				ReplicationService.handleGetDocumentInfoRequest(out, params, response);
     				ReplicationService.handleGetDocumentInfoRequest(params, response);
     			} else if (action.equals("gettime")) {
     				ReplicationService.handleGetTimeRequest(out, params, response);
     				ReplicationService.handleGetTimeRequest(params, response);
     			} else if (action.equals("getcatalog")) {
     				ReplicationService.handleGetCatalogRequest(out, params, response, true);
     				ReplicationService.handleGetCatalogRequest(params, response, true);
     			} else if (action.equals("servercontrol")) {
     				ReplicationService.handleServerControlRequest(out, params, response);
     				ReplicationService.handleServerControlRequest(params, response);
     			} else if (action.equals("test")) {
     				response.setContentType("text/html");
     				out = response.getWriter();
     				out.println("<html><body>Test successfully</body></html>");
+    			}
-...
     			logReplication.error("ReplicationServlet.handleGetOrPost - Metacat utility error in ReplicationServlet.handleGetOrPost: "
     							+ mue.getMessage());
     		} finally {
     			out.close();
     			if (out != null) {
     				out.close();
+    			}
+    		}
+    	}
+    }

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 5755

Added by ben leinfelder almost 14 years ago