1 files changed, 110 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/orbsvcs/Event/ECG_UDP_EH.h b/trunk/TAO/orbsvcs/orbsvcs/Event/ECG_UDP_EH.h
new file mode 100644
index 00000000000..48672ad0feb
--- /dev/null
+++ b/trunk/TAO/orbsvcs/orbsvcs/Event/ECG_UDP_EH.h
@@ -0,0 +1,110 @@
+// -*- C++ -*-
+
+/**
+ *  @file   ECG_UDP_EH.h
+ *
+ *  $Id$
+ *
+ *  @author Carlos O'Ryan (coryan@cs.wustl.edu)
+ *  @author Marina Spivak (marina@atdesk.com)
+ *
+ * http://doc.ece.uci.edu/~coryan/EC/index.html
+ */
+
+#ifndef TAO_ECG_UDP_EH_H
+#define TAO_ECG_UDP_EH_H
+#include /**/ "ace/pre.h"
+
+#include "ace/Event_Handler.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include /**/ "orbsvcs/Event/event_serv_export.h"
+#include "orbsvcs/Event/ECG_Adapters.h"
+#include "ace/SOCK_Dgram.h"
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+class TAO_ECG_UDP_Receiver;
+
+/**
+ * @class TAO_ECG_UDP_EH
+ *
+ * @brief Event Handler for UDP messages.
+ *
+ * Listens for messages on a UDP socket.  When there is a message,
+ * calls handle_input () on a specified TAO_ECG_Dgram_Handler to
+ * inform it about message arrival.
+ *
+ * NOT THREAD-SAFE.
+ */
+class TAO_RTEvent_Serv_Export TAO_ECG_UDP_EH :
+  public ACE_Event_Handler
+, public TAO_ECG_Handler_Shutdown
+{
+public:
+
+  /// Initialization and termination methods.
+  //@{
+  /// Constructor.
+  /// Messages received by this EH will be forwarded to the <recv>.
+  /*
+   * See comments for <receiver_> data member on why raw pointer is
+   * used for the <recv> argument.
+   */
+  TAO_ECG_UDP_EH (TAO_ECG_Dgram_Handler *recv);
+
+  /// Destructor.
+  virtual ~TAO_ECG_UDP_EH (void);
+
+  /// Open the datagram and register itself with this->reactor().
+  /// To insure proper resource clean up, if open () is successful,
+  /// the user MUST call shutdown () when handler is no longer needed
+  /// (and its reactor still exists).
+  int open (const ACE_INET_Addr& ipaddr,
+            int reuse_addr = 0);
+
+  /// TAO_ECG_Handler_Shutdown method.
+  /// Unsubscribe from the reactor and close the datagram.
+  virtual int shutdown (void);
+  //@}
+
+  /// Main method - reactor callback.  Notify <receiver_> that
+  /// <dgram_> is ready for reading.
+  virtual int handle_input (ACE_HANDLE fd);
+
+  /**
+   * Obtain the dgram, this is one of those "controlled violations of
+   * type safety", allowing the user to setup options and gain access
+   * to low-level features.
+   */
+  ACE_SOCK_Dgram &dgram (void);
+
+private:
+
+  /// The datagram used to receive the data.
+  ACE_SOCK_Dgram dgram_;
+
+  /// We callback to this object when a message arrives.
+  /*
+   * We can keep a raw pointer to the receiver (even though it may
+   * be a refcounted object) because receiver guarantees
+   * to notify us (by calling shutdown ()) before going away.
+   *
+   * We have to use raw pointer instead of a refcounting mechanism
+   * here to avoid a circular refcounting dependency between
+   * receiver and handler.
+   */
+  TAO_ECG_Dgram_Handler* receiver_;
+};
+
+TAO_END_VERSIONED_NAMESPACE_DECL
+
+#if defined(__ACE_INLINE__)
+#include "orbsvcs/Event/ECG_UDP_EH.inl"
+#endif /* __ACE_INLINE__ */
+
+#include /**/ "ace/post.h"
+#endif /* TAO_ECG_UDP_EH_H */