Author: gsim
Date: Wed Apr 23 07:07:07 2008
New Revision: 650875
URL: http://svn.apache.org/viewvc?rev=650875&view=rev
Log:
Add support for reading 0-10 arrays; Set sync bit on session header for
commands sent with auto_sync on.
Modified:
incubator/qpid/trunk/qpid/python/qpid/codec010.py
incubator/qpid/trunk/qpid/python/qpid/session.py
Modified: incubator/qpid/trunk/qpid/python/qpid/codec010.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/codec010.py?rev=650875&r1=650874&r2=650875&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/codec010.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/codec010.py Wed Apr 23 07:07:07 2008
@@ -179,7 +179,14 @@
def write_array(self, a):
pass
def read_array(self):
- pass
+ sc = StringCodec(self.spec, self.read_vbin32())
+ type = self.spec.types[sc.read_uint8()]
+ count = sc.read_uint32()
+ result = []
+ while count:
+ result.append(type.decode(sc))
+ count = count - 1
+ return result
def read_struct32(self):
size = self.read_uint32()
Modified: incubator/qpid/trunk/qpid/python/qpid/session.py
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/qpid/session.py?rev=650875&r1=650874&r2=650875&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/qpid/session.py (original)
+++ incubator/qpid/trunk/qpid/python/qpid/session.py Wed Apr 23 07:07:07 2008
@@ -152,6 +152,7 @@
cmd = type.new(args, kwargs)
sc = StringCodec(self.spec)
hdr = Struct(self.spec["session.header"])
+ hdr.sync = self.auto_sync
sc.write_command(hdr, cmd)
seg = Segment(True, (message == None or
