From 86255826a849d7d8ced73009274a5bee909a0923 Mon Sep 17 00:00:00 2001
From: Andrew Stitcher <astitcher@apache.org>
Date: Wed, 12 Sep 2007 13:11:52 +0000
Subject: * Python: reinstated 0-8 framing in parallel with the new 0-10
 framing

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@574936 13f79535-47bb-0310-9956-ffa450edef68
---
 python/qpid/connection.py | 36 +++++++++++++++++++++++++++++++++---
 1 file changed, 33 insertions(+), 3 deletions(-)

(limited to 'python/qpid')

diff --git a/python/qpid/connection.py b/python/qpid/connection.py
index 11a0d3ec6a..3ae88979fd 100644
--- a/python/qpid/connection.py
+++ b/python/qpid/connection.py
@@ -77,7 +77,9 @@ class Connection:
     self.codec = codec.Codec(io, spec)
     self.spec = spec
     self.FRAME_END = self.spec.constants.byname["frame_end"].id
-
+    self.write = getattr(self, "write_%s_%s" % (self.spec.major, self.spec.minor))
+    self.read = getattr(self, "read_%s_%s" % (self.spec.major, self.spec.minor))
+    
   def flush(self):
     self.codec.flush()
 
@@ -89,8 +91,36 @@ class Connection:
 
   def tini(self):
     self.codec.unpack(Connection.INIT)
+  
+  def write_8_0(self, frame):
+    c = self.codec
+    c.encode_octet(self.spec.constants.byname[frame.type].id)
+    c.encode_short(frame.channel)
+    body = StringIO()
+    enc = codec.Codec(body, self.spec)
+    frame.encode(enc)
+    enc.flush()
+    c.encode_longstr(body.getvalue())
+    c.encode_octet(self.FRAME_END)
+
+  def read_8_0(self):
+    c = self.codec
+    type = self.spec.constants.byid[c.decode_octet()].name
+    channel = c.decode_short()
+    body = c.decode_longstr()
+    dec = codec.Codec(StringIO(body), self.spec)
+    frame = Frame.DECODERS[type].decode(self.spec, dec, len(body))
+    frame.channel = channel
+    end = c.decode_octet()
+    if end != self.FRAME_END:
+      garbage = ""
+      while end != self.FRAME_END:
+        garbage += chr(end)
+        end = c.decode_octet()
+      raise "frame error: expected %r, got %r" % (self.FRAME_END, garbage)
+    return frame
 
-  def write(self, frame):
+  def write_0_10(self, frame):
     c = self.codec
     c.encode_octet(0x0f) # TODO: currently fixed at ver=0, B=E=b=e=1
     c.encode_octet(self.spec.constants.byname[frame.type].id)
@@ -107,7 +137,7 @@ class Connection:
     c.write(body.getvalue())
     c.encode_octet(self.FRAME_END)
 
-  def read(self):
+  def read_0_10(self):
     c = self.codec
     flags = c.decode_octet() # TODO: currently ignoring flags
     framing_version = (flags & 0xc0) >> 6
-- 
cgit v1.2.1