manifoldcf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r1841470 - /manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
Date Thu, 20 Sep 2018 13:12:34 GMT
Author: kwright
Date: Thu Sep 20 13:12:34 2018
New Revision: 1841470

URL: http://svn.apache.org/viewvc?rev=1841470&view=rev
Log:
Add more logging detail to job initialization

Modified:
    manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java

Modified: manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
URL: http://svn.apache.org/viewvc/manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java?rev=1841470&r1=1841469&r2=1841470&view=diff
==============================================================================
--- manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
(original)
+++ manifoldcf/trunk/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/jobs/JobManager.java
Thu Sep 20 13:12:34 2018
@@ -6718,7 +6718,11 @@ public class JobManager implements IJobM
     if (connectorModel == IRepositoryConnector.MODEL_ADD_CHANGE_DELETE)
     {
       if (fromBeginningOfTime)
+      {
+        Logging.jobs.info("Preparing MODEL_ADD_CHANGE_DELETE job "+jobID+" for run: fromBeginningOfTime=true,
so queueAllExisting invoked");
         queueAllExisting(jobID,legalLinkTypes);
+      }
+      Logging.jobs.info("Preparing MODEL_ADD_CHANGE_DELETE job "+jobID+" for run: fromBeginningOfTime=false,
so nothing needed");
       return;
     }
     
@@ -6727,9 +6731,15 @@ public class JobManager implements IJobM
     if (connectorModel == IRepositoryConnector.MODEL_CHAINED_ADD_CHANGE_DELETE)
     {
       if (fromBeginningOfTime)
+      {
+        Logging.jobs.info("Preparing MODEL_CHAINED_ADD_CHANGE_DELETE job "+jobID+" for run:
fromBeginningOfTime=true, so queueAllExisting invoked");
         queueAllExisting(jobID,legalLinkTypes);
+      }
       else
+      {
+        Logging.jobs.info("Preparing MODEL_CHAINED_ADD_CHANGE_DELETE job "+jobID+" for run:
fromBeginningOfTime=false, so preparePartialScan invoked");
         jobQueue.preparePartialScan(jobID);
+      }
       return;
     }
 
@@ -6743,7 +6753,11 @@ public class JobManager implements IJobM
       // will flag the documents we want to look at.
       if (connectorModel == IRepositoryConnector.MODEL_CHAINED_ADD ||
         connectorModel == IRepositoryConnector.MODEL_CHAINED_ADD_CHANGE)
+      {
+        Logging.jobs.info("Preparing minimal MODEL_CHAINED_* job "+jobID+" for run: preparePartialScan
invoked");
         jobQueue.preparePartialScan(jobID);
+      }
+      Logging.jobs.info("Preparing minimal non-MODEL_CHAINED_* job "+jobID+" for run: nothing
needed");
       return;
     }
     
@@ -6754,6 +6768,7 @@ public class JobManager implements IJobM
       // (a) not a continuous job, and
       // (b) not a partial model (which always disables full scans), and
       // (c) either MODEL_ALL or from the beginning of time (which are essentially equivalent)
+      Logging.jobs.info("Preparing non-continuous non-partial, either MODEL_ALL or fromBeginningOfTime,
"+jobID+" for run: prepareFullScan");
       prepareFullScan(jobID,legalLinkTypes,hopcountMethod);
     }
     else
@@ -6764,6 +6779,7 @@ public class JobManager implements IJobM
       // (c) not MODEL_ALL AND not from beginning of time
       // This causes all existing documents to be rechecked!  This is needed because the
model is not
       // complete at this point; we have ADD but we don't have either CHANGE or DELETE.
+      Logging.jobs.info("Preparing incremental scan for "+jobID+": prepareIncrementalScan");
       jobQueue.prepareIncrementalScan(jobID);
     }
   }



Mime
View raw message