diff options
author | Lars Wirzenius <liw@liw.fi> | 2012-03-31 02:06:57 +0100 |
---|---|---|
committer | Lars Wirzenius <liw@liw.fi> | 2012-03-31 02:06:57 +0100 |
commit | 9bb3860221b247ebeffa6576faa97709dd019120 (patch) | |
tree | 281ed9a29c74c5d7fa8be2297c54d962a36f4da3 | |
parent | 1e31a1318e1ee8cfb0c4de6db18e1fb33afc33e9 (diff) | |
download | seivot-9bb3860221b247ebeffa6576faa97709dd019120.tar.gz |
Extract from obnam's log how many sftp round trips were done
-rwxr-xr-x | seivot | 7 |
1 files changed, 7 insertions, 0 deletions
@@ -37,6 +37,7 @@ class Measurement(object): self.repo_size_after = 0 self.repo_bytes_written = 0 self.repo_bytes_read = 0 + self.repo_roundtrips = 0 def runcmd(argv, **kwargs): @@ -193,13 +194,17 @@ class Obnam(BackupProgram): pat = re.compile(r' VFS:( __del__:)? baseurl=.* ' r'read=(?P<read>\d+) written=(?P<written>\d+)') + pat2 = re.compile(r' VFS: baseurl=.* roundtrips=(?P<n>\d+)') f = open(logfile) for line in f: m = pat.search(line) + m2 = pat2.search(line) if m and self.repo in line: measurement.repo_bytes_written = long(m.group('written')) measurement.repo_bytes_read = long(m.group('read')) + elif m2 and self.repo in line: + measurement.repo_roundtrips = long(m2.group('n')) f.close() def prepare(self): @@ -318,6 +323,8 @@ class Report(object): m.repo_bytes_written) cp.set(section, '%s.repo-bytes-read' % op, m.repo_bytes_read) + cp.set(section, '%s.repo-roundtrips' % op, + m.repo_roundtrips) cp.write(fp) |