from multiprocessing.managers import BaseManager,ListProxy

from iro.worker import Worker

from iro.job import Job

    def __init__(self,buffer=None):

        buffer.

            buffer: log messages to this buffer, needed f.ex for processes or threads'''

        self.buffer=buffer

        if record.exc_info:                                                      #sonst geht das append schief, weil nicht picklebar

            print record.exc_info

            record.exc_info=record.exc_info[:-1]                                              

MyManager.register('list', list, ListProxy)

        #erstelle eine Queue&Manager

        self.manager = MyManager()

        self.queue = Queue()

        #manager starten, damit wir Logging anpassen können

        self.manager.start()

        self.setUpLogging()

        #eigentlich Workerprocess starten

        self.worker= Worker(self.queue)

        self.worker.start()

    def tearDown(self):

        #Thread&Queue stoppen

        self.stop()

        #Logging änderungen rückgängig

        self.tearDownLogging()

        self.manager.shutdown()

    def stop(self):

        self.queue.close()

        self.queue.join_thread()

        self.worker.terminate()

    def setUpLogging(self):

        '''Logging so umbasteln, das wir alle logging Meldung in self.buf sind'''

        #wir brauchen eine threadsichere liste

        self.buffer=self.manager.list()

        #Handler erstellen, der in den Buffer schreibt

        self.handler = h = MyHandler(self.buffer)

        self.logger =l= logging.getLogger()

        #Level anpassen 

        l.setLevel(logging.DEBUG)

        h.setLevel(logging.DEBUG)

    def tearDownLogging(self):

        '''crazy logging hacks wieder entfernen'''

        self.logger.removeHandler(self.handler)

        self.logger.setLevel(logging.NOTSET)

        self.handler.close()

        '''einen Job verarbeiten'''

        job=self.manager.Job(None,None,"test")

        self.assertEqual(job.getStatus(),"init")

        sleep(.1)

        self.stop()

        self.assertEqual(job.getStatus(),"started")

        self.assertEqual([(l['levelno'],l['msg']) for l in self.buffer if l['name']=="iro.worker"],

                [(20,'Workerprocess läuft nun...'),

                 (20,'ein neuer Job(1)'),

                 (20,'Job(1) fertig ;)')])