asmuts 2005/06/03 13:25:55
Modified: src/conf cacheJG3.ccf cache2.ccf remote.cache.ccf
log4j.properties cacheJG2.ccf cache.ccf
remote.cache2.ccf cacheJG1.ccf
src/java/org/apache/jcs/auxiliary/lateral/javagroups
JGConnectionHolder.java
src/java/org/apache/jcs/auxiliary/lateral/behavior
ILateralCacheAttributes.java
src/scripts startRemoteCache.sh
src/test-conf log4j.properties cache.ccf
src/java/org/apache/jcs/auxiliary/remote/server
RemoteCacheServer.java
RemoteCacheServerListener.java
RemoteCacheServerFactory.java
src/java/org/apache/jcs/auxiliary/lateral LateralCache.java
LateralCacheNoWait.java LateralCacheManager.java
LateralCacheMonitor.java
LateralCacheNoWaitFacade.java
LateralCacheFactory.java
LateralCacheAttributes.java
src/test/org/apache/jcs TestSimpleLoad.java
TestJCSvHashtablePerf.java
. .cvsignore project.xml
src/java/org/apache/jcs/auxiliary/lateral/socket/tcp
LateralTCPSender.java LateralTCPListener.java
src/java/org/apache/jcs/engine CacheElement.java
Added: src/conf cacheNA2.ccf cacheTCP1.ccf cacheTCP2.ccf
cacheNB.ccf cacheTCP4.ccf cacheNA3.ccf
cacheLMD1.ccf cacheNA.ccf cacheTCP3.ccf
src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery
UDPDiscoveryManager.java UDPDiscoveryReceiver.java
UDPDiscoveryService.java
UDPDiscoverySenderThread.java
UDPDiscoverySender.java UDPDiscoveryMessage.java
src/test-conf TestZeroSizeCache.ccf TestSimpleLoad.ccf
TestUDPDiscovery.ccf
src/test/org/apache/jcs TestZeroSizeCache.java
src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery
TestUDPDiscovery.java MockLateralCache.java
src/test/org/apache/jcs/auxiliary/lateral/socket/tcp
TestTCPLateral.java
Removed: src/java/org/apache/jcs/utils/servlet/session
SessionInfo.java ISessionConstants.java
DistSessionGC.java DistSession.java
MetaHttpSession.java SessionIdGenerator.java
DistSessionTracker.java
HttpServletRequestFacade.java
DistSessionPoolManager.java
src/test/org/apache/jcs/servlet SessionExampleServlet.java
Log:
Added 2 new features to the TCP Lateral cache, some test files, and some unit
tests.
New features:
1. Can send but not receive using the TCP lateral cache
By default you do both.
jcs.auxiliary.LTCP.attributes.Receive=false
This turns off receiving. If you just want to broadcast invalidations or
puts this is useful.
Not all nodes need to receive. A data producer might not want to get
messages.
This is very useful.
2. Configurationless TCP lateral cache
You can configure the TCP lateral to use UDP discovery.
Lateral caches will broadcast to a multicast address and port, letting
all listeners know where they are. One startup each lateral will request a
broadcast from the others.
Broadcasts occur every 30 seconds. (to be made configurable)
Regions that don't receive don't broadcast anythign but requests.
When a lateral receives a discovery message it will try to add the lateral to
the nowait facade for the
region. If it already exists nothing happens. If a region is not configured
to send laterally, nothing happens,
since it doesn't have a no wait.
This allows you to have the same configuration on every machine.
Here is a sample config section:
jcs.auxiliary.LTCP=org.apache.jcs.auxiliary.lateral.LateralCacheFactory
jcs.auxiliary.LTCP.attributes=org.apache.jcs.auxiliary.lateral.LateralCacheAttributes
jcs.auxiliary.LTCP.attributes.TransmissionTypeName=TCP
#you can put something here or not
#jcs.auxiliary.LTCP.attributes.TcpServers=
jcs.auxiliary.LTCP.attributes.TcpListenerPort=1118
jcs.auxiliary.LTCP.attributes.PutOnlyMode=true
jcs.auxiliary.LTCP.attributes.UdpDiscoveryAddr=228.5.6.8
jcs.auxiliary.LTCP.attributes.UdpDiscoveryPort=6780
jcs.auxiliary.LTCP.attributes.UdpDiscoveryEnabled=true
jcs.auxiliary.LTCP.attributes.Receive=true
I'll add documentation later.
Revision Changes Path
1.3 +1 -2 jakarta-turbine-jcs/src/conf/cacheJG3.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheJG3.ccf.diff?r1=1.2&r2=1.3
1.8 +4 -4 jakarta-turbine-jcs/src/conf/cache2.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cache2.ccf.diff?r1=1.7&r2=1.8
1.8 +3 -3 jakarta-turbine-jcs/src/conf/remote.cache.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/remote.cache.ccf.diff?r1=1.7&r2=1.8
1.10 +12 -9 jakarta-turbine-jcs/src/conf/log4j.properties
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/log4j.properties.diff?r1=1.9&r2=1.10
1.2 +1 -1 jakarta-turbine-jcs/src/conf/cacheJG2.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheJG2.ccf.diff?r1=1.1&r2=1.2
1.20 +4 -4 jakarta-turbine-jcs/src/conf/cache.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cache.ccf.diff?r1=1.19&r2=1.20
1.6 +3 -3 jakarta-turbine-jcs/src/conf/remote.cache2.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/remote.cache2.ccf.diff?r1=1.5&r2=1.6
1.2 +1 -1 jakarta-turbine-jcs/src/conf/cacheJG1.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheJG1.ccf.diff?r1=1.1&r2=1.2
1.1 jakarta-turbine-jcs/src/conf/cacheNA2.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheNA2.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheTCP1.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheTCP1.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheTCP2.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheTCP2.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheNB.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheNB.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheTCP4.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheTCP4.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheNA3.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheNA3.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheLMD1.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheLMD1.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheNA.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheNA.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/conf/cacheTCP3.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/conf/cacheTCP3.ccf?rev=1.1
1.1
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryManager.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryManager.java?rev=1.1
1.1
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryReceiver.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryReceiver.java?rev=1.1
1.1
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryService.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryService.java?rev=1.1
1.1
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoverySenderThread.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoverySenderThread.java?rev=1.1
1.1
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoverySender.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoverySender.java?rev=1.1
1.1
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryMessage.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/UDPDiscoveryMessage.java?rev=1.1
1.8 +20 -24
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/javagroups/JGConnectionHolder.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/javagroups/JGConnectionHolder.java.diff?r1=1.7&r2=1.8
1.6 +124 -62
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/behavior/ILateralCacheAttributes.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/behavior/ILateralCacheAttributes.java.diff?r1=1.5&r2=1.6
1.2 +27 -6 jakarta-turbine-jcs/src/scripts/startRemoteCache.sh
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/scripts/startRemoteCache.sh.diff?r1=1.1&r2=1.2
1.8 +4 -3 jakarta-turbine-jcs/src/test-conf/log4j.properties
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test-conf/log4j.properties.diff?r1=1.7&r2=1.8
1.3 +1 -5 jakarta-turbine-jcs/src/test-conf/cache.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test-conf/cache.ccf.diff?r1=1.2&r2=1.3
1.1 jakarta-turbine-jcs/src/test-conf/TestZeroSizeCache.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test-conf/TestZeroSizeCache.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/test-conf/TestSimpleLoad.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test-conf/TestSimpleLoad.ccf?rev=1.1
1.1 jakarta-turbine-jcs/src/test-conf/TestUDPDiscovery.ccf
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test-conf/TestUDPDiscovery.ccf?rev=1.1
1.24 +3 -2
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/remote/server/RemoteCacheServer.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/remote/server/RemoteCacheServer.java.diff?r1=1.23&r2=1.24
1.12 +6 -6
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/remote/server/RemoteCacheServerListener.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/remote/server/RemoteCacheServerListener.java.diff?r1=1.11&r2=1.12
1.10 +1 -0
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/remote/server/RemoteCacheServerFactory.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/remote/server/RemoteCacheServerFactory.java.diff?r1=1.9&r2=1.10
1.13 +14 -10
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCache.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCache.java.diff?r1=1.12&r2=1.13
1.13 +260 -248
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheNoWait.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheNoWait.java.diff?r1=1.12&r2=1.13
1.14 +68 -49
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheManager.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheManager.java.diff?r1=1.13&r2=1.14
1.9 +140 -76
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheMonitor.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheMonitor.java.diff?r1=1.8&r2=1.9
1.12 +121 -78
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheNoWaitFacade.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheNoWaitFacade.java.diff?r1=1.11&r2=1.12
1.11 +108 -26
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheFactory.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheFactory.java.diff?r1=1.10&r2=1.11
1.11 +161 -95
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheAttributes.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/LateralCacheAttributes.java.diff?r1=1.10&r2=1.11
1.4 +12 -2
jakarta-turbine-jcs/src/test/org/apache/jcs/TestSimpleLoad.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test/org/apache/jcs/TestSimpleLoad.java.diff?r1=1.3&r2=1.4
1.3 +1 -1
jakarta-turbine-jcs/src/test/org/apache/jcs/TestJCSvHashtablePerf.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test/org/apache/jcs/TestJCSvHashtablePerf.java.diff?r1=1.2&r2=1.3
1.1
jakarta-turbine-jcs/src/test/org/apache/jcs/TestZeroSizeCache.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test/org/apache/jcs/TestZeroSizeCache.java?rev=1.1
1.3 +1 -0 jakarta-turbine-jcs/.cvsignore
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/.cvsignore.diff?r1=1.2&r2=1.3
1.53 +2 -1 jakarta-turbine-jcs/project.xml
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/project.xml.diff?r1=1.52&r2=1.53
1.13 +85 -94
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/LateralTCPSender.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/LateralTCPSender.java.diff?r1=1.12&r2=1.13
1.11 +82 -45
jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/LateralTCPListener.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/auxiliary/lateral/socket/tcp/LateralTCPListener.java.diff?r1=1.10&r2=1.11
1.1
jakarta-turbine-jcs/src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/TestUDPDiscovery.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/TestUDPDiscovery.java?rev=1.1
1.1
jakarta-turbine-jcs/src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/MockLateralCache.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/discovery/MockLateralCache.java?rev=1.1
1.1
jakarta-turbine-jcs/src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/TestTCPLateral.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/test/org/apache/jcs/auxiliary/lateral/socket/tcp/TestTCPLateral.java?rev=1.1
1.6 +8 -1
jakarta-turbine-jcs/src/java/org/apache/jcs/engine/CacheElement.java
http://cvs.apache.org/viewcvs/jakarta-turbine-jcs/src/java/org/apache/jcs/engine/CacheElement.java.diff?r1=1.5&r2=1.6
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
