|
|
@ -424,8 +424,8 @@ class TestNode():
|
|
|
|
def wallets_path(self) -> Path:
|
|
|
|
def wallets_path(self) -> Path:
|
|
|
|
return self.chain_path / "wallets"
|
|
|
|
return self.chain_path / "wallets"
|
|
|
|
|
|
|
|
|
|
|
|
def debug_log_bytes(self) -> int:
|
|
|
|
def debug_log_size(self, **kwargs) -> int:
|
|
|
|
with open(self.debug_log_path, encoding='utf-8') as dl:
|
|
|
|
with open(self.debug_log_path, **kwargs) as dl:
|
|
|
|
dl.seek(0, 2)
|
|
|
|
dl.seek(0, 2)
|
|
|
|
return dl.tell()
|
|
|
|
return dl.tell()
|
|
|
|
|
|
|
|
|
|
|
@ -434,13 +434,13 @@ class TestNode():
|
|
|
|
if unexpected_msgs is None:
|
|
|
|
if unexpected_msgs is None:
|
|
|
|
unexpected_msgs = []
|
|
|
|
unexpected_msgs = []
|
|
|
|
time_end = time.time() + timeout * self.timeout_factor
|
|
|
|
time_end = time.time() + timeout * self.timeout_factor
|
|
|
|
prev_size = self.debug_log_bytes()
|
|
|
|
prev_size = self.debug_log_size(encoding="utf-8") # Must use same encoding that is used to read() below
|
|
|
|
|
|
|
|
|
|
|
|
yield
|
|
|
|
yield
|
|
|
|
|
|
|
|
|
|
|
|
while True:
|
|
|
|
while True:
|
|
|
|
found = True
|
|
|
|
found = True
|
|
|
|
with open(self.debug_log_path, encoding='utf-8') as dl:
|
|
|
|
with open(self.debug_log_path, encoding="utf-8", errors="replace") as dl:
|
|
|
|
dl.seek(prev_size)
|
|
|
|
dl.seek(prev_size)
|
|
|
|
log = dl.read()
|
|
|
|
log = dl.read()
|
|
|
|
print_log = " - " + "\n - ".join(log.splitlines())
|
|
|
|
print_log = " - " + "\n - ".join(log.splitlines())
|
|
|
@ -465,7 +465,7 @@ class TestNode():
|
|
|
|
the number of log lines we encountered when matching
|
|
|
|
the number of log lines we encountered when matching
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
time_end = time.time() + timeout * self.timeout_factor
|
|
|
|
time_end = time.time() + timeout * self.timeout_factor
|
|
|
|
prev_size = self.debug_log_bytes()
|
|
|
|
prev_size = self.debug_log_size(mode="rb") # Must use same mode that is used to read() below
|
|
|
|
|
|
|
|
|
|
|
|
yield
|
|
|
|
yield
|
|
|
|
|
|
|
|
|
|
|
|