import Queue import os import pwd import threading import logger import tools _name_worker_lock = threading.Lock() _name_worker = {} def all(): pw_ents = pwd.getpwall() for pw_ent in pw_ents: if pw_ent[6] in acct_class_by_shell: yield acct_class_by_shell[pw_ent[6]].TYPE, pw_ent[0] def get(name): _name_worker_lock.acquire() try: if name not in _name_worker: _name_worker[name] = Worker(name) return _name_worker[name] finally: _name_worker_lock.release() def install_ssh_keys(rec): """Write to 's authorized_keys file.""" dot_ssh = '/home/%s/.ssh' % rec['name'] def do_installation(): if not os.access(dot_ssh, os.F_OK): os.mkdir(dot_ssh) tools.write_file(dot_ssh + '/authorized_keys', lambda thefile: thefile.write(rec['ssh_keys'])) logger.log('%s: installing ssh keys' % rec['name']) tools.fork_as(rec['name'], do_installation) TYPES = [] acct_class_by_shell = {} acct_class_by_type = {} def register_account_type(acct_class): TYPES.append(acct_class.TYPE) acct_class_by_shell[acct_class.SHELL] = acct_class acct_class_by_type[acct_class.TYPE] = acct_class class Worker: # these semaphores are acquired before creating/destroying an account _create_sem = threading.Semaphore(1) _destroy_sem = threading.Semaphore(1) def __init__(self, name): self.name = name self._acct = None self._q = Queue.Queue() tools.as_daemon_thread(self._run) def ensure_created(self, rec): self._q.put((self._ensure_created, tools.deepcopy(rec))) def _ensure_created(self, rec): curr_class = self._get_class() next_class = acct_class_by_type[rec['account_type']] if next_class != curr_class: self._destroy(curr_class) self._create_sem.acquire() try: next_class.create(self.name) finally: self._create_sem.release() self._make_acct_obj() self._acct.configure(rec) if next_class != curr_class: self._acct.start() def ensure_destroyed(self): self._q.put((self._ensure_destroyed,)) def _ensure_destroyed(self): self._destroy(self._get_class()) def start(self): self._q.put((self._start,)) def _start(self): self._make_acct_obj() self._acct.start() def stop(self): self._q.put((self._stop,)) def _stop(self): self._make_acct_obj() self._acct.stop() def _destroy(self, curr_class): self._acct = None if curr_class: self._destroy_sem.acquire() try: curr_class.destroy(self.name) finally: self._destroy_sem.release() def _get_class(self): try: shell = pwd.getpwnam(self.name)[6] except KeyError: return None return acct_class_by_shell[shell] def _make_acct_obj(self): curr_class = self._get_class() if not isinstance(self._acct, curr_class): self._acct = curr_class(self.name) def _run(self): while True: try: cmd = self._q.get() cmd[0](*cmd[1:]) except: logger.log_exc()