You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@thrift.apache.org by ro...@apache.org on 2012/04/12 00:15:16 UTC
svn commit: r1325041 - /thrift/trunk/lib/py/src/transport/THttpClient.py
Author: roger
Date: Wed Apr 11 22:15:15 2012
New Revision: 1325041
URL: http://svn.apache.org/viewvc?rev=1325041&view=rev
Log:
THRIFT-1560 Add setCustomHeaders() method to python thrift lib
Patch: Dave Watson
Modified:
thrift/trunk/lib/py/src/transport/THttpClient.py
Modified: thrift/trunk/lib/py/src/transport/THttpClient.py
URL: http://svn.apache.org/viewvc/thrift/trunk/lib/py/src/transport/THttpClient.py?rev=1325041&r1=1325040&r2=1325041&view=diff
==============================================================================
--- thrift/trunk/lib/py/src/transport/THttpClient.py (original)
+++ thrift/trunk/lib/py/src/transport/THttpClient.py Wed Apr 11 22:15:15 2012
@@ -63,6 +63,7 @@ class THttpClient(TTransportBase):
self.__wbuf = StringIO()
self.__http = None
self.__timeout = None
+ self.__custom_headers = None
def open(self):
if self.scheme == 'http':
@@ -86,6 +87,9 @@ class THttpClient(TTransportBase):
else:
self.__timeout = ms / 1000.0
+ def setCustomHeaders(self, headers):
+ self.__custom_headers = headers
+
def read(self, sz):
return self.__http.file.read(sz)
@@ -117,6 +121,11 @@ class THttpClient(TTransportBase):
self.__http.putheader('Host', self.host)
self.__http.putheader('Content-Type', 'application/x-thrift')
self.__http.putheader('Content-Length', str(len(data)))
+
+ if self.__custom_headers:
+ for key, val in self.__custom_headers.iteritems():
+ self.__http.putheader(key, val)
+
self.__http.endheaders()
# Write payload