diff options
Diffstat (limited to 'ACE/tests/Process_Manual_Event_Test.cpp')
| -rw-r--r-- | ACE/tests/Process_Manual_Event_Test.cpp | 264 |
1 files changed, 264 insertions, 0 deletions
diff --git a/ACE/tests/Process_Manual_Event_Test.cpp b/ACE/tests/Process_Manual_Event_Test.cpp new file mode 100644 index 00000000000..85be15358fb --- /dev/null +++ b/ACE/tests/Process_Manual_Event_Test.cpp @@ -0,0 +1,264 @@ +// $Id$ + +// ============================================================================ +// +// = LIBRARY +// tests +// +// = FILENAME +// Process_Manual_Event_Test.cpp +// +// = DESCRIPTION +// This test verifies the functionality of the <ACE_Manual_Event> +// process-shared implementation. +// +// = AUTHOR +// Martin Corino <mcorino@remedy.nl> +// +// ============================================================================ + +#include "test_config.h" +#include "ace/Process.h" +#include "ace/Manual_Event.h" +#include "ace/Time_Value.h" +#include "ace/Get_Opt.h" +#include "ace/ACE.h" +#include "ace/OS_NS_stdio.h" +#include "ace/OS_NS_string.h" +#include "ace/OS_NS_sys_time.h" +#include "ace/OS_NS_unistd.h" +#include "ace/os_include/os_dirent.h" + + +#if (!defined (ACE_LACKS_FORK) || defined (ACE_WIN32)) && \ + (defined (ACE_WIN32) || \ + (defined (ACE_HAS_PTHREADS) && defined (_POSIX_THREAD_PROCESS_SHARED) && \ + !defined (ACE_LACKS_MUTEXATTR_PSHARED) && !defined (ACE_LACKS_CONDATTR_PSHARED)) || \ + defined (ACE_USES_FIFO_SEM) || \ + (defined (ACE_HAS_POSIX_SEM) && defined (ACE_HAS_POSIX_SEM_TIMEOUT) && !defined (ACE_LACKS_NAMED_POSIX_SEM))) +static int iterations = 10; +static int child_process = 0; +static const ACE_TCHAR *event_ping_name = ACE_TEXT ("ACE_Ping_Event"); +static const ACE_TCHAR *event_pong_name = ACE_TEXT ("ACE_Pong_Event"); + +// Explain usage and exit. +static void +print_usage_and_die (void) +{ + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("usage: %n [-i #iterations] [-c (child process)]\n"))); + ACE_OS::exit (1); +} + +// Parse the command-line arguments and set options. +static void +parse_args (int argc, ACE_TCHAR *argv[]) +{ + ACE_Get_Opt get_opt (argc, argv, ACE_TEXT ("i:c")); + + int c; + + while ((c = get_opt ()) != -1) + switch (c) + { + case 'i': + iterations = ACE_OS::atoi (get_opt.opt_arg ()); + break; + case 'c': + child_process = 1; + break; + default: + print_usage_and_die (); + break; + } +} + +static void +acquire_release (void) +{ + ACE_Manual_Event event_ping (0, USYNC_PROCESS, event_ping_name); + ACE_Manual_Event event_pong (0, USYNC_PROCESS, event_pong_name); + + // Make sure the constructor succeeded + ACE_ASSERT (ACE_LOG_MSG->op_status () == 0); + + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%P) Begin ping-pong\n"))); + + int i; + if (child_process) + { + for (i = 0; i < iterations; ++i) + { + event_ping.signal (); + + if (event_pong.wait ()) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) %p\n"), + ACE_TEXT ("Failed acquiring pong"))); + else + { + event_pong.reset (); + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P) Pong\n"))); + } + } + + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P) Testing timeouts\n"))); + + // test timed wait + ACE_Time_Value wait = ACE_OS::gettimeofday (); + wait.sec (wait.sec () + 3); // timeout in 3 secs + + if (event_pong.wait (&wait)) + { + if (errno != ETIME) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) %p, but expected ETIME\n"), + ACE_TEXT ("event_pong.wait()"))); + } + else + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) Acquired pong without release()\n"))); + + event_ping.signal (); // release waiting parent before timeout + } + else + { + for (i = 0; i < iterations; ++i) + { + if (event_ping.wait ()) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) %p\n"), + ACE_TEXT ("Failed acquiring ping"))); + else + { + event_ping.reset (); + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%P) Ping\n"))); + } + + event_pong.signal (); + } + + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P) Testing timeouts\n"))); + + // test timed wait + ACE_Time_Value wait = ACE_OS::gettimeofday (); + wait.sec (wait.sec () + 10); // timeout in 10 secs + + if (event_ping.wait (&wait)) + { + if (errno != ETIME) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) %p but should be ETIME\n"), + ACE_TEXT ("Acquire pong"))); + + ACE_ERROR ((LM_ERROR, ACE_TEXT ("(%P) Acquire pong timed out\n"))); + } + } +} +#endif /* ! ACE_LACKS_FORK */ + +int +run_main (int argc, ACE_TCHAR *argv[]) +{ +#if defined (ACE_LACKS_FORK) && !defined (ACE_WIN32) + ACE_UNUSED_ARG (argc); + ACE_UNUSED_ARG (argv); + + ACE_START_TEST (ACE_TEXT ("Process_Manual_Event_Test")); + ACE_ERROR ((LM_INFO, + ACE_TEXT ("fork is not supported on this platform\n"))); + ACE_END_TEST; +#elif defined (ACE_WIN32) || \ + (defined (ACE_HAS_PTHREADS) && defined (_POSIX_THREAD_PROCESS_SHARED) && \ + !defined (ACE_LACKS_MUTEXATTR_PSHARED) && !defined (ACE_LACKS_CONDATTR_PSHARED)) || \ + defined (ACE_USES_FIFO_SEM) || \ + (defined (ACE_HAS_POSIX_SEM) && defined (ACE_HAS_POSIX_SEM_TIMEOUT) && !defined (ACE_LACKS_NAMED_POSIX_SEM)) + + parse_args (argc, argv); + + // Child process code. + if (child_process) + { + ACE_START_TEST (ACE_TEXT ("Process_Manual_Event_Test-child")); + ACE_OS::sleep (2); + acquire_release (); + ACE_END_LOG; + } + else + { + ACE_START_TEST (ACE_TEXT ("Process_Manual_Event_Test")); + + // The parent cleans up any remnant of past runs of this test. + // See Bugzilla #2662 for further info. + // On AIX, this is done by removing the shared memory objects before + // trying to run. +# if defined (AIX) + // FUZZ: disable check_for_lack_ACE_OS + if (::shm_unlink (event_ping_name) != 0 && errno != ENOENT) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) event_ping %p\n"), + ACE_TEXT ("shm_unlink"))); + if (::shm_unlink (event_pong_name) != 0 && errno != ENOENT) + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("(%P) event_pong %p\n"), + ACE_TEXT ("shm_unlink"))); + // FUZZ: enable check_for_lack_ACE_OS +# endif /* AIX */ + +#if defined (ACE_WIN32) + const ACE_TCHAR *cmdline_format = ACE_TEXT("\"%s\" -c -i %d"); +#elif !defined (ACE_USES_WCHAR) +const ACE_TCHAR *cmdline_format = ACE_TEXT (".") ACE_DIRECTORY_SEPARATOR_STR ACE_TEXT("%s -c -i %d"); +#else +const ACE_TCHAR *cmdline_format = ACE_TEXT (".") ACE_DIRECTORY_SEPARATOR_STR ACE_TEXT("%ls -c -i %d"); +#endif + + ACE_Process_Options options; + options.command_line (cmdline_format, + argc > 0 ? argv[0] : ACE_TEXT ("Process_Manual_Event_Test"), + iterations); + // Spawn a child process that will contend for the + // lock. + ACE_Process child; + + // Spawn the child process. + pid_t result = child.spawn (options); + if (result != ACE_INVALID_PID) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Parent spawned child process with pid = %d.\n"), + child.getpid ())); + else + ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), + ACE_TEXT ("spawn failed")), 1); + + // start test + acquire_release (); + + ACE_exitcode child_status; + // Wait for the child processes we created to exit. + int wait_result = child.wait (&child_status); + ACE_ASSERT (wait_result != -1); + if (child_status == 0) + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("Child %d finished ok\n"), + child.getpid ())); + else + ACE_ERROR ((LM_ERROR, + ACE_TEXT ("Child %d finished with status %d\n"), + child.getpid (), child_status)); + ACE_END_TEST; + } +#else /* !ACE_LACKS_FORK */ + ACE_UNUSED_ARG (argc); + ACE_UNUSED_ARG (argv); + + ACE_START_TEST (ACE_TEXT ("Process_Manual_Event_Test")); + ACE_ERROR ((LM_INFO, + ACE_TEXT ("Process shared events are not supported on this platform\n"))); + ACE_END_TEST; +#endif /* ! ACE_LACKS_FORK */ + + return 0; +} |