# Path: flumotion/common/log.py
# def init():


import time
import gst
from twisted.internet import reactor, defer
from flumotion.common import log
from flumotion.common.poller import Poller
                            considered inactive, taking the name of the
                            monitor.
        @type  setInactive: callable
        """
        self._last_data_time = -1 # system time in epoch secs of last reception
        self._pad = pad
        self.name = name
        self._active = False
        self._first = True
        self._running = True

        self._doSetActive = []
        self._doSetInactive = []
        self.addWatch(setActive, setInactive)

        # This dict sillyness is because python's dict operations are atomic
        # w.r.t. the GIL.
        self._probe_id = {}

        self.check_poller = Poller(self._probe_timeout,
                                   self.PAD_MONITOR_PROBE_INTERVAL,
                                   immediately=True)

        self.watch_poller = Poller(self._check_timeout,
                                   self.PAD_MONITOR_CHECK_INTERVAL)

    def logMessage(self, message, *args):
        if self._first:
            self.debug(message, *args)
        else:

# Path: flumotion/common/log.py
# def init():


# Path: flumotion/component/padmonitor.py
import time
import gst
from twisted.internet import reactor, defer
from flumotion.common import log
from flumotion.common.poller import Poller

                            considered inactive, taking the name of the
                            monitor.
        @type  setInactive: callable
        """
        self._last_data_time = -1 # system time in epoch secs of last reception
        self._pad = pad
        self.name = name
        self._active = False
        self._first = True
        self._running = True

        self._doSetActive = []
        self._doSetInactive = []
        self.addWatch(setActive, setInactive)

        # This dict sillyness is because python's dict operations are atomic
        # w.r.t. the GIL.
        self._probe_id = {}

        self.check_poller = Poller(self._probe_timeout,
                                   self.PAD_MONITOR_PROBE_INTERVAL,
                                   immediately=True)

        self.watch_poller = Poller(self._check_timeout,
                                   self.PAD_MONITOR_CHECK_INTERVAL)

    def logMessage(self, message, *args):
        if self._first:
            self.debug(message, *args)
        else:

            self.log(message, *args)