summaryrefslogtreecommitdiffstats
path: root/lib/bb
diff options
context:
space:
mode:
authorRichard Purdie <richard.purdie@linuxfoundation.org>2011-06-08 13:11:11 +0100
committerRichard Purdie <richard.purdie@linuxfoundation.org>2011-06-08 13:11:11 +0100
commitc30c1349db85c0cf777fc48915c6ecdfd5a8a7e4 (patch)
tree9a393973c788dac5020b26a30906ce67509319b1 /lib/bb
parentd21d5954d0c08b1c80b72c5f37becc2e58ec916a (diff)
downloadbitbake-c30c1349db85c0cf777fc48915c6ecdfd5a8a7e4.tar.gz
bitbake/server: Add the none server back for now
Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
Diffstat (limited to 'lib/bb')
-rw-r--r--lib/bb/server/none.py203
1 files changed, 203 insertions, 0 deletions
diff --git a/lib/bb/server/none.py b/lib/bb/server/none.py
new file mode 100644
index 000000000..3be7b1daf
--- /dev/null
+++ b/lib/bb/server/none.py
@@ -0,0 +1,203 @@
+#
+# BitBake 'dummy' Passthrough Server
+#
+# Copyright (C) 2006 - 2007 Michael 'Mickey' Lauer
+# Copyright (C) 2006 - 2008 Richard Purdie
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License version 2 as
+# published by the Free Software Foundation.
+#
+# 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.
+
+"""
+ This module implements a passthrough server for BitBake.
+
+ Use register_idle_function() to add a function which the server
+ calls from within idle_commands when no requests are pending. Make sure
+ that those functions are non-blocking or else you will introduce latency
+ in the server's main loop.
+"""
+
+import time
+import bb
+import signal
+
+DEBUG = False
+
+import inspect, select
+
+class BitBakeServerCommands():
+ def __init__(self, server):
+ self.server = server
+
+ def runCommand(self, command):
+ """
+ Run a cooker command on the server
+ """
+ #print "Running Command %s" % command
+ return self.cooker.command.runCommand(command)
+
+ def terminateServer(self):
+ """
+ Trigger the server to quit
+ """
+ self.server.server_exit()
+ #print "Server (cooker) exitting"
+ return
+
+ def ping(self):
+ """
+ Dummy method which can be used to check the server is still alive
+ """
+ return True
+
+eventQueue = []
+
+class BBUIEventQueue:
+ class event:
+ def __init__(self, parent):
+ self.parent = parent
+ @staticmethod
+ def send(event):
+ bb.server.none.eventQueue.append(event)
+ @staticmethod
+ def quit():
+ return
+
+ def __init__(self, BBServer):
+ self.eventQueue = bb.server.none.eventQueue
+ self.BBServer = BBServer
+ self.EventHandle = bb.event.register_UIHhandler(self)
+
+ def __popEvent(self):
+ if len(self.eventQueue) == 0:
+ return None
+ return self.eventQueue.pop(0)
+
+ def getEvent(self):
+ if len(self.eventQueue) == 0:
+ self.BBServer.idle_commands(0)
+ return self.__popEvent()
+
+ def waitEvent(self, delay):
+ event = self.__popEvent()
+ if event:
+ return event
+ self.BBServer.idle_commands(delay)
+ return self.__popEvent()
+
+ def queue_event(self, event):
+ self.eventQueue.append(event)
+
+ def system_quit( self ):
+ bb.event.unregister_UIHhandler(self.EventHandle)
+
+# Dummy signal handler to ensure we break out of sleep upon SIGCHLD
+def chldhandler(signum, stackframe):
+ pass
+
+class BitBakeNoneServer():
+ # remove this when you're done with debugging
+ # allow_reuse_address = True
+
+ def __init__(self):
+ self._idlefuns = {}
+ self.commands = BitBakeServerCommands(self)
+
+ def addcooker(self, cooker):
+ self.cooker = cooker
+ self.commands.cooker = cooker
+
+ def register_idle_function(self, function, data):
+ """Register a function to be called while the server is idle"""
+ assert hasattr(function, '__call__')
+ self._idlefuns[function] = data
+
+ def idle_commands(self, delay):
+ #print "Idle queue length %s" % len(self._idlefuns)
+ #print "Idle timeout, running idle functions"
+ #if len(self._idlefuns) == 0:
+ nextsleep = delay
+ for function, data in self._idlefuns.items():
+ try:
+ retval = function(self, data, False)
+ #print "Idle function returned %s" % (retval)
+ if retval is False:
+ del self._idlefuns[function]
+ elif retval is True:
+ nextsleep = None
+ elif nextsleep is None:
+ continue
+ elif retval < nextsleep:
+ nextsleep = retval
+ except SystemExit:
+ raise
+ except:
+ import traceback
+ traceback.print_exc()
+ self.commands.runCommand(["stateShutdown"])
+ pass
+ if nextsleep is not None:
+ #print "Sleeping for %s (%s)" % (nextsleep, delay)
+ signal.signal(signal.SIGCHLD, chldhandler)
+ time.sleep(nextsleep)
+ signal.signal(signal.SIGCHLD, signal.SIG_DFL)
+
+ def server_exit(self):
+ # Tell idle functions we're exiting
+ for function, data in self._idlefuns.items():
+ try:
+ retval = function(self, data, True)
+ except:
+ pass
+
+class BitBakeServerConnection():
+ def __init__(self, server):
+ self.server = server.server
+ self.connection = self.server.commands
+ self.events = bb.server.none.BBUIEventQueue(self.server)
+ for event in bb.event.ui_queue:
+ self.events.queue_event(event)
+
+ def terminate(self):
+ try:
+ self.events.system_quit()
+ except:
+ pass
+ try:
+ self.connection.terminateServer()
+ except:
+ pass
+
+class BitBakeServer(object):
+ def initServer(self):
+ self.server = BitBakeNoneServer()
+
+ def addcooker(self, cooker):
+ self.cooker = cooker
+ self.server.addcooker(cooker)
+
+ def getServerIdleCB(self):
+ return self.server.register_idle_function
+
+ def saveConnectionDetails(self):
+ return
+
+ def detach(self, cooker_logfile):
+ self.logfile = cooker_logfile
+
+ def establishConnection(self):
+ self.connection = BitBakeServerConnection(self)
+ return self.connection
+
+ def launchUI(self, uifunc, *args):
+ return bb.cooker.server_main(self.cooker, uifunc, *args)
+