+++ /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.
-*/
-
-/*
- * Copyright (c) 2003, 2004
- * Zdenek Nemec
- *
- * This material is provided "as is", with absolutely no warranty expressed
- * or implied. Any use is at your own risk.
- *
- * Permission to use or copy this software for any purpose is hereby granted
- * without fee, provided the above notices are retained on all copies.
- * Permission to modify the code and to distribute modified code is granted,
- * provided the above notices are retained, and a notice that the code was
- * modified is included with the above copyright notice.
- *
- */
-
-/*
-#if defined(_DEBUG) && _MSC_VER == 1500
-# define _CRTDBG_MAP_ALLOC
-# include <stdlib.h>
-# include <crtdbg.h>
-#endif
-*/
-
-#include "cppunit/cppunit_proxy.h"
-#include "cppunit/file_reporter.h"
-
-#include <cds/init.h>
-#include <cds/gc/hp.h>
-#include <cds/gc/dhp.h>
-#include <cds/urcu/general_instant.h>
-#include <cds/urcu/general_buffered.h>
-#include <cds/urcu/general_threaded.h>
-#include <cds/urcu/signal_buffered.h>
-#include <cds/urcu/signal_threaded.h>
-#include <cds/os/topology.h>
-
-#include "stdio.h"
-#include <fstream>
-#include <iostream>
-#include <set>
-#include <boost/date_time/posix_time/posix_time.hpp>
-#include <boost/thread/mutex.hpp>
-
-// Visual leak detector (see http://vld.codeplex.com/)
-#if defined(CDS_USE_VLD) && CDS_COMPILER == CDS_COMPILER_MSVC
-# ifdef _DEBUG
-# include <vld.h>
-# endif
-#endif
-
-
-std::ostream& operator << (std::ostream& s, const cds::gc::hp::GarbageCollector::InternalState& stat)
-{
- s << "\nHZP GC internal state:"
- << "\n\t HP record allocated=" << stat.nHPRecAllocated
- << "\n\t HP records used=" << stat.nHPRecUsed
- << "\n\t Total retired ptr count=" << stat.nTotalRetiredPtrCount
- << "\n\t Retired ptr in free HP records=" << stat.nRetiredPtrInFreeHPRecs
- << "\n\tEvents:"
- << "\n\t HPRec allocations=" << stat.evcAllocHPRec
- << "\n\t HPRec retire events=" << stat.evcRetireHPRec
- << "\n\tnew HPRec allocations from heap=" << stat.evcAllocNewHPRec
- << "\n\t HPRec deletions=" << stat.evcDeleteHPRec
- << "\n\t Scan call count=" << stat.evcScanCall
- << "\n\t HelpScan call count=" << stat.evcHelpScanCall
- << "\n\t Scan calls from HelpScan=" << stat.evcScanFromHelpScan
- << "\n\t retired object deleting=" << stat.evcDeletedNode
- << "\n\t guarded object on Scan=" << stat.evcDeferredNode
- << std::endl;
-
- return s;
-}
-
-namespace CppUnitMini
-{
- int TestCase::m_numErrors = 0;
- int TestCase::m_numTests = 0;
- std::vector<std::string> TestCase::m_arrStrings;
- bool TestCase::m_bPrintGCState = false;
- std::string TestCase::m_strTestDataDir(".");
- Config TestCase::m_Cfg;
- bool TestCase::m_bExactMatch = false;
-
- // random shuffle support
- /*static*/ std::random_device TestCase::m_RandomDevice;
- /*static*/ std::mt19937 TestCase::m_RandomGen( TestCase::m_RandomDevice() );
-
- TestCase * TestCase::m_pCurTestCase = nullptr;
-
- TestCase *TestCase::m_root = 0;
- Reporter *TestCase::m_reporter = 0;
-
- void TestCase::registerTestCase(TestCase *in_testCase) {
- in_testCase->m_next = m_root;
- m_root = in_testCase;
- }
-
- int TestCase::run(Reporter *in_reporter, const char *in_testName, bool invert)
- {
- TestCase::m_reporter = in_reporter;
-
- m_numErrors = 0;
- m_numTests = 0;
-
- TestCase *tmp = m_root;
- while (tmp != 0) {
- m_pCurTestCase = tmp;
- try {
- tmp->myRun(in_testName, invert);
- } catch ( std::exception& ex ) {
- in_reporter->message( "EXCEPTION: ");
- in_reporter->message( ex.what() );
- }
- tmp = tmp->m_next;
- }
-
- return m_numErrors;
- }
-
- bool TestCase::shouldRunThis(const char *in_desiredTest, const char *in_className, const char *in_functionName,
- bool invert, bool explicit_test, bool &do_progress)
- {
- if ((in_desiredTest) && (in_desiredTest[0] != '\0')) {
- do_progress = false;
- const char *ptr = strstr(in_desiredTest, "::");
- if (ptr) {
- bool match;
- if ( m_bExactMatch ) {
- match = (strncmp( in_desiredTest, in_className, strlen( in_className )) == 0 && in_desiredTest[strlen( in_className )] == ':')
- && (strcmp( ptr + 2, in_functionName ) == 0);
- }
- else {
- match = (strncmp( in_desiredTest, in_className, strlen( in_className )) == 0 && in_desiredTest[strlen( in_className )] == ':')
- && (strncmp( ptr + 2, in_functionName, strlen( ptr + 2 ) ) == 0);
- }
- // Invert shall not make explicit test run:
- return invert ? (match ? !match : !explicit_test)
- : match;
- }
- bool match = (strcmp(in_desiredTest, in_className) == 0);
- do_progress = match;
- return !explicit_test && (match == !invert);
- }
- do_progress = true;
-
- return !explicit_test;
- }
-
-
- void TestCase::print_gc_state()
- {
- if ( m_bPrintGCState ) {
- {
- cds::gc::hp::GarbageCollector::InternalState stat;
- std::cout << cds::gc::hp::GarbageCollector::instance().getInternalState( stat ) << std::endl;
- }
- }
- }
-
- void TestCase::print_test_list()
- {
- TestCase *tmp = m_root;
- std::cout << "Test list:\n";
- while (tmp != 0) {
- std::cout << "\t" << tmp->test_name() << "\n";
- tmp = tmp->m_next;
- }
- }
-
- void Config::load( const char * fileName )
- {
- std::ifstream s;
- s.open( fileName );
- if ( !s.is_open() ) {
- std::cerr << "WARNING: Cannot open test cfg file " << fileName
- << "\n\tUse default settings"
- << std::endl;
- return;
- }
-
- std::cout << "Using test config file: " << fileName << std::endl;
-
- char buf[ 4096 ];
-
- TestCfg * pMap = nullptr;
- while ( !s.eof() ) {
- s.getline( buf, sizeof(buf)/sizeof(buf[0]) );
- char * pszStr = buf;
- // trim left
- while ( *pszStr != 0 && (*pszStr == ' ' || *pszStr == '\t' )) ++pszStr;
- // trim right
- char * pszEnd = strchr( pszStr, 0 );
- if ( pszEnd == pszStr ) // empty srtring
- continue;
- --pszEnd;
- while ( pszEnd != pszStr && (*pszEnd ==' ' || *pszEnd=='\t' || *pszEnd=='\n' || *pszEnd=='\r' )) --pszEnd;
-
- if ( pszStr == pszEnd ) // empty string
- continue;
-
- pszEnd[1] = 0;
-
- if ( *pszStr == '#' ) // comment
- continue;
-
- if ( *pszStr == '[' && *pszEnd == ']' ) { // chapter header
- *pszEnd = 0;
- pMap = &( m_Cfg[ pszStr + 1 ] );
- continue;
- }
-
- if ( !pMap )
- continue;
-
- char * pszEq = strchr( pszStr, '=' );
- if ( !pszEq )
- continue;
- if ( pszEq == pszStr )
- continue;
-
- pszEnd = pszEq;
- while ( pszStr <= --pszEnd && (*pszEnd ==' ' || *pszEnd=='\t' || *pszEnd=='\n' || *pszEnd=='\r') );
-
- if ( pszEnd <= pszStr )
- continue;
- pszEnd[1] = 0;
- pMap->m_Cfg[ pszStr ] = pszEq + 1;
- }
- s.close();
- }
-
- std::vector<std::string> const & TestCase::getTestStrings()
- {
- if ( m_arrStrings.empty() ) {
- std::string strTestDir = m_strTestDataDir;
-
- std::ifstream fDict;
- char bufLine[1024];
- std::cout << "Loading test data " << strTestDir << "/dictionary.txt..." << std::endl;
- fDict.open( (strTestDir + "/dictionary.txt").c_str() );
- if ( fDict.is_open() ) {
- cds::OS::Timer timer;
- std::string str;
- fDict >> str ; // number of lines in file
-
- // Assume that dictionary.txt does not contain doubles.
- CppUnitMini::TestCase::m_arrStrings.reserve( atol(str.c_str()) );
- while ( !fDict.eof() ) {
- fDict.getline( bufLine, sizeof(bufLine)/sizeof(bufLine[0]) );
- if ( bufLine[0] )
- m_arrStrings.push_back( bufLine );
- }
- fDict.close();
-
- std::cout << " Duration=" << timer.duration() << " String count " << CppUnitMini::TestCase::m_arrStrings.size() << std::endl;
- }
- else
- std::cout << " Failed, file not found" << std::endl;
-
- }
- return m_arrStrings;
- }
-}
-
-static void usage(const char* name)
-{
- std::cout << "Usage: " << name << " [options] [-t=<class>[::<test>]] [-x=<class>[::<test>]] [-f=<file>]\n"
- "\t[-t=<class>[::<test>]] : test class or class::test to execute\n"
- "\t[-d=dir] : test data directory (default is .)\n"
- "\t[-f=<file>] : output file\n"
- "Options:\n"
- "\t-exact-match - class::test should be exactly matched to existing test\n"
- "\t-gc_state - print gc state after each test\n"
- "\t-cfg=<file> - config file name for tests\n"
- "\t-list - list all tests\n"
- "\t"
- << std::endl;
-}
-
-int main(int argc, char** argv)
-{
-
-#ifdef CDS_MSVC_MEMORY_LEAKS_DETECTING_ENABLED
- _CrtSetDbgFlag ( _CRTDBG_ALLOC_MEM_DF | _CRTDBG_LEAK_CHECK_DF );
-#endif
-
- // CppUnit(mini) test launcher
- // command line option syntax:
- // test [Options]
- // where Options are
- // -t=CLASS[::TEST] run the test class CLASS or member test CLASS::TEST
- // -x=CLASS[::TEST] run all except the test class CLASS or member test CLASS::TEST
- // -d=dir test data directory (default is .)
- // -f=FILE save output in file FILE instead of stdout
- // -m monitor test(s) execution
- // -gc_state print GC state after test
- const char *fileName = 0;
- const char *testName = "";
- const char *xtestName = "";
- const char *testDataDir = ".";
- const char *cfgFileName =
-#ifdef _DEBUG
- "test-debug.conf"
-#else
- "test.conf"
-#endif
-;
- bool doMonitoring = false;
-
- for (int i = 1; i < argc; ++i) {
- if (argv[i][0] == '-') {
- if ( strncmp(argv[i], "-t=", 3) == 0 ) {
- testName = argv[i]+3;
- continue;
- }
- else if ( strncmp(argv[i], "-f=", 3) == 0 ) {
- fileName = argv[i]+3;
- continue;
- }
- else if ( strncmp(argv[i], "-x=", 3) == 0 ) {
- xtestName = argv[i]+3;
- continue;
- }
- else if ( strncmp(argv[i], "-d=", 3) == 0 ) {
- testDataDir = argv[i] + 3;
- continue;
- }
- else if ( strncmp( argv[i], "-m", 2 ) == 0 ) {
- doMonitoring = true;
- continue;
- }
- else if ( strncmp( argv[i], "-exact-match", 12 ) == 0 ) {
- CppUnitMini::TestCase::m_bExactMatch = true;
- continue;
- }
- else if (strncmp(argv[i], "-list", 5) == 0) {
- CppUnitMini::TestCase::print_test_list();
- return 0;
- }
- else if ( strncmp(argv[i], "-gc_state", 9) == 0 ) {
- CppUnitMini::TestCase::m_bPrintGCState = true;
- continue;
- }
- else if( strncmp(argv[i], "-cfg=", 5) == 0 ) {
- cfgFileName = argv[i] + 5;
- continue;
- }
- }
-
- // invalid option, we display normal usage.
- usage(argv[0]);
- return 1;
-
- }
-
- {
- boost::posix_time::ptime cur( boost::posix_time::second_clock::local_time());
-
- std::cout << "libcds version " << CDS_VERSION_STRING << "\n";
- std::cout << "Test started " << cur << std::endl;
- }
-
-
- CppUnitMini::TestCase::m_strTestDataDir = testDataDir;
-
- CppUnitMini::Reporter* reporter;
- if (fileName != 0)
- reporter = new CppUnitMini::FileReporter(fileName, doMonitoring);
- else
- reporter = new CppUnitMini::FileReporter(stdout, doMonitoring);
-
- // Load config params
- CppUnitMini::TestCase::m_Cfg.load( cfgFileName );
-
- // Init CDS runtime
- cds::Initialize();
-
- int num_errors;
- {
- size_t nHazardPtrCount = 0;
- size_t dhp_liberateThreshold;
- size_t dhp_initialThreadGuardCount;
- size_t dhp_epochCount;
- {
- CppUnitMini::TestCfg& cfg = CppUnitMini::TestCase::m_Cfg.get( "General" );
- nHazardPtrCount = cfg.getULong( "hazard_pointer_count", 0 );
-
- dhp_liberateThreshold = cfg.getSizeT( "dhp_liberate_threshold", 1024 );
- dhp_initialThreadGuardCount = cfg.getSizeT( "dhp_init_guard_count", 8 );
- dhp_epochCount = cfg.getSizeT( "dhp_epoch_count", 16 );
- }
-
- // Safe reclamation schemes
- cds::gc::HP hzpGC( nHazardPtrCount );
- cds::gc::DHP dhpGC( dhp_liberateThreshold, dhp_initialThreadGuardCount, dhp_epochCount );
-
- // RCU varieties
- typedef cds::urcu::gc< cds::urcu::general_instant<> > rcu_gpi;
- rcu_gpi gpiRCU;
-
- typedef cds::urcu::gc< cds::urcu::general_buffered<> > rcu_gpb;
- rcu_gpb gpbRCU;
-
- typedef cds::urcu::gc< cds::urcu::general_threaded<> > rcu_gpt;
- rcu_gpt gptRCU;
-
-#ifdef CDS_URCU_SIGNAL_HANDLING_ENABLED
- typedef cds::urcu::gc< cds::urcu::signal_buffered<> > rcu_shb;
- rcu_shb shbRCU( 256, SIGUSR1 );
-
- typedef cds::urcu::gc< cds::urcu::signal_threaded<> > rcu_sht;
- rcu_sht shtRCU( 256, SIGUSR2 );
-#endif
-
- // System topology
- {
- std::cout
- << "System topology:\n"
- << " Logical processor count: " << std::thread::hardware_concurrency() << "\n";
- std::cout << std::endl;
- }
-
- {
- CppUnitMini::TestCfg& cfg = CppUnitMini::TestCase::m_Cfg.get( "General" );
- std::string strHZPScanStrategy = cfg.get( "HZP_scan_strategy", std::string("classic") );
- if ( strHZPScanStrategy == "inplace" )
- hzpGC.setScanType( cds::gc::HP::scan_type::inplace );
- else if ( strHZPScanStrategy == "classic" )
- hzpGC.setScanType( cds::gc::HP::scan_type::classic );
- else {
- std::cout << "Error value of HZP_scan_strategy in General section of test config\n";
- }
-
- switch (hzpGC.getScanType()) {
- case cds::gc::HP::scan_type::inplace:
- std::cout << "Use in-place scan strategy for Hazard Pointer memory reclamation algorithm\n";
- break;
- case cds::gc::HP::scan_type::classic:
- std::cout << "Use classic scan strategy for Hazard Pointer memory reclamation algorithm\n";
- break;
- default:
- std::cout << "ERROR: use unknown scan strategy for Hazard Pointer memory reclamation algorithm\n";
- break;
- }
-
- std::cout << " Hazard Pointer count: " << hzpGC.max_hazard_count() << "\n"
- << " Max thread count for HP: " << hzpGC.max_thread_count() << "\n"
- << "Retired HP array capacity: " << hzpGC.retired_array_capacity() << "\n";
- }
-
- if ( CppUnitMini::TestCase::m_bPrintGCState ) {
- cds::gc::hp::GarbageCollector::InternalState stat;
- cds::gc::hp::GarbageCollector::instance().getInternalState( stat );
-
- std::cout << "HP constants:"
- << "\n\tHP count per thread=" << stat.nHPCount
- << "\n\tMax thread count=" << stat.nMaxThreadCount
- << "\n\tMax retired pointer count per thread=" << stat.nMaxRetiredPtrCount
- << "\n\tHP record size in bytes=" << stat.nHPRecSize
- << "\n" << std::endl;
- }
-
- // Attach main thread to CDS GC
- cds::threading::Manager::attachThread();
-
- if (xtestName[0] != 0)
- num_errors = CppUnitMini::TestCase::run(reporter, xtestName, true);
- else
- num_errors = CppUnitMini::TestCase::run(reporter, testName);
-
- // Detach main thread from CDS GC
- cds::threading::Manager::detachThread();
-
- }
-
- // Finalize CDS runtime
- cds::Terminate();
-
- reporter->printSummary();
- delete reporter;
-
- return num_errors;
-}
projects / libcds.git / blobdiff