/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 1023

Added by Jing Tao over 22 years ago

Add two method: handleGetDataFileRequest and handleForceReplicateDataFile. The two methods will handle data file replication.

+        }
         if ( action.equals("readdata") )
+        {
           ServletOutputStream out=response.getOutputStream();
           OutputStream out=response.getOutputStream();
           //to get the data file.
           handleGetDataFileRequest(out, params, response);
           out.close();
+        }
         else if ( action.equals("forcereplicatedatafile") )
+        {
           //OutputStream out=response.getOutputStream();
           //read a specific docid from remote host, and store it into local host
           handleForceReplicateDataFileRequest(params);
           //out.close();
+        }
         else
+        {
         PrintWriter out = response.getWriter();
-...
         } else if ( action.equals("forcereplicate") ) {
           //read a specific docid from remote host, and store it into local host
           handleForceReplicateRequest(out, params, response);
         } else if ( action.equals("update") ) {
           //request an update list from the server
           handleUpdateRequest(out, params, response);
-...
+      }
       /**
        * when a forcereplication data file request comes in, local host sends a
        * readdata request to the requesting server (remote server) for the specified
        * docid. Then store it in local database and file system
        */
       private void handleForceReplicateDataFileRequest(Hashtable params)
+      {
         //check if the metacat was configured to handle replication
         if (!(util.getOption("replicationdata")).equals("on"))
+        {
           return;
+        }
         //make sure there is some parameters
         if(params.isEmpty())
+        {
           return;
+        }
         String server = ((String[])params.get("server"))[0]; // the server that
         //docid should include rev number
         String docid = ((String[])params.get("docid"))[0]; // sent the document
         if (docid==null)
+        {
           util.debugMessage("Didn't specify docid for replication");
           return;
+        }
         //docid was switch to two parts
         boolean override = false;
         int serverCode = 1;
         String dbaction=null;
         Connection conn=null;
         try
+        {
           //docid was switch to two parts
           String uniqueCode=MetaCatUtil.getDocIdFromString(docid);
           int rev=MetaCatUtil.getVersionFromString(docid);
           if(params.containsKey("dbaction"))
+          {
             dbaction = ((String[])params.get("dbaction"))[0];
+          }
           else//default value is update
+          {
             dbaction = "update";
+          }
           serverCode = MetacatReplication.getServerCode(server);
           MetacatReplication.replLog("force replication request from " + server);
           // get the document info from server
           URL docinfourl = new URL("https://" + server +
                                    "?server="+util.getLocalReplicationServerName()
                                    +"&action=getdocumentinfo&docid=" + uniqueCode);
           String docInfoStr = MetacatReplication.getURLContent(docinfourl);
           //dih is the parser for the docinfo xml format
           DocInfoHandler dih = new DocInfoHandler();
           XMLReader docinfoParser = ReplicationHandler.initParser(dih);
           docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));
           Hashtable docinfoHash = dih.getDocInfo();
           String user = (String)docinfoHash.get("user_owner");
           String docName = (String)docinfoHash.get("docname");
           String docType = (String)docinfoHash.get("doctype");
           conn = util.openDBConnection();
           //if action is delete, we don't delete the data file. Just archieve
           //the xml_documents
           if (dbaction.equals("delete"))
+          {
             DocumentImpl.delete(conn,docid,user,null);
+          }
           else if (dbaction.equals("insert"))
+          {
             //register data information into xml_documents table
             DocumentImpl.registerDocument(docName,docType,docid,user,serverCode);
             //Get data file and store it into local file system.
             // sending back readdata request to server
             URL url = new URL("https://" + server + "?server="
                     +util.getLocalReplicationServerName()
                     +"&action=readdata&docid=" + docid);
             //Create file to store the data.
             String datafilepath = util.getOption("datafilepath");
             File dataDirectory = new File(datafilepath);
             //dataDirectory.mkdirs();
             File newFile = new File(dataDirectory, docid);
             // create a buffered byte output stream
             // that uses a default-sized output buffer
             FileOutputStream fos = new FileOutputStream(newFile);
             BufferedOutputStream outPut = new BufferedOutputStream(fos);
             BufferedInputStream bis = null;
             bis = new BufferedInputStream(url.openStream());
             byte[] buf = new byte[4 * 1024]; // 4K buffer
             int b = bis.read(buf);
             while (b != -1)
+            {
               outPut.write(buf, 0, b);
               b = bis.read(buf);
+            }
             bis.close();
     	      outPut.close();
     	      fos.close();
+         }
          else if (dbaction.equals("update"))
+         {
             //archieve old entry
             DocumentImpl.unRegisterDocument(conn,docid,user,null);
             //register new one
             DocumentImpl.registerDocument(docName,docType,docid,user,serverCode);
             // sending back readdata request to server
             URL url = new URL("https://" + server + "?server="
                     +util.getLocalReplicationServerName()
                     +"&action=readdata&docid=" + docid);
             //Create file to store the data.
             String datafilepath = util.getOption("datafilepath");
             File dataDirectory = new File(datafilepath);
             //dataDirectory.mkdirs();
             File newFile = new File(dataDirectory, docid);
             // create a buffered byte output stream
             // that uses a default-sized output buffer
             FileOutputStream fos = new FileOutputStream(newFile);
             BufferedOutputStream outPut = new BufferedOutputStream(fos);
             BufferedInputStream bis = null;
             bis = new BufferedInputStream(url.openStream());
             byte[] buf = new byte[4 * 1024]; // 4K buffer
             int b = bis.read(buf);
             System.out.println("before the while loop");
             while (b != -1)
+            {
               outPut.write(buf, 0, b);
               b = bis.read(buf);
+            }
             bis.close();
     	      outPut.close();
     	      fos.close();
+        }
         conn.close();
         MetacatReplication.replLog("document " + docid + " added to DB with " +
                                      "action " + dbaction);
         } catch(Exception e)
+        {
           try
+          {
             conn.close();
+          }
           catch (SQLException sqlE)
+          {
             util.debugMessage(sqlE.getMessage());
+          }
           System.out.println("ERROR in MetacatReplication.handleForceReplicate" +
                              "Request(): " + e.getMessage());
+        }
+      }
       /**
        * Grants or denies a lock to a requesting host.
        * The servlet parameters of interrest are:
        * docid: the docid of the file the lock is being requested for
-...
       /**
        * Sends a datafile to a remote host
        */
       private void handleGetDataFileRequest(ServletOutputStream outPut,
       private void handleGetDataFileRequest(OutputStream outPut,
                                 Hashtable params, HttpServletResponse response)
+      {
         //check the metacat was configured to handle data replication
         if (!(util.getOption("replicationdata")).equals("on"))
+        {
           return;
+        }
         String filepath = util.getOption("datafilepath");
         String docId = ((String[])(params.get("docid")))[0];
         //check if the doicd is null
         if (docId==null)
+        {
           util.debugMessage("Didn't specify docid for replication");
           return;
+        }
         if(!filepath.endsWith("/"))
+        {
               filepath += "/";
+        }
         String filename = filepath + docId;      //MIME type
         System.out.println("filename: "+filename);
         String contentType = null;//getServletContext().getMimeType(filename);
         System.out.println("after getMimeType");
         if (contentType == null)
+        {
            if (filename.endsWith(".xml"))
-...
+              }
+           }
+       }
        System.out.println("contentye: "+contentType);
        response.setContentType(contentType);
        // if we decide to use "application/octet-stream" for all data returns
        // response.setContentType("application/octet-stream");
        FileInputStream fin = null;
        try
+       {
           System.out.println("in try");
           System.out.println(" after get output stream");
           fin = new FileInputStream(filename);
           System.out.println("here");
           byte[] buf = new byte[4 * 1024]; // 4K buffer
           int b = fin.read(buf);
           while (b != -1)
+          {
             System.out.println("in while loop");
             outPut.write(buf, 0, b);
             b = fin.read(buf);
+          }
           System.out.println(" before close");
           fin.close();
           System.out.println(" after close");
+       }
        catch(Exception e)
+       {

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 1023

Added by Jing Tao over 22 years ago