morgan/macos-stats
1
0
Fork 0
mirror of https://github.com/morgan9e/macos-stats synced 2026-04-14 00:04:15 +09:00
Code Issues Packages Projects Releases Wiki Activity

fix: fixed the forever loop in ICMP setup after adding an option to set the update interval for that reader (#2625)

Browse Source
This commit is contained in:
Serhiy Mytrovtsiy
2025-07-14 17:51:13 +02:00
parent e67961038d
commit 6ce8497277
1 changed files with 17 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
Modules/Net/readers.swift
View File

@@ -669,42 +669,26 @@ internal class ConnectivityReader: Reader<Network_Connectivity> {
private var _status: Bool? = nil
private var status: Bool? {
get {
self.variablesQueue.sync { self._status }
}
set {
self.variablesQueue.sync { self._status = newValue }
}
get { self.variablesQueue.sync { self._status } }
set { self.variablesQueue.sync { self._status = newValue } }
}
private var _timeoutTimer: Timer?
private var timeoutTimer: Timer? {
get {
self.variablesQueue.sync { self._timeoutTimer }
}
set {
self.variablesQueue.sync { self._timeoutTimer = newValue }
}
get { self.variablesQueue.sync { self._timeoutTimer } }
set { self.variablesQueue.sync { self._timeoutTimer = newValue } }
}
private var _isPinging: Bool = false
private var isPinging: Bool {
get {
self.variablesQueue.sync { self._isPinging }
}
set {
self.variablesQueue.sync { self._isPinging = newValue }
}
get { self.variablesQueue.sync { self._isPinging } }
set { self.variablesQueue.sync { self._isPinging = newValue } }
}
private var _latency: Double? = nil
private var latency: Double? {
get {
self.variablesQueue.sync { self._latency }
}
set {
self.variablesQueue.sync { self._latency = newValue }
}
get { self.variablesQueue.sync { self._latency } }
set { self.variablesQueue.sync { self._latency = newValue } }
}
var start: DispatchTime? = nil
@@ -733,6 +717,14 @@ internal class ConnectivityReader: Reader<Network_Connectivity> {
override func setup() {
self.setInterval(Store.shared.int(key: "Network_updateICMPInterval", defaultValue: 1))
self.prepare()
}
deinit {
self.closeConn()
}
private func prepare() {
DispatchQueue.global(qos: .background).async {
self.addr = self.resolve()
self.openConn()
@@ -740,10 +732,6 @@ internal class ConnectivityReader: Reader<Network_Connectivity> {
}
}
deinit {
self.closeConn()
}
override func read() {
guard !self.host.isEmpty else {
if self.socket != nil {
@@ -753,7 +741,7 @@ internal class ConnectivityReader: Reader<Network_Connectivity> {
}
if self.socket == nil {
self.setup()
self.prepare()
}
if self.lastHost != self.host {