summaryrefslogtreecommitdiff
path: root/ACE/tests/Time_Service_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/tests/Time_Service_Test.cpp')
-rw-r--r--ACE/tests/Time_Service_Test.cpp121
1 files changed, 121 insertions, 0 deletions
diff --git a/ACE/tests/Time_Service_Test.cpp b/ACE/tests/Time_Service_Test.cpp
new file mode 100644
index 00000000000..faaaf4a5501
--- /dev/null
+++ b/ACE/tests/Time_Service_Test.cpp
@@ -0,0 +1,121 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+// tests
+//
+// = FILENAME
+// Time_Service_Test
+//
+// = DESCRIPTION
+// This example tests the Time Service server and clerk
+// components. The test forks and execs two processes to run both
+// the clerk and the time server. The clerk and the server
+// communicate for a short duration after which the main process
+// kills both the processes. No command line arguments are needed
+// to run the test.
+//
+// = AUTHOR
+// Prashant Jain <pjain@cs.wustl.edu>
+//
+// ============================================================================
+
+#include "test_config.h"
+#include "ace/Process.h"
+#include "ace/ACE.h"
+#include "ace/OS_NS_string.h"
+#include "ace/OS_NS_unistd.h"
+
+ACE_RCSID(tests, Time_Service_Test, "$Id$")
+
+#define APPLICATION \
+ACE_TEXT ("..") ACE_DIRECTORY_SEPARATOR_STR \
+ACE_TEXT ("netsvcs") ACE_DIRECTORY_SEPARATOR_STR \
+ACE_TEXT ("servers") ACE_DIRECTORY_SEPARATOR_STR \
+ACE_TEXT ("main") ACE_PLATFORM_EXE_SUFFIX \
+ACE_TEXT (" -f ") ACE_PLATFORM
+
+int
+run_main (int, ACE_TCHAR *[])
+{
+ ACE_START_TEST (ACE_TEXT ("Time_Service_Test"));
+
+ // Make sure that the backing store is not there. We need to make
+ // sure because this test kills the Time Clerk and on some platforms
+ // the Clerk is not allowed to do a graceful shutdown. By cleaning
+ // the backing store here, we are sure that we get a fresh start and
+ // no garbage data from a possible aborted run
+ ACE_TCHAR backing_store[MAXPATHLEN + 1];
+
+#if defined (ACE_DEFAULT_BACKING_STORE)
+ // Create a temporary file.
+ ACE_OS::strcpy (backing_store,
+ ACE_DEFAULT_BACKING_STORE);
+#else /* ACE_DEFAULT_BACKING_STORE */
+ if (ACE::get_temp_dir (backing_store,
+ MAXPATHLEN - 17) == -1) // -17 for ace-malloc-XXXXXX
+ {
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("Temporary path too long, ")
+ ACE_TEXT ("defaulting to current directory\n")));
+ backing_store[0] = 0;
+ }
+
+ // Add the filename to the end
+ ACE_OS::strcat (backing_store,
+ ACE_TEXT ("ace-malloc-XXXXXX"));
+
+#endif /* ACE_DEFAULT_BACKING_STORE */
+
+ ACE_OS::unlink (backing_store);
+
+ const ACE_TCHAR *server_cl = APPLICATION ACE_TEXT ("server.conf");
+ ACE_Process_Options server_options;
+ server_options.command_line (server_cl);
+ ACE_Process server;
+
+ if (server.spawn (server_options) == -1)
+ ACE_ERROR_RETURN ((LM_DEBUG,
+ ACE_TEXT ("%n; %p (%s).\n"),
+ ACE_TEXT ("Server fork failed"),
+ server_cl),
+ -1);
+ else
+ ACE_DEBUG ((LM_DEBUG,
+ ACE_TEXT ("Server forked with pid = %d.\n"),
+ server.getpid ()));
+
+ ACE_OS::sleep (3);
+
+ const ACE_TCHAR *clerk_cl = APPLICATION ACE_TEXT ("clerk.conf");
+ ACE_Process_Options clerk_options;
+ clerk_options.command_line (clerk_cl);
+ ACE_Process clerk;
+
+ if (clerk.spawn (clerk_options) == -1)
+ ACE_ERROR_RETURN ((LM_DEBUG, ACE_TEXT ("%n; %p: (%s).\n"),
+ ACE_TEXT ("Clerk fork failed"), clerk_cl), -1);
+ else
+ ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Clerk forked with pid = %d.\n"),
+ clerk.getpid ()));
+
+ ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Sleeping...\n")));
+ ACE_OS::sleep (10);
+
+ if (clerk.terminate () == -1)
+ ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Terminate failed for clerk.\n")),
+ -1);
+
+ if (server.terminate () == -1)
+ ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("Terminate failed for server.\n")),
+ -1);
+
+ // Because we kill the clerk process, on Win32 it may not do a
+ // graceful shutdown and the backing store file is left behind.
+ if (clerk.wait () != 0)
+ ACE_OS::unlink (backing_store);
+
+ ACE_END_TEST;
+ return 0;
+}