Package Products :: Package DataCollector :: Module ApplyDataMap :: Class ApplyDataMapThread |
[hide private]
[frames] | no frames]

# Class ApplyDataMapThread

source code

            object --+
                     |
    threading._Verbose --+
                         |
          threading.Thread --+
                             |
                object --+   |
                         |   |
              ApplyDataMap --+
                             |
                            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.

Instance Methods | [hide private]
__init__(self, datacollector, app) | source code
processClient(self, device, collectorClient) Apply datamps to device. | source code
run(self) Process collectorClients as they are passed in from a data collector. | source code
stop(self) Stop the thread once all devices are processed. | source code
Inherited from `threading.Thread`: `__repr__`, `daemon`, `getName`, `ident`, `isAlive`, `isDaemon`, `is_alive`, `join`, `name`, `setDaemon`, `setName`, `start` Inherited from `threading.Thread` (private): `_block`, `_reset_internal_locks`, `_set_daemon`, `_set_ident` Inherited from `threading._Verbose` (private): `_note` Inherited from `ApplyDataMap`: `applyDataMap`, `logChange`, `logEvent`, `setDeviceClass` Inherited from `ApplyDataMap` (private): `_applyDataMap`, `_createRelObject`, `_updateObject`, `_updateRelationship`

Method Details | [hide private]

### __init__(self, datacollector, app) (Constructor) | source code
Overrides: ApplyDataMap.__init__

### processClient(self, device, collectorClient) | source code
Apply datamps to device. Parameters: `device` - DMD device object `collectorClient` - results of modeling Overrides: ApplyDataMap.processClient

### run(self) | source code
Process collectorClients as they are passed in from a data collector. Overrides: threading.Thread.run

### stop(self) | source code
Stop the thread once all devices are processed. Overrides: ApplyDataMap.stop