# Copyright (C) 2013 INRIA
#
# This program is free software: you can redistribute it and/or modify
-# it under the terms of the GNU General Public License as published by
-# the Free Software Foundation, either version 3 of the License, or
-# (at your option) any later version.
+# it under the terms of the GNU General Public License version 2 as
+# published by the Free Software Foundation;
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
@clsinit_copy
class Collector(ResourceManager):
- """ The collector is reponsible of collecting traces
+ """ The collector entity is reponsible of collecting traces
of a same type associated to RMs into a local directory.
.. class:: Class Args :
_help = "A Collector can be attached to a trace name on another " \
"ResourceManager and will retrieve and store the trace content " \
"in a local file at the end of the experiment"
- _backend_type = "all"
+ _platform = "all"
@classmethod
def _register_attributes(cls):
- trace_name = Attribute("traceName", "Name of the trace to be collected",
+ trace_name = Attribute("traceName",
+ "Name of the trace to be collected",
flags = Flags.Design)
- store_dir = Attribute("storeDir", "Path to local directory to store trace results",
- default = tempfile.gettempdir(),
- flags = Flags.Design)
- sub_dir = Attribute("subDir", "Sub directory to collect traces into",
+
+ sub_dir = Attribute("subDir",
+ "Sub directory to collect traces into",
flags = Flags.Design)
- rename = Attribute("rename", "Name to give to the collected trace file",
+
+ rename = Attribute("rename",
+ "Name to give to the collected trace file",
flags = Flags.Design)
cls._register_attribute(trace_name)
- cls._register_attribute(store_dir)
cls._register_attribute(sub_dir)
cls._register_attribute(rename)
msg = "No traceName was specified"
self.error(msg)
- raise RuntimeError, msg
+ raise RuntimeError(msg)
- store_dir = self.get("storeDir")
- self._store_path = os.path.join(store_dir, self.ec.exp_id, self.ec.run_id)
+ self._store_path = self.ec.run_dir
subdir = self.get("subDir")
if subdir:
- self._store_path = os.path.join(self._store_path, subdir)
+ self._store_path = os.path.join(self.store_path, subdir)
msg = "Creating local directory at %s to store %s traces " % (
- store_dir, trace_name)
+ self.store_path, trace_name)
self.info(msg)
try:
rms = self.get_connected()
for rm in rms:
- result = self.ec.trace(rm.guid, trace_name)
fpath = os.path.join(self.store_path, "%d.%s" % (rm.guid,
- rename))
+ rename))
+
try:
- f = open(fpath, "w")
- f.write(result)
- f.close()
+ result = self.ec.trace(rm.guid, trace_name)
+ with open(fpath, "w") as f:
+ f.write(result)
except:
+ import traceback
+ err = traceback.format_exc()
msg = "Couldn't retrieve trace %s for %d at %s " % (trace_name,
rm.guid, fpath)
- self.error(msg)
+ self.error(msg, out = "", err = err)
continue
super(Collector, self).do_release()