[rhmessaging-commits] rhmessaging commits: r1296 - store/trunk/cpp/lib.

[rhmessaging-commits at lists.jboss.org]

Author: cctrieloff
Date: 2007-11-13 08:41:48 -0500 (Tue, 13 Nov 2007)
New Revision: 1296

Modified:
   store/trunk/cpp/lib/BdbMessageStore.cpp
Log:
- check AIO busy


Modified: store/trunk/cpp/lib/BdbMessageStore.cpp
===================================================================
--- store/trunk/cpp/lib/BdbMessageStore.cpp	2007-11-13 05:23:59 UTC (rev 1295)
+++ store/trunk/cpp/lib/BdbMessageStore.cpp	2007-11-13 13:41:48 UTC (rev 1296)
@@ -1050,7 +1050,6 @@
 
 void BdbMessageStore::async_dequeue(TransactionContext* ctxt, PersistableMessage& msg, const PersistableQueue& queue)
 {
-//	unsigned aio_sleep_cnt = 0;
     bool written = false;
     boost::intrusive_ptr<DataTokenImpl> ddtokp(new DataTokenImpl);
 	ddtokp->ref();
@@ -1087,6 +1086,9 @@
                  usleep(AIO_SLEEP_TIME); // TODO add sleep time to get events call as option
                  jc->get_wr_events();
                  break;
+             case rhm::journal::RHM_IORES_BUSY:
+                 usleep(AIO_SLEEP_TIME); // TODO add sleep time to get events call as option
+                 break;
              default:
                  assert( "Store Error: Unexpected msg state");
          }