Show More
@@ -11,7 +11,9 b' import sys' | |||
|
11 | 11 | import zmq |
|
12 | 12 | |
|
13 | 13 | # Local imports. |
|
14 | from IPython.core.ultratb import FormattedTB | |
|
14 | 15 | from IPython.external.argparse import ArgumentParser |
|
16 | from IPython.utils import io | |
|
15 | 17 | from exitpoller import ExitPollerUnix, ExitPollerWindows |
|
16 | 18 | from displayhook import DisplayHook |
|
17 | 19 | from iostream import OutStream |
@@ -60,22 +62,25 b' def make_kernel(namespace, kernel_factory,' | |||
|
60 | 62 | out_stream_factory=None, display_hook_factory=None): |
|
61 | 63 | """ Creates a kernel. |
|
62 | 64 | """ |
|
65 | # Install minimal exception handling | |
|
66 | sys.excepthook = FormattedTB(mode='Verbose', ostream=sys.__stdout__) | |
|
67 | ||
|
63 | 68 | # Create a context, a session, and the kernel sockets. |
|
64 |
|
|
|
69 | io.rprint("Starting the kernel...") | |
|
65 | 70 | context = zmq.Context() |
|
66 | 71 | session = Session(username=u'kernel') |
|
67 | 72 | |
|
68 | 73 | reply_socket = context.socket(zmq.XREP) |
|
69 | 74 | xrep_port = bind_port(reply_socket, namespace.ip, namespace.xrep) |
|
70 |
|
|
|
75 | io.rprint("XREP Channel on port", xrep_port) | |
|
71 | 76 | |
|
72 | 77 | pub_socket = context.socket(zmq.PUB) |
|
73 | 78 | pub_port = bind_port(pub_socket, namespace.ip, namespace.pub) |
|
74 |
|
|
|
79 | io.rprint("PUB Channel on port", pub_port) | |
|
75 | 80 | |
|
76 | 81 | req_socket = context.socket(zmq.XREQ) |
|
77 | 82 | req_port = bind_port(req_socket, namespace.ip, namespace.req) |
|
78 |
|
|
|
83 | io.rprint("REQ Channel on port", req_port) | |
|
79 | 84 | |
|
80 | 85 | # Redirect input streams and set a display hook. |
|
81 | 86 | if out_stream_factory: |
General Comments 0
You need to be logged in to leave comments.
Login now