Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-10 03:56:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

hang on linux seems to point to the possibilit of more than one thread waiting on the enque mutex so this change to notifyAll should help

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@903330 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2010-01-26 17:29:00 +00:00
parent def2a34915
commit 4b49834ef6
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kahadb/src/main/java/org/apache/kahadb/journal/DataFileAppender.java
View File

@ -246,7 +246,7 @@ class DataFileAppender {
} }
nextWriteBatch = new WriteBatch(file, file.getLength(), write); nextWriteBatch = new WriteBatch(file, file.getLength(), write);
enqueueMutex.notify(); enqueueMutex.notifyAll();
break; break;
} else { } else {
// Append to current batch if possible.. // Append to current batch if possible..
@ -327,7 +327,7 @@ class DataFileAppender {
} }
enqueueMutex.wait(); enqueueMutex.wait();
} }
enqueueMutex.notify(); enqueueMutex.notifyAll();
} }
wb = (WriteBatch)o; wb = (WriteBatch)o;