[Gzz-commits] storm/doc/pegboard/storm_with_tapestry--hemppah...

[Hermanni Hyytiälä]

CVSROOT:        /cvsroot/storm
Module name:    storm
Branch:         
Changes by:     Hermanni Hyytiälä <address@hidden>      03/07/07 06:29:15

Modified files:
        doc/pegboard/storm_with_tapestry--hemppah: peg.rst 

Log message:
        real events and messages

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst.diff?tr1=1.8&tr2=1.9&r1=text&r2=text

Patches:
Index: storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst
diff -u storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst:1.8 
storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst:1.9
--- storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst:1.8 Mon Jul  7 
06:20:18 2003
+++ storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst     Mon Jul  7 
06:29:15 2003
@@ -5,8 +5,8 @@
 
 :Authors:  Hermanni Hyytiälä
 :Date-Created: 2003-07-03
-:Last-Modified: $Date: 2003/07/07 10:20:18 $
-:Revision: $Revision: 1.8 $
+:Last-Modified: $Date: 2003/07/07 10:29:15 $
+:Revision: $Revision: 1.9 $
 :Status:   Incomplete
 
 .. :Stakeholders:
@@ -225,8 +225,9 @@
                 // the *events* which we want to listen
 
                 array event_types = {
-                "seda.sandStorm.api.StormFooSignal1",
-                "seda.sandStorm.api.StormFooSignal2"            
+                "seda.sandStorm.api.StagesInitializedSignal",
+                "ostore.tapestry.impl.TapestryReadyMsg",
+                "ostore.tapestry.api.TapestryDetachConfirm"     
                }
                
                for (From i = 0 To numberOf(event_types)) {
@@ -236,11 +237,11 @@
                // the *messages* we want receive through Tapestry
 
                array message_types = {
-               "ostore.tapestry.interweave.StormErrorMsg",
-               "ostore.tapestry.interweave.StormLocateMsg",
-               "ostore.tapestry.interweave.StormResponseMsg",
-               "ostore.tapestry.interweave.StormBlockMsg",
-               "ostore.tapestry.interweave.StormBlockRequestMsg",
+               "org.nongnu.storm.p2p.tapestry.StormErrorMsg",
+               "org.nongnu.storm.p2p.tapestry.StormLocateMsg",
+               "org.nongnu.storm.p2p.tapestry.StormResponseMsg",
+               "org.nongnu.storm.p2p.tapestry.StormBlockMsg",
+               "org.nongnu.storm.p2p.tapestry.StormBlockRequestMsg",
                "ostore.tapestry.api.TapestryLocateFailure"
                }
                
@@ -257,7 +258,8 @@
 
                   classifier.subscribe (message_type[i], verifyInbound);
                }
- 
+               
+                
                }
                
                // handles *all* events which stage is listening
@@ -277,10 +279,10 @@
            
                } else if (item instanceof TapestryReadyMsg) {
                        // connected        
-           
+                       publishLocalStormPool()
                } else if (item instanceof TapestryDetachConfirm) {
                        // disconnected
-                       
+                       unpublishLocalStormPool()
                } else if (item instanceof TapestryLocateFailure) {
                        // Search failed