mirrors/deluge
0
0
Fork 0
mirror of https://git.deluge-torrent.org/deluge synced 2025-08-10 18:38:39 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Only update the peers list as necessary.

Browse source
This commit is contained in:
Andrew Resch 2008-04-08 05:55:20 +00:00
commit 3ca459df87
1 changed files with 49 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

67
deluge/ui/gtkui/peers_tab.py
View file

@ -56,13 +56,16 @@ class PeersTab:
def __init__(self): def __init__(self):
glade = component.get("MainWindow").get_glade() glade = component.get("MainWindow").get_glade()
self.listview = glade.get_widget("peers_listview") self.listview = glade.get_widget("peers_listview")
# country pixbuf, ip, client, progress, progress, downspeed, upspeed, country code, int_ip, seed/peer icon # country pixbuf, ip, client, downspeed, upspeed, country code, int_ip, seed/peer icon
self.liststore = gtk.ListStore(gtk.gdk.Pixbuf, str, str, int, int, str, int, gtk.gdk.Pixbuf) self.liststore = gtk.ListStore(gtk.gdk.Pixbuf, str, str, int, int, str, int, gtk.gdk.Pixbuf)
self.cached_flag_pixbufs = {} self.cached_flag_pixbufs = {}
self.seed_pixbuf = gtk.gdk.pixbuf_new_from_file(deluge.common.get_pixmap("seeding16.png")) self.seed_pixbuf = gtk.gdk.pixbuf_new_from_file(deluge.common.get_pixmap("seeding16.png"))
self.peer_pixbuf = gtk.gdk.pixbuf_new_from_file(deluge.common.get_pixmap("downloading16.png")) self.peer_pixbuf = gtk.gdk.pixbuf_new_from_file(deluge.common.get_pixmap("downloading16.png"))
# key is ip address, item is row iter
self.peers = {}
# Country column # Country column
column = gtk.TreeViewColumn() column = gtk.TreeViewColumn()
render = gtk.CellRendererPixbuf() render = gtk.CellRendererPixbuf()
@ -208,6 +211,7 @@ class PeersTab:
if torrent_id != self.torrent_id: if torrent_id != self.torrent_id:
# We only want to do this if the torrent_id has changed # We only want to do this if the torrent_id has changed
self.liststore.clear() self.liststore.clear()
self.peers = {}
self.torrent_id = torrent_id self.torrent_id = torrent_id
client.get_torrent_status(self._on_get_torrent_status, torrent_id, ["peers"]) client.get_torrent_status(self._on_get_torrent_status, torrent_id, ["peers"])
@ -231,25 +235,52 @@ class PeersTab:
return self.cached_flag_pixbufs[country] return self.cached_flag_pixbufs[country]
def _on_get_torrent_status(self, status): def _on_get_torrent_status(self, status):
self.liststore.clear() new_ips = set()
for peer in status["peers"]: for peer in status["peers"]:
# Create an int IP address for sorting purposes new_ips.add(peer["ip"])
ip_int = sum([int(byte) << shift if self.peers.has_key(peer["ip"]):
for byte, shift in izip(peer["ip"].split(":")[0].split("."), (24, 16, 8, 0))]) # We already have this peer in our list, so lets just update it
if peer["seed"]: row = self.peers[peer["ip"]]
icon = self.seed_pixbuf values = self.liststore.get(row, 3, 4, 7)
if peer["down_speed"] != values[0]:
self.liststore.set_value(row, 3, values[0])
if peer["up_speed"] != values[1]:
self.liststore.set_value(row, 4, values[1])
if peer["seed"]:
icon = self.seed_pixbuf
else:
icon = self.peer_pixbuf
if icon != values[2]:
self.liststore.set_value(row, 7, values[2])
else: else:
icon = self.peer_pixbuf # Peer is not in list so we need to add it
self.liststore.append([ # Create an int IP address for sorting purposes
self.get_flag_pixbuf(peer["country"]), ip_int = sum([int(byte) << shift
peer["ip"], for byte, shift in izip(peer["ip"].split(":")[0].split("."), (24, 16, 8, 0))])
peer["client"], if peer["seed"]:
peer["down_speed"], icon = self.seed_pixbuf
peer["up_speed"], else:
peer["country"], icon = self.peer_pixbuf
ip_int,
icon]) row = self.liststore.append([
self.get_flag_pixbuf(peer["country"]),
peer["ip"],
peer["client"],
peer["down_speed"],
peer["up_speed"],
peer["country"],
ip_int,
icon])
self.peers[peer["ip"]] = row
# Now we need to remove any ips that were not in status["peers"] list
for ip in set(self.peers.keys()).difference(new_ips):
self.liststore.remove(self.peers[ip])
del self.peers[ip]
def clear(self): def clear(self):
self.liststore.clear() self.liststore.clear()