incubator-connectors-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r1004255 [17/24] - in /incubator/lcf/trunk: modules/connectors/activedirectory/connector/src/main/java/org/apache/manifoldcf/authorities/authorities/activedirectory/ modules/connectors/documentum/connector/src/main/java/org/apache/manifoldc...
Date Mon, 04 Oct 2010 14:32:28 GMT
Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IFingerprintActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IFingerprintActivity.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IFingerprintActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IFingerprintActivity.java Mon Oct  4 14:32:19 2010
@@ -35,13 +35,13 @@ public interface IFingerprintActivity
   *@return true if the mime type is indexable by this connector.
   */
   public boolean checkMimeTypeIndexable(String mimeType)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Check whether a document is indexable by the currently specified output connector.
   *@param localFile is the local copy of the file to check.
   *@return true if the document is indexable.
   */
   public boolean checkDocumentIndexable(File localFile)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IHistoryActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IHistoryActivity.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IHistoryActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IHistoryActivity.java Mon Oct  4 14:32:19 2010
@@ -46,6 +46,6 @@ public interface IHistoryActivity
   */
   public void recordActivity(Long startTime, String activityType, Long dataSize,
     String entityIdentifier, String resultCode, String resultDescription, String[] childIdentifiers)
-    throws ACFException;
+    throws ManifoldCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IJobManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IJobManager.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IJobManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IJobManager.java Mon Oct  4 14:32:19 2010
@@ -54,46 +54,46 @@ public interface IJobManager
   /** Install the job manager's tables.
   */
   public void install()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Uninstall the job manager's tables.
   */
   public void deinstall()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Export configuration */
   public void exportConfiguration(java.io.OutputStream os)
-    throws java.io.IOException, ACFException;
+    throws java.io.IOException, ManifoldCFException;
 
   /** Import configuration */
   public void importConfiguration(java.io.InputStream is)
-    throws java.io.IOException, ACFException;
+    throws java.io.IOException, ManifoldCFException;
 
   /** Load a sorted list of job descriptions.
   *@return the list, sorted by description.
   */
   public IJobDescription[] getAllJobs()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Create a new job.
   *@return the new job.
   */
   public IJobDescription createJob()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Delete a job.
   *@param id is the job's identifier.  This method will purge all the records belonging to the job from the database, as
   * well as remove all documents indexed by the job from the index.
   */
   public void deleteJob(Long id)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Load a job for editing.
   *@param id is the job's identifier.
   *@return null if the job doesn't exist.
   */
   public IJobDescription load(Long id)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Load a job.
   *@param id is the job's identifier.
@@ -101,34 +101,34 @@ public interface IJobManager
   *@return null if the job doesn't exist.
   */
   public IJobDescription load(Long id, boolean readOnly)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Save a job.
   *@param jobDescription is the job description.
   */
   public void save(IJobDescription jobDescription)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** See if there's a reference to a connection name.
   *@param connectionName is the name of the connection.
   *@return true if there is a reference, false otherwise.
   */
   public boolean checkIfReference(String connectionName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** See if there's a reference to an output connection name.
   *@param connectionName is the name of the connection.
   *@return true if there is a reference, false otherwise.
   */
   public boolean checkIfOutputReference(String connectionName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get the job IDs associated with a given connection name.
   *@param connectionName is the name of the connection.
   *@return the set of job id's associated with that connection.
   */
   public IJobDescription[] findJobsForConnection(String connectionName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // These methods cover activities that require interaction with the job queue.
   // The job queue is maintained underneath this interface, and all threads that perform
@@ -141,27 +141,27 @@ public interface IJobManager
   * state.
   */
   public void prepareForStart()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset as part of restoring document worker threads.
   */
   public void resetDocumentWorkerStatus()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset as part of restoring seeding threads.
   */
   public void resetSeedingWorkerStatus()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset as part of restoring doc delete threads.
   */
   public void resetDocDeleteWorkerStatus()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset as part of restoring startup threads.
   */
   public void resetStartupWorkerStatus()
-    throws ACFException;
+    throws ManifoldCFException;
 
   // These methods support the "set doc priority" thread
 
@@ -173,7 +173,7 @@ public interface IJobManager
   *@return the document descriptions.
   */
   public DocumentDescription[] getNextAlreadyProcessedReprioritizationDocuments(long currentTime, int n)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get a list of not-yet-processed documents to reprioritize.  Documents in all jobs will be
   * returned by this method.  Up to n document descriptions will be returned.
@@ -183,7 +183,7 @@ public interface IJobManager
   *@return the document descriptions.
   */
   public DocumentDescription[] getNextNotYetProcessedReprioritizationDocuments(long currentTime, int n)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Save a set of document priorities.  In the case where a document was eligible to have its
   * priority set, but it no longer is eligible, then the provided priority will not be written.
@@ -192,7 +192,7 @@ public interface IJobManager
   *@param priorities are the desired priorities.
   */
   public void writeDocumentPriorities(long currentTime, DocumentDescription[] descriptions, double[] priorities)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // This method supports the "expiration" thread
 
@@ -206,7 +206,7 @@ public interface IJobManager
   *@return the array of document descriptions to expire.
   */
   public DocumentDescription[] getExpiredDocuments(int n, long currentTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // This method supports the "queue stuffer" thread
 
@@ -229,7 +229,7 @@ public interface IJobManager
   public DocumentDescription[] getNextDocuments(int n, long currentTime, long interval,
     BlockingDocuments blockingDocuments, PerformanceStatistics statistics,
     DepthStatistics scanRecord)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // These methods support the individual fetch/process threads.
 
@@ -239,25 +239,25 @@ public interface IJobManager
   *@return true if the job is in one of the "active" states.
   */
   public boolean checkJobActive(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Verify if a job is still processing documents, or no longer has any outstanding active documents */
   public boolean checkJobBusy(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note completion of document processing by a job thread of a document.
   * This method causes the state of the document to be marked as "completed".
   *@param documentDescriptions are the description objects for the documents that were processed.
   */
   public void markDocumentCompletedMultiple(DocumentDescription[] documentDescriptions)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note completion of document processing by a job thread of a document.
   * This method causes the state of the document to be marked as "completed".
   *@param documentDescription is the description object for the document that was processed.
   */
   public void markDocumentCompleted(DocumentDescription documentDescription)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note deletion as result of document processing by a job thread of a document.
   *@param documentDescriptions are the set of description objects for the documents that were processed.
@@ -267,7 +267,7 @@ public interface IJobManager
   */
   public DocumentDescription[] markDocumentDeletedMultiple(Long jobID, String[] legalLinkTypes, DocumentDescription[] documentDescriptions,
     int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note deletion as result of document processing by a job thread of a document.
   *@param documentDescription is the description object for the document that was processed.
@@ -277,7 +277,7 @@ public interface IJobManager
   */
   public DocumentDescription[] markDocumentDeleted(Long jobID, String[] legalLinkTypes, DocumentDescription documentDescription,
     int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Requeue a document set because of carrydown changes.
   * This method is called when carrydown data is modified for a set of documents.  The documents must be requeued for immediate reprocessing, even to the
@@ -287,7 +287,7 @@ public interface IJobManager
   *@return a flag for each document priority, true if it was used, false otherwise.
   */
   public boolean[] carrydownChangeDocumentMultiple(DocumentDescription[] documentDescriptions, long currentTime, double[] docPriorities)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Requeue a document because of carrydown changes.
   * This method is called when carrydown data is modified for a document.  The document must be requeued for immediate reprocessing, even to the
@@ -297,7 +297,7 @@ public interface IJobManager
   *@return a flag for the document priority, true if it was used, false otherwise.
   */
   public boolean carrydownChangeDocument(DocumentDescription documentDescription, long currentTime, double docPriority)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Requeue a document for further processing in the future.
   * This method is called after a document is processed, when the job is a "continuous" one.
@@ -309,7 +309,7 @@ public interface IJobManager
   */
   public void requeueDocumentMultiple(DocumentDescription[] documentDescriptions, Long[] executeTimes,
     int[] actions)
-    throws ACFException;
+    throws ManifoldCFException;
 
 
   /** Requeue a document for further processing in the future.
@@ -322,7 +322,7 @@ public interface IJobManager
   */
   public void requeueDocument(DocumentDescription documentDescription, Long executeTime,
     int action)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset documents for further processing in the future.
   * This method is called after a service interruption is thrown.
@@ -334,7 +334,7 @@ public interface IJobManager
   */
   public void resetDocumentMultiple(DocumentDescription[] documentDescriptions, long executeTime,
     int action, long failTime, int failCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset an active document back to its former state.
   * This gets done when there's a service interruption and the document cannot be processed yet.
@@ -346,7 +346,7 @@ public interface IJobManager
   */
   public void resetDocument(DocumentDescription documentDescription, long executeTime, int action, long failTime,
     int failCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset a set of deleting documents for further processing in the future.
   * This method is called after some unknown number of the documents were deleted, but then an ingestion service interruption occurred.
@@ -357,13 +357,13 @@ public interface IJobManager
   *@param documentDescriptions is the set of description objects for the document that was processed.
   */
   public void resetDeletingDocumentMultiple(DocumentDescription[] documentDescriptions)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset a deleting document back to its former state.
   * This gets done when a deleting thread sees a service interruption, etc., from the ingestion system.
   */
   public void resetDeletingDocument(DocumentDescription documentDescription)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add an initial set of documents to the queue.
   * This method is called during job startup, when the queue is being loaded.
@@ -384,7 +384,7 @@ public interface IJobManager
     String[] docIDHashes, String[] docIDs, boolean overrideSchedule,
     int hopcountMethod, long currentTime, double[] documentPriorities,
     String[][] prereqEventNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add an initial set of remaining documents to the queue.
   * This method is called during job startup, when the queue is being loaded, to list documents that
@@ -398,7 +398,7 @@ public interface IJobManager
   public void addRemainingDocumentsInitial(Long jobID, String[] legalLinkTypes,
     String[] docIDHashes,
     int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Signal that a seeding pass has been done.
   * Call this method at the end of a seeding pass.  It is used to perform the bookkeeping necessary to
@@ -411,20 +411,20 @@ public interface IJobManager
   */
   public void doneDocumentsInitial(Long jobID, String[] legalLinkTypes, boolean isPartial,
     int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Begin an event sequence.
   *@param eventName is the name of the event.
   *@return true if the event could be created, or false if it's already there.
   */
   public boolean beginEventSequence(String eventName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Complete an event sequence.
   *@param eventName is the name of the event.
   */
   public void completeEventSequence(String eventName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get the specified hop counts, with the limit as described.
   *@param jobID is the job identifier.
@@ -438,7 +438,7 @@ public interface IJobManager
   */
   public boolean[] findHopCounts(Long jobID, String[] legalLinkTypes, String[] docIDHashes, String linkType, int limit,
     int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get all the current seeds.
   * Returns the seed document identifiers for a job.
@@ -446,7 +446,7 @@ public interface IJobManager
   *@return the document identifier hashes that are currently considered to be seeds.
   */
   public String[] getAllSeeds(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add a document to the queue.
   * This method is called during document processing, when a document reference is discovered.
@@ -473,7 +473,7 @@ public interface IJobManager
     String relationshipType,
     int hopcountMethod, String[] dataNames, Object[][] dataValues,
     long currentTime, double priority, String[] prereqEventNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add documents to the queue in bulk.
   * This method is called during document processing, when a set of document references are discovered.
@@ -502,7 +502,7 @@ public interface IJobManager
     int hopcountMethod, String[][] dataNames, Object[][][] dataValues,
     long currentTime, double[] priorities,
     String[][] prereqEventNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Complete adding child documents to the queue, for a set of documents.
   * This method is called at the end of document processing, to help the hopcount tracking engine do its bookkeeping.
@@ -515,7 +515,7 @@ public interface IJobManager
   */
   public DocumentDescription[] finishDocuments(Long jobID, String[] legalLinkTypes,
     String[] parentIdentifierHashes, int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Retrieve specific parent data for a given document.
   *@param jobID is the job identifier.
@@ -524,7 +524,7 @@ public interface IJobManager
   *@return the unique data values.
   */
   public String[] retrieveParentData(Long jobID, String docIDHash, String dataName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Retrieve specific parent data for a given document.
   *@param jobID is the job identifier.
@@ -533,7 +533,7 @@ public interface IJobManager
   *@return the unique data values.
   */
   public CharacterInput[] retrieveParentDataAsFiles(Long jobID, String docIDHash, String dataName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // These methods support the job threads (which start jobs and end jobs)
   // There is one thread that starts jobs.  It simply looks for jobs which are ready to
@@ -547,40 +547,40 @@ public interface IJobManager
   *@param jobID is the ID of the job to start.
   */
   public void manualStart(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Manually abort a running job.  The job will be permanently stopped, and will not run again until
   * automatically started based on schedule, or manually started.
   *@param jobID is the job to abort.
   */
   public void manualAbort(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Manually restart a running job.  The job will be stopped and restarted.  Any schedule affinity will be lost,
   * until the job finishes on its own.
   *@param jobID is the job to abort.
   */
   public void manualAbortRestart(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Pause a job.
   *@param jobID is the job identifier to pause.
   */
   public void pauseJob(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Restart a paused job.
   *@param jobID is the job identifier to restart.
   */
   public void restartJob(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset job schedule.  This re-evaluates whether the job should be started now.  This method would typically
   * be called after a job's scheduling window has been changed.
   *@param jobID is the job identifier.
   */
   public void resetJobSchedule(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // These methods are called by automatic processes
 
@@ -591,7 +591,7 @@ public interface IJobManager
   *@param unwaitList is filled in with the set of job id's that were resumed (Long's).
   */
   public void startJobs(long currentTime, ArrayList unwaitList)
-    throws ACFException;
+    throws ManifoldCFException;
 
 
   /** Put active or paused jobs in wait state, if they've exceeded their window.
@@ -599,7 +599,7 @@ public interface IJobManager
   *@param waitList is filled in with the set of job id's that were put into a wait state (Long's).
   */
   public void waitJobs(long currentTime, ArrayList waitList)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get the list of jobs that are ready for seeding.
   *@param currentTime is the current time in milliseconds since epoch.
@@ -607,65 +607,65 @@ public interface IJobManager
   * based on what the connector says should be added to the queue.
   */
   public JobStartRecord[] getJobsReadyForSeeding(long currentTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset a seeding job back to "active" state.
   *@param jobID is the job id.
   */
   public void resetSeedJob(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get the list of jobs that are ready for startup.
   *@return jobs that were in the "readyforstartup" state.  These will be marked as being in the "starting up" state.
   */
   public JobStartRecord[] getJobsReadyForStartup()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Find the list of jobs that need to have their connectors notified of job completion.
   *@return the ID's of jobs that need their output connectors notified in order to become inactive.
   */
   public Long[] getJobsReadyForInactivity()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Inactivate a job, from the notification state.
   *@param jobID is the ID of the job to inactivate.
   */
   public void inactivateJob(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
     
   /** Reset a starting job back to "ready for startup" state.
   *@param jobID is the job id.
   */
   public void resetStartupJob(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Prepare for a full scan.
   *@param jobID is the job id.
   *@param hopcountMethod describes how to handle deletions for hopcount purposes.
   */
   public void prepareFullScan(Long jobID, String[] legalLinkTypes, int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Prepare for an incremental scan.
   *@param jobID is the job id.
   *@param hopcountMethod describes how to handle deletions for hopcount purposes.
   */
   public void prepareIncrementalScan(Long jobID, String[] legalLinkTypes, int hopcountMethod)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note job started.
   *@param jobID is the job id.
   *@param startTime is the job start time.
   */
   public void noteJobStarted(Long jobID, long startTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note job seeded.
   *@param jobID is the job id.
   *@param startTime is the job seed time.
   */
   public void noteJobSeeded(Long jobID, long startTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /**  Note the deregistration of a connector used by the specified connections.
   * This method will be called when the connector is deregistered.  Jobs that use these connections
@@ -673,7 +673,7 @@ public interface IJobManager
   *@param connectionNames is the set of connection names.
   */
   public void noteConnectorDeregistration(String[] connectionNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note the registration of a connector used by the specified connections.
   * This method will be called when a connector is registered, on which the specified
@@ -681,14 +681,14 @@ public interface IJobManager
   *@param connectionNames is the set of connection names.
   */
   public void noteConnectorRegistration(String[] connectionNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note a change in connection configuration.
   * This method will be called whenever a connection's configuration is modified, or when an external repository change
   * is signalled.
   */
   public void noteConnectionChange(String connectionName)
-    throws ACFException;
+    throws ManifoldCFException;
     
   /**  Note the deregistration of an output connector used by the specified connections.
   * This method will be called when the connector is deregistered.  Jobs that use these connections
@@ -696,7 +696,7 @@ public interface IJobManager
   *@param connectionNames is the set of connection names.
   */
   public void noteOutputConnectorDeregistration(String[] connectionNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note the registration of an output connector used by the specified connections.
   * This method will be called when a connector is registered, on which the specified
@@ -704,20 +704,20 @@ public interface IJobManager
   *@param connectionNames is the set of connection names.
   */
   public void noteOutputConnectorRegistration(String[] connectionNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Note a change in output connection configuration.
   * This method will be called whenever a connection's configuration is modified, or when an external output target change
   * is signalled.
   */
   public void noteOutputConnectionChange(String connectionName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Delete jobs in need of being deleted (which are marked "ready for delete").
   * This method is meant to be called periodically to perform delete processing on jobs.
   */
   public void deleteJobsReadyForDelete()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get list of deletable document descriptions.  This list will take into account
   * multiple jobs that may own the same document.
@@ -725,7 +725,7 @@ public interface IJobManager
   *@return the document descriptions for these documents.
   */
   public DocumentDescription[] getNextDeletableDocuments(int n)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Delete ingested document identifiers (as part of deleting the owning job).
   * The number of identifiers specified is guaranteed to be less than the maxInClauseCount
@@ -733,7 +733,7 @@ public interface IJobManager
   *@param identifiers is the set of document identifiers.
   */
   public void deleteIngestedDocumentIdentifiers(DocumentDescription[] identifiers)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Abort a running job due to a fatal error condition.
   *@param jobID is the job to abort.
@@ -741,19 +741,19 @@ public interface IJobManager
   *@return true if this is the first abort for the job.
   */
   public boolean errorAbort(Long jobID, String errorText)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Complete the sequence that aborts jobs and makes them runnable again.
   *@param timestamp is the current time in milliseconds since epoch.
   *@param abortJobs is filled in with the set of IJobDescription objects that were aborted.
   */
   public void finishJobAborts(long timestamp, ArrayList abortJobs)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Put all eligible jobs in the "shutting down" state.
   */
   public void finishJobs()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Reset eligible jobs back to "inactive" state.  This method is used to pick up all jobs in the shutting down state
   * whose purgatory records have been all cleaned up.
@@ -761,7 +761,7 @@ public interface IJobManager
   *@param resetJobs is filled in with the set of IJobDescription objects that were reset.
   */
   public void resetJobs(long currentTime, ArrayList resetJobs)
-    throws ACFException;
+    throws ManifoldCFException;
 
 
   // Status reports
@@ -770,25 +770,25 @@ public interface IJobManager
   *@return the status object for the specified job.
   */
   public JobStatus getStatus(Long jobID)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get a list of all jobs, and their status information.
   *@return an ordered array of job status objects.
   */
   public JobStatus[] getAllStatus()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get a list of running jobs.  This is for status reporting.
   *@return an array of the job status objects.
   */
   public JobStatus[] getRunningJobs()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get a list of completed jobs, and their statistics.
   *@return an array of the job status objects.
   */
   public JobStatus[] getFinishedJobs()
-    throws ACFException;
+    throws ManifoldCFException;
 
   // The following commands generate reports based on the queue.
 
@@ -803,7 +803,7 @@ public interface IJobManager
   */
   public IResultSet genDocumentStatus(String connectionName, StatusFilterCriteria filterCriteria, SortOrder sortOrder,
     int startRow, int rowCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Run a 'queue status' report.
   *@param connectionName is the name of the connection.
@@ -817,5 +817,5 @@ public interface IJobManager
   */
   public IResultSet genQueueStatus(String connectionName, StatusFilterCriteria filterCriteria, SortOrder sortOrder,
     BucketDescription idBucketDescription, int startRow, int rowCount)
-    throws ACFException;
+    throws ManifoldCFException;
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IProcessActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IProcessActivity.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IProcessActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IProcessActivity.java Mon Oct  4 14:32:19 2010
@@ -44,7 +44,7 @@ public interface IProcessActivity extend
   */
   public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType,
     String[] dataNames, Object[][] dataValues, Long originationTime, String[] prereqEventNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add a document description to the current job's queue.
   *@param localIdentifier is the local document identifier to add (for the connector that
@@ -61,7 +61,7 @@ public interface IProcessActivity extend
   */
   public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType,
     String[] dataNames, Object[][] dataValues, Long originationTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
 
   /** Add a document description to the current job's queue.
@@ -78,7 +78,7 @@ public interface IProcessActivity extend
   */
   public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType,
     String[] dataNames, Object[][] dataValues)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add a document description to the current job's queue.
   *@param localIdentifier is the local document identifier to add (for the connector that
@@ -90,7 +90,7 @@ public interface IProcessActivity extend
   * "getRelationshipTypes()".  May be null.
   */
   public void addDocumentReference(String localIdentifier, String parentIdentifier, String relationshipType)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Add a document description to the current job's queue.  This method is equivalent to
   * addDocumentReference(localIdentifier,null,null).
@@ -98,7 +98,7 @@ public interface IProcessActivity extend
   * fetched the document).
   */
   public void addDocumentReference(String localIdentifier)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Retrieve data passed from parents to a specified child document.
   *@param localIdentifier is the document identifier of the document we want the recorded data for.
@@ -106,7 +106,7 @@ public interface IProcessActivity extend
   *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
   */
   public String[] retrieveParentData(String localIdentifier, String dataName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Retrieve data passed from parents to a specified child document.
   *@param localIdentifier is the document identifier of the document we want the recorded data for.
@@ -114,14 +114,14 @@ public interface IProcessActivity extend
   *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
   */
   public CharacterInput[] retrieveParentDataAsFiles(String localIdentifier, String dataName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Record a document version, but don't ingest it.
   *@param localIdentifier is the document identifier.
   *@param version is the document version.
   */
   public void recordDocument(String localIdentifier, String version)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Ingest the current document.
   *@param localIdentifier is the document's local identifier.
@@ -132,13 +132,13 @@ public interface IProcessActivity extend
   *@param data is the document data.  The data is closed after ingestion is complete.
   */
   public void ingestDocument(String localIdentifier, String version, String documentURI, RepositoryDocument data)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Delete the current document from the search engine index.
   *@param localIdentifier is the document's local identifier.
   */
   public void deleteDocument(String localIdentifier)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Override the schedule for the next time a document is crawled.
   * Calling this method allows you to set an upper recrawl bound, lower recrawl bound, upper expire bound, lower expire bound,
@@ -153,7 +153,7 @@ public interface IProcessActivity extend
   public void setDocumentScheduleBounds(String localIdentifier,
     Long lowerRecrawlBoundTime, Long upperRecrawlBoundTime,
     Long lowerExpireBoundTime, Long upperExpireBoundTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Override a document's origination time.
   * Use this method to signal the framework that a document's origination time is something other than the first time it was crawled.
@@ -162,6 +162,6 @@ public interface IProcessActivity extend
   */
   public void setDocumentOriginationTime(String localIdentifier,
     Long originationTime)
-    throws ACFException;
+    throws ManifoldCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnectionManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnectionManager.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnectionManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnectionManager.java Mon Oct  4 14:32:19 2010
@@ -29,33 +29,33 @@ public interface IRepositoryConnectionMa
   /** Install the manager.
   */
   public void install()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Uninstall the manager.
   */
   public void deinstall()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Export configuration */
   public void exportConfiguration(java.io.OutputStream os)
-    throws java.io.IOException, ACFException;
+    throws java.io.IOException, ManifoldCFException;
 
   /** Import configuration */
   public void importConfiguration(java.io.InputStream is)
-    throws java.io.IOException, ACFException;
+    throws java.io.IOException, ManifoldCFException;
 
   /** Obtain a list of the repository connections, ordered by name.
   *@return an array of connection objects.
   */
   public IRepositoryConnection[] getAllConnections()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Load a repository connection by name.
   *@param name is the name of the repository connection.
   *@return the loaded connection object, or null if not found.
   */
   public IRepositoryConnection load(String name)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Load a set of repository connections.
   *@param names are the names of the repository connections.
@@ -63,48 +63,48 @@ public interface IRepositoryConnectionMa
   * values for those not found.
   */
   public IRepositoryConnection[] loadMultiple(String[] names)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Create a new repository connection object.
   *@return the new object.
   */
   public IRepositoryConnection create()
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Save a repository connection object.
   *@param object is the object to save.
   *@return true if the object is created, false otherwise.
   */
   public boolean save(IRepositoryConnection object)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Delete a repository connection.
   *@param name is the name of the connection to delete.  If the
   * name does not exist, no error is returned.
   */
   public void delete(String name)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Return true if the specified authority name is referenced.
   *@param authorityName is the authority name.
   *@return true if referenced, false otherwise.
   */
   public boolean isReferenced(String authorityName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get a list of repository connections that share the same connector.
   *@param className is the class name of the connector.
   *@return the repository connections that use that connector.
   */
   public String[] findConnectionsForConnector(String className)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Check if underlying connector exists.
   *@param name is the name of the connection to check.
   *@return true if the underlying connector is registered.
   */
   public boolean checkConnectorExists(String name)
-    throws ACFException;
+    throws ManifoldCFException;
 
   // Schema related
 
@@ -163,7 +163,7 @@ public interface IRepositoryConnectionMa
   */
   public void recordHistory(String connectionName, Long startTime, String activityType, Long dataSize,
     String entityIdentifier, String resultCode, String resultDescription, String[] childIdentifiers)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Generate a report, listing the start time, elapsed time, result code and description, number of bytes, and entity identifier.
   * The records selected for this report are based on the filtering criteria object passed into this method.
@@ -176,7 +176,7 @@ public interface IRepositoryConnectionMa
   *@param maxRowCount is the maximum number of rows to include.
   */
   public IResultSet genHistorySimple(String connectionName, FilterCriteria criteria, SortOrder sort, int startRow, int maxRowCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Count the number of rows specified by a given set of criteria.  This can be used to make decisions
   * as to whether a query based on those rows will complete in an acceptable amount of time.
@@ -185,7 +185,7 @@ public interface IRepositoryConnectionMa
   *@return the number of rows included by the criteria.
   */
   public long countHistoryRows(String connectionName, FilterCriteria criteria)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Generate a report, listing the start time, activity count, and identifier bucket, given
   * a time slice (interval) size.
@@ -205,7 +205,7 @@ public interface IRepositoryConnectionMa
   */
   public IResultSet genHistoryActivityCount(String connectionName, FilterCriteria criteria, SortOrder sort, BucketDescription idBucket,
     long interval, int startRow, int maxRowCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Generate a report, listing the start time, bytes processed, and identifier bucket, given
   * a time slice (interval) size.
@@ -225,7 +225,7 @@ public interface IRepositoryConnectionMa
   */
   public IResultSet genHistoryByteCount(String connectionName, FilterCriteria criteria, SortOrder sort, BucketDescription idBucket,
     long interval, int startRow, int maxRowCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
 
   /** Generate a report, listing the result bucket and identifier bucket.
@@ -244,7 +244,7 @@ public interface IRepositoryConnectionMa
   */
   public IResultSet genHistoryResultCodes(String connectionName, FilterCriteria criteria, SortOrder sort,
     BucketDescription resultCodeBucket, BucketDescription idBucket, int startRow, int maxRowCount)
-    throws ACFException;
+    throws ManifoldCFException;
 
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnector.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnector.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnector.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IRepositoryConnector.java Mon Oct  4 14:32:19 2010
@@ -24,7 +24,7 @@ import org.apache.manifoldcf.agents.inte
 import java.io.*;
 import java.util.*;
 
-/** This interface describes an instance of a connection between a repository and ACF's
+/** This interface describes an instance of a connection between a repository and ManifoldCF's
 * standard "pull" ingestion agent.
 *
 * Each instance of this interface is used in only one thread at a time.  Connection Pooling
@@ -48,14 +48,14 @@ import java.util.*;
 * It therefore establishes a space of document identifiers.  Each connector will only ever be
 * asked to deal with identifiers that have in some way originated from the connector.
 *
-* Documents are fetched by ACF in three stages.  First, the addSeedDocuments() method is called in the connector
-* implementation.  This method is meant to add a set of document identifiers to the queue.  When ACF is ready
+* Documents are fetched by ManifoldCF in three stages.  First, the addSeedDocuments() method is called in the connector
+* implementation.  This method is meant to add a set of document identifiers to the queue.  When ManifoldCF is ready
 * to process a document, the document identifier is used to obtain a current document version string, using the
 * getDocumentVersions() method (the second stage).  This version string is used to decide whether or not the
 * third stage need be called for the document or not.  The third stage is responsible for sending document content
 * to the output, and for extracting any references to additional documents, and consists of the processDocuments() method.
 *
-* All of these methods interact with ACF by means of an "activity" interface.  For example, an IVersionActivity object
+* All of these methods interact with ManifoldCF by means of an "activity" interface.  For example, an IVersionActivity object
 * is passed to the getDocumentVersions() method, and that object contains methods that are necessary for getDocumentVersions()
 * to do its job.  A similar architecture is used throughout the connector framework.
 */
@@ -129,7 +129,7 @@ public interface IRepositoryConnector ex
   *@return true if the resource is found, false if not.  In either case, output may be filled in.
   */
   public boolean requestInfo(Configuration output, String command)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Queue "seed" documents.  Seed documents are the starting places for crawling activity.  Documents
   * are seeded when this method calls appropriate methods in the passed in ISeedingActivity object.
@@ -159,7 +159,7 @@ public interface IRepositoryConnector ex
   */
   public void addSeedDocuments(ISeedingActivity activities, DocumentSpecification spec,
     long startTime, long endTime, int jobMode)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Get document versions given an array of document identifiers.
   * This method is called for EVERY document that is considered. It is
@@ -180,7 +180,7 @@ public interface IRepositoryConnector ex
   */
   public String[] getDocumentVersions(String[] documentIdentifiers, String[] oldVersions, IVersionActivity activities,
     DocumentSpecification spec, int jobMode, boolean usesDefaultAuthority)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Process a set of documents.
   * This is the method that should cause each document to be fetched, processed, and the results either added
@@ -198,7 +198,7 @@ public interface IRepositoryConnector ex
   */
   public void processDocuments(String[] documentIdentifiers, String[] versions, IProcessActivity activities,
     DocumentSpecification spec, boolean[] scanOnly, int jobMode)
-    throws ACFException, ServiceInterruption;
+    throws ManifoldCFException, ServiceInterruption;
 
   /** Free a set of documents.  This method is called for all documents whose versions have been fetched using
   * the getDocumentVersions() method, including those that returned null versions.  It may be used to free resources
@@ -208,7 +208,7 @@ public interface IRepositoryConnector ex
   *@param versions is the corresponding set of version identifiers (individual identifiers may be null).
   */
   public void releaseDocumentVersions(String[] documentIdentifiers, String[] versions)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Get the maximum number of documents to amalgamate together into one batch, for this connector.
   * The connector does not need to be connected for this method to be called.
@@ -233,7 +233,7 @@ public interface IRepositoryConnector ex
   *@param tabsArray is an array of tab names.  Add to this array any tab names that are specific to the connector.
   */
   public void outputSpecificationHeader(IHTTPOutput out, DocumentSpecification ds, ArrayList tabsArray)
-    throws ACFException, IOException;
+    throws ManifoldCFException, IOException;
   
   /** Output the specification body section.
   * This method is called in the body section of a job page which has selected a repository connection of the current type.  Its purpose is to present the required form elements for editing.
@@ -244,7 +244,7 @@ public interface IRepositoryConnector ex
   *@param tabName is the current tab name.
   */
   public void outputSpecificationBody(IHTTPOutput out, DocumentSpecification ds, String tabName)
-    throws ACFException, IOException;
+    throws ManifoldCFException, IOException;
   
   /** Process a specification post.
   * This method is called at the start of job's edit or view page, whenever there is a possibility that form data for a connection has been
@@ -255,7 +255,7 @@ public interface IRepositoryConnector ex
   *@return null if all is well, or a string error message if there is an error that should prevent saving of the job (and cause a redirection to an error page).
   */
   public String processSpecificationPost(IPostParameters variableContext, DocumentSpecification ds)
-    throws ACFException;
+    throws ManifoldCFException;
   
   /** View specification.
   * This method is called in the body section of a job's view page.  Its purpose is to present the document specification information to the user.
@@ -264,7 +264,7 @@ public interface IRepositoryConnector ex
   *@param ds is the current document specification for this job.
   */
   public void viewSpecification(IHTTPOutput out, DocumentSpecification ds)
-    throws ACFException, IOException;
+    throws ManifoldCFException, IOException;
 
 }
 

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/ISeedingActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/ISeedingActivity.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/ISeedingActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/ISeedingActivity.java Mon Oct  4 14:32:19 2010
@@ -46,7 +46,7 @@ public interface ISeedingActivity extend
   *@param prereqEventNames is the list of prerequisite events required for this document, or null if none.
   */
   public void addSeedDocument(String documentIdentifier, String[] prereqEventNames)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Record a "seed" document identifier.
   * Seeds passed to this method will be loaded into the job's queue at the beginning of the
@@ -62,7 +62,7 @@ public interface ISeedingActivity extend
   *@param documentIdentifier is the identifier of the document to add to the "pending" queue.
   */
   public void addSeedDocument(String documentIdentifier)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** This method receives document identifiers that should be considered part of the seeds, but do not need to be
   * queued for processing at this time.  (This method is used to keep the hopcount tables up to date.)  It is
@@ -76,6 +76,6 @@ public interface ISeedingActivity extend
   * "pending" queue.
   */
   public void addUnqueuedSeedDocument(String documentIdentifier)
-    throws ACFException;
+    throws ManifoldCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IVersionActivity.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IVersionActivity.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IVersionActivity.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IVersionActivity.java Mon Oct  4 14:32:19 2010
@@ -35,7 +35,7 @@ public interface IVersionActivity extend
   *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
   */
   public String[] retrieveParentData(String localIdentifier, String dataName)
-    throws ACFException;
+    throws ManifoldCFException;
 
   /** Retrieve data passed from parents to a specified child document.
   *@param localIdentifier is the document identifier of the document we want the recorded data for.
@@ -43,6 +43,6 @@ public interface IVersionActivity extend
   *@return an array containing the unique data values passed from ALL parents.  Note that these are in no particular order, and there will not be any duplicates.
   */
   public CharacterInput[] retrieveParentDataAsFiles(String localIdentifier, String dataName)
-    throws ACFException;
+    throws ManifoldCFException;
 
 }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/JobManagerFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/JobManagerFactory.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/JobManagerFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/JobManagerFactory.java Mon Oct  4 14:32:19 2010
@@ -39,15 +39,15 @@ public class JobManagerFactory
   *@return the handle.
   */
   public static IJobManager make(IThreadContext threadContext)
-    throws ACFException
+    throws ManifoldCFException
   {
     Object o = threadContext.get(jobManagerName);
     if (o == null || !(o instanceof IJobManager))
     {
       IDBInterface database = DBInterfaceFactory.make(threadContext,
-        ACF.getMasterDatabaseName(),
-        ACF.getMasterDatabaseUsername(),
-        ACF.getMasterDatabasePassword());
+        ManifoldCF.getMasterDatabaseName(),
+        ManifoldCF.getMasterDatabaseUsername(),
+        ManifoldCF.getMasterDatabasePassword());
 
       o = new org.apache.manifoldcf.crawler.jobs.JobManager(threadContext,database);
       threadContext.save(jobManagerName,o);

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectionManagerFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectionManagerFactory.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectionManagerFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectionManagerFactory.java Mon Oct  4 14:32:19 2010
@@ -19,7 +19,7 @@
 package org.apache.manifoldcf.crawler.interfaces;
 
 import org.apache.manifoldcf.core.interfaces.*;
-import org.apache.manifoldcf.crawler.system.ACF;
+import org.apache.manifoldcf.crawler.system.ManifoldCF;
 
 /** Repository connection manager factory.
 */
@@ -39,15 +39,15 @@ public class RepositoryConnectionManager
   *@return the handle.
   */
   public static IRepositoryConnectionManager make(IThreadContext tc)
-    throws ACFException
+    throws ManifoldCFException
   {
     Object o = tc.get(objectName);
     if (o == null || !(o instanceof IRepositoryConnectionManager))
     {
       IDBInterface database = DBInterfaceFactory.make(tc,
-        ACF.getMasterDatabaseName(),
-        ACF.getMasterDatabaseUsername(),
-        ACF.getMasterDatabasePassword());
+        ManifoldCF.getMasterDatabaseName(),
+        ManifoldCF.getMasterDatabaseUsername(),
+        ManifoldCF.getMasterDatabasePassword());
 
       o = new org.apache.manifoldcf.crawler.repository.RepositoryConnectionManager(tc,database);
       tc.save(objectName,o);

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectorFactory.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectorFactory.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectorFactory.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/RepositoryConnectorFactory.java Mon Oct  4 14:32:19 2010
@@ -21,7 +21,7 @@ package org.apache.manifoldcf.crawler.in
 import org.apache.manifoldcf.core.interfaces.*;
 import org.apache.manifoldcf.agents.interfaces.*;
 import org.apache.manifoldcf.crawler.system.Logging;
-import org.apache.manifoldcf.crawler.system.ACF;
+import org.apache.manifoldcf.crawler.system.ManifoldCF;
 
 import java.util.*;
 import java.io.*;
@@ -47,7 +47,7 @@ public class RepositoryConnectorFactory
   *@param className is the class name.
   */
   public static void install(IThreadContext threadContext, String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector connector = getConnectorNoCheck(className);
     connector.install(threadContext);
@@ -57,7 +57,7 @@ public class RepositoryConnectorFactory
   *@param className is the class name.
   */
   public static void deinstall(IThreadContext threadContext, String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector connector = getConnectorNoCheck(className);
     connector.deinstall(threadContext);
@@ -68,7 +68,7 @@ public class RepositoryConnectorFactory
   *@return the list of activities.
   */
   public static String[] getActivitiesList(IThreadContext threadContext, String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     if (connector == null)
@@ -83,7 +83,7 @@ public class RepositoryConnectorFactory
   *@return the list of link types, in sorted order.
   */
   public static String[] getRelationshipTypes(IThreadContext threadContext, String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     if (connector == null)
@@ -98,7 +98,7 @@ public class RepositoryConnectorFactory
   *@return the connector operating model, as specified in IRepositoryConnector.
   */
   public static int getConnectorModel(IThreadContext threadContext, String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     if (connector == null)
@@ -109,7 +109,7 @@ public class RepositoryConnectorFactory
   /** Output the configuration header section.
   */
   public static void outputConfigurationHeader(IThreadContext threadContext, String className, IHTTPOutput out, ConfigParams parameters, ArrayList tabsArray)
-    throws ACFException, IOException
+    throws ManifoldCFException, IOException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     if (connector == null)
@@ -120,7 +120,7 @@ public class RepositoryConnectorFactory
   /** Output the configuration body section.
   */
   public static void outputConfigurationBody(IThreadContext threadContext, String className, IHTTPOutput out, ConfigParams parameters, String tabName)
-    throws ACFException, IOException
+    throws ManifoldCFException, IOException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     if (connector == null)
@@ -131,7 +131,7 @@ public class RepositoryConnectorFactory
   /** Process configuration post data for a connector.
   */
   public static String processConfigurationPost(IThreadContext threadContext, String className, IPostParameters variableContext, ConfigParams configParams)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     if (connector == null)
@@ -142,7 +142,7 @@ public class RepositoryConnectorFactory
   /** View connector configuration.
   */
   public static void viewConfiguration(IThreadContext threadContext, String className, IHTTPOutput out, ConfigParams configParams)
-    throws ACFException, IOException
+    throws ManifoldCFException, IOException
   {
     IRepositoryConnector connector = getConnector(threadContext, className);
     // We want to be able to view connections even if they have unregistered connectors.
@@ -156,18 +156,18 @@ public class RepositoryConnectorFactory
   *@return the instance.
   */
   public static IRepositoryConnector getConnectorNoCheck(String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     try
     {
-      Class theClass = ACF.findClass(className);
+      Class theClass = ManifoldCF.findClass(className);
       Class[] argumentClasses = new Class[0];
       // Look for a constructor
       Constructor c = theClass.getConstructor(argumentClasses);
       Object[] arguments = new Object[0];
       Object o = c.newInstance(arguments);
       if (!(o instanceof IRepositoryConnector))
-        throw new ACFException("Class '"+className+"' does not implement IRepositoryConnector.");
+        throw new ManifoldCFException("Class '"+className+"' does not implement IRepositoryConnector.");
       return (IRepositoryConnector)o;
     }
     catch (InvocationTargetException e)
@@ -176,41 +176,41 @@ public class RepositoryConnectorFactory
       if (z instanceof Error)
         throw (Error)z;
       else
-        throw (ACFException)z;
+        throw (ManifoldCFException)z;
     }
     catch (ClassNotFoundException e)
     {
-      throw new ACFException("No repository connector class '"+className+"' was found.",
+      throw new ManifoldCFException("No repository connector class '"+className+"' was found.",
         e);
     }
     catch (NoSuchMethodException e)
     {
-      throw new ACFException("No appropriate constructor for IRepositoryConnector implementation '"+
+      throw new ManifoldCFException("No appropriate constructor for IRepositoryConnector implementation '"+
         className+"'.  Need xxx(ConfigParams).",
         e);
     }
     catch (SecurityException e)
     {
-      throw new ACFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
         e);
     }
     catch (IllegalAccessException e)
     {
-      throw new ACFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
         e);
     }
     catch (IllegalArgumentException e)
     {
-      throw new ACFException("Shouldn't happen!!!",e);
+      throw new ManifoldCFException("Shouldn't happen!!!",e);
     }
     catch (InstantiationException e)
     {
-      throw new ACFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
         e);
     }
     catch (ExceptionInInitializerError e)
     {
-      throw new ACFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
         e);
     }
 
@@ -221,7 +221,7 @@ public class RepositoryConnectorFactory
   *@return the instance.
   */
   protected static IRepositoryConnector getConnector(IThreadContext threadContext, String className)
-    throws ACFException
+    throws ManifoldCFException
   {
     IConnectorManager connMgr = ConnectorManagerFactory.make(threadContext);
     if (connMgr.isInstalled(className) == false)
@@ -229,14 +229,14 @@ public class RepositoryConnectorFactory
 
     try
     {
-      Class theClass = ACF.findClass(className);
+      Class theClass = ManifoldCF.findClass(className);
       Class[] argumentClasses = new Class[0];
       // Look for a constructor
       Constructor c = theClass.getConstructor(argumentClasses);
       Object[] arguments = new Object[0];
       Object o = c.newInstance(arguments);
       if (!(o instanceof IRepositoryConnector))
-        throw new ACFException("Class '"+className+"' does not implement IRepositoryConnector.");
+        throw new ManifoldCFException("Class '"+className+"' does not implement IRepositoryConnector.");
       return (IRepositoryConnector)o;
     }
     catch (InvocationTargetException e)
@@ -245,7 +245,7 @@ public class RepositoryConnectorFactory
       if (z instanceof Error)
         throw (Error)z;
       else
-        throw (ACFException)z;
+        throw (ManifoldCFException)z;
     }
     catch (ClassNotFoundException e)
     {
@@ -254,37 +254,37 @@ public class RepositoryConnectorFactory
       if (connMgr.isInstalled(className) == false)
         return null;
 
-      throw new ACFException("No repository connector class '"+className+"' was found.",
+      throw new ManifoldCFException("No repository connector class '"+className+"' was found.",
         e);
     }
     catch (NoSuchMethodException e)
     {
-      throw new ACFException("No appropriate constructor for IRepositoryConnector implementation '"+
+      throw new ManifoldCFException("No appropriate constructor for IRepositoryConnector implementation '"+
         className+"'.  Need xxx(ConfigParams).",
         e);
     }
     catch (SecurityException e)
     {
-      throw new ACFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
         e);
     }
     catch (IllegalAccessException e)
     {
-      throw new ACFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
         e);
     }
     catch (IllegalArgumentException e)
     {
-      throw new ACFException("Shouldn't happen!!!",e);
+      throw new ManifoldCFException("Shouldn't happen!!!",e);
     }
     catch (InstantiationException e)
     {
-      throw new ACFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
         e);
     }
     catch (ExceptionInInitializerError e)
     {
-      throw new ACFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
+      throw new ManifoldCFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
         e);
     }
 
@@ -295,7 +295,7 @@ public class RepositoryConnectorFactory
   */
   public static IRepositoryConnector[] grabMultiple(IThreadContext threadContext,
     String[] orderingKeys, String[] classNames, ConfigParams[] configInfos, int[] maxPoolSizes)
-    throws ACFException
+    throws ManifoldCFException
   {
     IRepositoryConnector[] rval = new IRepositoryConnector[classNames.length];
     HashMap orderMap = new HashMap();
@@ -303,7 +303,7 @@ public class RepositoryConnectorFactory
     while (i < orderingKeys.length)
     {
       if (orderMap.get(orderingKeys[i]) != null)
-        throw new ACFException("Found duplicate order key");
+        throw new ManifoldCFException("Found duplicate order key");
       orderMap.put(orderingKeys[i],new Integer(i));
       i++;
     }
@@ -332,13 +332,13 @@ public class RepositoryConnectorFactory
           {
             release(rval[index]);
           }
-          catch (ACFException e2)
+          catch (ManifoldCFException e2)
           {
           }
         }
-        if (e instanceof ACFException)
+        if (e instanceof ManifoldCFException)
         {
-          throw (ACFException)e;
+          throw (ManifoldCFException)e;
         }
         throw (Error)e;
       }
@@ -356,7 +356,7 @@ public class RepositoryConnectorFactory
   */
   public static IRepositoryConnector grab(IThreadContext threadContext,
     String className, ConfigParams configInfo, int maxPoolSize)
-    throws ACFException
+    throws ManifoldCFException
   {
     // We want to get handles off the pool and use them.  But the
     // handles we fetch have to have the right config information.
@@ -392,10 +392,10 @@ public class RepositoryConnectorFactory
   /** Release multiple repository connectors.
   */
   public static void releaseMultiple(IRepositoryConnector[] connectors)
-    throws ACFException
+    throws ManifoldCFException
   {
     int i = 0;
-    ACFException currentException = null;
+    ManifoldCFException currentException = null;
     while (i < connectors.length)
     {
       IRepositoryConnector c = connectors[i++];
@@ -403,7 +403,7 @@ public class RepositoryConnectorFactory
       {
         release(c);
       }
-      catch (ACFException e)
+      catch (ManifoldCFException e)
       {
         if (currentException == null)
           currentException = e;
@@ -417,7 +417,7 @@ public class RepositoryConnectorFactory
   *@param connector is the connector to release.
   */
   public static void release(IRepositoryConnector connector)
-    throws ACFException
+    throws ManifoldCFException
   {
     // If the connector is null, skip the release, because we never really got the connector in the first place.
     if (connector == null)
@@ -444,7 +444,7 @@ public class RepositoryConnectorFactory
   * This method polls all inactive handles.
   */
   public static void pollAllConnectors(IThreadContext threadContext)
-    throws ACFException
+    throws ManifoldCFException
   {
     // System.out.println("Pool stats:");
 
@@ -470,7 +470,7 @@ public class RepositoryConnectorFactory
   *@param threadContext is the local thread context.
   */
   public static void closeAllConnectors(IThreadContext threadContext)
-    throws ACFException
+    throws ManifoldCFException
   {
     // Go through the whole pool and clean it out
     synchronized (poolHash)
@@ -578,7 +578,7 @@ public class RepositoryConnectorFactory
     *@return the connector, or null if no connector could be connected.
     */
     public synchronized IRepositoryConnector getConnector(IThreadContext threadContext)
-      throws ACFException
+      throws ManifoldCFException
     {
       while (numFree == 0)
       {
@@ -588,7 +588,7 @@ public class RepositoryConnectorFactory
         }
         catch (InterruptedException e)
         {
-          throw new ACFException("Interrupted: "+e.getMessage(),e,ACFException.INTERRUPTED);
+          throw new ManifoldCFException("Interrupted: "+e.getMessage(),e,ManifoldCFException.INTERRUPTED);
         }
       }
 
@@ -604,14 +604,14 @@ public class RepositoryConnectorFactory
 
         try
         {
-          Class theClass = ACF.findClass(className);
+          Class theClass = ManifoldCF.findClass(className);
           Class[] argumentClasses = new Class[0];
           // Look for a constructor
           Constructor c = theClass.getConstructor(argumentClasses);
           Object[] arguments = new Object[0];
           Object o = c.newInstance(arguments);
           if (!(o instanceof IRepositoryConnector))
-            throw new ACFException("Class '"+className+"' does not implement IRepositoryConnector.");
+            throw new ManifoldCFException("Class '"+className+"' does not implement IRepositoryConnector.");
           rc = (IRepositoryConnector)o;
           rc.connect(configParams);
         }
@@ -621,7 +621,7 @@ public class RepositoryConnectorFactory
           if (z instanceof Error)
             throw (Error)z;
           else
-            throw (ACFException)z;
+            throw (ManifoldCFException)z;
         }
         catch (ClassNotFoundException e)
         {
@@ -631,37 +631,37 @@ public class RepositoryConnectorFactory
           if (connMgr.isInstalled(className) == false)
             return null;
 
-          throw new ACFException("No repository connector class '"+className+"' was found.",
+          throw new ManifoldCFException("No repository connector class '"+className+"' was found.",
             e);
         }
         catch (NoSuchMethodException e)
         {
-          throw new ACFException("No appropriate constructor for IRepositoryConnector implementation '"+
+          throw new ManifoldCFException("No appropriate constructor for IRepositoryConnector implementation '"+
             className+"'.  Need xxx(ConfigParams).",
             e);
         }
         catch (SecurityException e)
         {
-          throw new ACFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
+          throw new ManifoldCFException("Protected constructor for IRepositoryConnector implementation '"+className+"'",
             e);
         }
         catch (IllegalAccessException e)
         {
-          throw new ACFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
+          throw new ManifoldCFException("Unavailable constructor for IRepositoryConnector implementation '"+className+"'",
             e);
         }
         catch (IllegalArgumentException e)
         {
-          throw new ACFException("Shouldn't happen!!!",e);
+          throw new ManifoldCFException("Shouldn't happen!!!",e);
         }
         catch (InstantiationException e)
         {
-          throw new ACFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
+          throw new ManifoldCFException("InstantiationException for IRepositoryConnector implementation '"+className+"'",
             e);
         }
         catch (ExceptionInInitializerError e)
         {
-          throw new ACFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
+          throw new ManifoldCFException("ExceptionInInitializerError for IRepositoryConnector implementation '"+className+"'",
             e);
         }
       }
@@ -678,7 +678,7 @@ public class RepositoryConnectorFactory
     *@param connector is the connector.
     */
     public synchronized void releaseConnector(IRepositoryConnector connector)
-      throws ACFException
+      throws ManifoldCFException
     {
       if (connector == null)
         return;
@@ -694,7 +694,7 @@ public class RepositoryConnectorFactory
     /** Notify all free connectors.
     */
     public synchronized void pollAll(IThreadContext threadContext)
-      throws ACFException
+      throws ManifoldCFException
     {
       int i = 0;
       while (i < stack.size())
@@ -710,7 +710,7 @@ public class RepositoryConnectorFactory
     /** Release all free connectors.
     */
     public synchronized void releaseAll(IThreadContext threadContext)
-      throws ACFException
+      throws ManifoldCFException
     {
       while (stack.size() > 0)
       {

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/SortOrder.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/SortOrder.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/SortOrder.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/SortOrder.java Mon Oct  4 14:32:19 2010
@@ -44,7 +44,7 @@ public class SortOrder
   /** Constructor from string representation.
   */
   public SortOrder(String rep)
-    throws ACFException
+    throws ManifoldCFException
   {
     ParseBuffer pb = new ParseBuffer(rep);
     StringBuffer numBuffer = new StringBuffer();
@@ -52,7 +52,7 @@ public class SortOrder
     {
       int x = pb.peekCharAt();
       if (x == -1)
-        throw new ACFException("Unexpected end");
+        throw new ManifoldCFException("Unexpected end");
       char y = (char)x;
       pb.next();
       if (y == ':')
@@ -72,7 +72,7 @@ public class SortOrder
     }
     catch (NumberFormatException e)
     {
-      throw new ACFException("Bad number",e);
+      throw new ManifoldCFException("Bad number",e);
     }
   }
 
@@ -190,25 +190,25 @@ public class SortOrder
     }
 
     public SortSpec(ParseBuffer pb)
-      throws ACFException
+      throws ManifoldCFException
     {
       int x = pb.peekCharAt();
       if (x == -1)
-        throw new ACFException("Unexpected end");
+        throw new ManifoldCFException("Unexpected end");
       char y = (char)x;
       if (y == '+')
         this.direction = SORT_ASCENDING;
       else if (y == '-')
         this.direction = SORT_DESCENDING;
       else
-        throw new ACFException("Bad direction");
+        throw new ManifoldCFException("Bad direction");
       pb.next();
       StringBuffer sb = new StringBuffer();
       while (true)
       {
         x = pb.peekCharAt();
         if (x == -1)
-          throw new ACFException("Unexpected end");
+          throw new ManifoldCFException("Unexpected end");
         y = (char)x;
         pb.next();
         if (y == '.')

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/Carrydown.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/Carrydown.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/Carrydown.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/Carrydown.java Mon Oct  4 14:32:19 2010
@@ -23,7 +23,7 @@ import java.util.*;
 import org.apache.manifoldcf.core.interfaces.*;
 import org.apache.manifoldcf.crawler.interfaces.*;
 import org.apache.manifoldcf.crawler.system.Logging;
-import org.apache.manifoldcf.crawler.system.ACF;
+import org.apache.manifoldcf.crawler.system.ManifoldCF;
 
 /** This class manages the table that keeps track of intrinsic relationships between documents.
 */
@@ -65,7 +65,7 @@ public class Carrydown extends org.apach
   *@param database is the database handle.
   */
   public Carrydown(IDBInterface database)
-    throws ACFException
+    throws ManifoldCFException
   {
     super(database,"carrydown");
   }
@@ -73,7 +73,7 @@ public class Carrydown extends org.apach
   /** Install or upgrade.
   */
   public void install(String jobsTable, String jobsColumn)
-    throws ACFException
+    throws ManifoldCFException
   {
     // Standard practice: Outer loop, to support upgrade requirements.
     while (true)
@@ -153,7 +153,7 @@ public class Carrydown extends org.apach
   /** Uninstall.
   */
   public void deinstall()
-    throws ACFException
+    throws ManifoldCFException
   {
     performDrop(null);
   }
@@ -161,7 +161,7 @@ public class Carrydown extends org.apach
   /** Analyze job tables that need analysis.
   */
   public void analyzeTables()
-    throws ACFException
+    throws ManifoldCFException
   {
     long startTime = System.currentTimeMillis();
     Logging.perf.debug("Beginning to analyze carrydown table");
@@ -172,7 +172,7 @@ public class Carrydown extends org.apach
   /** Delete an owning job (and clean up the corresponding carrydown rows).
   */
   public void deleteOwner(Long jobID)
-    throws ACFException
+    throws ManifoldCFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -192,7 +192,7 @@ public class Carrydown extends org.apach
   /** Reset, at startup time.
   */
   public void reset()
-    throws ACFException
+    throws ManifoldCFException
   {
     // Delete "new" rows
     HashMap map = new HashMap();
@@ -213,7 +213,7 @@ public class Carrydown extends org.apach
   */
   public boolean recordCarrydownData(Long jobID, String parentDocumentIDHash, String childDocumentIDHash,
     String[] documentDataNames, String[][] documentDataValueHashes, Object[][] documentDataValues)
-    throws ACFException
+    throws ManifoldCFException
   {
     return recordCarrydownDataMultiple(jobID,parentDocumentIDHash,new String[]{childDocumentIDHash},
       new String[][]{documentDataNames},new String[][][]{documentDataValueHashes},new Object[][][]{documentDataValues})[0];
@@ -223,7 +223,7 @@ public class Carrydown extends org.apach
   */
   public boolean[] recordCarrydownDataMultiple(Long jobID, String parentDocumentIDHash, String[] childDocumentIDHashes,
     String[][] dataNames, String[][][] dataValueHashes, Object[][][] dataValues)
-    throws ACFException
+    throws ManifoldCFException
   {
 
     // Need to go into a transaction because we need to distinguish between update and insert.
@@ -384,7 +384,7 @@ public class Carrydown extends org.apach
 
   /** Do the exists check, in batch. */
   protected void performExistsCheck(Map presentMap, String query, ArrayList list)
-    throws ACFException
+    throws ManifoldCFException
   {
     // Note well: presentMap is only checked for the *existence* of a record, so we do not need to populate the datavalue field!
     // This is crucial, because otherwise we'd either be using an undetermined amount of memory, or we'd need to read into a temporary file.
@@ -406,7 +406,7 @@ public class Carrydown extends org.apach
   * and delete the old (eliminated) child records.
   */
   public void restoreRecords(Long jobID, String[] parentDocumentIDHashes)
-    throws ACFException
+    throws ManifoldCFException
   {
     beginTransaction();
     try
@@ -438,7 +438,7 @@ public class Carrydown extends org.apach
       if (k > 0)
         performRestoreRecords(sb.toString(),list);
     }
-    catch (ACFException e)
+    catch (ManifoldCFException e)
     {
       signalRollback();
       throw e;
@@ -455,7 +455,7 @@ public class Carrydown extends org.apach
   }
 
   protected void performRestoreRecords(String query, ArrayList list)
-    throws ACFException
+    throws ManifoldCFException
   {
     // Delete
     StringBuffer sb = new StringBuffer("WHERE (");
@@ -477,7 +477,7 @@ public class Carrydown extends org.apach
   /** Delete all records that mention a particular set of document identifiers.
   */
   public void deleteRecords(Long jobID, String[] documentIDHashes)
-    throws ACFException
+    throws ManifoldCFException
   {
     beginTransaction();
     try
@@ -524,7 +524,7 @@ public class Carrydown extends org.apach
 
 
     }
-    catch (ACFException e)
+    catch (ManifoldCFException e)
     {
       signalRollback();
       throw e;
@@ -542,7 +542,7 @@ public class Carrydown extends org.apach
   }
 
   protected void performDeleteRecords(String query, String query2, ArrayList list, ArrayList list2)
-    throws ACFException
+    throws ManifoldCFException
   {
     performDelete("WHERE "+query,list,null);
     performDelete("WHERE "+query2,list2,null);
@@ -550,7 +550,7 @@ public class Carrydown extends org.apach
 
   /** Get unique values given a document identifier, data name, an job identifier */
   public String[] getDataValues(Long jobID, String documentIdentifierHash, String dataName)
-    throws ACFException
+    throws ManifoldCFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -575,7 +575,7 @@ public class Carrydown extends org.apach
 
   /** Get unique values given a document identifier, data name, an job identifier */
   public CharacterInput[] getDataValuesAsFiles(Long jobID, String documentIdentifierHash, String dataName)
-    throws ACFException
+    throws ManifoldCFException
   {
     ArrayList list = new ArrayList();
     list.add(jobID);
@@ -624,7 +624,7 @@ public class Carrydown extends org.apach
   /** Conditionally do analyze operation.
   */
   public void conditionallyAnalyzeTables()
-    throws ACFException
+    throws ManifoldCFException
   {
     if (tracker.checkAnalyze())
     {
@@ -678,7 +678,7 @@ public class Carrydown extends org.apach
     *@return true if it should be included, false otherwise.
     */
     public boolean checkInclude(IResultRow row)
-      throws ACFException
+      throws ManifoldCFException
     {
       // Check to be sure that this row is different from the last; only then agree to include it.
       String value = (String)row.getValue(dataValueHashField);
@@ -696,7 +696,7 @@ public class Carrydown extends org.apach
     *@return true if we need to keep going, or false if we are done.
     */
     public boolean checkContinue()
-      throws ACFException
+      throws ManifoldCFException
     {
       return true;
     }
@@ -868,7 +868,7 @@ public class Carrydown extends org.apach
     *@return true if it should be included, false otherwise.
     */
     public boolean checkInclude(IResultRow row)
-      throws ACFException
+      throws ManifoldCFException
     {
       Long jobID = (Long)row.getValue(jobIDField);
       String parentIDHash = (String)row.getValue(parentIDHashField);
@@ -897,7 +897,7 @@ public class Carrydown extends org.apach
     *@return true if we need to keep going, or false if we are done.
     */
     public boolean checkContinue()
-      throws ACFException
+      throws ManifoldCFException
     {
       return true;
     }

Modified: incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/EventManager.java
URL: http://svn.apache.org/viewvc/incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/EventManager.java?rev=1004255&r1=1004254&r2=1004255&view=diff
==============================================================================
--- incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/EventManager.java (original)
+++ incubator/lcf/trunk/modules/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/EventManager.java Mon Oct  4 14:32:19 2010
@@ -39,7 +39,7 @@ public class EventManager extends org.ap
   *@param database is the database handle.
   */
   public EventManager(IDBInterface database)
-    throws ACFException
+    throws ManifoldCFException
   {
     super(database,"events");
   }
@@ -47,7 +47,7 @@ public class EventManager extends org.ap
   /** Install or upgrade this table.
   */
   public void install()
-    throws ACFException
+    throws ManifoldCFException
   {
     // Standard practice: outer loop for installs
     while (true)
@@ -73,14 +73,14 @@ public class EventManager extends org.ap
   /** Uninstall.
   */
   public void deinstall()
-    throws ACFException
+    throws ManifoldCFException
   {
     beginTransaction();
     try
     {
       performDrop(null);
     }
-    catch (ACFException e)
+    catch (ManifoldCFException e)
     {
       signalRollback();
       throw e;
@@ -99,7 +99,7 @@ public class EventManager extends org.ap
   /** Prepare for restart.
   */
   public void restart()
-    throws ACFException
+    throws ManifoldCFException
   {
     // Delete all rows in this table.
     performDelete("",null,null);
@@ -107,7 +107,7 @@ public class EventManager extends org.ap
 
   /** Atomically create an event - and return false if the event already exists */
   public void createEvent(String eventName)
-    throws ACFException
+    throws ManifoldCFException
   {
     HashMap map = new HashMap();
     map.put(eventNameField,eventName);
@@ -116,7 +116,7 @@ public class EventManager extends org.ap
 
   /** Destroy an event */
   public void destroyEvent(String eventName)
-    throws ACFException
+    throws ManifoldCFException
   {
     ArrayList list = new ArrayList();
     list.add(eventName);



Mime
View raw message