##// END OF EJS Templates
Lots of work on the display system, focused on pylab stuff....
Lots of work on the display system, focused on pylab stuff. * Moved the pprint attribute to PlainTextFormatter. * Added DisplayFormatter.plain_text_only for disabling all but the plain text formatting. This is now used by doctest_mode. * Remove result_display hook. * Fixed doctest_mode magic. * Refactored inline matplotlib backend to use new display system. * Added display formatter for matplotlib.figure.Figure objects. so the display system will show the svg for them. * Added display and display_png to the user's namespace in pylab. * Cleaned up pylabtools.py

File last commit:

r3144:cd371626
r3280:1bba7395
Show More
heartbeat.py
45 lines | 1.4 KiB | text/x-python | PythonLexer
"""The client and server for a basic ping-pong style heartbeat.
"""
#-----------------------------------------------------------------------------
# Copyright (C) 2008-2010 The IPython Development Team
#
# Distributed under the terms of the BSD License. The full license is in
# the file COPYING, distributed as part of this software.
#-----------------------------------------------------------------------------
#-----------------------------------------------------------------------------
# Imports
#-----------------------------------------------------------------------------
import sys
from threading import Thread
import zmq
from IPython.utils.localinterfaces import LOCALHOST
#-----------------------------------------------------------------------------
# Code
#-----------------------------------------------------------------------------
class Heartbeat(Thread):
"A simple ping-pong style heartbeat that runs in a thread."
def __init__(self, context, addr=(LOCALHOST, 0)):
Thread.__init__(self)
self.context = context
self.addr = addr
self.ip = addr[0]
self.port = addr[1]
self.daemon = True
def run(self):
self.socket = self.context.socket(zmq.REP)
if self.port == 0:
self.port = self.socket.bind_to_random_port('tcp://%s' % self.ip)
else:
self.socket.bind('tcp://%s:%i' % self.addr)
zmq.device(zmq.FORWARDER, self.socket, self.socket)