From f3d730428f7620ca5d9bb434fff0a06bf781051c Mon Sep 17 00:00:00 2001 From: Brian Warner Date: Wed, 15 Oct 2008 15:09:40 -0700 Subject: [PATCH] misc/incident-gatherer: add classify_tahoe.py: a foolscap incident-gatherer classification plugin --- misc/incident-gatherer/classify_tahoe.py | 67 ++++++++++++++++++++++++ 1 file changed, 67 insertions(+) create mode 100644 misc/incident-gatherer/classify_tahoe.py diff --git a/misc/incident-gatherer/classify_tahoe.py b/misc/incident-gatherer/classify_tahoe.py new file mode 100644 index 00000000..ea6d6f54 --- /dev/null +++ b/misc/incident-gatherer/classify_tahoe.py @@ -0,0 +1,67 @@ + +import re + +umidmap = { + 'lp1vaQ': 'download-not-enough-shares', + '3uuBUQ': 'download-connection-lost-in-get-buckets', + 'LkD9Pw': 'user-incident-button', +} + +def classify_incident(trigger): + m = trigger.get('message', '') + f = trigger.get('format', '') + + umid_value = umidmap.get(trigger.get('umid',''), None) + if umid_value: + return umid_value + + if re.search(r"^they had shares .* that we didn't know about$", m): + # Publish._got_write_answer + return "mutable-publish-surprise-shares" + + if m.startswith("error during query"): + # there are a couple of different places that can generate this + # message (the result of cut-and-paste error-handling), so it isn't + # clear which is which + + if re.search(r'mutable/servermap\.py.*_do_query', m): + # servermap.ServermapUpdater._query_failed() + where = "mapupdate" + elif re.search(r'mutable/retrieve\.py.*_got_results_one_share', m): + where = "retrieve" + else: + where = "unknown" + + if ("Calling Stale Broker" in m and "DeadReferenceError" in m): + # a storage server went offline while we were talking to it (or + # because the client was shut off in the middle of an operation) + what = "lost-server" + elif "IOError" in m: + what = "ioerror" + elif ("UncoordinatedWriteError" in m and + "someone wrote to the data since we read the servermap" in m): + what = "uncoordinated-write-error" + elif "ConnectionLost" in m: + what = "lost-server" + else: + what = "unknown" + + return "mutable-" + where + "-query-" + what + + if (f.startswith("ran out of peers:") and + "have" in trigger and "need" in trigger): + return "mutable-retrieve-failure" + if m.startswith("invalid privkey from "): + # TODO: a UCW causes this, after the prefix has changed. Compare the + # prefix before trying to validate the privkey, to avoid the + # duplicate error. + return "mutable-mapupdate-bad-privkey" + + if trigger.get('facility', '') == "tahoe.introducer": + if (trigger.get('isError', False) + and "ConnectionDone" in str(trigger.get('failure',''))): + return "introducer-lost-connection" + if "Initial Introducer connection failed" in m: + return "introducer-connection-failed" + + return None -- 2.45.2