Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Consider files stat()'d then written as output #236

Open
wants to merge 1 commit into
base: 1.x
Choose a base branch
from
Open

Consider files stat()'d then written as output #236

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 25 additions & 9 deletions reprozip/reprozip/tracer/trace.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
from reprozip import __version__ as reprozip_version
from reprozip import _pytracer
from reprozip.common import File, InputOutputFile, load_config, save_config, \
FILE_READ, FILE_WRITE, FILE_LINK
FILE_READ, FILE_WRITE, FILE_STAT, FILE_LINK
from reprozip.tracer.linux_pkgs import magic_dirs, system_dirs, \
identify_packages
from reprozip.utils import PY3, izip, iteritems, itervalues, \
Expand All @@ -42,16 +42,22 @@ class TracedFile(File):
# | |
# read v + write
# (init) +------------------> ONLY_READ +-------> READ_THEN_WRITTEN
# | ^ +
# | | |
# +-------> WRITTEN +--+ +---------+
# write ^ | read, write
# |\ ^ ^ +
# | \ | read | |
# | \ stat | +---------+
# | +--------> ONLY_STAT read, write
# | |
# | | write
# | v
# +-------> WRITTEN +--+
# write ^ |
# | |
# +---------+
# read, write
READ_THEN_WRITTEN = 0
ONLY_READ = 1
WRITTEN = 2
ONLY_STAT = 3

what = None

Expand All @@ -71,25 +77,33 @@ def __init__(self, path):
File.__init__(self, path, size)

def read(self, run):
if self.what is None:
if self.what in (None, TracedFile.ONLY_STAT):
self.what = TracedFile.ONLY_READ

if run is not None:
if self.runs[run] is None:
if self.runs[run] in (None, TracedFile.ONLY_STAT):
self.runs[run] = TracedFile.ONLY_READ

def write(self, run):
if self.what is None:
if self.what in (None, TracedFile.ONLY_STAT):
self.what = TracedFile.WRITTEN
elif self.what == TracedFile.ONLY_READ:
self.what = TracedFile.READ_THEN_WRITTEN

if run is not None:
if self.runs[run] is None:
if self.runs[run] in (None, TracedFile.ONLY_STAT):
self.runs[run] = TracedFile.WRITTEN
elif self.runs[run] == TracedFile.ONLY_READ:
self.runs[run] = TracedFile.READ_THEN_WRITTEN

def stat(self, run):
if self.what is None:
self.what = TracedFile.ONLY_STAT

if run is not None:
if self.runs[run] is None:
self.runs[run] = TracedFile.ONLY_STAT


def run_filter_plugins(files, input_files):
for entry_point in iter_entry_points('reprozip.filters'):
Expand Down Expand Up @@ -169,6 +183,8 @@ def get_files(conn):
files[f.path] = f
else:
f = files[r_name]
if r_mode & FILE_STAT:
f.stat(run)
if r_mode & FILE_READ:
f.read(run)
if r_mode & FILE_WRITE:
Expand Down