blob: 33692abea963e8020100602cacdd2fd22d91eef3 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
--- ./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
|
