Author: knguyen
Date: Fri Jun 15 16:53:31 2007
New Revision: 17602

URL: https://svndev.jahia.net/websvn/listing.php?sc=3D1&rev=3D17602&repname=
=3Djahia
Log:
PEU-50: avoid using quartz jobs for file indexation.

Modified:
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/hibernate/model/ind=
exingjob/JahiaContainerIndexingJob.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Ind=
exableDocument.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Ind=
exableDocumentImpl.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Jah=
iaSearchBaseService.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Jah=
iaSiteIndexingJob.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/com=
pass/LuceneResourceForHighLighting.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/luc=
ene/JahiaHitCollector.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/ContainerSearchIndexProcessValveImpl.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/FieldSearchIndexProcessValveImpl.java
    branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/FileFieldIndexingThread.java

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/hibernate/mod=
el/indexingjob/JahiaContainerIndexingJob.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/hibernate/model/indexingjob/JahiaContainerIn=
dexingJob.java&rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/hibernate/model/ind=
exingjob/JahiaContainerIndexingJob.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/hibernate/model/ind=
exingjob/JahiaContainerIndexingJob.java Fri Jun 15 16:53:31 2007
@@ -22,6 +22,7 @@
 import org.jahia.services.usermanager.JahiaUser;
 import org.jahia.services.search.IndexableDocument;
 import org.jahia.services.search.RemovableDocument;
+import org.jahia.services.search.JahiaFieldIndexableDocument;
 import org.jahia.registries.ServicesRegistry;
 =

 import java.util.List;
@@ -107,6 +108,8 @@
                 .getIndexableDocumentsForContainer(this.getCtnId().intValu=
e(), user);
         Iterator iterator =3D docs.iterator();
         IndexableDocument doc =3D null;
+        HashMap fieldDocs =3D null;
+        HashMap removeFieldDocs =3D null;
         while ( iterator.hasNext() ){
             doc =3D (IndexableDocument)iterator.next();
             if ( doc instanceof RemovableDocument ){
@@ -114,6 +117,25 @@
             } else {
                 toAdd.add(doc);
             }
+            fieldDocs =3D new HashMap();
+            removeFieldDocs =3D new HashMap();
+            List childDocs =3D doc.getChildIndexableDocuments();
+            Iterator childDocsIterator =3D childDocs.iterator();
+            IndexableDocument childDoc =3D null;
+            while ( childDocsIterator.hasNext() ){
+                childDoc =3D (IndexableDocument)childDocsIterator.next();
+                if ( childDoc instanceof RemovableDocument ){
+                    if ( !removeFieldDocs.containsKey(childDoc.getKey()) ){
+                        toRemove.add(childDoc);
+                        removeFieldDocs.put(childDoc.getKey(),childDoc.get=
Key());
+                    }
+                } else if ( childDoc instanceof JahiaFieldIndexableDocumen=
t){
+                    if ( !fieldDocs.containsKey(childDoc.getKey()) ){
+                        toAdd.add(childDoc);
+                        fieldDocs.put(childDoc.getKey(),childDoc.getKey());
+                    }
+                }
+            }
         }
     }
 =


Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/IndexableDocument.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/IndexableDocument.java&rev=
=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Ind=
exableDocument.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Ind=
exableDocument.java Fri Jun 15 16:53:31 2007
@@ -17,6 +17,7 @@
  */package org.jahia.services.search;
 =

 import java.util.Map;
+import java.util.List;
 import java.io.Serializable;
 =

 /**
@@ -98,4 +99,6 @@
      */
     public abstract void removeField (String name);
 =

+    public abstract List getChildIndexableDocuments();
+    =

 }
\ No newline at end of file

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/IndexableDocumentImpl.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/IndexableDocumentImpl.java&r=
ev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Ind=
exableDocumentImpl.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Ind=
exableDocumentImpl.java Fri Jun 15 16:53:31 2007
@@ -18,6 +18,8 @@
 =

 import java.util.Map;
 import java.util.HashMap;
+import java.util.List;
+import java.util.ArrayList;
 =

 /**
  *
@@ -30,6 +32,8 @@
 =

     private Map fields =3D new HashMap();
 =

+    private List childIndexableDocuments =3D new ArrayList();
+
     public IndexableDocumentImpl(){
 =

     }
@@ -164,4 +168,12 @@
         }
     }
 =

+    public List getChildIndexableDocuments() {
+        return childIndexableDocuments;
+    }
+
+    public void setChildIndexableDocuments(List childIndexableDocuments) {
+        this.childIndexableDocuments =3D childIndexableDocuments;
+    }
+    =

 }
\ No newline at end of file

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/JahiaSearchBaseService.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/JahiaSearchBaseService.java&=
rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Jah=
iaSearchBaseService.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Jah=
iaSearchBaseService.java Fri Jun 15 16:53:31 2007
@@ -848,7 +848,7 @@
                 diff =3D job.getDate().longValue()-lastInsertTime.longValu=
e();
                 if (diff < this.indexingJobInsertMinInterval) {
                     // skip inserting the job
-                    //logger.info("Skip inserting indexingJob ");
+                    // logger.info("Skip inserting indexingJob " + job.get=
ClassName() + "_" + job.getId());
                     return;
                 } else {
                     indexingJobInserts.put(keyAsString,job.getDate());
@@ -1197,9 +1197,34 @@
                 JahiaSite site =3D sitesService.getSite(contentContainer.g=
etSiteID());
                 List docs =3D getIndexableDocumentsForContainer(ctnId,user=
);
                 Iterator iterator =3D docs.iterator();
+                List childDocs =3D null;
+                Iterator childDocsIterator =3D null;
+                Map fieldDocs =3D null;
+                Map removeFieldDocs =3D null;
                 while ( iterator.hasNext() ){
+                    fieldDocs =3D new HashMap();
+                    removeFieldDocs =3D new HashMap();
+                    IndexableDocument doc =3D (IndexableDocument)iterator.=
next();
                     this.getSearchHandler(site.getID())
-                            .addDocument((IndexableDocument)iterator.next(=
));
+                            .addDocument(doc);
+                    childDocs =3D doc.getChildIndexableDocuments();
+                    childDocsIterator =3D childDocs.iterator();
+                    IndexableDocument childDoc =3D null;
+                    while ( childDocsIterator.hasNext() ){
+                        childDoc =3D (IndexableDocument)childDocsIterator.=
next();
+                        if ( childDoc instanceof RemovableDocument ){
+                            if ( !removeFieldDocs.containsKey(childDoc.get=
Key()) ){
+                                this.getSearchHandler(site.getID())
+                                    .addDocument(childDoc);
+                                removeFieldDocs.put(childDoc.getKey(),chil=
dDoc.getKey());
+                            }
+                        } else if ( childDoc instanceof JahiaFieldIndexabl=
eDocument ){
+                            if ( !fieldDocs.containsKey(childDoc.getKey())=
 ){
+                                this.getSearchHandler(site.getID()).addDoc=
ument(childDoc);
+                                fieldDocs.put(childDoc.getKey(),childDoc.g=
etKey());
+                            }
+                        }
+                    }
                 }
             } else {
                 this.addIndexingJob(indJob);

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/JahiaSiteIndexingJob.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/JahiaSiteIndexingJob.java&re=
v=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Jah=
iaSiteIndexingJob.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/Jah=
iaSiteIndexingJob.java Fri Jun 15 16:53:31 2007
@@ -188,6 +188,8 @@
                 }
                 ctnListIds =3D containerService.getContainerListIDsInPage(=
contentPage,loadRequest);
                 ctnListEnum =3D ctnListIds.elements();
+                Map fieldDocs =3D null;
+                Map removeFieldDocs =3D null;
                 while ( ctnListEnum.hasMoreElements() ){
                     listId =3D (Integer)ctnListEnum.nextElement();
                     ctnIds =3D containerService.getctnidsInList(listId.int=
Value(), loadRequest);
@@ -209,6 +211,25 @@
                             } else {
                                 toAdd.add(doc);
                             }
+                            fieldDocs =3D new HashMap();
+                            removeFieldDocs =3D new HashMap();
+                            List childDocs =3D doc.getChildIndexableDocume=
nts();
+                            Iterator childDocsIterator =3D childDocs.itera=
tor();
+                            IndexableDocument childDoc =3D null;
+                            while ( childDocsIterator.hasNext() ){
+                                childDoc =3D (IndexableDocument)childDocsI=
terator.next();
+                                if ( childDoc instanceof RemovableDocument=
 ){
+                                    if ( !removeFieldDocs.containsKey(chil=
dDoc.getKey()) ){
+                                        toRemove.add(childDoc);
+                                        removeFieldDocs.put(childDoc.getKe=
y(),childDoc.getKey());
+                                    }
+                                } else if ( childDoc instanceof JahiaField=
IndexableDocument){
+                                    if ( !fieldDocs.containsKey(childDoc.g=
etKey()) ){
+                                        toAdd.add(childDoc);
+                                        fieldDocs.put(childDoc.getKey(),ch=
ildDoc.getKey());
+                                    }
+                                }
+                            }
                         }
                         if ( toAdd.size() > batchSize ){
                             synchronized (lock){

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/compass/LuceneResourceForHighLighting.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/compass/LuceneResourceForHig=
hLighting.java&rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/com=
pass/LuceneResourceForHighLighting.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/com=
pass/LuceneResourceForHighLighting.java Fri Jun 15 16:53:31 2007
@@ -167,7 +167,7 @@
                     ExtractedDocument extDoc =3D ServicesRegistry
                             .getInstance().getFileExtractionService()
                             .getAlreadyExtractedDocument(
-                                    contentType,file.getPath());
+                                    contentType,site.getSiteKey() + "_" + =
file.getPath());
                     if ( extDoc !=3D null ){
                         Field f =3D Field.Text(JahiaSearchConstant.FILE_CO=
NTENT_FULLTEXT_SEARCH_FIELD,
                                 extDoc.getContentAsString());

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/lucene/JahiaHitCollector.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/lucene/JahiaHitCollector.jav=
a&rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/luc=
ene/JahiaHitCollector.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/luc=
ene/JahiaHitCollector.java Fri Jun 15 16:53:31 2007
@@ -359,6 +359,8 @@
         this.scores.clear();
         this.docs.clear();
         this.maxScore =3D 0f;
+        this.maxHitsCount =3D 0;
+        this.luceneDocsCount =3D 0;
+        this.limitReached =3D false;
     }
-
 }

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/valves/ContainerSearchIndexProcessValveImpl.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/valves/ContainerSearchIndexP=
rocessValveImpl.java&rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/ContainerSearchIndexProcessValveImpl.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/ContainerSearchIndexProcessValveImpl.java Fri Jun 15 16:53:31 2007
@@ -30,6 +30,7 @@
 import org.jahia.services.sites.JahiaSite;
 import org.jahia.services.webdav.DAVFileAccess;
 import org.jahia.services.webdav.JahiaWebdavBaseService;
+import org.jahia.services.fileextraction.FileExtractor;
 import org.jahia.utils.LanguageCodeConverters;
 import org.jahia.registries.ServicesRegistry;
 import org.jahia.params.ProcessingContext;
@@ -38,10 +39,7 @@
 import org.quartz.JobDataMap;
 import org.quartz.SimpleTrigger;
 =

-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Enumeration;
-import java.util.Map;
+import java.util.*;
 =

 /**
  * <p>Title: </p>
@@ -166,6 +164,16 @@
                     DAVFileAccess file =3D JahiaWebdavBaseService.getInsta=
nce ()
                             .getDAVFileAccess (site, fField.getRealName ()=
);
                     if (file.isValid () && file.hasRevisions () && !file.i=
sCollection ()) {
+                        List docs =3D ServicesRegistry.getInstance().getJa=
hiaSearchService()
+                                .getIndexableDocumentsForField(field.getID=
(),context.getUser());
+                        if ( docs !=3D null && !docs.isEmpty() ){
+                            doc.getChildIndexableDocuments().addAll(docs);
+                        }
+                        /*
+                        ServicesRegistry.getInstance().getJahiaSearchServi=
ce()
+                        .indexField(field.getID(), context.getUser(), fals=
e, true);
+                        */
+                        /*
                         String contentType =3D fField.getType ();
                         if ("application/pdf".equalsIgnoreCase(contentType=
)) {
                             long lastModifiedDate =3D System.currentTimeMi=
llis();
@@ -176,7 +184,7 @@
                             }
                             boolean newExtractionRequired =3D ServicesRegi=
stry.getInstance()
                                 .getFileExtractionService().newExtractionR=
equired(
-                                    contentType, file.getPath(),lastModifi=
edDate);
+                                    contentType, site.getSiteKey() + "_" +=
 file.getPath(),lastModifiedDate);
                             if ( newExtractionRequired ){
                                 JobDetail jobDetail =3D new JobDetail("Ext=
racting File Field" + fField.getID(),
                                         Scheduler.DEFAULT_GROUP, FileField=
IndexingThread.class );
@@ -194,7 +202,7 @@
                         } else {
                             ServicesRegistry.getInstance().getJahiaSearchS=
ervice()
                                 .indexField(field.getID(), context.getUser=
(), false, true);
-                        }
+                        }*/
                     }
                 } else {
                     valuesList.addAll(Arrays.asList(values));

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/valves/FieldSearchIndexProcessValveImpl.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/valves/FieldSearchIndexProce=
ssValveImpl.java&rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/FieldSearchIndexProcessValveImpl.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/FieldSearchIndexProcessValveImpl.java Fri Jun 15 16:53:31 2007
@@ -186,7 +186,25 @@
                             ExtractedDocument extDoc =3D ServicesRegistry
                                     .getInstance().getFileExtractionServic=
e()
                                     .getAlreadyExtractedDocument(
-                                            contentType,file.getPath());
+                                            contentType,site.getSiteKey() =
+ "_" + file.getPath());
+                            if ( extDoc =3D=3D null ){
+                                try {
+                                    long lastModifiedDate =3D System.curre=
ntTimeMillis();
+                                    try {
+                                        lastModifiedDate =3D file.getJahia=
FileField()
+                                                .getLastModifDate();
+                                    } catch (Throwable t) {
+                                        logger.debug(t);
+                                    }
+                                    InputStream ins =3D file.downloadFile(=
);
+                                    extDoc =3D ServicesRegistry.getInstanc=
e().getFileExtractionService()
+                                            .getExtractedDocument(contentT=
ype, site.getSiteKey() + "_" + file.getPath(), lastModifiedDate,
+                                                    true, ins);
+                                    ins.close();
+                                } catch (Throwable t) {
+                                    logger.info(t);
+                                }
+                            }
                             if ( extDoc !=3D null ){
                                 strVal =3D extDoc.getContentAsString();
                                 doc.addFieldValue(JahiaSearchConstant.FILE=
_CONTENT_FULLTEXT_SEARCH_FIELD,strVal);
@@ -207,6 +225,7 @@
                                     }
                                 }
                             }
+                            /*
                             long lastModifiedDate =3D System.currentTimeMi=
llis();
                             try {
                                 lastModifiedDate =3D file.getJahiaFileFiel=
d()
@@ -227,7 +246,7 @@
                                 SimpleTrigger trigger =3D new SimpleTrigge=
r(jobDetail.getName(), Scheduler.DEFAULT_GROUP);
                                 ServicesRegistry.getInstance().getSchedule=
rService().deleteRamJob(jobDetail.getName(), Scheduler.DEFAULT_GROUP);
                                 ServicesRegistry.getInstance().getSchedule=
rService().scheduleRamJob(jobDetail, trigger);
-                            }
+                            }*/
                         } catch ( Throwable t ){
                             logger.debug(t);
                         }

Modified: branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/sear=
ch/valves/FileFieldIndexingThread.java
URL: https://svndev.jahia.net/websvn/diff.php?path=3D/branches/JAHIA-5-0-1-=
BRANCH/core/src/java/org/jahia/services/search/valves/FileFieldIndexingThre=
ad.java&rev=3D17602&repname=3Djahia
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D
--- branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/FileFieldIndexingThread.java (original)
+++ branches/JAHIA-5-0-1-BRANCH/core/src/java/org/jahia/services/search/val=
ves/FileFieldIndexingThread.java Fri Jun 15 16:53:31 2007
@@ -23,6 +23,7 @@
 import org.jahia.services.sites.JahiaSite;
 import org.jahia.services.webdav.DAVFileAccess;
 import org.jahia.services.webdav.JahiaWebdavBaseService;
+import org.jahia.services.fileextraction.ExtractedDocument;
 import org.quartz.Job;
 import org.quartz.JobDataMap;
 import org.quartz.JobExecutionContext;
@@ -71,25 +72,25 @@
                                 logger.debug(t);
                             }
                             InputStream ins =3D file.downloadFile();
-                            ServicesRegistry.getInstance().getFileExtracti=
onService()
-                                    .getExtractedDocument(contentType, fil=
e.getPath(), lastModifiedDate,
+                            ExtractedDocument extDoc =3D ServicesRegistry.=
getInstance().getFileExtractionService()
+                                    .getExtractedDocument(contentType, sit=
e.getSiteKey() + "_" + file.getPath(), lastModifiedDate,
                                             true, ins);
                             ins.close();
-                            if ( ServicesRegistry.getInstance().getFileExt=
ractionService()
-                                    .getAlreadyExtractedDocument(contentTy=
pe,file.getPath()) !=3D null ){
+                            if ( extDoc !=3D null ){
                                 ServicesRegistry.getInstance().getJahiaSea=
rchService()
                                     .indexField(field.getID(), context.get=
User(), false, true);
                             }
                         } catch (Throwable t) {
-                            logger.debug(t);
+                            logger.info(t);
                         }
                     }
                 }
             }
-            org.jahia.services.database.ConnectionDispenser.terminateConne=
ction();            =

         } catch (Throwable t) {
             org.jahia.services.database.ConnectionDispenser.abortConnectio=
n();            =

-            logger.debug("Exception occured extracting file", t);
+            logger.info("Exception occured extracting file", t);
+        } finally {
+            org.jahia.services.database.ConnectionDispenser.terminateConne=
ction();
         }
     }
 }

_______________________________________________
cvs_list mailing list
[email protected]
http://lists.jahia.org/cgi-bin/mailman/listinfo/cvs_list

Reply via email to