Watcher. More...

Public Member Functions
def	__init__
def	get_watch_loop_period
def	set_watch_loop_period
def	start
Public Attributes
	trigger_update
Private Member Functions
def	_sleep
Private Attributes
	_default_watch_loop_period
	_flipped_interface
	_gateway
	_hub_manager
	_hubs
	_internal_sleep_period
	_last_loop_timestamp
	_master
	_pulled_interface
	_trigger_shutdown
	_watch_loop_period

Detailed Description

Watcher.

  This used to be on a thread of its own, but now moved into
  the gateway's main thread for running.

Definition at line 19 of file watcher_thread.py.

Constructor & Destructor Documentation

def rocon_gateway.watcher_thread.WatcherThread.__init__	(	self,
		gateway,
		watch_loop_period
	)

Definition at line 26 of file watcher_thread.py.

Member Function Documentation

def rocon_gateway.watcher_thread.WatcherThread._sleep ( self ) [private]

  Internal non-interruptible sleep loop to check for shutdown and update triggers.
  This lets us set a really long watch_loop update if we wish.

Definition at line 82 of file watcher_thread.py.

def rocon_gateway.watcher_thread.WatcherThread.get_watch_loop_period ( self )

  Use Duration's to_sec() method to convert this to float.

  @return the watcher loop period.
  @rtype float

Definition at line 50 of file watcher_thread.py.

def rocon_gateway.watcher_thread.WatcherThread.set_watch_loop_period	(	self,
		period
	)

  This is used via the gateway node service to configure the rate of the
  watcher thread. If not positive, it will reset to the default.

  @param period : new setting in seconds
  @type float

Definition at line 40 of file watcher_thread.py.

def rocon_gateway.watcher_thread.WatcherThread.start ( self )

  The watcher thread - monitors both the local master's system state (list of connections)
  and the various rules to make sure rules and existing connections or flips are in sync.

Definition at line 59 of file watcher_thread.py.