diff --git a/contrib/transaction_profiling_analyzer/transaction_profiling_analyzer.py b/contrib/transaction_profiling_analyzer/transaction_profiling_analyzer.py index 3731a20377..23a28c1c54 100644 --- a/contrib/transaction_profiling_analyzer/transaction_profiling_analyzer.py +++ b/contrib/transaction_profiling_analyzer/transaction_profiling_analyzer.py @@ -98,6 +98,9 @@ class ByteBuffer(object): def get_double(self): return struct.unpack("= PROTOCOL_VERSION_6_3: + self.report_conflicting_keys = bb.get_bool() class ErrorGetInfo(BaseInfo): @@ -255,7 +260,8 @@ class ErrorCommitInfo(BaseInfo): self.mutations = mutations self.read_snapshot_version = bb.get_long() - + if protocol_version >= PROTOCOL_VERSION_6_3: + self.report_conflicting_keys = bb.get_bool() class UnsupportedProtocolVersionError(Exception): def __init__(self, protocol_version): @@ -546,7 +552,7 @@ class ReadCounter(object): def get_total_reads(self): return sum([v for v in self.read_counts.values()]) - + def matches_filter(addresses, required_addresses): for addr in required_addresses: if addr not in addresses: