[rhmessaging-commits] rhmessaging commits: r1586 - store/trunk/cpp/tests/jrnl/jtt.

[rhmessaging-commits at lists.jboss.org]

Author: kpvdr
Date: 2008-01-20 16:47:07 -0500 (Sun, 20 Jan 2008)
New Revision: 1586

Modified:
   store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.cpp
   store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.hpp
Log:
Change to test tool form FILO to FIFO behavior for dequeueing, which gives a higher probability of journal full errors during large volume tests.

Modified: store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.cpp
===================================================================
--- store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.cpp	2008-01-20 17:02:11 UTC (rev 1585)
+++ store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.cpp	2008-01-20 21:47:07 UTC (rev 1586)
@@ -229,8 +229,8 @@
                     journal::data_tok* dtokp;
                     {
                         rhm::journal::slock sl(&_dm);
-                        dtokp = _dtok_deq_list.back();
-                        _dtok_deq_list.pop_back();
+                        dtokp = _dtok_deq_list.front();
+                        _dtok_deq_list.pop_front();
                     }
 
                     rhm::journal::iores res;

Modified: store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.hpp
===================================================================
--- store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.hpp	2008-01-20 17:02:11 UTC (rev 1585)
+++ store/trunk/cpp/tests/jrnl/jtt/jrnl_instance.hpp	2008-01-20 21:47:07 UTC (rev 1586)
@@ -28,6 +28,7 @@
 #include "test_case.hpp"
 
 #include <boost/shared_ptr.hpp>
+#include <deque>
 #include <jrnl/data_tok.hpp>
 #include <jrnl/jcntl.hpp>
 #include <jrnl/slock.hpp>
@@ -47,7 +48,7 @@
     private:
         jrnl_init_params::shared_ptr _jpp;
         std::vector<dtok_ptr> _dtok_master_list;
-        std::vector<journal::data_tok*> _dtok_deq_list;
+        std::deque<journal::data_tok*> _dtok_deq_list;
         pthread_mutex_t _dm;  ///< Dequeue vector mutex
         pthread_t _enq_thread;
         pthread_t _deq_thread;