1 files changed, 186 insertions, 0 deletions
diff --git a/ACE/TAO/tests/RTScheduling/Scheduler.cpp b/ACE/TAO/tests/RTScheduling/Scheduler.cpp
new file mode 100644
index 00000000000..375217055ca
--- /dev/null
+++ b/ACE/TAO/tests/RTScheduling/Scheduler.cpp
@@ -0,0 +1,186 @@
+//$Id$
+
+#include "Scheduler.h"
+#include "tao/ORB.h"
+#include "ace/Atomic_Op.h"
+#include "tao/RTScheduling/Request_Interceptor.h"
+
+TAO_Scheduler::TAO_Scheduler (CORBA::ORB_ptr orb)
+{
+  CORBA::Object_var current_obj =
+    orb->resolve_initial_references ("RTScheduler_Current");
+
+  current_ = RTScheduling::Current::_narrow (current_obj.in ());
+}
+
+TAO_Scheduler::~TAO_Scheduler (void)
+{
+}
+
+CORBA::PolicyList*
+TAO_Scheduler::scheduling_policies (void)
+{
+  return 0;
+}
+
+void
+TAO_Scheduler::scheduling_policies (const CORBA::PolicyList &)
+{
+}
+
+CORBA::PolicyList*
+TAO_Scheduler::poa_policies (void)
+{
+  return 0;
+}
+
+char *
+TAO_Scheduler::scheduling_discipline_name (void)
+{
+  return 0;
+}
+
+RTScheduling::ResourceManager_ptr
+TAO_Scheduler::create_resource_manager (const char *,
+                                        CORBA::Policy_ptr)
+{
+  return 0;
+}
+
+void
+TAO_Scheduler::set_scheduling_parameter (PortableServer::Servant &,
+                                         const char *,
+                                         CORBA::Policy_ptr)
+{
+}
+
+void
+TAO_Scheduler::begin_new_scheduling_segment (const RTScheduling::Current::IdType &,
+                                             const char *,
+                                             CORBA::Policy_ptr,
+                                             CORBA::Policy_ptr)
+{
+}
+
+void
+TAO_Scheduler::begin_nested_scheduling_segment (const RTScheduling::Current::IdType &,
+                                                const char *,
+                                                CORBA::Policy_ptr,
+                                                CORBA::Policy_ptr)
+{
+}
+
+void
+TAO_Scheduler::update_scheduling_segment (const RTScheduling::Current::IdType &,
+                                          const char *,
+                                          CORBA::Policy_ptr,
+                                          CORBA::Policy_ptr)
+{
+}
+
+void
+TAO_Scheduler::end_scheduling_segment (const RTScheduling::Current::IdType &,
+                                       const char *)
+{
+}
+
+void
+TAO_Scheduler::end_nested_scheduling_segment (const RTScheduling::Current::IdType &,
+                                              const char *,
+                                              CORBA::Policy_ptr)
+{
+}
+
+
+void
+TAO_Scheduler::send_request (PortableInterceptor::ClientRequestInfo_ptr request_info)
+{
+  IOP::ServiceContext* srv_con = new IOP::ServiceContext;
+  srv_con->context_id = Client_Interceptor::SchedulingInfo;
+  srv_con->context_data.length (sizeof (size_t));
+  ACE_OS::memcpy (srv_con->context_data.get_buffer (),
+                  current_->id ()->get_buffer (),
+                  sizeof (size_t));
+  request_info->add_request_service_context (*srv_con,
+                                             0);
+}
+
+void
+TAO_Scheduler::receive_request (PortableInterceptor::ServerRequestInfo_ptr request_info,
+                                RTScheduling::Current::IdType_out guid_out,
+                                CORBA::String_out /*name*/,
+                                CORBA::Policy_out /*sched_param*/,
+                                CORBA::Policy_out /*implicit_sched_param*/)
+{
+  IOP::ServiceContext_var serv_cxt;
+
+  try
+    {
+      serv_cxt = request_info->get_request_service_context (Server_Interceptor::SchedulingInfo);
+
+      size_t gu_id;
+      ACE_OS::memcpy (&gu_id,
+                      serv_cxt->context_data.get_buffer (),
+                      serv_cxt->context_data.length ());
+
+      ACE_DEBUG ((LM_DEBUG,
+                  "The Guid is %d\n",
+                  gu_id));
+
+      RTScheduling::Current::IdType* guid;
+      ACE_NEW (guid,
+               RTScheduling::Current::IdType);
+
+      guid->length (sizeof (size_t));
+      ACE_OS::memcpy (guid->get_buffer (),
+                      serv_cxt->context_data.get_buffer (),
+                      sizeof (size_t));
+
+      guid_out.ptr () = guid;
+    }
+  catch (const CORBA::Exception&)
+    {
+      ACE_DEBUG ((LM_DEBUG,
+                  "Invalid Service Context\n"));
+    }
+}
+
+void
+TAO_Scheduler::send_reply (PortableInterceptor::ServerRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::send_exception (PortableInterceptor::ServerRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::send_other (PortableInterceptor::ServerRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::send_poll (PortableInterceptor::ClientRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::receive_reply (PortableInterceptor::ClientRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::receive_exception (PortableInterceptor::ClientRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::receive_other (PortableInterceptor::ClientRequestInfo_ptr)
+{
+}
+
+void
+TAO_Scheduler::cancel (const RTScheduling::Current::IdType &)
+{
+}