Compare commits
1 Commits
master
...
checkmenui
Author | SHA1 | Date | |
---|---|---|---|
45dabcc3ed |
56
.gitignore
vendored
56
.gitignore
vendored
|
@ -1,56 +0,0 @@
|
||||||
# Byte-compiled / optimized / DLL files
|
|
||||||
__pycache__/
|
|
||||||
*.py[cod]
|
|
||||||
|
|
||||||
# C extensions
|
|
||||||
*.so
|
|
||||||
|
|
||||||
# Distribution / packaging
|
|
||||||
bin/
|
|
||||||
build/
|
|
||||||
develop-eggs/
|
|
||||||
dist/
|
|
||||||
eggs/
|
|
||||||
lib/
|
|
||||||
lib64/
|
|
||||||
parts/
|
|
||||||
sdist/
|
|
||||||
var/
|
|
||||||
*.egg-info/
|
|
||||||
.installed.cfg
|
|
||||||
*.egg
|
|
||||||
|
|
||||||
# Installer logs
|
|
||||||
pip-log.txt
|
|
||||||
pip-delete-this-directory.txt
|
|
||||||
|
|
||||||
# Unit test / coverage reports
|
|
||||||
.tox/
|
|
||||||
.coverage
|
|
||||||
.cache
|
|
||||||
nosetests.xml
|
|
||||||
coverage.xml
|
|
||||||
|
|
||||||
# Translations
|
|
||||||
*.mo
|
|
||||||
|
|
||||||
# Mr Developer
|
|
||||||
.mr.developer.cfg
|
|
||||||
.project
|
|
||||||
.pydevproject
|
|
||||||
|
|
||||||
# Rope
|
|
||||||
.ropeproject
|
|
||||||
|
|
||||||
# Django stuff:
|
|
||||||
*.log
|
|
||||||
*.pot
|
|
||||||
|
|
||||||
# Sphinx documentation
|
|
||||||
docs/_build/
|
|
||||||
|
|
||||||
#deleted files
|
|
||||||
*~
|
|
||||||
|
|
||||||
# Temporary graph file
|
|
||||||
graph.png
|
|
15
COPYING.txt
15
COPYING.txt
|
@ -1,15 +0,0 @@
|
||||||
This package is free software; you can redistribute it and/or modify
|
|
||||||
it under the terms of the GNU General Public License as published by
|
|
||||||
the Free Software Foundation; either version 2 of the License, or
|
|
||||||
(at your option) any later version.
|
|
||||||
.
|
|
||||||
This package is distributed in the hope that it will be useful,
|
|
||||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
GNU General Public License for more details.
|
|
||||||
.
|
|
||||||
You should have received a copy of the GNU General Public License
|
|
||||||
along with this program. If not, see <http://www.gnu.org/licenses/>
|
|
||||||
.
|
|
||||||
On Debian systems, the complete text of the GNU General
|
|
||||||
Public License version 2 can be found in "/usr/share/common-licenses/GPL-2".
|
|
|
@ -1,5 +1,3 @@
|
||||||
![Screenshot](https://github.com/zyphlar/pinger/raw/master/pinger.png)
|
|
||||||
|
|
||||||
Pinger.py
|
Pinger.py
|
||||||
=========
|
=========
|
||||||
A ping tool that sits in your system tray
|
A ping tool that sits in your system tray
|
||||||
|
@ -21,6 +19,6 @@ Open the Terminal program and enter the following commands:
|
||||||
git clone https://github.com/zyphlar/pinger.git
|
git clone https://github.com/zyphlar/pinger.git
|
||||||
python pinger/pinger.py &
|
python pinger/pinger.py &
|
||||||
|
|
||||||
Pinger should open in your system tray. To set Pinger to start automatically (in Ubuntu) click it and choose Start Automatically.
|
Pinger should open in your system tray (It just looks like "XX.X ms"). To set Pinger to start automatically (in Ubuntu) click it and choose Start Automatically.
|
||||||
|
|
||||||
Report bugs or feature requests at https://github.com/zyphlar/pinger/issues
|
Report bugs or feature requests at https://github.com/zyphlar/pinger/issues
|
||||||
|
|
5
TODO.md
5
TODO.md
|
@ -1,5 +0,0 @@
|
||||||
- local caching
|
|
||||||
- remote submission
|
|
||||||
- centralized reporting
|
|
||||||
- packaging/distribution
|
|
||||||
- cross-platform gui
|
|
146
ping.inc.py
146
ping.inc.py
|
@ -1,146 +0,0 @@
|
||||||
#!/usr/bin/env python
|
|
||||||
# -*- coding: utf-8 -*-
|
|
||||||
#
|
|
||||||
# Pinger.py -- A ping tool that sits in your system tray
|
|
||||||
# Copyright 2013 Will Bradley
|
|
||||||
#
|
|
||||||
# Contributors: Will Bradley <bradley.will@gmail.com>
|
|
||||||
# AltF4 <altf4@phx2600.org>
|
|
||||||
#
|
|
||||||
# This program is free software: you can redistribute it and/or modify it
|
|
||||||
# under the terms of either or both of the following licenses:
|
|
||||||
#
|
|
||||||
# 1) the GNU Lesser General Public License version 3, as published by the
|
|
||||||
# Free Software Foundation; and/or
|
|
||||||
# 2) the GNU Lesser General Public License version 2.1, as published by
|
|
||||||
# the Free Software Foundation.
|
|
||||||
#
|
|
||||||
# This program is distributed in the hope that it will be useful, but
|
|
||||||
# WITHOUT ANY WARRANTY; without even the implied warranties of
|
|
||||||
# MERCHANTABILITY, SATISFACTORY QUALITY or FITNESS FOR A PARTICULAR
|
|
||||||
# PURPOSE. See the applicable version of the GNU Lesser General Public
|
|
||||||
# License for more details.
|
|
||||||
#
|
|
||||||
# You should have received a copy of both the GNU Lesser General Public
|
|
||||||
# License version 3 and version 2.1 along with this program. If not, see
|
|
||||||
# <http://www.gnu.org/licenses/>
|
|
||||||
#
|
|
||||||
|
|
||||||
#
|
|
||||||
# Dependencies
|
|
||||||
#
|
|
||||||
|
|
||||||
# System Tray Icon
|
|
||||||
|
|
||||||
# Timer
|
|
||||||
|
|
||||||
# Date
|
|
||||||
import datetime
|
|
||||||
# Pinging
|
|
||||||
import subprocess
|
|
||||||
# Regex
|
|
||||||
import re
|
|
||||||
# Ctrl-c
|
|
||||||
import signal
|
|
||||||
# File paths
|
|
||||||
import os
|
|
||||||
# OS naming
|
|
||||||
import platform
|
|
||||||
# Argument parsing
|
|
||||||
import argparse
|
|
||||||
# For exit
|
|
||||||
import sys
|
|
||||||
# For graphing
|
|
||||||
|
|
||||||
# For IP addresses
|
|
||||||
import socket, struct
|
|
||||||
# For API
|
|
||||||
import json
|
|
||||||
|
|
||||||
#
|
|
||||||
# Main Class
|
|
||||||
#
|
|
||||||
|
|
||||||
class Pinger:
|
|
||||||
|
|
||||||
def ping(self, target, log=None, widget=None, data=None):
|
|
||||||
pingResult = Util.doPing(target)
|
|
||||||
ssidResult = Util.getSsid()
|
|
||||||
|
|
||||||
print json.dumps({
|
|
||||||
'target': target,
|
|
||||||
'ssid': ssidResult,
|
|
||||||
'loss': float(pingResult['loss']),
|
|
||||||
'rtt_avg': float(pingResult['rtt_avg']),
|
|
||||||
})
|
|
||||||
|
|
||||||
def __init__(self):
|
|
||||||
# Print welcome message
|
|
||||||
print "Starting Pinger..."
|
|
||||||
|
|
||||||
self.ping("4.2.2.2")
|
|
||||||
|
|
||||||
# Print started message
|
|
||||||
print "Finished."
|
|
||||||
|
|
||||||
#
|
|
||||||
# Utility class for platform-agnosticism and reusability
|
|
||||||
#
|
|
||||||
class Util:
|
|
||||||
@staticmethod
|
|
||||||
def getSsid():
|
|
||||||
if platform.system() == "Linux":
|
|
||||||
ssid = subprocess.Popen(["nmcli","-t","-f","active,ssid","dev","wifi"],
|
|
||||||
stdout = subprocess.PIPE,
|
|
||||||
stderr = subprocess.PIPE
|
|
||||||
) # | egrep '^yes(.*)' | cut -d\' -f2
|
|
||||||
out, error = ssid.communicate()
|
|
||||||
m = re.search(r'yes:(.*)', out)
|
|
||||||
result = m.group(1)
|
|
||||||
elif platform.system() == "Darwin":
|
|
||||||
ssid = subprocess.Popen(["/System/Library/PrivateFrameworks/Apple80211.framework/Versions/Current/Resources/airport","-I"],
|
|
||||||
stdout = subprocess.PIPE,
|
|
||||||
stderr = subprocess.PIPE
|
|
||||||
)
|
|
||||||
out, error = ssid.communicate()
|
|
||||||
result = out
|
|
||||||
return result
|
|
||||||
|
|
||||||
@staticmethod
|
|
||||||
def doPing(target):
|
|
||||||
if platform.system() == "Linux":
|
|
||||||
ping = subprocess.Popen(
|
|
||||||
["ping", "-c", "5", target],
|
|
||||||
stdout = subprocess.PIPE,
|
|
||||||
stderr = subprocess.PIPE
|
|
||||||
)
|
|
||||||
pingOut, pingError = ping.communicate()
|
|
||||||
# Doing two regexes because Python doesn't like doing both in one
|
|
||||||
lossResult = re.search(r' ([\d\.]+)% packet loss', pingOut, re.MULTILINE)
|
|
||||||
rttAvgResult = re.search(r' = [\d\.]+/([\d\.]+)/[\d\.]+/[\d\.]+', pingOut, re.MULTILINE)
|
|
||||||
if pingError or lossResult is None or rttAvgResult is None:
|
|
||||||
output = {'loss':-1, 'rtt_avg':-1};
|
|
||||||
else:
|
|
||||||
output = {'loss':lossResult.group(1), 'rtt_avg':rttAvgResult.group(1)};
|
|
||||||
elif platform.system() == "Darwin": # Macintosh
|
|
||||||
ping = subprocess.Popen(
|
|
||||||
["ping", "-c", "5", target],
|
|
||||||
stdout = subprocess.PIPE,
|
|
||||||
stderr = subprocess.PIPE
|
|
||||||
)
|
|
||||||
pingOut, pingError = ping.communicate()
|
|
||||||
# print out
|
|
||||||
lossResult = re.search(r' ([\d\.]+)% packet loss', pingOut, re.MULTILINE)
|
|
||||||
rttAvgResult = re.search(r' = [\d\.]+/([\d\.]+)/[\d\.]+/[\d\.]+', pingOut, re.MULTILINE)
|
|
||||||
if pingError or lossResult is None or rttAvgResult is None:
|
|
||||||
output = {'loss':-1, 'rtt_avg':-1};
|
|
||||||
else:
|
|
||||||
output = {'loss':lossResult.group(1), 'rtt_avg':rttAvgResult.group(1)};
|
|
||||||
return output
|
|
||||||
|
|
||||||
#
|
|
||||||
# Runtime
|
|
||||||
#
|
|
||||||
|
|
||||||
if __name__ == "__main__":
|
|
||||||
pinger = Pinger()
|
|
BIN
pinger.png
BIN
pinger.png
Binary file not shown.
Before Width: | Height: | Size: 18 KiB |
320
pinger.py
Executable file → Normal file
320
pinger.py
Executable file → Normal file
|
@ -1,11 +1,9 @@
|
||||||
#!/usr/bin/env python
|
#!/usr/bin/env python
|
||||||
# -*- coding: utf-8 -*-
|
|
||||||
#
|
#
|
||||||
# Pinger.py -- A ping tool that sits in your system tray
|
# Pinger.py -- A ping tool that sits in your system tray
|
||||||
# Copyright 2013 Will Bradley
|
# Copyright 2013 Will Bradley
|
||||||
#
|
#
|
||||||
# Contributors: Will Bradley <bradley.will@gmail.com>
|
# Authors: Will Bradley <bradley.will@gmail.com>
|
||||||
# AltF4 <altf4@phx2600.org>
|
|
||||||
#
|
#
|
||||||
# This program is free software: you can redistribute it and/or modify it
|
# This program is free software: you can redistribute it and/or modify it
|
||||||
# under the terms of either or both of the following licenses:
|
# under the terms of either or both of the following licenses:
|
||||||
|
@ -26,6 +24,10 @@
|
||||||
# <http://www.gnu.org/licenses/>
|
# <http://www.gnu.org/licenses/>
|
||||||
#
|
#
|
||||||
|
|
||||||
|
# User-editable variables
|
||||||
|
host = "4.2.2.2" # IP or hostname
|
||||||
|
ping_frequency = 5 # in seconds
|
||||||
|
|
||||||
#
|
#
|
||||||
# Dependencies
|
# Dependencies
|
||||||
#
|
#
|
||||||
|
@ -35,7 +37,6 @@ from gi.repository import Gtk
|
||||||
from gi.repository import AppIndicator3 as appindicator
|
from gi.repository import AppIndicator3 as appindicator
|
||||||
# Timer
|
# Timer
|
||||||
from gi.repository import GObject as gobject
|
from gi.repository import GObject as gobject
|
||||||
import datetime
|
|
||||||
# Pinging
|
# Pinging
|
||||||
import subprocess
|
import subprocess
|
||||||
# Regex
|
# Regex
|
||||||
|
@ -44,155 +45,42 @@ import re
|
||||||
import signal
|
import signal
|
||||||
# File paths
|
# File paths
|
||||||
import os
|
import os
|
||||||
# Argument parsing
|
|
||||||
import argparse
|
|
||||||
# For exit
|
|
||||||
import sys
|
|
||||||
# For graphing
|
|
||||||
import cairo
|
|
||||||
# For IP addresses
|
|
||||||
import socket, struct
|
|
||||||
|
|
||||||
# Vars
|
# Vars
|
||||||
startup_active_label = "✓ Start Automatically"
|
startup_label = "Start Automatically"
|
||||||
startup_inactive_label = "Start Automatically"
|
|
||||||
pause_label = "Pause"
|
|
||||||
play_label = "Resume"
|
|
||||||
home_path = os.path.expanduser("~")
|
home_path = os.path.expanduser("~")
|
||||||
startup_path = home_path+'/.config/autostart/pinger.desktop'
|
startup_path = home_path+'/.config/autostart/pinger.desktop'
|
||||||
startup_dir = home_path+'/.config/autostart/'
|
|
||||||
|
|
||||||
parser = argparse.ArgumentParser()
|
|
||||||
parser.add_argument("-t", "--target", help="Target to PING against. (IP / Hostname / Domain name). Defaults to 8.8.8.8")
|
|
||||||
parser.add_argument("-f", "--freq", help="Timeout between pings, in seconds. Defaults to 5")
|
|
||||||
parser.add_argument("-m", "--maxlog", help="Maximum amount of pings to log. Defaults to 40")
|
|
||||||
parser.add_argument("-c", "--color", help="Color scheme ('dark' or 'light'). Defaults to dark.")
|
|
||||||
args = parser.parse_args()
|
|
||||||
|
|
||||||
ubuntu_mono_dark_rgba = [0xdf, 0xd8, 0xc8, 0xff]
|
|
||||||
ubuntu_mono_light_rgba = [0x3a, 0x39, 0x35, 0xff]
|
|
||||||
black = [0, 0, 0, 0xff]
|
|
||||||
red = [0xdf, 0x38, 0x2c, 0xff]
|
|
||||||
orange = [0xdd, 0x48, 0x14, 0xff]
|
|
||||||
yellow = [0xef, 0xb7, 0x3e, 0xff]
|
|
||||||
white = [0xff, 0xff, 0xff, 0xff]
|
|
||||||
dark_bg = [0, 0, 0, 0x3f]
|
|
||||||
light_bg = [0xff, 0xff, 0xff, 0x3f]
|
|
||||||
|
|
||||||
#accumulate the arguments for use later
|
|
||||||
arguments = " "
|
|
||||||
for arg in sys.argv[1:]:
|
|
||||||
arguments += arg + " "
|
|
||||||
|
|
||||||
# User-editable variables
|
|
||||||
if args.target:
|
|
||||||
default_host = args.target
|
|
||||||
else:
|
|
||||||
print "Using default Internet target of 8.8.8.8"
|
|
||||||
default_host = "8.8.8.8" # IP or hostname of WAN
|
|
||||||
|
|
||||||
default_router = "192.168.1.1" # IP or hostname of router
|
|
||||||
|
|
||||||
if args.freq:
|
|
||||||
try:
|
|
||||||
ping_frequency = int(args.freq)
|
|
||||||
except ValueError:
|
|
||||||
sys.stderr.write("Error parsing argument '--freq'\n")
|
|
||||||
sys.exit(1)
|
|
||||||
else:
|
|
||||||
ping_frequency = 5 # in seconds
|
|
||||||
|
|
||||||
if args.maxlog:
|
|
||||||
try:
|
|
||||||
ping_log_max_size = int(args.maxlog)
|
|
||||||
except ValueError:
|
|
||||||
sys.stderr.write("Error parsing argument '--maxlog'\n")
|
|
||||||
sys.exit(1)
|
|
||||||
else:
|
|
||||||
ping_log_max_size = 40
|
|
||||||
|
|
||||||
if args.color == "light":
|
|
||||||
graph_color = ubuntu_mono_light_rgba
|
|
||||||
danger_color = red
|
|
||||||
warning_color = yellow
|
|
||||||
graph_highlight = ubuntu_mono_dark_rgba
|
|
||||||
graph_background = light_bg
|
|
||||||
else:
|
|
||||||
graph_color = ubuntu_mono_dark_rgba
|
|
||||||
danger_color = red
|
|
||||||
warning_color = yellow
|
|
||||||
graph_highlight = ubuntu_mono_light_rgba
|
|
||||||
graph_background = dark_bg
|
|
||||||
|
|
||||||
#
|
#
|
||||||
# Main Class
|
# Main Class
|
||||||
#
|
#
|
||||||
|
|
||||||
class Pinger:
|
class Pinger:
|
||||||
host = None
|
|
||||||
router = None
|
|
||||||
host_log = []
|
|
||||||
router_log = []
|
|
||||||
paused = False
|
|
||||||
autostart = False
|
|
||||||
icon_height = 22
|
|
||||||
|
|
||||||
def ping(self, target, log, widget=None, data=None):
|
def ping(self, widget=None, data=None):
|
||||||
if not self.paused:
|
ping = subprocess.Popen(
|
||||||
#print "Pinging "+str(target)
|
["ping", "-c", "1", host],
|
||||||
ping = subprocess.Popen(
|
stdout = subprocess.PIPE,
|
||||||
["ping", "-c", "1", target],
|
stderr = subprocess.PIPE
|
||||||
stdout = subprocess.PIPE,
|
)
|
||||||
stderr = subprocess.PIPE
|
out, error = ping.communicate()
|
||||||
)
|
m = re.search('time=(.*) ms', out)
|
||||||
out, error = ping.communicate()
|
if error or m == None:
|
||||||
m = re.search('time=(.*) ms', out)
|
label = "PING FAIL"
|
||||||
if error or m == None:
|
else:
|
||||||
label = "PING FAIL"
|
label = m.group(1)+" ms"
|
||||||
self.log_ping(log, -1)
|
self.ind.set_label (label, "100.0 ms")
|
||||||
else:
|
#self.ping_menu_item.set_label(out)
|
||||||
latency = "%.2f" % float(m.group(1))
|
gobject.timeout_add_seconds(self.timeout, self.ping)
|
||||||
label = latency+" ms"
|
|
||||||
self.log_ping(log, latency)
|
|
||||||
|
|
||||||
#self.ind.set_label(label, "100.0 ms")
|
def create_menu_item(self, menu_type, text, callback):
|
||||||
|
if menu_type == "check":
|
||||||
|
menu_item = Gtk.CheckMenuItem(text)
|
||||||
def ping_both(self):
|
menu_item.set_active(True)
|
||||||
self.ping(self.host, self.host_log)
|
else:
|
||||||
self.ping(self.router, self.router_log)
|
menu_item = Gtk.MenuItem(text)
|
||||||
self.update_log_menu()
|
|
||||||
|
|
||||||
# If we have 5 router failures, try getting the default GW again
|
|
||||||
if (self.routerLastUpdated != None
|
|
||||||
and (datetime.datetime.now()-self.routerLastUpdated).seconds > 60):
|
|
||||||
|
|
||||||
if (len(self.router_log) > 5
|
|
||||||
and self.router_log[-1] == -1
|
|
||||||
and self.router_log[-2] == -1
|
|
||||||
and self.router_log[-3] == -1):
|
|
||||||
|
|
||||||
new_router = self.get_default_gateway_linux()
|
|
||||||
# Only update router if it's not blank
|
|
||||||
if new_router != None:
|
|
||||||
self.router = new_router
|
|
||||||
print "Updated router target to "+str(self.router)
|
|
||||||
self.routerLastUpdated = datetime.datetime.now()
|
|
||||||
|
|
||||||
gobject.timeout_add_seconds(self.timeout, self.ping_both)
|
|
||||||
|
|
||||||
def log_ping(self, log, value):
|
|
||||||
log.append(float(value))
|
|
||||||
# limit the size of the log
|
|
||||||
if len(log) >= ping_log_max_size:
|
|
||||||
# remove the earliest ping, not the latest
|
|
||||||
log.pop(0)
|
|
||||||
|
|
||||||
def create_menu_item(self, text, callback):
|
|
||||||
menu_item = Gtk.MenuItem(text)
|
|
||||||
self.menu.append(menu_item)
|
self.menu.append(menu_item)
|
||||||
if callback:
|
menu_item.connect("activate", callback, text)
|
||||||
menu_item.connect("activate", callback, text)
|
|
||||||
menu_item.show()
|
menu_item.show()
|
||||||
return menu_item
|
return menu_item
|
||||||
|
|
||||||
|
@ -200,107 +88,27 @@ class Pinger:
|
||||||
print "Quitting..."
|
print "Quitting..."
|
||||||
Gtk.main_quit()
|
Gtk.main_quit()
|
||||||
|
|
||||||
def toggle_autostart(self, widget, data=None):
|
def create_autostart(self, widget, data=None):
|
||||||
if not self.autostart:
|
with open(startup_path,'w') as f:
|
||||||
if not os.path.exists(startup_dir):
|
f.write("[Desktop Entry]\r\n"
|
||||||
os.makedirs(startup_dir)
|
"Type=Application\r\n"
|
||||||
with open(startup_path,'w') as f:
|
"Exec=python "+os.path.abspath( __file__ )+"\r\n"
|
||||||
f.write("[Desktop Entry]\r\n"
|
"X-GNOME-Autostart-enabled=true\r\n"
|
||||||
"Type=Application\r\n"
|
"Name=Pinger\r\n"
|
||||||
"Exec=python "+os.path.abspath( __file__ )+arguments+"\r\n"
|
"Comment=Pings the internet every few seconds")
|
||||||
"X-GNOME-Autostart-enabled=true\r\n"
|
self.update_startup_menu()
|
||||||
"Name=Pinger\r\n"
|
|
||||||
"Comment=Pings the internet every few seconds")
|
|
||||||
self.autostart = True
|
|
||||||
self.startup_menu.set_label(startup_active_label)
|
|
||||||
else:
|
|
||||||
os.remove(startup_path)
|
|
||||||
self.autostart = False
|
|
||||||
self.startup_menu.set_label(startup_inactive_label)
|
|
||||||
|
|
||||||
def toggle_pause(self, widget, data=None):
|
def remove_autostart(self, widget, data=None):
|
||||||
if self.paused:
|
os.remove(startup_path)
|
||||||
self.paused = False
|
self.update_startup_menu()
|
||||||
self.pause_menu.set_label(pause_label)
|
|
||||||
else:
|
|
||||||
self.paused = True
|
|
||||||
self.pause_menu.set_label(play_label)
|
|
||||||
|
|
||||||
def update_log_menu(self):
|
|
||||||
surface = cairo.ImageSurface(cairo.FORMAT_ARGB32, ping_log_max_size, self.icon_height)
|
|
||||||
ctx = cairo.Context(surface)
|
|
||||||
|
|
||||||
# draw semitransparent box
|
|
||||||
self.draw_rect( ctx, [0,0], [ping_log_max_size,self.icon_height], graph_background )
|
|
||||||
|
|
||||||
if len(self.host_log) > 0:
|
|
||||||
self.draw_log(ctx, self.host_log, 0)
|
|
||||||
host_avg = sum(self.host_log)/len(self.host_log)
|
|
||||||
self.ping_menu.set_label("Internet: "+str(int(round(self.host_log[-1])))+" ms "+str(int(round(host_avg)))+" avg")
|
|
||||||
if len(self.router_log) > 0:
|
|
||||||
self.draw_log(ctx, self.router_log, (self.icon_height/2))
|
|
||||||
router_avg = sum(self.router_log)/len(self.router_log)
|
|
||||||
self.router_menu.set_label("Router: "+str(int(round(self.router_log[-1])))+" ms "+str(int(round(router_avg)))+" avg")
|
|
||||||
|
|
||||||
try:
|
|
||||||
os.remove("/tmp/graph.png")
|
|
||||||
except:
|
|
||||||
pass
|
|
||||||
surface.write_to_png("/tmp/graph.png")
|
|
||||||
self.ind.set_icon("") # gotta set it to nothing in order to update
|
|
||||||
self.ind.set_icon("graph")
|
|
||||||
|
|
||||||
|
def update_startup_menu(self):
|
||||||
def draw_log(self, ctx, log, yOffset):
|
if os.path.exists(startup_path):
|
||||||
if(max(log) < 100):
|
self.startup_menu.connect("activate", self.remove_autostart, startup_label)
|
||||||
max_ping = 100
|
self.startup_menu.set_active(False)
|
||||||
elif(max(log) > 1000):
|
|
||||||
max_ping = 1000
|
|
||||||
else:
|
else:
|
||||||
max_ping = max(log)
|
self.startup_menu.connect("activate", self.create_autostart, startup_label)
|
||||||
|
self.startup_menu.set_active(True)
|
||||||
for index, ping in enumerate(log):
|
|
||||||
|
|
||||||
if float(ping) == -1: # Ping error
|
|
||||||
# Draw full-height error bar
|
|
||||||
|
|
||||||
self.draw_rect( ctx, [index,(self.icon_height/2)+yOffset], [1,(-self.icon_height/2)-1], danger_color )
|
|
||||||
else:
|
|
||||||
# draw normal bar
|
|
||||||
bar_height = -int(self.scale(ping, (0,max_ping), (0,(self.icon_height/2)-1)))
|
|
||||||
|
|
||||||
if bar_height > -1:
|
|
||||||
bar_height = -1
|
|
||||||
|
|
||||||
if ping > 100:
|
|
||||||
color = warning_color
|
|
||||||
else:
|
|
||||||
color = graph_color
|
|
||||||
|
|
||||||
self.draw_rect( ctx, [index,self.icon_height/2+yOffset], [1,bar_height], color )
|
|
||||||
|
|
||||||
|
|
||||||
def draw_rect(self, ctx, point, size, rgba):
|
|
||||||
ctx.rectangle( point[0], point[1], size[0], size[1] )
|
|
||||||
ctx.set_source_rgba(rgba[0]/float(255), rgba[1]/float(255), rgba[2]/float(255), rgba[3]/float(255))
|
|
||||||
ctx.fill()
|
|
||||||
|
|
||||||
def scale(self, val, src, dst):
|
|
||||||
"""
|
|
||||||
Scale the given value from the scale of src to the scale of dst.
|
|
||||||
"""
|
|
||||||
scale = ((val - src[0]) / (src[1]-src[0])) * (dst[1]-dst[0]) + dst[0]
|
|
||||||
return scale
|
|
||||||
|
|
||||||
def get_default_gateway_linux(self):
|
|
||||||
# Read the default gateway directly from /proc.
|
|
||||||
with open("/proc/net/route") as fh:
|
|
||||||
for line in fh:
|
|
||||||
fields = line.strip().split()
|
|
||||||
if fields[1] != '00000000' or not int(fields[3], 16) & 2:
|
|
||||||
continue
|
|
||||||
|
|
||||||
return str(socket.inet_ntoa(struct.pack("<L", int(fields[2], 16))))
|
|
||||||
|
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
# Handle ctrl-c
|
# Handle ctrl-c
|
||||||
|
@ -313,44 +121,22 @@ class Pinger:
|
||||||
self.ind = appindicator.Indicator.new (
|
self.ind = appindicator.Indicator.new (
|
||||||
"pinger",
|
"pinger",
|
||||||
"", # no icon
|
"", # no icon
|
||||||
appindicator.IndicatorCategory.SYSTEM_SERVICES)
|
appindicator.IndicatorCategory.COMMUNICATIONS)
|
||||||
self.ind.set_status (appindicator.IndicatorStatus.ACTIVE)
|
self.ind.set_status (appindicator.IndicatorStatus.ACTIVE)
|
||||||
#self.ind.set_label ("Pinger Loading...", "Pinger Loading...")
|
self.ind.set_label ("Pinger Loading...", "Pinger Loading...")
|
||||||
self.ind.set_icon_theme_path("/tmp")
|
|
||||||
|
|
||||||
# create a menu
|
# create a menu
|
||||||
self.menu = Gtk.Menu()
|
self.menu = Gtk.Menu()
|
||||||
# with ping numbers
|
|
||||||
self.ping_menu = self.create_menu_item("", None)
|
self.startup_menu = self.create_menu_item("check",startup_label, self.remove_autostart)
|
||||||
self.router_menu = self.create_menu_item("", None)
|
#self.update_startup_menu()
|
||||||
# with pause option
|
self.create_menu_item(None, "Exit", self.destroy)
|
||||||
self.pause_menu = self.create_menu_item(pause_label, self.toggle_pause)
|
|
||||||
# with autostart option
|
|
||||||
# first, check current autostart state by checking existance of .desktop file
|
|
||||||
if os.path.exists(startup_path):
|
|
||||||
self.autostart = True
|
|
||||||
self.startup_menu = self.create_menu_item(startup_active_label, self.toggle_autostart)
|
|
||||||
else:
|
|
||||||
self.autostart = False
|
|
||||||
self.startup_menu = self.create_menu_item(startup_inactive_label, self.toggle_autostart)
|
|
||||||
# and exit option
|
|
||||||
self.create_menu_item("Exit", self.destroy)
|
|
||||||
self.ind.set_menu(self.menu)
|
self.ind.set_menu(self.menu)
|
||||||
|
|
||||||
# load host/router vars
|
|
||||||
self.host = default_host
|
|
||||||
|
|
||||||
# set router / gateway dynamically
|
|
||||||
self.router = self.get_default_gateway_linux()
|
|
||||||
if self.router == None:
|
|
||||||
self.router = default_router
|
|
||||||
print "Set router target to "+str(self.router)
|
|
||||||
self.routerLastUpdated = datetime.datetime.now()
|
|
||||||
|
|
||||||
# start the ping process
|
# start the ping process
|
||||||
self.counter = 0
|
self.counter = 0
|
||||||
self.timeout = ping_frequency
|
self.timeout = ping_frequency
|
||||||
self.ping_both()
|
self.ping()
|
||||||
|
|
||||||
# Print started message
|
# Print started message
|
||||||
print "Started."
|
print "Started."
|
||||||
|
|
Loading…
Reference in New Issue
Block a user