X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fthird_party%2Fwebpagereplay%2Fservermanager.py;h=d9c3623abf212133cb683fb763924b79dcc127de;hb=ff3e2503a20db9193d323c1d19c38c68004dec4a;hp=2fe0281dccb4272ab33ef6b7e7e898b260c36787;hpb=7338fba38ba696536d1cc9d389afd716a6ab2fe6;p=platform%2Fframework%2Fweb%2Fcrosswalk.git

diff --git a/src/third_party/webpagereplay/servermanager.py b/src/third_party/webpagereplay/servermanager.py
index 2fe0281..d9c3623 100644
--- a/src/third_party/webpagereplay/servermanager.py
+++ b/src/third_party/webpagereplay/servermanager.py
@@ -33,6 +33,7 @@ class ServerManager(object):
     self.initializers = []
     self.record_callbacks = []
     self.replay_callbacks = []
+    self.traffic_shapers = []
     self.is_record_mode = is_record_mode
     self.should_exit = False
 
@@ -50,6 +51,17 @@ class ServerManager(object):
     """
     self.initializers.append((initializer, init_args, init_kwargs))
 
+  def AppendTrafficShaper(self, initializer, *init_args, **init_kwargs):
+    """Append a traffic shaper to the end of the list to run.
+
+    Args:
+      initializer: a function that returns a server instance.
+          A server needs to implement the with-statement interface.
+      init_args: positional arguments for the initializer.
+      init_args: keyword arguments for the initializer.
+    """
+    self.traffic_shapers.append((initializer, init_args, init_kwargs))
+
   def AppendRecordCallback(self, func):
     """Append a function to the list to call when switching to record mode.
 
@@ -91,6 +103,7 @@ class ServerManager(object):
       any exception raised by the servers
     """
     server_exits = []
+    server_ports = []
     exception_info = (None, None, None)
     try:
       for initializer, init_args, init_kwargs in self.initializers:
@@ -98,6 +111,14 @@ class ServerManager(object):
         if server:
           server_exits.insert(0, server.__exit__)
           server.__enter__()
+          if hasattr(server, 'server_port'):
+            server_ports.append(server.server_port)
+      for initializer, init_args, init_kwargs in self.traffic_shapers:
+        init_kwargs['ports'] = server_ports
+        shaper = initializer(*init_args, **init_kwargs)
+        if server:
+          server_exits.insert(0, shaper.__exit__)
+          shaper.__enter__()
       while True:
         time.sleep(1)
         if self.should_exit: