From 908c28bab89525250172a4013667319942846065 Mon Sep 17 00:00:00 2001
From: mkaay <mkaay@mkaay.de>
Date: Sun, 13 Feb 2011 15:06:03 +0100
Subject: fixes + improvements

---
 module/remote/thriftbackend/Transport.py | 15 +++++++++++++++
 1 file changed, 15 insertions(+)
 create mode 100644 module/remote/thriftbackend/Transport.py

(limited to 'module/remote/thriftbackend/Transport.py')

diff --git a/module/remote/thriftbackend/Transport.py b/module/remote/thriftbackend/Transport.py
new file mode 100644
index 000000000..50638f461
--- /dev/null
+++ b/module/remote/thriftbackend/Transport.py
@@ -0,0 +1,15 @@
+# -*- coding: utf-8 -*-
+
+from thrift.transport.TTransport import TBufferedTransport
+
+class Transport(TBufferedTransport):
+    DEFAULT_BUFFER = 4096
+
+    def __init__(self, trans, rbuf_size = DEFAULT_BUFFER):
+        TBufferedTransport.__init__(self, trans, rbuf_size)
+        self.remoteaddr = trans.handle.getpeername()
+
+class TransportFactory:
+    def getTransport(self, trans):
+        buffered = Transport(trans)
+        return buffered
-- 
cgit v1.2.3