mirror of
https://github.com/KeksPirates/SoftwareManager.git
synced 2026-08-03 17:39:42 +02:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 83adbb027f |
@@ -4,6 +4,7 @@ from core.utils.data.state import state
|
|||||||
from core.utils.general.logs import update_download_completed_by_hash
|
from core.utils.general.logs import update_download_completed_by_hash
|
||||||
from core.utils.general.logs import consoleLog
|
from core.utils.general.logs import consoleLog
|
||||||
from plyer import notification
|
from plyer import notification
|
||||||
|
import socket
|
||||||
import time
|
import time
|
||||||
import sys
|
import sys
|
||||||
|
|
||||||
@@ -42,6 +43,21 @@ def aria2server():
|
|||||||
stderr=subprocess.DEVNULL,
|
stderr=subprocess.DEVNULL,
|
||||||
creationflags=subprocess.CREATE_NO_WINDOW if sys.platform == 'win32' else 0
|
creationflags=subprocess.CREATE_NO_WINDOW if sys.platform == 'win32' else 0
|
||||||
)
|
)
|
||||||
|
|
||||||
|
max_checks = 50
|
||||||
|
for check in range(max_checks):
|
||||||
|
try:
|
||||||
|
sock = socket.socket()
|
||||||
|
sock.settimeout(0.1)
|
||||||
|
sock.connect(("localhost", 6800))
|
||||||
|
sock.close()
|
||||||
|
break
|
||||||
|
except(ConnectionRefusedError, socket.timeout):
|
||||||
|
time.sleep(0.1)
|
||||||
|
else:
|
||||||
|
raise RuntimeError("Aria2 Server failed to start")
|
||||||
|
|
||||||
|
consoleLog("Aria2 Server started")
|
||||||
return aria2server
|
return aria2server
|
||||||
|
|
||||||
def dlprogress():
|
def dlprogress():
|
||||||
|
|||||||
Reference in New Issue
Block a user