/ - Diff - Metacat - Ecoinformatics Redmine

                                    HttpServletResponse response)
                                    throws ServletException, IOException
+      {
     System.out.println("in metacatreplication");
         PrintWriter out = response.getWriter();
         Hashtable params = new Hashtable();
         Enumeration paramlist = request.getParameterNames();
-...
+          }
           else if(((String[])params.get("action"))[0].equals("forcereplicate"))
+          {
             replicationDaemon.schedule(new ReplicationHandler(out), 0);
             String server = ((String[])params.get("server"))[0];
             int serverCheckCode = 0;
             try
+            {
               serverCheckCode = MetacatReplication.getServerCode(server);
+            }
             catch(Exception e)
+            {
               System.out.println("error in metacatReplication.handleUpdateRequest"+
                                  ": could not get server code");
+            }
             replicationDaemon.schedule(new ReplicationHandler(out, serverCheckCode),
 );
+          }
           else if(((String[])params.get("action"))[0].equals("update"))
           { //request an update list from the server
             handleUpdateRequest(out, params, response);
             if(params.contains("servercheckcode"))
+            {
               System.out.println("metacatreplication: servercheckcode: " +
                                    ((int[])params.get("servercheckcode"))[0]);
               handleUpdateRequest(out, params, response,
                                   ((int[])params.get("servercheckcode"))[0]);
+            }
             else
+            {
               handleUpdateRequest(out, params, response);
+            }
+          }
           else if(((String[])params.get("action"))[0].equals("read"))
           { //request a specific document from the server
-...
+        }
+      }
       /**
        * Does default handling for update requests
        */
       private void handleUpdateRequest(PrintWriter out, Hashtable params,
                                        HttpServletResponse response)
+      {
         handleUpdateRequest(out, params, response, 1);
+      }
       /**
        * Initiates an update of all server in the xml_replication table.
-...
        * queries the db for any document that was updated after the update date
        * and returns a list of those documents to the remote host.  It also
        * sends back a list of the files that were locally deleted.
        * serverCheckCode allows the requestor to request documents from this
        * server that reside on a different server.  Normally, this server
        * should only replicate files that it owns but in the case of updating
        * a file that does not belong to this server, it is needed.  See
        * DocumentImpl.write().
        */
       private void handleUpdateRequest(PrintWriter out, Hashtable params,
                                        HttpServletResponse response)
+      {
                                        HttpServletResponse response,
                                        int serverCheckCode)
+      {
         System.out.println("incoming update request for dt/time " +
                            ((String[])params.get("date"))[0] +
                            " from external metacat");
-...
             String docid = rs.getString(1);
             String dateUpdated = rs.getString(2);
             int serverCode = rs.getInt(3);
             if(serverCode == 1)
             if(serverCode == serverCheckCode)
             { //check that this document is from this server.
               //servers only replicate their own documents!
               returnXML.append("<updatedDocument><docid>").append(docid);

       public static String write( Connection conn, Reader xml, Reader acl,
                                   String action, String docid, String user,
                                   String group, int serverCode )
                     throws Exception {
                     throws Exception
+      {
     System.out.println("in write!!!!");
         MetaCatUtil util = new MetaCatUtil();
             // Determine if the docid is OK for INSERT or UPDATE
         AccessionNumber ac = new AccessionNumber(conn);
         String newdocid = ac.generate(docid, action);
-...
             //after inserting the document locally, tell the document's home server
             //to come get a copy from here.
             URL comeAndGetIt = new URL("http://" + server +
                                        "?action=forcereplicate&");
                                        "?action=forcereplicate&server=" +
                                        util.getOption("server") +
                                        util.getOption("replicationpath"));
             System.out.println("documentimpl url: " + comeAndGetIt.toString());
             String message = MetacatReplication.getURLContent(comeAndGetIt);
             if ( (docid != null) && !(newdocid.equals(docid)) )

      */
     public class ReplicationHandler extends TimerTask
+    {
       int serverCheckCode = 1;
       MetaCatUtil util = new MetaCatUtil();
       Hashtable serverList = new Hashtable();
       Connection conn;
-...
         this.out = o;
+      }
       public ReplicationHandler(PrintWriter o, int serverCheckCode)
+      {
         this.out = o;
         this.serverCheckCode = serverCheckCode;
+      }
       /**
        * Method that implements TimerTask.run().  It runs whenever the timer is
        * fired.
-...
             update = update.replace(' ', '+');
             u = new URL("http://" + server + "?action=update&date=" + update);
             if(serverCheckCode != 1)
+            {
               u = new URL("http://" + server + "?action=update&date=" + update +
                           "&servercheckcode=" + serverCheckCode);
+            }
             else
+            {
               u = new URL("http://" + server + "?action=update&date=" + update);
+            }
             responses.add(MetacatReplication.getURLContent(u)); //list of updates
+          }

Project

General

Profile

Metacat

Revision 573

Added by berkley over 23 years ago