diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2011-03-08 18:47:39 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2011-03-08 18:47:39 +0000 |
| commit | fef19b12dca6276108213ee891c6d31327350e6f (patch) | |
| tree | 30e02155e9c84232e8b4c97091f38c3a35313882 | |
| parent | 16459edd6e4a6ab3fcc33c1a575b854efcf19487 (diff) | |
| download | qpid-python-fef19b12dca6276108213ee891c6d31327350e6f.tar.gz | |
QPID-3130: applied patch for slow codec
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/0.10@1079482 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/python/qpid/codec010.py | 17 |
1 files changed, 11 insertions, 6 deletions
diff --git a/qpid/python/qpid/codec010.py b/qpid/python/qpid/codec010.py index 0846db6bf7..94a1cd4263 100644 --- a/qpid/python/qpid/codec010.py +++ b/qpid/python/qpid/codec010.py @@ -17,7 +17,7 @@ # under the License. # -import datetime +import datetime, string from packer import Packer from datatypes import serial, timestamp, RangedSet, Struct, UUID from ops import Compound, PRIMITIVE, COMPOUND @@ -241,15 +241,20 @@ class Codec(Packer): v = sc.read_primitive(type) result[k] = v return result + + def _write_map_elem(self, k, v): + type = self.encoding(v) + sc = StringCodec() + sc.write_str8(k) + sc.write_uint8(type.CODE) + sc.write_primitive(type, v) + return sc.encoded + def write_map(self, m): sc = StringCodec() if m is not None: sc.write_uint32(len(m)) - for k, v in m.items(): - type = self.encoding(v) - sc.write_str8(k) - sc.write_uint8(type.CODE) - sc.write_primitive(type, v) + sc.write(string.joinfields(map(self._write_map_elem, m.keys(), m.values()), "")) self.write_vbin32(sc.encoded) def read_array(self): |