You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jcs-dev@jakarta.apache.org by as...@apache.org on 2006/06/05 15:43:43 UTC
svn commit: r411785 -
/jakarta/jcs/trunk/src/java/org/apache/jcs/auxiliary/disk/indexed/IndexedDiskCache.java
Author: asmuts
Date: Mon Jun 5 06:43:43 2006
New Revision: 411785
URL: http://svn.apache.org/viewvc?rev=411785&view=rev
Log:
fixed deserialization problem when running inside the remote cache. The disk cache was not casting to the ICacheElement interface. It was using the CacheElement implementation, but the wrapper was the special remote cache element.
Modified:
jakarta/jcs/trunk/src/java/org/apache/jcs/auxiliary/disk/indexed/IndexedDiskCache.java
Modified: jakarta/jcs/trunk/src/java/org/apache/jcs/auxiliary/disk/indexed/IndexedDiskCache.java
URL: http://svn.apache.org/viewvc/jakarta/jcs/trunk/src/java/org/apache/jcs/auxiliary/disk/indexed/IndexedDiskCache.java?rev=411785&r1=411784&r2=411785&view=diff
==============================================================================
--- jakarta/jcs/trunk/src/java/org/apache/jcs/auxiliary/disk/indexed/IndexedDiskCache.java (original)
+++ jakarta/jcs/trunk/src/java/org/apache/jcs/auxiliary/disk/indexed/IndexedDiskCache.java Mon Jun 5 06:43:43 2006
@@ -35,7 +35,6 @@
import org.apache.jcs.auxiliary.disk.AbstractDiskCache;
import org.apache.jcs.auxiliary.disk.LRUMapJCS;
import org.apache.jcs.engine.CacheConstants;
-import org.apache.jcs.engine.CacheElement;
import org.apache.jcs.engine.behavior.ICacheElement;
import org.apache.jcs.engine.control.group.GroupAttrName;
import org.apache.jcs.engine.control.group.GroupId;
@@ -95,7 +94,7 @@
private int recycleCnt = 0;
private int startupSize = 0;
-
+
/**
* use this lock to synchronize reads and writes to the underlying storage
* mechansism.
@@ -181,7 +180,7 @@
{
log.error( "Failure initializing for fileName: " + fileName + " and root directory: " + rootDirName, e );
}
-
+
ShutdownHook shutdownHook = new ShutdownHook();
Runtime.getRuntime().addShutdownHook( shutdownHook );
}
@@ -374,7 +373,7 @@
byte[] data = IndexedDisk.serialize( ce );
// make sure this only locks for one particular cache region
- storageLock.writeLock().acquire();
+ storageLock.writeLock().acquire();
try
{
ded.init( dataFile.length(), data );
@@ -427,7 +426,7 @@
}
finally
- {
+ {
storageLock.writeLock().release();
}
@@ -508,10 +507,10 @@
* @return
* @throws IOException
*/
- private CacheElement readElement( Serializable key )
+ private ICacheElement readElement( Serializable key )
throws IOException
{
- CacheElement object = null;
+ ICacheElement object = null;
IndexedDiskElementDescriptor ded = (IndexedDiskElementDescriptor) keyHash.get( key );
@@ -523,14 +522,18 @@
}
try
{
- object = (CacheElement) dataFile.readObject( ded.pos );
+ object = (ICacheElement) dataFile.readObject( ded.pos );
}
catch ( IOException e )
{
- log.error( "Problem reading object from file" );
+ log.error( "IO Exception, Problem reading object from file", e );
throw e;
}
-
+ catch ( Exception e )
+ {
+ log.error( "Exception, Problem reading object from file", e );
+ throw new IOException( "Problem reading object from disk. " + e.getMessage() );
+ }
}
return object;
@@ -1126,7 +1129,7 @@
throws Exception
{
- CacheElement tempDe = null;
+ ICacheElement tempDe = null;
try
{
tempDe = readElement( key );
@@ -1453,25 +1456,26 @@
}
}
-
+
/**
* Called on shutdown
- *
+ *
* @author Aaron Smuts
- *
+ *
*/
- class ShutdownHook extends Thread
+ class ShutdownHook
+ extends Thread
{
-
+
public void run()
{
if ( alive )
{
log.info( "Disk cache was not shutdown properly. Will try to dispose." );
-
+
doDispose();
- }
+ }
}
-
+
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: jcs-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: jcs-dev-help@jakarta.apache.org