Wait more for port opening
This commit is contained in:
parent
61b4d97832
commit
5a234745fc
3 changed files with 3 additions and 3 deletions
|
@ -115,7 +115,7 @@ class TestSiteDownload:
|
||||||
file_server_full = FileServer("127.0.0.1", 1546)
|
file_server_full = FileServer("127.0.0.1", 1546)
|
||||||
site_full.connection_server = file_server_full
|
site_full.connection_server = file_server_full
|
||||||
gevent.spawn(lambda: ConnectionServer.start(file_server_full))
|
gevent.spawn(lambda: ConnectionServer.start(file_server_full))
|
||||||
time.sleep(0) # Port opening
|
time.sleep(0.001) # Port opening
|
||||||
file_server_full.sites[site_full.address] = site_full # Add site
|
file_server_full.sites[site_full.address] = site_full # Add site
|
||||||
site_full.storage.verifyFiles(quick_check=True) # Check optional files
|
site_full.storage.verifyFiles(quick_check=True) # Check optional files
|
||||||
site_full_peer = site.addPeer("127.0.0.1", 1546) # Add it to source server
|
site_full_peer = site.addPeer("127.0.0.1", 1546) # Add it to source server
|
||||||
|
|
|
@ -137,7 +137,7 @@ def file_server(request):
|
||||||
request.addfinalizer(CryptConnection.manager.removeCerts) # Remove cert files after end
|
request.addfinalizer(CryptConnection.manager.removeCerts) # Remove cert files after end
|
||||||
file_server = FileServer("127.0.0.1", 1544)
|
file_server = FileServer("127.0.0.1", 1544)
|
||||||
gevent.spawn(lambda: ConnectionServer.start(file_server))
|
gevent.spawn(lambda: ConnectionServer.start(file_server))
|
||||||
time.sleep(0) # Port opening
|
time.sleep(0.1) # Port opening
|
||||||
assert file_server.running
|
assert file_server.running
|
||||||
|
|
||||||
def stop():
|
def stop():
|
||||||
|
|
|
@ -266,7 +266,7 @@ class Actions(object):
|
||||||
file_server = FileServer()
|
file_server = FileServer()
|
||||||
site.connection_server = file_server
|
site.connection_server = file_server
|
||||||
file_server_thread = gevent.spawn(file_server.start, check_sites=False) # Dont check every site integrity
|
file_server_thread = gevent.spawn(file_server.start, check_sites=False) # Dont check every site integrity
|
||||||
time.sleep(0)
|
time.sleep(0.001)
|
||||||
|
|
||||||
if not file_server_thread.ready():
|
if not file_server_thread.ready():
|
||||||
# Started fileserver
|
# Started fileserver
|
||||||
|
|
Loading…
Reference in a new issue