17 files changed, 0 insertions, 3094 deletions
diff --git a/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp b/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp
deleted file mode 100644
index 71c152b0687..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Consumer_Router.cpp
+++ /dev/null
@@ -1,148 +0,0 @@
-#include "Consumer_Router.h"
-// $Id$
-
-#include "Options.h"
-
-#if defined (ACE_HAS_THREADS)
-
-typedef Acceptor_Factory<Consumer_Handler, CONSUMER_KEY> CONSUMER_FACTORY;
-
-int
-Consumer_Handler::open (void *a)
-{
-  CONSUMER_FACTORY *af = (CONSUMER_FACTORY *) a;
-  this->router_task_ = af->router ();
-  return this->Peer_Handler<CONSUMER_ROUTER, CONSUMER_KEY>::open (a);
-}
-
-Consumer_Handler::Consumer_Handler (ACE_Thread_Manager *tm)
-  : Peer_Handler<CONSUMER_ROUTER, CONSUMER_KEY> (tm)
-{
-}
-
-// Create a new handler that will interact with a consumer and point
-// its ROUTER_TASK_ data member to the CONSUMER_ROUTER.
-
-Consumer_Router::Consumer_Router (ACE_Thread_Manager *tm)
-  : CONSUMER_ROUTER (tm)
-{
-}
-
-// Initialize the Router..
-
-int
-Consumer_Router::open (void *)
-{
-  ACE_ASSERT (this->is_reader ());
-  char *argv[3];
-
-  argv[0] = (char *) this->name ();
-  argv[1] = options.consumer_file ();
-  argv[2] = 0;
-
-  if (this->init (1, &argv[1]) == -1)
-    return -1;
-
-  // Make this an active object.
-  //   return this->activate (options.t_flags ());
-
-  // Until that's done, return 1 to indicate that the object wasn't activated.
-  return 1;
-}
-
-int
-Consumer_Router::close (u_long)
-{
-  ACE_ASSERT (this->is_reader ());
-  this->peer_map_.close ();
-  this->msg_queue ()->deactivate();
-  return 0;
-}
-
-
-// Handle incoming messages in a separate thread..
-
-int
-Consumer_Router::svc (void)
-{
-  ACE_Message_Block *mb = 0;
-
-  ACE_ASSERT (this->is_reader ());
-
-  if (options.debug ())
-    ACE_DEBUG ((LM_DEBUG, "(%t) starting svc in %s\n", this->name ()));
-
-  while (this->getq (mb) > 0)
-    if (this->put_next (mb) == -1)
-      ACE_ERROR_RETURN ((LM_ERROR, "(%t) put_next failed in %s\n", this->name ()), -1);
-
-  return 0;
-  // Note the implicit ACE_OS::thr_exit() via destructor.
-}
-
-// Send a MESSAGE_BLOCK to the supplier(s)..
-
-int
-Consumer_Router::put (ACE_Message_Block *mb, ACE_Time_Value *)
-{
-  ACE_ASSERT (this->is_reader ());
-
-  if (mb->msg_type () == ACE_Message_Block::MB_IOCTL)
-    {
-      this->control (mb);
-      return this->put_next (mb);
-    }
-  else
-{
-//printf("consumer-Router is routing : send_peers\n");
-    return this->send_peers (mb);
-}
-}
-
-// Return information about the Client_Router ACE_Module..
-
-int
-Consumer_Router::info (char **strp, size_t length) const
-{
-  char	     buf[BUFSIZ];
-  ACE_UPIPE_Addr  addr;
-  const char *mod_name = this->name ();
-  ACE_UPIPE_Acceptor &sa = (ACE_UPIPE_Acceptor &) *this->acceptor_;
-
-  if (sa.get_local_addr (addr) == -1)
-    return -1;
-
-  ACE_OS::sprintf (buf, "%s\t /%s %s",
-	     mod_name,  "upipe",
-	     "# consumer router\n");
-
-  if (*strp == 0 && (*strp = ACE_OS::strdup (mod_name)) == 0)
-    return -1;
-  else
-    ACE_OS::strncpy (*strp, mod_name, length);
-  return ACE_OS::strlen (mod_name);
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class ACE_Acceptor<Consumer_Handler, ACE_UPIPE_ACCEPTOR>;
-template class Acceptor_Factory<Consumer_Handler, CONSUMER_KEY>;
-template class Peer_Handler<CONSUMER_ROUTER, CONSUMER_KEY>;
-template class Peer_Router<Consumer_Handler, CONSUMER_KEY>;
-template class ACE_Map_Entry<CONSUMER_KEY, Consumer_Handler *>;
-template class ACE_Map_Iterator_Base<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>;
-template class ACE_Map_Iterator<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>;
-template class ACE_Map_Reverse_Iterator<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>;
-template class ACE_Map_Manager<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>;
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate ACE_Acceptor<Consumer_Handler, ACE_UPIPE_ACCEPTOR>
-#pragma instantiate Acceptor_Factory<Consumer_Handler, CONSUMER_KEY>
-#pragma instantiate Peer_Handler<CONSUMER_ROUTER, CONSUMER_KEY>
-#pragma instantiate Peer_Router<Consumer_Handler, CONSUMER_KEY>
-#pragma instantiate ACE_Map_Entry<CONSUMER_KEY, Consumer_Handler *>
-#pragma instantiate ACE_Map_Iterator_Base<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Map_Iterator<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Map_Reverse_Iterator<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Map_Manager<CONSUMER_KEY, Consumer_Handler *, ACE_RW_Mutex>
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
-
-#endif /* ACE_HAS_THREADS */
diff --git a/examples/ASX/UPIPE_Event_Server/Consumer_Router.h b/examples/ASX/UPIPE_Event_Server/Consumer_Router.h
deleted file mode 100644
index 4568ddf8311..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Consumer_Router.h
+++ /dev/null
@@ -1,48 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// The interface between one or more consumers and an Event Server
-// ACE_Stream.
-
-#if !defined (_CONSUMER_ROUTER_H)
-#define _CONSUMER_ROUTER_H
-
-#include "ace/Thread_Manager.h"
-#include "ace/UPIPE_Acceptor.h"
-#include "ace/UPIPE_Addr.h"
-#include "ace/Svc_Handler.h"
-#include "Peer_Router.h"
-
-#if defined (ACE_HAS_THREADS)
-
-class Consumer_Handler; // Forward declaration....
-
-typedef ACE_HANDLE CONSUMER_KEY;
-
-typedef Peer_Router<Consumer_Handler, CONSUMER_KEY> CONSUMER_ROUTER;
-
-class Consumer_Handler 
-  : public Peer_Handler<CONSUMER_ROUTER, CONSUMER_KEY>
-{
-public:
-  Consumer_Handler (ACE_Thread_Manager *tm = 0);
-  virtual int open (void *);
-};
-
-class Consumer_Router : public CONSUMER_ROUTER
-{
-public:
-  Consumer_Router (ACE_Thread_Manager *thr_manager);
-
-protected:
-  // ACE_Task hooks..
-  virtual int open (void *a = 0);
-  virtual int close (u_long flags = 0);
-  virtual int put (ACE_Message_Block *msg, ACE_Time_Value * = 0);
-  virtual int svc (void);
-
-  // Dynamic linking hooks.
-  virtual int info (char **info_string, size_t length) const;
-};
-#endif /* ACE_HAS_THREADS */
-#endif /* _CONSUMER_ROUTER_H */
diff --git a/examples/ASX/UPIPE_Event_Server/Event_Analyzer.cpp b/examples/ASX/UPIPE_Event_Server/Event_Analyzer.cpp
deleted file mode 100644
index 10133b3c90e..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Event_Analyzer.cpp
+++ /dev/null
@@ -1,70 +0,0 @@
-#include "Event_Analyzer.h"
-// $Id$
-
-
-#if defined (ACE_HAS_THREADS)
-
-int
-Event_Analyzer::open (void *)
-{
-  return 0;
-}
-
-int
-Event_Analyzer::close (u_long)
-{
-  return 0;
-}
-
-int
-Event_Analyzer::control (ACE_Message_Block *mb)
-{
-  ACE_IO_Cntl_Msg *ioc = (ACE_IO_Cntl_Msg *) mb->rd_ptr ();
-  ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds cmd;
-
-  switch (cmd = ioc->cmd ())
-    {
-    case ACE_IO_Cntl_Msg::SET_LWM: 
-    case ACE_IO_Cntl_Msg::SET_HWM:
-      this->water_marks (cmd, *(size_t *) mb->cont ()->rd_ptr ());
-      break;
-    default:
-      break;
-    }
-  return 0;
-}
-
-int 
-Event_Analyzer::put (ACE_Message_Block *mb, ACE_Time_Value *)
-{
-  if (mb->msg_type () == ACE_Message_Block::MB_IOCTL)
-    this->control (mb);
-
-  return this->put_next (mb);
-}
-
-int 
-Event_Analyzer::init (int, char *[])
-{
-  return 0;
-}
-
-int 
-Event_Analyzer::fini (void)
-{
-  return 0;
-}
-
-int 
-Event_Analyzer::info (char **strp, size_t length) const
-{
-  const char *mod_name = this->name ();
-  
-  if (*strp == 0 && (*strp = ACE_OS::strdup (mod_name)) == 0)
-    return -1;
-  else
-    ACE_OS::strncpy (*strp, mod_name, length);
-  return ACE_OS::strlen (mod_name);
-}
-
-#endif /* ACE_HAS_THREADS */
diff --git a/examples/ASX/UPIPE_Event_Server/Event_Analyzer.h b/examples/ASX/UPIPE_Event_Server/Event_Analyzer.h
deleted file mode 100644
index a815e7d642a..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Event_Analyzer.h
+++ /dev/null
@@ -1,33 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// Signal router.
-
-#if !defined (_EVENT_ANALYZER_H)
-#define _EVENT_ANALYZER_H     
-
-#include "ace/Stream.h"
-#include "ace/Module.h"
-#include "ace/Task.h"
-#include "ace/Synch.h"
-
-#if defined (ACE_HAS_THREADS)
-
-class Event_Analyzer : public ACE_Task<ACE_MT_SYNCH>
-{
-public:
-  virtual int open (void *a = 0);
-  virtual int close (u_long flags = 0);
-  virtual int put (ACE_Message_Block *msg, ACE_Time_Value * = 0);
-
-  // Dynamic linking hooks.
-  virtual int init (int argc, char *argv[]);
-  virtual int fini (void);
-  virtual int info (char **info_string, size_t length) const;
-
-private:
-  virtual int control (ACE_Message_Block *);
-};
-
-#endif /* ACE_HAS_THREADS */
-#endif /* _EVENT_ANALYZER_H */
diff --git a/examples/ASX/UPIPE_Event_Server/Makefile b/examples/ASX/UPIPE_Event_Server/Makefile
deleted file mode 100644
index 439e7e7cd4f..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Makefile
+++ /dev/null
@@ -1,334 +0,0 @@
-#----------------------------------------------------------------------------
-#	@(#)Makefile	1.1	10/18/96
-#
-#	Makefile for the Event Server test
-#----------------------------------------------------------------------------
-
-#----------------------------------------------------------------------------
-#	Local macros
-#----------------------------------------------------------------------------
-
-BIN   	= event_server
-
-FILES  	= Options \
-          Supplier_Router \
-	  Event_Analyzer \
-	  Consumer_Router \
-	  Peer_Router
-
-LSRC	= $(addsuffix .cpp,$(FILES))
-LOBJ	= $(addsuffix .o,$(FILES))
-SHOBJ	= $(addsuffix .so,$(FILES))
-
-BUILD 	= $(VBIN)
-
-#----------------------------------------------------------------------------
-#	Include macros and targets
-#----------------------------------------------------------------------------
-
-include		$(ACE_ROOT)/include/makeinclude/wrapper_macros.GNU
-include		$(ACE_ROOT)/include/makeinclude/macros.GNU
-include		$(ACE_ROOT)/include/makeinclude/rules.common.GNU
-include		$(ACE_ROOT)/include/makeinclude/rules.nonested.GNU
-include		$(ACE_ROOT)/include/makeinclude/rules.lib.GNU
-include		$(ACE_ROOT)/include/makeinclude/rules.bin.GNU
-include		$(ACE_ROOT)/include/makeinclude/rules.local.GNU
-
-#----------------------------------------------------------------------------
-#	Local targets
-#----------------------------------------------------------------------------
-
-#----------------------------------------------------------------------------
-#	Dependencies
-#----------------------------------------------------------------------------
-
-# DO NOT DELETE THIS LINE -- g++dep uses it.
-# DO NOT PUT ANYTHING AFTER THIS LINE, IT WILL GO AWAY.
-
-.obj/Options.o .obj/Options.so .shobj/Options.o .shobj/Options.so: Options.cpp $(ACE_ROOT)/ace/Get_Opt.h \
- $(ACE_ROOT)/ace/ACE.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Version.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Synch.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h Options.h \
- $(ACE_ROOT)/ace/Profile_Timer.h \
- $(ACE_ROOT)/ace/Time_Value.h \
- $(ACE_ROOT)/ace/High_Res_Timer.h
-.obj/Supplier_Router.o .obj/Supplier_Router.so .shobj/Supplier_Router.o .shobj/Supplier_Router.so: Supplier_Router.cpp Options.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/ACE.h \
- $(ACE_ROOT)/ace/Version.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Profile_Timer.h \
- $(ACE_ROOT)/ace/Time_Value.h \
- $(ACE_ROOT)/ace/High_Res_Timer.h \
- Supplier_Router.h $(ACE_ROOT)/ace/UPIPE_Addr.h \
- $(ACE_ROOT)/ace/SPIPE_Addr.h \
- $(ACE_ROOT)/ace/Addr.h \
- $(ACE_ROOT)/ace/UPIPE_Acceptor.h \
- $(ACE_ROOT)/ace/UPIPE_Stream.h \
- $(ACE_ROOT)/ace/Stream.h \
- $(ACE_ROOT)/ace/IO_Cntl_Msg.h \
- $(ACE_ROOT)/ace/Message_Block.h \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Synch.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Module.h \
- $(ACE_ROOT)/ace/Task_T.h \
- $(ACE_ROOT)/ace/Message_Queue.h \
- $(ACE_ROOT)/ace/Strategies.h \
- $(ACE_ROOT)/ace/Strategies_T.h \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- $(ACE_ROOT)/ace/Synch_Options.h \
- $(ACE_ROOT)/ace/Hash_Map_Manager.h \
- $(ACE_ROOT)/ace/Task.h \
- $(ACE_ROOT)/ace/Thread_Manager.h \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/SPIPE.h \
- $(ACE_ROOT)/ace/IPC_SAP.h \
- $(ACE_ROOT)/ace/IPC_SAP.i \
- $(ACE_ROOT)/ace/SPIPE.i \
- $(ACE_ROOT)/ace/SPIPE_Acceptor.h \
- $(ACE_ROOT)/ace/SPIPE_Stream.h \
- $(ACE_ROOT)/ace/SPIPE_Stream.i \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/Svc_Handler.h \
- $(ACE_ROOT)/ace/Dynamic.h \
- $(ACE_ROOT)/ace/Singleton.h Peer_Router.h \
- $(ACE_ROOT)/ace/Acceptor.h \
- $(ACE_ROOT)/ace/Acceptor.i
-.obj/Event_Analyzer.o .obj/Event_Analyzer.so .shobj/Event_Analyzer.o .shobj/Event_Analyzer.so: Event_Analyzer.cpp Event_Analyzer.h \
- $(ACE_ROOT)/ace/Stream.h \
- $(ACE_ROOT)/ace/ACE.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Version.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/IO_Cntl_Msg.h \
- $(ACE_ROOT)/ace/Message_Block.h \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Synch.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Time_Value.h \
- $(ACE_ROOT)/ace/Module.h \
- $(ACE_ROOT)/ace/Task_T.h \
- $(ACE_ROOT)/ace/Message_Queue.h \
- $(ACE_ROOT)/ace/Strategies.h \
- $(ACE_ROOT)/ace/Strategies_T.h \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- $(ACE_ROOT)/ace/Synch_Options.h \
- $(ACE_ROOT)/ace/Hash_Map_Manager.h \
- $(ACE_ROOT)/ace/Task.h \
- $(ACE_ROOT)/ace/Thread_Manager.h \
- $(ACE_ROOT)/ace/Thread.h
-.obj/Consumer_Router.o .obj/Consumer_Router.so .shobj/Consumer_Router.o .shobj/Consumer_Router.so: Consumer_Router.cpp Consumer_Router.h \
- $(ACE_ROOT)/ace/Thread_Manager.h \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/ACE.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Version.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Synch.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/UPIPE_Acceptor.h \
- $(ACE_ROOT)/ace/UPIPE_Stream.h \
- $(ACE_ROOT)/ace/Stream.h \
- $(ACE_ROOT)/ace/IO_Cntl_Msg.h \
- $(ACE_ROOT)/ace/Message_Block.h \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Time_Value.h \
- $(ACE_ROOT)/ace/Module.h \
- $(ACE_ROOT)/ace/Task_T.h \
- $(ACE_ROOT)/ace/Message_Queue.h \
- $(ACE_ROOT)/ace/Strategies.h \
- $(ACE_ROOT)/ace/Strategies_T.h \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- $(ACE_ROOT)/ace/Synch_Options.h \
- $(ACE_ROOT)/ace/Hash_Map_Manager.h \
- $(ACE_ROOT)/ace/Task.h \
- $(ACE_ROOT)/ace/SPIPE.h \
- $(ACE_ROOT)/ace/IPC_SAP.h \
- $(ACE_ROOT)/ace/IPC_SAP.i \
- $(ACE_ROOT)/ace/SPIPE_Addr.h \
- $(ACE_ROOT)/ace/Addr.h \
- $(ACE_ROOT)/ace/SPIPE.i \
- $(ACE_ROOT)/ace/UPIPE_Addr.h \
- $(ACE_ROOT)/ace/SPIPE_Acceptor.h \
- $(ACE_ROOT)/ace/SPIPE_Stream.h \
- $(ACE_ROOT)/ace/SPIPE_Stream.i \
- $(ACE_ROOT)/ace/Svc_Handler.h \
- $(ACE_ROOT)/ace/Dynamic.h \
- $(ACE_ROOT)/ace/Singleton.h Peer_Router.h \
- $(ACE_ROOT)/ace/Acceptor.h \
- $(ACE_ROOT)/ace/Acceptor.i \
- $(ACE_ROOT)/ace/Map_Manager.h Options.h \
- $(ACE_ROOT)/ace/Profile_Timer.h \
- $(ACE_ROOT)/ace/High_Res_Timer.h
-.obj/Peer_Router.o .obj/Peer_Router.so .shobj/Peer_Router.o .shobj/Peer_Router.so: Peer_Router.cpp \
- $(ACE_ROOT)/ace/Get_Opt.h \
- $(ACE_ROOT)/ace/ACE.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Version.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Synch.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.h \
- $(ACE_ROOT)/ace/SV_Semaphore_Simple.i \
- $(ACE_ROOT)/ace/SV_Semaphore_Complex.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h Peer_Router.h \
- $(ACE_ROOT)/ace/Acceptor.h \
- $(ACE_ROOT)/ace/Svc_Handler.h \
- $(ACE_ROOT)/ace/Synch_Options.h \
- $(ACE_ROOT)/ace/Task.h \
- $(ACE_ROOT)/ace/Thread_Manager.h \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Task_T.h \
- $(ACE_ROOT)/ace/Message_Queue.h \
- $(ACE_ROOT)/ace/Message_Block.h \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/IO_Cntl_Msg.h \
- $(ACE_ROOT)/ace/Strategies.h \
- $(ACE_ROOT)/ace/Strategies_T.h \
- $(ACE_ROOT)/ace/Hash_Map_Manager.h \
- $(ACE_ROOT)/ace/Dynamic.h \
- $(ACE_ROOT)/ace/Singleton.h \
- $(ACE_ROOT)/ace/Acceptor.i \
- $(ACE_ROOT)/ace/UPIPE_Acceptor.h \
- $(ACE_ROOT)/ace/UPIPE_Stream.h \
- $(ACE_ROOT)/ace/Stream.h \
- $(ACE_ROOT)/ace/Time_Value.h \
- $(ACE_ROOT)/ace/Module.h \
- $(ACE_ROOT)/ace/SPIPE.h \
- $(ACE_ROOT)/ace/IPC_SAP.h \
- $(ACE_ROOT)/ace/IPC_SAP.i \
- $(ACE_ROOT)/ace/SPIPE_Addr.h \
- $(ACE_ROOT)/ace/Addr.h \
- $(ACE_ROOT)/ace/SPIPE.i \
- $(ACE_ROOT)/ace/UPIPE_Addr.h \
- $(ACE_ROOT)/ace/SPIPE_Acceptor.h \
- $(ACE_ROOT)/ace/SPIPE_Stream.h \
- $(ACE_ROOT)/ace/SPIPE_Stream.i \
- $(ACE_ROOT)/ace/Map_Manager.h Options.h \
- $(ACE_ROOT)/ace/Profile_Timer.h \
- $(ACE_ROOT)/ace/High_Res_Timer.h
-
-# IF YOU PUT ANYTHING HERE IT WILL GO AWAY
diff --git a/examples/ASX/UPIPE_Event_Server/Options.cpp b/examples/ASX/UPIPE_Event_Server/Options.cpp
deleted file mode 100644
index f77333da2a3..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Options.cpp
+++ /dev/null
@@ -1,191 +0,0 @@
-#include "ace/Get_Opt.h"
-// $Id$
-
-#include "ace/Synch.h"
-
-#include "Options.h"
-
-#if defined (ACE_HAS_THREADS)
-
-Options::Options (void)
-		 : thr_count_ (4),
-		   t_flags_ (THR_DETACHED),
-		   high_water_mark_ (8 * 1024),
-		   low_water_mark_ (1024),
-		   message_size_ (128),
-		   initial_queue_length_ (0),
-		   iterations_ (100000),
-		   debugging_ (0),
-		   verbosity_ (0),
-		   consumer_port_ ("-p 10000"),
-		   supplier_port_ ("-p 10001"),
-		   consumer_file_ ("-f/tmp/conupipe"),
-		   supplier_file_ ("-f/tmp/supupipe")
-{
-}
-
-Options::~Options (void)
-{
-}
-
-void Options::print_results (void)
-{
-  ACE_Profile_Timer::ACE_Elapsed_Time et;
-  this->itimer_.elapsed_time (et);
-
-#if defined (ACE_HAS_PRUSAGE_T)
-  prusage_t rusage;
-  this->itimer_.get_rusage (rusage);
-
-  if (options.verbose ())
-    {
-      ACE_OS::printf ("final concurrency hint = %d\n", ACE_OS::thr_getconcurrency ());
-      ACE_OS::printf ("%8d = lwpid\n"
-		"%8d = lwp count\n"
-		"%8d = minor page faults\n"
-		"%8d = major page faults\n"
-		"%8d = input blocks\n"
-		"%8d = output blocks\n"
-		"%8d = messages sent\n"
-		"%8d = messages received\n"
-		"%8d = signals received\n"
-		"%8ds, %dms = wait-cpu (latency) time\n"		
-		"%8ds, %dms = user lock wait sleep time\n"
-		"%8ds, %dms = all other sleep time\n"
-		"%8d = voluntary context switches\n"
-		"%8d = involuntary context switches\n"
-		"%8d = system calls\n"
-		"%8d = chars read/written\n",
-		rusage.pr_lwpid,
-		rusage.pr_count,
-		rusage.pr_minf,
-		rusage.pr_majf,
-		rusage.pr_inblk,
-		rusage.pr_oublk,
-		rusage.pr_msnd,
-		rusage.pr_mrcv,
-		rusage.pr_sigs,
-		rusage.pr_wtime.tv_sec, rusage.pr_wtime.tv_nsec / 1000000,
-		rusage.pr_ltime.tv_sec, rusage.pr_ltime.tv_nsec / 1000000,
-		rusage.pr_slptime.tv_sec, rusage.pr_slptime.tv_nsec / 1000000,
-		rusage.pr_vctx,
-		rusage.pr_ictx,
-		rusage.pr_sysc,
-		rusage.pr_ioch);
-    }
-#endif /* ACE_HAS_PRUSAGE_T */
-
-  ACE_OS::printf ("---------------------\n"
-	    "real time   = %.3f\n"
-	    "user time   = %.3f\n"
-	    "system time = %.3f\n"
-	    "---------------------\n",
-	    et.real_time, et.user_time, et.system_time);
-}
-
-// Manages the options.
-Options options;
-
-void
-Options::parse_args (int argc, char *argv[])
-{
-  ACE_LOG_MSG->open (argv[0]);
-
-  ACE_Get_Opt getopt (argc, argv, "C:c:bdH:i:L:l:M:nS:s:t:T:v");
-  int c;
-
-  while ((c = getopt ()) != -1)
-    switch (c)
-      {
-      case 'b':
-	this->t_flags (THR_BOUND);
-	break;
-      case 'C':
-	this->consumer_file (getopt.optarg);
-	break;
-      case 'c':
-	this->consumer_port (getopt.optarg);
-	break;
-      case 'd':
-	this->debugging_ = 1;
-	break;
-      case 'H':
-	this->high_water_mark (ACE_OS::atoi (getopt.optarg));
-	break;
-      case 'i':
-	this->iterations (ACE_OS::atoi (getopt.optarg));
-	break;
-      case 'L':
-	this->low_water_mark (ACE_OS::atoi (getopt.optarg));
-	break;
-      case 'l':
-	this->initial_queue_length (ACE_OS::atoi (getopt.optarg));
-	break;
-      case 'M':
-	this->message_size (ACE_OS::atoi (getopt.optarg));
-	break;
-      case 'n':
-	this->t_flags (THR_NEW_LWP);
-	break;
-      case 'S':
-	this->supplier_file (getopt.optarg);
-	break;
-      case 's':
-	this->supplier_port (getopt.optarg);
-	break;
-      case 'T':
-	if (ACE_OS::strcasecmp (getopt.optarg, "ON") == 0)
-	  ACE_Trace::start_tracing ();
-	else if (ACE_OS::strcasecmp (getopt.optarg, "OFF") == 0)
-	  ACE_Trace::stop_tracing ();
-	break;
-      case 't':
-	this->thr_count (ACE_OS::atoi (getopt.optarg));
-	break;
-      case 'v':
-	this->verbosity_ = 1;
-	break;
-      default:
-	::fprintf (stderr, "%s\n"
-		   "\t[-b] (THR_BOUND)\n"
-		   "\t[-C consumer file]\n"
-		   "\t[-c consumer port]\n"
-		   "\t[-d] (enable debugging)\n"
-		   "\t[-H high water mark]\n"
-		   "\t[-i number of test iterations]\n"
-		   "\t[-L low water mark]\n"
-		   "\t[-M] message size \n" 
-		   "\t[-n] (THR_NEW_LWP)\n" 
-		   "\t[-q max queue size]\n"
-		   "\t[-S supplier file]\n"
-		   "\t[-s supplier port]\n"
-		   "\t[-t number of threads]\n"
-		   "\t[-v] (verbose) \n",
-		   argv[0]);
-	::exit (1);
-	/* NOTREACHED */
-	break;
-      }
-
-  if (this->verbose ())
-    ACE_OS::printf ("%8d = initial concurrency hint\n"
-	      "%8d = total iterations\n"
-	      "%8d = thread count\n"
-	      "%8d = low water mark\n"
-	      "%8d = high water mark\n"
-	      "%8d = message_size\n"
-	      "%8d = initial queue length\n"
-	      "%8d = THR_BOUND\n"
-	      "%8d = THR_NEW_LWP\n",
-	      ACE_OS::thr_getconcurrency (),
-	      this->iterations (),
-	      this->thr_count (),
-	      this->low_water_mark (),
-	      this->high_water_mark (),
-	      this->message_size (),
-	      this->initial_queue_length (),
-	      (this->t_flags () & THR_BOUND) != 0,
-	      (this->t_flags () & THR_NEW_LWP) != 0);
-}
-
-#endif /* ACE_HAS_THREADS */
diff --git a/examples/ASX/UPIPE_Event_Server/Options.h b/examples/ASX/UPIPE_Event_Server/Options.h
deleted file mode 100644
index fff2593e435..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Options.h
+++ /dev/null
@@ -1,83 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// Option manager for Event Server.
-
-#if !defined (DEVICE_OPTIONS_H)
-#define DEVICE_OPTIONS_H
-
-#include "ace/OS.h"
-#include "ace/Profile_Timer.h"
-
-#if defined (ACE_HAS_THREADS)
-
-class Options
-{
-public:
-  Options (void);
-  ~Options (void);
-  void parse_args (int argc, char *argv[]);
-
-  void   stop_timer (void);
-  void   start_timer (void);
-
-  void   thr_count (size_t count);
-  size_t thr_count (void);
-
-  void	 initial_queue_length (size_t length);
-  size_t initial_queue_length (void);
-
-  void   high_water_mark (size_t size);
-  size_t high_water_mark (void);
-
-  void   low_water_mark (size_t size);
-  size_t low_water_mark (void);
-
-  void	 message_size (size_t size);
-  size_t message_size (void);
-
-  void   iterations (size_t n);
-  size_t iterations (void);
-
-  void   t_flags (long flag);
-  long   t_flags (void);
-
-  void   supplier_port (char *port);
-  char   *supplier_port (void);
-
-  void   consumer_port (char *port);
-  char	 *consumer_port (void);
-
-  void   supplier_file (char *file);
-  char   *supplier_file (void);
-
-  void   consumer_file (char *file);
-  char	 *consumer_file (void);
-
-  int    debug (void);
-  int    verbose (void);
-
-  void   print_results (void);
-
-private:
-  ACE_Profile_Timer itimer_;	        // Time the process.
-  size_t	thr_count_;		// Number of threads to spawn.
-  long		t_flags_;		// Flags to thr_create().
-  size_t	high_water_mark_;	// ACE_Task high water mark.
-  size_t	low_water_mark_;        // ACE_Task low water mark.
-  size_t	message_size_;		// Size of a message.
-  size_t	initial_queue_length_;	// Initial number of items in the queue.
-  size_t	iterations_;		// Number of iterations to run the test program.
-  int		debugging_;		// Extra debugging info.
-  int		verbosity_;		// Extra verbose messages.
-  char		*consumer_port_;	// Port that the Consumer_Router is using.
-  char		*supplier_port_;	// Port that the Supplier_Router is using.
-  char		*consumer_file_;	// file that the Consumer_Router is using.
-  char		*supplier_file_;	// file that the Supplier_Router is using.
-};
-
-extern Options options;
-
-#include "Options.i"
-#endif /* ACE_HAS_THREADS */
-#endif /* DEVICE_OPTIONS_H */
diff --git a/examples/ASX/UPIPE_Event_Server/Options.i b/examples/ASX/UPIPE_Event_Server/Options.i
deleted file mode 100644
index 4641b301473..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Options.i
+++ /dev/null
@@ -1,161 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// Option manager for ustreams.
-
-inline void   
-Options::supplier_port (char *port)
-{
-  this->supplier_port_ = port;
-}
-
-inline char *
-Options::supplier_port (void)
-{
-  return this->supplier_port_;
-}
-
-inline void   
-Options::supplier_file (char *file)
-{
-  this->supplier_file_ = file;
-}
-
-inline char *
-Options::supplier_file (void)
-{
-  return this->supplier_file_;
-}
-
-inline void   
-Options::consumer_file (char *file)
-{
-  this->consumer_file_ = file;
-}
-
-inline char *
-Options::consumer_file (void)
-{
-  return this->consumer_file_;
-}
-
-inline void   
-Options::consumer_port (char *port)
-{
-  this->consumer_port_ = port;
-}
-
-inline char *
-Options::consumer_port (void)
-{
-  return this->consumer_port_;
-}
-
-inline void
-Options::start_timer (void)
-{
-  this->itimer_.start ();
-}
-
-inline void
-Options::stop_timer (void)
-{
-  this->itimer_.stop ();
-}
-
-inline void
-Options::thr_count (size_t count)
-{
-  this->thr_count_ = count;
-}
-
-inline size_t
-Options::thr_count (void)
-{
-  return this->thr_count_;
-}
-
-inline void 
-Options::initial_queue_length (size_t length)
-{
-  this->initial_queue_length_ = length;
-}
-
-inline size_t  
-Options::initial_queue_length (void)
-{
-  return this->initial_queue_length_;
-}
-
-inline void 
-Options::high_water_mark (size_t size)
-{
-  this->high_water_mark_ = size;
-}
-
-inline size_t  
-Options::high_water_mark (void)
-{
-  return this->high_water_mark_;
-}
-
-inline void 
-Options::low_water_mark (size_t size)
-{
-  this->low_water_mark_ = size;
-}
-
-inline size_t  
-Options::low_water_mark (void)
-{
-  return this->low_water_mark_;
-}
-
-inline void 
-Options::message_size (size_t size)
-{
-  this->message_size_ = size;
-}
-
-inline size_t  
-Options::message_size (void)
-{
-  return this->message_size_;
-}
-
-inline void 
-Options::iterations (size_t n)
-{
-  this->iterations_ = n;
-}
-
-inline size_t
-Options::iterations (void)
-{
-  return this->iterations_;
-}
-
-inline void 
-Options::t_flags (long flag)
-{
-  this->t_flags_ |= flag;
-}
-
-inline long
-Options::t_flags (void)
-{
-  return this->t_flags_;
-}
-
-inline int 
-Options::debug (void)
-{
-  return this->debugging_;
-}
-
-inline int 
-Options::verbose (void)
-{
-  return this->verbosity_;
-}
-
diff --git a/examples/ASX/UPIPE_Event_Server/Peer_Router.cpp b/examples/ASX/UPIPE_Event_Server/Peer_Router.cpp
deleted file mode 100644
index d87ed2b263f..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Peer_Router.cpp
+++ /dev/null
@@ -1,271 +0,0 @@
-#if !defined (_PEER_ROUTER_C)
-// $Id$
-
-#define _PEER_ROUTER_C
-
-#include "ace/Get_Opt.h"
-#include "ace/Service_Config.h"
-
-#include "Peer_Router.h"
-#include "Options.h"
-
-#if defined (ACE_HAS_THREADS)
-
-// Define some short-hand macros to deal with long templates
-// names... 
-
-#define PH  PEER_HANDLER
-#define PA  PEER_ACCEPTOR
-#define PAD PEER_ADDR
-#define PK  PEER_KEY
-#define PM  PEER_MAP
-
-template <class PH, class PK> int
-Acceptor_Factory<PH, PK>::init (int argc, char *argv[])
-{
-  ACE_Get_Opt get_opt (argc, argv, "df:", 0);
-  ACE_UPIPE_Addr addr;
-
-  for (int c; (c = get_opt ()) != -1; )
-     switch (c)
-       {
-       case 'f': 
-	 addr.set (get_opt.optarg);
-	 break;
-       case 'd':
-	 break;
-       default:
-	 break;
-       }
-  
-  if (this->open (addr, ACE_Reactor::instance ()) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1);
-  return 0;
-}
-
-template <class PH, class PK> 
-Acceptor_Factory<PH, PK>::Acceptor_Factory (Peer_Router<PH, PK> *pr)
-  : pr_ (pr) 
-{
-}
-
-template <class PH, class PK> Peer_Router<PH, PK> *
-Acceptor_Factory<PH, PK>::router (void)
-{ 
-  return this->pr_; 
-}
-
-template <class ROUTER, class KEY> 
-Peer_Handler<ROUTER, KEY>::Peer_Handler (ACE_Thread_Manager *tm)
-  : ACE_Svc_Handler<ACE_UPIPE_STREAM, ACE_MT_SYNCH> (tm)
-{
-}
-
-template <class ROUTER, class KEY> int
-Peer_Handler<ROUTER, KEY>::svc (void)
-{
-  // Just a try !!  we're just reading from our ACE_Message_Queue.
-  ACE_Message_Block *db, *hb;
-  int n;
-  // do an endless loop
-  for (;;)
-    {
-      db = new ACE_Message_Block (BUFSIZ);
-      hb = new ACE_Message_Block (sizeof (KEY), ACE_Message_Block::MB_PROTO, db);
-  
-      if ((n = this->peer ().recv (db->rd_ptr (), db->size ())) == -1)
-	ACE_ERROR_RETURN ((LM_ERROR, "%p", "recv failed"), -1);    
-      else if (n == 0) // Client has closed down the connection.
-	{
-
-	  if (this->router_task_->unbind_peer (this->get_handle ()) == -1)
-	    ACE_ERROR_RETURN ((LM_ERROR, "%p", "unbind failed"), -1);
-          ACE_DEBUG ((LM_DEBUG, "(%t) shutting down \n"));
-	  return -1; // We do not need to be deregistered by reactor
-	  // as we were not registered at all
-	}
-      else // Transform incoming buffer into a Message and pass downstream.
-	{
-	  db->wr_ptr (n);
-	  *(ACE_HANDLE *) hb->rd_ptr () = this->get_handle (); // structure assignment.
-	  hb->wr_ptr (sizeof (long));
-	  if (this->router_task_->reply (hb) == -1)
-	    {
-              ACE_DEBUG ((LM_DEBUG, "Peer_Handler.svc : router_task->reply failed\n"));
-	      return -1;
-	    }
-       
-          // return this->router_task_->reply (hb) == -1 ? -1 : 0;
-	}
-    }
-  ACE_NOTREACHED(return 0);
-}
-
-template <class ROUTER, class KEY> int
-Peer_Handler<ROUTER, KEY>::put (ACE_Message_Block *mb, ACE_Time_Value *)
-{
-  return this->peer ().send_n (mb->rd_ptr (), mb->length ());
-}
-
-// Create a new handler and point its ROUTER_TASK_ data member to the
-// corresponding router.  Note that this router is extracted out of
-// the Acceptor_Factory * that is passed in via the
-// ACE_Acceptor::handle_input() method.
-
-template <class ROUTER, class KEY> int
-Peer_Handler<ROUTER, KEY>::open (void *a)
-{
-  char buf[BUFSIZ], *p = buf;
-
-  if (this->router_task_->info (&p, sizeof buf) != -1)
-    ACE_DEBUG ((LM_DEBUG, "(%t) creating handler for %s, fd = %d, this = %d\n", 
-	       buf, this->get_handle (), a));
-  else
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "info"), -1);
-
-  if ( this->activate (options.t_flags ()) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "activation of thread failed"), -1);
-  else if (this->router_task_->bind_peer (this->get_handle (), this) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "bind_peer"), -1);
-  return 0;
-}
-
-// Receive a message from a supplier..
-
-template <class ROUTER, class KEY> int
-Peer_Handler<ROUTER, KEY>::handle_input (ACE_HANDLE h)
-{
-
-  ACE_DEBUG ((LM_DEBUG, "(%t) input arrived on sd %d\n", h));
-//  ACE_Reactor::instance ()->remove_handler(h,
-//                                          ACE_Event_Handler::ALL_EVENTS_MASK
-//                                          |ACE_Event_Handler::DONT_CALL);
-// this method should be called only if the peer shuts down
-// so we deactivate our ACE_Message_Queue to awake our svc thread
-
-  return 0;
-
-#if 0
-  ACE_Message_Block *db = new ACE_Message_Block (BUFSIZ);
-  ACE_Message_Block *hb = new ACE_Message_Block (sizeof (KEY), ACE_Message_Block::MB_PROTO, db);
-  int           n;
-
-  if ((n = this->peer ().recv (db->rd_ptr (), db->size ())) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p", "recv failed"), -1);    
-  else if (n == 0) // Client has closed down the connection.
-    {
-      if (this->router_task_->unbind_peer (this->get_handle ()) == -1)
-	ACE_ERROR_RETURN ((LM_ERROR, "%p", "unbind failed"), -1);
-      ACE_DEBUG ((LM_DEBUG, "(%t) shutting down %d\n", h));
-      return -1; // Instruct the ACE_Reactor to deregister us by returning -1.
-    }
-  else // Transform incoming buffer into a Message and pass downstream.
-    {
-      db->wr_ptr (n);
-      *(long *) hb->rd_ptr () = this->get_handle (); // structure assignment.
-      hb->wr_ptr (sizeof (long));
-      return this->router_task_->reply (hb) == -1 ? -1 : 0;
-    }
-#endif 
-}
-
-template <class PH, class PK>
-Peer_Router<PH, PK>::Peer_Router (ACE_Thread_Manager *tm)
-  : ACE_Task<ACE_MT_SYNCH> (tm)
-{
-}
-
-template <class PH, class PK> int
-Peer_Router<PH, PK>::send_peers (ACE_Message_Block *mb)
-{
-  ACE_Map_Iterator<PK, PH *, ACE_RW_Mutex> map_iter = this->peer_map_;
-  int		 bytes       = 0;
-  int		 iterations  = 0;
-  ACE_Message_Block	 *data_block = mb->cont ();
-  for (ACE_Map_Entry<PK, PH *> *ss = 0;
-       map_iter.next (ss) != 0;
-       map_iter.advance ())
-    {
-      if (options.debug ())
-	ACE_DEBUG ((LM_DEBUG, "(%t) sending to peer via sd %d\n", ss->ext_id_));
-
-      iterations++;
-      bytes += ss->int_id_->put (data_block);
-    }
-
-  mb->release ();
-  return bytes == 0 ? 0 : bytes / iterations;
-}
-
-template <class PH, class PK>
-Peer_Router<PH, PK>::~Peer_Router (void)
-{
-}
-
-template <class PH, class PK> int
-Peer_Router<PH, PK>::fini (void)
-{
-  delete this->acceptor_;
-  return 0;
-}
-
-template <class PH, class PK> int
-Peer_Router<PH, PK>::control (ACE_Message_Block *mb)
-{
-  ACE_IO_Cntl_Msg *ioc = (ACE_IO_Cntl_Msg *) mb->rd_ptr ();
-  ACE_IO_Cntl_Msg::ACE_IO_Cntl_Cmds command;
-
-  switch (command = ioc->cmd ())
-    {
-    case ACE_IO_Cntl_Msg::SET_LWM:
-    case ACE_IO_Cntl_Msg::SET_HWM:
-      this->water_marks (command, *(size_t *) mb->cont ()->rd_ptr ());
-      break;
-    default:
-      return -1;
-    }
-  return 0;
-}
-
-template <class PH, class PK> int
-Peer_Router<PH, PK>::unbind_peer (PK key)
-{
-  return this->peer_map_.unbind (key);
-}
-
-template <class PH, class PK> int
-Peer_Router<PH, PK>::bind_peer (PK key, Peer_Handler<Peer_Router<PH, PK>, PK> *ph)
-{
-  PH *peer_handler = (PH *) ph;
-  return this->peer_map_.bind (key, peer_handler);
-}
-
-template <class PH, class PK> int 
-Peer_Router<PH, PK>::init (int argc, char *argv[])
-{
-  this->acceptor_ = new Acceptor_Factory <PH, PK> (this);
-
-  if (this->acceptor_->init (argc, argv) == -1
-      || this->peer_map_.open () == -1)
-    return -1;
-  else
-    {
-      ACE_UPIPE_Addr addr;
-      ACE_UPIPE_Acceptor &pa = this->acceptor_->acceptor ();
-      
-      if (pa.get_local_addr (addr) != -1)
-	ACE_DEBUG ((LM_DEBUG, "(%t) initializing %s, file = %s, fd = %d, this = %u\n", 
-		   this->name (), addr.get_path_name (), pa.get_handle (), this));
-      else
-	ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "get_local_addr"), -1);
-    }
-  return 0;
-}
-
-#undef PH
-#undef PA
-#undef PAD
-#undef PK
-#undef PM
-#endif /* ACE_HAS_THREADS */
-#endif /* _PEER_ROUTER_C */
diff --git a/examples/ASX/UPIPE_Event_Server/Peer_Router.h b/examples/ASX/UPIPE_Event_Server/Peer_Router.h
deleted file mode 100644
index c60da36c931..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Peer_Router.h
+++ /dev/null
@@ -1,116 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// The interface between one or more peers and a stream.  A peer
-// typically runs remotely on another machine.
-
-#if !defined (_PEER_ROUTER_H)
-#define _PEER_ROUTER_H
-
-#include "ace/Acceptor.h"
-#include "ace/Svc_Handler.h"
-#include "ace/UPIPE_Acceptor.h"
-#include "ace/UPIPE_Addr.h"
-#include "ace/Thread_Manager.h"
-#include "ace/Map_Manager.h"
-
-#if defined (ACE_HAS_THREADS)
-
-// Forward declaration.
-template <class PEER_HANDLER, class KEY>
-class Peer_Router;
-
-template <class PEER_HANDLER, class KEY> 
-class Acceptor_Factory : public ACE_Acceptor<PEER_HANDLER, ACE_UPIPE_ACCEPTOR>
-{
-public:
-  Acceptor_Factory (Peer_Router<PEER_HANDLER, KEY> *pr);
-  Peer_Router<PEER_HANDLER, KEY> *router (void);
-
-  int init (int argc, char *argv[]);
-  // Initialize the acceptor when it's linked dynamically.
-
-private:
-  Peer_Router<PEER_HANDLER, KEY> *pr_;
-};
-
-// Receive input from a Peer..
-template <class ROUTER, class KEY>
-class Peer_Handler : public ACE_Svc_Handler<ACE_UPIPE_STREAM, ACE_MT_SYNCH>
-{
-public:
-  Peer_Handler (ACE_Thread_Manager * = 0);
-
-  virtual int open (void * = 0);
-  // Called by the ACE_Acceptor::handle_input() to activate this object.
-
-  virtual int handle_input (ACE_HANDLE);
-  // Receive input from the peer..
-
-  virtual int put (ACE_Message_Block *, ACE_Time_Value *tv = 0);  
-  // Send output to a peer. 
-
-protected:
-  ROUTER *router_task_;  
-  // Pointer to write task..
-
-private:
-  // Don't need this method here...
-  virtual int svc (void);
-};
-
-// This abstract base class provides mechanisms for routing messages
-// to/from a ACE_Stream from/to one or more peers (which are typically
-// running on remote hosts).  A subclass of Peer_Router overrides the
-// open(), close(), and put() methods in order to specialize the
-// behavior of the router to meet application-specific requirements.
-
-template <class PEER_HANDLER, class PEER_KEY>
-class Peer_Router : public ACE_Task<ACE_MT_SYNCH>
-{
-public:
-  Peer_Router (ACE_Thread_Manager * = 0);
-  ~Peer_Router (void);
-
-  typedef Peer_Handler<Peer_Router<PEER_HANDLER, PEER_KEY>, PEER_KEY> HANDLER;
-
-  // Remove a PEER_HANDLER from the PEER_MAP.
-  virtual int unbind_peer (PEER_KEY);
-
-  // Add a PEER_HANDLER to the PEER_MAP.
-  virtual int bind_peer (PEER_KEY, HANDLER *);
-
-  // Send the message block to the peer(s)..
-  int send_peers (ACE_Message_Block *mb);
-
-protected:
-// Handle control messages arriving from adjacent Modules.
-  virtual int control (ACE_Message_Block *); 
-
-  // Map used to keep track of active peers.
-  ACE_Map_Manager <PEER_KEY, PEER_HANDLER *, ACE_RW_Mutex> peer_map_;
-
-  // Dynamic linking initialization hooks inherited from ACE_Task.
-  virtual int init (int argc, char *argv[]);
-  virtual int fini (void);
-
-  // Factory for accepting new PEER_HANDLERs.
-  Acceptor_Factory<PEER_HANDLER, PEER_KEY> *acceptor_;
-
-private:
-// Prevent copies and pass-by-value.
-  ACE_UNIMPLEMENTED_FUNC (Peer_Router (const Peer_Router<PEER_HANDLER, PEER_KEY> &))
-  ACE_UNIMPLEMENTED_FUNC (void operator= (const Peer_Router<PEER_HANDLER, PEER_KEY> &))
-};
-
-#if defined (__ACE_INLINE__)
-#define ACE_INLINE inline
-#else
-#define ACE_INLINE 
-#endif /* __ACE_INLINE__ */
-
-#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
-#include "Peer_Router.cpp"
-#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */
-#endif /* ACE_HAS_THREADS */
-#endif /* _PEER_ROUTER_H */
diff --git a/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp b/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp
deleted file mode 100644
index b12f30a411f..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Supplier_Router.cpp
+++ /dev/null
@@ -1,158 +0,0 @@
-// $Id$
-
-#include "Options.h"
-#include "Supplier_Router.h"
-
-#if defined (ACE_HAS_THREADS)
-
-typedef Acceptor_Factory<Supplier_Handler, SUPPLIER_KEY> SUPPLIER_FACTORY;
-
-int
-Supplier_Handler::open (void *a)
-{
-  SUPPLIER_FACTORY *af = (SUPPLIER_FACTORY *) a;
-  this->router_task_ = af->router ();
-  return this->Peer_Handler<SUPPLIER_ROUTER, SUPPLIER_KEY>::open (a);
-}
-
-Supplier_Handler::Supplier_Handler (ACE_Thread_Manager *tm)
-  : Peer_Handler<SUPPLIER_ROUTER, SUPPLIER_KEY> (tm)
-{
-}
-
-// Create a new router and associate it with the REACTOR parameter..
-
-Supplier_Router::Supplier_Router (ACE_Thread_Manager *tm)
-  : SUPPLIER_ROUTER (tm)
-{
-}
-
-// Handle incoming messages in a separate thread..
-
-int
-Supplier_Router::svc (void)
-{
-  ACE_ASSERT (this->is_writer ());
-
-  ACE_Message_Block *message_block = 0;
-
-  if (options.debug ())
-    ACE_DEBUG ((LM_DEBUG, "(%t) starting svc in %s\n", this->name ()));
-
-  while (this->getq (message_block) > 0)
-  {
-    if (this->put_next (message_block) == -1)
-      ACE_ERROR_RETURN ((LM_ERROR, "(%t) put_next failed in %s\n", this->name ()), -1);
-  }
-
-  return 0;
-}
-
-// Initialize the Router..
-
-int
-Supplier_Router::open (void *)
-{
-  ACE_ASSERT (this->is_writer ());
-  char *argv[3];
-
-  argv[0] = (char *) this->name ();
-  argv[1] = options.supplier_file ();
-  argv[2] = 0;
-
-  if (this->init (1, &argv[1]) == -1)
-    return -1;
-
-  // Make this an active object.
-  //   return this->activate (options.t_flags ());
-
-  // Until that's done, return 1 to indicate that the object wasn't activated.
-  return 1;
-}
-
-// Close down the router..
-
-int
-Supplier_Router::close (u_long)
-{
-  ACE_ASSERT (this->is_writer ());
-  this->peer_map_.close ();
-  this->msg_queue ()->deactivate();
-  return 0;
-}
-
-// Send a MESSAGE_BLOCK to the supplier(s)..
-
-int
-Supplier_Router::put (ACE_Message_Block *mb, ACE_Time_Value *)
-{
-  ACE_ASSERT (this->is_writer ());
-
-  if (mb->msg_type () == ACE_Message_Block::MB_IOCTL)
-    {
-      this->control (mb);
-      return this->put_next (mb);
-    }
-  else
-    {
-//printf("supplier-Router is routing: send_peers\n");
-      return this->send_peers (mb);
-    }
-}
-
-// Return information about the Supplier_Router ACE_Module..
-
-int
-Supplier_Router::info (char **strp, size_t length) const
-{
-  char       buf[BUFSIZ];
-  ACE_UPIPE_Addr  addr;
-  const char *mod_name = this->name ();
-  ACE_UPIPE_Acceptor &sa = (ACE_UPIPE_Acceptor &) *this->acceptor_;
-
-  if (sa.get_local_addr (addr) == -1)
-    return -1;
-
-  ACE_OS::sprintf (buf, "%s\t %s/ %s",
-	     mod_name,  "upipe",
-	     "# supplier router\n");
-
-  if (*strp == 0 && (*strp = ACE_OS::strdup (mod_name)) == 0)
-    return -1;
-  else
-    ACE_OS::strncpy (*strp, mod_name, length);
-  return ACE_OS::strlen (mod_name);
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class Acceptor_Factory<Supplier_Handler, SUPPLIER_KEY>;
-template class ACE_Acceptor<Supplier_Handler, ACE_UPIPE_ACCEPTOR>;
-template class ACE_Svc_Handler<ACE_UPIPE_STREAM, ACE_MT_SYNCH>;
-template class Peer_Handler<SUPPLIER_ROUTER, SUPPLIER_KEY>;
-template class Peer_Router<Supplier_Handler, SUPPLIER_KEY>;
-template class ACE_Map_Entry<SUPPLIER_KEY, Supplier_Handler *>;
-template class ACE_Map_Iterator_Base<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>;
-template class ACE_Map_Iterator<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>;
-template class ACE_Map_Reverse_Iterator<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>;
-template class ACE_Map_Manager<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>;
-template class ACE_Read_Guard<ACE_RW_Mutex>;
-template class ACE_Write_Guard<ACE_RW_Mutex>;
-template class ACE_Guard<ACE_RW_Mutex>;
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate Acceptor_Factory<Supplier_Handler, SUPPLIER_KEY>
-#pragma instantiate ACE_Acceptor<Supplier_Handler, ACE_UPIPE_ACCEPTOR>
-#pragma instantiate ACE_Svc_Handler<ACE_UPIPE_STREAM, ACE_MT_SYNCH>
-#pragma instantiate Peer_Handler<SUPPLIER_ROUTER, SUPPLIER_KEY>
-#pragma instantiate Peer_Router<Supplier_Handler, SUPPLIER_KEY>
-#pragma instantiate ACE_Map_Entry<SUPPLIER_KEY, Supplier_Handler *>
-#pragma instantiate ACE_Map_Iterator_Base<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Map_Iterator<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Map_Reverse_Iterator<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Map_Manager<SUPPLIER_KEY, Supplier_Handler *, ACE_RW_Mutex>
-#pragma instantiate ACE_Read_Guard<ACE_RW_Mutex>
-#pragma instantiate ACE_Write_Guard<ACE_RW_Mutex>
-#pragma instantiate ACE_Guard<ACE_RW_Mutex>
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
-
-
-#endif /* ACE_HAS_THREADS */
diff --git a/examples/ASX/UPIPE_Event_Server/Supplier_Router.h b/examples/ASX/UPIPE_Event_Server/Supplier_Router.h
deleted file mode 100644
index 0fcb72f4c20..00000000000
--- a/examples/ASX/UPIPE_Event_Server/Supplier_Router.h
+++ /dev/null
@@ -1,52 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// The interface between a supplier and an Event Service ACE_Stream.
-
-#if !defined (_SUPPLIER_ROUTER_H)
-#define _SUPPLIER_ROUTER_H
-
-#include "ace/UPIPE_Addr.h"
-#include "ace/UPIPE_Acceptor.h"
-#include "ace/Map_Manager.h"
-#include "ace/Svc_Handler.h"
-#include "Peer_Router.h"
-
-#if defined (ACE_HAS_THREADS)
-
-// Forward declaration.
-class Supplier_Handler; 
-
-// Type of search key for SUPPLIER_MAP.
-typedef ACE_HANDLE SUPPLIER_KEY;
-
-// Instantiated type for routing messages to suppliers.
-
-typedef Peer_Router<Supplier_Handler, SUPPLIER_KEY> SUPPLIER_ROUTER;
-
-class Supplier_Handler 
-  : public Peer_Handler<SUPPLIER_ROUTER, SUPPLIER_KEY>
-{
-public:
-  Supplier_Handler (ACE_Thread_Manager *tm = 0);
-  virtual int open (void *);
-};
-
-class Supplier_Router : public SUPPLIER_ROUTER
-{
-public:
-  Supplier_Router (ACE_Thread_Manager *);
-
-protected:
-  // ACE_Task hooks..
-  virtual int open (void *a = 0);
-  virtual int close (u_long flags = 0);
-  virtual int put (ACE_Message_Block *msg, ACE_Time_Value * = 0);
-  virtual int svc (void);
-
-  // Dynamic linking hooks inherited from Peer_Router.
-  virtual int info (char **info_string, size_t length) const;
-};
-
-#endif /* ACE_HAS_THREADS */
-#endif /* _SUPPLIER_ROUTER_H */
diff --git a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.dsp b/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.dsp
deleted file mode 100644
index 2d3ef985f31..00000000000
--- a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.dsp
+++ /dev/null
@@ -1,115 +0,0 @@
-# Microsoft Developer Studio Project File - Name="UPIPE_Event_Server" - Package Owner=<4>
-# Microsoft Developer Studio Generated Build File, Format Version 5.00
-# ** DO NOT EDIT **
-
-# TARGTYPE "Win32 (x86) Console Application" 0x0103
-
-CFG=UPIPE_Event_Server - Win32 Debug
-!MESSAGE This is not a valid makefile. To build this project using NMAKE,
-!MESSAGE use the Export Makefile command and run
-!MESSAGE 
-!MESSAGE NMAKE /f "UPIPE_Event_Server.mak".
-!MESSAGE 
-!MESSAGE You can specify a configuration when running NMAKE
-!MESSAGE by defining the macro CFG on the command line. For example:
-!MESSAGE 
-!MESSAGE NMAKE /f "UPIPE_Event_Server.mak"\
- CFG="UPIPE_Event_Server - Win32 Debug"
-!MESSAGE 
-!MESSAGE Possible choices for configuration are:
-!MESSAGE 
-!MESSAGE "UPIPE_Event_Server - Win32 Debug" (based on\
- "Win32 (x86) Console Application")
-!MESSAGE 
-
-# Begin Project
-# PROP Scc_ProjName ""
-# PROP Scc_LocalPath ""
-CPP=cl.exe
-RSC=rc.exe
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 1
-# PROP BASE Output_Dir ".\Debug"
-# PROP BASE Intermediate_Dir ".\Debug"
-# PROP BASE Target_Dir ""
-# PROP Use_MFC 0
-# PROP Use_Debug_Libraries 1
-# PROP Output_Dir "."
-# PROP Intermediate_Dir ".\Debug"
-# PROP Ignore_Export_Lib 0
-# PROP Target_Dir ""
-# ADD BASE CPP /nologo /W3 /Gm /GX /Zi /Od /D "WIN32" /D "_DEBUG" /D "_CONSOLE" /YX /c
-# ADD CPP /nologo /MDd /W3 /Gm /GX /Zi /Od /I "..\..\..\\" /D "WIN32" /D "_DEBUG" /D "_CONSOLE" /YX /FD /c
-# ADD BASE RSC /l 0x409 /d "_DEBUG"
-# ADD RSC /l 0x409 /d "_DEBUG"
-BSC32=bscmake.exe
-# ADD BASE BSC32 /nologo
-# ADD BSC32 /nologo
-LINK32=link.exe
-# ADD BASE LINK32 kernel32.lib user32.lib gdi32.lib winspool.lib comdlg32.lib advapi32.lib shell32.lib ole32.lib oleaut32.lib uuid.lib odbc32.lib odbccp32.lib /nologo /subsystem:console /debug /machine:I386
-# ADD LINK32 aced.lib /nologo /subsystem:console /debug /machine:I386 /libpath:"..\..\..\ace"
-# Begin Target
-
-# Name "UPIPE_Event_Server - Win32 Debug"
-# Begin Group "Source Files"
-
-# PROP Default_Filter "cpp;c;cxx;rc;def;r;odl;hpj;bat;for;f90"
-# Begin Source File
-
-SOURCE=.\Consumer_Router.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_Analyzer.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\event_server.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Options.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Peer_Router.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Supplier_Router.cpp
-# End Source File
-# End Group
-# Begin Group "Header Files"
-
-# PROP Default_Filter "h;hpp;hxx;hm;inl;fi;fd"
-# Begin Source File
-
-SOURCE=.\Consumer_Router.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_Analyzer.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Options.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Peer_Router.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Supplier_Router.h
-# End Source File
-# End Group
-# Begin Group "Resource Files"
-
-# PROP Default_Filter "ico;cur;bmp;dlg;rc2;rct;bin;cnt;rtf;gif;jpg;jpeg;jpe"
-# End Group
-# Begin Source File
-
-SOURCE=.\Options.i
-# End Source File
-# End Target
-# End Project
diff --git a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.dsw b/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.dsw
deleted file mode 100644
index 0f79b50ee9d..00000000000
--- a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.dsw
+++ /dev/null
@@ -1,29 +0,0 @@
-Microsoft Developer Studio Workspace File, Format Version 5.00
-# WARNING: DO NOT EDIT OR DELETE THIS WORKSPACE FILE!
-
-###############################################################################
-
-Project: "UPIPE_Event_Server"=.\UPIPE_Event_Server.dsp - Package Owner=<4>
-
-Package=<5>
-{{{
-}}}
-
-Package=<4>
-{{{
-}}}
-
-###############################################################################
-
-Global:
-
-Package=<5>
-{{{
-}}}
-
-Package=<3>
-{{{
-}}}
-
-###############################################################################
-
diff --git a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.mak b/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.mak
deleted file mode 100644
index 648fefb06c2..00000000000
--- a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.mak
+++ /dev/null
@@ -1,1034 +0,0 @@
-# Microsoft Developer Studio Generated NMAKE File, Format Version 4.20
-# ** DO NOT EDIT **
-
-# TARGTYPE "Win32 (x86) Console Application" 0x0103
-
-!IF "$(CFG)" == ""
-CFG=UPIPE_Event_Server - Win32 Debug
-!MESSAGE No configuration specified.  Defaulting to UPIPE_Event_Server - Win32\
- Debug.
-!ENDIF 
-
-!IF "$(CFG)" != "UPIPE_Event_Server - Win32 Debug"
-!MESSAGE Invalid configuration "$(CFG)" specified.
-!MESSAGE You can specify a configuration when running NMAKE on this makefile
-!MESSAGE by defining the macro CFG on the command line.  For example:
-!MESSAGE 
-!MESSAGE NMAKE /f "UPIPE_Event_Server.mak"\
- CFG="UPIPE_Event_Server - Win32 Debug"
-!MESSAGE 
-!MESSAGE Possible choices for configuration are:
-!MESSAGE 
-!MESSAGE "UPIPE_Event_Server - Win32 Debug" (based on\
- "Win32 (x86) Console Application")
-!MESSAGE 
-!ERROR An invalid configuration is specified.
-!ENDIF 
-
-!IF "$(OS)" == "Windows_NT"
-NULL=
-!ELSE 
-NULL=nul
-!ENDIF 
-################################################################################
-# Begin Project
-# PROP Target_Last_Scanned "UPIPE_Event_Server - Win32 Debug"
-RSC=rc.exe
-CPP=cl.exe
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 1
-# PROP BASE Output_Dir "Debug"
-# PROP BASE Intermediate_Dir "Debug"
-# PROP BASE Target_Dir ""
-# PROP Use_MFC 0
-# PROP Use_Debug_Libraries 1
-# PROP Output_Dir "."
-# PROP Intermediate_Dir "Debug"
-# PROP Target_Dir ""
-OUTDIR=.\.
-INTDIR=.\Debug
-
-ALL : "$(OUTDIR)\UPIPE_Event_Server.exe"
-
-CLEAN : 
-	-@erase "$(INTDIR)\Consumer_Router.obj"
-	-@erase "$(INTDIR)\Event_Analyzer.obj"
-	-@erase "$(INTDIR)\event_server.obj"
-	-@erase "$(INTDIR)\Options.obj"
-	-@erase "$(INTDIR)\Peer_Router.obj"
-	-@erase "$(INTDIR)\Supplier_Router.obj"
-	-@erase "$(INTDIR)\vc40.idb"
-	-@erase "$(INTDIR)\vc40.pdb"
-	-@erase "$(OUTDIR)\UPIPE_Event_Server.exe"
-	-@erase "$(OUTDIR)\UPIPE_Event_Server.ilk"
-	-@erase "$(OUTDIR)\UPIPE_Event_Server.pdb"
-
-"$(OUTDIR)" :
-    if not exist "$(OUTDIR)/$(NULL)" mkdir "$(OUTDIR)"
-
-"$(INTDIR)" :
-    if not exist "$(INTDIR)/$(NULL)" mkdir "$(INTDIR)"
-
-# ADD BASE CPP /nologo /W3 /Gm /GX /Zi /Od /D "WIN32" /D "_DEBUG" /D "_CONSOLE" /YX /c
-# ADD CPP /nologo /MDd /W3 /Gm /GX /Zi /Od /D "WIN32" /D "_DEBUG" /D "_CONSOLE" /YX /c
-# ADD BASE RSC /l 0x409 /d "_DEBUG"
-# ADD RSC /l 0x409 /d "_DEBUG"
-BSC32=bscmake.exe
-# ADD BASE BSC32 /nologo
-# ADD BSC32 /nologo
-BSC32_FLAGS=/nologo /o"$(OUTDIR)/UPIPE_Event_Server.bsc" 
-BSC32_SBRS= \
-	
-LINK32=link.exe
-# ADD BASE LINK32 kernel32.lib user32.lib gdi32.lib winspool.lib comdlg32.lib advapi32.lib shell32.lib ole32.lib oleaut32.lib uuid.lib odbc32.lib odbccp32.lib /nologo /subsystem:console /debug /machine:I386
-# ADD LINK32 aced.lib kernel32.lib user32.lib gdi32.lib winspool.lib comdlg32.lib advapi32.lib shell32.lib ole32.lib oleaut32.lib uuid.lib odbc32.lib odbccp32.lib /nologo /subsystem:console /debug /machine:I386
-LINK32_FLAGS=aced.lib kernel32.lib user32.lib gdi32.lib winspool.lib\
- comdlg32.lib advapi32.lib shell32.lib ole32.lib oleaut32.lib uuid.lib\
- odbc32.lib odbccp32.lib /nologo /subsystem:console /incremental:yes\
- /pdb:"$(OUTDIR)/UPIPE_Event_Server.pdb" /debug /machine:I386\
- /out:"$(OUTDIR)/UPIPE_Event_Server.exe" 
-LINK32_OBJS= \
-	"$(INTDIR)\Consumer_Router.obj" \
-	"$(INTDIR)\Event_Analyzer.obj" \
-	"$(INTDIR)\event_server.obj" \
-	"$(INTDIR)\Options.obj" \
-	"$(INTDIR)\Peer_Router.obj" \
-	"$(INTDIR)\Supplier_Router.obj"
-
-"$(OUTDIR)\UPIPE_Event_Server.exe" : "$(OUTDIR)" $(DEF_FILE) $(LINK32_OBJS)
-    $(LINK32) @<<
-  $(LINK32_FLAGS) $(LINK32_OBJS)
-<<
-
-CPP_PROJ=/nologo /MDd /W3 /Gm /GX /Zi /Od /D "WIN32" /D "_DEBUG" /D "_CONSOLE"\
- /Fp"$(INTDIR)/UPIPE_Event_Server.pch" /YX /Fo"$(INTDIR)/" /Fd"$(INTDIR)/" /c 
-CPP_OBJS=.\Debug/
-CPP_SBRS=.\.
-
-.c{$(CPP_OBJS)}.obj:
-   $(CPP) $(CPP_PROJ) $<  
-
-.cpp{$(CPP_OBJS)}.obj:
-   $(CPP) $(CPP_PROJ) $<  
-
-.cxx{$(CPP_OBJS)}.obj:
-   $(CPP) $(CPP_PROJ) $<  
-
-.c{$(CPP_SBRS)}.sbr:
-   $(CPP) $(CPP_PROJ) $<  
-
-.cpp{$(CPP_SBRS)}.sbr:
-   $(CPP) $(CPP_PROJ) $<  
-
-.cxx{$(CPP_SBRS)}.sbr:
-   $(CPP) $(CPP_PROJ) $<  
-
-################################################################################
-# Begin Target
-
-# Name "UPIPE_Event_Server - Win32 Debug"
-################################################################################
-# Begin Source File
-
-SOURCE=.\Supplier_Router.cpp
-DEP_CPP_SUPPL=\
-	"..\..\..\ace\config-win32.h"\
-	".\Options.h"\
-	".\Options.i"\
-	".\Peer_Router.cpp"\
-	".\Peer_Router.h"\
-	".\Supplier_Router.h"\
-	{$(INCLUDE)}"\ace\Acceptor.cpp"\
-	{$(INCLUDE)}"\ace\Acceptor.h"\
-	{$(INCLUDE)}"\ace\Acceptor.i"\
-	{$(INCLUDE)}"\ace\ACE.h"\
-	{$(INCLUDE)}"\ace\ACE.i"\
-	{$(INCLUDE)}"\ace\Addr.h"\
-	{$(INCLUDE)}"\ace\Addr.i"\
-	{$(INCLUDE)}"\ace\Asynch_IO.h"\
-	{$(INCLUDE)}"\ace\Asynch_IO.i"\
-	{$(INCLUDE)}"\ace\Atomic_Op.i"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.cpp"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.h"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.i"\
-	{$(INCLUDE)}"\ace\config-win32-common.h"\
-	{$(INCLUDE)}"\ace\config.h"\
-	{$(INCLUDE)}"\ace\Containers.cpp"\
-	{$(INCLUDE)}"\ace\Containers.h"\
-	{$(INCLUDE)}"\ace\Containers.i"\
-	{$(INCLUDE)}"\ace\Dynamic.h"\
-	{$(INCLUDE)}"\ace\Dynamic.i"\
-	{$(INCLUDE)}"\ace\Event_Handler.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.i"\
-	{$(INCLUDE)}"\ace\Free_List.cpp"\
-	{$(INCLUDE)}"\ace\Free_List.h"\
-	{$(INCLUDE)}"\ace\Free_List.i"\
-	{$(INCLUDE)}"\ace\Get_Opt.h"\
-	{$(INCLUDE)}"\ace\Get_Opt.i"\
-	{$(INCLUDE)}"\ace\Handle_Set.h"\
-	{$(INCLUDE)}"\ace\Handle_Set.i"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.i"\
-	{$(INCLUDE)}"\ace\INET_Addr.h"\
-	{$(INCLUDE)}"\ace\INET_Addr.i"\
-	{$(INCLUDE)}"\ace\IO_Cntl_Msg.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.i"\
-	{$(INCLUDE)}"\ace\Local_Tokens.h"\
-	{$(INCLUDE)}"\ace\Local_Tokens.i"\
-	{$(INCLUDE)}"\ace\Log_Msg.h"\
-	{$(INCLUDE)}"\ace\Log_Priority.h"\
-	{$(INCLUDE)}"\ace\Log_Record.h"\
-	{$(INCLUDE)}"\ace\Log_Record.i"\
-	{$(INCLUDE)}"\ace\Malloc.h"\
-	{$(INCLUDE)}"\ace\Malloc.i"\
-	{$(INCLUDE)}"\ace\Malloc_T.cpp"\
-	{$(INCLUDE)}"\ace\Malloc_T.h"\
-	{$(INCLUDE)}"\ace\Malloc_T.i"\
-	{$(INCLUDE)}"\ace\Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Map_Manager.h"\
-	{$(INCLUDE)}"\ace\Map_Manager.i"\
-	{$(INCLUDE)}"\ace\Mem_Map.h"\
-	{$(INCLUDE)}"\ace\Mem_Map.i"\
-	{$(INCLUDE)}"\ace\Memory_Pool.h"\
-	{$(INCLUDE)}"\ace\Memory_Pool.i"\
-	{$(INCLUDE)}"\ace\Message_Block.h"\
-	{$(INCLUDE)}"\ace\Message_Block.i"\
-	{$(INCLUDE)}"\ace\Message_Queue.cpp"\
-	{$(INCLUDE)}"\ace\Message_Queue.h"\
-	{$(INCLUDE)}"\ace\Message_Queue.i"\
-	{$(INCLUDE)}"\ace\Module.cpp"\
-	{$(INCLUDE)}"\ace\Module.h"\
-	{$(INCLUDE)}"\ace\Module.i"\
-	{$(INCLUDE)}"\ace\Object_Manager.h"\
-	{$(INCLUDE)}"\ace\Object_Manager.i"\
-	{$(INCLUDE)}"\ace\OS.h"\
-	{$(INCLUDE)}"\ace\OS.i"\
-	{$(INCLUDE)}"\ace\Pipe.h"\
-	{$(INCLUDE)}"\ace\Pipe.i"\
-	{$(INCLUDE)}"\ace\Proactor.h"\
-	{$(INCLUDE)}"\ace\Proactor.i"\
-	{$(INCLUDE)}"\ace\Profile_Timer.h"\
-	{$(INCLUDE)}"\ace\Profile_Timer.i"\
-	{$(INCLUDE)}"\ace\Reactor.h"\
-	{$(INCLUDE)}"\ace\Reactor.i"\
-	{$(INCLUDE)}"\ace\ReactorEx.h"\
-	{$(INCLUDE)}"\ace\ReactorEx.i"\
-	{$(INCLUDE)}"\ace\Service_Config.h"\
-	{$(INCLUDE)}"\ace\Service_Config.i"\
-	{$(INCLUDE)}"\ace\Service_Object.h"\
-	{$(INCLUDE)}"\ace\Service_Object.i"\
-	{$(INCLUDE)}"\ace\Shared_Object.h"\
-	{$(INCLUDE)}"\ace\Shared_Object.i"\
-	{$(INCLUDE)}"\ace\Signal.h"\
-	{$(INCLUDE)}"\ace\Signal.i"\
-	{$(INCLUDE)}"\ace\SOCK.h"\
-	{$(INCLUDE)}"\ace\SOCK.i"\
-	{$(INCLUDE)}"\ace\SOCK_IO.h"\
-	{$(INCLUDE)}"\ace\SOCK_IO.i"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.h"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.i"\
-	{$(INCLUDE)}"\ace\SPIPE.h"\
-	{$(INCLUDE)}"\ace\SPIPE.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\SString.h"\
-	{$(INCLUDE)}"\ace\SString.i"\
-	{$(INCLUDE)}"\ace\stdcpp.h"\
-	{$(INCLUDE)}"\ace\Strategies.h"\
-	{$(INCLUDE)}"\ace\Strategies_T.cpp"\
-	{$(INCLUDE)}"\ace\Strategies_T.h"\
-	{$(INCLUDE)}"\ace\Stream.cpp"\
-	{$(INCLUDE)}"\ace\Stream.h"\
-	{$(INCLUDE)}"\ace\Stream.i"\
-	{$(INCLUDE)}"\ace\Stream_Modules.cpp"\
-	{$(INCLUDE)}"\ace\Stream_Modules.h"\
-	{$(INCLUDE)}"\ace\Stream_Modules.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.i"\
-	{$(INCLUDE)}"\ace\Svc_Conf_Tokens.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.cpp"\
-	{$(INCLUDE)}"\ace\Svc_Handler.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.i"\
-	{$(INCLUDE)}"\ace\Synch.h"\
-	{$(INCLUDE)}"\ace\Synch.i"\
-	{$(INCLUDE)}"\ace\Synch_Options.h"\
-	{$(INCLUDE)}"\ace\Synch_T.cpp"\
-	{$(INCLUDE)}"\ace\Synch_T.h"\
-	{$(INCLUDE)}"\ace\Synch_T.i"\
-	{$(INCLUDE)}"\ace\Task.h"\
-	{$(INCLUDE)}"\ace\Task.i"\
-	{$(INCLUDE)}"\ace\Task_T.cpp"\
-	{$(INCLUDE)}"\ace\Task_T.h"\
-	{$(INCLUDE)}"\ace\Task_T.i"\
-	{$(INCLUDE)}"\ace\Thread.h"\
-	{$(INCLUDE)}"\ace\Thread.i"\
-	{$(INCLUDE)}"\ace\Thread_Manager.h"\
-	{$(INCLUDE)}"\ace\Thread_Manager.i"\
-	{$(INCLUDE)}"\ace\Time_Value.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.h"\
-	{$(INCLUDE)}"\ace\Timer_List.h"\
-	{$(INCLUDE)}"\ace\Timer_List_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_List_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.i"\
-	{$(INCLUDE)}"\ace\Timer_Wheel.h"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.h"\
-	{$(INCLUDE)}"\ace\Token.h"\
-	{$(INCLUDE)}"\ace\Token.i"\
-	{$(INCLUDE)}"\ace\Trace.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.i"\
-	{$(INCLUDE)}"\ace\UPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\ws2tcpip.h"\
-	
-
-"$(INTDIR)\Supplier_Router.obj" : $(SOURCE) $(DEP_CPP_SUPPL) "$(INTDIR)"
-
-
-# End Source File
-################################################################################
-# Begin Source File
-
-SOURCE=.\Event_Analyzer.cpp
-DEP_CPP_EVENT=\
-	"..\..\..\ace\config-win32.h"\
-	".\Event_Analyzer.h"\
-	{$(INCLUDE)}"\ace\ACE.h"\
-	{$(INCLUDE)}"\ace\ACE.i"\
-	{$(INCLUDE)}"\ace\Addr.h"\
-	{$(INCLUDE)}"\ace\Addr.i"\
-	{$(INCLUDE)}"\ace\Asynch_IO.h"\
-	{$(INCLUDE)}"\ace\Asynch_IO.i"\
-	{$(INCLUDE)}"\ace\Atomic_Op.i"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.cpp"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.h"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.i"\
-	{$(INCLUDE)}"\ace\config-win32-common.h"\
-	{$(INCLUDE)}"\ace\config.h"\
-	{$(INCLUDE)}"\ace\Containers.cpp"\
-	{$(INCLUDE)}"\ace\Containers.h"\
-	{$(INCLUDE)}"\ace\Containers.i"\
-	{$(INCLUDE)}"\ace\Event_Handler.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.i"\
-	{$(INCLUDE)}"\ace\Free_List.cpp"\
-	{$(INCLUDE)}"\ace\Free_List.h"\
-	{$(INCLUDE)}"\ace\Free_List.i"\
-	{$(INCLUDE)}"\ace\Handle_Set.h"\
-	{$(INCLUDE)}"\ace\Handle_Set.i"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.i"\
-	{$(INCLUDE)}"\ace\INET_Addr.h"\
-	{$(INCLUDE)}"\ace\INET_Addr.i"\
-	{$(INCLUDE)}"\ace\IO_Cntl_Msg.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.i"\
-	{$(INCLUDE)}"\ace\Local_Tokens.h"\
-	{$(INCLUDE)}"\ace\Local_Tokens.i"\
-	{$(INCLUDE)}"\ace\Log_Msg.h"\
-	{$(INCLUDE)}"\ace\Log_Priority.h"\
-	{$(INCLUDE)}"\ace\Log_Record.h"\
-	{$(INCLUDE)}"\ace\Log_Record.i"\
-	{$(INCLUDE)}"\ace\Malloc.h"\
-	{$(INCLUDE)}"\ace\Malloc.i"\
-	{$(INCLUDE)}"\ace\Malloc_T.cpp"\
-	{$(INCLUDE)}"\ace\Malloc_T.h"\
-	{$(INCLUDE)}"\ace\Malloc_T.i"\
-	{$(INCLUDE)}"\ace\Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Map_Manager.h"\
-	{$(INCLUDE)}"\ace\Map_Manager.i"\
-	{$(INCLUDE)}"\ace\Mem_Map.h"\
-	{$(INCLUDE)}"\ace\Mem_Map.i"\
-	{$(INCLUDE)}"\ace\Memory_Pool.h"\
-	{$(INCLUDE)}"\ace\Memory_Pool.i"\
-	{$(INCLUDE)}"\ace\Message_Block.h"\
-	{$(INCLUDE)}"\ace\Message_Block.i"\
-	{$(INCLUDE)}"\ace\Message_Queue.cpp"\
-	{$(INCLUDE)}"\ace\Message_Queue.h"\
-	{$(INCLUDE)}"\ace\Message_Queue.i"\
-	{$(INCLUDE)}"\ace\Module.cpp"\
-	{$(INCLUDE)}"\ace\Module.h"\
-	{$(INCLUDE)}"\ace\Module.i"\
-	{$(INCLUDE)}"\ace\Object_Manager.h"\
-	{$(INCLUDE)}"\ace\Object_Manager.i"\
-	{$(INCLUDE)}"\ace\OS.h"\
-	{$(INCLUDE)}"\ace\OS.i"\
-	{$(INCLUDE)}"\ace\Pipe.h"\
-	{$(INCLUDE)}"\ace\Pipe.i"\
-	{$(INCLUDE)}"\ace\Proactor.h"\
-	{$(INCLUDE)}"\ace\Proactor.i"\
-	{$(INCLUDE)}"\ace\Reactor.h"\
-	{$(INCLUDE)}"\ace\Reactor.i"\
-	{$(INCLUDE)}"\ace\ReactorEx.h"\
-	{$(INCLUDE)}"\ace\ReactorEx.i"\
-	{$(INCLUDE)}"\ace\Service_Config.h"\
-	{$(INCLUDE)}"\ace\Service_Config.i"\
-	{$(INCLUDE)}"\ace\Service_Object.h"\
-	{$(INCLUDE)}"\ace\Service_Object.i"\
-	{$(INCLUDE)}"\ace\Shared_Object.h"\
-	{$(INCLUDE)}"\ace\Shared_Object.i"\
-	{$(INCLUDE)}"\ace\Signal.h"\
-	{$(INCLUDE)}"\ace\Signal.i"\
-	{$(INCLUDE)}"\ace\SOCK.h"\
-	{$(INCLUDE)}"\ace\SOCK.i"\
-	{$(INCLUDE)}"\ace\SOCK_IO.h"\
-	{$(INCLUDE)}"\ace\SOCK_IO.i"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.h"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.i"\
-	{$(INCLUDE)}"\ace\SString.h"\
-	{$(INCLUDE)}"\ace\SString.i"\
-	{$(INCLUDE)}"\ace\stdcpp.h"\
-	{$(INCLUDE)}"\ace\Strategies.h"\
-	{$(INCLUDE)}"\ace\Strategies_T.cpp"\
-	{$(INCLUDE)}"\ace\Strategies_T.h"\
-	{$(INCLUDE)}"\ace\Stream.cpp"\
-	{$(INCLUDE)}"\ace\Stream.h"\
-	{$(INCLUDE)}"\ace\Stream.i"\
-	{$(INCLUDE)}"\ace\Stream_Modules.cpp"\
-	{$(INCLUDE)}"\ace\Stream_Modules.h"\
-	{$(INCLUDE)}"\ace\Stream_Modules.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.i"\
-	{$(INCLUDE)}"\ace\Svc_Conf_Tokens.h"\
-	{$(INCLUDE)}"\ace\Synch.h"\
-	{$(INCLUDE)}"\ace\Synch.i"\
-	{$(INCLUDE)}"\ace\Synch_Options.h"\
-	{$(INCLUDE)}"\ace\Synch_T.cpp"\
-	{$(INCLUDE)}"\ace\Synch_T.h"\
-	{$(INCLUDE)}"\ace\Synch_T.i"\
-	{$(INCLUDE)}"\ace\Task.h"\
-	{$(INCLUDE)}"\ace\Task.i"\
-	{$(INCLUDE)}"\ace\Task_T.cpp"\
-	{$(INCLUDE)}"\ace\Task_T.h"\
-	{$(INCLUDE)}"\ace\Task_T.i"\
-	{$(INCLUDE)}"\ace\Thread.h"\
-	{$(INCLUDE)}"\ace\Thread.i"\
-	{$(INCLUDE)}"\ace\Thread_Manager.h"\
-	{$(INCLUDE)}"\ace\Thread_Manager.i"\
-	{$(INCLUDE)}"\ace\Time_Value.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.h"\
-	{$(INCLUDE)}"\ace\Timer_List.h"\
-	{$(INCLUDE)}"\ace\Timer_List_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_List_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.i"\
-	{$(INCLUDE)}"\ace\Timer_Wheel.h"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.h"\
-	{$(INCLUDE)}"\ace\Token.h"\
-	{$(INCLUDE)}"\ace\Token.i"\
-	{$(INCLUDE)}"\ace\Trace.h"\
-	{$(INCLUDE)}"\ace\ws2tcpip.h"\
-	
-
-"$(INTDIR)\Event_Analyzer.obj" : $(SOURCE) $(DEP_CPP_EVENT) "$(INTDIR)"
-
-
-# End Source File
-################################################################################
-# Begin Source File
-
-SOURCE=.\event_server.cpp
-DEP_CPP_EVENT_=\
-	"..\..\..\ace\config-win32.h"\
-	".\Consumer_Router.h"\
-	".\Event_Analyzer.h"\
-	".\Options.h"\
-	".\Options.i"\
-	".\Peer_Router.cpp"\
-	".\Peer_Router.h"\
-	".\Supplier_Router.h"\
-	{$(INCLUDE)}"\ace\Acceptor.cpp"\
-	{$(INCLUDE)}"\ace\Acceptor.h"\
-	{$(INCLUDE)}"\ace\Acceptor.i"\
-	{$(INCLUDE)}"\ace\ACE.h"\
-	{$(INCLUDE)}"\ace\ACE.i"\
-	{$(INCLUDE)}"\ace\Addr.h"\
-	{$(INCLUDE)}"\ace\Addr.i"\
-	{$(INCLUDE)}"\ace\Asynch_IO.h"\
-	{$(INCLUDE)}"\ace\Asynch_IO.i"\
-	{$(INCLUDE)}"\ace\Atomic_Op.i"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.cpp"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.h"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.i"\
-	{$(INCLUDE)}"\ace\config-win32-common.h"\
-	{$(INCLUDE)}"\ace\config.h"\
-	{$(INCLUDE)}"\ace\Containers.cpp"\
-	{$(INCLUDE)}"\ace\Containers.h"\
-	{$(INCLUDE)}"\ace\Containers.i"\
-	{$(INCLUDE)}"\ace\Dynamic.h"\
-	{$(INCLUDE)}"\ace\Dynamic.i"\
-	{$(INCLUDE)}"\ace\Event_Handler.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.i"\
-	{$(INCLUDE)}"\ace\Free_List.cpp"\
-	{$(INCLUDE)}"\ace\Free_List.h"\
-	{$(INCLUDE)}"\ace\Free_List.i"\
-	{$(INCLUDE)}"\ace\Get_Opt.h"\
-	{$(INCLUDE)}"\ace\Get_Opt.i"\
-	{$(INCLUDE)}"\ace\Handle_Set.h"\
-	{$(INCLUDE)}"\ace\Handle_Set.i"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.i"\
-	{$(INCLUDE)}"\ace\INET_Addr.h"\
-	{$(INCLUDE)}"\ace\INET_Addr.i"\
-	{$(INCLUDE)}"\ace\IO_Cntl_Msg.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.i"\
-	{$(INCLUDE)}"\ace\Local_Tokens.h"\
-	{$(INCLUDE)}"\ace\Local_Tokens.i"\
-	{$(INCLUDE)}"\ace\Log_Msg.h"\
-	{$(INCLUDE)}"\ace\Log_Priority.h"\
-	{$(INCLUDE)}"\ace\Log_Record.h"\
-	{$(INCLUDE)}"\ace\Log_Record.i"\
-	{$(INCLUDE)}"\ace\Malloc.h"\
-	{$(INCLUDE)}"\ace\Malloc.i"\
-	{$(INCLUDE)}"\ace\Malloc_T.cpp"\
-	{$(INCLUDE)}"\ace\Malloc_T.h"\
-	{$(INCLUDE)}"\ace\Malloc_T.i"\
-	{$(INCLUDE)}"\ace\Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Map_Manager.h"\
-	{$(INCLUDE)}"\ace\Map_Manager.i"\
-	{$(INCLUDE)}"\ace\Mem_Map.h"\
-	{$(INCLUDE)}"\ace\Mem_Map.i"\
-	{$(INCLUDE)}"\ace\Memory_Pool.h"\
-	{$(INCLUDE)}"\ace\Memory_Pool.i"\
-	{$(INCLUDE)}"\ace\Message_Block.h"\
-	{$(INCLUDE)}"\ace\Message_Block.i"\
-	{$(INCLUDE)}"\ace\Message_Queue.cpp"\
-	{$(INCLUDE)}"\ace\Message_Queue.h"\
-	{$(INCLUDE)}"\ace\Message_Queue.i"\
-	{$(INCLUDE)}"\ace\Module.cpp"\
-	{$(INCLUDE)}"\ace\Module.h"\
-	{$(INCLUDE)}"\ace\Module.i"\
-	{$(INCLUDE)}"\ace\Object_Manager.h"\
-	{$(INCLUDE)}"\ace\Object_Manager.i"\
-	{$(INCLUDE)}"\ace\OS.h"\
-	{$(INCLUDE)}"\ace\OS.i"\
-	{$(INCLUDE)}"\ace\Pipe.h"\
-	{$(INCLUDE)}"\ace\Pipe.i"\
-	{$(INCLUDE)}"\ace\Proactor.h"\
-	{$(INCLUDE)}"\ace\Proactor.i"\
-	{$(INCLUDE)}"\ace\Profile_Timer.h"\
-	{$(INCLUDE)}"\ace\Profile_Timer.i"\
-	{$(INCLUDE)}"\ace\Reactor.h"\
-	{$(INCLUDE)}"\ace\Reactor.i"\
-	{$(INCLUDE)}"\ace\ReactorEx.h"\
-	{$(INCLUDE)}"\ace\ReactorEx.i"\
-	{$(INCLUDE)}"\ace\Service_Config.h"\
-	{$(INCLUDE)}"\ace\Service_Config.i"\
-	{$(INCLUDE)}"\ace\Service_Object.h"\
-	{$(INCLUDE)}"\ace\Service_Object.i"\
-	{$(INCLUDE)}"\ace\Shared_Object.h"\
-	{$(INCLUDE)}"\ace\Shared_Object.i"\
-	{$(INCLUDE)}"\ace\Signal.h"\
-	{$(INCLUDE)}"\ace\Signal.i"\
-	{$(INCLUDE)}"\ace\SOCK.h"\
-	{$(INCLUDE)}"\ace\SOCK.i"\
-	{$(INCLUDE)}"\ace\SOCK_IO.h"\
-	{$(INCLUDE)}"\ace\SOCK_IO.i"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.h"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.i"\
-	{$(INCLUDE)}"\ace\SPIPE.h"\
-	{$(INCLUDE)}"\ace\SPIPE.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\SString.h"\
-	{$(INCLUDE)}"\ace\SString.i"\
-	{$(INCLUDE)}"\ace\stdcpp.h"\
-	{$(INCLUDE)}"\ace\Strategies.h"\
-	{$(INCLUDE)}"\ace\Strategies_T.cpp"\
-	{$(INCLUDE)}"\ace\Strategies_T.h"\
-	{$(INCLUDE)}"\ace\Stream.cpp"\
-	{$(INCLUDE)}"\ace\Stream.h"\
-	{$(INCLUDE)}"\ace\Stream.i"\
-	{$(INCLUDE)}"\ace\Stream_Modules.cpp"\
-	{$(INCLUDE)}"\ace\Stream_Modules.h"\
-	{$(INCLUDE)}"\ace\Stream_Modules.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.i"\
-	{$(INCLUDE)}"\ace\Svc_Conf_Tokens.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.cpp"\
-	{$(INCLUDE)}"\ace\Svc_Handler.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.i"\
-	{$(INCLUDE)}"\ace\Synch.h"\
-	{$(INCLUDE)}"\ace\Synch.i"\
-	{$(INCLUDE)}"\ace\Synch_Options.h"\
-	{$(INCLUDE)}"\ace\Synch_T.cpp"\
-	{$(INCLUDE)}"\ace\Synch_T.h"\
-	{$(INCLUDE)}"\ace\Synch_T.i"\
-	{$(INCLUDE)}"\ace\Task.h"\
-	{$(INCLUDE)}"\ace\Task.i"\
-	{$(INCLUDE)}"\ace\Task_T.cpp"\
-	{$(INCLUDE)}"\ace\Task_T.h"\
-	{$(INCLUDE)}"\ace\Task_T.i"\
-	{$(INCLUDE)}"\ace\Thread.h"\
-	{$(INCLUDE)}"\ace\Thread.i"\
-	{$(INCLUDE)}"\ace\Thread_Manager.h"\
-	{$(INCLUDE)}"\ace\Thread_Manager.i"\
-	{$(INCLUDE)}"\ace\Time_Value.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.h"\
-	{$(INCLUDE)}"\ace\Timer_List.h"\
-	{$(INCLUDE)}"\ace\Timer_List_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_List_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.i"\
-	{$(INCLUDE)}"\ace\Timer_Wheel.h"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.h"\
-	{$(INCLUDE)}"\ace\Token.h"\
-	{$(INCLUDE)}"\ace\Token.i"\
-	{$(INCLUDE)}"\ace\Trace.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.i"\
-	{$(INCLUDE)}"\ace\UPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Connector.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Connector.i"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\ws2tcpip.h"\
-	
-
-"$(INTDIR)\event_server.obj" : $(SOURCE) $(DEP_CPP_EVENT_) "$(INTDIR)"
-
-
-# End Source File
-################################################################################
-# Begin Source File
-
-SOURCE=.\Options.cpp
-DEP_CPP_OPTIO=\
-	"..\..\..\ace\config-win32.h"\
-	".\Options.h"\
-	".\Options.i"\
-	{$(INCLUDE)}"\ace\ACE.h"\
-	{$(INCLUDE)}"\ace\ACE.i"\
-	{$(INCLUDE)}"\ace\Atomic_Op.i"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.cpp"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.h"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.i"\
-	{$(INCLUDE)}"\ace\config-win32-common.h"\
-	{$(INCLUDE)}"\ace\config.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.i"\
-	{$(INCLUDE)}"\ace\Get_Opt.h"\
-	{$(INCLUDE)}"\ace\Get_Opt.i"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.i"\
-	{$(INCLUDE)}"\ace\Log_Msg.h"\
-	{$(INCLUDE)}"\ace\Log_Priority.h"\
-	{$(INCLUDE)}"\ace\Log_Record.h"\
-	{$(INCLUDE)}"\ace\Log_Record.i"\
-	{$(INCLUDE)}"\ace\Object_Manager.h"\
-	{$(INCLUDE)}"\ace\Object_Manager.i"\
-	{$(INCLUDE)}"\ace\OS.h"\
-	{$(INCLUDE)}"\ace\OS.i"\
-	{$(INCLUDE)}"\ace\Profile_Timer.h"\
-	{$(INCLUDE)}"\ace\Profile_Timer.i"\
-	{$(INCLUDE)}"\ace\SString.h"\
-	{$(INCLUDE)}"\ace\SString.i"\
-	{$(INCLUDE)}"\ace\stdcpp.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.i"\
-	{$(INCLUDE)}"\ace\Synch.h"\
-	{$(INCLUDE)}"\ace\Synch.i"\
-	{$(INCLUDE)}"\ace\Synch_T.cpp"\
-	{$(INCLUDE)}"\ace\Synch_T.h"\
-	{$(INCLUDE)}"\ace\Synch_T.i"\
-	{$(INCLUDE)}"\ace\Thread.h"\
-	{$(INCLUDE)}"\ace\Thread.i"\
-	{$(INCLUDE)}"\ace\Time_Value.h"\
-	{$(INCLUDE)}"\ace\Trace.h"\
-	{$(INCLUDE)}"\ace\ws2tcpip.h"\
-	
-
-"$(INTDIR)\Options.obj" : $(SOURCE) $(DEP_CPP_OPTIO) "$(INTDIR)"
-
-
-# End Source File
-################################################################################
-# Begin Source File
-
-SOURCE=.\Peer_Router.cpp
-DEP_CPP_PEER_=\
-	"..\..\..\ace\config-win32.h"\
-	".\Options.h"\
-	".\Options.i"\
-	".\Peer_Router.cpp"\
-	".\Peer_Router.h"\
-	{$(INCLUDE)}"\ace\Acceptor.cpp"\
-	{$(INCLUDE)}"\ace\Acceptor.h"\
-	{$(INCLUDE)}"\ace\Acceptor.i"\
-	{$(INCLUDE)}"\ace\ACE.h"\
-	{$(INCLUDE)}"\ace\ACE.i"\
-	{$(INCLUDE)}"\ace\Addr.h"\
-	{$(INCLUDE)}"\ace\Addr.i"\
-	{$(INCLUDE)}"\ace\Asynch_IO.h"\
-	{$(INCLUDE)}"\ace\Asynch_IO.i"\
-	{$(INCLUDE)}"\ace\Atomic_Op.i"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.cpp"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.h"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.i"\
-	{$(INCLUDE)}"\ace\config-win32-common.h"\
-	{$(INCLUDE)}"\ace\config.h"\
-	{$(INCLUDE)}"\ace\Containers.cpp"\
-	{$(INCLUDE)}"\ace\Containers.h"\
-	{$(INCLUDE)}"\ace\Containers.i"\
-	{$(INCLUDE)}"\ace\Dynamic.h"\
-	{$(INCLUDE)}"\ace\Dynamic.i"\
-	{$(INCLUDE)}"\ace\Event_Handler.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.i"\
-	{$(INCLUDE)}"\ace\Free_List.cpp"\
-	{$(INCLUDE)}"\ace\Free_List.h"\
-	{$(INCLUDE)}"\ace\Free_List.i"\
-	{$(INCLUDE)}"\ace\Get_Opt.h"\
-	{$(INCLUDE)}"\ace\Get_Opt.i"\
-	{$(INCLUDE)}"\ace\Handle_Set.h"\
-	{$(INCLUDE)}"\ace\Handle_Set.i"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.i"\
-	{$(INCLUDE)}"\ace\INET_Addr.h"\
-	{$(INCLUDE)}"\ace\INET_Addr.i"\
-	{$(INCLUDE)}"\ace\IO_Cntl_Msg.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.i"\
-	{$(INCLUDE)}"\ace\Local_Tokens.h"\
-	{$(INCLUDE)}"\ace\Local_Tokens.i"\
-	{$(INCLUDE)}"\ace\Log_Msg.h"\
-	{$(INCLUDE)}"\ace\Log_Priority.h"\
-	{$(INCLUDE)}"\ace\Log_Record.h"\
-	{$(INCLUDE)}"\ace\Log_Record.i"\
-	{$(INCLUDE)}"\ace\Malloc.h"\
-	{$(INCLUDE)}"\ace\Malloc.i"\
-	{$(INCLUDE)}"\ace\Malloc_T.cpp"\
-	{$(INCLUDE)}"\ace\Malloc_T.h"\
-	{$(INCLUDE)}"\ace\Malloc_T.i"\
-	{$(INCLUDE)}"\ace\Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Map_Manager.h"\
-	{$(INCLUDE)}"\ace\Map_Manager.i"\
-	{$(INCLUDE)}"\ace\Mem_Map.h"\
-	{$(INCLUDE)}"\ace\Mem_Map.i"\
-	{$(INCLUDE)}"\ace\Memory_Pool.h"\
-	{$(INCLUDE)}"\ace\Memory_Pool.i"\
-	{$(INCLUDE)}"\ace\Message_Block.h"\
-	{$(INCLUDE)}"\ace\Message_Block.i"\
-	{$(INCLUDE)}"\ace\Message_Queue.cpp"\
-	{$(INCLUDE)}"\ace\Message_Queue.h"\
-	{$(INCLUDE)}"\ace\Message_Queue.i"\
-	{$(INCLUDE)}"\ace\Module.cpp"\
-	{$(INCLUDE)}"\ace\Module.h"\
-	{$(INCLUDE)}"\ace\Module.i"\
-	{$(INCLUDE)}"\ace\Object_Manager.h"\
-	{$(INCLUDE)}"\ace\Object_Manager.i"\
-	{$(INCLUDE)}"\ace\OS.h"\
-	{$(INCLUDE)}"\ace\OS.i"\
-	{$(INCLUDE)}"\ace\Pipe.h"\
-	{$(INCLUDE)}"\ace\Pipe.i"\
-	{$(INCLUDE)}"\ace\Proactor.h"\
-	{$(INCLUDE)}"\ace\Proactor.i"\
-	{$(INCLUDE)}"\ace\Profile_Timer.h"\
-	{$(INCLUDE)}"\ace\Profile_Timer.i"\
-	{$(INCLUDE)}"\ace\Reactor.h"\
-	{$(INCLUDE)}"\ace\Reactor.i"\
-	{$(INCLUDE)}"\ace\ReactorEx.h"\
-	{$(INCLUDE)}"\ace\ReactorEx.i"\
-	{$(INCLUDE)}"\ace\Service_Config.h"\
-	{$(INCLUDE)}"\ace\Service_Config.i"\
-	{$(INCLUDE)}"\ace\Service_Object.h"\
-	{$(INCLUDE)}"\ace\Service_Object.i"\
-	{$(INCLUDE)}"\ace\Shared_Object.h"\
-	{$(INCLUDE)}"\ace\Shared_Object.i"\
-	{$(INCLUDE)}"\ace\Signal.h"\
-	{$(INCLUDE)}"\ace\Signal.i"\
-	{$(INCLUDE)}"\ace\SOCK.h"\
-	{$(INCLUDE)}"\ace\SOCK.i"\
-	{$(INCLUDE)}"\ace\SOCK_IO.h"\
-	{$(INCLUDE)}"\ace\SOCK_IO.i"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.h"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.i"\
-	{$(INCLUDE)}"\ace\SPIPE.h"\
-	{$(INCLUDE)}"\ace\SPIPE.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\SString.h"\
-	{$(INCLUDE)}"\ace\SString.i"\
-	{$(INCLUDE)}"\ace\stdcpp.h"\
-	{$(INCLUDE)}"\ace\Strategies.h"\
-	{$(INCLUDE)}"\ace\Strategies_T.cpp"\
-	{$(INCLUDE)}"\ace\Strategies_T.h"\
-	{$(INCLUDE)}"\ace\Stream.cpp"\
-	{$(INCLUDE)}"\ace\Stream.h"\
-	{$(INCLUDE)}"\ace\Stream.i"\
-	{$(INCLUDE)}"\ace\Stream_Modules.cpp"\
-	{$(INCLUDE)}"\ace\Stream_Modules.h"\
-	{$(INCLUDE)}"\ace\Stream_Modules.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.i"\
-	{$(INCLUDE)}"\ace\Svc_Conf_Tokens.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.cpp"\
-	{$(INCLUDE)}"\ace\Svc_Handler.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.i"\
-	{$(INCLUDE)}"\ace\Synch.h"\
-	{$(INCLUDE)}"\ace\Synch.i"\
-	{$(INCLUDE)}"\ace\Synch_Options.h"\
-	{$(INCLUDE)}"\ace\Synch_T.cpp"\
-	{$(INCLUDE)}"\ace\Synch_T.h"\
-	{$(INCLUDE)}"\ace\Synch_T.i"\
-	{$(INCLUDE)}"\ace\Task.h"\
-	{$(INCLUDE)}"\ace\Task.i"\
-	{$(INCLUDE)}"\ace\Task_T.cpp"\
-	{$(INCLUDE)}"\ace\Task_T.h"\
-	{$(INCLUDE)}"\ace\Task_T.i"\
-	{$(INCLUDE)}"\ace\Thread.h"\
-	{$(INCLUDE)}"\ace\Thread.i"\
-	{$(INCLUDE)}"\ace\Thread_Manager.h"\
-	{$(INCLUDE)}"\ace\Thread_Manager.i"\
-	{$(INCLUDE)}"\ace\Time_Value.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.h"\
-	{$(INCLUDE)}"\ace\Timer_List.h"\
-	{$(INCLUDE)}"\ace\Timer_List_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_List_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.i"\
-	{$(INCLUDE)}"\ace\Timer_Wheel.h"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.h"\
-	{$(INCLUDE)}"\ace\Token.h"\
-	{$(INCLUDE)}"\ace\Token.i"\
-	{$(INCLUDE)}"\ace\Trace.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.i"\
-	{$(INCLUDE)}"\ace\UPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\ws2tcpip.h"\
-	
-
-"$(INTDIR)\Peer_Router.obj" : $(SOURCE) $(DEP_CPP_PEER_) "$(INTDIR)"\
- ".\Peer_Router.cpp"
-
-
-# End Source File
-################################################################################
-# Begin Source File
-
-SOURCE=.\Consumer_Router.cpp
-DEP_CPP_CONSU=\
-	"..\..\..\ace\config-win32.h"\
-	".\Consumer_Router.h"\
-	".\Options.h"\
-	".\Options.i"\
-	".\Peer_Router.cpp"\
-	".\Peer_Router.h"\
-	{$(INCLUDE)}"\ace\Acceptor.cpp"\
-	{$(INCLUDE)}"\ace\Acceptor.h"\
-	{$(INCLUDE)}"\ace\Acceptor.i"\
-	{$(INCLUDE)}"\ace\ACE.h"\
-	{$(INCLUDE)}"\ace\ACE.i"\
-	{$(INCLUDE)}"\ace\Addr.h"\
-	{$(INCLUDE)}"\ace\Addr.i"\
-	{$(INCLUDE)}"\ace\Asynch_IO.h"\
-	{$(INCLUDE)}"\ace\Asynch_IO.i"\
-	{$(INCLUDE)}"\ace\Atomic_Op.i"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.cpp"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.h"\
-	{$(INCLUDE)}"\ace\Auto_Ptr.i"\
-	{$(INCLUDE)}"\ace\config-win32-common.h"\
-	{$(INCLUDE)}"\ace\config.h"\
-	{$(INCLUDE)}"\ace\Containers.cpp"\
-	{$(INCLUDE)}"\ace\Containers.h"\
-	{$(INCLUDE)}"\ace\Containers.i"\
-	{$(INCLUDE)}"\ace\Dynamic.h"\
-	{$(INCLUDE)}"\ace\Dynamic.i"\
-	{$(INCLUDE)}"\ace\Event_Handler.h"\
-	{$(INCLUDE)}"\ace\Event_Handler.i"\
-	{$(INCLUDE)}"\ace\Free_List.cpp"\
-	{$(INCLUDE)}"\ace\Free_List.h"\
-	{$(INCLUDE)}"\ace\Free_List.i"\
-	{$(INCLUDE)}"\ace\Get_Opt.h"\
-	{$(INCLUDE)}"\ace\Get_Opt.i"\
-	{$(INCLUDE)}"\ace\Handle_Set.h"\
-	{$(INCLUDE)}"\ace\Handle_Set.i"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Hash_Map_Manager.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.h"\
-	{$(INCLUDE)}"\ace\High_Res_Timer.i"\
-	{$(INCLUDE)}"\ace\INET_Addr.h"\
-	{$(INCLUDE)}"\ace\INET_Addr.i"\
-	{$(INCLUDE)}"\ace\IO_Cntl_Msg.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.h"\
-	{$(INCLUDE)}"\ace\IPC_SAP.i"\
-	{$(INCLUDE)}"\ace\Local_Tokens.h"\
-	{$(INCLUDE)}"\ace\Local_Tokens.i"\
-	{$(INCLUDE)}"\ace\Log_Msg.h"\
-	{$(INCLUDE)}"\ace\Log_Priority.h"\
-	{$(INCLUDE)}"\ace\Log_Record.h"\
-	{$(INCLUDE)}"\ace\Log_Record.i"\
-	{$(INCLUDE)}"\ace\Malloc.h"\
-	{$(INCLUDE)}"\ace\Malloc.i"\
-	{$(INCLUDE)}"\ace\Malloc_T.cpp"\
-	{$(INCLUDE)}"\ace\Malloc_T.h"\
-	{$(INCLUDE)}"\ace\Malloc_T.i"\
-	{$(INCLUDE)}"\ace\Map_Manager.cpp"\
-	{$(INCLUDE)}"\ace\Map_Manager.h"\
-	{$(INCLUDE)}"\ace\Map_Manager.i"\
-	{$(INCLUDE)}"\ace\Mem_Map.h"\
-	{$(INCLUDE)}"\ace\Mem_Map.i"\
-	{$(INCLUDE)}"\ace\Memory_Pool.h"\
-	{$(INCLUDE)}"\ace\Memory_Pool.i"\
-	{$(INCLUDE)}"\ace\Message_Block.h"\
-	{$(INCLUDE)}"\ace\Message_Block.i"\
-	{$(INCLUDE)}"\ace\Message_Queue.cpp"\
-	{$(INCLUDE)}"\ace\Message_Queue.h"\
-	{$(INCLUDE)}"\ace\Message_Queue.i"\
-	{$(INCLUDE)}"\ace\Module.cpp"\
-	{$(INCLUDE)}"\ace\Module.h"\
-	{$(INCLUDE)}"\ace\Module.i"\
-	{$(INCLUDE)}"\ace\Object_Manager.h"\
-	{$(INCLUDE)}"\ace\Object_Manager.i"\
-	{$(INCLUDE)}"\ace\OS.h"\
-	{$(INCLUDE)}"\ace\OS.i"\
-	{$(INCLUDE)}"\ace\Pipe.h"\
-	{$(INCLUDE)}"\ace\Pipe.i"\
-	{$(INCLUDE)}"\ace\Proactor.h"\
-	{$(INCLUDE)}"\ace\Proactor.i"\
-	{$(INCLUDE)}"\ace\Profile_Timer.h"\
-	{$(INCLUDE)}"\ace\Profile_Timer.i"\
-	{$(INCLUDE)}"\ace\Reactor.h"\
-	{$(INCLUDE)}"\ace\Reactor.i"\
-	{$(INCLUDE)}"\ace\ReactorEx.h"\
-	{$(INCLUDE)}"\ace\ReactorEx.i"\
-	{$(INCLUDE)}"\ace\Service_Config.h"\
-	{$(INCLUDE)}"\ace\Service_Config.i"\
-	{$(INCLUDE)}"\ace\Service_Object.h"\
-	{$(INCLUDE)}"\ace\Service_Object.i"\
-	{$(INCLUDE)}"\ace\Shared_Object.h"\
-	{$(INCLUDE)}"\ace\Shared_Object.i"\
-	{$(INCLUDE)}"\ace\Signal.h"\
-	{$(INCLUDE)}"\ace\Signal.i"\
-	{$(INCLUDE)}"\ace\SOCK.h"\
-	{$(INCLUDE)}"\ace\SOCK.i"\
-	{$(INCLUDE)}"\ace\SOCK_IO.h"\
-	{$(INCLUDE)}"\ace\SOCK_IO.i"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.h"\
-	{$(INCLUDE)}"\ace\SOCK_Stream.i"\
-	{$(INCLUDE)}"\ace\SPIPE.h"\
-	{$(INCLUDE)}"\ace\SPIPE.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Addr.i"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\SPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\SString.h"\
-	{$(INCLUDE)}"\ace\SString.i"\
-	{$(INCLUDE)}"\ace\stdcpp.h"\
-	{$(INCLUDE)}"\ace\Strategies.h"\
-	{$(INCLUDE)}"\ace\Strategies_T.cpp"\
-	{$(INCLUDE)}"\ace\Strategies_T.h"\
-	{$(INCLUDE)}"\ace\Stream.cpp"\
-	{$(INCLUDE)}"\ace\Stream.h"\
-	{$(INCLUDE)}"\ace\Stream.i"\
-	{$(INCLUDE)}"\ace\Stream_Modules.cpp"\
-	{$(INCLUDE)}"\ace\Stream_Modules.h"\
-	{$(INCLUDE)}"\ace\Stream_Modules.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Complex.i"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.h"\
-	{$(INCLUDE)}"\ace\SV_Semaphore_Simple.i"\
-	{$(INCLUDE)}"\ace\Svc_Conf_Tokens.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.cpp"\
-	{$(INCLUDE)}"\ace\Svc_Handler.h"\
-	{$(INCLUDE)}"\ace\Svc_Handler.i"\
-	{$(INCLUDE)}"\ace\Synch.h"\
-	{$(INCLUDE)}"\ace\Synch.i"\
-	{$(INCLUDE)}"\ace\Synch_Options.h"\
-	{$(INCLUDE)}"\ace\Synch_T.cpp"\
-	{$(INCLUDE)}"\ace\Synch_T.h"\
-	{$(INCLUDE)}"\ace\Synch_T.i"\
-	{$(INCLUDE)}"\ace\Task.h"\
-	{$(INCLUDE)}"\ace\Task.i"\
-	{$(INCLUDE)}"\ace\Task_T.cpp"\
-	{$(INCLUDE)}"\ace\Task_T.h"\
-	{$(INCLUDE)}"\ace\Task_T.i"\
-	{$(INCLUDE)}"\ace\Thread.h"\
-	{$(INCLUDE)}"\ace\Thread.i"\
-	{$(INCLUDE)}"\ace\Thread_Manager.h"\
-	{$(INCLUDE)}"\ace\Thread_Manager.i"\
-	{$(INCLUDE)}"\ace\Time_Value.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap.h"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Heap_T.h"\
-	{$(INCLUDE)}"\ace\Timer_List.h"\
-	{$(INCLUDE)}"\ace\Timer_List_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_List_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.h"\
-	{$(INCLUDE)}"\ace\Timer_Queue_T.i"\
-	{$(INCLUDE)}"\ace\Timer_Wheel.h"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.cpp"\
-	{$(INCLUDE)}"\ace\Timer_Wheel_T.h"\
-	{$(INCLUDE)}"\ace\Token.h"\
-	{$(INCLUDE)}"\ace\Token.i"\
-	{$(INCLUDE)}"\ace\Trace.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Acceptor.i"\
-	{$(INCLUDE)}"\ace\UPIPE_Addr.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.h"\
-	{$(INCLUDE)}"\ace\UPIPE_Stream.i"\
-	{$(INCLUDE)}"\ace\ws2tcpip.h"\
-	
-
-"$(INTDIR)\Consumer_Router.obj" : $(SOURCE) $(DEP_CPP_CONSU) "$(INTDIR)"\
- ".\Peer_Router.cpp"
-
-
-# End Source File
-# End Target
-# End Project
-################################################################################
diff --git a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.mdp b/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.mdp
deleted file mode 100644
index 5fe4dad98ec..00000000000
--- a/examples/ASX/UPIPE_Event_Server/UPIPE_Event_Server.mdp
+++ /dev/null
diff --git a/examples/ASX/UPIPE_Event_Server/event_server.cpp b/examples/ASX/UPIPE_Event_Server/event_server.cpp
deleted file mode 100644
index d7d788939d5..00000000000
--- a/examples/ASX/UPIPE_Event_Server/event_server.cpp
+++ /dev/null
@@ -1,251 +0,0 @@
-// Test the event server.
-// $Id$
-
-#include "ace/Stream.h"
-#include "ace/Service_Config.h"
-#include "Options.h"
-#include "Consumer_Router.h"
-#include "Event_Analyzer.h"
-#include "Supplier_Router.h"
-#include "ace/UPIPE_Acceptor.h"
-#include "ace/UPIPE_Connector.h"
-#include "ace/streams.h"
-
-#if defined (ACE_HAS_THREADS)
-
-typedef ACE_Stream<ACE_MT_SYNCH> MT_Stream;
-typedef ACE_Module<ACE_MT_SYNCH> MT_Module;
-
-// Handle SIGINT and terminate the entire application.
-
-class Quit_Handler : public ACE_Sig_Adapter
-{
-public:
-  Quit_Handler (void);
-  virtual int handle_input (ACE_HANDLE fd);
-};
-
-Quit_Handler::Quit_Handler (void)
-  : ACE_Sig_Adapter (ACE_Sig_Handler_Ex (ACE_Reactor::end_event_loop))
-{  
-  // Register to trap input from the user.
-  if (ACE::register_stdin_handler (this,
-				   ACE_Reactor::instance (),
-				   ACE_Thread_Manager::instance ()) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n", "register_stdin_handler"));
-  // Register to trap the SIGINT signal.
-  else if (ACE_Reactor::instance ()->register_handler 
-	   (SIGINT, this) == -1)
-    ACE_ERROR ((LM_ERROR, "%p\n", "register_handler"));
-}
-
-int
-Quit_Handler::handle_input (ACE_HANDLE)
-{
-  options.stop_timer ();
-  ACE_DEBUG ((LM_INFO, " (%t) closing down the test\n"));
-  options.print_results ();
-
-  ACE_Reactor::end_event_loop();
-  return 0;
-}
-
-static void *
-consumer (void *)
-{
-  ACE_UPIPE_Stream c_stream;
-  ACE_UPIPE_Addr c_addr ("/tmp/conupipe");
-
-  int verb = options.verbose ();
-  int msiz = options.message_size ();
-  int secs, par1, par2;
-  time_t currsec;
-
-  if (verb)
-    cout << "consumer starting connect" << endl;
-
-  ACE_UPIPE_Connector con;
-
-  if (con.connect (c_stream, c_addr) == -1)
-    ACE_DEBUG ((LM_INFO, " (%t) connect failed\n"));
-  else
-    cout << "consumer :we're connected" << endl;
-
-  ACE_Message_Block *mb_p;
-
-  int done = 0;
-  int cnt = 0;
-  ACE_OS::time (&currsec);
-
-  par1= (time_t) currsec;
-
-  while (done == 0 
-	 && (c_stream.recv (mb_p) != -1))
-    if (mb_p->length () > 1) 
-      {
-	cnt++;
-	if (verb)
-	  cout << " consumer received message !!!!!! " 
-	       << mb_p->rd_ptr () << endl;
-      }
-    else
-      {
-	if (verb)
-	  cout << "consumer got last mb" 
-	       << (char) * (mb_p->rd_ptr ()) << endl;
-	c_stream.close ();
-	done = 1;
-      }
-
-    ACE_OS::time (&currsec);
-    par2 = (time_t) currsec;
-
-    secs = par2 - par1;
-
-    if (secs <= 0)
-      secs=1;
-
-    cout << "consumer got " << cnt << " messages of size " << msiz 
-	 << "within " << secs << " seconds" << endl;
-
-    ACE_OS::sleep (2);
-    cout << "consumer terminating " << endl;
-    return 0;
-}
-
-static void *
-supplier (void *dummy)
-{
-  ACE_UPIPE_Stream s_stream;
-  ACE_UPIPE_Addr serv_addr ("/tmp/supupipe");
-  ACE_UPIPE_Connector con;
-
-  int iter = options.iterations ();
-  int verb = options.verbose ();
-  int msiz = options.message_size ();
-  cout << "supplier starting connect" << endl;
-
-  if (con.connect (s_stream, serv_addr) == -1)
-    ACE_DEBUG ((LM_INFO, " (%t) connect failed\n"));
-
-  cout << "supplier : we're connected" << endl;
-  int	   n;
-  n = 0;
-  ACE_Message_Block * mb_p;
-
-  while (n < iter)
-    {
-      mb_p = new ACE_Message_Block (msiz);
-      strcpy (mb_p->rd_ptr (), (char *) dummy);
-      mb_p->length (msiz);
-      if (verb)
-        cout << "supplier sending 1 message_block" << endl;
-      if (s_stream.send (mb_p) == -1)
-	{
-	  cout << "supplier send failed" << endl;
-	  return (void *) -1;
-	}
-      n++;
-    }
-
-  mb_p = new ACE_Message_Block (10);
-  mb_p->length (1);
-  *mb_p->rd_ptr () = 'g';
-
-  cout << "supplier sending last message_block" << endl;
-
-  if (s_stream.send (mb_p) == -1)
-    {
-      cout << "supplier send last mb failed" << endl;
-      return (void *) -1;
-    }
-  mb_p = new ACE_Message_Block (10);
-  mb_p->length (0);
-
-  if (verb)
-    cout << "supplier sending very last message_block" << endl;
-
-  if (s_stream.send (mb_p) == -1)
-    {
-      cout << "supplier send very last mb failed" << endl;
-      return (void *) -1;
-    }
-
-  ACE_OS::sleep (2);
-  cout << "supplier terminating" << endl;
-  return 0;
-}
-
-int
-main (int argc, char *argv[])
-{
-  ACE_Service_Config daemon;
-  
-  options.parse_args (argc, argv);
-  options.start_timer ();
-
-  // Primary ACE_Stream for EVENT_SERVER application.
-  MT_Stream event_server; 
-
-  // Enable graceful shutdowns....
-  Quit_Handler quit_handler;
-
-  // Create the modules..
-
-  MT_Module *sr = new MT_Module ("Supplier_Router", 
-	  new Supplier_Router (ACE_Thread_Manager::instance ()));
-  MT_Module *ea = new MT_Module ("Event_Analyzer", 
-				 new Event_Analyzer, 
-				 new Event_Analyzer);
-  MT_Module *cr = new MT_Module ("Consumer_Router", 
-				 0, // 0 triggers the creation of a ACE_Thru_Task...
-				 new Consumer_Router (ACE_Thread_Manager::instance ()));
-
-  // Push the modules onto the event_server stream.
-
-  if (event_server.push (sr) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "push (Supplier_Router)"), -1);
-					
-  if (event_server.push (ea) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "push (Event_Analyzer)"), -1);
-
-  if (event_server.push (cr) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "push (Consumer_Router)"), -1);
-
-  // Set the high and low water marks appropriately.
-
-  int wm = options.low_water_mark ();
-
-  if (event_server.control (ACE_IO_Cntl_Msg::SET_LWM, &wm) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "push (setting low watermark)"), -1);
-
-  wm = options.high_water_mark ();
-  if (event_server.control (ACE_IO_Cntl_Msg::SET_HWM, &wm) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "push (setting high watermark)"), -1);
-
-  // spawn the two threads.
-
-  if (ACE_Thread_Manager::instance ()->spawn (ACE_THR_FUNC (consumer), (void *) 0,
-					     THR_NEW_LWP | THR_DETACHED) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "spawn"), 1);
-
-  else if (ACE_Thread_Manager::instance ()->spawn (ACE_THR_FUNC (supplier), (void *) "hello",
-						  THR_NEW_LWP | THR_DETACHED) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "spawn"), 1);
- 
-  // Perform the main event loop waiting for the user to type ^C or to
-  // enter a line on the ACE_STDIN.
-
-  ACE_Reactor::run_event_loop ();
-
-  ACE_DEBUG ((LM_DEBUG, "main exiting\n"));
-
-  return 0;
-}
-#else
-int 
-main (int, char *[])
-{
-  ACE_ERROR_RETURN ((LM_ERROR, "test not defined for this platform\n"), -1);
-}
-#endif /* ACE_HAS_THREADS */