[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 04:21:44

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

Log message:
        more pseudo code

CVSWeb URLs:
http://savannah.gnu.org/cgi-bin/viewcvs/storm/storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst.diff?tr1=1.6&tr2=1.7&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.6 
storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst:1.7
--- storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst:1.6 Mon Jul  7 
03:54:39 2003
+++ storm/doc/pegboard/storm_with_tapestry--hemppah/peg.rst     Mon Jul  7 
04:21:44 2003
@@ -5,8 +5,8 @@
 
 :Authors:  Hermanni Hyytiälä
 :Date-Created: 2003-07-03
-:Last-Modified: $Date: 2003/07/07 07:54:39 $
-:Revision: $Revision: 1.6 $
+:Last-Modified: $Date: 2003/07/07 08:21:44 $
+:Revision: $Revision: 1.7 $
 :Status:   Incomplete
 
 .. :Stakeholders:
@@ -154,10 +154,11 @@
 
    - BlockIDTag class for Storm blocks' IDs (implements 
      ostore.tapestry.api.TapestryTag) for storing query specific information:
-     in our case, we store block's GUID
+     in our case, we store at least block's GUID and other related info 
+     (if needed)
 
    - BlockIDQuery (implements ostore.tapestry.api.TapestryQuery) to receive an 
-     object identified by a BlockIDTag dispatch a 
+     object identified by a BlockIDTag, dispatch a 
      ostore.tapestry.api.TapestryLocateMsg that contains a BlockIDQuery  
      
    - StormQueryMsg class (extends ostore.tapestry.api.TapestryLocateMsg, 
@@ -165,11 +166,19 @@
      identified by a BlockIDTag in a Tapestry overlay
    
    - StormResponseMsg class (extends ostore.tapestry.api.TapestryRouteMsg,
-     implements ostore.util.QuickSerializable)) to carry meta data for a 
-     requested Storm block
+     implements ostore.util.QuickSerializable) to carry meta data for a 
+     requested Storm block. This is an optional class, i.e., if we want
+     to see query results, we may use this
+     
+   - StormBlockRequestMsg (extends ostore.tapestry.api.TapestryRouteMsg,
+     implements ostore.util.QuickSerializable) to request a specific Storm
+     block
+   
+   - StormErrorMsg (extends ostore.tapestry.api.TapestryRouteMsg,
+     implements ostore.util.QuickSerializable) for sending error messages
    
    - StormBlockMsg class (extends ostore.tapestry.api.TapestryRouteMsg,
-     implements ostore.util.QuickSerializable)to carry a requested Storm
+     implements ostore.util.QuickSerializable) to carry a requested Storm
      block being sent to a original requester
    
 - For interacting Storm's storage model with Tapestry:
@@ -177,6 +186,7 @@
    - StormTapestryManager class which
      - registers Storm to handle Storm-related Tapestry events and messages
      - handles and dispatches Storm-related Tapestry events and messages
+     - interacts with a local Storm pool
      
      
  PSEUDOCODE for Storm
@@ -264,7 +274,8 @@
                        } else if (item instanceof StormResponseMsg) {
                                handleStormResponseMsg(item)
                        } else {
-                               handleOtherMsg(item)            
+                               handleOtherMsg(item)
+                               ...
                        }
                                
                }
@@ -281,7 +292,7 @@
                        dispatch(response)              
                }
                
-               // createa a Storm query to a network
+               // create a Storm query to a Tapestry network
                // Query tag is Storm block's GUID
                method query(){
                        blockTag = new BlockIDTag(blockGUID)
@@ -289,7 +300,30 @@
                        queryMsg=  new StormQueryMsg(blockTag, q)
                        dispatch(queryMsg)
                }
-    }
+               
+               // dispatch TapestryPublishMsg for all blocks in the 
+               // local Storm pool
+               method publishLocalStormPool(){         
+                       for each block in localPool
+                               block = localPool.getBlock()
+                               tag = new BlockIDTag(block.getGUID())           
                
+                               publishMsg = new 
+                               TapestryPublishMsg(block.getGUID(), tag)
+                               dispatch(publishMsg)            
+               }
+               
+               // dispatch TapestryUnpublishMsg for all blocks in the 
+               // local Storm pool
+               method unpublishLocalStormPool(){               
+                       for each block in localPool
+                               block = localPool.getBlock()
+                               tag = new BlockIDTag(block.getGUID())           
                
+                               unpublishMsg = new 
+                               TapestryUnpublishMsg(block.getGUID(), tag)
+                               dispatch(unpublishMsg)
+               }
+               
+       }
     
 .. more to come