Please enable JavaScript to use RhodeCode Enterprise
##// END OF EJS Templates
MinRK
- Fri, 08 Apr 2011 00:38:25
Show More
IPython/zmq/parallel/asyncresult.py
0
+1
-1
@@
-1,6
+1,6
1
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
5
# Distributed under the terms of the BSD License. The full license is in
6
6
# the file COPYING, distributed as part of this software.
IPython/zmq/parallel/dependency.py
0
+6
0
@@
-1,4
+1,10
1
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
9
from IPython.external.decorator import decorator
4
10
IPython/zmq/parallel/engine.py
0
+7
0
@@
-3,6
+3,13
3
3
it handles registration, etc. and launches a kernel
4
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
13
from __future__ import print_function
7
14
8
15
import sys
IPython/zmq/parallel/entry_point.py
0
+6
0
@@
-5,6
+5,12
launchers.
5
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
15
# Standard library imports.
10
16
import atexit
IPython/zmq/parallel/heartmonitor.py
0
+6
0
@@
-3,6
+3,12
3
3
A multi-heart Heartbeat system using PUB and XREP sockets. pings are sent out on the PUB,
4
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
13
from __future__ import print_function
8
14
import time
IPython/zmq/parallel/ipcluster.py
0
+7
0
@@
-1,4
+1,11
1
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
9
from __future__ import print_function
3
10
4
11
import os
IPython/zmq/parallel/kernelstarter.py
0
+6
0
@@
-1,4
+1,10
1
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
9
from zmq.eventloop import ioloop
4
10
IPython/zmq/parallel/remotenamespace.py
0
+6
0
@@
-1,5
+1,11
1
1
"""RemoteNamespace object, for dict style interaction with a remote
2
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
10
from functools import wraps
5
11
from IPython.external.decorator import decorator
IPython/zmq/parallel/scheduler.py
0
+6
0
@@
-4,6
+4,12
The Pure ZMQ scheduler does not allow routing schemes other than LRU,
4
4
nor does it check msg_id DAG dependencies. For those, a slightly slower
5
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
15
# Imports
IPython/zmq/parallel/streamkernel.py
0
+6
0
@@
-2,6
+2,12
2
2
"""
3
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
13
# Imports
IPython/zmq/parallel/streamsession.py
0
+6
0
@@
-1,6
+1,12
1
1
#!/usr/bin/env python
2
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
12
import os
IPython/zmq/parallel/taskthread.py
0
+6
0
@@
-1,4
+1,10
1
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
10
import time
IPython/zmq/parallel/util.py
0
+19
0
@@
-1,4
+1,15
1
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
13
import re
3
14
import socket
4
15
@@
-15,6
+26,10
from IPython.utils.newserialized import serialize, unserialize
15
26
16
27
ISO8601 = "%Y-%m- %d T%H:%M:%S. %f "
17
28
29
#-----------------------------------------------------------------------------
30
# Classes
31
#-----------------------------------------------------------------------------
32
18
33
class Namespace ( dict ):
19
34
"""Subclass of dict for attribute access to keys."""
20
35
@@
-64,6
+79,10
class ReverseDict(dict):
64
79
except KeyError :
65
80
return default
66
81
82
#-----------------------------------------------------------------------------
83
# Functions
84
#-----------------------------------------------------------------------------
85
67
86
def validate_url ( url ):
68
87
"""validate a url for zeromq"""
69
88
if not isinstance ( url , basestring ):
Site-wide shortcuts
/
Use quick search box
g h
Goto home page
g g
Goto my private gists page
g G
Goto my public gists page
g 0-9
Goto bookmarked items from 0-9
n r
New repository page
n g
New gist page
Repositories
g s
Goto summary page
g c
Goto changelog page
g f
Goto files page
g F
Goto files page with file search activated
g p
Goto pull requests page
g o
Goto repository settings
g O
Goto repository access permissions settings
t s
Toggle sidebar on some pages