isnLib.net.queryManager.queryRoot

Package isnLib :: Package net :: Module queryManager :: Class queryRoot

[show private | hide private]

Class queryRoot

Jellyable --+        
            |        
 Serializable --+    
                |    
    Referenceable --+
                    |
                   queryRoot

Known Subclasses:: queryRootSig

query object

this is passed by peers when info about an ongoing query is needed. An instance of this class should hold info for the state machine needed by the query forwarding mechanism

Method Summary
	`__init__(self, cbs, pq)` Return count of new files found and sucessfully added to db
	`done(self)`
	`persist(self, data, dataDescr)`
	`remote_takeResultSet(self, reslist, remoteClient)` to be implemented by subclasses
	`summon(self, data)`
Inherited from Referenceable
	`jellyFor(self, jellier)` (internal)
	`remoteMessageReceived(self, broker, message, args, kw)` A remote message has been received.
Inherited from Serializable
	`processUniqueID(self)` Return an ID which uniquely represents this object for this process.
Inherited from Jellyable
	`getStateFor(self, jellier)`

Class Variable Summary
`list`	`queryData` = `['cpath', 'numres']`
`int`	`timeout` = 120
Inherited from Referenceable
`NoneType`	`perspective` = None
Inherited from Jellyable
`tuple`	`__implements__` = `(<class 'twisted.spread.interfaces.IJel...`

Method Details

init(self, cbs=None, pq=None)
(Constructor)

Parameters:: cbs - list of functions that will get called when this query is done. The parameter to this call will be self; pq - a reference to the queryRoot that originated this query. None on the master query obj.

Returns:: count of new files found and sucessfully added to db

remote_takeResultSet(self, reslist, remoteClient)

to be implemented by subclasses

Class Variable Details

queryData

Type:: list
Value:: ['cpath', 'numres']

timeout

Type:: int
Value:: 120

Generated by Epydoc 2.0 on Thu Dec 25 10:59:56 2003

http://epydoc.sf.net

Class queryRoot

__init__(self, cbs=None, pq=None) (Constructor)

remote_takeResultSet(self, reslist, remoteClient)

queryData

timeout

init(self, cbs=None, pq=None)
(Constructor)