1 files changed, 110 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Service_Callbacks.h b/ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Service_Callbacks.h
new file mode 100644
index 00000000000..de694bb723c
--- /dev/null
+++ b/ACE/TAO/orbsvcs/orbsvcs/FaultTolerance/FT_Service_Callbacks.h
@@ -0,0 +1,110 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ * @file FT_Service_Callbacks.h
+ *
+ * $Id$
+ *
+ * A concrete FT service callback implementation
+ *
+ * @author Balachandran Natarajan <bala@cs.wustl.edu>
+ */
+//=============================================================================
+
+#ifndef TAO_FT_CALLBACKS_H
+#define TAO_FT_CALLBACKS_H
+#include /**/ "ace/pre.h"
+
+#include "orbsvcs/FaultTolerance/FT_ClientORB_export.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "tao/Service_Callbacks.h"
+#include "orbsvcs/FT_CORBA_ORBC.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+class TAO_Profile;
+class TAO_MProfile;
+class TAO_ORB_Core;
+
+/**
+ * @class TAO_FT_Service_Callbacks
+ *
+ * @brief A class to dynamically load the FT callback implementations in
+ * to the ORB.
+ *
+ * An implementation of the service callbacks that allows the
+ * loading of the FT ORB level library in to the ORB
+ */
+class TAO_FT_ClientORB_Export TAO_FT_Service_Callbacks : public TAO_Service_Callbacks
+{
+public:
+  /// Constructor
+  TAO_FT_Service_Callbacks (TAO_ORB_Core *orb_core);
+
+  /// Dtor
+  virtual ~TAO_FT_Service_Callbacks (void);
+
+  /// Select the profile from MProfile as the needs of the services
+  /// may be. Return the profile in <pfile>
+  virtual CORBA::Boolean select_profile (const TAO_MProfile &mprofile,
+                                         TAO_Profile *&pfile);
+
+  /// Check whether <obj> is nil or not. FT spec suggests some
+  /// extensions for a CORBA::is_nil () operation.
+  virtual CORBA::Boolean object_is_nil (CORBA::Object_ptr obj);
+
+  /// Check for equivalency of the two profiles
+  virtual TAO_Service_Callbacks::Profile_Equivalence is_profile_equivalent (
+                                                const TAO_Profile *,
+                                                const TAO_Profile *);
+  /// Calculate the hash
+  virtual CORBA::ULong hash_ft (TAO_Profile *p,
+                                CORBA::ULong m);
+
+
+  /// Verify condition for  permanent forward is given,
+  /// both parameters must provide group attributes.
+  virtual CORBA::Boolean is_permanent_forward_condition
+  (const CORBA::Object_ptr obj,
+   const TAO_Service_Context &service_context) const;
+
+  /// Check whether we need to raise an exception or go for a
+  /// reinvocaton.
+  virtual TAO::Invocation_Status raise_comm_failure (
+      IOP::ServiceContextList &clist,
+      TAO_Profile *profile);
+
+  /// Check whether we need to raise an exception or go for a
+  /// reinvocaton.
+  virtual TAO::Invocation_Status raise_transient_failure (
+      IOP::ServiceContextList &clist,
+      TAO_Profile *profile);
+
+  static TimeBase::TimeT now (void);
+
+private:
+
+  /// Check whether the right flags are available so that we can issue a
+  /// restart.
+  CORBA::Boolean restart_policy_check (IOP::ServiceContextList &service_list,
+                                       const TAO_Profile *profile);
+
+private:
+  /// The ORB core in which we have been activated
+  TAO_ORB_Core *orb_core_;
+
+  /// Mutex to protect access to the profile that gets passed along
+  /// @@ Lock needs to be removed...
+  ACE_Lock* profile_lock_;
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#include /**/ "ace/post.h"
+
+#endif /*TAO_FT_CALLBACKS_H*/