mitmproxy/libmproxy/controller.py

# Copyright (C) 2010  Aldo Cortesi
# 
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
# 
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
# 
# You should have received a copy of the GNU General Public License
# along with this program.  If not, see <http://www.gnu.org/licenses/>.

import sys
import Queue, threading

exit = False

#begin nocover

class Msg:
    def __init__(self):
        self.q = Queue.Queue()
        self.acked = False

    def ack(self, data=False):
        self.acked = True
        if data is None:
            self.q.put(data)
        else:
            self.q.put(data or self)

    def send(self, masterq):
        self.acked = False
        try:
            masterq.put(self, timeout=3)
            while not exit:
                try:
                    g = self.q.get(timeout=0.5)
                except Queue.Empty:
                    continue
                return g
        except (Queue.Empty, Queue.Full):
            return None


class Slave(threading.Thread):
    def __init__(self, masterq, server):
        self.masterq, self.server = masterq, server
        self.server.set_mqueue(masterq)
        threading.Thread.__init__(self)

    def run(self):
        self.server.serve_forever()


class Master:
    def __init__(self, server):
        self.server = server
        self.masterq = None

    def tick(self, q):
        try:
            # This endless loop runs until the 'Queue.Empty'
            # exception is thrown. If more than one request is in
            # the queue, this speeds up every request by 0.1 seconds,
            # because get_input(..) function is not blocking.
            while True:
                # Small timeout to prevent pegging the CPU
                msg = q.get(timeout=0.01)
                self.handle(msg)
        except Queue.Empty:
            pass

    def run(self):
        q = Queue.Queue()
        self.masterq = q
        slave = Slave(q, self.server)
        slave.start()
        while not exit:
            self.tick(q)
        self.shutdown()

    def handle(self, msg):
        c = "handle_" + msg.__class__.__name__.lower()
        m = getattr(self, c, None)
        if m:
            m(msg)
        else:
            msg.ack()

    def shutdown(self):
        global exit
        if not exit:
            exit = True
            if self.server:
                self.server.shutdown()