Package org.apache.excalibur.source

Examples of org.apache.excalibur.source.SourceValidity

176
177
178
179
180
181
182
183
184
185
186
187
            try {
                List invalid = new LinkedList();
                for (Iterator i = javaSource.entrySet().iterator(); i.hasNext();) {
                    Map.Entry e = (Map.Entry) i.next();
                    String uri = (String) e.getKey();
                    SourceValidity validity = (SourceValidity) e.getValue();
                    int valid = validity.isValid();
                    if (valid == SourceValidity.UNKNOWN) {
                        Source newSrc = null;
                        try {
                            newSrc = sourceResolver.resolveURI(uri);
                            valid = newSrc.getValidity().isValid(validity);
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
        this.configuration = configuration;
    }

    public Object get(Source source, String prefix) {
        String key = prefix + source.getURI();
        SourceValidity newValidity = source.getValidity();

        // If source is not valid then remove object from cache and return null
        if (newValidity == null) {
            this.cache.remove(key);
            return null;
        }

        // If object is not in cache then return null
        Object[] objectAndValidity = (Object[]) this.cache.get(key);
        if (objectAndValidity == null) {
            return null;
        }

        // Check stored validity against current source validity
        SourceValidity storedValidity = (SourceValidity) objectAndValidity[1];
        int valid = storedValidity.isValid();
        boolean isValid;
        if (valid == SourceValidity.UNKNOWN) {
            valid = storedValidity.isValid(newValidity);
            isValid = (valid == SourceValidity.VALID);
        } else {
            isValid = (valid == SourceValidity.VALID);
        }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
        return objectAndValidity[0];
    }

    public void set(Object object, Source source, String prefix) throws IOException {
        String key = prefix + source.getURI();
        SourceValidity validity = source.getValidity();
        if (validity != null) {
            Object[] objectAndValidity = {object,  validity};
            cache.put(key, objectAndValidity);
        }
    }
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
        assertTrue("New file already exists", !child.exists());
        fillSource(child, text + " and blah!");

        long length = child.getContentLength();

        SourceValidity validity = child.getValidity();
        assertEquals("Validity is not valid", 1, validity.isValid());

        // Wait 2 seconds before updating the file
        Thread.sleep(2 * 1000L);

        // Now change its content
        PrintWriter pw = new PrintWriter(child.getOutputStream());
        pw.write(text);

        assertEquals("File length modified", length, child.getContentLength());

        pw.close();

        assertTrue("File length not modified", length != child.getContentLength());

        assertEquals("Validity is valid", -1, validity.isValid());
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
    public void testValidity() throws Exception
    {
        ResourceSource src1 = new ResourceSource("resource://org/apache/excalibur/source/test/ResourceSourceTestCase.class");
        ResourceSource src2 = new ResourceSource("resource://org/apache/excalibur/source/test/ResourceSourceTestCase.class");

        SourceValidity val1 = src1.getValidity();
        SourceValidity val2 = src2.getValidity();
       
        assertEquals("Validities should match", SourceValidity.VALID, val1.isValid(val2));
    }
View Full Code Here
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
    Object result = null;
    if (this.objectCache == null)
      init();
    CacheEntry cacheEntry = (CacheEntry) this.objectCache.get(key);
    if (cacheEntry != null) {
      SourceValidity previous = cacheEntry.validity;
      Source source = null;
      switch (previous.isValid()) {
        case SourceValidity.VALID:
          result = cacheEntry.object;
          break;
        case SourceValidity.UNKNOWN:
          source = resolver.resolveURI(uri);
          SourceValidity fresh = source.getValidity();
          switch (previous.isValid(fresh)){
            case SourceValidity.VALID:
              result = cacheEntry.object;
              break;
            case SourceValidity.UNKNOWN:
View Full Code Here
65
66
67
68
69
70
71
72
73
74
  public void store(Serializable key,
                    CachedResponse response)
                    throws ProcessingException {
        SourceValidity[] validities = response.getValidityObjects();
        for (int i=0; i< validities.length;i++) {
            SourceValidity val = validities[i];
            examineValidity(val, key);
        }
        super.store(key, response);
  }
View Full Code Here
182
183
184
185
186
187
188
189
190
191
                                    AbstractAggregatedValidity val,
                                    Serializable key) {
        // AggregatedValidity must be investigated further.
         Iterator it = val.getValidities().iterator();
         while (it.hasNext()) {
             SourceValidity thisVal = (SourceValidity)it.next();
             // Allow recursion
             examineValidity(thisVal, key);
         }
    }
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
        this.configuration = configuration;
    }

    public Object get(Source source, String prefix) {
        String key = prefix + source.getURI();
        SourceValidity newValidity = source.getValidity();

        if (newValidity == null) {
            cache.remove(key);
            return null;
        }

        Object[] objectAndValidity = (Object[])cache.get(key);
        if (objectAndValidity == null)
            return null;

        SourceValidity storedValidity = (SourceValidity)objectAndValidity[1];
        int valid = storedValidity.isValid();
        boolean isValid;
        if (valid == 0) {
            valid = storedValidity.isValid(newValidity);
            isValid = (valid == 1);
        } else {
            isValid = (valid == 1);
        }
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
        return objectAndValidity[0];
    }

    public void set(Object object, Source source, String prefix) throws IOException {
        String key = prefix + source.getURI();
        SourceValidity validity = source.getValidity();
        if (validity != null) {
            Object[] objectAndValidity = {object,  validity};
            cache.put(key, objectAndValidity);
        }
    }
View Full Code Here
TOP

Related Classes of org.apache.excalibur.source.SourceValidity

  • org.apache.avalon.excalibur.monitor.SourceResource
  • org.apache.cocoon.caching.impl.EventAwareCacheImpl
  • org.apache.cocoon.caching.SimpleCache
  • org.apache.cocoon.components.flow.javascript.fom.FOM_JavaScriptInterpreter$MyClassRepository
  • org.apache.cocoon.components.flow.ws.WebServiceLoader$MyClassRepository
  • org.apache.cocoon.components.modules.input.LocationMapModule
  • org.apache.cocoon.components.modules.input.XMLFileModule$DocumentHelper
  • org.apache.cocoon.components.modules.input.XPathXMLFileModule$DocumentInfo
  • org.apache.cocoon.components.pipeline.impl.AbstractCachingProcessingPipeline
  • org.apache.cocoon.components.pipeline.impl.ExpiresCachingProcessingPipeline
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.