1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
# Data for log.py, describes the format of log records
# There are a small number of main log record types.
#
# Some log record types, such as transaction commit, also include a list of
# "log operations" within the same log record. Both log record types and log
# operations are described here.
class LogRecordType:
def __init__(self, name, desc, fields):
self.name = name
self.desc = desc
self.fields = fields
def macro_name(self):
return 'WT_LOGREC_%s' % self.name.upper()
def prname(self):
return '__logrec_print_' + self.name
rectypes = [
# A database-wide checkpoint.
LogRecordType('checkpoint', 'checkpoint', [
('WT_LSN', 'ckpt_lsn'), ('uint32', 'nsnapshot'), ('item', 'snapshot')]),
# Common case: a transaction commit
LogRecordType('commit', 'transaction commit', [('uint64', 'txnid')]),
# Mark the start / end of a file sync operation (usually when a file is
# closed). These log records aren't required during recovery, but we use
# the allocated LSN to reduce the amount of work recovery has to do, and
# they are useful for debugging recovery.
LogRecordType('file_sync', 'file sync', [
('uint32', 'fileid'), ('int', 'start')]),
# Debugging message in the log
LogRecordType('message', 'message', [('string', 'message')]),
]
class LogOperationType:
def __init__(self, name, desc, fields):
self.name = name
self.desc = desc
self.fields = fields
def macro_name(self):
return 'WT_LOGOP_%s' % self.name.upper()
optypes = [
LogOperationType('col_put', 'column put',
[('uint32', 'fileid'), ('recno', 'recno'), ('item', 'value')]),
LogOperationType('col_remove', 'column remove',
[('uint32', 'fileid'), ('recno', 'recno')]),
LogOperationType('col_truncate', 'column truncate',
[('uint32', 'fileid'), ('recno', 'start'), ('recno', 'stop')]),
LogOperationType('row_put', 'row put',
[('uint32', 'fileid'), ('item', 'key'), ('item', 'value')]),
LogOperationType('row_remove', 'row remove',
[('uint32', 'fileid'), ('item', 'key')]),
LogOperationType('row_truncate', 'row truncate',
[('uint32', 'fileid'), ('item', 'start'), ('item', 'stop'),
('uint32', 'mode')]),
]
|
