diff options
| author |   Deepak S <deepak.s@linux.intel.com> | 2017-10-10 12:17:17 +0530 |
|---|---|---|
| committer |   Ross Brattain <ross.b.brattain@intel.com> | 2017-10-13 13:59:37 -0700 |
| commit | 85478cb47190b1a91b8299585f974d522faa7b1c (patch) | |
| tree | 10607d97601b41e601c1e9d19b4ba17dbd34704c /yardstick | |
| parent | f05d3844c6f43310618b62d942442b2f05f91551 (diff) | |
Enable intel_pmu plugin in collectd
Change-Id: I62c6416e5c79d0b90880985bb5c076b65e34192e
Signed-off-by: Deepak S <deepak.s@linux.intel.com>
Diffstat (limited to 'yardstick')
| -rw-r--r-- | yardstick/network_services/nfvi/resource.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/yardstick/network_services/nfvi/resource.py b/yardstick/network_services/nfvi/resource.py index a32948ae8..fef44e207 100644 --- a/yardstick/network_services/nfvi/resource.py +++ b/yardstick/network_services/nfvi/resource.py @@ -166,7 +166,7 @@ class ResourceProfile(object): res_key0 = next(res_key_iter) res_key1 = next(res_key_iter) - if "cpu" in res_key0 or "intel_rdt" in res_key0: + if "cpu" in res_key0 or "intel_rdt" in res_key0 or "intel_pmu" in res_key0: cpu_key, name, metric, testcase = \ self.get_cpu_data(res_key0, res_key1, value) result["cpu"].setdefault(cpu_key, {}).update({name: metric}) @@ -186,9 +186,6 @@ class ResourceProfile(object): elif "ovs_stats" in res_key0: result["ovs_stats"].update(self.parse_ovs_stats(key_split, value)) - elif "intel_pmu-all" in res_key0: - result["intel_pmu"].update(self.parse_intel_pmu_stats(res_key1, value)) - result["timestamp"] = testcase return result @@ -278,7 +275,10 @@ class ResourceProfile(object): connection.execute("sudo rabbitmqctl set_permissions -p / admin '.*' '.*' '.*'") LOG.debug("Start collectd service..... %s second timeout", self.timeout) - connection.execute("sudo %s" % collectd_path, timeout=self.timeout) + # intel_pmu plug requires large numbers of files open, so try to set + # ulimit -n to a large value + connection.execute("sudo bash -c 'ulimit -n 1000000 ; %s'" % collectd_path, + timeout=self.timeout) LOG.debug("Done") def initiate_systemagent(self, bin_path): |