commit c8ee6ec8a163915b4144c5198d326ef9412b14db
author Benny Prijono <bennylp@teluu.com> Thu Oct 12 16:00:02 2006 +0000
committer Benny Prijono <bennylp@teluu.com> Thu Oct 12 16:00:02 2006 +0000
tree 136978cb4e63dc595f61321b81dc28ade6b315b0
parent 658a1c5681f6d2ff65b03a5e6fa0884aec95f989

Fixed bugs in pasound.c again, this time it is suspected that two input/output streams will be called by different threads, while pasound.c only expect it to be called by the same thread [thanks Norman Franke]



git-svn-id: https://svn.pjsip.org/repos/pjproject/trunk@766 74dad513-b988-da41-8d7b-12977e46ad98

pjmedia/src/pjmedia/pasound.c

diff --git a/pjmedia/src/pjmedia/pasound.c b/pjmedia/src/pjmedia/pasound.c
index 5c16177..388e410 100644
--- a/pjmedia/src/pjmedia/pasound.c
+++ b/pjmedia/src/pjmedia/pasound.c
@@ -63,10 +63,15 @@
 
     pj_bool_t		 quit_flag;
 
-    pj_bool_t		 thread_exited;
-    pj_bool_t		 thread_initialized;
-    pj_thread_desc	 thread_desc;
-    pj_thread_t		*thread;
+    pj_bool_t		 rec_thread_exited;
+    pj_bool_t		 rec_thread_initialized;
+    pj_thread_desc	 rec_thread_desc;
+    pj_thread_t		*rec_thread;
+
+    pj_bool_t		 play_thread_exited;
+    pj_bool_t		 play_thread_initialized;
+    pj_thread_desc	 play_thread_desc;
+    pj_thread_t		*play_thread;
 };
 
 
@@ -89,10 +94,10 @@
     if (input == NULL)
 	return paContinue;
 
-    if (stream->thread_initialized == 0) {
-	status = pj_thread_register("pa_rec", stream->thread_desc, 
-				    &stream->thread);
-	stream->thread_initialized = 1;
+    if (stream->rec_thread_initialized == 0) {
+	status = pj_thread_register("pa_rec", stream->rec_thread_desc, 
+				    &stream->rec_thread);
+	stream->rec_thread_initialized = 1;
 	PJ_LOG(5,(THIS_FILE, "Recorder thread started"));
     }
 
@@ -112,7 +117,7 @@
 	return paContinue;
 
 on_break:
-    stream->thread_exited = 1;
+    stream->rec_thread_exited = 1;
     return paAbort;
 }
 
@@ -137,10 +142,10 @@
     if (output == NULL)
 	return paContinue;
 
-    if (stream->thread_initialized == 0) {
-	status = pj_thread_register("portaudio", stream->thread_desc,
-				    &stream->thread);
-	stream->thread_initialized = 1;
+    if (stream->play_thread_initialized == 0) {
+	status = pj_thread_register("portaudio", stream->play_thread_desc,
+				    &stream->play_thread);
+	stream->play_thread_initialized = 1;
 	PJ_LOG(5,(THIS_FILE, "Player thread started"));
     }
 
@@ -158,7 +163,7 @@
 	return paContinue;
 
 on_break:
-    stream->thread_exited = 1;
+    stream->play_thread_exited = 1;
     return paAbort;
 }
 
@@ -743,7 +748,9 @@
     int i, err = 0;
 
     stream->quit_flag = 1;
-    for (i=0; !stream->thread_exited && i<100; ++i)
+    for (i=0; !stream->rec_thread_exited && i<100; ++i)
+	pj_thread_sleep(10);
+    for (i=0; !stream->play_thread_exited && i<100; ++i)
 	pj_thread_sleep(10);
 
     pj_thread_sleep(1);
@@ -769,7 +776,10 @@
     int i, err = 0;
 
     stream->quit_flag = 1;
-    for (i=0; !stream->thread_exited && i<100; ++i) {
+    for (i=0; !stream->rec_thread_exited && i<100; ++i) {
+	pj_thread_sleep(1);
+    }
+    for (i=0; !stream->play_thread_exited && i<100; ++i) {
 	pj_thread_sleep(1);
     }