Changeset 2165 for pjproject/trunk/pjsip-apps/src/python/pjsua.py

Timestamp:

Jul 21, 2008 10:46:35 PM (16 years ago)

Author:

bennylp

Message:

Added sleep() in python handle events to avoid starvation in the main thread

File:

• pjproject/trunk/pjsip-apps/src/python/pjsua.py (modified) (7 diffs)

pjproject/trunk/pjsip-apps/src/python/pjsua.py

@@ -153 +153 @@
 import threading
 import weakref
+import time
 
 class Error:
@@ -2085 +2086 @@
         self._lck = lck
         self._lck.acquire()
-        #print 'lck acquire'
+        #_Trace(('lock acquired',))
 
     def __del__(self):
-        self._lck.release()
-        #print 'lck release'
+        try:
+            self._lck.release()
+            #_Trace(('lock released',))
+        except:
+            #_Trace(('lock release error',))
+            pass
 
 
@@ -2116 +2121 @@
         _pjsua.destroy()
         del self._lock
-        print 'Lib destroyed'
+        _Trace(('Lib destroyed',))
 
     def __str__(self):
@@ -2168 +2173 @@
             loop = 0
             while self._quit != 2 and loop < 400:
-                self.handle_events(50)
+                self.handle_events(5)
                 loop = loop + 1
+                time.sleep(0.050)
         _pjsua.destroy()
         _lib = None
@@ -2181 +2187 @@
 
         """
+        lck = self.auto_lock()
         err = _pjsua.start()
         self._err_check("start()", self, err)
@@ -2850 +2857 @@
 def _worker_thread_main(arg):
     global _lib
+    _Trace(('worker thread started..',))
     thread_desc = 0;
     err = _pjsua.thread_register("python worker", thread_desc)
     _lib._err_check("thread_register()", _lib, err)
     while _lib and _lib._quit == 0:
-        _lib.handle_events(50)
+        _lib.handle_events(1)
+        time.sleep(0.050)
     if _lib:
         _lib._quit = 2
+    _Trace(('worker thread exited..',))
 
 def _Trace(args):
@@ -2864 +2874 @@
             print arg,
         print " **"
+