incubator-connectors-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r988237 [20/24] - in /incubator/lcf/trunk: modules/connectors/activedirectory/connector/org/apache/acf/authorities/authorities/activedirectory/ modules/connectors/documentum/connector/org/apache/acf/crawler/authorities/DCTM/ modules/connect...
Date Mon, 23 Aug 2010 18:08:42 GMT
Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/Jobs.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/Jobs.java?rev=988237&r1=988236&r2=988237&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/Jobs.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/Jobs.java Mon Aug 23 18:08:32 2010
@@ -190,7 +190,7 @@ public class Jobs extends org.apache.acf
   *@param database is the database handle.
   */
   public Jobs(IThreadContext threadContext, IDBInterface database)
-    throws LCFException
+    throws ACFException
   {
     super(database,"jobs");
     this.threadContext = threadContext;
@@ -205,7 +205,7 @@ public class Jobs extends org.apache.acf
   /** Install or upgrade this table.
   */
   public void install(String outputTableName, String outputNameField, String connectionTableName, String connectionNameField)
-    throws LCFException
+    throws ACFException
   {
     // Standard practice: Have a loop around everything, in case upgrade needs it.
     while (true)
@@ -276,7 +276,7 @@ public class Jobs extends org.apache.acf
   /** Uninstall.
   */
   public void deinstall()
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -285,7 +285,7 @@ public class Jobs extends org.apache.acf
       scheduleManager.deinstall();
       performDrop(null);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -305,7 +305,7 @@ public class Jobs extends org.apache.acf
   *@return the time, in minutes.
   */
   public int getAnalyzeTime()
-    throws LCFException
+    throws ACFException
   {
     // Since we never expect jobs to grow rapidly, every 24hrs should always be fine
     return 24 * 60;
@@ -314,7 +314,7 @@ public class Jobs extends org.apache.acf
   /** Analyze job tables that need analysis.
   */
   public void analyzeTables()
-    throws LCFException
+    throws ACFException
   {
     analyzeTable();
   }
@@ -322,7 +322,7 @@ public class Jobs extends org.apache.acf
   /** Read schedule records for a specified set of jobs.  Cannot use caching!
   */
   public ScheduleRecord[][] readScheduleRecords(Long[] jobIDs)
-    throws LCFException
+    throws ACFException
   {
     Map uniqueIDs = new HashMap();
     int i = 0;
@@ -364,7 +364,7 @@ public class Jobs extends org.apache.acf
       signalRollback();
       throw e;
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -403,7 +403,7 @@ public class Jobs extends org.apache.acf
   *@return the array of all jobs.
   */
   public IJobDescription[] getAll()
-    throws LCFException
+    throws ACFException
   {
     // Begin transaction
     beginTransaction();
@@ -431,7 +431,7 @@ public class Jobs extends org.apache.acf
       }
       return loadMultiple(ids,readOnlies);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -451,7 +451,7 @@ public class Jobs extends org.apache.acf
   *@return a resultset with "jobid" and "connectionname" fields.
   */
   public IResultSet getActiveJobConnections()
-    throws LCFException
+    throws ACFException
   {
     return performQuery("SELECT "+idField+" AS jobid,"+connectionNameField+" AS connectionname FROM "+getTableName()+" WHERE "+
       statusField+" IN ("+
@@ -463,7 +463,7 @@ public class Jobs extends org.apache.acf
   *@return the array of connection names corresponding to active jobs.
   */
   public String[] getActiveConnectionNames()
-    throws LCFException
+    throws ACFException
   {
     IResultSet set = performQuery("SELECT DISTINCT "+connectionNameField+" FROM "+getTableName()+" WHERE "+
       statusField+" IN ("+
@@ -482,7 +482,7 @@ public class Jobs extends org.apache.acf
 
   /** Are there any jobs that have a specified priority level */
   public boolean hasPriorityJobs(int priority)
-    throws LCFException
+    throws ACFException
   {
     IResultSet set = performQuery("SELECT * FROM "+getTableName()+" WHERE "+priorityField+"="+Integer.toString(priority)+
       " AND "+
@@ -495,7 +495,7 @@ public class Jobs extends org.apache.acf
   /** Create a job.
   */
   public IJobDescription create()
-    throws LCFException
+    throws ACFException
   {
     JobDescription rval = new JobDescription();
     rval.setIsNew(true);
@@ -507,7 +507,7 @@ public class Jobs extends org.apache.acf
   *@param id is the job id.
   */
   public void delete(Long id)
-    throws LCFException
+    throws ACFException
   {
     StringSetBuffer ssb = new StringSetBuffer();
     ssb.add(getJobsKey());
@@ -523,7 +523,7 @@ public class Jobs extends org.apache.acf
       params.add(id);
       performDelete("WHERE "+idField+"=?",params,cacheKeys);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -544,7 +544,7 @@ public class Jobs extends org.apache.acf
   *@return the editable job description.
   */
   public IJobDescription load(Long id, boolean readOnly)
-    throws LCFException
+    throws ACFException
   {
     return loadMultiple(new Long[]{id}, new boolean[]{readOnly})[0];
   }
@@ -555,7 +555,7 @@ public class Jobs extends org.apache.acf
   *@return the array of objects, in order.
   */
   public IJobDescription[] loadMultiple(Long[] ids, boolean[] readOnlies)
-    throws LCFException
+    throws ACFException
   {
     // Build description objects
     JobObjectDescription[] objectDescriptions = new JobObjectDescription[ids.length];
@@ -578,7 +578,7 @@ public class Jobs extends org.apache.acf
   *@param jobDescription is the job description.
   */
   public void save(IJobDescription jobDescription)
-    throws LCFException
+    throws ACFException
   {
     // The invalidation keys for this are both the general and the specific.
     Long id = jobDescription.getID();
@@ -672,7 +672,7 @@ public class Jobs extends org.apache.acf
 
         cacheManager.invalidateKeys(ch);
       }
-      catch (LCFException e)
+      catch (ACFException e)
       {
         signalRollback();
         throw e;
@@ -696,7 +696,7 @@ public class Jobs extends org.apache.acf
   /** This method is called on a restart.
   */
   public void restart()
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -758,7 +758,7 @@ public class Jobs extends org.apache.acf
       // No need to do anything to the queue; it looks like it can take care of
       // itself.
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -779,7 +779,7 @@ public class Jobs extends org.apache.acf
   *@param oldStatusValue is the current status value for the job.
   */
   public void noteOutputConnectorDeregistration(Long jobID, int oldStatusValue)
-    throws LCFException
+    throws ACFException
   {
     int newStatusValue;
     // The following states are special, in that when the underlying connector goes away, the jobs
@@ -826,7 +826,7 @@ public class Jobs extends org.apache.acf
   *@param oldStatusValue is the current status value for the job.
   */
   public void noteOutputConnectorRegistration(Long jobID, int oldStatusValue)
-    throws LCFException
+    throws ACFException
   {
     int newStatusValue;
     // The following states are special, in that when the underlying connector returns, the jobs
@@ -869,7 +869,7 @@ public class Jobs extends org.apache.acf
   *@param oldStatusValue is the current status value for the job.
   */
   public void noteConnectorDeregistration(Long jobID, int oldStatusValue)
-    throws LCFException
+    throws ACFException
   {
     int newStatusValue;
     // The following states are special, in that when the underlying connector goes away, the jobs
@@ -913,7 +913,7 @@ public class Jobs extends org.apache.acf
   *@param oldStatusValue is the current status value for the job.
   */
   public void noteConnectorRegistration(Long jobID, int oldStatusValue)
-    throws LCFException
+    throws ACFException
   {
     int newStatusValue;
     // The following states are special, in that when the underlying connector returns, the jobs
@@ -953,7 +953,7 @@ public class Jobs extends org.apache.acf
   * is signalled.
   */
   public void noteConnectionChange(String connectionName)
-    throws LCFException
+    throws ACFException
   {
     // No cache keys need invalidation, since we're changing the start time, not the status.
     HashMap newValues = new HashMap();
@@ -968,7 +968,7 @@ public class Jobs extends org.apache.acf
   * is signalled.
   */
   public void noteOutputConnectionChange(String connectionName)
-    throws LCFException
+    throws ACFException
   {
     // No cache keys need invalidation, since we're changing the start time, not the status.
     HashMap newValues = new HashMap();
@@ -981,7 +981,7 @@ public class Jobs extends org.apache.acf
   /** Check whether a job's status indicates that it is in ACTIVE or ACTIVESEEDING state.
   */
   public boolean checkJobActive(Long jobID)
-    throws LCFException
+    throws ACFException
   {
     StringSet cacheKeys = new StringSet(getJobStatusKey());
     ArrayList list = new ArrayList();
@@ -1000,7 +1000,7 @@ public class Jobs extends org.apache.acf
   /** Reset startup worker thread status.
   */
   public void resetStartupWorkerStatus()
-    throws LCFException
+    throws ACFException
   {
     // We have to handle all states that the startup thread would resolve, and change them to something appropriate.
 
@@ -1025,7 +1025,7 @@ public class Jobs extends org.apache.acf
   /** Reset as part of restoring seeding worker threads.
   */
   public void resetSeedingWorkerStatus()
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -1072,7 +1072,7 @@ public class Jobs extends org.apache.acf
       performUpdate(map,"WHERE "+statusField+"=?",list,invKey);
 
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1095,7 +1095,7 @@ public class Jobs extends org.apache.acf
   *@param windowEnd is the window end time, if any
   */
   public void startJob(Long jobID, Long windowEnd)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1113,7 +1113,7 @@ public class Jobs extends org.apache.acf
   *@param startTime is the current time in milliseconds from start of epoch.
   */
   public void noteJobStarted(Long jobID, long startTime)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -1123,7 +1123,7 @@ public class Jobs extends org.apache.acf
       IResultSet set = performQuery("SELECT "+statusField+","+connectionNameField+","+outputNameField+" FROM "+getTableName()+" WHERE "+
         idField+"=? FOR UPDATE",list,null,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("Can't find job "+jobID.toString());
+        throw new ACFException("Can't find job "+jobID.toString());
       IResultRow row = set.getRow(0);
       int status = stringToStatus((String)row.getValue(statusField));
       int newStatus;
@@ -1153,7 +1153,7 @@ public class Jobs extends org.apache.acf
         break;
       default:
         // Complain!
-        throw new LCFException("Unexpected job status encountered: "+Integer.toString(status));
+        throw new ACFException("Unexpected job status encountered: "+Integer.toString(status));
       }
 
       HashMap map = new HashMap();
@@ -1165,7 +1165,7 @@ public class Jobs extends org.apache.acf
       map.put(lastCheckTimeField,new Long(startTime));
       performUpdate(map,"WHERE "+idField+"=?",list,new StringSet(getJobStatusKey()));
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1186,7 +1186,7 @@ public class Jobs extends org.apache.acf
   *@param seedTime is the job seed time.
   */
   public void noteJobSeeded(Long jobID, long seedTime)
-    throws LCFException
+    throws ACFException
   {
     // We have to convert the current status to the non-seeding equivalent
     beginTransaction();
@@ -1197,7 +1197,7 @@ public class Jobs extends org.apache.acf
       IResultSet set = performQuery("SELECT "+statusField+" FROM "+getTableName()+" WHERE "+
         idField+"=? FOR UPDATE",list,null,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("Can't find job "+jobID.toString());
+        throw new ACFException("Can't find job "+jobID.toString());
       IResultRow row = set.getRow(0);
       int status = stringToStatus((String)row.getValue(statusField));
       int newStatus;
@@ -1231,7 +1231,7 @@ public class Jobs extends org.apache.acf
         newStatus = STATUS_ABORTINGFORRESTART;
         break;
       default:
-        throw new LCFException("Unexpected job status encountered: "+Integer.toString(status));
+        throw new ACFException("Unexpected job status encountered: "+Integer.toString(status));
       }
       HashMap map = new HashMap();
       map.put(statusField,statusToString(newStatus));
@@ -1243,7 +1243,7 @@ public class Jobs extends org.apache.acf
       signalRollback();
       throw e;
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1261,7 +1261,7 @@ public class Jobs extends org.apache.acf
   *@param windowEnd is the window end time, if any.
   */
   public void unwaitJob(Long jobID, int newStatus, Long windowEnd)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1277,7 +1277,7 @@ public class Jobs extends org.apache.acf
   *  STATUS_ACTIVEWAITSEEDING or STATUS_PAUSEDWAITSEEDING)
   */
   public void waitJob(Long jobID, int newStatus)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1293,7 +1293,7 @@ public class Jobs extends org.apache.acf
   *@return true if there wasn't an abort already logged for this job.
   */
   public boolean abortJob(Long jobID, String errorText)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -1304,7 +1304,7 @@ public class Jobs extends org.apache.acf
       IResultSet set = performQuery("SELECT "+statusField+" FROM "+getTableName()+
         " WHERE "+idField+"=? FOR UPDATE",list,null,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("Job does not exist: "+jobID);
+        throw new ACFException("Job does not exist: "+jobID);
       IResultRow row = set.getRow(0);
       int status = stringToStatus(row.getValue(statusField).toString());
       if (status == STATUS_ABORTING || status == STATUS_ABORTINGSEEDING || status == STATUS_ABORTINGSTARTINGUP)
@@ -1338,7 +1338,7 @@ public class Jobs extends org.apache.acf
         newStatus = STATUS_ABORTINGSEEDING;
         break;
       default:
-        throw new LCFException("Job "+jobID+" is not active");
+        throw new ACFException("Job "+jobID+" is not active");
       }
       // Pause the job
       HashMap map = new HashMap();
@@ -1347,7 +1347,7 @@ public class Jobs extends org.apache.acf
       performUpdate(map,"WHERE "+idField+"=?",list,new StringSet(getJobStatusKey()));
       return true;
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1367,7 +1367,7 @@ public class Jobs extends org.apache.acf
   *@param jobID is the job id.
   */
   public void abortRestartJob(Long jobID)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -1378,7 +1378,7 @@ public class Jobs extends org.apache.acf
       IResultSet set = performQuery("SELECT "+statusField+" FROM "+getTableName()+
         " WHERE "+idField+"=? FOR UPDATE",list,null,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("Job does not exist: "+jobID);
+        throw new ACFException("Job does not exist: "+jobID);
       IResultRow row = set.getRow(0);
       int status = stringToStatus(row.getValue(statusField).toString());
       if (status == STATUS_ABORTINGFORRESTART || status == STATUS_ABORTINGFORRESTARTSEEDING || status == STATUS_ABORTINGSTARTINGUPFORRESTART)
@@ -1409,14 +1409,14 @@ public class Jobs extends org.apache.acf
         newStatus = STATUS_ABORTINGFORRESTARTSEEDING;
         break;
       default:
-        throw new LCFException("Job "+jobID+" is not restartable");
+        throw new ACFException("Job "+jobID+" is not restartable");
       }
       // reset the job
       HashMap map = new HashMap();
       map.put(statusField,statusToString(newStatus));
       performUpdate(map,"WHERE "+idField+"=?",list,new StringSet(getJobStatusKey()));
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1436,7 +1436,7 @@ public class Jobs extends org.apache.acf
   *@param jobID is the job id.
   */
   public void pauseJob(Long jobID)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -1447,7 +1447,7 @@ public class Jobs extends org.apache.acf
       IResultSet set = performQuery("SELECT "+statusField+" FROM "+getTableName()+
         " WHERE "+idField+"=? FOR UPDATE",list,null,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("Job does not exist: "+jobID);
+        throw new ACFException("Job does not exist: "+jobID);
       IResultRow row = set.getRow(0);
       int status = stringToStatus(row.getValue(statusField).toString());
       int newStatus;
@@ -1472,14 +1472,14 @@ public class Jobs extends org.apache.acf
         newStatus = STATUS_PAUSEDWAITSEEDING;
         break;
       default:
-        throw new LCFException("Job "+jobID+" is not active");
+        throw new ACFException("Job "+jobID+" is not active");
       }
       // Pause the job
       HashMap map = new HashMap();
       map.put(statusField,statusToString(newStatus));
       performUpdate(map,"WHERE "+idField+"=?",list,new StringSet(getJobStatusKey()));
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1499,7 +1499,7 @@ public class Jobs extends org.apache.acf
   *@param jobID is the job id.
   */
   public void restartJob(Long jobID)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -1510,7 +1510,7 @@ public class Jobs extends org.apache.acf
       IResultSet set = performQuery("SELECT "+statusField+","+connectionNameField+","+outputNameField+" FROM "+getTableName()+
         " WHERE "+idField+"=? FOR UPDATE",list,null,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("Job does not exist: "+jobID);
+        throw new ACFException("Job does not exist: "+jobID);
       IResultRow row = set.getRow(0);
       int status = stringToStatus(row.getValue(statusField).toString());
       String connectionName = (String)row.getValue(connectionNameField);
@@ -1557,14 +1557,14 @@ public class Jobs extends org.apache.acf
         newStatus = STATUS_ACTIVEWAITSEEDING;
         break;
       default:
-        throw new LCFException("Job "+jobID+" is not paused");
+        throw new ACFException("Job "+jobID+" is not paused");
       }
       // Pause the job
       HashMap map = new HashMap();
       map.put(statusField,statusToString(newStatus));
       performUpdate(map,"WHERE "+idField+"=?",list,new StringSet(getJobStatusKey()));
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1586,7 +1586,7 @@ public class Jobs extends org.apache.acf
   *@param reseedTime is the reseed time.
   */
   public void writeStatus(Long jobID, int status, Long reseedTime)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1601,7 +1601,7 @@ public class Jobs extends org.apache.acf
   *@param status is the desired status.
   */
   public void writeStatus(Long jobID, int status)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1615,7 +1615,7 @@ public class Jobs extends org.apache.acf
   *@param currentTime is the current time.
   */
   public void updateLastTime(Long jobID, long currentTime)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1630,7 +1630,7 @@ public class Jobs extends org.apache.acf
   *@param finishTime is the finish time.
   */
   public void finishJob(Long jobID, long finishTime)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1649,7 +1649,7 @@ public class Jobs extends org.apache.acf
   *@param jobID is the job id.
   */
   public void finishAbortJob(Long jobID, long abortTime)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -1668,7 +1668,7 @@ public class Jobs extends org.apache.acf
   *@return true if there is a reference, false otherwise.
   */
   public boolean checkIfReference(String connectionName)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(connectionName);
@@ -1682,7 +1682,7 @@ public class Jobs extends org.apache.acf
   *@return true if there is a reference, false otherwise.
   */
   public boolean checkIfOutputReference(String connectionName)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(connectionName);
@@ -1696,7 +1696,7 @@ public class Jobs extends org.apache.acf
   *@return the set of job id's associated with that connection.
   */
   public IJobDescription[] findJobsForConnection(String connectionName)
-    throws LCFException
+    throws ACFException
   {
     // Begin transaction
     beginTransaction();
@@ -1725,7 +1725,7 @@ public class Jobs extends org.apache.acf
       }
       return loadMultiple(ids,readOnlies);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -1748,7 +1748,7 @@ public class Jobs extends org.apache.acf
   *@return true if such jobs exist.
   */
   public boolean deletingJobsPresent()
-    throws LCFException
+    throws ACFException
   {
     IResultSet set = performQuery("SELECT "+idField+" FROM "+getTableName()+" WHERE "+
       statusField+" IN ("+quoteSQLString(statusToString(STATUS_READYFORDELETE))+","+
@@ -1763,7 +1763,7 @@ public class Jobs extends org.apache.acf
   *@return true if such jobs exist.
   */
   public boolean activeJobsPresent()
-    throws LCFException
+    throws ACFException
   {
     // To improve the postgres CPU usage of the system at rest, we do a *fast* check to be
     // sure there are ANY jobs in an active state.
@@ -1782,11 +1782,11 @@ public class Jobs extends org.apache.acf
   *@return the status value.
   */
   public static int stringToStatus(String value)
-    throws LCFException
+    throws ACFException
   {
     Integer x = (Integer)statusMap.get(value);
     if (x == null)
-      throw new LCFException("Bad status value: '"+value+"'");
+      throw new ACFException("Bad status value: '"+value+"'");
     return x.intValue();
   }
 
@@ -1795,7 +1795,7 @@ public class Jobs extends org.apache.acf
   *@return the string.
   */
   public static String statusToString(int status)
-    throws LCFException
+    throws ACFException
   {
     switch (status)
     {
@@ -1853,7 +1853,7 @@ public class Jobs extends org.apache.acf
       return "D";
 
     default:
-      throw new LCFException("Bad status value: "+Integer.toString(status));
+      throw new ACFException("Bad status value: "+Integer.toString(status));
     }
   }
 
@@ -1862,11 +1862,11 @@ public class Jobs extends org.apache.acf
   *@return the type value.
   */
   public static int stringToType(String value)
-    throws LCFException
+    throws ACFException
   {
     Integer x = (Integer)typeMap.get(value);
     if (x == null)
-      throw new LCFException("Bad type value: '"+value+"'");
+      throw new ACFException("Bad type value: '"+value+"'");
     return x.intValue();
   }
 
@@ -1875,7 +1875,7 @@ public class Jobs extends org.apache.acf
   *@return the string.
   */
   public static String typeToString(int type)
-    throws LCFException
+    throws ACFException
   {
     switch (type)
     {
@@ -1884,27 +1884,27 @@ public class Jobs extends org.apache.acf
     case TYPE_SPECIFIED:
       return "S";
     default:
-      throw new LCFException("Bad type: "+Integer.toString(type));
+      throw new ACFException("Bad type: "+Integer.toString(type));
     }
   }
 
   /** Go from string to hopcount mode.
   */
   public static int stringToHopcountMode(String value)
-    throws LCFException
+    throws ACFException
   {
     if (value == null || value.length() == 0)
       return HOPCOUNT_ACCURATE;
     Integer x = (Integer)hopmodeMap.get(value);
     if (x == null)
-      throw new LCFException("Bad hopcount mode value: '"+value+"'");
+      throw new ACFException("Bad hopcount mode value: '"+value+"'");
     return x.intValue();
   }
 
   /** Go from hopcount mode to string.
   */
   public static String hopcountModeToString(int value)
-    throws LCFException
+    throws ACFException
   {
     switch(value)
     {
@@ -1915,7 +1915,7 @@ public class Jobs extends org.apache.acf
     case HOPCOUNT_NEVERDELETE:
       return "V";
     default:
-      throw new LCFException("Unknown hopcount mode value "+Integer.toString(value));
+      throw new ACFException("Unknown hopcount mode value "+Integer.toString(value));
     }
   }
 
@@ -1924,11 +1924,11 @@ public class Jobs extends org.apache.acf
   *@return the start method value.
   */
   public static int stringToStartMethod(String value)
-    throws LCFException
+    throws ACFException
   {
     Integer x = (Integer)startMap.get(value);
     if (x == null)
-      throw new LCFException("Bad start method value: '"+value+"'");
+      throw new ACFException("Bad start method value: '"+value+"'");
     return x.intValue();
   }
 
@@ -1937,7 +1937,7 @@ public class Jobs extends org.apache.acf
   *@return a string.
   */
   public static String startMethodToString(int startMethod)
-    throws LCFException
+    throws ACFException
   {
     switch(startMethod)
     {
@@ -1948,7 +1948,7 @@ public class Jobs extends org.apache.acf
     case START_DISABLE:
       return "D";
     default:
-      throw new LCFException("Bad start method: "+Integer.toString(startMethod));
+      throw new ACFException("Bad start method: "+Integer.toString(startMethod));
     }
   }
 
@@ -1958,7 +1958,7 @@ public class Jobs extends org.apache.acf
   *@return the enumerated value.
   */
   public static EnumeratedValues stringToEnumeratedValue(String value)
-    throws LCFException
+    throws ACFException
   {
     if (value == null)
       return null;
@@ -1984,7 +1984,7 @@ public class Jobs extends org.apache.acf
     }
     catch (NumberFormatException e)
     {
-      throw new LCFException("Bad number: '"+value+"'",e);
+      throw new ACFException("Bad number: '"+value+"'",e);
     }
 
   }
@@ -2036,7 +2036,7 @@ public class Jobs extends org.apache.acf
   *@return the corresponding job descriptions.
   */
   protected JobDescription[] getJobsMultiple(Long[] ids)
-    throws LCFException
+    throws ACFException
   {
     // Fetch all the jobs, but only once for each ID.  Then, assign each one by id into the final array.
     HashMap uniqueIDs = new HashMap();
@@ -2078,7 +2078,7 @@ public class Jobs extends org.apache.acf
       signalRollback();
       throw e;
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -2109,7 +2109,7 @@ public class Jobs extends org.apache.acf
   *@param params is the set of parameters.
   */
   protected void getJobsChunk(Map returnValues, String idList, ArrayList params)
-    throws LCFException
+    throws ACFException
   {
     try
     {
@@ -2150,7 +2150,7 @@ public class Jobs extends org.apache.acf
     }
     catch (NumberFormatException e)
     {
-      throw new LCFException("Bad number",e);
+      throw new ACFException("Bad number",e);
     }
   }
 
@@ -2257,7 +2257,7 @@ public class Jobs extends org.apache.acf
     * @return the newly created objects to cache, or null, if any object cannot be created.
     *  The order of the returned objects must correspond to the order of the object descriptinos.
     */
-    public Object[] create(ICacheDescription[] objectDescriptions) throws LCFException
+    public Object[] create(ICacheDescription[] objectDescriptions) throws ACFException
     {
       // Turn the object descriptions into the parameters for the ToolInstance requests
       Long[] ids = new Long[objectDescriptions.length];
@@ -2280,7 +2280,7 @@ public class Jobs extends org.apache.acf
     * @param objectDescription is the unique identifier of the object.
     * @param cachedObject is the cached object.
     */
-    public void exists(ICacheDescription objectDescription, Object cachedObject) throws LCFException
+    public void exists(ICacheDescription objectDescription, Object cachedObject) throws ACFException
     {
       // Cast what came in as what it really is
       JobObjectDescription objectDesc = (JobObjectDescription)objectDescription;
@@ -2296,7 +2296,7 @@ public class Jobs extends org.apache.acf
     /** Perform the desired operation.  This method is called after either createGetObject()
     * or exists() is called for every requested object.
     */
-    public void execute() throws LCFException
+    public void execute() throws ACFException
     {
       // Does nothing; we only want to fetch objects in this cacher.
     }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/PrereqEventManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/PrereqEventManager.java?rev=988237&r1=988236&r2=988237&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/PrereqEventManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/PrereqEventManager.java Mon Aug 23 18:08:32 2010
@@ -50,7 +50,7 @@ public class PrereqEventManager extends 
   *@param database is the database handle.
   */
   public PrereqEventManager(IDBInterface database)
-    throws LCFException
+    throws ACFException
   {
     super(database,"prereqevents");
   }
@@ -58,7 +58,7 @@ public class PrereqEventManager extends 
   /** Install or upgrade this table.
   */
   public void install(String ownerTableName, String ownerColumn)
-    throws LCFException
+    throws ACFException
   {
     // Standard practice: Outer loop for upgrade support.
     while (true)
@@ -105,14 +105,14 @@ public class PrereqEventManager extends 
   /** Uninstall.
   */
   public void deinstall()
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
     {
       performDrop(null);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -130,7 +130,7 @@ public class PrereqEventManager extends 
 
   /** Delete specified rows, based on jobqueue criteria. */
   public void deleteRows(String parentTableName, String joinField, String parentCriteria, ArrayList list)
-    throws LCFException
+    throws ACFException
   {
     StringBuffer sb = new StringBuffer();
     sb.append("WHERE EXISTS(SELECT 'x' FROM ").append(parentTableName).append(" WHERE ").append(joinField).append("=")
@@ -144,7 +144,7 @@ public class PrereqEventManager extends 
 
   /** Delete specified rows, as directly specified without a join. */
   public void deleteRows(String ownerQueryPart, ArrayList list)
-    throws LCFException
+    throws ACFException
   {
     performDelete("WHERE "+ownerField+" IN("+ownerQueryPart+")",list,null);
     reindexTracker.noteEvent();
@@ -152,7 +152,7 @@ public class PrereqEventManager extends 
 
   /** Delete rows pertaining to a single entry */
   public void deleteRows(Long recordID)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(recordID);
@@ -162,7 +162,7 @@ public class PrereqEventManager extends 
 
   /** Add rows pertaining to a single entry */
   public void addRows(Long recordID, String[] eventNames)
-    throws LCFException
+    throws ACFException
   {
     if (eventNames != null)
     {
@@ -181,7 +181,7 @@ public class PrereqEventManager extends 
   /** Conditionally do analyze operation.
   */
   public void conditionallyMaintainTables()
-    throws LCFException
+    throws ACFException
   {
     if (tracker.checkAction())
     {

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/ScheduleManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/ScheduleManager.java?rev=988237&r1=988236&r2=988237&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/ScheduleManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/jobs/ScheduleManager.java Mon Aug 23 18:08:32 2010
@@ -48,7 +48,7 @@ public class ScheduleManager extends org
   *@param database is the database instance.
   */
   public ScheduleManager(IThreadContext threadContext, IDBInterface database)
-    throws LCFException
+    throws ACFException
   {
     super(database,"schedules");
   }
@@ -58,7 +58,7 @@ public class ScheduleManager extends org
   *@param owningTablePrimaryKey is the primary key of the owning table.
   */
   public void install(String ownerTable, String owningTablePrimaryKey)
-    throws LCFException
+    throws ACFException
   {
     // Standard practice: Outer loop to support upgrades
     while (true)
@@ -125,7 +125,7 @@ public class ScheduleManager extends org
   /** Uninstall.
   */
   public void deinstall()
-    throws LCFException
+    throws ACFException
   {
     performDrop(null);
   }
@@ -136,7 +136,7 @@ public class ScheduleManager extends org
   *@param ownerIDParams is the corresponding set of owner id parameters.
   */
   public void getRows(Map returnValues, String ownerIDList, ArrayList ownerIDParams)
-    throws LCFException
+    throws ACFException
   {
     IResultSet set = performQuery("SELECT * FROM "+getTableName()+" WHERE "+ownerIDField+" IN ("+ownerIDList+") ORDER BY "+ordinalField+" ASC",ownerIDParams,
       null,null);
@@ -164,7 +164,7 @@ public class ScheduleManager extends org
   *@param ownerIDParams is the corresponding set of owner id parameters.
   */
   public void getRowsAlternate(Map returnValues, String ownerIDList, ArrayList ownerIDParams)
-    throws LCFException
+    throws ACFException
   {
     IResultSet set = performQuery("SELECT * FROM "+getTableName()+" WHERE "+ownerIDField+" IN ("+ownerIDList+") ORDER BY "+ordinalField+" ASC",ownerIDParams,
       null,null);
@@ -197,7 +197,7 @@ public class ScheduleManager extends org
   *@param list is the job description that is the source of the schedule.
   */
   public void writeRows(Long ownerID, IJobDescription list)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -222,7 +222,7 @@ public class ScheduleManager extends org
         i++;
       }
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -242,7 +242,7 @@ public class ScheduleManager extends org
   *@param ownerID is the owner whose rows to delete.
   */
   public void deleteRows(Long ownerID)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(ownerID);
@@ -254,7 +254,7 @@ public class ScheduleManager extends org
   *@return the enumerated value.
   */
   public static EnumeratedValues stringToEnumeratedValue(String value)
-    throws LCFException
+    throws ACFException
   {
     if (value == null)
       return null;
@@ -280,7 +280,7 @@ public class ScheduleManager extends org
     }
     catch (NumberFormatException e)
     {
-      throw new LCFException("Bad number: '"+value+"'",e);
+      throw new ACFException("Bad number: '"+value+"'",e);
     }
 
   }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryConnectionManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryConnectionManager.java?rev=988237&r1=988236&r2=988237&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryConnectionManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryConnectionManager.java Mon Aug 23 18:08:32 2010
@@ -23,7 +23,7 @@ import org.apache.acf.core.interfaces.*;
 import org.apache.acf.crawler.interfaces.*;
 import org.apache.acf.authorities.interfaces.*;
 import org.apache.acf.crawler.interfaces.CacheKeyFactory;
-import org.apache.acf.crawler.system.LCF;
+import org.apache.acf.crawler.system.ACF;
 
 
 /** This class is the manager of the repository connection description.  Inside, multiple database tables are managed,
@@ -60,7 +60,7 @@ public class RepositoryConnectionManager
   *@param threadContext is the thread context.
   */
   public RepositoryConnectionManager(IThreadContext threadContext, IDBInterface database)
-    throws LCFException
+    throws ACFException
   {
     super(database,"repoconnections");
 
@@ -73,7 +73,7 @@ public class RepositoryConnectionManager
   /** Install the manager.
   */
   public void install()
-    throws LCFException
+    throws ACFException
   {
     // First, get the authority manager table name and name column
     IAuthorityConnectionManager authMgr = AuthorityConnectionManagerFactory.make(threadContext);
@@ -113,7 +113,7 @@ public class RepositoryConnectionManager
   /** Uninstall the manager.
   */
   public void deinstall()
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -122,7 +122,7 @@ public class RepositoryConnectionManager
       historyManager.deinstall();
       performDrop(null);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -140,62 +140,62 @@ public class RepositoryConnectionManager
 
   /** Export configuration */
   public void exportConfiguration(java.io.OutputStream os)
-    throws java.io.IOException, LCFException
+    throws java.io.IOException, ACFException
   {
     // Write a version indicator
-    LCF.writeDword(os,1);
+    ACF.writeDword(os,1);
     // Get the authority list
     IRepositoryConnection[] list = getAllConnections();
     // Write the number of authorities
-    LCF.writeDword(os,list.length);
+    ACF.writeDword(os,list.length);
     // Loop through the list and write the individual repository connection info
     int i = 0;
     while (i < list.length)
     {
       IRepositoryConnection conn = list[i++];
-      LCF.writeString(os,conn.getName());
-      LCF.writeString(os,conn.getDescription());
-      LCF.writeString(os,conn.getClassName());
-      LCF.writeString(os,conn.getConfigParams().toXML());
-      LCF.writeString(os,conn.getACLAuthority());
-      LCF.writeDword(os,conn.getMaxConnections());
+      ACF.writeString(os,conn.getName());
+      ACF.writeString(os,conn.getDescription());
+      ACF.writeString(os,conn.getClassName());
+      ACF.writeString(os,conn.getConfigParams().toXML());
+      ACF.writeString(os,conn.getACLAuthority());
+      ACF.writeDword(os,conn.getMaxConnections());
       String[] throttles = conn.getThrottles();
-      LCF.writeDword(os,throttles.length);
+      ACF.writeDword(os,throttles.length);
       int j = 0;
       while (j < throttles.length)
       {
         String throttleName = throttles[j++];
-        LCF.writeString(os,throttleName);
-        LCF.writeString(os,conn.getThrottleDescription(throttleName));
-        LCF.writefloat(os,conn.getThrottleValue(throttleName));
+        ACF.writeString(os,throttleName);
+        ACF.writeString(os,conn.getThrottleDescription(throttleName));
+        ACF.writefloat(os,conn.getThrottleValue(throttleName));
       }
     }
   }
 
   /** Import configuration */
   public void importConfiguration(java.io.InputStream is)
-    throws java.io.IOException, LCFException
+    throws java.io.IOException, ACFException
   {
-    int version = LCF.readDword(is);
+    int version = ACF.readDword(is);
     if (version != 1)
       throw new java.io.IOException("Unknown repository connection configuration version: "+Integer.toString(version));
-    int count = LCF.readDword(is);
+    int count = ACF.readDword(is);
     int i = 0;
     while (i < count)
     {
       IRepositoryConnection conn = create();
-      conn.setName(LCF.readString(is));
-      conn.setDescription(LCF.readString(is));
-      conn.setClassName(LCF.readString(is));
-      conn.getConfigParams().fromXML(LCF.readString(is));
-      conn.setACLAuthority(LCF.readString(is));
-      conn.setMaxConnections(LCF.readDword(is));
-      int throttleCount = LCF.readDword(is);
+      conn.setName(ACF.readString(is));
+      conn.setDescription(ACF.readString(is));
+      conn.setClassName(ACF.readString(is));
+      conn.getConfigParams().fromXML(ACF.readString(is));
+      conn.setACLAuthority(ACF.readString(is));
+      conn.setMaxConnections(ACF.readDword(is));
+      int throttleCount = ACF.readDword(is);
       int j = 0;
       while (j < throttleCount)
       {
-        String throttleName = LCF.readString(is);
-        conn.addThrottleValue(throttleName,LCF.readString(is),LCF.readfloat(is));
+        String throttleName = ACF.readString(is);
+        conn.addThrottleValue(throttleName,ACF.readString(is),ACF.readfloat(is));
         j++;
       }
       // Attempt to save this connection
@@ -208,7 +208,7 @@ public class RepositoryConnectionManager
   *@return an array of connection objects.
   */
   public IRepositoryConnection[] getAllConnections()
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -229,7 +229,7 @@ public class RepositoryConnectionManager
       }
       return loadMultiple(names);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -250,7 +250,7 @@ public class RepositoryConnectionManager
   *@return the loaded connection object, or null if not found.
   */
   public IRepositoryConnection load(String name)
-    throws LCFException
+    throws ACFException
   {
     return loadMultiple(new String[]{name})[0];
   }
@@ -260,7 +260,7 @@ public class RepositoryConnectionManager
   *@return the loaded connection objects.
   */
   public IRepositoryConnection[] loadMultiple(String[] names)
-    throws LCFException
+    throws ACFException
   {
     // Build description objects
     RepositoryConnectionDescription[] objectDescriptions = new RepositoryConnectionDescription[names.length];
@@ -283,7 +283,7 @@ public class RepositoryConnectionManager
   *@return the new object.
   */
   public IRepositoryConnection create()
-    throws LCFException
+    throws ACFException
   {
     RepositoryConnection rval = new RepositoryConnection();
     return rval;
@@ -293,7 +293,7 @@ public class RepositoryConnectionManager
   *@param object is the object to save.
   */
   public void save(IRepositoryConnection object)
-    throws LCFException
+    throws ACFException
   {
     StringSetBuffer ssb = new StringSetBuffer();
     ssb.add(getRepositoryConnectionsKey());
@@ -307,7 +307,7 @@ public class RepositoryConnectionManager
       {
         performLock();
         // Notify of a change to the configuration
-        LCF.noteConfigurationChange();
+        ACF.noteConfigurationChange();
         // See whether the instance exists
         ArrayList params = new ArrayList();
         params.add(object.getName());
@@ -355,7 +355,7 @@ public class RepositoryConnectionManager
 
         cacheManager.invalidateKeys(ch);
       }
-      catch (LCFException e)
+      catch (ACFException e)
       {
         signalRollback();
         throw e;
@@ -381,7 +381,7 @@ public class RepositoryConnectionManager
   * name does not exist, no error is returned.
   */
   public void delete(String name)
-    throws LCFException
+    throws ACFException
   {
     // Grab a job manager handle.  We will need to check if any jobs refer to this connection.
     IJobManager jobManager = JobManagerFactory.make(threadContext);
@@ -398,8 +398,8 @@ public class RepositoryConnectionManager
       {
         // Check if any jobs refer to this connection name
         if (jobManager.checkIfReference(name))
-          throw new LCFException("Can't delete repository connection '"+name+"': existing jobs refer to it");
-        LCF.noteConfigurationChange();
+          throw new ACFException("Can't delete repository connection '"+name+"': existing jobs refer to it");
+        ACF.noteConfigurationChange();
         throttleSpecManager.deleteRows(name);
         historyManager.deleteOwner(name,null);
         ArrayList params = new ArrayList();
@@ -407,7 +407,7 @@ public class RepositoryConnectionManager
         performDelete("WHERE "+nameField+"=?",params,null);
         cacheManager.invalidateKeys(ch);
       }
-      catch (LCFException e)
+      catch (ACFException e)
       {
         signalRollback();
         throw e;
@@ -434,7 +434,7 @@ public class RepositoryConnectionManager
   *@return true if referenced, false otherwise.
   */
   public boolean isReferenced(String authorityName)
-    throws LCFException
+    throws ACFException
   {
     StringSetBuffer ssb = new StringSetBuffer();
     ssb.add(getRepositoryConnectionsKey());
@@ -451,7 +451,7 @@ public class RepositoryConnectionManager
   *@return the repository connections that use that connector.
   */
   public String[] findConnectionsForConnector(String className)
-    throws LCFException
+    throws ACFException
   {
     StringSetBuffer ssb = new StringSetBuffer();
     ssb.add(getRepositoryConnectionsKey());
@@ -477,7 +477,7 @@ public class RepositoryConnectionManager
   *@return true if the underlying connector is registered.
   */
   public boolean checkConnectorExists(String name)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -490,13 +490,13 @@ public class RepositoryConnectionManager
       IResultSet set = performQuery("SELECT "+classNameField+" FROM "+getTableName()+" WHERE "+nameField+"=?",params,
         localCacheKeys,null);
       if (set.getRowCount() == 0)
-        throw new LCFException("No such connection: '"+name+"'");
+        throw new ACFException("No such connection: '"+name+"'");
       IResultRow row = set.getRow(0);
       String className = (String)row.getValue(classNameField);
       IConnectorManager cm = ConnectorManagerFactory.make(threadContext);
       return cm.isInstalled(className);
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -548,7 +548,7 @@ public class RepositoryConnectionManager
   */
   public void recordHistory(String connectionName, Long startTime, String activityType, Long dataSize,
     String entityIdentifier, String resultCode, String resultDescription, String[] childIdentifiers)
-    throws LCFException
+    throws ACFException
   {
     long endTimeValue = System.currentTimeMillis();
     long startTimeValue;
@@ -580,7 +580,7 @@ public class RepositoryConnectionManager
   *@return the number of rows included by the criteria.
   */
   public long countHistoryRows(String connectionName, FilterCriteria criteria)
-    throws LCFException
+    throws ACFException
   {
     return historyManager.countHistoryRows(connectionName,criteria);
   }
@@ -596,7 +596,7 @@ public class RepositoryConnectionManager
   *@param maxRowCount is the maximum number of rows to include.
   */
   public IResultSet genHistorySimple(String connectionName, FilterCriteria criteria, SortOrder sort, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     return historyManager.simpleReport(connectionName,criteria,sort,startRow,maxRowCount);
   }
@@ -619,7 +619,7 @@ public class RepositoryConnectionManager
   */
   public IResultSet genHistoryActivityCount(String connectionName, FilterCriteria criteria, SortOrder sort, BucketDescription idBucket,
     long interval, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     return historyManager.maxActivityCountReport(connectionName,criteria,sort,idBucket,interval,startRow,maxRowCount);
   }
@@ -642,7 +642,7 @@ public class RepositoryConnectionManager
   */
   public IResultSet genHistoryByteCount(String connectionName, FilterCriteria criteria, SortOrder sort, BucketDescription idBucket,
     long interval, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     return historyManager.maxByteCountReport(connectionName,criteria,sort,idBucket,interval,startRow,maxRowCount);
   }
@@ -664,7 +664,7 @@ public class RepositoryConnectionManager
   */
   public IResultSet genHistoryResultCodes(String connectionName, FilterCriteria criteria, SortOrder sort,
     BucketDescription resultCodeBucket, BucketDescription idBucket, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     return historyManager.resultCodesReport(connectionName,criteria,sort,resultCodeBucket,idBucket,startRow,maxRowCount);
   }
@@ -696,7 +696,7 @@ public class RepositoryConnectionManager
   *@return the corresponding repository connection objects.
   */
   protected RepositoryConnection[] getRepositoryConnectionsMultiple(String[] connectionNames)
-    throws LCFException
+    throws ACFException
   {
     RepositoryConnection[] rval = new RepositoryConnection[connectionNames.length];
     HashMap returnIndex = new HashMap();
@@ -740,7 +740,7 @@ public class RepositoryConnectionManager
       signalRollback();
       throw e;
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -758,7 +758,7 @@ public class RepositoryConnectionManager
   *@param params is the set of parameters.
   */
   protected void getRepositoryConnectionsChunk(RepositoryConnection[] rval, Map returnIndex, String idList, ArrayList params)
-    throws LCFException
+    throws ACFException
   {
     IResultSet set;
     set = performQuery("SELECT * FROM "+getTableName()+" WHERE "+
@@ -883,7 +883,7 @@ public class RepositoryConnectionManager
     * @return the newly created objects to cache, or null, if any object cannot be created.
     *  The order of the returned objects must correspond to the order of the object descriptinos.
     */
-    public Object[] create(ICacheDescription[] objectDescriptions) throws LCFException
+    public Object[] create(ICacheDescription[] objectDescriptions) throws ACFException
     {
       // Turn the object descriptions into the parameters for the ToolInstance requests
       String[] connectionNames = new String[objectDescriptions.length];
@@ -906,7 +906,7 @@ public class RepositoryConnectionManager
     * @param objectDescription is the unique identifier of the object.
     * @param cachedObject is the cached object.
     */
-    public void exists(ICacheDescription objectDescription, Object cachedObject) throws LCFException
+    public void exists(ICacheDescription objectDescription, Object cachedObject) throws ACFException
     {
       // Cast what came in as what it really is
       RepositoryConnectionDescription objectDesc = (RepositoryConnectionDescription)objectDescription;
@@ -924,7 +924,7 @@ public class RepositoryConnectionManager
     /** Perform the desired operation.  This method is called after either createGetObject()
     * or exists() is called for every requested object.
     */
-    public void execute() throws LCFException
+    public void execute() throws ACFException
     {
       // Does nothing; we only want to fetch objects in this cacher.
     }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryHistoryManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryHistoryManager.java?rev=988237&r1=988236&r2=988237&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryHistoryManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/RepositoryHistoryManager.java Mon Aug 23 18:08:32 2010
@@ -49,7 +49,7 @@ public class RepositoryHistoryManager ex
   *@param database is the database instance.
   */
   public RepositoryHistoryManager(IThreadContext tc, IDBInterface database)
-    throws LCFException
+    throws ACFException
   {
     super(database,"repohistory");
     this.threadContext = tc;
@@ -60,7 +60,7 @@ public class RepositoryHistoryManager ex
   *@param parentField is the parent field.
   */
   public void install(String parentTable, String parentField)
-    throws LCFException
+    throws ACFException
   {
     // Always have an outer loop, in case of upgrade
     while (true)
@@ -137,7 +137,7 @@ public class RepositoryHistoryManager ex
   /** Uninstall the table.
   */
   public void deinstall()
-    throws LCFException
+    throws ACFException
   {
     performDrop(null);
   }
@@ -147,7 +147,7 @@ public class RepositoryHistoryManager ex
   *@param invKeys are the invalidation keys.
   */
   public void deleteOwner(String owner, StringSet invKeys)
-    throws LCFException
+    throws ACFException
   {
     ArrayList params = new ArrayList();
     params.add(owner);
@@ -158,7 +158,7 @@ public class RepositoryHistoryManager ex
   */
   public Long addRow(String connectionName, long startTime, long endTime, long dataSize, String activityType,
     String entityIdentifier, String resultCode, String resultDescription)
-    throws LCFException
+    throws ACFException
   {
     Long id = new Long(IDFactory.make(threadContext));
     HashMap map = new HashMap();
@@ -254,7 +254,7 @@ public class RepositoryHistoryManager ex
   * The resultset returned should have the following columns: "activity","starttime","elapsedtime","resultcode","resultdesc","bytes","identifier".
   */
   public IResultSet simpleReport(String connectionName, FilterCriteria criteria, SortOrder sort, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     // Build the query.
     StringBuffer sb = new StringBuffer("SELECT ");
@@ -278,14 +278,14 @@ public class RepositoryHistoryManager ex
   *@return the number of rows included by the criteria.
   */
   public long countHistoryRows(String connectionName, FilterCriteria criteria)
-    throws LCFException
+    throws ACFException
   {
     StringBuffer sb = new StringBuffer("SELECT COUNT(*) AS countcol FROM ");
     sb.append(getTableName());
     addCriteria(sb,"",connectionName,criteria,false);
     IResultSet set = performQuery(sb.toString(),null,null,null);
     if (set.getRowCount() < 1)
-      throw new LCFException("Expected at least one row");
+      throw new ACFException("Expected at least one row");
     IResultRow row = set.getRow(0);
     Long value = (Long)row.getValue("countcol");
     return value.longValue();
@@ -298,7 +298,7 @@ public class RepositoryHistoryManager ex
   */
   public IResultSet maxActivityCountReport(String connectionName, FilterCriteria filterCriteria, SortOrder sort, BucketDescription idBucket,
     long interval, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     // The query we will generate here looks like this:
     // SELECT *
@@ -385,7 +385,7 @@ public class RepositoryHistoryManager ex
   */
   public IResultSet maxByteCountReport(String connectionName, FilterCriteria filterCriteria, SortOrder sort, BucketDescription idBucket,
     long interval, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     // The query we will generate here looks like this:
     // SELECT *
@@ -473,7 +473,7 @@ public class RepositoryHistoryManager ex
   */
   public IResultSet resultCodesReport(String connectionName, FilterCriteria filterCriteria, SortOrder sort,
     BucketDescription resultCodeBucket, BucketDescription idBucket, int startRow, int maxRowCount)
-    throws LCFException
+    throws ACFException
   {
     // The query we'll use here will be:
     //
@@ -649,7 +649,7 @@ public class RepositoryHistoryManager ex
   /** Conditionally do analyze operation.
   */
   protected void conditionallyAnalyzeInsert()
-    throws LCFException
+    throws ACFException
   {
     synchronized (tracker)
     {

Modified: incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/ThrottleSpecManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/ThrottleSpecManager.java?rev=988237&r1=988236&r2=988237&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/ThrottleSpecManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/org/apache/acf/crawler/repository/ThrottleSpecManager.java Mon Aug 23 18:08:32 2010
@@ -41,7 +41,7 @@ public class ThrottleSpecManager extends
   *@param database is the database instance.
   */
   public ThrottleSpecManager(IDBInterface database)
-    throws LCFException
+    throws ACFException
   {
     super(database,"throttlespec");
   }
@@ -51,7 +51,7 @@ public class ThrottleSpecManager extends
   *@param owningTablePrimaryKey is the primary key of the owning table.
   */
   public void install(String ownerTable, String owningTablePrimaryKey)
-    throws LCFException
+    throws ACFException
   {
     // Always use a loop, in case upgrade needs it.
     while (true)
@@ -111,7 +111,7 @@ public class ThrottleSpecManager extends
   /** Uninstall.
   */
   public void deinstall()
-    throws LCFException
+    throws ACFException
   {
     performDrop(null);
   }
@@ -121,7 +121,7 @@ public class ThrottleSpecManager extends
   *@return a list, with columns: "description", "match", and "value".
   */
   public IResultSet readRows(String name)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(name);
@@ -136,7 +136,7 @@ public class ThrottleSpecManager extends
   *@param ownerNameParams is the corresponding set of connection name parameters.
   */
   public void getRows(IRepositoryConnection[] connections, Map indexMap, String ownerNameList, ArrayList ownerNameParams)
-    throws LCFException
+    throws ACFException
   {
     IResultSet set = performQuery("SELECT * FROM "+getTableName()+" WHERE "+ownerNameField+" IN ("+ownerNameList+")",ownerNameParams,
       null,null);
@@ -159,7 +159,7 @@ public class ThrottleSpecManager extends
   *@param connection is the connection to write throttle specs for.
   */
   public void writeRows(String owner, IRepositoryConnection connection)
-    throws LCFException
+    throws ACFException
   {
     beginTransaction();
     try
@@ -181,7 +181,7 @@ public class ThrottleSpecManager extends
         performInsert(map,null);
       }
     }
-    catch (LCFException e)
+    catch (ACFException e)
     {
       signalRollback();
       throw e;
@@ -201,7 +201,7 @@ public class ThrottleSpecManager extends
   *@param owner is the owner whose rows to delete.
   */
   public void deleteRows(String owner)
-    throws LCFException
+    throws ACFException
   {
     ArrayList list = new ArrayList();
     list.add(owner);



Mime
View raw message