Bitmessage/MiNode
3
0
Fork 1
Code Pull Requests 9 Actions Activity

Improving the network communication #4

Merged
PeterSurda merged 12 commits from lee.miller/MiNode:network into v0.3 2024-07-15 07:58:57 +02:00
Conversation 0 Commits 12 Files Changed 10 +4 -4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 16031874c7 - Show all commits

8
minode/tests/test_process.py
View File

@ -21,7 +21,7 @@ except (OSError, socket.error):
class TestProcessProto(unittest.TestCase): class TestProcessProto(unittest.TestCase):
"""Test process attributes, common flow""" """Test process attributes, common flow"""
_process_cmd = ['minode'] _process_cmd = ['minode']
_connection_limit = 4 if sys.platform.startswith('win') else 10 _connection_limit = 4 if sys.platform.startswith('win') else 8
_listen = False _listen = False
_listening_port = None _listening_port = None
@ -84,7 +84,7 @@ class TestProcessShutdown(TestProcessProto):
class TestProcess(TestProcessProto): class TestProcess(TestProcessProto):
"""The test case for minode process""" """The test case for minode process"""
_wait_time = 120 _wait_time = 180
_check_limit = False _check_limit = False
def test_connections(self): def test_connections(self):
@ -104,7 +104,7 @@ class TestProcess(TestProcessProto):
time.sleep(1) time.sleep(1)
for _ in range(self._wait_time * 2): for _ in range(self._wait_time * 2):
if len(self.connections()) > self._connection_limit / 2: if len(self.connections()) >= self._connection_limit / 2:
_time_to_connect = round(time.time() - _started) _time_to_connect = round(time.time() - _started)
break break
if '--i2p' not in self._process_cmd: if '--i2p' not in self._process_cmd:
@ -116,7 +116,7 @@ class TestProcess(TestProcessProto):
time.sleep(0.5) time.sleep(0.5)
else: else:
self.fail( self.fail(
'Failed establish at least %i connections in %s sec' 'Failed to establish at least %i connections in %s sec'
% (int(self._connection_limit / 2), self._wait_time)) % (int(self._connection_limit / 2), self._wait_time))
if self._check_limit: if self._check_limit: