Para que una aplicación gráfica guste, lo primero es que funcione bien, pero lo segundo y en este órden es que sea agradable a la vista y no parezca que se arrastra...
Por eso he estado implementando que algunas acciones de TcosMonitor se ejecuten en hilos (Threads) para que la interfaz no se congele, todavía no funciona todo lo bien que quisiera pero la fluided se nota bastante.
Por ejemplo, el descubrimiento de equipos, es decir, las máquinas conectadas al puerto 6000 del servidor (realmente a 6000-6009 porque parece que LTSP si se configura startx en un screen distinto del 0 se conecta a otro puerto... )
Esto es el código que se ejecuta al pulsar el botón de actualizar:
def on_refreshbutton_click(self,widget):
if self.init.searching:
print_debug( "on_refreshbutton_click() searching TRUE" )
# FIXME show a msg
return
self.write_into_statusbar ( _("Searching for connected hosts...") )
allclients=self.localdata.GetAllClients()
if len(allclients) == 0:
self.write_into_statusbar ( _("Not connected hosts found.") )
return
else:
txt=_("Found %d hosts, retrieving data..." ) %len(allclients)
self.write_into_statusbar ( txt )
# populate_list in a thread
Thread( target=self.init.populate_hostlist, args=([allclients]) ).start()
return
La acción que más tiempo lleva es tomar usuario, nombre de host, número de procesos, tiempo conectado, y estado del bloqueo de pantalla para cada equipo, por lo que esto se ejecuta en un nuevo Thread (línea negrita), siendo el trozo subrallado la función que hace todas estas cosas.
La función populate_hostlist de la clase Initialize es la siguiente:
def populate_hostlist(self, clients):
print_debug ( "populate_hostlist() init" )
start1=time()
if self.searching:
return
self.searching=True
# clean list
print_debug ( "populate_hostlist() clear list!!!" )
self.model.clear()
COL_HOST, COL_IP, COL_USERNAME, COL_ACTIVE, COL_LOGGED, COL_BLOCKED, COL_PROCESS, COL_TIME = range(8)
inactive_image = gtk.gdk.pixbuf_new_from_file(shared.GLADE_DIR + '/images/inactive.png')
active_image = gtk.gdk.pixbuf_new_from_file(shared.GLADE_DIR + '/images/active.png')
logged_image = gtk.gdk.pixbuf_new_from_file(shared.GLADE_DIR + '/images/logged.png')
unlogged_image = gtk.gdk.pixbuf_new_from_file(shared.GLADE_DIR + '/images/unlogged.png')
locked_image = gtk.gdk.pixbuf_new_from_file(shared.GLADE_DIR + '/images/locked.png')
unlocked_image = gtk.gdk.pixbuf_new_from_file(shared.GLADE_DIR + '/images/unlocked.png')
i=0
for host in clients:
i += 1
self.main.localdata.newhost(host)
self.main.xmlrpc.newhost (host)
ip=host
hostname=self.main.localdata.GetHostname(ip)
username=self.main.localdata.GetUsername(ip)
num_process=self.main.localdata.GetNumProcess(ip)
time_logged=self.main.localdata.GetTimeLogged(ip)
if self.main.localdata.IsActive(ip):
image_active=active_image
else:
image_active=inactive_image
if self.main.localdata.IsLogged(ip):
image_logged=logged_image
else:
image_logged=unlogged_image
if self.main.localdata.IsBlocked(host):
image_blocked=locked_image
else:
image_blocked=unlocked_image
gtk.threads_enter()
self.iter = self.model.append (None)
self.model.set_value (self.iter, COL_HOST, hostname )
self.model.set_value (self.iter, COL_IP, host )
self.model.set_value (self.iter, COL_USERNAME, username )
self.model.set_value (self.iter, COL_ACTIVE, image_active )
self.model.set_value (self.iter, COL_LOGGED, image_logged)
self.model.set_value (self.iter, COL_BLOCKED, image_blocked)
self.model.set_value (self.iter, COL_PROCESS, num_process )
self.model.set_value (self.iter, COL_TIME, time_logged)
gtk.threads_leave()
crono(start1, "populate_host_list(%s)" %(ip) )
print_debug ( "populate_hostlist() END" )
self.searching=False
return
El código en negrita es lo más crítico de la función ya que accede al interfaz gráfico GTK para completar los valores del TreeView, por eso van encerrados entre llamadas a gtk.threads_{enter,leave}. La función crono no es más que un cronómetro que resta dos variables de tiempo para saber cuando se tarda en ejecutar el proceso, si se desactiva el modo debug hay muchas cosas que ya no se ejecutan como ésta.
Como se puede adivinar self.searching es un bloqueo para que no se llame a esta función si ya se está ejecutando.
Funciona bastante bien pero de vez en cuando y aleatoriamente da una extraña violación de segmento acompañada de un fallo de tubería de wc, que me da que pensar que algo falla en la extracción del número de procesos:
cmd=" ps aux|grep "^%s "| wc -l" %(self.username)
He añadido un par de condiciones a la función que lo hace y parece que ya no ha vuelto a suceder.
También estoy implementando un control de cache de los datos, por ejemplo, guardar en un array si el equipo está vivo (responde a los ping), los puertos abiertos, usuario y nombre de equipo, para que sólo se calculen la primera vez y el resto se devuelvan desde cache, para evitar problemas cada elemento del array (cada host) tiene un tiempo de vida que si se supera se vuelve a pedir, (configurable desde las preferencias).
Para terminar unas capturas de la interfaz un poco más bonita con sus iconos de menús, con una red simple de 3 equipos funcionando sobre 3 vmplayer en mi pobre portátil:
- tcos1 es un equipo basado en TCOS
- tcos2 es un equipo basado en LTSP 4.2
- tcos3 es un equipo basado en PXES 1.2
Con esto se demuestra que TcosMonitor ya funciona medianamente en las tres plataformas.
ATENCIÓN:
Los paquetes los he partido para no tener que instalar cosas que no vamos a usar:
tcosmonitor - interfaz pyhton
tcos-tcosmonitor - complementos para que tcosmonitor funcione con tcos
pxes-1.0-tcosmonitor - complementos para que tcosmonitor funcione con pxes-1.0
pxes-1.1-tcosmonitor - complementos para que tcosmonitor funcione con pxes-1.1
pxes-1.2-tcosmonitor - complementos para que tcosmonitor funcione con pxes1.2
ltsp-tcosmonitor - complementos para que tcosmonitor funcione con LTSP (instalado en /opt/ltsp)
El mirror donde siempre:
deb http://soleup.eup.uva.es/tcos/debian unstable main
