1 files changed, 80 insertions, 0 deletions
diff --git a/TAO/tao/RTScheduling/Request_Interceptor.h b/TAO/tao/RTScheduling/Request_Interceptor.h
new file mode 100644
index 00000000000..bc476915dd2
--- /dev/null
+++ b/TAO/tao/RTScheduling/Request_Interceptor.h
@@ -0,0 +1,80 @@
+// -*- C++ -*-
+//
+//$Id$
+
+#ifndef TAO_RTSCHEDULING_REQUEST_INTERCEPTOR_H
+#define TAO_RTSCHEDULING_REQUEST_INTERCEPTOR_H
+
+#include "tao/RTScheduling/rtscheduler_export.h"
+#include "tao/RTScheduling/RTScheduler.h"
+#include "ace/Atomic_Op.h"
+#include "tao/RTScheduling/Current.h"
+#include "tao/LocalObject.h"
+
+#include "tao/PI/PI.h"
+#include "tao/PI_Server/PI_Server.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+extern ACE_Atomic_Op<TAO_SYNCH_MUTEX, long> server_guid_counter;
+
+class TAO_RTScheduler_Export Client_Interceptor:
+  public PortableInterceptor::ClientRequestInterceptor,
+  public TAO_Local_RefCounted_Object
+{
+public:
+
+  //  Client_Interceptor (RTScheduling::Current_ptr current);
+  virtual void send_request (PortableInterceptor::ClientRequestInfo_ptr ri
+                             );
+
+  virtual void send_poll (PortableInterceptor::ClientRequestInfo_ptr ri
+                          );
+
+  virtual void receive_reply (PortableInterceptor::ClientRequestInfo_ptr ri
+                              );
+
+  virtual void receive_exception (PortableInterceptor::ClientRequestInfo_ptr ri);
+
+  virtual void receive_other (PortableInterceptor::ClientRequestInfo_ptr ri);
+
+  virtual char* name (void);
+
+  virtual void destroy (void);
+
+  static const IOP::ServiceId SchedulingInfo;
+
+};
+
+class TAO_RTScheduler_Export Server_Interceptor :
+  public PortableInterceptor::ServerRequestInterceptor,
+  public TAO_Local_RefCounted_Object
+{
+
+public:
+  Server_Interceptor (TAO_RTScheduler_Current_ptr current);
+
+  virtual void receive_request_service_contexts (PortableInterceptor::ServerRequestInfo_ptr ri);
+
+  virtual void receive_request (PortableInterceptor::ServerRequestInfo_ptr ri);
+
+  virtual void send_reply (PortableInterceptor::ServerRequestInfo_ptr ri);
+
+  virtual void send_exception (PortableInterceptor::ServerRequestInfo_ptr ri);
+
+  virtual void send_other (PortableInterceptor::ServerRequestInfo_ptr ri);
+
+  virtual char* name (void);
+
+  virtual void destroy (void);
+
+  static const IOP::ServiceId SchedulingInfo;
+
+ private:
+  TAO_RTScheduler_Current_var current_;
+
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#endif  /* TAO_RTSCHEDULING_REQUEST_INTERCEPTOR_H */