Merge branch 'python24' into dmw
* python24: WIP first run of py24 CI issue #477: initial Python 2.4.6 build for CI. issue #477: enable git-lfs for tests/data/*.tar.bz2. issue #477: import build script for Python 2.4.6. issue #477: add mitogen_py24 CI test type. issue #477: disable Django parts of module_finder_test on 2.4. issue #477: clean up globals after unix_test. issue #477: remove unused pytest bits from importer_test. issue #477: remove fork use from unix_test. parent: don't kill child when profiling=True issue #485: import new throuhgput bench issue #477: more fork removal issue #477: Py2.4 startswith() did not support tuples. issue #477: util/fakessh/two_three_compat fixes. issue #477: call_function_test fixes for 2.4. issue #477: promote setup_gil() to mitogen.utils issue #477: fix lxc_test any polyfill import. issue #477: stop using fork in responder_test. issue #477: stop using fork in service_test. issue #477: Python<2.5 ioctl() request parameter was signed. issue #477: stop using fork() in parent_test, compatible enumerate(). issue #477: Popen.terminate() polyfill for Py2.4. issue #477: stop using .fork() in router_test, one small 2.4 fix. issue #477: document master.Router.max_message_size. issue #477: old Py zlib did not include extended exception text. issue #477: stop using router.fork() in receiver_test issue #477: any() polyfill for lxc_test. issue #477: replace type(e) -> __class__ for an exception issue #477: old Mock does not throw side_effect exceptions from a list issue #477: 2.4 stat() returned int timestamps not float. issue #477: set().union(a, b, ..) unsupported on Py2.4. issue #477: Logger.log(extra=) unsupported on Py2.4. issue #477: fix another Threading.getName() call. issue #477: %f date format requires Py2.6 or newer. issue #477: make mitogen.fork unsupported on Py<2.6. issue #477: Py2.4 dep scanner bytecode difference Drop 'alpha' trove classifier issue #477: fix another str/bytes mixup. issue #477: blacklist 'thread' module to avoid roundtrip on 2.x->3.x issue #477: fix 3.x failure in new target.set_file_mode() function. issue #477: fix 3.x failure in new target.set_file_mode() function. issue #477: fix 2 runner tests on Ansible 2.7. issue #477: fix 3.x test regressions. issue #477: fix new KwargsTest on Python 3.x. issue #477: ModuleFinder now returns Unicode module names. issue #477: Python3 does not have Pickler.dispatch. issue #477: ModuleFinder test fixes. issue #477: Ansible 2.3 compatible regression/all.yml. issue #477: Ansible 2.3 requires placeholder module for assert_equals issue #477: build a CentOS 5/Py2.4 container + playbook compat fixes. issue #477: use PY24 constant rather than explicit test. issue #477: backport mitogen.master to Python 2.4. issue #477: parent: make iter_read() log disconnect reason. issue #477: backport ansible_mitogen.runner to 2.4. issue #477: backport various test modules to Python 2.4. issue #477: backport ansible_mitogen/target.py to Python2.4 issue #477: add all() polyfill to custom_python_detect_environmnet issue #477: polyfill partition() use in mitogen.parent. issue #477: polyfill partition() use in mitogen.service. issue #477: polyfill partition() use in mitogen.ssh. issue #477: vendorize the last 2.4-compatible simplejson issue #477: _update_linecache() must append newlines. issue #415, #477: Poller must handle POLLHUP too. issue #477: Python 2.5 needs next() polyfill too. issue #477: explicitly populate Py2.4 linecache from Importer. issue #477: rename and add tests for polyfill functions. issue #477: various core.py docstring cleanups. issue #477: Ansible 2.3 module output format difference. issue #477: Ansible 2.3 cannot use when: on an include. issue #477: tests: use Ansible 2.3-compatible include rather than import issue #477: serve up junk ansible/__init__.py just like Ansible. issue #477: testlib: Py2.4 did not have BaseException. issue #477: master: ability to override ModuleResponder output. issue #477: yet another bug in core._partition(). issue #477: 2.4.x compat fixes for mitogen.service. issue #477: Py2.4 lacks all(). issue #477: Ansible 2.3 had stricter arg spec format. issue #477: make CallError serializable on 2.4. issue #477: log full module name when SyntaxError occurs. issue #477: more Py2.4 (str|unicode).partition(). issue #477: Py2.4 cannot tolerate unicode kwargs. issue #477: Py2.4 lacks BaseException. issue #477: Py2.4: enumerate() may return stopped threads. issue #477: Py2.4: more unicode.rpartition() usage. issue #477: Python 2.4 type(exc) returns old-style instance. issue #477: Python 2.4 lacked str.partition. issue #477: Python 2.4 lacked Thread.name. issue #477: Python 2.4 lacked context managers. issue #477: Python <2.5 did not have combined try/finally/except. issue #477: older Ansibles had no vars plugin base class. issue #477: Python <2.5 lacked any(). issue #477: Python <2.6 lacked rpartition(). issue #477: make CallError inherit from object for 2.4/2.5. issue #477: 2.4/2.5 had no better poller than poll().issue510
David Wilson
6 years ago
commit
104e7a963f
@ -0,0 +1,14 @@
|
||||
#!/usr/bin/env python
|
||||
|
||||
import ci_lib
|
||||
|
||||
batches = [
|
||||
[
|
||||
'docker pull %s' % (ci_lib.image_for_distro(ci_lib.DISTRO),),
|
||||
],
|
||||
[
|
||||
'sudo tar -C / -jxvf tests/data/ubuntu-python-2.4.6.tar.bz2',
|
||||
]
|
||||
]
|
||||
|
||||
ci_lib.run_batches(batches)
|
||||
@ -0,0 +1,17 @@
|
||||
#!/usr/bin/env python
|
||||
# Mitogen tests for Python 2.4.
|
||||
|
||||
import os
|
||||
|
||||
import ci_lib
|
||||
|
||||
os.environ.update({
|
||||
'NOCOVERAGE': '1',
|
||||
'UNIT2': '/usr/local/python2.4.6/bin/unit2',
|
||||
|
||||
'MITOGEN_TEST_DISTRO': ci_lib.DISTRO,
|
||||
'MITOGEN_LOG_LEVEL': 'debug',
|
||||
'SKIP_ANSIBLE': '1',
|
||||
})
|
||||
|
||||
ci_lib.run('./run_tests -v')
|
||||
@ -0,0 +1,318 @@
|
||||
r"""JSON (JavaScript Object Notation) <http://json.org> is a subset of
|
||||
JavaScript syntax (ECMA-262 3rd edition) used as a lightweight data
|
||||
interchange format.
|
||||
|
||||
:mod:`simplejson` exposes an API familiar to users of the standard library
|
||||
:mod:`marshal` and :mod:`pickle` modules. It is the externally maintained
|
||||
version of the :mod:`json` library contained in Python 2.6, but maintains
|
||||
compatibility with Python 2.4 and Python 2.5 and (currently) has
|
||||
significant performance advantages, even without using the optional C
|
||||
extension for speedups.
|
||||
|
||||
Encoding basic Python object hierarchies::
|
||||
|
||||
>>> import simplejson as json
|
||||
>>> json.dumps(['foo', {'bar': ('baz', None, 1.0, 2)}])
|
||||
'["foo", {"bar": ["baz", null, 1.0, 2]}]'
|
||||
>>> print json.dumps("\"foo\bar")
|
||||
"\"foo\bar"
|
||||
>>> print json.dumps(u'\u1234')
|
||||
"\u1234"
|
||||
>>> print json.dumps('\\')
|
||||
"\\"
|
||||
>>> print json.dumps({"c": 0, "b": 0, "a": 0}, sort_keys=True)
|
||||
{"a": 0, "b": 0, "c": 0}
|
||||
>>> from StringIO import StringIO
|
||||
>>> io = StringIO()
|
||||
>>> json.dump(['streaming API'], io)
|
||||
>>> io.getvalue()
|
||||
'["streaming API"]'
|
||||
|
||||
Compact encoding::
|
||||
|
||||
>>> import simplejson as json
|
||||
>>> json.dumps([1,2,3,{'4': 5, '6': 7}], separators=(',',':'))
|
||||
'[1,2,3,{"4":5,"6":7}]'
|
||||
|
||||
Pretty printing::
|
||||
|
||||
>>> import simplejson as json
|
||||
>>> s = json.dumps({'4': 5, '6': 7}, sort_keys=True, indent=4)
|
||||
>>> print '\n'.join([l.rstrip() for l in s.splitlines()])
|
||||
{
|
||||
"4": 5,
|
||||
"6": 7
|
||||
}
|
||||
|
||||
Decoding JSON::
|
||||
|
||||
>>> import simplejson as json
|
||||
>>> obj = [u'foo', {u'bar': [u'baz', None, 1.0, 2]}]
|
||||
>>> json.loads('["foo", {"bar":["baz", null, 1.0, 2]}]') == obj
|
||||
True
|
||||
>>> json.loads('"\\"foo\\bar"') == u'"foo\x08ar'
|
||||
True
|
||||
>>> from StringIO import StringIO
|
||||
>>> io = StringIO('["streaming API"]')
|
||||
>>> json.load(io)[0] == 'streaming API'
|
||||
True
|
||||
|
||||
Specializing JSON object decoding::
|
||||
|
||||
>>> import simplejson as json
|
||||
>>> def as_complex(dct):
|
||||
... if '__complex__' in dct:
|
||||
... return complex(dct['real'], dct['imag'])
|
||||
... return dct
|
||||
...
|
||||
>>> json.loads('{"__complex__": true, "real": 1, "imag": 2}',
|
||||
... object_hook=as_complex)
|
||||
(1+2j)
|
||||
>>> import decimal
|
||||
>>> json.loads('1.1', parse_float=decimal.Decimal) == decimal.Decimal('1.1')
|
||||
True
|
||||
|
||||
Specializing JSON object encoding::
|
||||
|
||||
>>> import simplejson as json
|
||||
>>> def encode_complex(obj):
|
||||
... if isinstance(obj, complex):
|
||||
... return [obj.real, obj.imag]
|
||||
... raise TypeError(repr(o) + " is not JSON serializable")
|
||||
...
|
||||
>>> json.dumps(2 + 1j, default=encode_complex)
|
||||
'[2.0, 1.0]'
|
||||
>>> json.JSONEncoder(default=encode_complex).encode(2 + 1j)
|
||||
'[2.0, 1.0]'
|
||||
>>> ''.join(json.JSONEncoder(default=encode_complex).iterencode(2 + 1j))
|
||||
'[2.0, 1.0]'
|
||||
|
||||
|
||||
Using simplejson.tool from the shell to validate and pretty-print::
|
||||
|
||||
$ echo '{"json":"obj"}' | python -m simplejson.tool
|
||||
{
|
||||
"json": "obj"
|
||||
}
|
||||
$ echo '{ 1.2:3.4}' | python -m simplejson.tool
|
||||
Expecting property name: line 1 column 2 (char 2)
|
||||
"""
|
||||
__version__ = '2.0.9'
|
||||
__all__ = [
|
||||
'dump', 'dumps', 'load', 'loads',
|
||||
'JSONDecoder', 'JSONEncoder',
|
||||
]
|
||||
|
||||
__author__ = 'Bob Ippolito <bob@redivi.com>'
|
||||
|
||||
from decoder import JSONDecoder
|
||||
from encoder import JSONEncoder
|
||||
|
||||
_default_encoder = JSONEncoder(
|
||||
skipkeys=False,
|
||||
ensure_ascii=True,
|
||||
check_circular=True,
|
||||
allow_nan=True,
|
||||
indent=None,
|
||||
separators=None,
|
||||
encoding='utf-8',
|
||||
default=None,
|
||||
)
|
||||
|
||||
def dump(obj, fp, skipkeys=False, ensure_ascii=True, check_circular=True,
|
||||
allow_nan=True, cls=None, indent=None, separators=None,
|
||||
encoding='utf-8', default=None, **kw):
|
||||
"""Serialize ``obj`` as a JSON formatted stream to ``fp`` (a
|
||||
``.write()``-supporting file-like object).
|
||||
|
||||
If ``skipkeys`` is true then ``dict`` keys that are not basic types
|
||||
(``str``, ``unicode``, ``int``, ``long``, ``float``, ``bool``, ``None``)
|
||||
will be skipped instead of raising a ``TypeError``.
|
||||
|
||||
If ``ensure_ascii`` is false, then the some chunks written to ``fp``
|
||||
may be ``unicode`` instances, subject to normal Python ``str`` to
|
||||
``unicode`` coercion rules. Unless ``fp.write()`` explicitly
|
||||
understands ``unicode`` (as in ``codecs.getwriter()``) this is likely
|
||||
to cause an error.
|
||||
|
||||
If ``check_circular`` is false, then the circular reference check
|
||||
for container types will be skipped and a circular reference will
|
||||
result in an ``OverflowError`` (or worse).
|
||||
|
||||
If ``allow_nan`` is false, then it will be a ``ValueError`` to
|
||||
serialize out of range ``float`` values (``nan``, ``inf``, ``-inf``)
|
||||
in strict compliance of the JSON specification, instead of using the
|
||||
JavaScript equivalents (``NaN``, ``Infinity``, ``-Infinity``).
|
||||
|
||||
If ``indent`` is a non-negative integer, then JSON array elements and object
|
||||
members will be pretty-printed with that indent level. An indent level
|
||||
of 0 will only insert newlines. ``None`` is the most compact representation.
|
||||
|
||||
If ``separators`` is an ``(item_separator, dict_separator)`` tuple
|
||||
then it will be used instead of the default ``(', ', ': ')`` separators.
|
||||
``(',', ':')`` is the most compact JSON representation.
|
||||
|
||||
``encoding`` is the character encoding for str instances, default is UTF-8.
|
||||
|
||||
``default(obj)`` is a function that should return a serializable version
|
||||
of obj or raise TypeError. The default simply raises TypeError.
|
||||
|
||||
To use a custom ``JSONEncoder`` subclass (e.g. one that overrides the
|
||||
``.default()`` method to serialize additional types), specify it with
|
||||
the ``cls`` kwarg.
|
||||
|
||||
"""
|
||||
# cached encoder
|
||||
if (not skipkeys and ensure_ascii and
|
||||
check_circular and allow_nan and
|
||||
cls is None and indent is None and separators is None and
|
||||
encoding == 'utf-8' and default is None and not kw):
|
||||
iterable = _default_encoder.iterencode(obj)
|
||||
else:
|
||||
if cls is None:
|
||||
cls = JSONEncoder
|
||||
iterable = cls(skipkeys=skipkeys, ensure_ascii=ensure_ascii,
|
||||
check_circular=check_circular, allow_nan=allow_nan, indent=indent,
|
||||
separators=separators, encoding=encoding,
|
||||
default=default, **kw).iterencode(obj)
|
||||
# could accelerate with writelines in some versions of Python, at
|
||||
# a debuggability cost
|
||||
for chunk in iterable:
|
||||
fp.write(chunk)
|
||||
|
||||
|
||||
def dumps(obj, skipkeys=False, ensure_ascii=True, check_circular=True,
|
||||
allow_nan=True, cls=None, indent=None, separators=None,
|
||||
encoding='utf-8', default=None, **kw):
|
||||
"""Serialize ``obj`` to a JSON formatted ``str``.
|
||||
|
||||
If ``skipkeys`` is false then ``dict`` keys that are not basic types
|
||||
(``str``, ``unicode``, ``int``, ``long``, ``float``, ``bool``, ``None``)
|
||||
will be skipped instead of raising a ``TypeError``.
|
||||
|
||||
If ``ensure_ascii`` is false, then the return value will be a
|
||||
``unicode`` instance subject to normal Python ``str`` to ``unicode``
|
||||
coercion rules instead of being escaped to an ASCII ``str``.
|
||||
|
||||
If ``check_circular`` is false, then the circular reference check
|
||||
for container types will be skipped and a circular reference will
|
||||
result in an ``OverflowError`` (or worse).
|
||||
|
||||
If ``allow_nan`` is false, then it will be a ``ValueError`` to
|
||||
serialize out of range ``float`` values (``nan``, ``inf``, ``-inf``) in
|
||||
strict compliance of the JSON specification, instead of using the
|
||||
JavaScript equivalents (``NaN``, ``Infinity``, ``-Infinity``).
|
||||
|
||||
If ``indent`` is a non-negative integer, then JSON array elements and
|
||||
object members will be pretty-printed with that indent level. An indent
|
||||
level of 0 will only insert newlines. ``None`` is the most compact
|
||||
representation.
|
||||
|
||||
If ``separators`` is an ``(item_separator, dict_separator)`` tuple
|
||||
then it will be used instead of the default ``(', ', ': ')`` separators.
|
||||
``(',', ':')`` is the most compact JSON representation.
|
||||
|
||||
``encoding`` is the character encoding for str instances, default is UTF-8.
|
||||
|
||||
``default(obj)`` is a function that should return a serializable version
|
||||
of obj or raise TypeError. The default simply raises TypeError.
|
||||
|
||||
To use a custom ``JSONEncoder`` subclass (e.g. one that overrides the
|
||||
``.default()`` method to serialize additional types), specify it with
|
||||
the ``cls`` kwarg.
|
||||
|
||||
"""
|
||||
# cached encoder
|
||||
if (not skipkeys and ensure_ascii and
|
||||
check_circular and allow_nan and
|
||||
cls is None and indent is None and separators is None and
|
||||
encoding == 'utf-8' and default is None and not kw):
|
||||
return _default_encoder.encode(obj)
|
||||
if cls is None:
|
||||
cls = JSONEncoder
|
||||
return cls(
|
||||
skipkeys=skipkeys, ensure_ascii=ensure_ascii,
|
||||
check_circular=check_circular, allow_nan=allow_nan, indent=indent,
|
||||
separators=separators, encoding=encoding, default=default,
|
||||
**kw).encode(obj)
|
||||
|
||||
|
||||
_default_decoder = JSONDecoder(encoding=None, object_hook=None)
|
||||
|
||||
|
||||
def load(fp, encoding=None, cls=None, object_hook=None, parse_float=None,
|
||||
parse_int=None, parse_constant=None, **kw):
|
||||
"""Deserialize ``fp`` (a ``.read()``-supporting file-like object containing
|
||||
a JSON document) to a Python object.
|
||||
|
||||
If the contents of ``fp`` is encoded with an ASCII based encoding other
|
||||
than utf-8 (e.g. latin-1), then an appropriate ``encoding`` name must
|
||||
be specified. Encodings that are not ASCII based (such as UCS-2) are
|
||||
not allowed, and should be wrapped with
|
||||
``codecs.getreader(fp)(encoding)``, or simply decoded to a ``unicode``
|
||||
object and passed to ``loads()``
|
||||
|
||||
``object_hook`` is an optional function that will be called with the
|
||||
result of any object literal decode (a ``dict``). The return value of
|
||||
``object_hook`` will be used instead of the ``dict``. This feature
|
||||
can be used to implement custom decoders (e.g. JSON-RPC class hinting).
|
||||
|
||||
To use a custom ``JSONDecoder`` subclass, specify it with the ``cls``
|
||||
kwarg.
|
||||
|
||||
"""
|
||||
return loads(fp.read(),
|
||||
encoding=encoding, cls=cls, object_hook=object_hook,
|
||||
parse_float=parse_float, parse_int=parse_int,
|
||||
parse_constant=parse_constant, **kw)
|
||||
|
||||
|
||||
def loads(s, encoding=None, cls=None, object_hook=None, parse_float=None,
|
||||
parse_int=None, parse_constant=None, **kw):
|
||||
"""Deserialize ``s`` (a ``str`` or ``unicode`` instance containing a JSON
|
||||
document) to a Python object.
|
||||
|
||||
If ``s`` is a ``str`` instance and is encoded with an ASCII based encoding
|
||||
other than utf-8 (e.g. latin-1) then an appropriate ``encoding`` name
|
||||
must be specified. Encodings that are not ASCII based (such as UCS-2)
|
||||
are not allowed and should be decoded to ``unicode`` first.
|
||||
|
||||
``object_hook`` is an optional function that will be called with the
|
||||
result of any object literal decode (a ``dict``). The return value of
|
||||
``object_hook`` will be used instead of the ``dict``. This feature
|
||||
can be used to implement custom decoders (e.g. JSON-RPC class hinting).
|
||||
|
||||
``parse_float``, if specified, will be called with the string
|
||||
of every JSON float to be decoded. By default this is equivalent to
|
||||
float(num_str). This can be used to use another datatype or parser
|
||||
for JSON floats (e.g. decimal.Decimal).
|
||||
|
||||
``parse_int``, if specified, will be called with the string
|
||||
of every JSON int to be decoded. By default this is equivalent to
|
||||
int(num_str). This can be used to use another datatype or parser
|
||||
for JSON integers (e.g. float).
|
||||
|
||||
``parse_constant``, if specified, will be called with one of the
|
||||
following strings: -Infinity, Infinity, NaN, null, true, false.
|
||||
This can be used to raise an exception if invalid JSON numbers
|
||||
are encountered.
|
||||
|
||||
To use a custom ``JSONDecoder`` subclass, specify it with the ``cls``
|
||||
kwarg.
|
||||
|
||||
"""
|
||||
if (cls is None and encoding is None and object_hook is None and
|
||||
parse_int is None and parse_float is None and
|
||||
parse_constant is None and not kw):
|
||||
return _default_decoder.decode(s)
|
||||
if cls is None:
|
||||
cls = JSONDecoder
|
||||
if object_hook is not None:
|
||||
kw['object_hook'] = object_hook
|
||||
if parse_float is not None:
|
||||
kw['parse_float'] = parse_float
|
||||
if parse_int is not None:
|
||||
kw['parse_int'] = parse_int
|
||||
if parse_constant is not None:
|
||||
kw['parse_constant'] = parse_constant
|
||||
return cls(encoding=encoding, **kw).decode(s)
|
||||
@ -0,0 +1,354 @@
|
||||
"""Implementation of JSONDecoder
|
||||
"""
|
||||
import re
|
||||
import sys
|
||||
import struct
|
||||
|
||||
from simplejson.scanner import make_scanner
|
||||
try:
|
||||
from simplejson._speedups import scanstring as c_scanstring
|
||||
except ImportError:
|
||||
c_scanstring = None
|
||||
|
||||
__all__ = ['JSONDecoder']
|
||||
|
||||
FLAGS = re.VERBOSE | re.MULTILINE | re.DOTALL
|
||||
|
||||
def _floatconstants():
|
||||
_BYTES = '7FF80000000000007FF0000000000000'.decode('hex')
|
||||
if sys.byteorder != 'big':
|
||||
_BYTES = _BYTES[:8][::-1] + _BYTES[8:][::-1]
|
||||
nan, inf = struct.unpack('dd', _BYTES)
|
||||
return nan, inf, -inf
|
||||
|
||||
NaN, PosInf, NegInf = _floatconstants()
|
||||
|
||||
|
||||
def linecol(doc, pos):
|
||||
lineno = doc.count('\n', 0, pos) + 1
|
||||
if lineno == 1:
|
||||
colno = pos
|
||||
else:
|
||||
colno = pos - doc.rindex('\n', 0, pos)
|
||||
return lineno, colno
|
||||
|
||||
|
||||
def errmsg(msg, doc, pos, end=None):
|
||||
# Note that this function is called from _speedups
|
||||
lineno, colno = linecol(doc, pos)
|
||||
if end is None:
|
||||
#fmt = '{0}: line {1} column {2} (char {3})'
|
||||
#return fmt.format(msg, lineno, colno, pos)
|
||||
fmt = '%s: line %d column %d (char %d)'
|
||||
return fmt % (msg, lineno, colno, pos)
|
||||
endlineno, endcolno = linecol(doc, end)
|
||||
#fmt = '{0}: line {1} column {2} - line {3} column {4} (char {5} - {6})'
|
||||
#return fmt.format(msg, lineno, colno, endlineno, endcolno, pos, end)
|
||||
fmt = '%s: line %d column %d - line %d column %d (char %d - %d)'
|
||||
return fmt % (msg, lineno, colno, endlineno, endcolno, pos, end)
|
||||
|
||||
|
||||
_CONSTANTS = {
|
||||
'-Infinity': NegInf,
|
||||
'Infinity': PosInf,
|
||||
'NaN': NaN,
|
||||
}
|
||||
|
||||
STRINGCHUNK = re.compile(r'(.*?)(["\\\x00-\x1f])', FLAGS)
|
||||
BACKSLASH = {
|
||||
'"': u'"', '\\': u'\\', '/': u'/',
|
||||
'b': u'\b', 'f': u'\f', 'n': u'\n', 'r': u'\r', 't': u'\t',
|
||||
}
|
||||
|
||||
DEFAULT_ENCODING = "utf-8"
|
||||
|
||||
def py_scanstring(s, end, encoding=None, strict=True, _b=BACKSLASH, _m=STRINGCHUNK.match):
|
||||
"""Scan the string s for a JSON string. End is the index of the
|
||||
character in s after the quote that started the JSON string.
|
||||
Unescapes all valid JSON string escape sequences and raises ValueError
|
||||
on attempt to decode an invalid string. If strict is False then literal
|
||||
control characters are allowed in the string.
|
||||
|
||||
Returns a tuple of the decoded string and the index of the character in s
|
||||
after the end quote."""
|
||||
if encoding is None:
|
||||
encoding = DEFAULT_ENCODING
|
||||
chunks = []
|
||||
_append = chunks.append
|
||||
begin = end - 1
|
||||
while 1:
|
||||
chunk = _m(s, end)
|
||||
if chunk is None:
|
||||
raise ValueError(
|
||||
errmsg("Unterminated string starting at", s, begin))
|
||||
end = chunk.end()
|
||||
content, terminator = chunk.groups()
|
||||
# Content is contains zero or more unescaped string characters
|
||||
if content:
|
||||
if not isinstance(content, unicode):
|
||||
content = unicode(content, encoding)
|
||||
_append(content)
|
||||
# Terminator is the end of string, a literal control character,
|
||||
# or a backslash denoting that an escape sequence follows
|
||||
if terminator == '"':
|
||||
break
|
||||
elif terminator != '\\':
|
||||
if strict:
|
||||
msg = "Invalid control character %r at" % (terminator,)
|
||||
#msg = "Invalid control character {0!r} at".format(terminator)
|
||||
raise ValueError(errmsg(msg, s, end))
|
||||
else:
|
||||
_append(terminator)
|
||||
continue
|
||||
try:
|
||||
esc = s[end]
|
||||
except IndexError:
|
||||
raise ValueError(
|
||||
errmsg("Unterminated string starting at", s, begin))
|
||||
# If not a unicode escape sequence, must be in the lookup table
|
||||
if esc != 'u':
|
||||
try:
|
||||
char = _b[esc]
|
||||
except KeyError:
|
||||
msg = "Invalid \\escape: " + repr(esc)
|
||||
raise ValueError(errmsg(msg, s, end))
|
||||
end += 1
|
||||
else:
|
||||
# Unicode escape sequence
|
||||
esc = s[end + 1:end + 5]
|
||||
next_end = end + 5
|
||||
if len(esc) != 4:
|
||||
msg = "Invalid \\uXXXX escape"
|
||||
raise ValueError(errmsg(msg, s, end))
|
||||
uni = int(esc, 16)
|
||||
# Check for surrogate pair on UCS-4 systems
|
||||
if 0xd800 <= uni <= 0xdbff and sys.maxunicode > 65535:
|
||||
msg = "Invalid \\uXXXX\\uXXXX surrogate pair"
|
||||
if not s[end + 5:end + 7] == '\\u':
|
||||
raise ValueError(errmsg(msg, s, end))
|
||||
esc2 = s[end + 7:end + 11]
|
||||
if len(esc2) != 4:
|
||||
raise ValueError(errmsg(msg, s, end))
|
||||
uni2 = int(esc2, 16)
|
||||
uni = 0x10000 + (((uni - 0xd800) << 10) | (uni2 - 0xdc00))
|
||||
next_end += 6
|
||||
char = unichr(uni)
|
||||
end = next_end
|
||||
# Append the unescaped character
|
||||
_append(char)
|
||||
return u''.join(chunks), end
|
||||
|
||||
|
||||
# Use speedup if available
|
||||
scanstring = c_scanstring or py_scanstring
|
||||
|
||||
WHITESPACE = re.compile(r'[ \t\n\r]*', FLAGS)
|
||||
WHITESPACE_STR = ' \t\n\r'
|
||||
|
||||
def JSONObject((s, end), encoding, strict, scan_once, object_hook, _w=WHITESPACE.match, _ws=WHITESPACE_STR):
|
||||
pairs = {}
|
||||
# Use a slice to prevent IndexError from being raised, the following
|
||||
# check will raise a more specific ValueError if the string is empty
|
||||
nextchar = s[end:end + 1]
|
||||
# Normally we expect nextchar == '"'
|
||||
if nextchar != '"':
|
||||
if nextchar in _ws:
|
||||
end = _w(s, end).end()
|
||||
nextchar = s[end:end + 1]
|
||||
# Trivial empty object
|
||||
if nextchar == '}':
|
||||
return pairs, end + 1
|
||||
elif nextchar != '"':
|
||||
raise ValueError(errmsg("Expecting property name", s, end))
|
||||
end += 1
|
||||
while True:
|
||||
key, end = scanstring(s, end, encoding, strict)
|
||||
|
||||
# To skip some function call overhead we optimize the fast paths where
|
||||
# the JSON key separator is ": " or just ":".
|
||||
if s[end:end + 1] != ':':
|
||||
end = _w(s, end).end()
|
||||
if s[end:end + 1] != ':':
|
||||
raise ValueError(errmsg("Expecting : delimiter", s, end))
|
||||
|
||||
end += 1
|
||||
|
||||
try:
|
||||
if s[end] in _ws:
|
||||
end += 1
|
||||
if s[end] in _ws:
|
||||
end = _w(s, end + 1).end()
|
||||
except IndexError:
|
||||
pass
|
||||
|
||||
try:
|
||||
value, end = scan_once(s, end)
|
||||
except StopIteration:
|
||||
raise ValueError(errmsg("Expecting object", s, end))
|
||||
pairs[key] = value
|
||||
|
||||
try:
|
||||
nextchar = s[end]
|
||||
if nextchar in _ws:
|
||||
end = _w(s, end + 1).end()
|
||||
nextchar = s[end]
|
||||
except IndexError:
|
||||
nextchar = ''
|
||||
end += 1
|
||||
|
||||
if nextchar == '}':
|
||||
break
|
||||
elif nextchar != ',':
|
||||
raise ValueError(errmsg("Expecting , delimiter", s, end - 1))
|
||||
|
||||
try:
|
||||
nextchar = s[end]
|
||||
if nextchar in _ws:
|
||||
end += 1
|
||||
nextchar = s[end]
|
||||
if nextchar in _ws:
|
||||
end = _w(s, end + 1).end()
|
||||
nextchar = s[end]
|
||||
except IndexError:
|
||||
nextchar = ''
|
||||
|
||||
end += 1
|
||||
if nextchar != '"':
|
||||
raise ValueError(errmsg("Expecting property name", s, end - 1))
|
||||
|
||||
if object_hook is not None:
|
||||
pairs = object_hook(pairs)
|
||||
return pairs, end
|
||||
|
||||
def JSONArray((s, end), scan_once, _w=WHITESPACE.match, _ws=WHITESPACE_STR):
|
||||
values = []
|
||||
nextchar = s[end:end + 1]
|
||||
if nextchar in _ws:
|
||||
end = _w(s, end + 1).end()
|
||||
nextchar = s[end:end + 1]
|
||||
# Look-ahead for trivial empty array
|
||||
if nextchar == ']':
|
||||
return values, end + 1
|
||||
_append = values.append
|
||||
while True:
|
||||
try:
|
||||
value, end = scan_once(s, end)
|
||||
except StopIteration:
|
||||
raise ValueError(errmsg("Expecting object", s, end))
|
||||
_append(value)
|
||||
nextchar = s[end:end + 1]
|
||||
if nextchar in _ws:
|
||||
end = _w(s, end + 1).end()
|
||||
nextchar = s[end:end + 1]
|
||||
end += 1
|
||||
if nextchar == ']':
|
||||
break
|
||||
elif nextchar != ',':
|
||||
raise ValueError(errmsg("Expecting , delimiter", s, end))
|
||||
|
||||
try:
|
||||
if s[end] in _ws:
|
||||
end += 1
|
||||
if s[end] in _ws:
|
||||
end = _w(s, end + 1).end()
|
||||
except IndexError:
|
||||
pass
|
||||
|
||||
return values, end
|
||||
|
||||
class JSONDecoder(object):
|
||||
"""Simple JSON <http://json.org> decoder
|
||||
|
||||
Performs the following translations in decoding by default:
|
||||
|
||||
+---------------+-------------------+
|
||||
| JSON | Python |
|
||||
+===============+===================+
|
||||
| object | dict |
|
||||
+---------------+-------------------+
|
||||
| array | list |
|
||||
+---------------+-------------------+
|
||||
| string | unicode |
|
||||
+---------------+-------------------+
|
||||
| number (int) | int, long |
|
||||
+---------------+-------------------+
|
||||
| number (real) | float |
|
||||
+---------------+-------------------+
|
||||
| true | True |
|
||||
+---------------+-------------------+
|
||||
| false | False |
|
||||
+---------------+-------------------+
|
||||
| null | None |
|
||||
+---------------+-------------------+
|
||||
|
||||
It also understands ``NaN``, ``Infinity``, and ``-Infinity`` as
|
||||
their corresponding ``float`` values, which is outside the JSON spec.
|
||||
|
||||
"""
|
||||
|
||||
def __init__(self, encoding=None, object_hook=None, parse_float=None,
|
||||
parse_int=None, parse_constant=None, strict=True):
|
||||
"""``encoding`` determines the encoding used to interpret any ``str``
|
||||
objects decoded by this instance (utf-8 by default). It has no
|
||||
effect when decoding ``unicode`` objects.
|
||||
|
||||
Note that currently only encodings that are a superset of ASCII work,
|
||||
strings of other encodings should be passed in as ``unicode``.
|
||||
|
||||
``object_hook``, if specified, will be called with the result
|
||||
of every JSON object decoded and its return value will be used in
|
||||
place of the given ``dict``. This can be used to provide custom
|
||||
deserializations (e.g. to support JSON-RPC class hinting).
|
||||
|
||||
``parse_float``, if specified, will be called with the string
|
||||
of every JSON float to be decoded. By default this is equivalent to
|
||||
float(num_str). This can be used to use another datatype or parser
|
||||
for JSON floats (e.g. decimal.Decimal).
|
||||
|
||||
``parse_int``, if specified, will be called with the string
|
||||
of every JSON int to be decoded. By default this is equivalent to
|
||||
int(num_str). This can be used to use another datatype or parser
|
||||
for JSON integers (e.g. float).
|
||||
|
||||
``parse_constant``, if specified, will be called with one of the
|
||||
following strings: -Infinity, Infinity, NaN.
|
||||
This can be used to raise an exception if invalid JSON numbers
|
||||
are encountered.
|
||||
|
||||
"""
|
||||
self.encoding = encoding
|
||||
self.object_hook = object_hook
|
||||
self.parse_float = parse_float or float
|
||||
self.parse_int = parse_int or int
|
||||
self.parse_constant = parse_constant or _CONSTANTS.__getitem__
|
||||
self.strict = strict
|
||||
self.parse_object = JSONObject
|
||||
self.parse_array = JSONArray
|
||||
self.parse_string = scanstring
|
||||
self.scan_once = make_scanner(self)
|
||||
|
||||
def decode(self, s, _w=WHITESPACE.match):
|
||||
"""Return the Python representation of ``s`` (a ``str`` or ``unicode``
|
||||
instance containing a JSON document)
|
||||
|
||||
"""
|
||||
obj, end = self.raw_decode(s, idx=_w(s, 0).end())
|
||||
end = _w(s, end).end()
|
||||
if end != len(s):
|
||||
raise ValueError(errmsg("Extra data", s, end, len(s)))
|
||||
return obj
|
||||
|
||||
def raw_decode(self, s, idx=0):
|
||||
"""Decode a JSON document from ``s`` (a ``str`` or ``unicode`` beginning
|
||||
with a JSON document) and return a 2-tuple of the Python
|
||||
representation and the index in ``s`` where the document ended.
|
||||
|
||||
This can be used to decode a JSON document from a string that may
|
||||
have extraneous data at the end.
|
||||
|
||||
"""
|
||||
try:
|
||||
obj, end = self.scan_once(s, idx)
|
||||
except StopIteration:
|
||||
raise ValueError("No JSON object could be decoded")
|
||||
return obj, end
|
||||
@ -0,0 +1,440 @@
|
||||
"""Implementation of JSONEncoder
|
||||
"""
|
||||
import re
|
||||
|
||||
try:
|
||||
from simplejson._speedups import encode_basestring_ascii as c_encode_basestring_ascii
|
||||
except ImportError:
|
||||
c_encode_basestring_ascii = None
|
||||
try:
|
||||
from simplejson._speedups import make_encoder as c_make_encoder
|
||||
except ImportError:
|
||||
c_make_encoder = None
|
||||
|
||||
ESCAPE = re.compile(r'[\x00-\x1f\\"\b\f\n\r\t]')
|
||||
ESCAPE_ASCII = re.compile(r'([\\"]|[^\ -~])')
|
||||
HAS_UTF8 = re.compile(r'[\x80-\xff]')
|
||||
ESCAPE_DCT = {
|
||||
'\\': '\\\\',
|
||||
'"': '\\"',
|
||||
'\b': '\\b',
|
||||
'\f': '\\f',
|
||||
'\n': '\\n',
|
||||
'\r': '\\r',
|
||||
'\t': '\\t',
|
||||
}
|
||||
for i in range(0x20):
|
||||
#ESCAPE_DCT.setdefault(chr(i), '\\u{0:04x}'.format(i))
|
||||
ESCAPE_DCT.setdefault(chr(i), '\\u%04x' % (i,))
|
||||
|
||||
# Assume this produces an infinity on all machines (probably not guaranteed)
|
||||
INFINITY = float('1e66666')
|
||||
FLOAT_REPR = repr
|
||||
|
||||
def encode_basestring(s):
|
||||
"""Return a JSON representation of a Python string
|
||||
|
||||
"""
|
||||
def replace(match):
|
||||
return ESCAPE_DCT[match.group(0)]
|
||||
return '"' + ESCAPE.sub(replace, s) + '"'
|
||||
|
||||
|
||||
def py_encode_basestring_ascii(s):
|
||||
"""Return an ASCII-only JSON representation of a Python string
|
||||
|
||||
"""
|
||||
if isinstance(s, str) and HAS_UTF8.search(s) is not None:
|
||||
s = s.decode('utf-8')
|
||||
def replace(match):
|
||||
s = match.group(0)
|
||||
try:
|
||||
return ESCAPE_DCT[s]
|
||||
except KeyError:
|
||||
n = ord(s)
|
||||
if n < 0x10000:
|
||||
#return '\\u{0:04x}'.format(n)
|
||||
return '\\u%04x' % (n,)
|
||||
else:
|
||||
# surrogate pair
|
||||
n -= 0x10000
|
||||
s1 = 0xd800 | ((n >> 10) & 0x3ff)
|
||||
s2 = 0xdc00 | (n & 0x3ff)
|
||||
#return '\\u{0:04x}\\u{1:04x}'.format(s1, s2)
|
||||
return '\\u%04x\\u%04x' % (s1, s2)
|
||||
return '"' + str(ESCAPE_ASCII.sub(replace, s)) + '"'
|
||||
|
||||
|
||||
encode_basestring_ascii = c_encode_basestring_ascii or py_encode_basestring_ascii
|
||||
|
||||
class JSONEncoder(object):
|
||||
"""Extensible JSON <http://json.org> encoder for Python data structures.
|
||||
|
||||
Supports the following objects and types by default:
|
||||
|
||||
+-------------------+---------------+
|
||||
| Python | JSON |
|
||||
+===================+===============+
|
||||
| dict | object |
|
||||
+-------------------+---------------+
|
||||
| list, tuple | array |
|
||||
+-------------------+---------------+
|
||||
| str, unicode | string |
|
||||
+-------------------+---------------+
|
||||
| int, long, float | number |
|
||||
+-------------------+---------------+
|
||||
| True | true |
|
||||
+-------------------+---------------+
|
||||
| False | false |
|
||||
+-------------------+---------------+
|
||||
| None | null |
|
||||
+-------------------+---------------+
|
||||
|
||||
To extend this to recognize other objects, subclass and implement a
|
||||
``.default()`` method with another method that returns a serializable
|
||||
object for ``o`` if possible, otherwise it should call the superclass
|
||||
implementation (to raise ``TypeError``).
|
||||
|
||||
"""
|
||||
item_separator = ', '
|
||||
key_separator = ': '
|
||||
def __init__(self, skipkeys=False, ensure_ascii=True,
|
||||
check_circular=True, allow_nan=True, sort_keys=False,
|
||||
indent=None, separators=None, encoding='utf-8', default=None):
|
||||
"""Constructor for JSONEncoder, with sensible defaults.
|
||||
|
||||
If skipkeys is false, then it is a TypeError to attempt
|
||||
encoding of keys that are not str, int, long, float or None. If
|
||||
skipkeys is True, such items are simply skipped.
|
||||
|
||||
If ensure_ascii is true, the output is guaranteed to be str
|
||||
objects with all incoming unicode characters escaped. If
|
||||
ensure_ascii is false, the output will be unicode object.
|
||||
|
||||
If check_circular is true, then lists, dicts, and custom encoded
|
||||
objects will be checked for circular references during encoding to
|
||||
prevent an infinite recursion (which would cause an OverflowError).
|
||||
Otherwise, no such check takes place.
|
||||
|
||||
If allow_nan is true, then NaN, Infinity, and -Infinity will be
|
||||
encoded as such. This behavior is not JSON specification compliant,
|
||||
but is consistent with most JavaScript based encoders and decoders.
|
||||
Otherwise, it will be a ValueError to encode such floats.
|
||||
|
||||
If sort_keys is true, then the output of dictionaries will be
|
||||
sorted by key; this is useful for regression tests to ensure
|
||||
that JSON serializations can be compared on a day-to-day basis.
|
||||
|
||||
If indent is a non-negative integer, then JSON array
|
||||
elements and object members will be pretty-printed with that
|
||||
indent level. An indent level of 0 will only insert newlines.
|
||||
None is the most compact representation.
|
||||
|
||||
If specified, separators should be a (item_separator, key_separator)
|
||||
tuple. The default is (', ', ': '). To get the most compact JSON
|
||||
representation you should specify (',', ':') to eliminate whitespace.
|
||||
|
||||
If specified, default is a function that gets called for objects
|
||||
that can't otherwise be serialized. It should return a JSON encodable
|
||||
version of the object or raise a ``TypeError``.
|
||||
|
||||
If encoding is not None, then all input strings will be
|
||||
transformed into unicode using that encoding prior to JSON-encoding.
|
||||
The default is UTF-8.
|
||||
|
||||
"""
|
||||
|
||||
self.skipkeys = skipkeys
|
||||
self.ensure_ascii = ensure_ascii
|
||||
self.check_circular = check_circular
|
||||
self.allow_nan = allow_nan
|
||||
self.sort_keys = sort_keys
|
||||
self.indent = indent
|
||||
if separators is not None:
|
||||
self.item_separator, self.key_separator = separators
|
||||
if default is not None:
|
||||
self.default = default
|
||||
self.encoding = encoding
|
||||
|
||||
def default(self, o):
|
||||
"""Implement this method in a subclass such that it returns
|
||||
a serializable object for ``o``, or calls the base implementation
|
||||
(to raise a ``TypeError``).
|
||||
|
||||
For example, to support arbitrary iterators, you could
|
||||
implement default like this::
|
||||
|
||||
def default(self, o):
|
||||
try:
|
||||
iterable = iter(o)
|
||||
except TypeError:
|
||||
pass
|
||||
else:
|
||||
return list(iterable)
|
||||
return JSONEncoder.default(self, o)
|
||||
|
||||
"""
|
||||
raise TypeError(repr(o) + " is not JSON serializable")
|
||||
|
||||
def encode(self, o):
|
||||
"""Return a JSON string representation of a Python data structure.
|
||||
|
||||
>>> JSONEncoder().encode({"foo": ["bar", "baz"]})
|
||||
'{"foo": ["bar", "baz"]}'
|
||||
|
||||
"""
|
||||
# This is for extremely simple cases and benchmarks.
|
||||
if isinstance(o, basestring):
|
||||
if isinstance(o, str):
|
||||
_encoding = self.encoding
|
||||
if (_encoding is not None
|
||||
and not (_encoding == 'utf-8')):
|
||||
o = o.decode(_encoding)
|
||||
if self.ensure_ascii:
|
||||
return encode_basestring_ascii(o)
|
||||
else:
|
||||
return encode_basestring(o)
|
||||
# This doesn't pass the iterator directly to ''.join() because the
|
||||
# exceptions aren't as detailed. The list call should be roughly
|
||||
# equivalent to the PySequence_Fast that ''.join() would do.
|
||||
chunks = self.iterencode(o, _one_shot=True)
|
||||
if not isinstance(chunks, (list, tuple)):
|
||||
chunks = list(chunks)
|
||||
return ''.join(chunks)
|
||||
|
||||
def iterencode(self, o, _one_shot=False):
|
||||
"""Encode the given object and yield each string
|
||||
representation as available.
|
||||
|
||||
For example::
|
||||
|
||||
for chunk in JSONEncoder().iterencode(bigobject):
|
||||
mysocket.write(chunk)
|
||||
|
||||
"""
|
||||
if self.check_circular:
|
||||
markers = {}
|
||||
else:
|
||||
markers = None
|
||||
if self.ensure_ascii:
|
||||
_encoder = encode_basestring_ascii
|
||||
else:
|
||||
_encoder = encode_basestring
|
||||
if self.encoding != 'utf-8':
|
||||
def _encoder(o, _orig_encoder=_encoder, _encoding=self.encoding):
|
||||
if isinstance(o, str):
|
||||
o = o.decode(_encoding)
|
||||
return _orig_encoder(o)
|
||||
|
||||
def floatstr(o, allow_nan=self.allow_nan, _repr=FLOAT_REPR, _inf=INFINITY, _neginf=-INFINITY):
|
||||
# Check for specials. Note that this type of test is processor- and/or
|
||||
# platform-specific, so do tests which don't depend on the internals.
|
||||
|
||||
if o != o:
|
||||
text = 'NaN'
|
||||
elif o == _inf:
|
||||
text = 'Infinity'
|
||||
elif o == _neginf:
|
||||
text = '-Infinity'
|
||||
else:
|
||||
return _repr(o)
|
||||
|
||||
if not allow_nan:
|
||||
raise ValueError(
|
||||
"Out of range float values are not JSON compliant: " +
|
||||
repr(o))
|
||||
|
||||
return text
|
||||
|
||||
|
||||
if _one_shot and c_make_encoder is not None and not self.indent and not self.sort_keys:
|
||||
_iterencode = c_make_encoder(
|
||||
markers, self.default, _encoder, self.indent,
|
||||
self.key_separator, self.item_separator, self.sort_keys,
|
||||
self.skipkeys, self.allow_nan)
|
||||
else:
|
||||
_iterencode = _make_iterencode(
|
||||
markers, self.default, _encoder, self.indent, floatstr,
|
||||
self.key_separator, self.item_separator, self.sort_keys,
|
||||
self.skipkeys, _one_shot)
|
||||
return _iterencode(o, 0)
|
||||
|
||||
def _make_iterencode(markers, _default, _encoder, _indent, _floatstr, _key_separator, _item_separator, _sort_keys, _skipkeys, _one_shot,
|
||||
## HACK: hand-optimized bytecode; turn globals into locals
|
||||
False=False,
|
||||
True=True,
|
||||
ValueError=ValueError,
|
||||
basestring=basestring,
|
||||
dict=dict,
|
||||
float=float,
|
||||
id=id,
|
||||
int=int,
|
||||
isinstance=isinstance,
|
||||
list=list,
|
||||
long=long,
|
||||
str=str,
|
||||
tuple=tuple,
|
||||
):
|
||||
|
||||
def _iterencode_list(lst, _current_indent_level):
|
||||
if not lst:
|
||||
yield '[]'
|
||||
return
|
||||
if markers is not None:
|
||||
markerid = id(lst)
|
||||
if markerid in markers:
|
||||
raise ValueError("Circular reference detected")
|
||||
markers[markerid] = lst
|
||||
buf = '['
|
||||
if _indent is not None:
|
||||
_current_indent_level += 1
|
||||
newline_indent = '\n' + (' ' * (_indent * _current_indent_level))
|
||||
separator = _item_separator + newline_indent
|
||||
buf += newline_indent
|
||||
else:
|
||||
newline_indent = None
|
||||
separator = _item_separator
|
||||
first = True
|
||||
for value in lst:
|
||||
if first:
|
||||
first = False
|
||||
else:
|
||||
buf = separator
|
||||
if isinstance(value, basestring):
|
||||
yield buf + _encoder(value)
|
||||
elif value is None:
|
||||
yield buf + 'null'
|
||||
elif value is True:
|
||||
yield buf + 'true'
|
||||
elif value is False:
|
||||
yield buf + 'false'
|
||||
elif isinstance(value, (int, long)):
|
||||
yield buf + str(value)
|
||||
elif isinstance(value, float):
|
||||
yield buf + _floatstr(value)
|
||||
else:
|
||||
yield buf
|
||||
if isinstance(value, (list, tuple)):
|
||||
chunks = _iterencode_list(value, _current_indent_level)
|
||||
elif isinstance(value, dict):
|
||||
chunks = _iterencode_dict(value, _current_indent_level)
|
||||
else:
|
||||
chunks = _iterencode(value, _current_indent_level)
|
||||
for chunk in chunks:
|
||||
yield chunk
|
||||
if newline_indent is not None:
|
||||
_current_indent_level -= 1
|
||||
yield '\n' + (' ' * (_indent * _current_indent_level))
|
||||
yield ']'
|
||||
if markers is not None:
|
||||
del markers[markerid]
|
||||
|
||||
def _iterencode_dict(dct, _current_indent_level):
|
||||
if not dct:
|
||||
yield '{}'
|
||||
return
|
||||
if markers is not None:
|
||||
markerid = id(dct)
|
||||
if markerid in markers:
|
||||
raise ValueError("Circular reference detected")
|
||||
markers[markerid] = dct
|
||||
yield '{'
|
||||
if _indent is not None:
|
||||
_current_indent_level += 1
|
||||
newline_indent = '\n' + (' ' * (_indent * _current_indent_level))
|
||||
item_separator = _item_separator + newline_indent
|
||||
yield newline_indent
|
||||
else:
|
||||
newline_indent = None
|
||||
item_separator = _item_separator
|
||||
first = True
|
||||
if _sort_keys:
|
||||
items = dct.items()
|
||||
items.sort(key=lambda kv: kv[0])
|
||||
else:
|
||||
items = dct.iteritems()
|
||||
for key, value in items:
|
||||
if isinstance(key, basestring):
|
||||
pass
|
||||
# JavaScript is weakly typed for these, so it makes sense to
|
||||
# also allow them. Many encoders seem to do something like this.
|
||||
elif isinstance(key, float):
|
||||
key = _floatstr(key)
|
||||
elif key is True:
|
||||
key = 'true'
|
||||
elif key is False:
|
||||
key = 'false'
|
||||
elif key is None:
|
||||
key = 'null'
|
||||
elif isinstance(key, (int, long)):
|
||||
key = str(key)
|
||||
elif _skipkeys:
|
||||
continue
|
||||
else:
|
||||
raise TypeError("key " + repr(key) + " is not a string")
|
||||
if first:
|
||||
first = False
|
||||
else:
|
||||
yield item_separator
|
||||
yield _encoder(key)
|
||||
yield _key_separator
|
||||
if isinstance(value, basestring):
|
||||
yield _encoder(value)
|
||||
elif value is None:
|
||||
yield 'null'
|
||||
elif value is True:
|
||||
yield 'true'
|
||||
elif value is False:
|
||||
yield 'false'
|
||||
elif isinstance(value, (int, long)):
|
||||
yield str(value)
|
||||
elif isinstance(value, float):
|
||||
yield _floatstr(value)
|
||||
else:
|
||||
if isinstance(value, (list, tuple)):
|
||||
chunks = _iterencode_list(value, _current_indent_level)
|
||||
elif isinstance(value, dict):
|
||||
chunks = _iterencode_dict(value, _current_indent_level)
|
||||
else:
|
||||
chunks = _iterencode(value, _current_indent_level)
|
||||
for chunk in chunks:
|
||||
yield chunk
|
||||
if newline_indent is not None:
|
||||
_current_indent_level -= 1
|
||||
yield '\n' + (' ' * (_indent * _current_indent_level))
|
||||
yield '}'
|
||||
if markers is not None:
|
||||
del markers[markerid]
|
||||
|
||||
def _iterencode(o, _current_indent_level):
|
||||
if isinstance(o, basestring):
|
||||
yield _encoder(o)
|
||||
elif o is None:
|
||||
yield 'null'
|
||||
elif o is True:
|
||||
yield 'true'
|
||||
elif o is False:
|
||||
yield 'false'
|
||||
elif isinstance(o, (int, long)):
|
||||
yield str(o)
|
||||
elif isinstance(o, float):
|
||||
yield _floatstr(o)
|
||||
elif isinstance(o, (list, tuple)):
|
||||
for chunk in _iterencode_list(o, _current_indent_level):
|
||||
yield chunk
|
||||
elif isinstance(o, dict):
|
||||
for chunk in _iterencode_dict(o, _current_indent_level):
|
||||
yield chunk
|
||||
else:
|
||||
if markers is not None:
|
||||
markerid = id(o)
|
||||
if markerid in markers:
|
||||
raise ValueError("Circular reference detected")
|
||||
markers[markerid] = o
|
||||
o = _default(o)
|
||||
for chunk in _iterencode(o, _current_indent_level):
|
||||
yield chunk
|
||||
if markers is not None:
|
||||
del markers[markerid]
|
||||
|
||||
return _iterencode
|
||||
@ -0,0 +1,65 @@
|
||||
"""JSON token scanner
|
||||
"""
|
||||
import re
|
||||
try:
|
||||
from simplejson._speedups import make_scanner as c_make_scanner
|
||||
except ImportError:
|
||||
c_make_scanner = None
|
||||
|
||||
__all__ = ['make_scanner']
|
||||
|
||||
NUMBER_RE = re.compile(
|
||||
r'(-?(?:0|[1-9]\d*))(\.\d+)?([eE][-+]?\d+)?',
|
||||
(re.VERBOSE | re.MULTILINE | re.DOTALL))
|
||||
|
||||
def py_make_scanner(context):
|
||||
parse_object = context.parse_object
|
||||
parse_array = context.parse_array
|
||||
parse_string = context.parse_string
|
||||
match_number = NUMBER_RE.match
|
||||
encoding = context.encoding
|
||||
strict = context.strict
|
||||
parse_float = context.parse_float
|
||||
parse_int = context.parse_int
|
||||
parse_constant = context.parse_constant
|
||||
object_hook = context.object_hook
|
||||
|
||||
def _scan_once(string, idx):
|
||||
try:
|
||||
nextchar = string[idx]
|
||||
except IndexError:
|
||||
raise StopIteration
|
||||
|
||||
if nextchar == '"':
|
||||
return parse_string(string, idx + 1, encoding, strict)
|
||||
elif nextchar == '{':
|
||||
return parse_object((string, idx + 1), encoding, strict, _scan_once, object_hook)
|
||||
elif nextchar == '[':
|
||||
return parse_array((string, idx + 1), _scan_once)
|
||||
elif nextchar == 'n' and string[idx:idx + 4] == 'null':
|
||||
return None, idx + 4
|
||||
elif nextchar == 't' and string[idx:idx + 4] == 'true':
|
||||
return True, idx + 4
|
||||
elif nextchar == 'f' and string[idx:idx + 5] == 'false':
|
||||
return False, idx + 5
|
||||
|
||||
m = match_number(string, idx)
|
||||
if m is not None:
|
||||
integer, frac, exp = m.groups()
|
||||
if frac or exp:
|
||||
res = parse_float(integer + (frac or '') + (exp or ''))
|
||||
else:
|
||||
res = parse_int(integer)
|
||||
return res, m.end()
|
||||
elif nextchar == 'N' and string[idx:idx + 3] == 'NaN':
|
||||
return parse_constant('NaN'), idx + 3
|
||||
elif nextchar == 'I' and string[idx:idx + 8] == 'Infinity':
|
||||
return parse_constant('Infinity'), idx + 8
|
||||
elif nextchar == '-' and string[idx:idx + 9] == '-Infinity':
|
||||
return parse_constant('-Infinity'), idx + 9
|
||||
else:
|
||||
raise StopIteration
|
||||
|
||||
return _scan_once
|
||||
|
||||
make_scanner = c_make_scanner or py_make_scanner
|
||||
@ -1,3 +1,3 @@
|
||||
- import_playbook: regression/all.yml
|
||||
- import_playbook: integration/all.yml
|
||||
- include: regression/all.yml
|
||||
- include: integration/all.yml
|
||||
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
- import_playbook: copy.yml
|
||||
- import_playbook: fixup_perms2__copy.yml
|
||||
- import_playbook: low_level_execute_command.yml
|
||||
- import_playbook: make_tmp_path.yml
|
||||
- import_playbook: remote_expand_user.yml
|
||||
- import_playbook: remote_file_exists.yml
|
||||
- import_playbook: remove_tmp_path.yml
|
||||
- import_playbook: synchronize.yml
|
||||
- import_playbook: transfer_data.yml
|
||||
- include: copy.yml
|
||||
- include: fixup_perms2__copy.yml
|
||||
- include: low_level_execute_command.yml
|
||||
- include: make_tmp_path.yml
|
||||
- include: remote_expand_user.yml
|
||||
- include: remote_file_exists.yml
|
||||
- include: remove_tmp_path.yml
|
||||
- include: synchronize.yml
|
||||
- include: transfer_data.yml
|
||||
|
||||
@ -1,9 +1,9 @@
|
||||
- import_playbook: multiple_items_loop.yml
|
||||
- import_playbook: result_binary_producing_json.yml
|
||||
- import_playbook: result_binary_producing_junk.yml
|
||||
- import_playbook: result_shell_echo_hi.yml
|
||||
- import_playbook: runner_new_process.yml
|
||||
- import_playbook: runner_one_job.yml
|
||||
- import_playbook: runner_timeout_then_polling.yml
|
||||
- import_playbook: runner_two_simultaneous_jobs.yml
|
||||
- import_playbook: runner_with_polling_and_timeout.yml
|
||||
- include: multiple_items_loop.yml
|
||||
- include: result_binary_producing_json.yml
|
||||
- include: result_binary_producing_junk.yml
|
||||
- include: result_shell_echo_hi.yml
|
||||
- include: runner_new_process.yml
|
||||
- include: runner_one_job.yml
|
||||
- include: runner_timeout_then_polling.yml
|
||||
- include: runner_two_simultaneous_jobs.yml
|
||||
- include: runner_with_polling_and_timeout.yml
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
|
||||
- import_playbook: su_password.yml
|
||||
- import_playbook: sudo_flags_failure.yml
|
||||
- import_playbook: sudo_nonexistent.yml
|
||||
- import_playbook: sudo_nopassword.yml
|
||||
- import_playbook: sudo_password.yml
|
||||
- import_playbook: sudo_requiretty.yml
|
||||
- include: su_password.yml
|
||||
- include: sudo_flags_failure.yml
|
||||
- include: sudo_nonexistent.yml
|
||||
- include: sudo_nopassword.yml
|
||||
- include: sudo_password.yml
|
||||
- include: sudo_requiretty.yml
|
||||
|
||||
@ -1,8 +1,8 @@
|
||||
---
|
||||
|
||||
- import_playbook: disconnect_during_module.yml
|
||||
- import_playbook: disconnect_resets_connection.yml
|
||||
- import_playbook: exec_command.yml
|
||||
- import_playbook: put_large_file.yml
|
||||
- import_playbook: put_small_file.yml
|
||||
- import_playbook: reset.yml
|
||||
- include: disconnect_during_module.yml
|
||||
- include: disconnect_resets_connection.yml
|
||||
- include: exec_command.yml
|
||||
- include: put_large_file.yml
|
||||
- include: put_small_file.yml
|
||||
- include: reset.yml
|
||||
|
||||
@ -1,5 +1,5 @@
|
||||
- import_playbook: delegate_to_template.yml
|
||||
- import_playbook: local_action.yml
|
||||
- import_playbook: osa_container_standalone.yml
|
||||
- import_playbook: osa_delegate_to_self.yml
|
||||
- import_playbook: stack_construction.yml
|
||||
- include: delegate_to_template.yml
|
||||
- include: local_action.yml
|
||||
- include: osa_container_standalone.yml
|
||||
- include: osa_delegate_to_self.yml
|
||||
- include: stack_construction.yml
|
||||
|
||||
@ -1,3 +1,3 @@
|
||||
- import_playbook: local_blemished.yml
|
||||
- import_playbook: paramiko_unblemished.yml
|
||||
- import_playbook: ssh_blemished.yml
|
||||
- include: local_blemished.yml
|
||||
- include: paramiko_unblemished.yml
|
||||
- include: ssh_blemished.yml
|
||||
|
||||
@ -1,3 +1,3 @@
|
||||
- import_playbook: disconnect_cleanup.yml
|
||||
- import_playbook: lru_one_target.yml
|
||||
- import_playbook: reconnection.yml
|
||||
- include: disconnect_cleanup.yml
|
||||
- include: lru_one_target.yml
|
||||
- include: reconnection.yml
|
||||
|
||||
@ -1,2 +1,2 @@
|
||||
|
||||
- import_playbook: resolv_conf.yml
|
||||
- include: resolv_conf.yml
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
|
||||
- import_playbook: cwd_preserved.yml
|
||||
- import_playbook: env_preserved.yml
|
||||
- include: cwd_preserved.yml
|
||||
- include: env_preserved.yml
|
||||
|
||||
|
||||
@ -1,6 +1,6 @@
|
||||
|
||||
#- import_playbook: from_config_path.yml
|
||||
#- import_playbook: from_config_path_pkg.yml
|
||||
#- import_playbook: adjacent_to_playbook.yml
|
||||
- import_playbook: adjacent_to_role.yml
|
||||
#- import_playbook: overrides_builtin.yml
|
||||
#- include: from_config_path.yml
|
||||
#- include: from_config_path_pkg.yml
|
||||
#- include: adjacent_to_playbook.yml
|
||||
- include: adjacent_to_role.yml
|
||||
#- include: overrides_builtin.yml
|
||||
|
||||
@ -1,4 +1,4 @@
|
||||
- import_playbook: become_flags.yml
|
||||
- import_playbook: delegate_to.yml
|
||||
- import_playbook: environment.yml
|
||||
- import_playbook: with_items.yml
|
||||
- include: become_flags.yml
|
||||
- include: delegate_to.yml
|
||||
- include: environment.yml
|
||||
- include: with_items.yml
|
||||
|
||||
@ -1,21 +1,21 @@
|
||||
- import_playbook: atexit.yml
|
||||
- import_playbook: builtin_command_module.yml
|
||||
- import_playbook: custom_bash_hashbang_argument.yml
|
||||
- import_playbook: custom_bash_old_style_module.yml
|
||||
- import_playbook: custom_bash_want_json_module.yml
|
||||
- import_playbook: custom_binary_producing_json.yml
|
||||
- import_playbook: custom_binary_producing_junk.yml
|
||||
- import_playbook: custom_binary_single_null.yml
|
||||
- import_playbook: custom_perl_json_args_module.yml
|
||||
- import_playbook: custom_perl_want_json_module.yml
|
||||
- import_playbook: custom_python_json_args_module.yml
|
||||
- import_playbook: custom_python_new_style_missing_interpreter.yml
|
||||
- import_playbook: custom_python_new_style_module.yml
|
||||
- import_playbook: custom_python_want_json_module.yml
|
||||
- import_playbook: custom_script_interpreter.yml
|
||||
- import_playbook: environment_isolation.yml
|
||||
- import_playbook: etc_environment.yml
|
||||
- import_playbook: forking_active.yml
|
||||
- import_playbook: forking_correct_parent.yml
|
||||
- import_playbook: forking_inactive.yml
|
||||
- import_playbook: missing_module.yml
|
||||
- include: atexit.yml
|
||||
- include: builtin_command_module.yml
|
||||
- include: custom_bash_hashbang_argument.yml
|
||||
- include: custom_bash_old_style_module.yml
|
||||
- include: custom_bash_want_json_module.yml
|
||||
- include: custom_binary_producing_json.yml
|
||||
- include: custom_binary_producing_junk.yml
|
||||
- include: custom_binary_single_null.yml
|
||||
- include: custom_perl_json_args_module.yml
|
||||
- include: custom_perl_want_json_module.yml
|
||||
- include: custom_python_json_args_module.yml
|
||||
- include: custom_python_new_style_missing_interpreter.yml
|
||||
- include: custom_python_new_style_module.yml
|
||||
- include: custom_python_want_json_module.yml
|
||||
- include: custom_script_interpreter.yml
|
||||
- include: environment_isolation.yml
|
||||
- include: etc_environment.yml
|
||||
- include: forking_active.yml
|
||||
- include: forking_correct_parent.yml
|
||||
- include: forking_inactive.yml
|
||||
- include: missing_module.yml
|
||||
|
||||
@ -1,3 +1,3 @@
|
||||
- import_playbook: config.yml
|
||||
- import_playbook: timeouts.yml
|
||||
- import_playbook: variables.yml
|
||||
- include: config.yml
|
||||
- include: timeouts.yml
|
||||
- include: variables.yml
|
||||
|
||||
@ -1 +1 @@
|
||||
- import_playbook: mixed_vanilla_mitogen.yml
|
||||
- include: mixed_vanilla_mitogen.yml
|
||||
|
||||
@ -1,7 +1,7 @@
|
||||
- import_playbook: kubectl.yml
|
||||
- import_playbook: lxc.yml
|
||||
- import_playbook: lxd.yml
|
||||
- import_playbook: mitogen_doas.yml
|
||||
- import_playbook: mitogen_sudo.yml
|
||||
- import_playbook: setns_lxc.yml
|
||||
- import_playbook: setns_lxd.yml
|
||||
- include: kubectl.yml
|
||||
- include: lxc.yml
|
||||
- include: lxd.yml
|
||||
- include: mitogen_doas.yml
|
||||
- include: mitogen_sudo.yml
|
||||
- include: setns_lxc.yml
|
||||
- include: setns_lxd.yml
|
||||
|
||||
@ -1,2 +1,2 @@
|
||||
|
||||
- import_playbook: kubectl.yml
|
||||
- include: kubectl.yml
|
||||
|
||||
@ -1,16 +1,12 @@
|
||||
# https://github.com/dw/mitogen/issues/297
|
||||
|
||||
from __future__ import (absolute_import, division, print_function)
|
||||
__metaclass__ = type
|
||||
|
||||
from ansible.plugins.vars import BaseVarsPlugin
|
||||
import os
|
||||
|
||||
class VarsModule(BaseVarsPlugin):
|
||||
class VarsModule(object):
|
||||
def __init__(self, *args):
|
||||
super(VarsModule, self).__init__(*args)
|
||||
os.environ['EVIL_VARS_PLUGIN'] = 'YIPEEE'
|
||||
|
||||
def get_vars(self, loader, path, entities, cache=True):
|
||||
super(VarsModule, self).get_vars(loader, path, entities)
|
||||
return {}
|
||||
|
||||
@ -1,10 +1,10 @@
|
||||
- import_playbook: issue_109__target_has_old_ansible_installed.yml
|
||||
- import_playbook: issue_113__duplicate_module_imports.yml
|
||||
- import_playbook: issue_118__script_not_marked_exec.yml
|
||||
- import_playbook: issue_122__environment_difference.yml
|
||||
- import_playbook: issue_140__thread_pileup.yml
|
||||
- import_playbook: issue_152__local_action_wrong_interpreter.yml
|
||||
- import_playbook: issue_152__virtualenv_python_fails.yml
|
||||
- import_playbook: issue_154__module_state_leaks.yml
|
||||
- import_playbook: issue_177__copy_module_failing.yml
|
||||
- import_playbook: issue_332_ansiblemoduleerror_first_occurrence.yml
|
||||
- include: issue_109__target_has_old_ansible_installed.yml
|
||||
- include: issue_113__duplicate_module_imports.yml
|
||||
- include: issue_118__script_not_marked_exec.yml
|
||||
- include: issue_122__environment_difference.yml
|
||||
- include: issue_140__thread_pileup.yml
|
||||
- include: issue_152__local_action_wrong_interpreter.yml
|
||||
- include: issue_152__virtualenv_python_fails.yml
|
||||
- include: issue_154__module_state_leaks.yml
|
||||
- include: issue_177__copy_module_failing.yml
|
||||
- include: issue_332_ansiblemoduleerror_first_occurrence.yml
|
||||
|
||||
@ -0,0 +1,74 @@
|
||||
# Verify throughput over sudo and SSH at various compression levels.
|
||||
|
||||
import os
|
||||
import random
|
||||
import socket
|
||||
import subprocess
|
||||
import tempfile
|
||||
import time
|
||||
|
||||
import mitogen
|
||||
import mitogen.service
|
||||
|
||||
|
||||
def prepare():
|
||||
pass
|
||||
|
||||
|
||||
def transfer(context, path):
|
||||
fp = open('/dev/null', 'wb')
|
||||
mitogen.service.FileService.get(context, path, fp)
|
||||
fp.close()
|
||||
|
||||
|
||||
def fill_with_random(fp, size):
|
||||
n = 0
|
||||
s = os.urandom(1048576*16)
|
||||
while n < size:
|
||||
fp.write(s)
|
||||
n += len(s)
|
||||
|
||||
|
||||
def run_test(router, fp, s, context):
|
||||
fp.seek(0, 2)
|
||||
size = fp.tell()
|
||||
print('Testing %s...' % (s,))
|
||||
context.call(prepare)
|
||||
t0 = time.time()
|
||||
context.call(transfer, router.myself(), fp.name)
|
||||
t1 = time.time()
|
||||
print('%s took %.2f ms to transfer %.2f MiB, %.2f MiB/s' % (
|
||||
s, 1000 * (t1 - t0), size / 1048576.0,
|
||||
(size / (t1 - t0) / 1048576.0),
|
||||
))
|
||||
|
||||
|
||||
@mitogen.main()
|
||||
def main(router):
|
||||
bigfile = tempfile.NamedTemporaryFile()
|
||||
fill_with_random(bigfile, 1048576*512)
|
||||
|
||||
file_service = mitogen.service.FileService(router)
|
||||
pool = mitogen.service.Pool(router, ())
|
||||
file_service.register(bigfile.name)
|
||||
pool.add(file_service)
|
||||
try:
|
||||
context = router.local()
|
||||
run_test(router, bigfile, 'local()', context)
|
||||
context.shutdown(wait=True)
|
||||
|
||||
context = router.sudo()
|
||||
run_test(router, bigfile, 'sudo()', context)
|
||||
context.shutdown(wait=True)
|
||||
|
||||
context = router.ssh(hostname='localhost', compression=False)
|
||||
run_test(router, bigfile, 'ssh(compression=False)', context)
|
||||
context.shutdown(wait=True)
|
||||
|
||||
context = router.ssh(hostname='localhost', compression=True)
|
||||
run_test(router, bigfile, 'ssh(compression=True)', context)
|
||||
context.shutdown(wait=True)
|
||||
finally:
|
||||
pool.stop()
|
||||
bigfile.close()
|
||||
|
||||
@ -0,0 +1 @@
|
||||
*.tar.bz2 filter=lfs diff=lfs merge=lfs -text
|
||||
@ -1,9 +0,0 @@
|
||||
|
||||
# https://www.toofishes.net/blog/trouble-sudoers-or-last-entry-wins/
|
||||
%mitogen__sudo_nopw ALL=(ALL:ALL) NOPASSWD:ALL
|
||||
mitogen__has_sudo_nopw ALL = (mitogen__pw_required) ALL
|
||||
mitogen__has_sudo_nopw ALL = (mitogen__require_tty_pw_required) ALL
|
||||
|
||||
Defaults>mitogen__pw_required targetpw
|
||||
Defaults>mitogen__require_tty requiretty
|
||||
Defaults>mitogen__require_tty_pw_required requiretty,targetpw
|
||||
@ -0,0 +1,6 @@
|
||||
|
||||
|
||||
def ping(*args):
|
||||
return args
|
||||
|
||||
|
||||
@ -0,0 +1,3 @@
|
||||
version https://git-lfs.github.com/spec/v1
|
||||
oid sha256:123ddbd9055745d37e8f14bf1c8352541ff4d500e6daa4aa3165e604fb7e8b6a
|
||||
size 6176131
|
||||
@ -0,0 +1,32 @@
|
||||
#!/bin/bash
|
||||
# Build the tests/data/ubuntu-python-2.4.6.tar.bz2 tarball.
|
||||
|
||||
set -ex
|
||||
|
||||
[ "" ] && {
|
||||
wget -cO setuptools-1.4.2.tar.gz https://files.pythonhosted.org/packages/source/s/setuptools/setuptools-1.4.2.tar.gz
|
||||
wget -cO ez_setup.py https://raw.githubusercontent.com/pypa/setuptools/bootstrap-py24/ez_setup.py
|
||||
wget -cO simplejson-2.0.9.tar.gz https://github.com/simplejson/simplejson/archive/v2.0.9.tar.gz
|
||||
wget -cO psutil-2.1.3.tar.gz https://github.com/giampaolo/psutil/archive/release-2.1.3.tar.gz
|
||||
wget -cO unittest2-0.5.1.zip http://voidspace.org.uk/downloads/unittest2-0.5.1-python2.3.zip
|
||||
wget -cO cpython-2.4.6.tar.gz https://github.com/python/cpython/archive/v2.4.6.tar.gz
|
||||
wget -cO mock-0.8.0.tar.gz https://github.com/testing-cabal/mock/archive/0.8.0.tar.gz
|
||||
|
||||
tar xzvf cpython-2.4.6.tar.gz
|
||||
}
|
||||
|
||||
(
|
||||
cd cpython-2.4.6
|
||||
./configure --prefix=/usr/local/python2.4.6 --with-pydebug --enable-debug CFLAGS="-g -O0" # --enable-debug
|
||||
echo 'zlib zlibmodule.c -I$(prefix)/include -L$(exec_prefix)/lib -lz' >> Modules/Setup.config
|
||||
make -j 8
|
||||
sudo make install
|
||||
)
|
||||
|
||||
sudo /usr/local/python2.4.6/bin/python2.4 ez_setup.py
|
||||
sudo /usr/local/python2.4.6/bin/easy_install psutil-2.1.3.tar.gz
|
||||
sudo /usr/local/python2.4.6/bin/easy_install simplejson-2.0.9.tar.gz
|
||||
sudo /usr/local/python2.4.6/bin/easy_install unittest2-0.5.1.zip
|
||||
sudo /usr/local/python2.4.6/bin/easy_install mock-0.8.0.tar.gz
|
||||
sudo find /usr/local/python2.4.6 -name '*.py[co]' -delete
|
||||
tar jcvf ubuntu-python-2.4.6.tar.bz2 /usr/local/python2.4.6
|
||||
@ -0,0 +1,103 @@
|
||||
|
||||
import testlib
|
||||
import unittest2
|
||||
|
||||
import mitogen.core
|
||||
from mitogen.core import b
|
||||
|
||||
|
||||
class BytesPartitionTest(testlib.TestCase):
|
||||
func = staticmethod(mitogen.core.bytes_partition)
|
||||
|
||||
def test_no_sep(self):
|
||||
left, sep, right = self.func(b('dave'), b('x'))
|
||||
self.assertTrue(isinstance(left, mitogen.core.BytesType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.BytesType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.BytesType))
|
||||
self.assertEquals(left, b('dave'))
|
||||
self.assertEquals(sep, b(''))
|
||||
self.assertEquals(right, b(''))
|
||||
|
||||
def test_one_sep(self):
|
||||
left, sep, right = self.func(b('davexdave'), b('x'))
|
||||
self.assertTrue(isinstance(left, mitogen.core.BytesType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.BytesType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.BytesType))
|
||||
self.assertEquals(left, b('dave'))
|
||||
self.assertEquals(sep, b('x'))
|
||||
self.assertEquals(right, b('dave'))
|
||||
|
||||
def test_two_seps(self):
|
||||
left, sep, right = self.func(b('davexdavexdave'), b('x'))
|
||||
self.assertTrue(isinstance(left, mitogen.core.BytesType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.BytesType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.BytesType))
|
||||
self.assertEquals(left, b('dave'))
|
||||
self.assertEquals(sep, b('x'))
|
||||
self.assertEquals(right, b('davexdave'))
|
||||
|
||||
|
||||
class StrPartitionTest(testlib.TestCase):
|
||||
func = staticmethod(mitogen.core.str_partition)
|
||||
|
||||
def test_no_sep(self):
|
||||
left, sep, right = self.func(u'dave', u'x')
|
||||
self.assertTrue(isinstance(left, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.UnicodeType))
|
||||
self.assertEquals(left, u'dave')
|
||||
self.assertEquals(sep, u'')
|
||||
self.assertEquals(right, u'')
|
||||
|
||||
def test_one_sep(self):
|
||||
left, sep, right = self.func(u'davexdave', u'x')
|
||||
self.assertTrue(isinstance(left, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.UnicodeType))
|
||||
self.assertEquals(left, u'dave')
|
||||
self.assertEquals(sep, u'x')
|
||||
self.assertEquals(right, u'dave')
|
||||
|
||||
def test_two_seps(self):
|
||||
left, sep, right = self.func(u'davexdavexdave', u'x')
|
||||
self.assertTrue(isinstance(left, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.UnicodeType))
|
||||
self.assertEquals(left, u'dave')
|
||||
self.assertEquals(sep, u'x')
|
||||
self.assertEquals(right, u'davexdave')
|
||||
|
||||
|
||||
class StrRpartitionTest(testlib.TestCase):
|
||||
func = staticmethod(mitogen.core.str_rpartition)
|
||||
|
||||
def test_no_sep(self):
|
||||
left, sep, right = self.func(u'dave', u'x')
|
||||
self.assertTrue(isinstance(left, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.UnicodeType))
|
||||
self.assertEquals(left, u'')
|
||||
self.assertEquals(sep, u'')
|
||||
self.assertEquals(right, u'dave')
|
||||
|
||||
def test_one_sep(self):
|
||||
left, sep, right = self.func(u'davexdave', u'x')
|
||||
self.assertTrue(isinstance(left, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.UnicodeType))
|
||||
self.assertEquals(left, u'dave')
|
||||
self.assertEquals(sep, u'x')
|
||||
self.assertEquals(right, u'dave')
|
||||
|
||||
def test_two_seps(self):
|
||||
left, sep, right = self.func(u'davexdavexdave', u'x')
|
||||
self.assertTrue(isinstance(left, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(sep, mitogen.core.UnicodeType))
|
||||
self.assertTrue(isinstance(right, mitogen.core.UnicodeType))
|
||||
self.assertEquals(left, u'davexdave')
|
||||
self.assertEquals(sep, u'x')
|
||||
self.assertEquals(right, u'dave')
|
||||
|
||||
|
||||
if __name__ == '__main__':
|
||||
unittest2.main()
|
||||
Loading…
Reference in New Issue