Author: fhanik
Date: Wed Mar 15 11:17:58 2006
New Revision: 386141
URL: http://svn.apache.org/viewcvs?rev=386141&view=rev
Log:
Updated todo list and demo code
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/ChannelCreator.java
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/MapDemo.java
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/test/TestNioSender.java
tomcat/container/tc5.5.x/modules/groupcom/to-do.txt
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/ChannelCreator.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/ChannelCreator.java?rev=386141&r1=386140&r2=386141&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/ChannelCreator.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/ChannelCreator.java
Wed Mar 15 11:17:58 2006
@@ -29,6 +29,7 @@
import org.apache.catalina.tribes.tcp.ReceiverBase;
import org.apache.catalina.tribes.tcp.ReplicationTransmitter;
import org.apache.tomcat.util.IntrospectionUtils;
+import org.apache.catalina.tribes.tcp.*;
/**
* <p>Title: </p>
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/MapDemo.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/MapDemo.java?rev=386141&r1=386140&r2=386141&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/MapDemo.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/demos/MapDemo.java
Wed Mar 15 11:17:58 2006
@@ -25,6 +25,7 @@
import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.MembershipListener;
import org.apache.catalina.tribes.tipis.LazyReplicatedMap;
+import org.apache.catalina.tribes.tcp.*;
/**
* <p>Title: </p>
Modified:
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/test/TestNioSender.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/test/TestNioSender.java?rev=386141&r1=386140&r2=386141&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/test/TestNioSender.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/test/org/apache/catalina/tribes/test/TestNioSender.java
Wed Mar 15 11:17:58 2006
@@ -5,7 +5,7 @@
import java.util.Iterator;
import java.nio.channels.Selector;
import org.apache.catalina.tribes.tcp.nio.NioSender;
-import org.apache.catalina.tribes.mcast.McastMember;
+import org.apache.catalina.tribes.mcast.MemberImpl;
import org.apache.catalina.tribes.io.ClusterData;
import org.apache.catalina.tribes.io.XByteBuffer;
import org.apache.catalina.tribes.Member;
@@ -25,7 +25,7 @@
public class TestNioSender {
private Selector selector = null;
private int counter = 0;
- McastMember mbr;
+ MemberImpl mbr;
public TestNioSender() {
}
@@ -44,7 +44,7 @@
public void init() throws Exception {
selector = Selector.open();
- mbr = new McastMember("","localhost",4444,0);
+ mbr = new MemberImpl("","localhost",4444,0);
NioSender sender = new NioSender(mbr);
sender.setWaitForAck(false);
sender.setDirect(true);
Modified: tomcat/container/tc5.5.x/modules/groupcom/to-do.txt
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/to-do.txt?rev=386141&r1=386140&r2=386141&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/to-do.txt (original)
+++ tomcat/container/tc5.5.x/modules/groupcom/to-do.txt Wed Mar 15 11:17:58 2006
@@ -8,6 +8,7 @@
Code Tasks:
===========================================
+18. Implement SSL encryption over message transfers
8. WaitForCompletionInterceptor - waits for the message to get processed by
all receivers before returning
(This is useful when synchronized=false and waitForAck=false, to improve
@@ -27,19 +28,6 @@
11. Code a ReplicatedFileSystem example, package org.apache.catalina.tipis
-12. LazyReplicatedHashMap - memory efficient clustered map.
- This map can be used for PRIMARY/SECONDARY session replication
- Ahh, the beauty of storing data in remote locations
- The lazy hash map will only replicate its attribute names to all members
in the group
- with that name, it will also replicate the source (where to get the object)
- and the backup member where it can find a backup if the source is gone.
- If the source disappears, the backup node will replicate attributes that
- are stored to a new primary backups can be chosen on round robin.
- When a new member arrives and requests state, that member will get all the
attribute
- names and the locations.
- It can replicate every X seconds, or on dirty flags by the objects stored,
- or a request to scan for dirty flags, or a request with the objects.
-
13. StateTransfer interceptor
the ideas just come up in my head. the state transfer interceptor
will hold all incoming messages until it has received a message
@@ -52,11 +40,9 @@
14. Keepalive count and idle kill off for Nio senders
-15. remove DataSenderFactory and DataSender.properties -
- these cause the settings to be hard coded ant not pluggable.
-
16. Guaranteed delivery of messages, ie either all get it or none get it.
Meaning, that all receivers get it, then wait for a process command.
+ ala Gossip protocol
17. Implement transactions - the ability to start a transaction, send several
messages,
and then commit the transaction
@@ -93,3 +79,21 @@
7. FragmentationInterceptor - splits up messages that are larger than X bytes.
Notes: complated
+
+15. remove DataSenderFactory and DataSender.properties -
+ these cause the settings to be hard coded ant not pluggable.
+Notes: Completed, now you can initialize a transport class
+
+12. LazyReplicatedHashMap - memory efficient clustered map.
+ This map can be used for PRIMARY/SECONDARY session replication
+ Ahh, the beauty of storing data in remote locations
+ The lazy hash map will only replicate its attribute names to all members
in the group
+ with that name, it will also replicate the source (where to get the object)
+ and the backup member where it can find a backup if the source is gone.
+ If the source disappears, the backup node will replicate attributes that
+ are stored to a new primary backups can be chosen on round robin.
+ When a new member arrives and requests state, that member will get all the
attribute
+ names and the locations.
+ It can replicate every X seconds, or on dirty flags by the objects stored,
+ or a request to scan for dirty flags, or a request with the objects.
+Notes: the map has been completed
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
