Catastrophe.py 文件源码

def process(self, nodemeta, timestamp, data, description):

        if self._job.getdata('perf')['active'] != True:
            self._error = ProcessingError.RAW_COUNTER_UNAVAILABLE
            return False

        if len(data[0]) == 0:
            # Ignore datapoints where no data stored
            return True

        if nodemeta.nodename not in self._data:
            self._data[nodemeta.nodename] = {"x": [], "t": []}

        info = self._data[nodemeta.nodename]
        info['x'].append(1.0 * numpy.sum(data[0]))
        info['t'].append(timestamp)

        if len(info['x']) > 1:
            if numpy.any(info['x'][-1] - info['x'][-2] < 0.0):
                self._error = ProcessingError.PMDA_RESTARTED_DURING_JOB
                return False

        return True