DataCollector.ApplyDataMap.ApplyDataMapThread

Package DataCollector :: Module ApplyDataMap :: Class ApplyDataMapThread

[show private | hide private]

Type ApplyDataMapThread

    object --+    
             |    
  ApplyDataMap --+
                 |
object --+       |
         |       |
  _Verbose --+   |
             |   |
        Thread --+
                 |
                ApplyDataMapThread

Thread that applies datamaps to a device. It reads from a queue that should have tuples of (devid, datamaps) where devid is the primaryId to the device and datamps is a list of datamaps to apply. Cache is synced at the start of each transaction and there is one transaction per device.

Method Summary
	`__init__(self, datacollector, app)`
	`processClient(self, device, collectorClient)` Apply datamps to device.
	`run(self)` Process collectorClients as they are passed in from a data collector.
	`stop(self)` Stop the thread once all devices are processed.
Inherited from `Thread`: `__repr__`, `getName`, `isAlive`, `isDaemon`, `join`, `setDaemon`, `setName`, `start` Inherited from `ApplyDataMap`: `applyDataMap`, `logChange`, `logEvent` Inherited from `object`: `__delattr__`, `__getattribute__`, `__hash__`, `__new__`, `__reduce__`, `__reduce_ex__`, `__setattr__`, `__str__`

Method Details

processClient(self, device, collectorClient)

Apply datamps to device.

Overrides:: DataCollector.ApplyDataMap.ApplyDataMap.processClient

run(self)

Process collectorClients as they are passed in from a data collector.

Overrides:: threading.Thread.run

stop(self)

Stop the thread once all devices are processed.

Overrides:: DataCollector.ApplyDataMap.ApplyDataMap.stop

Generated by Epydoc 2.1 on Thu Aug 16 09:55:11 2007

http://epydoc.sf.net