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"); }