133
133
u" retries, exiting.", rename_count)
134
134
raise AvahiServiceError("Too many renames")
135
135
name = server.GetAlternativeServiceName(name)
136
logger.notice(u"Changing name to %r ...", name)
136
logger.error(u"Changing name to %r ...", name)
139
139
self.rename_count += 1
221
221
interval = property(lambda self: self._interval,
223
223
del _set_interval
224
def __init__(self, name=None, stop_hook=None, fingerprint=None,
225
secret=None, secfile=None, fqdn=None, timeout=None,
226
interval=-1, checker=None):
224
def __init__(self, name = None, stop_hook=None, config={}):
227
225
"""Note: the 'checker' argument sets the 'checker_command'
228
226
attribute and not the 'checker' attribute.."""
231
229
# Uppercase and remove spaces from fingerprint
232
230
# for later comparison purposes with return value of
233
231
# the fingerprint() function
234
self.fingerprint = fingerprint.upper().replace(u" ", u"")
232
self.fingerprint = config["fingerprint"].upper()\
235
234
logger.debug(u" Fingerprint: %s", self.fingerprint)
237
self.secret = secret.decode(u"base64")
235
if "secret" in config:
236
self.secret = config["secret"].decode(u"base64")
237
elif "secfile" in config:
238
sf = open(config["secfile"])
240
239
self.secret = sf.read()
243
242
raise TypeError(u"No secret or secfile for client %s"
244
self.fqdn = config.get("fqdn", "")
246
245
self.created = datetime.datetime.now()
247
246
self.last_checked_ok = None
248
self.timeout = string_to_delta(timeout)
249
self.interval = string_to_delta(interval)
247
self.timeout = string_to_delta(config["timeout"])
248
self.interval = string_to_delta(config["interval"])
250
249
self.stop_hook = stop_hook
251
250
self.checker = None
252
251
self.checker_initiator_tag = None
253
252
self.stop_initiator_tag = None
254
253
self.checker_callback_tag = None
255
self.check_command = checker
254
self.check_command = config["checker"]
257
256
"""Start this client's checker and timeout hooks"""
258
257
# Schedule a new checker to be started an 'interval' from now,
272
271
but not currently used."""
273
272
# If this client doesn't have a secret, it is already stopped.
275
logger.debug(u"Stopping client %s", self.name)
274
logger.info(u"Stopping client %s", self.name)
276
275
self.secret = None
297
296
self.checker = None
298
297
if os.WIFEXITED(condition) \
299
298
and (os.WEXITSTATUS(condition) == 0):
300
logger.debug(u"Checker for %(name)s succeeded",
299
logger.info(u"Checker for %(name)s succeeded",
302
301
self.last_checked_ok = now
303
302
gobject.source_remove(self.stop_initiator_tag)
304
303
self.stop_initiator_tag = gobject.timeout_add\
308
307
logger.warning(u"Checker for %(name)s crashed?",
311
logger.debug(u"Checker for %(name)s failed",
310
logger.info(u"Checker for %(name)s failed",
313
312
def start_checker(self):
314
313
"""Start a new checker subprocess if one is not running.
315
314
If a checker already exists, leave it running and do
338
337
u' %s', self.check_command, error)
339
338
return True # Try again later
341
logger.debug(u"Starting checker %r for %s",
340
logger.info(u"Starting checker %r for %s",
343
342
self.checker = subprocess.Popen(command,
345
344
shell=True, cwd="/")
431
430
Note: This will run in its own forked process."""
433
432
def handle(self):
434
logger.debug(u"TCP connection from: %s",
433
logger.info(u"TCP connection from: %s",
435
434
unicode(self.client_address))
436
435
session = gnutls.connection.ClientSession\
437
436
(self.request, gnutls.connection.X509Credentials())
438
line = self.request.makefile().readline()
439
logger.debug(u"Protocol version: %r", line)
441
if int(line.strip().split()[0]) > 1:
443
except (ValueError, IndexError, RuntimeError), error:
444
logger.error(u"Unknown protocol version: %s", error)
438
447
# Note: gnutls.connection.X509Credentials is really a generic
439
448
# GnuTLS certificate credentials object so long as no X.509
440
449
# keys are added to it. Therefore, we can use it here despite
454
463
session.handshake()
455
464
except gnutls.errors.GNUTLSError, error:
456
logger.debug(u"Handshake failed: %s", error)
465
logger.warning(u"Handshake failed: %s", error)
457
466
# Do not run session.bye() here: the session is not
458
467
# established. Just abandon the request.
461
470
fpr = fingerprint(peer_certificate(session))
462
471
except (TypeError, gnutls.errors.GNUTLSError), error:
463
logger.debug(u"Bad certificate: %s", error)
472
logger.warning(u"Bad certificate: %s", error)
466
475
logger.debug(u"Fingerprint: %s", fpr)
473
logger.debug(u"Client not found for fingerprint: %s", fpr)
482
logger.warning(u"Client not found for fingerprint: %s",
476
486
# Have to check if client.still_valid(), since it is possible
477
487
# that the client timed out while establishing the GnuTLS
479
489
if not client.still_valid():
480
logger.debug(u"Client %(name)s is invalid", vars(client))
490
logger.warning(u"Client %(name)s is invalid",
518
529
self.settings["interface"])
519
530
except socket.error, error:
520
531
if error[0] == errno.EPERM:
521
logger.warning(u"No permission to"
522
u" bind to interface %s",
523
self.settings["interface"])
532
logger.error(u"No permission to"
533
u" bind to interface %s",
534
self.settings["interface"])
526
537
# Only bind(2) the socket if we really need to.
572
583
def server_state_changed(state):
573
584
"""Derived from the Avahi example code"""
574
585
if state == avahi.SERVER_COLLISION:
575
logger.warning(u"Server name collision")
586
logger.error(u"Server name collision")
577
588
elif state == avahi.SERVER_RUNNING:
593
604
raise AvahiGroupError("State changed: %s", str(error))
595
def if_nametoindex(interface, _func=[None]):
606
def if_nametoindex(interface):
596
607
"""Call the C function if_nametoindex(), or equivalent"""
597
if _func[0] is not None:
598
return _func[0](interface)
608
global if_nametoindex
600
610
if "ctypes.util" not in sys.modules:
601
611
import ctypes.util
604
libc = ctypes.cdll.LoadLibrary\
605
(ctypes.util.find_library("c"))
606
_func[0] = libc.if_nametoindex
607
return _func[0](interface)
612
if_nametoindex = ctypes.cdll.LoadLibrary\
613
(ctypes.util.find_library("c")).if_nametoindex
611
614
except (OSError, AttributeError):
612
615
if "struct" not in sys.modules:
614
617
if "fcntl" not in sys.modules:
616
def the_hard_way(interface):
619
def if_nametoindex(interface):
617
620
"Get an interface index the hard way, i.e. using fcntl()"
618
621
SIOCGIFINDEX = 0x8933 # From /usr/include/linux/sockios.h
619
622
s = socket.socket()
623
626
interface_index = struct.unpack("I", ifreq[16:20])[0]
624
627
return interface_index
625
_func[0] = the_hard_way
626
return _func[0](interface)
628
return if_nametoindex(interface)
629
631
def daemon(nochdir, noclose):
751
753
def remove_from_clients(client):
752
754
clients.remove(client)
754
logger.debug(u"No clients left, exiting")
756
logger.critical(u"No clients left, exiting")
757
clients.update(Set(Client(name=section,
759
clients.update(Set(Client(name = section,
758
760
stop_hook = remove_from_clients,
759
**(dict(client_config\
762
= dict(client_config.items(section)))
761
763
for section in client_config.sections()))
795
797
# Find out what port we got
796
798
service.port = tcp_server.socket.getsockname()[1]
797
logger.debug(u"Now listening on address %r, port %d, flowinfo %d,"
798
u" scope_id %d" % tcp_server.socket.getsockname())
799
logger.info(u"Now listening on address %r, port %d, flowinfo %d,"
800
u" scope_id %d" % tcp_server.socket.getsockname())
800
802
#service.interface = tcp_server.socket.getsockname()[3]