[jboss-cvs] JBoss Messaging SVN: r4795 - trunk/src/main/org/jboss/messaging/core/asyncio/impl.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Tue Aug 12 12:33:30 EDT 2008
Author: clebert.suconic at jboss.com
Date: 2008-08-12 12:33:30 -0400 (Tue, 12 Aug 2008)
New Revision: 4795
Modified:
trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java
Log:
Small tweak
Modified: trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java 2008-08-12 14:14:25 UTC (rev 4794)
+++ trunk/src/main/org/jboss/messaging/core/asyncio/impl/AsynchronousFileImpl.java 2008-08-12 16:33:30 UTC (rev 4795)
@@ -142,16 +142,18 @@
public void open(final String fileName, final int maxIO)
{
+ writeLock.lock();
+
try
{
- writeLock.lock();
+ if (opened)
+ {
+ throw new IllegalStateException("AsynchronousFile is already opened");
+ }
+
this.maxIO = maxIO;
writeSemaphore = new Semaphore(this.maxIO);
- if (opened)
- {
- throw new IllegalStateException("AsynchronousFile is already opened");
- }
opened = true;
this.fileName=fileName;
handler = init (fileName, this.maxIO, log);
@@ -168,9 +170,10 @@
{
checkOpened();
- try
+ writeLock.lock();
+
+ try
{
- writeLock.lock();
while (!writeSemaphore.tryAcquire(maxIO, 60, TimeUnit.SECONDS))
{
More information about the jboss-cvs-commits
mailing list