in src/experimental/org/apache/commons/jcs/auxiliary/lateral/xmlrpc/LateralXMLRPCReceiverConnection.java [103:168]
public Serializable executeImpl( LateralElementDescriptor led )
{
Serializable obj = "junk return value";
try
{
if ( led == null )
{
log.debug( "LateralElementDescriptor is null" );
//continue;
}
if ( led.requesterId == LateralCacheInfo.listenerId )
{
log.debug( "from self" );
}
else
{
if ( log.isDebugEnabled() )
{
log.debug( "receiving LateralElementDescriptor from another, led = "
+ ", led = " + led
+ ", led.command = " + led.command
+ ", led.ce = " + led.ce
+ ", ilcl = " + ilcl );
}
if ( led.command == led.UPDATE )
{
puts++;
if ( log.isDebugEnabled() )
{
if ( puts % 100 == 0 )
{
log.debug( "puts = " + puts );
}
}
ilcl.handlePut( led.ce );
}
else
if ( led.command == led.REMOVE )
{
ilcl.handleRemove( led.ce.getCacheName(), led.ce.getKey() );
}
else
if ( led.command == led.GET )
{
obj = getAndRespond( led.ce.getCacheName(), led.ce.getKey() );
//ilcl.handleGet( led.ce.getCacheName(), led.ce.getKey() );
}
}
// }
}
catch ( java.io.EOFException e )
{
log.info( "Caught java.io.EOFException closing conneciton." );
}
catch ( java.net.SocketException e )
{
log.info( "Caught java.net.SocketException closing conneciton." );
}
catch ( Exception e )
{
log.error( "Unexpected exception. Closing conneciton", e );
}
return obj;
}