Return to thread2.py CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / libxml2 / python / tests

Annotation of embedaddon/libxml2/python/tests/thread2.py, revision 1.1

1.1     ! misho       1: #!/usr/bin/python -u
        !             2: import string, sys, time
        !             3: import thread
        !             4: from threading import Thread, Lock
        !             5: 
        !             6: import libxml2
        !             7: 
        !             8: THREADS_COUNT = 15
        !             9: 
        !            10: failed = 0
        !            11: 
        !            12: class ErrorHandler:
        !            13: 
        !            14:     def __init__(self):
        !            15:         self.errors = []
        !            16:         self.lock = Lock()
        !            17: 
        !            18:     def handler(self,ctx,str):
        !            19:         self.lock.acquire()
        !            20:         self.errors.append(str)
        !            21:         self.lock.release()
        !            22: 
        !            23: def getLineNumbersDefault():
        !            24:     old = libxml2.lineNumbersDefault(0)
        !            25:     libxml2.lineNumbersDefault(old)
        !            26:     return old
        !            27: 
        !            28: def test(expectedLineNumbersDefault):
        !            29:     time.sleep(1)
        !            30:     global failed
        !            31:     # check a per thread-global
        !            32:     if expectedLineNumbersDefault != getLineNumbersDefault():
        !            33:         failed = 1
        !            34:         print "FAILED to obtain correct value for " \
        !            35:               "lineNumbersDefault in thread %d" % thread.get_ident()
        !            36:     # check ther global error handler 
        !            37:     # (which is NOT per-thread in the python bindings)
        !            38:     try:
        !            39:         doc = libxml2.parseFile("bad.xml")
        !            40:     except:
        !            41:         pass
        !            42:     else:
        !            43:         assert "failed"
        !            44: 
        !            45: # global error handler
        !            46: eh = ErrorHandler()
        !            47: libxml2.registerErrorHandler(eh.handler,"")
        !            48: 
        !            49: # set on the main thread only
        !            50: libxml2.lineNumbersDefault(1) 
        !            51: test(1)
        !            52: ec = len(eh.errors)
        !            53: if ec == 0:
        !            54:     print "FAILED: should have obtained errors"
        !            55:     sys.exit(1)
        !            56: 
        !            57: ts = []
        !            58: for i in range(THREADS_COUNT):
        !            59:     # expect 0 for lineNumbersDefault because
        !            60:     # the new value has been set on the main thread only
        !            61:     ts.append(Thread(target=test,args=(0,)))
        !            62: for t in ts:
        !            63:     t.start()
        !            64: for t in ts:
        !            65:     t.join()
        !            66: 
        !            67: if len(eh.errors) != ec+THREADS_COUNT*ec:
        !            68:     print "FAILED: did not obtain the correct number of errors"
        !            69:     sys.exit(1)
        !            70: 
        !            71: # set lineNumbersDefault for future new threads
        !            72: libxml2.thrDefLineNumbersDefaultValue(1)
        !            73: ts = []
        !            74: for i in range(THREADS_COUNT):
        !            75:     # expect 1 for lineNumbersDefault
        !            76:     ts.append(Thread(target=test,args=(1,)))
        !            77: for t in ts:
        !            78:     t.start()
        !            79: for t in ts:
        !            80:     t.join()
        !            81: 
        !            82: if len(eh.errors) != ec+THREADS_COUNT*ec*2:
        !            83:     print "FAILED: did not obtain the correct number of errors"
        !            84:     sys.exit(1)
        !            85: 
        !            86: if failed:
        !            87:     print "FAILED"
        !            88:     sys.exit(1)
        !            89: 
        !            90: # Memory debug specific
        !            91: libxml2.cleanupParser()
        !            92: if libxml2.debugMemory(1) == 0:
        !            93:     print "OK"
        !            94: else:
        !            95:     print "Memory leak %d bytes" % (libxml2.debugMemory(1))
        !            96:     libxml2.dumpMemory()