Logo Search packages:      
Sourcecode: rabbitvcs version File versions  Download package


# Copyright (C) 2009 Jason Heeris <jason.heeris@gmail.com>
# Copyright (C) 2009 by Bruce van der Kooij <brucevdkooij@gmail.com>
# Copyright (C) 2009 by Adam Plumb <adamplumb@gmail.com>#
# RabbitVCS 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 2 of the License, or
# (at your option) any later version.
# RabbitVCS is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# GNU General Public License for more details.
# You should have received a copy of the GNU General Public License
# along with RabbitVCS;  If not, see <http://www.gnu.org/licenses/>.

""" The checker service for RabbitVCS background status checks.

This file can be run as a Python script, in which case it starts a background
VCS status checking service that can be called via DBUS. It also contains class
definitions to call these methods from within a separate Python process.

This currently works like so:

    1. Nautilus loads our extension, RabbitVCS
    2. RabbitVCS creates a StatusCheckerStub
    3. StatusCheckerStub calls start(), which is a wrapper for a more general
       service starter convenience method
    4. The service starter method looks for a DBUS object with the given service
       name and object path; if none is found, it creates it by running this
RabbitVCS can then call the stub methods, getting status info via the
CheckStatus method itself, or more likely from a callback upon completion of a
status check.

NOTE: as a general rule, the data piped between processes or sent over DBUS
should be kept to a minimum. Use convenience methods to condense and summarise
data wherever possible (this is the case in the actual status cache and checker

import os, os.path
import sys

import gobject
    # Older distributions will not have a glib module.  For them, they must
    # still use the gobject module
    import glib
    HAS_GLIB = True
except ImportError:
    HAS_GLIB = False

import dbus
import dbus.glib # FIXME: this might actually already set the default loop
    import dbus.mainloop.glib
except ImportError, e:
    # Older distributions do not have this module

import dbus.service

import rabbitvcs.util._locale
import rabbitvcs.lib.helper
import rabbitvcs.services.service
from rabbitvcs.services.statuscheckerplus import StatusCheckerPlus

from rabbitvcs.lib.log import Log
log = Log("rabbitvcs.services.checkerservice")

INTERFACE = "org.google.code.rabbitvcs.StatusChecker"
OBJECT_PATH = "/org/google/code/rabbitvcs/StatusChecker"
SERVICE = "org.google.code.rabbitvcs.RabbitVCS.Checker"
TIMEOUT = 60*15*100 # seconds

def idle_add(callback, *args, **kwargs):
    if HAS_GLIB:
        glib.idle_add(callback, *args, **kwargs)
        gobject.idle_add(callback, *args, **kwargs)

00087 class StatusCheckerService(dbus.service.Object):
    """ StatusCheckerService objects wrap a StatusCheckerPlus instance,
    exporting methods that can be called via DBUS.
    There should only be a single such object running in a separate process from
    the GUI (ie. do not create this in the Nautilus extension code, you should
    use a StatusCheckerStub there instead).
00096     def __init__(self, connection, mainloop):
        """ Creates a new status checker wrapper service, with the given DBUS
        The mainloop argument is needed for process management (eg. calling
        Quit() for graceful exiting).
        @param connection: the DBUS connection (eg. session bus, system bus)
        @type connection: a DBUS connection object
        @param mainloop: the main loop that DBUS is using
        @type mainloop: any main loop with a quit() method
        dbus.service.Object.__init__(self, connection, OBJECT_PATH)
        self.mainloop = mainloop
        # Start the status checking daemon so we can do requests in the
        # background
        self.status_checker = StatusCheckerPlus()
    def ExtraInformation(self):
        return self.status_checker.extra_info()
    def MemoryUsage(self):
        own_mem = rabbitvcs.lib.helper.process_memory(os.getpid())
        checker_mem = self.status_checker.get_memory_usage() 
        return own_mem + checker_mem
    def PID(self):
        return os.getpid()
    def CheckerType(self):
        return self.status_checker.CHECKER_NAME
00136     def CheckFinished(self, path, statuses):
        """ Empty method for connection status check callbacks. This is a DBUS
        signal, and can be "connected" to as per the python DBUS docs.
00143     def CheckStatus(self, path, recurse=False, invalidate=False,
                      summary=False, callback=False):
        """ Requests a status check from the underlying status checker.
        See the StatusCheckerPlus documentation for details of the parameters,
        but note that "callback" behaves differently. The actual callback that
        is given to the status checker is the "CheckFinished" method of this
        object, if callback is True.
        Any entity wanting notification of a completed status check should
        connect to the DBUS signal "CheckFinished", and sort out its own
        logic from there.
        @param callback: whether or not to notify when a status check is
        @type callback: boolean
        if callback:
            callback = self.CheckFinished
            callback = None
        return self.status_checker.check_status(u"" + path, recurse=recurse,
00170     def Quit(self):
        """ Quits the service, performing any necessary cleanup operations.

        You can call this from the command line with:
        dbus-send --print-reply \
        --dest=org.google.code.rabbitvcs.RabbitVCS.Checker \
        /org/google/code/rabbitvcs/StatusChecker \
        If calling this programmatically, then you can do "os.waitpid(pid, 0)"
        on the returned PID to prevent a zombie process.
        log.debug("Quitting main loop...")
        return self.PID()
00189 class StatusCheckerStub:
    """ StatusCheckerStub objects contain methods that call an actual status
    checker running in another process.
    These objects should be created by the GUI as needed (eg. the nautilus
    extension code).
    Note that even though the status checker itself takes a callback for each
    call to "check_status", this stub requires it to be provided at
    initialisation. The callback can be triggered (or not) using the boolean
    callback parameter of the "check_status" method.
    The inter-process communication is via DBUS.
00204     def __init__(self, callback=None):
        """ Creates an object that can call the VCS status checker via DBUS.
        If there is not already a DBUS object with the path "OBJECT_PATH", we
        create one by starting a new Python process that runs this file.
        @param callback: the function to call when status checks are completed
                         (see the StatusCheckerPlus method documentation for
        self.session_bus = dbus.SessionBus()
        self.callback = callback
        self.status_checker = None
    def _connect_to_checker(self):

        # Start the status checker, if it's not running this should start it up.
        # Otherwise it leaves it alone.
        # start()
        # Try to get a new checker
            self.status_checker = self.session_bus.get_object(SERVICE,
            if self.callback:
        except dbus.DBusException, ex:
            # There is not much we should do about this...
00240     def status_callback(self, *args, **kwargs):
        """ Notifies the callback of a completed status check.
        The callback will be performed when the glib main loop is idle. This is
        basically a way of making this a lower priority than direct calls to
        "check_status", which need to return ASAP.
        idle_add(self.callback, *args, **kwargs)
        # Switch to this method to just call it straight from here:
        # self.callback(*args, **kwargs)
00251     def check_status(self, path, recurse=False, invalidate=False,
                       summary=False, callback=False):
        """ Check the VCS status of the given path.
        This is a pass-through method to the check_status method of the DBUS
        service (which is, in turn, a wrapper around the real status checker). 
        status = None
            status = self.status_checker.CheckStatus(path, recurse, invalidate,
                                                     summary, callback,
            # Test client error problems :)
            # raise dbus.DBusException("Test")
        except dbus.DBusException, ex:
            status = {path: {"text_status": "error",
                             "prop_status": "error"}}
            if summary:
                status = (status, status)
            # Try to reconnect
        return status
def start():
    """ Starts the checker service, via the utility method in "service.py". """
    rabbitvcs.services.service.start_service(os.path.abspath(__file__), SERVICE,

def Main():
    """ The main point of entry for the checker service.
    This will set up the DBUS and glib extensions, the gobject/glib main loop,
    and start the service.
    global log
    log = Log("rabbitvcs.services.checkerservice:main")
    log.debug("Checker: starting service: %s (%s)" % (OBJECT_PATH, os.getpid()))
    # We need this to for the client to be able to do asynchronous calls
    # The following calls are required to make DBus thread-aware and therefore
    # support the ability run threads.
    # This registers our service name with the bus
    session_bus = dbus.SessionBus()
    service_name = dbus.service.BusName(SERVICE, session_bus)
    mainloop = gobject.MainLoop()
    checker_service = StatusCheckerService(session_bus, mainloop)
    # import cProfile
    # import rabbitvcs.lib.helper
    # profile_data_file = os.path.join(
    #                        rabbitvcs.lib.helper.get_home_folder(),
    #                        "rvcs_checker.stats")
    # cProfile.run("mainloop.run()", profile_data_file)
    idle_add(sys.stdout.write, "Started status checker service\n")
    log.debug("Checker: ended service: %s (%s)" % (OBJECT_PATH, os.getpid()))

if __name__ == "__main__":

Generated by  Doxygen 1.6.0   Back to index