asmuts 02/01/17 18:11:32
Modified: src/java/org/apache/stratum/jcs/access TestCacheAccess.java
src/java/org/apache/stratum/jcs/auxiliary/lateral/socket/tcp
LateralCacheTCPListener.java
src/conf cache2.ccf cache.ccf
Log:
Added teh ability to switch between caches in the tester interface. If you start
the tester and tester 2 you can switch 2 to move to testCache2. i set up testCache2
to use the TCP lateral distribution. It is very fast. If you don't want a
centralized remote, say if you have only 2 front end servers, then the TCP
distribution would be a good choice.
It is also good if you have some background processes that need to expire data on
the webservers.
I'm thinging about ading a get to the TCP lateral cache. This is a major change.
Multiple lateral caches would result in several failures. We could specify a maximium
number of gets, a maximum time to search (requires some sophisticated monitoring), or
some sort of simultaneous searching of multiple lateral caches (which may result in
too much chatter). The timeout seems best. I'll look into it.
TCP failover and recovery is working fine. May need to add some timeout to the
connect, so it won't block if a firewall allows incoming but not outgoing connection
to the port. This is always tricky.
This is a very efficient means of keeping multiple caches in best-bet
synchronization.
I'm also thinking of creating a socket remote cache.
Revision Changes Path
1.6 +26 -1
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/access/TestCacheAccess.java
Index: TestCacheAccess.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/access/TestCacheAccess.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- TestCacheAccess.java 16 Jan 2002 17:04:47 -0000 1.5
+++ TestCacheAccess.java 18 Jan 2002 02:11:32 -0000 1.6
@@ -117,7 +117,7 @@
// start the local cache witht he appropriate props file
GroupCacheManagerFactory.getInstance( args[0] );
- cache_control = GroupCacheAccess.getGroupAccess( "testCache" );
+ cache_control = GroupCacheAccess.getGroupAccess( "testCache1" );
// not necessary if you don't set default element attributes
try
@@ -595,6 +595,30 @@
p( "---cloned attr " + num + " in " + String.valueOf(
n_end - n_start ) + " millis ---" );
}
}
+ else
+ if ( message.startsWith( "switch" ) )
+ {
+ String numS = message.substring( message.indexOf( " " ) +
1, message.length() );
+ try {
+ int num = Integer.parseInt( numS.trim() );
+ }
+ catch ( Exception e )
+ {
+ p( "usage: switch number" );
+ p( " 1 == testCache1" );
+ }
+ if ( numS == null )
+ {
+ p( "usage: switch number" );
+ p( " 1 == testCache1" );
+ }
+ else
+ {
+ cache_control = GroupCacheAccess.getGroupAccess(
"testCache" + numS );
+ p( "switched to cache = " + "testCache" + numS );
+ p( cache_control.toString() );
+ }
+ }
}
}
@@ -649,6 +673,7 @@
p( "type 'stats' to get stats" );
p( "type 'cloneattr num' to clone attr" );
p( "type 'removeLateralDirect key' to remove lateral" );
+ p( "type 'switch number' to switch to testCache[number], 1 == testCache1" );
p( "type 'help' for commands" );
}
1.4 +5 -4
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/socket/tcp/LateralCacheTCPListener.java
Index: LateralCacheTCPListener.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/socket/tcp/LateralCacheTCPListener.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- LateralCacheTCPListener.java 15 Jan 2002 21:33:31 -0000 1.3
+++ LateralCacheTCPListener.java 18 Jan 2002 02:11:32 -0000 1.4
@@ -40,16 +40,17 @@
* Description of the Field
*/
protected final static boolean debug = false;
- //true;
+
/**
* Description of the Field
*/
protected final static boolean debugcmd = false;
- //true;
+
/**
* Description of the Field
*/
protected static transient Logger log;
+
/**
* Description of the Field
*/
@@ -191,7 +192,7 @@
}
getCacheManager();
ICompositeCache cache = ( ICompositeCache ) cacheMgr.getCache(
cb.getCacheName() );
- cache.update( cb, false );
+ cache.update( cb, ICache.REMOTE_INVOKATION );
//handleRemove(cb.getCacheName(), cb.getKey());
}
@@ -220,7 +221,7 @@
// interface limitation here
ICompositeCache cache = ( ICompositeCache ) cacheMgr.getCache( cacheName );
- cache.remove( key, cache.REMOTE_INVOKATION );
+ cache.remove( key, ICache.REMOTE_INVOKATION );
}
1.3 +10 -5 jakarta-turbine-stratum/src/conf/cache2.ccf
Index: cache2.ccf
===================================================================
RCS file: /home/cvs/jakarta-turbine-stratum/src/conf/cache2.ccf,v
retrieving revision 1.2
retrieving revision 1.3
diff -u -r1.2 -r1.3
--- cache2.ccf 15 Jan 2002 17:59:03 -0000 1.2
+++ cache2.ccf 18 Jan 2002 02:11:32 -0000 1.3
@@ -15,10 +15,15 @@
##############################################################
################## CACHE REGIONS AVAILABLE ###################
-jcs.region.testCache=DC,RC
-jcs.region.testCache.cacheattributes=org.apache.stratum.jcs.engine.CompositeCacheAttributes
-jcs.region.testCache.cacheattributes.MaxObjects=1000
-jcs.region.testCache.cacheattributes.MemoryCacheName=org.apache.stratum.jcs.engine.memory.lru.LRUMemoryCache
+jcs.region.testCache1=DC,RC
+jcs.region.testCache1.cacheattributes=org.apache.stratum.jcs.engine.CompositeCacheAttributes
+jcs.region.testCache1.cacheattributes.MaxObjects=1000
+jcs.region.testCache1.cacheattributes.MemoryCacheName=org.apache.stratum.jcs.engine.memory.lru.LRUMemoryCache
+
+jcs.region.testCache2=DC,LTCP
+jcs.region.testCache2.cacheattributes=org.apache.stratum.jcs.engine.CompositeCacheAttributes
+jcs.region.testCache2.cacheattributes.MaxObjects=1000
+jcs.region.testCache2.cacheattributes.MemoryCacheName=org.apache.stratum.jcs.engine.memory.lru.LRUMemoryCache
# prefered config
jcs.region.test2=DC
@@ -58,7 +63,7 @@
jcs.auxiliary.LTCP=org.apache.stratum.jcs.auxiliary.lateral.LateralCacheFactory
jcs.auxiliary.LTCP.attributes=org.apache.stratum.jcs.auxiliary.lateral.LateralCacheAttributes
jcs.auxiliary.LTCP.attributes.TransmissionTypeName=TCP
-jcs.auxiliary.LTCP.attributes.TcpServers=10.17.1.154:1111
+jcs.auxiliary.LTCP.attributes.TcpServers=localhost:1110
jcs.auxiliary.LTCP.attributes.TcpListenerPort=1111
jcs.auxiliary.LTCP2=org.apache.stratum.jcs.auxiliary.lateral.LateralCacheFactory
1.4 +10 -5 jakarta-turbine-stratum/src/conf/cache.ccf
Index: cache.ccf
===================================================================
RCS file: /home/cvs/jakarta-turbine-stratum/src/conf/cache.ccf,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- cache.ccf 17 Jan 2002 00:19:37 -0000 1.3
+++ cache.ccf 18 Jan 2002 02:11:32 -0000 1.4
@@ -17,10 +17,15 @@
##############################################################
################## CACHE REGIONS AVAILABLE ###################
# Regions preconfirgured for caching
-jcs.region.testCache=DC,RFailover
-jcs.region.testCache.cacheattributes=org.apache.stratum.jcs.engine.CompositeCacheAttributes
-jcs.region.testCache.cacheattributes.MaxObjects=1000
-jcs.region.testCache.cacheattributes.MemoryCacheName=org.apache.stratum.jcs.engine.memory.lru.LRUMemoryCache
+jcs.region.testCache1=DC,RFailover
+jcs.region.testCache1.cacheattributes=org.apache.stratum.jcs.engine.CompositeCacheAttributes
+jcs.region.testCache1.cacheattributes.MaxObjects=1000
+jcs.region.testCache1.cacheattributes.MemoryCacheName=org.apache.stratum.jcs.engine.memory.lru.LRUMemoryCache
+
+jcs.region.testCache2=DC,LTCP
+jcs.region.testCache2.cacheattributes=org.apache.stratum.jcs.engine.CompositeCacheAttributes
+jcs.region.testCache2.cacheattributes.MaxObjects=1000
+jcs.region.testCache2.cacheattributes.MemoryCacheName=org.apache.stratum.jcs.engine.memory.lru.LRUMemoryCache
# prefered config
jcs.region.test2=DC,RFailover
@@ -87,7 +92,7 @@
jcs.auxiliary.LTCP.attributes=org.apache.stratum.jcs.auxiliary.lateral.LateralCacheAttributes
jcs.auxiliary.LTCP.attributes.TransmissionTypeName=TCP
jcs.auxiliary.LTCP.attributes.TcpServers=localhost:1111
-jcs.auxiliary.LTCP.attributes.TcpListenerPort=1111
+jcs.auxiliary.LTCP.attributes.TcpListenerPort=1110
jcs.auxiliary.LTCP2=org.apache.stratum.jcs.auxiliary.lateral.LateralCacheFactory
jcs.auxiliary.LTCP2.attributes=org.apache.stratum.jcs.auxiliary.lateral.LateralCacheAttributes
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
