asmuts 02/02/23 22:16:16
Modified: src/java/org/apache/stratum/jcs/auxiliary/lateral
LateralCacheManager.java LateralCacheFactory.java
LateralCacheAttributes.java
src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior
ILateralCacheAttributes.java
Log:
JavaGroups canges, need to refactor with specialized props files
an interesting distribution system
some code problems, like hidden system outs
need the javagroups2.0.jar
Revision Changes Path
1.8 +15 -0
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/LateralCacheManager.java
Index: LateralCacheManager.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/LateralCacheManager.java,v
retrieving revision 1.7
retrieving revision 1.8
diff -u -r1.7 -r1.8
--- LateralCacheManager.java 20 Feb 2002 05:31:03 -0000 1.7
+++ LateralCacheManager.java 24 Feb 2002 06:16:16 -0000 1.8
@@ -31,6 +31,10 @@
import
org.apache.stratum.jcs.auxiliary.lateral.xmlrpc.LateralGroupCacheXMLRPCListener;
import org.apache.stratum.jcs.auxiliary.lateral.xmlrpc.LateralXMLRPCService;
+import
org.apache.stratum.jcs.auxiliary.lateral.javagroups.LateralGroupCacheJGListener;
+import org.apache.stratum.jcs.auxiliary.lateral.javagroups.LateralJGService;
+
+
import org.apache.stratum.jcs.engine.CacheWatchRepairable;
import org.apache.stratum.jcs.engine.behavior.ICache;
@@ -171,6 +175,12 @@
this.lateralService = new LateralXMLRPCService( lca );
}
+ else if ( lca.getTransmissionType() == lca.JAVAGROUPS )
+ {
+ log.debug( "Creating JAVAGROUPS service" );
+
+ this.lateralService = new LateralJGService( lca );
+ }
else
{
log.error( "Type not recognized, must zombie" );
@@ -263,6 +273,11 @@
if ( lca.getTransmissionType() == lca.XMLRPC )
{
addLateralCacheListener( cacheName,
LateralGroupCacheXMLRPCListener.getInstance( lca ) );
+ }
+ else
+ if ( lca.getTransmissionType() == lca.JAVAGROUPS )
+ {
+ addLateralCacheListener( cacheName,
LateralGroupCacheJGListener.getInstance( lca ) );
}
}
catch ( IOException ioe )
1.7 +9 -0
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/LateralCacheFactory.java
Index: LateralCacheFactory.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/LateralCacheFactory.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- LateralCacheFactory.java 20 Feb 2002 05:31:03 -0000 1.6
+++ LateralCacheFactory.java 24 Feb 2002 06:16:16 -0000 1.7
@@ -52,6 +52,15 @@
{
noWaits.add( ic );
}
+ } else
+ if ( lac.getTransmissionType() == lac.JAVAGROUPS )
+ {
+ LateralCacheManager lcm = LateralCacheManager.getInstance( lac );
+ ICache ic = lcm.getCache( lac.getCacheName() );
+ if ( ic != null )
+ {
+ noWaits.add( ic );
+ }
}
else
if ( lac.getTransmissionType() == lac.TCP )
1.7 +10 -0
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/LateralCacheAttributes.java
Index: LateralCacheAttributes.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/LateralCacheAttributes.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- LateralCacheAttributes.java 20 Feb 2002 05:31:03 -0000 1.6
+++ LateralCacheAttributes.java 24 Feb 2002 06:16:16 -0000 1.7
@@ -255,6 +255,11 @@
{
transmissionTypeName = "XMLRPC";
}
+ else
+ if ( val == JAVAGROUPS )
+ {
+ transmissionTypeName = "JAVAGROUPS";
+ }
}
@@ -296,6 +301,11 @@
if ( val.equals( "XMLRPC" ) )
{
transmissionType = XMLRPC;
+ }
+ else
+ if ( val.equals( "JAVAGROUPS" ) )
+ {
+ transmissionType = JAVAGROUPS;
}
}
1.7 +1 -0
jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior/ILateralCacheAttributes.java
Index: ILateralCacheAttributes.java
===================================================================
RCS file:
/home/cvs/jakarta-turbine-stratum/src/java/org/apache/stratum/jcs/auxiliary/lateral/behavior/ILateralCacheAttributes.java,v
retrieving revision 1.6
retrieving revision 1.7
diff -u -r1.6 -r1.7
--- ILateralCacheAttributes.java 20 Feb 2002 05:31:03 -0000 1.6
+++ ILateralCacheAttributes.java 24 Feb 2002 06:16:16 -0000 1.7
@@ -17,6 +17,7 @@
final static int UDP = 2;
final static int TCP = 3;
final static int XMLRPC = 4;
+ final static int JAVAGROUPS = 5;
/**
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
