environment/lib/python2.7/site-packages/IPython/parallel/controller/heartmonitor.py
def handle_pong(self, msg):
        "a heart just beat"
        current = str_to_bytes(str(self.lifetime))
        last = str_to_bytes(str(self.last_ping))
        if msg[1] == current:
            delta = time.time()-self.tic
            # self.log.debug("heartbeat::heart %r took %.2f ms to respond"%(msg[0], 1000*delta))
            self.responses.add(msg[0])
        elif msg[1] == last:
            delta = time.time()-self.tic + (self.lifetime-self.last_ping)
            self.log.warn("heartbeat::heart %r missed a beat, and took %.2f ms to respond", msg[0], 1000*delta)
            self.responses.add(msg[0])
        else:
            self.log.warn("heartbeat::got bad heartbeat (possibly old?): %s (current=%.3f)", msg[1], self.lifetime)
def handle_pong(self, msg):
        "a heart just beat"
        current = str_to_bytes(str(self.lifetime))
        last = str_to_bytes(str(self.last_ping))
        if msg[1] == current:
            delta = time.time()-self.tic
            # self.log.debug("heartbeat::heart %r took %.2f ms to respond"%(msg[0], 1000*delta))
            self.responses.add(msg[0])
        elif msg[1] == last:
            delta = time.time()-self.tic + (self.lifetime-self.last_ping)
            self.log.warn("heartbeat::heart %r missed a beat, and took %.2f ms to respond", msg[0], 1000*delta)
            self.responses.add(msg[0])
        else:
            self.log.warn("heartbeat::got bad heartbeat (possibly old?): %s (current=%.3f)", msg[1], self.lifetime)
def handle_pong ( self , msg ) : current = str_to_bytes ( str ( self . lifetime ) ) last = str_to_bytes ( str ( self . last_ping ) ) if msg [ 1 ] == current : delta = time . time ( ) - self . tic # self.log.debug("heartbeat::heart %r took %.2f ms to respond"%(msg[0], 1000*delta)) self . responses . add ( msg [ 0 ] ) elif msg [ 1 ] == last : delta = time . time ( ) - self . tic + ( self . lifetime - self . last_ping ) self . log . warn ( "heartbeat::heart %r missed a beat, and took %.2f ms to respond" , msg [ 0 ] , 1000 * delta ) self . responses . add ( msg [ 0 ] ) else : self . log . warn ( "heartbeat::got bad heartbeat (possibly old?): %s (current=%.3f)" , msg [ 1 ] , self . lifetime )
a heart just beat
a heart just beat