##// END OF EJS Templates
Remove unused copies of validate_string_dict
Thomas Kluyver -
Show More
@@ -11,21 +11,6 b' try:'
11 except ImportError:
11 except ImportError:
12 from Queue import Queue, Empty # Py 2
12 from Queue import Queue, Empty # Py 2
13
13
14 from IPython.utils.py3compat import string_types, iteritems
15
16 # some utilities to validate message structure, these might get moved elsewhere
17 # if they prove to have more generic utility
18
19 def validate_string_dict(dct):
20 """Validate that the input is a dict with string keys and values.
21
22 Raises ValueError if not."""
23 for k,v in iteritems(dct):
24 if not isinstance(k, string_types):
25 raise ValueError('key %r in dict must be a string' % k)
26 if not isinstance(v, string_types):
27 raise ValueError('value %r in dict must be a string' % v)
28
29
14
30 class ZMQSocketChannel(object):
15 class ZMQSocketChannel(object):
31 """A ZMQ socket in a simple blocking API"""
16 """A ZMQ socket in a simple blocking API"""
@@ -14,12 +14,10 b' import zmq'
14 # import ZMQError in top-level namespace, to avoid ugly attribute-error messages
14 # import ZMQError in top-level namespace, to avoid ugly attribute-error messages
15 # during garbage collection of threads at exit:
15 # during garbage collection of threads at exit:
16 from zmq import ZMQError
16 from zmq import ZMQError
17 from zmq.eventloop import ioloop, zmqstream
18
17
19 from IPython.core.release import kernel_protocol_version_info
18 from IPython.core.release import kernel_protocol_version_info
20
19
21 from .channelsabc import HBChannelABC
20 from .channelsabc import HBChannelABC
22 from IPython.utils.py3compat import string_types, iteritems
23
21
24 #-----------------------------------------------------------------------------
22 #-----------------------------------------------------------------------------
25 # Constants and exceptions
23 # Constants and exceptions
@@ -30,23 +28,6 b' major_protocol_version = kernel_protocol_version_info[0]'
30 class InvalidPortNumber(Exception):
28 class InvalidPortNumber(Exception):
31 pass
29 pass
32
30
33 #-----------------------------------------------------------------------------
34 # Utility functions
35 #-----------------------------------------------------------------------------
36
37 # some utilities to validate message structure, these might get moved elsewhere
38 # if they prove to have more generic utility
39
40 def validate_string_dict(dct):
41 """Validate that the input is a dict with string keys and values.
42
43 Raises ValueError if not."""
44 for k,v in iteritems(dct):
45 if not isinstance(k, string_types):
46 raise ValueError('key %r in dict must be a string' % k)
47 if not isinstance(v, string_types):
48 raise ValueError('value %r in dict must be a string' % v)
49
50
31
51 def make_shell_socket(context, identity, address):
32 def make_shell_socket(context, identity, address):
52 socket = context.socket(zmq.DEALER)
33 socket = context.socket(zmq.DEALER)
@@ -4,8 +4,8 b''
4 # Distributed under the terms of the Modified BSD License.
4 # Distributed under the terms of the Modified BSD License.
5
5
6 from __future__ import absolute_import
6 from __future__ import absolute_import
7 from IPython.kernel.channels import validate_string_dict, major_protocol_version
7 from IPython.kernel.channels import major_protocol_version
8 from IPython.utils.py3compat import string_types
8 from IPython.utils.py3compat import string_types, iteritems
9
9
10 import zmq
10 import zmq
11
11
@@ -21,6 +21,20 b' from .clientabc import KernelClientABC'
21 from .connect import ConnectionFileMixin
21 from .connect import ConnectionFileMixin
22
22
23
23
24 # some utilities to validate message structure, these might get moved elsewhere
25 # if they prove to have more generic utility
26
27 def validate_string_dict(dct):
28 """Validate that the input is a dict with string keys and values.
29
30 Raises ValueError if not."""
31 for k,v in iteritems(dct):
32 if not isinstance(k, string_types):
33 raise ValueError('key %r in dict must be a string' % k)
34 if not isinstance(v, string_types):
35 raise ValueError('value %r in dict must be a string' % v)
36
37
24 class KernelClient(ConnectionFileMixin):
38 class KernelClient(ConnectionFileMixin):
25 """Communicates with a single kernel on any host via zmq channels.
39 """Communicates with a single kernel on any host via zmq channels.
26
40
@@ -37,28 +37,11 b' class QtHBChannel(SuperQObject, HBChannel):'
37
37
38 from IPython.core.release import kernel_protocol_version_info
38 from IPython.core.release import kernel_protocol_version_info
39
39
40 from IPython.utils.py3compat import string_types, iteritems
41
42 major_protocol_version = kernel_protocol_version_info[0]
40 major_protocol_version = kernel_protocol_version_info[0]
43
41
44 class InvalidPortNumber(Exception):
42 class InvalidPortNumber(Exception):
45 pass
43 pass
46
44
47 # some utilities to validate message structure, these might get moved elsewhere
48 # if they prove to have more generic utility
49
50
51 def validate_string_dict(dct):
52 """Validate that the input is a dict with string keys and values.
53
54 Raises ValueError if not."""
55 for k,v in iteritems(dct):
56 if not isinstance(k, string_types):
57 raise ValueError('key %r in dict must be a string' % k)
58 if not isinstance(v, string_types):
59 raise ValueError('value %r in dict must be a string' % v)
60
61
62
45
63 class QtZMQSocketChannel(SuperQObject):
46 class QtZMQSocketChannel(SuperQObject):
64 """A ZMQ socket emitting a Qt signal when a message is received."""
47 """A ZMQ socket emitting a Qt signal when a message is received."""
General Comments 0
You need to be logged in to leave comments. Login now