1 files changed, 87 insertions, 0 deletions
diff --git a/trunk/ACE/examples/APG/Proactor/HA_Proactive_Status.h b/trunk/ACE/examples/APG/Proactor/HA_Proactive_Status.h
new file mode 100644
index 00000000000..f66080b62cd
--- /dev/null
+++ b/trunk/ACE/examples/APG/Proactor/HA_Proactive_Status.h
@@ -0,0 +1,87 @@
+/* -*- C++ -*- */
+/*
+** $Id$
+**
+** Example program from The ACE Programmer's Guide, Chapter 8.
+** Copyright 2003 Addison-Wesley. All Rights Reserved.
+*/
+
+#ifndef __HA_PROACTIVE_STATUS_H
+#define __HA_PROACTIVE_STATUS_H
+
+#include "ace/OS_NS_sys_socket.h"
+#include "ace/Asynch_IO.h"
+#include "ace/Service_Object.h"
+// Listing 1 code/ch08
+#include "ace/Asynch_IO.h"
+
+#if (defined (ACE_WIN32) && !defined (ACE_HAS_WINCE)) || (defined (ACE_HAS_AIO_CALLS))
+
+class HA_Proactive_Service : public ACE_Service_Handler
+{
+public:
+  ~HA_Proactive_Service ()
+   {
+     if (this->handle () != ACE_INVALID_HANDLE)
+       ACE_OS::closesocket (this->handle ());
+   }
+
+  virtual void open (ACE_HANDLE h, ACE_Message_Block&);
+
+  // This method will be called when an asynchronous read
+  // completes on a stream.
+  virtual void handle_read_stream
+    (const ACE_Asynch_Read_Stream::Result &result);
+
+  // This method will be called when an asynchronous write
+  // completes on a stream.
+  virtual void handle_write_stream
+    (const ACE_Asynch_Write_Stream::Result &result);
+
+private:
+  ACE_Asynch_Read_Stream reader_;
+  ACE_Asynch_Write_Stream writer_;
+};
+// Listing 1
+
+// Listing 2 code/ch08
+#include "ace/Asynch_Acceptor.h"
+#include "ace/INET_Addr.h"
+
+class HA_Proactive_Acceptor :
+    public ACE_Asynch_Acceptor<HA_Proactive_Service>
+{
+public:
+  virtual int validate_connection
+    (const ACE_Asynch_Accept::Result& result,
+     const ACE_INET_Addr &remote,
+     const ACE_INET_Addr &local);
+};
+// Listing 2
+
+#endif /* (ACE_WIN32 && != ACE_HAS_WINCE) || ACE_HAS_AIO_CALLS*/
+
+#if 0
+// Listing 3 code/ch08
+template <class HANDLER>
+class ACE_Asynch_Acceptor : public ACE_Handler
+      ...
+protected:
+  virtual HANDLER *make_handler (void)
+  {
+    return new HANDLER;
+  }
+// Listing 3
+#endif
+
+class HA_Proactive_Status : public ACE_Service_Object
+{
+public:
+  // Initializes object when dynamic linking occurs.
+  virtual int init (int argc, ACE_TCHAR *argv[]);
+
+  // Terminates object when dynamic unlinking occurs.
+  virtual int fini (void);
+};
+
+#endif /* __HA_PROACTIVE_STATUS_H */