Show More
@@ -1,6 +1,6 b'' | |||||
1 | """AsyncResult objects for the client""" |
|
1 | """AsyncResult objects for the client""" | |
2 | #----------------------------------------------------------------------------- |
|
2 | #----------------------------------------------------------------------------- | |
3 | # Copyright (C) 2010 The IPython Development Team |
|
3 | # Copyright (C) 2010-2011 The IPython Development Team | |
4 | # |
|
4 | # | |
5 | # Distributed under the terms of the BSD License. The full license is in |
|
5 | # Distributed under the terms of the BSD License. The full license is in | |
6 | # the file COPYING, distributed as part of this software. |
|
6 | # the file COPYING, distributed as part of this software. |
@@ -1,4 +1,10 b'' | |||||
1 | """Dependency utilities""" |
|
1 | """Dependency utilities""" | |
|
2 | #----------------------------------------------------------------------------- | |||
|
3 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
4 | # | |||
|
5 | # Distributed under the terms of the BSD License. The full license is in | |||
|
6 | # the file COPYING, distributed as part of this software. | |||
|
7 | #----------------------------------------------------------------------------- | |||
2 |
|
8 | |||
3 | from IPython.external.decorator import decorator |
|
9 | from IPython.external.decorator import decorator | |
4 |
|
10 |
@@ -3,6 +3,13 b'' | |||||
3 | it handles registration, etc. and launches a kernel |
|
3 | it handles registration, etc. and launches a kernel | |
4 | connected to the Controller's Schedulers. |
|
4 | connected to the Controller's Schedulers. | |
5 | """ |
|
5 | """ | |
|
6 | #----------------------------------------------------------------------------- | |||
|
7 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
8 | # | |||
|
9 | # Distributed under the terms of the BSD License. The full license is in | |||
|
10 | # the file COPYING, distributed as part of this software. | |||
|
11 | #----------------------------------------------------------------------------- | |||
|
12 | ||||
6 | from __future__ import print_function |
|
13 | from __future__ import print_function | |
7 |
|
14 | |||
8 | import sys |
|
15 | import sys |
@@ -5,6 +5,12 b' launchers.' | |||||
5 | NOTE: Most of this module has been deprecated by moving to Configurables |
|
5 | NOTE: Most of this module has been deprecated by moving to Configurables | |
6 | ************ |
|
6 | ************ | |
7 | """ |
|
7 | """ | |
|
8 | #----------------------------------------------------------------------------- | |||
|
9 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
10 | # | |||
|
11 | # Distributed under the terms of the BSD License. The full license is in | |||
|
12 | # the file COPYING, distributed as part of this software. | |||
|
13 | #----------------------------------------------------------------------------- | |||
8 |
|
14 | |||
9 | # Standard library imports. |
|
15 | # Standard library imports. | |
10 | import atexit |
|
16 | import atexit |
@@ -3,6 +3,12 b'' | |||||
3 | A multi-heart Heartbeat system using PUB and XREP sockets. pings are sent out on the PUB, |
|
3 | A multi-heart Heartbeat system using PUB and XREP sockets. pings are sent out on the PUB, | |
4 | and hearts are tracked based on their XREQ identities. |
|
4 | and hearts are tracked based on their XREQ identities. | |
5 | """ |
|
5 | """ | |
|
6 | #----------------------------------------------------------------------------- | |||
|
7 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
8 | # | |||
|
9 | # Distributed under the terms of the BSD License. The full license is in | |||
|
10 | # the file COPYING, distributed as part of this software. | |||
|
11 | #----------------------------------------------------------------------------- | |||
6 |
|
12 | |||
7 | from __future__ import print_function |
|
13 | from __future__ import print_function | |
8 | import time |
|
14 | import time |
@@ -1,4 +1,11 b'' | |||||
1 | #!/usr/bin/env python |
|
1 | #!/usr/bin/env python | |
|
2 | """Old ipcluster script. Possibly to be removed.""" | |||
|
3 | #----------------------------------------------------------------------------- | |||
|
4 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
5 | # | |||
|
6 | # Distributed under the terms of the BSD License. The full license is in | |||
|
7 | # the file COPYING, distributed as part of this software. | |||
|
8 | #----------------------------------------------------------------------------- | |||
2 | from __future__ import print_function |
|
9 | from __future__ import print_function | |
3 |
|
10 | |||
4 | import os |
|
11 | import os |
@@ -1,4 +1,10 b'' | |||||
1 | """KernelStarter class that intercepts Control Queue messages, and handles process management.""" |
|
1 | """KernelStarter class that intercepts Control Queue messages, and handles process management.""" | |
|
2 | #----------------------------------------------------------------------------- | |||
|
3 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
4 | # | |||
|
5 | # Distributed under the terms of the BSD License. The full license is in | |||
|
6 | # the file COPYING, distributed as part of this software. | |||
|
7 | #----------------------------------------------------------------------------- | |||
2 |
|
8 | |||
3 | from zmq.eventloop import ioloop |
|
9 | from zmq.eventloop import ioloop | |
4 |
|
10 |
@@ -1,5 +1,11 b'' | |||||
1 | """RemoteNamespace object, for dict style interaction with a remote |
|
1 | """RemoteNamespace object, for dict style interaction with a remote | |
2 | execution kernel.""" |
|
2 | execution kernel.""" | |
|
3 | #----------------------------------------------------------------------------- | |||
|
4 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
5 | # | |||
|
6 | # Distributed under the terms of the BSD License. The full license is in | |||
|
7 | # the file COPYING, distributed as part of this software. | |||
|
8 | #----------------------------------------------------------------------------- | |||
3 |
|
9 | |||
4 | from functools import wraps |
|
10 | from functools import wraps | |
5 | from IPython.external.decorator import decorator |
|
11 | from IPython.external.decorator import decorator |
@@ -4,6 +4,12 b' The Pure ZMQ scheduler does not allow routing schemes other than LRU,' | |||||
4 | nor does it check msg_id DAG dependencies. For those, a slightly slower |
|
4 | nor does it check msg_id DAG dependencies. For those, a slightly slower | |
5 | Python Scheduler exists. |
|
5 | Python Scheduler exists. | |
6 | """ |
|
6 | """ | |
|
7 | #----------------------------------------------------------------------------- | |||
|
8 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
9 | # | |||
|
10 | # Distributed under the terms of the BSD License. The full license is in | |||
|
11 | # the file COPYING, distributed as part of this software. | |||
|
12 | #----------------------------------------------------------------------------- | |||
7 |
|
13 | |||
8 | #---------------------------------------------------------------------- |
|
14 | #---------------------------------------------------------------------- | |
9 | # Imports |
|
15 | # Imports |
@@ -2,6 +2,12 b'' | |||||
2 | """ |
|
2 | """ | |
3 | Kernel adapted from kernel.py to use ZMQ Streams |
|
3 | Kernel adapted from kernel.py to use ZMQ Streams | |
4 | """ |
|
4 | """ | |
|
5 | #----------------------------------------------------------------------------- | |||
|
6 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
7 | # | |||
|
8 | # Distributed under the terms of the BSD License. The full license is in | |||
|
9 | # the file COPYING, distributed as part of this software. | |||
|
10 | #----------------------------------------------------------------------------- | |||
5 |
|
11 | |||
6 | #----------------------------------------------------------------------------- |
|
12 | #----------------------------------------------------------------------------- | |
7 | # Imports |
|
13 | # Imports |
@@ -1,6 +1,12 b'' | |||||
1 | #!/usr/bin/env python |
|
1 | #!/usr/bin/env python | |
2 | """edited session.py to work with streams, and move msg_type to the header |
|
2 | """edited session.py to work with streams, and move msg_type to the header | |
3 | """ |
|
3 | """ | |
|
4 | #----------------------------------------------------------------------------- | |||
|
5 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
6 | # | |||
|
7 | # Distributed under the terms of the BSD License. The full license is in | |||
|
8 | # the file COPYING, distributed as part of this software. | |||
|
9 | #----------------------------------------------------------------------------- | |||
4 |
|
10 | |||
5 |
|
11 | |||
6 | import os |
|
12 | import os |
@@ -1,4 +1,10 b'' | |||||
1 | """Thread for popping Tasks from zmq to Python Queue""" |
|
1 | """Thread for popping Tasks from zmq to Python Queue""" | |
|
2 | #----------------------------------------------------------------------------- | |||
|
3 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
4 | # | |||
|
5 | # Distributed under the terms of the BSD License. The full license is in | |||
|
6 | # the file COPYING, distributed as part of this software. | |||
|
7 | #----------------------------------------------------------------------------- | |||
2 |
|
8 | |||
3 |
|
9 | |||
4 | import time |
|
10 | import time |
@@ -1,4 +1,15 b'' | |||||
1 | """some generic utilities for dealing with classes, urls, and serialization""" |
|
1 | """some generic utilities for dealing with classes, urls, and serialization""" | |
|
2 | #----------------------------------------------------------------------------- | |||
|
3 | # Copyright (C) 2010-2011 The IPython Development Team | |||
|
4 | # | |||
|
5 | # Distributed under the terms of the BSD License. The full license is in | |||
|
6 | # the file COPYING, distributed as part of this software. | |||
|
7 | #----------------------------------------------------------------------------- | |||
|
8 | ||||
|
9 | #----------------------------------------------------------------------------- | |||
|
10 | # Imports | |||
|
11 | #----------------------------------------------------------------------------- | |||
|
12 | ||||
2 | import re |
|
13 | import re | |
3 | import socket |
|
14 | import socket | |
4 |
|
15 | |||
@@ -15,6 +26,10 b' from IPython.utils.newserialized import serialize, unserialize' | |||||
15 |
|
26 | |||
16 | ISO8601="%Y-%m-%dT%H:%M:%S.%f" |
|
27 | ISO8601="%Y-%m-%dT%H:%M:%S.%f" | |
17 |
|
28 | |||
|
29 | #----------------------------------------------------------------------------- | |||
|
30 | # Classes | |||
|
31 | #----------------------------------------------------------------------------- | |||
|
32 | ||||
18 | class Namespace(dict): |
|
33 | class Namespace(dict): | |
19 | """Subclass of dict for attribute access to keys.""" |
|
34 | """Subclass of dict for attribute access to keys.""" | |
20 |
|
35 | |||
@@ -64,6 +79,10 b' class ReverseDict(dict):' | |||||
64 | except KeyError: |
|
79 | except KeyError: | |
65 | return default |
|
80 | return default | |
66 |
|
81 | |||
|
82 | #----------------------------------------------------------------------------- | |||
|
83 | # Functions | |||
|
84 | #----------------------------------------------------------------------------- | |||
|
85 | ||||
67 | def validate_url(url): |
|
86 | def validate_url(url): | |
68 | """validate a url for zeromq""" |
|
87 | """validate a url for zeromq""" | |
69 | if not isinstance(url, basestring): |
|
88 | if not isinstance(url, basestring): |
General Comments 0
You need to be logged in to leave comments.
Login now