Max/LorenEteval_Furious
1
0
Fork 0
mirror of https://github.com/LorenEteval/Furious.git synced 2026-10-09 15:19:56 +03:00
Code Issues Packages Projects Releases Wiki Activity

Move to icmplib implementation

Browse Source 
Signed-off-by: Loren Eteval <loren.eteval@proton.me>
This commit is contained in:
Loren Eteval
2024-03-07 00:57:06 +08:00
parent 825c01c88d
commit a2cef472b9
1 changed files with 12 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Furious/Widget/UserServersQTableWidget.py
+12 -11
View File
@@ -35,9 +35,9 @@ from PySide6.QtNetwork import *
from typing import Callable, Union, Sequence, MutableSequence
import ping3
import queue
import logging
import icmplib
import functools
__all__ = ['UserServersQTableWidget']
@@ -114,13 +114,13 @@ class SubscriptionManager(AppQNetworkAccessManager):
for uri in uris:
parent.appendNewItem(config=uri, subsId=unique)
if isConnected and subsGroupIndex >= 0:
if subsGroupIndex >= 0:
newIndex = remaining + subsGroupIndex
if newIndex < len(AS_UserServers()):
parent.activateItemByIndex(newIndex, True)
if not APP().isSystemTrayConnected():
if isConnected and not APP().isSystemTrayConnected():
# Trigger connect
APP().systemTray.ConnectAction.trigger()
@@ -186,19 +186,20 @@ class TestPingLatencyWorker(ItemUpdateProtocol, QtCore.QObject, QtCore.QRunnable
assert isinstance(self.currentItem, ConfigurationFactory)
try:
result = ping3.ping(self.currentItem.itemAddress, timeout=2, unit='ms')
except Exception:
result = icmplib.ping(self.currentItem.itemAddress, count=1)
except Exception as ex:
# Any non-exit exceptions
self.currentItem.setExtras('delayResult', 'Timeout')
self.currentItem.setExtras('delayResult', str(ex))
self.updateResult()
else:
if result is False:
self.currentItem.setExtras('delayResult', 'Error')
elif result is None:
self.currentItem.setExtras('delayResult', 'Timeout')
if result.is_alive:
self.currentItem.setExtras('delayResult', f'{round(result.avg_rtt)}ms')
else:
self.currentItem.setExtras('delayResult', f'{round(result)}ms')
if result.packet_loss == 1:
self.currentItem.setExtras('delayResult', 'Timeout')
else:
self.currentItem.setExtras('delayResult', 'Error')
self.updateResult()