c211319ae8
- Pass maintainership to submitter. PR: ports/179100 Submitted by: Chenguang Li <horus.li gmail.com>
42 lines
999 B
Python
42 lines
999 B
Python
--- ./src/txamqp/codec.py.orig 2009-08-16 19:25:45.000000000 +0800
|
|
+++ ./src/txamqp/codec.py 2013-05-30 13:54:50.000000000 +0800
|
|
@@ -25,12 +25,12 @@
|
|
"""
|
|
|
|
from cStringIO import StringIO
|
|
-from struct import *
|
|
+from struct import pack, calcsize, unpack
|
|
|
|
class EOF(Exception):
|
|
pass
|
|
|
|
-class Codec:
|
|
+class Codec(object):
|
|
|
|
def __init__(self, stream):
|
|
self.stream = stream
|
|
@@ -153,6 +153,13 @@
|
|
def decode_longstr(self):
|
|
return self.dec_str("!L")
|
|
|
|
+ # timestamp
|
|
+ def encode_timestamp(self, o):
|
|
+ self.pack("!Q", o)
|
|
+
|
|
+ def decode_timestamp(self):
|
|
+ return self.unpack("!Q")
|
|
+
|
|
# table
|
|
def encode_table(self, tbl):
|
|
enc = StringIO()
|
|
@@ -180,6 +187,10 @@
|
|
value = self.decode_longstr()
|
|
elif type == "I":
|
|
value = self.decode_long()
|
|
+ elif type == "F":
|
|
+ value = self.decode_table()
|
|
+ elif type == "t":
|
|
+ value = (self.decode_octet() != 0)
|
|
else:
|
|
raise ValueError(repr(type))
|
|
result[key] = value
|