summaryrefslogtreecommitdiff
path: root/ACE/TAO/tests/RTScheduling/Current/test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ACE/TAO/tests/RTScheduling/Current/test.cpp')
-rw-r--r--ACE/TAO/tests/RTScheduling/Current/test.cpp42
1 files changed, 42 insertions, 0 deletions
diff --git a/ACE/TAO/tests/RTScheduling/Current/test.cpp b/ACE/TAO/tests/RTScheduling/Current/test.cpp
new file mode 100644
index 00000000000..b20a0f805ec
--- /dev/null
+++ b/ACE/TAO/tests/RTScheduling/Current/test.cpp
@@ -0,0 +1,42 @@
+// $Id$
+
+#include "Thread_Task.h"
+#include "../Scheduler.h"
+#include "tao/RTScheduling/RTScheduler_Manager.h"
+
+int
+ACE_TMAIN(int argc, ACE_TCHAR *argv[])
+{
+ try
+ {
+ CORBA::ORB_var orb =
+ CORBA::ORB_init (argc,
+ argv);
+
+ CORBA::Object_var manager_obj = orb->resolve_initial_references ("RTSchedulerManager");
+
+ TAO_RTScheduler_Manager_var manager = TAO_RTScheduler_Manager::_narrow (manager_obj.in ());
+
+ TAO_Scheduler scheduler (orb.in ());
+
+ manager->rtscheduler (&scheduler);
+
+ Thread_Task task (orb.in ());
+
+ task.activate_task (4);
+
+ orb->run ();
+
+ // Wait until all threads are ready.
+ ACE_Thread_Manager::instance ()->wait ();
+
+ orb->destroy ();
+ }
+ catch (const CORBA::Exception& ex)
+ {
+ ex._tao_print_exception ("Caught exception:");
+ return 1;
+ }
+
+ return 0;
+}