1 files changed, 0 insertions, 156 deletions
diff --git a/examples/Connection/misc/test_upipe.cpp b/examples/Connection/misc/test_upipe.cpp
deleted file mode 100644
index 8775512c8ad..00000000000
--- a/examples/Connection/misc/test_upipe.cpp
+++ /dev/null
@@ -1,156 +0,0 @@
-// $Id$
-
-// This short program illustrates in implementation of the classic
-// "bounded buffer" program using ACE_UPIPEs.  This program also shows
-// how the ACE_Connector and ACE_Acceptor patterns work when used with
-// ACE_UPIPEs.
-
-#include "ace/Acceptor.h"
-#include "ace/Connector.h"
-#include "ace/UPIPE_Acceptor.h"
-#include "ace/UPIPE_Connector.h"
-#include "ace/UPIPE_Addr.h"
-
-ACE_RCSID(misc, test_upipe, "$Id$")
-
-#if defined (ACE_HAS_THREADS)
-
-#include "test_upipe.h"
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class ACE_Accept_Strategy<Server_Service, ACE_UPIPE_ACCEPTOR>;
-template class ACE_Acceptor<Server_Service, ACE_UPIPE_ACCEPTOR>;
-template class ACE_Concurrency_Strategy<Server_Service>;
-template class ACE_Connector<Client_Service, ACE_UPIPE_CONNECTOR>;
-template class ACE_Creation_Strategy<Server_Service>;
-template class ACE_Map_Entry<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *>;
-template class ACE_Map_Iterator_Base<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>;
-template class ACE_Map_Iterator<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>;
-template class ACE_Map_Reverse_Iterator<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>;
-template class ACE_Map_Manager<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>;
-template class ACE_Scheduling_Strategy<Server_Service>;
-template class ACE_Strategy_Acceptor<Server_Service, ACE_UPIPE_ACCEPTOR>;
-template class ACE_Svc_Handler<ACE_UPIPE_STREAM, ACE_NULL_SYNCH>;
-template class ACE_Svc_Tuple<Client_Service>;
-template class ACE_Thread_Strategy<Server_Service>;
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate ACE_Accept_Strategy<Server_Service, ACE_UPIPE_ACCEPTOR>
-#pragma instantiate ACE_Acceptor<Server_Service, ACE_UPIPE_ACCEPTOR>
-#pragma instantiate ACE_Concurrency_Strategy<Server_Service>
-#pragma instantiate ACE_Connector<Client_Service, ACE_UPIPE_CONNECTOR>
-#pragma instantiate ACE_Creation_Strategy<Server_Service>
-#pragma instantiate ACE_Map_Entry<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *>
-#pragma instantiate ACE_Map_Iterator_Base<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>
-#pragma instantiate ACE_Map_Iterator<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>
-#pragma instantiate ACE_Map_Reverse_Iterator<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>
-#pragma instantiate ACE_Map_Manager<ACE_HANDLE, ACE_Svc_Tuple<Client_Service> *, ACE_SYNCH_RW_MUTEX>
-#pragma instantiate ACE_Scheduling_Strategy<Server_Service>
-#pragma instantiate ACE_Strategy_Acceptor<Server_Service, ACE_UPIPE_ACCEPTOR>
-#pragma instantiate ACE_Svc_Handler<ACE_UPIPE_STREAM, ACE_NULL_SYNCH>
-#pragma instantiate ACE_Svc_Tuple<Client_Service>
-#pragma instantiate ACE_Thread_Strategy<Server_Service>
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */
-
-class Server : public ACE_Strategy_Acceptor <Server_Service, ACE_UPIPE_ACCEPTOR>
-{
-  // = TITLE
-  //     Defines the interface for a factory that accepts connections
-  //     and creates/activates Server_Service objects.
-public:
-  Server (ACE_Thread_Manager *thr_mgr,
-	  ACE_Reactor *reactor)
-    : reactor_ (reactor),
-      thr_mgr_ (thr_mgr)
-    {
-      ACE_TRACE ("Server::Server");
-    }
-
-  virtual int init (int argc, char *argv[])
-    {
-      ACE_TRACE ("Server::init");
-      const char *l_addr = argc > 1 ? argv[1] : ACE_DEFAULT_RENDEZVOUS;
-
-      ACE_UPIPE_Addr local_addr (l_addr);
-
-      if (this->thr_strategy_.open (this->thr_mgr_, THR_DETACHED | THR_NEW_LWP) == -1)
-	return -1;
-      else if (this->open (local_addr, this->reactor_,
-			   0, 0, &this->thr_strategy_) == -1)
-	return -1;
-
-      // Give server a chance to register the STREAM pipe.
-      ACE_OS::sleep (ACE_Time_Value (4));
-      return 0;
-    }
-
-private:
-  ACE_Reactor *reactor_;
-  // Our instance of the reactor.
-
-  ACE_Thread_Manager *thr_mgr_;
-  // Our instance of a thread manager.
-
-  ACE_Thread_Strategy<Server_Service> thr_strategy_;
-  // Our concurrency strategy.
-};
-
-class Client : public ACE_Connector <Client_Service, ACE_UPIPE_CONNECTOR>
-{
-  // = TITLE
-  //     Defines the interface for a factory that connects
-  //     a Client_Service with a Server.
-public:
-  Client (ACE_Thread_Manager *thr_mgr)
-    : thr_mgr_ (thr_mgr)
-    {
-      ACE_TRACE ("Client::Client");
-    }
-
-  virtual int init (int argc, char *argv[])
-  {
-    ACE_TRACE ("Client::init");
-
-    const char *r_addr = argc > 1 ? argv[1] : ACE_DEFAULT_RENDEZVOUS;
-
-    ACE_UPIPE_Addr remote_addr (r_addr);
-
-    Client_Service *cs;
-
-    ACE_NEW_RETURN (cs, Client_Service (this->thr_mgr_), -1);
-
-    return this->connect (cs, remote_addr);
-  }
-
-private:
-  ACE_Thread_Manager *thr_mgr_;
-};
-
-int 
-main (int argc, char *argv[])
-{
-  ACE_Service_Config svc_conf;
-  ACE_Thread_Manager thr_mgr;
-
-  Client peer_connector (&thr_mgr);
-  Server peer_acceptor (&thr_mgr, ACE_Reactor::instance ());
-
-  // Establish the connection between Acceptor and Connector.
-
-  if (peer_acceptor.init (argc, argv) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "init"), -1);
-  else if (peer_connector.init (argc, argv) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "init"), -1);
-
-  // Wait for threads to exit.
-  thr_mgr.wait ();
-  return 0;
-}
-#else
-int
-main (int, char *[])
-{
-  ACE_ERROR_RETURN ((LM_ERROR,
-                     "your platform does not support threads\n"),
-                    1);
-}
-#endif /* ACE_HAS_THREADS */