

def peerCheckRequest(self, data=None):
    LOGGER.debug('Signaling peers.')
    deferreds = []
    for uuid in self.peers:
        if ((uuid != self.uuid) and self.peers[uuid]['active']):
            LOGGER.debug(('Signaling %s to check peers.' % self.peers[uuid]['uri']))
            d = self.rq.getPage((self.peers[uuid]['uri'] + '/coordinate'), prioritize=True)
            d.addCallback(self._peerCheckRequestCallback, self.peers[uuid]['uri'])
            d.addErrback(self._peerCheckRequestErrback, self.peers[uuid]['uri'])
            deferreds.append(d)
    if (len(deferreds) > 0):
        LOGGER.debug('Combinining shutdown signal deferreds.')
        return DeferredList(deferreds, consumeErrors=True)
    return True

dataset/ETHPy150Open wehriam/awspider/awspider/servers/execution.py ExecutionServer.peerCheckRequest/original