[Sync] Finch Experiment : Enable compression between sync client and server

sync/tools/testserver/sync_testserver.py

 #!/usr/bin/env python
 # Copyright 2013 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 """This is a python sync server used for testing Chrome Sync.
 
 By default, it listens on an ephemeral port and xmpp_port and sends the port
 numbers back to the originating process over a pipe. The originating process can
 specify an explicit port and xmpp_port if necessary.
 """
 
 import asyncore
 import BaseHTTPServer
 import errno
+import gzip
 import os
 import select
+import StringIO
 import socket
 import sys
 import urlparse
 
 import chromiumsync
 import echo_message
 import testserver_base
 import xmppserver
 
 
@@ skipping 161 matching lines @@
     This covers all sync protocol commands: authentication, getupdates, and
     commit.
     """
 
     test_name = "/chromiumsync/command"
     if not self._ShouldHandleRequest(test_name):
       return False
 
     length = int(self.headers.getheader('content-length'))
     raw_request = self.rfile.read(length)
+    if self.headers.getheader('Content-Encoding'):
+      enocde = self.headers.getheader('Content-Encoding')

[Nicolas Zea, 2015/07/30 19:59:44]

enocde -> encode

[Gang Wu, 2015/07/31 00:39:45]

Done.

+      if enocde == "gzip":
+        raw_request = gzip.GzipFile(
+            fileobj=StringIO.StringIO(raw_request)).read()
+
     http_response = 200
     raw_reply = None
     if not self.server.GetAuthenticated():
       http_response = 401
       challenge = 'GoogleLogin realm="http://%s", service="chromiumsync"' % (
         self.server.server_address[0])
     else:
       http_response, raw_reply = self.server.HandleCommand(
           self.path, raw_request)
 
@@ skipping 345 matching lines @@
     testserver_base.TestServerRunner.add_options(self)
     self.option_parser.add_option('--xmpp-port', default='0', type='int',
                                   help='Port used by the XMPP server. If '
                                   'unspecified, the XMPP server will listen on '
                                   'an ephemeral port.')
     # Override the default logfile name used in testserver.py.
     self.option_parser.set_defaults(log_file='sync_testserver.log')
 
 if __name__ == '__main__':
   sys.exit(SyncServerRunner().main())