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
|
from . import defines
from .varint import read_varint
class Progress(object):
def __init__(self):
self.rows = 0
self.bytes = 0
self.total_rows = 0
self.written_rows = 0
self.written_bytes = 0
super(Progress, self).__init__()
def read(self, server_revision, fin):
self.rows = read_varint(fin)
self.bytes = read_varint(fin)
revision = server_revision
if revision >= defines.DBMS_MIN_REVISION_WITH_TOTAL_ROWS_IN_PROGRESS:
self.total_rows = read_varint(fin)
if revision >= defines.DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFO:
self.written_rows = read_varint(fin)
self.written_bytes = read_varint(fin)
def increment(self, another_progress):
self.rows += another_progress.rows
self.bytes += another_progress.bytes
self.total_rows += another_progress.total_rows
self.written_rows += another_progress.written_rows
self.written_bytes += another_progress.written_bytes
|
