Metacat

        out.println("Replication Handler Started");

        System.out.println("Replication Handler Started");

      }

      else if(((String[])params.get("action"))[0].equals("forcereplicate"))

      {

        handleForceReplicateRequest(out, params, response);

      {

        handleGetCatalogRequest(out, params, response, true);

      }

    }

  }

  /**

   * when a forcereplication request comes in, this method sends a read request

   * to the requesting server for the specified docid.

          lockThread = new Thread(this);

          lockThread.setPriority(Thread.MIN_PRIORITY);

          lockThread.start();

          MetacatReplication.replLog("lock granted for " + docid);

        }

        else

      out.print(di.toString());

      conn.close();

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

    }

    catch(Exception e)

    {

  {

    try

    {

      StringBuffer docsql = new StringBuffer();

      StringBuffer doclist = new StringBuffer();

      conn.close();

      response.setContentType("text/xml");

      out.println(doclist.toString());

    }

    catch(Exception e)

    {

    {

      MetaCatUtil.debugMessage("thread started for docid: " + 

                               (String)fileLocks.elementAt(0));

      Thread.sleep(30000); //the lock will expire in 30 seconds

      MetaCatUtil.debugMessage("thread for docid: " + 

      fileLocks.remove(fileLocks.size() - 1);

      //fileLocks is treated as a FIFO queue.  If there are more than one lock

      //in the vector, the first one inserted will be removed.

    catch(Exception e)

    {

      System.out.println("error writing to replication log");

    }

  }

}

    XMLReader parser;

    URL u;

    try

    {

      MetaCatUtil.debugMessage("init parser");

      keys = serverList.keys();

      while(keys.hasMoreElements())

      {

        server = (String)(keys.nextElement());

        MetacatReplication.replLog("full update started to: " + server);

        u = new URL("http://" + server + "?action=update");

        String result = MetacatReplication.getURLContent(u);

        responses.add(result);

      }

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

      { //check each server for updated files

          { //if the document needs to be updated or inserted, this is executed

            u = new URL("http://" + docServer + "?action=read&docid=" +

                          docid);

            String newxmldoc = MetacatReplication.getURLContent(u);

            DocInfoHandler dih = new DocInfoHandler();

            XMLReader docinfoParser = initParser(dih);

            URL docinfoUrl = new URL("http://" + docServer + 

                                   "?action=getdocumentinfo&docid=" +

                                   docid);

            String docInfoStr = MetacatReplication.getURLContent(docinfoUrl);

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

            Hashtable docinfoHash = dih.getDocInfo();

                              true);

            MetacatReplication.replLog("wrote doc " + docid + " from " + 

                                        docServer);

          }

        }

          if(!alreadyDeleted(docid, conn))

          {

            DocumentImpl.delete(conn, docid, null, null);

            MetacatReplication.replLog("doc " + docid + " deleted");

          }

        }

          pstmt = conn.prepareStatement(sql.toString());

          pstmt.executeUpdate();

          //conn.commit();

                            server);

        }

      }

      while(keys.hasMoreElements())

      { //go through each server

        server = (String)(keys.nextElement());

        URL u = new URL("http://" + server + "?action=getcatalog");

        String catxml = MetacatReplication.getURLContent(u);

        CatalogMessageHandler cmh = new CatalogMessageHandler();

        XMLReader catparser = initParser(cmh);

        catparser.parse(new InputSource(new StringReader(catxml)));

        Vector remoteCatalog = cmh.getCatalogVect();

        String localcatxml = MetacatReplication.getCatalogXML();

        cmh = new CatalogMessageHandler();

        catparser = initParser(cmh);

        catparser.parse(new InputSource(new StringReader(localcatxml)));

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

        {

          Vector v = new Vector((Vector)localCatalog.elementAt(i));

          publicId.add(new String((String)v.elementAt(3)));

        }

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

        {

          Vector v = (Vector)remoteCatalog.elementAt(i);

          //System.out.println("i: " + i);

          //System.out.println("remoteCatalog.size(): " + remoteCatalog.size());

          if(!publicId.contains(v.elementAt(3)))

          { //so we don't have this public id in our local table so we need to

            //add it.

            StringBuffer sql = new StringBuffer();

            sql.append("insert into xml_catalog (entry_type, source_doctype, ");

            sql.append("target_doctype, public_id, system_id) values (?,?,?,");

            sql.append("?,?)");

            PreparedStatement pstmt = conn.prepareStatement(sql.toString());

            pstmt.setString(1, (String)v.elementAt(0));

            pstmt.setString(2, (String)v.elementAt(1));

       || currentTag.equals("target_doctype") || currentTag.equals("public_id")

       || currentTag.equals("system_id"))

    {

      indivUpdate.add((new String(ch, start, length)).trim());

    }

  }