Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(559)

Unified Diff: lib/cros_test_proxy.py

Issue 5632002: Create a transparent proxy for test programs to use, with the (Closed) Base URL: ssh://git@gitrw.chromium.org:9222/crosutils.git@master
Patch Set: Readd comment lost in rebase. Created 10 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « image_to_live.sh ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: lib/cros_test_proxy.py
diff --git a/lib/cros_test_proxy.py b/lib/cros_test_proxy.py
new file mode 100755
index 0000000000000000000000000000000000000000..21709829c35c26049b365c35f2d6bbdab21992e9
--- /dev/null
+++ b/lib/cros_test_proxy.py
@@ -0,0 +1,113 @@
+# Copyright (c) 2010 The Chromium OS Authors. All rights reserved.
+# Use of this source code is governed by a BSD-style license that can be
+# found in the LICENSE file.
+
+import select
+import socket
+import SocketServer
+import threading
+
+class Filter(object):
+ """Base class for data filters.
+
+ Pass subclass of this to CrosTestProxy which will perform whatever
+ connection manipulation you prefer.
+ """
+
+ def setup(self):
+ """This setup method is called once per connection."""
+ pass
+
+ def InBound(self, data):
+ """This method is called once per packet of incoming data.
+
+ The value returned is what is sent through the proxy. If
+ None is returned, the connection will be closed.
+ """
+ return data
+
+ def OutBound(self, data):
+ """This method is called once per packet of outgoing data.
+
+ The value returned is what is sent through the proxy. If
+ None is returned, the connection will be closed.
+ """
+ return data
+
+
+class CrosTestProxy(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
+ """A transparent proxy for simulating network errors"""
+
+ class _Handler(SocketServer.BaseRequestHandler):
+ """Proxy connection handler that passes data though a filter"""
+
+ def setup(self):
+ """Setup is called once for each connection proxied."""
+ self.server.filter.setup()
+
+ def handle(self):
+ """Handles each incoming connection.
+
+ Opens a new connection to the port we are proxing to, then
+ passes each packet along in both directions after passing
+ them through the filter object passed in.
+ """
+ # Open outgoing socket
+ s_in = self.request
+ s_out = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ s_out.connect((self.server.address_out, self.server.port_out))
+
+ while True:
+ rlist, wlist, xlist = select.select([s_in, s_out], [], [])
+
+ if s_in in rlist:
+ data = s_in.recv(1024)
+ data = self.server.filter.InBound(data)
+ if not data: break
+ try:
+ # If there is any error sending data, close both connections.
+ s_out.sendall(data)
+ except socket.error:
+ break
+
+ if s_out in rlist:
+ data = s_out.recv(1024)
+ data = self.server.filter.OutBound(data)
+ if not data: break
+ try:
+ # If there is any error sending data, close both connections.
+ s_in.sendall(data)
+ except socket.error:
+ break
+
+ s_in.close()
+ s_out.close()
+
+ def __init__(self,
+ filter,
+ port_in=8081,
+ address_out='127.0.0.1', port_out=8080):
+ """Configures the proxy object.
+
+ Args:
+ filter: An instance of a subclass of Filter.
+ port_in: Port on which to listen for incoming connections.
+ address_out: Address to which outgoing connections will go.
+ address_port: Port to which outgoing connections will go.
+ """
+ self.port_in = port_in
+ self.address_out = address_out
+ self.port_out = port_out
+ self.filter = filter
+
+ SocketServer.TCPServer.__init__(self,
+ ('', port_in),
+ self._Handler)
+
+ def serve_forever_in_thread(self):
+ """Helper method to start the server in a new background thread."""
+ server_thread = threading.Thread(target=self.serve_forever)
+ server_thread.setDaemon(True)
+ server_thread.start()
+
+ return server_thread
« no previous file with comments | « image_to_live.sh ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698