(self, collectors, last_values, site=None)
| 108 | )) |
| 109 | |
| 110 | def collectDatas(self, collectors, last_values, site=None): |
| 111 | if site is None: |
| 112 | peers = self.getUniquePeers() |
| 113 | datas = {} |
| 114 | for key, collector in collectors.items(): |
| 115 | try: |
| 116 | if site: |
| 117 | value = collector(site) |
| 118 | elif key.startswith("peer"): |
| 119 | value = collector(peers) |
| 120 | else: |
| 121 | value = collector() |
| 122 | except Exception as err: |
| 123 | self.log.info("Collector %s error: %s" % (key, err)) |
| 124 | value = None |
| 125 | |
| 126 | if "|change" in key: # Store changes relative to last value |
| 127 | key = key.replace("|change", "") |
| 128 | last_value = last_values.get(key, 0) |
| 129 | last_values[key] = value |
| 130 | value = value - last_value |
| 131 | |
| 132 | if value is None: |
| 133 | datas[key] = None |
| 134 | else: |
| 135 | datas[key] = round(value, 3) |
| 136 | return datas |
| 137 | |
| 138 | def collectGlobal(self, collectors, last_values): |
| 139 | now = int(time.time()) |
no test coverage detected