Project

General

Profile

1
# Exception handling
2

    
3
import copy
4
import atexit
5
import sys
6
import traceback
7

    
8
import format
9
import strings
10
import term
11
import util
12

    
13
def raise_(e): raise e
14

    
15
def sys_traceback():
16
    '''Note that Python tracebacks seems to have a bug that truncates them to
17
    only a few stack frames. See <http://bugs.python.org/issue7378>.'''
18
    return sys.exc_info()[2]
19
        # can't just return pointer to traceback because it will change :-(
20

    
21
def has_tracebacks(e): return hasattr(e, 'tracebacks')
22

    
23
def add_traceback(e):
24
    '''Adds current traceback to an exception if it doesn't already have one'''
25
    traceback_ = sys_traceback() # get first in case later code throws exception
26
    if not has_tracebacks(e): e.tracebacks = []
27
    if util.list_get(e.tracebacks, 0) == traceback_: return
28
    e.tracebacks.insert(0, traceback_) # tracebacks have most recent call last
29

    
30
def get_traceback_str(traceback_):
31
    return ''.join(traceback.format_exception(None, None, traceback_)[:-1])
32
        # remove final "None" line ("exception name")
33

    
34
def get_e_tracebacks_str(e):
35
    try: tracebacks = e.tracebacks
36
    except AttributeError: return ''
37
    return ''.join(get_traceback_str(t) for t in tracebacks)
38

    
39
def add_msg(e, msg): e.args = (strings.ensure_newl(strings.ustr(e))+msg,)
40

    
41
def repl_msg(e, **repls): e.args = (strings.ustr(e) % repls,)
42

    
43
def e_ct_exit_status(e_ct): return min(e_ct, 255)
44

    
45
class ExceptionWithCause(Exception):
46
    def __init__(self, msg, cause=None, cause_newline=False):
47
        add_traceback(self)
48
        if cause != None:
49
            if cause_newline: msg += '\ncause'
50
            msg += ': '+str_(cause)
51
        Exception.__init__(self, msg)
52

    
53
def str_(e, first_line_only=False):
54
    msg = u''.join(traceback.format_exception_only(type(e), e)).rstrip()
55
    if first_line_only: msg = msg.partition('\n')[0]
56
    return msg
57

    
58
def print_ex(e, emph=True, detail=True, plain=False):
59
    if plain:
60
        emph = False
61
        detail = False
62
    
63
    msg = str_(e)+'\n'
64
    if detail: msg += get_e_tracebacks_str(e)
65
    if emph:
66
        first_line, nl, rest = msg.partition('\n')
67
        msg = term.error(first_line)+nl+rest
68
    sys.stderr.write(msg)
69

    
70
class ExTracker:
71
    def __init__(self):
72
        self.e_ct = 0
73
    
74
    def msg(self): return 'Encountered '+str(self.e_ct)+' error(s)'
75
    
76
    def track(self, e, **format):
77
        self.e_ct += 1
78
        print_ex(e, **format)
79
    
80
    def exit(self):
81
        if self.e_ct > 0: raise SystemExit(e_ct_exit_status(self.e_ct))
82

    
83
class ExPercentTracker(ExTracker):
84
    def __init__(self, iter_text='iteration'):
85
        ExTracker.__init__(self)
86
        self.iter_text = iter_text
87
        self.iter_ct = None
88
        self.err_iter_ct = None
89
        self.last_iter_num = None
90
    
91
    def add_iters(self, iter_ct):
92
        if self.iter_ct == None: self.iter_ct = 0
93
        self.iter_ct += iter_ct
94
    
95
    def track(self, e, iter_num=None, **format):
96
        if iter_num != None:
97
            if iter_num != self.last_iter_num: # a new iter produced an error
98
                if self.err_iter_ct == None: self.err_iter_ct = 0
99
                self.err_iter_ct += 1
100
                self.last_iter_num = iter_num
101
        ExTracker.track(self, e, **format)
102
    
103
    def msg(self):
104
        msg = ExTracker.msg(self)
105
        iter_text_plural = self.iter_text+'(s)'
106
        numerator = self.e_ct
107
        if self.err_iter_ct != None:
108
            msg += ' in '+format.int2str(self.err_iter_ct)
109
            numerator = self.err_iter_ct
110
        if self.iter_ct != None and self.iter_ct > 0:
111
            msg += ('/'+format.int2str(self.iter_ct)+' '+iter_text_plural+' = '
112
            +format.to_percent(float(numerator)/self.iter_ct))
113
        return msg
(12-12/34)