package/mpp
1
0
Fork 0
mirror of https://github.com/nyanmisaka/mpp.git synced 2025-10-05 17:16:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[test]: Fix error on mpp_thread_test

Browse Source 
Change-Id: Id9f0bc58e72256f27cab6bc7fb39d441803a2bfb
Signed-off-by: Herman Chen <herman.chen@rock-chips.com>
This commit is contained in:
Herman Chen
2019-08-20 10:58:17 +08:00
parent 666782b834
commit bbbc9afd5e
1 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
osal/test/mpp_thread_test.c
View File

@@ -38,8 +38,8 @@ static pthread_mutex_t mutex_0;
static pthread_mutex_t mutex_1; static pthread_mutex_t mutex_1;
static pthread_cond_t cond_0; static pthread_cond_t cond_0;
static pthread_cond_t cond_1; static pthread_cond_t cond_1;
static RK_S32 flag_0 = 1; static volatile RK_S32 flag_0 = 1;
static RK_S32 flag_1 = 1; static volatile RK_S32 flag_1 = 1;
void *thread_test(void *pdata) void *thread_test(void *pdata)
{ {
@@ -58,7 +58,7 @@ void* mutex_performance_test_loop_0(void *arg)
thread_dbg("0 %5d lock\n", i); thread_dbg("0 %5d lock\n", i);
pthread_mutex_lock(&mutex_0); pthread_mutex_lock(&mutex_0);
thread_dbg("0 %5d wait\n", i); thread_dbg("0 %5d wait flag %d\n", i, flag_0);
if (flag_0) { if (flag_0) {
pthread_cond_wait(&cond_0, &mutex_0); pthread_cond_wait(&cond_0, &mutex_0);
} }
@@ -81,13 +81,11 @@ void *mutex_performance_test_loop_1(void *arg)
{ {
RK_S32 i = 0; RK_S32 i = 0;
flag_0 = 0;
for (i = 0; i < MAX_LOCK_LOOP; i++) { for (i = 0; i < MAX_LOCK_LOOP; i++) {
thread_dbg("1 %5d lock\n", i); thread_dbg("1 %5d lock\n", i);
pthread_mutex_lock(&mutex_1); pthread_mutex_lock(&mutex_1);
thread_dbg("1 %5d wait\n", i); thread_dbg("1 %5d wait flag %d\n", i, flag_1);
if (flag_1) { if (flag_1) {
pthread_cond_wait(&cond_1, &mutex_1); pthread_cond_wait(&cond_1, &mutex_1);
} }
@@ -177,6 +175,7 @@ int main()
time_start = mpp_time(); time_start = mpp_time();
pthread_create(&threads[0], &attr, mutex_performance_test_loop_0, NULL); pthread_create(&threads[0], &attr, mutex_performance_test_loop_0, NULL);
flag_0 = 0;
pthread_create(&threads[1], &attr, mutex_performance_test_loop_1, NULL); pthread_create(&threads[1], &attr, mutex_performance_test_loop_1, NULL);
pthread_join(threads[0], &dummy); pthread_join(threads[0], &dummy);