aboutsummaryrefslogtreecommitdiffstats
path: root/lib/bb/server
diff options
context:
space:
mode:
authorRichard Purdie <richard.purdie@linuxfoundation.org>2013-05-28 14:28:30 +0100
committerRichard Purdie <richard.purdie@linuxfoundation.org>2013-05-28 14:28:33 +0100
commit9af03a89605e3db9bce3cea1e0f2d0b6cfaa6fe1 (patch)
tree3e67c6c0263e4ebbccce29878d1f8b00b685479c /lib/bb/server
parent64ca1aa1fd5f0473196b6cd805637fa644a92173 (diff)
downloadbitbake-contrib-9af03a89605e3db9bce3cea1e0f2d0b6cfaa6fe1.tar.gz
server: Remove none server
The process server backend has been serving well as the default for a long time now and the UI model is much better thought out that it used to be. With the move to make bitbake a memory resident process, the none server is now looking rather pointless and complicates the code needlessly. Lets therefore now remove it. Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
Diffstat (limited to 'lib/bb/server')
-rw-r--r--lib/bb/server/none.py203
1 files changed, 0 insertions, 203 deletions
diff --git a/lib/bb/server/none.py b/lib/bb/server/none.py
deleted file mode 100644
index f5fd4d4f7..000000000
--- a/lib/bb/server/none.py
+++ /dev/null
@@ -1,203 +0,0 @@
-#
-# 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):
- return
-
- def establishConnection(self):
- self.connection = BitBakeServerConnection(self)
- return self.connection
-
- def launchUI(self, uifunc, *args):
- return bb.cooker.server_main(self.cooker, uifunc, *args)
-