]> git.ipfire.org Git - thirdparty/tornado.git/commitdiff
Fix for Python 2.7.
authorAndreas Røsdal <andreas.rosdal@gmail.com>
Wed, 8 Mar 2017 19:57:39 +0000 (20:57 +0100)
committerAndreas Røsdal <andreas.rosdal@gmail.com>
Wed, 8 Mar 2017 19:57:39 +0000 (20:57 +0100)
tornado/websocket.py

index 48486d5bd94fdfc1388770ae01a86dff9931103e..78549c6197394900e107bb56f7b1e044de1a69dd 100644 (file)
@@ -689,7 +689,7 @@ class WebSocketProtocol13(WebSocketProtocol):
             else:
                 raise ValueError("unsupported extension %r", ext)
 
-    def _get_compressor_options(self, side, agreed_parameters):
+    def _get_compressor_options(self, side, agreed_parameters, compression_options):
         """Converts a websocket agreed_parameters set to keyword arguments
         for our compressor objects.
         """
@@ -700,6 +700,7 @@ class WebSocketProtocol13(WebSocketProtocol):
             options['max_wbits'] = zlib.MAX_WBITS
         else:
             options['max_wbits'] = int(wbits_header)
+        options['compression_options'] = compression_options
         return options
 
     def _create_compressors(self, side, agreed_parameters, compression_options=None):
@@ -713,7 +714,7 @@ class WebSocketProtocol13(WebSocketProtocol):
                 raise ValueError("unsupported compression parameter %r" % key)
         other_side = 'client' if (side == 'server') else 'server'
         self._compressor = _PerMessageDeflateCompressor(
-            **self._get_compressor_options(side, agreed_parameters), compression_options=compression_options)
+            **self._get_compressor_options(side, agreed_parameters, compression_options))
         self._decompressor = _PerMessageDeflateDecompressor(
             **self._get_compressor_options(other_side, agreed_parameters))