Changeset 113

Show
Ignore:
Timestamp:
11/26/07 16:31:30 (1 year ago)
Author:
edsuom
Message:

Dealing with disconnects is now AsynQueue?'s job

Files:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved

  • projects/AsynCluster/trunk/asyncluster/master/control.py

    r111 r113  
    213213        A node client has disconnected, so detach its root referenceable from 
    214214        my map of node roots. 
     215 
     216        AsynQueue's job manager takes care of detaching the node's worker from 
     217        the queue, so we don't get involved with that. 
    215218        """ 
    216219        self.nodes.pop(ID, None) 
    217         d = self.jobber.detachChild(ID) 
    218220        if hasattr(self, 'sessionManager'): 
    219             d.addCallback( 
    220                 lambda _: self.sessionManager.end(ID, callClient=False)) 
    221         return d 
     221            return self.sessionManager.end(ID, callClient=False) 
    222222 
    223223    def _remoteError(self, failure, ID):