mirror of
https://github.com/qinyuhang/ShadowsocksX-NG-R.git
synced 2026-10-06 19:03:54 +00:00
133 lines
4.8 KiB
Swift
Executable File
133 lines
4.8 KiB
Swift
Executable File
//
|
|
// MonitorTask.swift
|
|
// Up&Down
|
|
//
|
|
// Created by 郭佳哲 on 6/3/16.
|
|
// Copyright © 2016 郭佳哲. All rights reserved.
|
|
//
|
|
|
|
import Foundation
|
|
|
|
open class NetWorkMonitor: NSObject {
|
|
let statusItemView: StatusItemView
|
|
|
|
var thread:Thread?
|
|
var timer:Timer?
|
|
|
|
init(statusItemView view: StatusItemView) {
|
|
statusItemView = view
|
|
}
|
|
|
|
func start() {
|
|
thread = Thread(target: self, selector: #selector(startUpdateTimer), object: nil)
|
|
thread?.start()
|
|
statusItemView.showSpeed = true
|
|
}
|
|
|
|
func startUpdateTimer() {
|
|
timer = Timer.scheduledTimer(timeInterval: 1, target: self, selector: #selector(updateNetWorkData), userInfo: nil, repeats: true)
|
|
if #available(OSX 10.12, *){
|
|
|
|
let alertView = NSAlert()
|
|
alertView.messageText = "网速显示不支持 macOS 10.12 Sierra!"
|
|
alertView.informativeText = "因为 macOS 10.12 Sierra ABI 不稳定，因此暂时移除网速功能"
|
|
alertView.addButton(withTitle: "取消网速显示")
|
|
_ = DispatchQueue.main.sync(execute: { Void in
|
|
alertView.runModal()
|
|
})
|
|
stop()
|
|
// NSRunLoop.currentRunLoop().run()
|
|
// CFRunLoopRun()
|
|
|
|
} else {
|
|
RunLoop.current.add(timer!, forMode: RunLoopMode.commonModes)
|
|
RunLoop.current.run()
|
|
print(RunLoop.current.getCFRunLoop())
|
|
}
|
|
}
|
|
|
|
func stop(){
|
|
thread?.cancel()
|
|
statusItemView.showSpeed = false
|
|
|
|
}
|
|
|
|
|
|
func updateNetWorkData() {
|
|
|
|
if Thread.current.isCancelled{
|
|
timer?.invalidate()
|
|
timer = nil
|
|
thread = nil
|
|
Thread.exit()
|
|
|
|
}
|
|
|
|
let task = Process()
|
|
task.launchPath = "/usr/bin/sar"
|
|
task.arguments = ["-n", "DEV", "1"]
|
|
|
|
let pipe = Pipe()
|
|
task.standardOutput = pipe
|
|
|
|
task.launch()
|
|
task.waitUntilExit()
|
|
|
|
let status = task.terminationStatus
|
|
if status == 0 {
|
|
// print("Task succeeded.")
|
|
let fileHandle = pipe.fileHandleForReading
|
|
let data = fileHandle.readDataToEndOfFile()
|
|
|
|
var string = String(data: data, encoding: String.Encoding.utf8)
|
|
string = string?.substring(from: (string?.range(of: "Aver")?.lowerBound)!)
|
|
handleNetWorkData(string!)
|
|
} else {
|
|
print("Task failed.")
|
|
}
|
|
}
|
|
|
|
/*
|
|
23:18:25 IFACE Ipkts/s Ibytes/s Opkts/s Obytes/s
|
|
|
|
|
|
23:18:26 lo0 0 0 0 0
|
|
23:18:26 gif0 0 0 0 0
|
|
23:18:26 stf0 0 0 0 0
|
|
23:18:26 en0 0 0 0 0
|
|
23:18:26 en1 0 0 0 0
|
|
23:18:26 en2 0 0 0 0
|
|
23:18:26 p2p0 0 0 0 0
|
|
23:18:26 awdl0 0 0 0 0
|
|
23:18:26 bridge0 0 0 0 0
|
|
23:18:26 en4 0 0 0 0
|
|
Average: lo0 0 0 0 0
|
|
Average: gif0 0 0 0 0
|
|
Average: stf0 0 0 0 0
|
|
Average: en0 0 0 0 0
|
|
Average: en1 0 0 0 0
|
|
Average: en2 0 0 0 0
|
|
Average: p2p0 0 0 0 0
|
|
Average: awdl0 0 0 0 0
|
|
Average: bridge0 0 0 0 0
|
|
Average: en4 0 0 0 0
|
|
*/
|
|
func handleNetWorkData(_ string: String) {
|
|
// print(string)
|
|
let pattern = "en\\w+\\s+(\\d+)\\s+(\\d+)\\s+(\\d+)\\s+(\\d+)"
|
|
do {
|
|
let regex = try NSRegularExpression(pattern: pattern, options: NSRegularExpression.Options.caseInsensitive)
|
|
let results = regex.matches(in: string, options: NSRegularExpression.MatchingOptions(rawValue: 0), range: NSMakeRange(0, string.count))
|
|
var upRate: Float = 0.00
|
|
var downRate: Float = 0.00
|
|
for result in results {
|
|
downRate += Float((string as NSString).substring(with: result.rangeAt(2)))!
|
|
upRate += Float((string as NSString).substring(with: result.rangeAt(4)))!
|
|
}
|
|
statusItemView.setRateData(up: upRate, down: downRate)
|
|
}
|
|
catch {}
|
|
}
|
|
|
|
}
|