/* -*- C++ -*- */ // $Id$ // ============================================================================ // = FILENAME // test_config.h // // = AUTHOR // Prashant Jain , Tim Harrison // , and David Levine // // ============================================================================ #ifndef ACE_TEST_CONFIG_H #define ACE_TEST_CONFIG_H #include "ace/ACE.h" #include "ace/Log_Msg.h" #include "ace/OS_main.h" #include "ace/OS_NS_stdio.h" #include "ace/OS_NS_time.h" #include "ace/OS_NS_sys_stat.h" // FUZZ: disable check_for_streams_include #include "ace/streams.h" #if !defined (ACE_HAS_TEMPLATE_SPECIALIZATION) class KEY // ============================================================================ // = TITLE // Define a key for use with the Map_Manager_Test. // // = DESCRIPTION // This class is put into the test_config.h header file to work // around AIX C++ compiler "features" related to template // instantiation... It is only used by Map_Manager_Test.cpp // ============================================================================ { public: KEY (size_t v = 0): value_ (v) { } size_t hash (void) const { return this->value_; } operator size_t () const { return this->value_; } private: size_t value_; }; #else typedef size_t KEY; #endif /* ACE_HAS_TEMPLATE_SPECIALIZATION */ #if defined (ACE_WIN32) #define ACE_DEFAULT_TEST_FILE ACE_TEXT ("C:\\temp\\ace_test_file") #define ACE_TEMP_FILE_NAME ACE_TEXT ("C:\\temp\\ace_temp_file") #define ACE_LOG_DIRECTORY ACE_TEXT ("C:\\temp\\log\\") #define MAKE_PIPE_NAME(X) ACE_TEXT ("\\\\.\\pipe\\"#X) #else #define ACE_DEFAULT_TEST_FILE ACE_TEXT ("/tmp/ace_test_file") #define ACE_TEMP_FILE_NAME ACE_TEXT ("/tmp/ace_temp_file") #define ACE_LOG_DIRECTORY ACE_TEXT ("log/") #define MAKE_PIPE_NAME(X) ACE_TEXT (X) #endif /* ACE_WIN32 */ #define ACE_START_TEST(NAME) \ const char *program = NAME; \ ACE_LOG_MSG->open (program, ACE_Log_Msg::OSTREAM); \ if (ace_file_stream.set_output (program) != 0) \ ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "set_output failed"), -1); \ ACE_DEBUG ((LM_DEBUG, "(%P|%t) starting %s test at %T\n", program)); #define ACE_END_TEST \ ACE_DEBUG ((LM_DEBUG, "(%P|%t) Ending %s test at %T\n", program)); \ ace_file_stream.close (); #define ACE_NEW_THREAD \ do {\ ACE_LOG_MSG->msg_ostream (ace_file_stream.output_file ()); \ ACE_LOG_MSG->clr_flags (ACE_Log_Msg::STDERR | ACE_Log_Msg::LOGGER ); \ ACE_LOG_MSG->set_flags (ACE_Log_Msg::OSTREAM); \ } while (0) #define ACE_APPEND_LOG(NAME) \ const char *program = NAME; \ ACE_LOG_MSG->open (program, ACE_Log_Msg::OSTREAM); \ if (ace_file_stream.set_output (program, 1) != 0) \ ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "set_output failed"), -1); \ ACE_DEBUG ((LM_DEBUG, "(%P|%t) Starting %s test at %T\n", program)); #define ACE_END_LOG \ ACE_DEBUG ((LM_DEBUG, "(%P|%t) Ending %s test at %T\n\n", program)); \ ace_file_stream.close (); #define ACE_INIT_LOG(NAME) \ char temp[BUFSIZ]; \ ACE_OS::sprintf (temp, "%s%s%s", \ ACE_LOG_DIRECTORY, \ ACE::basename (NAME, ACE_DIRECTORY_SEPARATOR_CHAR), \ ".log"); \ ACE_DEBUG ((LM_DEBUG, "Deleting old log file %s (if any)\n\n", temp)); \ ACE_OS::unlink (temp); const int ACE_NS_MAX_ENTRIES = 1000; const int ACE_MAX_TIMERS = 4; const int ACE_MAX_THREADS = 4; const int ACE_MAX_DELAY = 10; const int ACE_MAX_INTERVAL = 0; const int ACE_MAX_ITERATIONS = 10; const int ACE_MAX_PROCESSES = 10; char ACE_ALPHABET[] = "abcdefghijklmnopqrstuvwxyz"; class ACE_Test_Output { public: ACE_Test_Output (void); ~ACE_Test_Output (void); int set_output (const char *filename, int append = 0); ofstream *output_file (void); void close (void); private: ofstream output_file_; }; static ACE_Test_Output ace_file_stream; ACE_Test_Output::ACE_Test_Output (void) { } ACE_Test_Output::~ACE_Test_Output (void) { } int ACE_Test_Output::set_output (const char *filename, int append) { char temp[BUFSIZ]; // Ignore the error value since the directory may already exist. ACE_OS::mkdir (ACE_LOG_DIRECTORY); ACE_OS::sprintf (temp, "%s%s%s", ACE_LOG_DIRECTORY, ACE::basename (filename, ACE_DIRECTORY_SEPARATOR_CHAR), ".log"); this->output_file_.open (temp, ios::out | (append ? ios::app : ios::trunc)); if (this->output_file_.bad ()) return -1; ACE_LOG_MSG->msg_ostream (ace_file_stream.output_file ()); ACE_LOG_MSG->clr_flags (ACE_Log_Msg::STDERR | ACE_Log_Msg::LOGGER ); ACE_LOG_MSG->set_flags (ACE_Log_Msg::OSTREAM); return 0; } ofstream * ACE_Test_Output::output_file (void) { return &this->output_file_; } void ACE_Test_Output::close (void) { this->output_file_.flush (); this->output_file_.close (); } void randomize (int array[], size_t size) { size_t i; for (i = 0; i < size; i++) array [i] = i; ACE_OS::srand (ACE_OS::time (0L)); // Generate an array of random numbers from 0 .. size - 1. for (i = 0; i < size; i++) { int index = ACE_OS::rand() % size--; int temp = array [index]; array [index] = array [size]; array [size] = temp; } } #endif /* ACE_TEST_CONFIG_H */