1 files changed, 99 insertions, 0 deletions
diff --git a/morphlib/buildworker.py b/morphlib/buildworker.py
new file mode 100644
index 00000000..ad951466
--- /dev/null
+++ b/morphlib/buildworker.py
@@ -0,0 +1,99 @@
+# Copyright (C) 2012  Codethink Limited
+# 
+# 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; version 2 of the License.
+# 
+# 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, write to the Free Software Foundation, Inc.,
+# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+
+
+import datetime
+from multiprocessing import Manager, Process
+
+import morphlib
+
+
+class BuildWorker(object):
+
+    def __init__(self, name, app):
+        self.name = name
+        self.settings = app.settings
+        self.real_msg = app.msg
+        self.indent = 2
+        self.idle_since = datetime.datetime.now()
+
+    def __str__(self):
+        return self.name
+
+    def indent_more(self):
+        self.indent += 1
+
+    def indent_less(self):
+        self.indent -= 1
+
+    def msg(self, text):
+        spaces = '  ' * self.indent
+        self.real_msg('%s%s' % (spaces, text))
+
+    def build(self, blob):
+        raise NotImplementedError
+
+    def check_complete(self, timeout):
+        raise NotImplementedError
+
+
+class LocalBuildWorker(BuildWorker):
+
+    def __init__(self, name, app):
+        BuildWorker.__init__(self, name, app)
+        self.manager = Manager()
+        self.reset()
+
+    def reset(self):
+        self.process = None
+        self.blob = None
+        self._output = self.manager.list()
+
+    def run(self, repo, ref, filename, output):
+        ex = morphlib.execute.Execute('.', self.msg)
+        stdout = ex.runv(['./morph', '--verbose', '--keep-path',
+                          'build', repo, ref, filename])
+        output.append(stdout)
+
+    def build(self, blob):
+        self.reset()
+        self.blob = blob
+        args = (blob.morph.treeish.original_repo,
+                blob.morph.treeish.ref,
+                blob.morph.filename,
+                self._output)
+        self.process = Process(group=None, target=self.run, args=args)
+        self.process.start()
+
+    def check_complete(self, timeout):
+        if self.process:
+            self.process.join(timeout)
+            if self.process.is_alive():
+                return False
+            else:
+                self.idle_since = datetime.datetime.now()
+                return True
+        else:
+            return True
+
+    @property
+    def output(self):
+        return self._output[0]
+
+
+class RemoteBuildWorker(BuildWorker):
+
+    def __init__(self, app):
+        BuildWorker.__init__(self, app)