/ - Diff - Metacat - Ecoinformatics Redmine

             replicationDaemon.scheduleAtFixedRate(new ReplicationHandler(out), 0,
                                                   rate * 1000);
             out.println("Replication Handler Started");
             System.out.println("Replication Handler Started");
+          }
           else if(((String[])params.get("action"))[0].equals("forcereplicate"))
+          {
             replicationDaemon.schedule(new ReplicationHandler(out), 0);
+          }
           else if(((String[])params.get("action"))[0].equals("update"))
           { //request an update list from the server
             handleUpdateRequest(out, params, response);
-...
+        {
           Connection conn = util.openDBConnection();
           String docid = ((String[])params.get("docid"))[0];
     System.out.println("docid: " + docid);
           String remoteDateStr = ((String[])params.get("updatedate"))[0];
           DocumentImpl requestDoc = new DocumentImpl(conn, docid);
-...
           remoteDate = formatter.parse(remoteDateStr, pos);
           pos = new ParsePosition(0);
           localDate = formatter.parse(localDateStr, pos);
     System.out.println("remotedate: " + remoteDate.toString());
     System.out.println("localdate: " + localDate.toString());
           if(remoteDate.compareTo(localDate) >= 0)
+          {
             if(!fileLocks.contains(docid))
-...
+        }
+      }
       /**
        * Initiates an update of all server in the xml_replication table.
        * the remote host sends an update date.  The local host (this method)
        * 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.
        */
       private void handleUpdateRequest(PrintWriter out, Hashtable params,
                                        HttpServletResponse response)
+      {

           if(openingtag.equals("<lockgranted>"))
           {//the lock was granted go ahead with the insert
             if ( action.equals("UPDATE") )
+            {
               // check for 'write' permission for 'user' to update this document
               if ( !hasWritePermission(conn, docid, user, group) )
+              {
                 throw new Exception("User " + user +
                       " does not have permission to update XML Document #" + docid);
+              }
+            }
             try
+            {
               XMLReader parser = initializeParser(conn,action,newdocid,user,serverCode);
-...
+                }
                 AccessControlList aclobj = new AccessControlList(conn, newdocid, acl);
                 conn.commit();
+              }
+              }
               conn.setAutoCommit(true);
+            }
             catch (Exception e)
+            {

+            }
+          }
           //update the last_update field for each server to the current date/time
           SimpleDateFormat formatter = new SimpleDateFormat ("yy-MM-dd HH:mm:ss");
           java.util.Date newDate = new java.util.Date(System.currentTimeMillis());
           ParsePosition pos = new ParsePosition(0);
           String dateString = formatter.format(newDate);
           //System.out.println("dateString: " + dateString);
           StringBuffer sql = new StringBuffer();
           sql.append("update xml_replication set last_checked = to_date('");
           sql.append(dateString).append("', 'YY-MM-DD HH24:MI:SS')");
           //System.out.println("sql: " + sql.toString());
           pstmt = conn.prepareStatement(sql.toString());
           pstmt.executeUpdate();
           //conn.commit();
           System.out.println("last_checked updated: " + dateString);
           keys = serverList.keys();
           while(keys.hasMoreElements())
+          {
             server = (String)(keys.nextElement());
             URL dateurl = new URL("http://" + server + "?action=gettime");
             String datexml = MetacatReplication.getURLContent(dateurl);
             System.out.println("datexml: " + datexml);
             String datestr = datexml.substring(11, datexml.indexOf('<', 11));
             System.out.println("datestr: " + datestr);
             StringBuffer sql = new StringBuffer();
             sql.append("update xml_replication set last_checked = to_date('");
             sql.append(datestr).append("', 'YY-MM-DD HH24:MI:SS') where ");
             sql.append("server like '").append(server).append("'");
             //System.out.println("sql: " + sql.toString());
             pstmt = conn.prepareStatement(sql.toString());
             pstmt.executeUpdate();
             //conn.commit();
             System.out.println("last_checked updated to " + datestr + " on " +
                                 server);
+          }
+        }
         catch(Exception e)

Project

General

Profile

Metacat

Revision 572

Added by berkley almost 24 years ago