make the whole project more python idiomatic

* rename src directory to allocbench
* make global variable names UPPERCASE
* format a lot of code using yapf
* use lowercase ld_preload and ld_library_path as Allocator members
* name expected Errors 'err' and don't raise a new Exception
* disable some pylint messages

1 files changed, 0 insertions, 163 deletions

diff --git a/src/artifact.py b/src/artifact.py
deleted file mode 100644
index ecedbe9..0000000
--- a/src/artifact.py
+++ /dev/null
@@ -1,163 +0,0 @@
-# Copyright 2018-2019 Florian Fischer <florian.fl.fischer@fau.de>
-#
-# This file is part of allocbench.
-#
-# allocbench 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.
-#
-# allocbench is distributed in the hope that it will be useful,
-# but WITHOUT ANY WARRANTY; without even the implied warranty of
-# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
-# GNU General Public License for more details.
-#
-# You should have received a copy of the GNU General Public License
-# along with allocbench.  If not, see <http://www.gnu.org/licenses/>.
-"""Artifact classes
-
-An Artifact is a external ressource downloaded from the internet.
-There are two flavours of artifacts available: archives and git repositories.
-Both flavours are version controlled archive with a checksum and git repositories
-with a specific checkout.
-"""
-
-import os
-from subprocess import CalledProcessError
-
-import src.globalvars
-from src.util import print_status, print_info, print_debug, print_error, run_cmd, sha1sum
-
-ARTIFACT_STORE_DIR = os.path.join(src.globalvars.allocbenchdir, "cache")
-
-
-class Artifact:
-    """Base class for external ressources"""
-    store = {}
-
-    def __init__(self, name):
-        if name in Artifact.store:
-            raise Exception(f'duplicate artifact "{name}"')
-
-        Artifact.store[name] = self
-        self.name = name
-        self.basedir = os.path.join(ARTIFACT_STORE_DIR, name)
-
-    def _retrieve(self, cmd):
-        """Run cmd to retrieve the artifact"""
-        os.makedirs(self.basedir, exist_ok=True)
-
-        print_status(f'Retrieving artifact "{self.name}" ...')
-        print_debug(f"By running: {cmd} in {self.basedir}")
-        run_cmd(cmd, output_verbosity=1, cwd=self.basedir)
-
-
-class GitArtifact(Artifact):
-    """External git repository"""
-    def __init__(self, name, url):
-        super().__init__(name)
-        self.url = url
-        self.repo = os.path.join(self.basedir, "repo")
-
-    def retrieve(self):
-        """clone the git repo"""
-        super()._retrieve(
-            ["git", "clone", "--recursive", "--bare", self.url, "repo"])
-
-    def provide(self, checkout, location=None):
-        """checkout new worktree at location"""
-        if not location:
-            location = os.path.join(self.basedir, checkout)
-
-        # check if we have already provided this checkout
-        if os.path.exists(location):
-            try:
-                run_cmd(["git", "fetch", "--force"], output_verbosity=1, cwd=location)
-            except CalledProcessError:
-                print_error(f"Failed to update {location}")
-                raise
-            try:
-                run_cmd(["git", "reset", "--hard", checkout], output_verbosity=1, cwd=location)
-            except CalledProcessError:
-                print_error(f"Failed to update {location}")
-                raise
-            return location
-
-        # check if we have already retrieved the repo
-        if not os.path.exists(self.repo):
-            self.retrieve()
-
-        # update repo
-        print_status(f'Updating git repository "{self.name}" ...')
-        try:
-            run_cmd(["git", "fetch", "--force"], output_verbosity=1, cwd=self.repo)
-        except CalledProcessError:
-            print_error(f"Failed to update {self.name}")
-            raise
-
-        worktree_cmd = ["git", "worktree", "add", location, checkout]
-        print_debug("create new worktree. By running: ", worktree_cmd,
-                    f"in {self.repo}")
-        try:
-            run_cmd(worktree_cmd, output_verbosity=1, cwd=self.repo)
-        except CalledProcessError:
-            print_error(f"Failed to provide {self.name}")
-            raise
-
-        submodule_init_cmd = [
-            "git", "submodule", "update", "--init", "--recursive"
-        ]
-        print_debug("update submodules in worktree. By running: ",
-                    f"{submodule_init_cmd} in {self.repo}")
-        run_cmd(submodule_init_cmd, output_verbosity=1, cwd=location)
-        return location
-
-
-class ArchiveArtifact(Artifact):
-    """External archive"""
-    supported_formats = ["tar"]
-
-    def __init__(self, name, url, archive_format, checksum):
-        super().__init__(name)
-        self.url = url
-        if archive_format not in self.supported_formats:
-            raise Exception(
-                f'Archive format "{format}" not in supported list {self.supported_formats}'
-            )
-        self.archive_format = archive_format
-        self.archive = os.path.join(self.basedir, f"{self.name}.{self.archive_format}")
-        self.checksum = checksum
-
-    def retrieve(self):
-        """download the archive"""
-        super()._retrieve(["wget", "-O", self.archive, self.url])
-
-    def provide(self, location=None):
-        """extract the archive"""
-
-        # Download archive
-        if not os.path.exists(self.archive):
-            self.retrieve()
-
-        # compare checksums
-        print_info("Verify checksum ...")
-        if sha1sum(self.archive) != self.checksum:
-            raise Exception(
-                f"Archive {self.archive} does not match provided checksum")
-
-        if not location:
-            location = os.path.join(self.basedir, "content")
-
-        # Check if we already provided the archive at location
-        if os.path.exists(location):
-            return location
-
-        os.makedirs(location, exist_ok=True)
-
-        # Extract archive
-        if self.archive_format == "tar":
-            cmd = ["tar", "Cxf", location, self.archive]
-
-        print_debug(f"extract archive by running: {cmd} in {self.basedir}")
-        run_cmd(cmd, output_verbosity=1, cwd=self.basedir)
-        return location