1 files changed, 67 insertions, 0 deletions
diff --git a/ACE/ace/Reactor_Notification_Strategy.h b/ACE/ace/Reactor_Notification_Strategy.h
new file mode 100644
index 00000000000..5d38f5609a6
--- /dev/null
+++ b/ACE/ace/Reactor_Notification_Strategy.h
@@ -0,0 +1,67 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file   Reactor_Notification_Strategy.h
+ *
+ *  $Id$
+ *
+ *  @author Doug Schmidt
+ */
+//=============================================================================
+#ifndef ACE_REACTOR_NOTIFICATION_STRATEGY_H
+#define ACE_REACTOR_NOTIFICATION_STRATEGY_H
+
+#include /**/ "ace/pre.h"
+
+#include "ace/Notification_Strategy.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+ACE_BEGIN_VERSIONED_NAMESPACE_DECL
+
+/**
+ * @class ACE_Reactor_Notification_Strategy
+ *
+ * @brief Used to notify an ACE_Reactor
+ *
+ * Integrates the ACE_Message_Queue notification into the
+ * <ACE_Reactor::notify> method.
+ */
+class ACE_Export ACE_Reactor_Notification_Strategy : public ACE_Notification_Strategy
+{
+public:
+  ACE_Reactor_Notification_Strategy (ACE_Reactor *reactor,
+                                     ACE_Event_Handler *eh,
+                                     ACE_Reactor_Mask mask);
+
+  /// Default dtor.
+  virtual ~ACE_Reactor_Notification_Strategy (void);
+
+  virtual int notify (void);
+
+  virtual int notify (ACE_Event_Handler *,
+                      ACE_Reactor_Mask mask);
+
+  /// Get the reactor
+  ACE_Reactor *reactor (void);
+
+  /// Set the reactor
+  void reactor (ACE_Reactor *r);
+
+protected:
+  /// The Reactor
+  ACE_Reactor *reactor_;
+};
+
+ACE_END_VERSIONED_NAMESPACE_DECL
+
+#if defined (__ACE_INLINE__)
+#include "ace/Reactor_Notification_Strategy.inl"
+#endif /* __ACE_INLINE __ */
+
+#include /**/ "ace/post.h"
+
+#endif /*ACE_REACTOR_NOTIFICATION_STRATEGY_H */