--- /dev/null
+/*
+ This file is a part of libcds - Concurrent Data Structures library
+
+ (C) Copyright Maxim Khizhinsky (libcds.dev@gmail.com) 2006-2016
+
+ Source code repo: http://github.com/khizmax/libcds/
+ Download: http://sourceforge.net/projects/libcds/files/
+
+ Redistribution and use in source and binary forms, with or without
+ modification, are permitted provided that the following conditions are met:
+
+ * Redistributions of source code must retain the above copyright notice, this
+ list of conditions and the following disclaimer.
+
+ * Redistributions in binary form must reproduce the above copyright notice,
+ this list of conditions and the following disclaimer in the documentation
+ and/or other materials provided with the distribution.
+
+ THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
+ AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
+ FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
+ SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
+ CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
+ OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+*/
+
+#include "intrusive_stack_push_pop.h"
+
+namespace cds_test {
+ /*static*/ size_t intrusive_stack_push_pop::s_nPushThreadCount = 4;
+ /*static*/ size_t intrusive_stack_push_pop::s_nPopThreadCount = 4;
+ /*static*/ size_t intrusive_stack_push_pop::s_nStackSize = 10000000;
+ /*static*/ size_t intrusive_stack_push_pop::s_nEliminationSize = 4;
+ /*static*/ bool intrusive_stack_push_pop::s_bFCIterative = false;
+ /*static*/ unsigned int intrusive_stack_push_pop::s_nFCCombinePassCount = 64;
+ /*static*/ unsigned int intrusive_stack_push_pop::s_nFCCompactFactor = 1024;
+
+ /*static*/ atomics::atomic<size_t> intrusive_stack_push_pop::s_nWorkingProducers( 0 );
+
+ /*static*/ void intrusive_stack_push_pop::SetUpTestCase()
+ {
+ cds_test::config const& cfg = get_config( "IntrusiveStack_PushPop" );
+
+ s_nPushThreadCount = cfg.get_size_t( "PushThreadCount", s_nPushThreadCount );
+ s_nPopThreadCount = cfg.get_size_t( "PopThreadCount", s_nPopThreadCount );
+ s_nStackSize = cfg.get_size_t( "StackSize", s_nStackSize );
+ s_nEliminationSize = cfg.get_size_t( "EliminationSize", s_nEliminationSize );
+ s_bFCIterative = cfg.get_bool( "FCIterate", s_bFCIterative );
+ s_nFCCombinePassCount = cfg.get_uint( "FCCombinePassCount", s_nFCCombinePassCount );
+ s_nFCCompactFactor = cfg.get_uint( "FCCompactFactor", s_nFCCompactFactor );
+
+ if ( s_nPushThreadCount == 0 )
+ s_nPushThreadCount = 1;
+ if ( s_nPopThreadCount == 0 )
+ s_nPopThreadCount = 1;
+ if ( s_nEliminationSize == 0 )
+ s_nEliminationSize = 1;
+ }
+} // namespace cds_test
+
+namespace {
+ class intrusive_stack_push_pop : public cds_test::intrusive_stack_push_pop
+ {
+ typedef cds_test::intrusive_stack_push_pop base_class;
+ protected:
+ typedef base_class::value_type<> value_type;
+ typedef base_class::value_type< cds::intrusive::treiber_stack::node< cds::gc::HP >> hp_value_type;
+ typedef base_class::value_type< cds::intrusive::treiber_stack::node< cds::gc::DHP >> dhp_value_type;
+
+ template <typename Stack>
+ void test()
+ {
+ value_array<typename Stack::value_type> arrValue( s_nStackSize );
+ {
+ Stack stack;
+ do_test( stack, arrValue );
+ }
+ Stack::gc::force_dispose();
+ }
+
+ void check_elimination_stat( cds::intrusive::treiber_stack::empty_stat const& )
+ {}
+
+ void check_elimination_stat( cds::intrusive::treiber_stack::stat<> const& s )
+ {
+ EXPECT_EQ( s.m_PushCount.get() + s.m_ActivePushCollision.get() + s.m_PassivePushCollision.get(), s_nStackSize );
+ EXPECT_EQ( s.m_PopCount.get() + s.m_ActivePopCollision.get() + s.m_PassivePopCollision.get(), s_nStackSize );
+ EXPECT_EQ( s.m_PushCount.get(), s.m_PopCount.get() );
+ EXPECT_EQ( s.m_ActivePopCollision.get(), s.m_PassivePushCollision.get() );
+ EXPECT_EQ( s.m_ActivePushCollision.get(), s.m_PassivePopCollision.get() );
+ }
+
+ template <typename Stack>
+ void test_elimination()
+ {
+ value_array<typename Stack::value_type> arrValue( s_nStackSize );
+ {
+ Stack stack( s_nEliminationSize );
+ do_test( stack, arrValue );
+ check_elimination_stat( stack.statistics() );
+ }
+ Stack::gc::force_dispose();
+ }
+
+ template <typename Stack>
+ void test_std()
+ {
+ value_array<typename Stack::value_type> arrValue( s_nStackSize );
+ Stack stack;
+ do_test( stack, arrValue );
+ }
+ };
+
+ // TreiberStack<cds::gc::HP>
+#define CDSSTRESS_Stack_F( test_fixture, stack_impl ) \
+ TEST_F( test_fixture, stack_impl ) \
+ { \
+ typedef typename istack::Types<hp_value_type>::stack_impl stack_type; \
+ test< stack_type >(); \
+ }
+
+ CDSSTRESS_TreiberStack_HP( intrusive_stack_push_pop )
+
+#undef CDSSTRESS_Stack_F
+
+ // TreiberStack<cds::gc::DHP>
+#define CDSSTRESS_Stack_F( test_fixture, stack_impl ) \
+ TEST_F( test_fixture, stack_impl ) \
+ { \
+ typedef typename istack::Types<dhp_value_type>::stack_impl stack_type; \
+ test< stack_type >(); \
+ }
+
+ CDSSTRESS_TreiberStack_DHP( intrusive_stack_push_pop )
+
+#undef CDSSTRESS_Stack_F
+
+ // TreiberStack<cds::gc::HP> + elimination enabled
+#define CDSSTRESS_Stack_F( test_fixture, stack_impl ) \
+ TEST_F( test_fixture, stack_impl ) \
+ { \
+ typedef typename istack::Types<hp_value_type>::stack_impl stack_type; \
+ test_elimination< stack_type >(); \
+ }
+
+ CDSSTRESS_EliminationStack_HP( intrusive_stack_push_pop )
+
+#undef CDSSTRESS_Stack_F
+
+
+ // TreiberStack<cds::gc::DHP> + elimination enabled
+#define CDSSTRESS_Stack_F( test_fixture, stack_impl ) \
+ TEST_F( test_fixture, stack_impl ) \
+ { \
+ typedef typename istack::Types<dhp_value_type>::stack_impl stack_type; \
+ test_elimination< stack_type >(); \
+ }
+
+ CDSSTRESS_EliminationStack_DHP( intrusive_stack_push_pop )
+
+#undef CDSSTRESS_Stack_F
+
+
+ // StdStack
+#define CDSSTRESS_Stack_F( test_fixture, stack_impl ) \
+ TEST_F( test_fixture, stack_impl ) \
+ { \
+ typedef typename istack::Types<value_type>::stack_impl stack_type; \
+ test_std< stack_type >(); \
+ }
+
+ CDSSTRESS_StdStack( intrusive_stack_push_pop )
+
+#undef CDSSTRESS_Stack_F
+
+} // namespace
projects / libcds.git / blobdiff