/usr/lib/python2.7/dist-packages/ControlAula/ScanTeachers.py is in controlaula 1.8.0-3.1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 | ##############################################################################
# -*- coding: utf-8 -*-
# Project: Controlaula
# Module: ScanTeachers.py
# Purpose: Class to browse the network looking for teachers
# Language: Python 2.5
# Date: 18-Jan-2010.
# Ver: 29-Jan-2010.
# Author: José L. Redrejo Rodríguez
# Copyright: 2009-2010 - José L. Redrejo Rodríguez <jredrejo @nospam@ debian.org>
#
# ControlAula 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 3 of the License, or
# (at your option) any later version.
# ControlAula 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 ControlAula. If not, see <http://www.gnu.org/licenses/>.
#
##############################################################################
try:
import dbus
if getattr(dbus, 'version', (0,0,0)) >= (0,41,0):
import dbus.glib
except ImportError:
dbus = None
if dbus:
try:
import avahi
except ImportError:
avahi = None
else:
avahi = None
import logging
class AvahiMonitor(object):
def __init__(self):
self._callbacks = {'new-service': [],
'remove-service': []
}
# initialize dbus stuff needed for discovery
self.bus = dbus.SystemBus()
avahi_bus = self.bus.get_object(avahi.DBUS_NAME, avahi.DBUS_PATH_SERVER)
self.server = dbus.Interface(avahi_bus, avahi.DBUS_INTERFACE_SERVER)
stype = '_controlaula._tcp'
domain = 'local'
self._plugged = {}
avahi_browser = self.server.ServiceBrowserNew(avahi.IF_UNSPEC,
avahi.PROTO_UNSPEC,
stype, domain,
dbus.UInt32(0))
obj = self.bus.get_object(avahi.DBUS_NAME, avahi_browser)
self.browser = dbus.Interface(obj, avahi.DBUS_INTERFACE_SERVICE_BROWSER)
def start(self):
self.browser.connect_to_signal('ItemNew', self.new_service)
self.browser.connect_to_signal('ItemRemove', self.remove_service)
def stop(self):
self.bus.close()
def new_service(self, interface, protocol, name, stype, domain, flags):
def resolve_service_reply(*service):
address, port = service[-4:-2]
name = unicode(service[2])
data=avahi.txt_array_to_string_array(service[9])
datdict={}
for i in data:
bit=i.split('=')
if len(bit)==2:
datdict[bit[0]]=bit[1]
for cb in self._callbacks['new-service']:
self._plugged[name] = (address,port)
cb(self,name, address, port,datdict)
def resolve_service_error(exception):
try:
if exception._dbus_error_name=="org.freedesktop.Avahi.TimeoutError":
#let'st try it again
# self.stop()
# self.start()
pass
except:
logging.getLogger().debug('could not resolve controlaula service %s %s: %s' % (name, domain, exception))
print exception
self.server.ResolveService(interface, protocol, name, stype, domain,
avahi.PROTO_UNSPEC, dbus.UInt32(0),
reply_handler=resolve_service_reply,
error_handler=resolve_service_error)
def remove_service(self, interface, protocol, name, stype, domain,server):
address, port = self._plugged[name]
for cb in self._callbacks['remove-service']:
cb(self,name, address, port)
def add_callback(self, sig_name, callback):
self._callbacks[sig_name].append(callback)
def remove_callback(self, sig_name, callback):
self._callback[sig_name].remove(callback)
|