[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