summaryrefslogtreecommitdiff
path: root/TAO/examples/Event_Comm
diff options
context:
space:
mode:
authornobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1999-02-15 19:18:27 +0000
committernobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>1999-02-15 19:18:27 +0000
commit8c3acf83c6ebdb83436580b7ce4d30b9bb067e9d (patch)
treed2e6d4a4a12a28acc83417dd1e1f99258656a90a /TAO/examples/Event_Comm
parentf0c2268cbafbbb544c3f29529f8f87a56d230287 (diff)
downloadATCD-ACE-4_6_22.tar.gz
This commit was manufactured by cvs2svn to create tag 'ACE-4_6_22'.ACE-4_6_22
Diffstat (limited to 'TAO/examples/Event_Comm')
-rw-r--r--TAO/examples/Event_Comm/Consumer.dsp191
-rw-r--r--TAO/examples/Event_Comm/Consumer_Handler.cpp155
-rw-r--r--TAO/examples/Event_Comm/Consumer_Handler.h93
-rw-r--r--TAO/examples/Event_Comm/Consumer_Input_Handler.cpp150
-rw-r--r--TAO/examples/Event_Comm/Consumer_Input_Handler.h71
-rw-r--r--TAO/examples/Event_Comm/Event_Comm.dsw53
-rw-r--r--TAO/examples/Event_Comm/Event_Comm.idl110
-rw-r--r--TAO/examples/Event_Comm/Event_Comm_i.cpp451
-rw-r--r--TAO/examples/Event_Comm/Event_Comm_i.h125
-rw-r--r--TAO/examples/Event_Comm/Makefile966
-rw-r--r--TAO/examples/Event_Comm/Notifier.dsp175
-rw-r--r--TAO/examples/Event_Comm/Notifier_Handler.cpp130
-rw-r--r--TAO/examples/Event_Comm/Notifier_Handler.h81
-rw-r--r--TAO/examples/Event_Comm/Notifier_Server.cpp146
-rw-r--r--TAO/examples/Event_Comm/Notifier_Server.h71
-rw-r--r--TAO/examples/Event_Comm/README97
-rw-r--r--TAO/examples/Event_Comm/Supplier.dsp191
-rw-r--r--TAO/examples/Event_Comm/Supplier_Input_Handler.cpp121
-rw-r--r--TAO/examples/Event_Comm/Supplier_Input_Handler.h65
-rw-r--r--TAO/examples/Event_Comm/consumer.cpp132
-rw-r--r--TAO/examples/Event_Comm/notifier.cpp71
-rw-r--r--TAO/examples/Event_Comm/notifier.h46
-rw-r--r--TAO/examples/Event_Comm/supplier.cpp85
-rw-r--r--TAO/examples/Event_Comm/supplier.h56
24 files changed, 0 insertions, 3832 deletions
diff --git a/TAO/examples/Event_Comm/Consumer.dsp b/TAO/examples/Event_Comm/Consumer.dsp
deleted file mode 100644
index 466ca55927d..00000000000
--- a/TAO/examples/Event_Comm/Consumer.dsp
+++ /dev/null
@@ -1,191 +0,0 @@
-# Microsoft Developer Studio Project File - Name="Consumer" - Package Owner=<4>
-# Microsoft Developer Studio Generated Build File, Format Version 5.00
-# ** DO NOT EDIT **
-
-# TARGTYPE "Win32 (x86) Console Application" 0x0103
-
-CFG=Consumer - 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 "Consumer.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 "Consumer.mak" CFG="Consumer - Win32 Debug"
-!MESSAGE
-!MESSAGE Possible choices for configuration are:
-!MESSAGE
-!MESSAGE "Consumer - Win32 Release" (based on\
- "Win32 (x86) Console Application")
-!MESSAGE "Consumer - Win32 Debug" (based on "Win32 (x86) Console Application")
-!MESSAGE
-
-# Begin Project
-# PROP Scc_ProjName ""
-# PROP Scc_LocalPath ""
-CPP=cl.exe
-RSC=rc.exe
-
-!IF "$(CFG)" == "Consumer - Win32 Release"
-
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 0
-# PROP BASE Output_Dir "Consumer"
-# PROP BASE Intermediate_Dir "Consumer"
-# PROP BASE Target_Dir ""
-# PROP Use_MFC 0
-# PROP Use_Debug_Libraries 0
-# PROP Output_Dir ""
-# PROP Intermediate_Dir "Release"
-# PROP Ignore_Export_Lib 0
-# PROP Target_Dir ""
-# ADD BASE CPP /nologo /W3 /GX /O2 /D "WIN32" /D "NDEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
-# ADD CPP /nologo /MD /W3 /GX /O2 /I "..\..\\" /I "..\..\..\\" /I "..\..\orbsvcs" /D "NDEBUG" /D "WIN32" /D "_CONSOLE" /FD /c
-# ADD BASE RSC /l 0x409 /d "NDEBUG"
-# ADD RSC /l 0x409 /d "NDEBUG"
-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 /machine:I386
-# ADD LINK32 ace.lib TAO.lib orbsvcs.lib /nologo /subsystem:console /pdb:"Release/client.pdb" /machine:I386 /out:"Release/Consumer.exe" /libpath:"..\..\tao" /libpath:"..\..\..\ace" /libpath:"..\..\orbsvcs\orbsvcs"
-# SUBTRACT LINK32 /pdb:none
-
-!ELSEIF "$(CFG)" == "Consumer - Win32 Debug"
-
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 1
-# PROP BASE Output_Dir "Consume0"
-# PROP BASE Intermediate_Dir "Consume0"
-# 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" /D "_MBCS" /YX /FD /c
-# ADD CPP /nologo /MDd /W3 /Gm /GX /Zi /Od /I "..\..\\" /I "..\..\..\\" /I "..\..\orbsvcs" /D "_DEBUG" /D "WIN32" /D "_CONSOLE" /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 /pdbtype:sept
-# ADD LINK32 aced.lib TAOd.lib orbsvcsd.lib /nologo /subsystem:console /pdb:"client.pdb" /debug /machine:I386 /libpath:"..\..\tao" /libpath:"..\..\..\ace" /libpath:"..\..\orbsvcs\orbsvcs"
-# SUBTRACT LINK32 /pdb:none
-
-!ENDIF
-
-# Begin Target
-
-# Name "Consumer - Win32 Release"
-# Name "Consumer - Win32 Debug"
-# Begin Group "Source"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\consumer.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Consumer_Handler.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Consumer_Input_Handler.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_Comm_i.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommC.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommS.cpp
-# End Source File
-# End Group
-# Begin Group "Header"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Consumer_Handler.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Consumer_Input_Handler.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_Comm_i.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommC.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommS.h
-# End Source File
-# End Group
-# Begin Group "IDL"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm.idl
-
-!IF "$(CFG)" == "Consumer - Win32 Release"
-
-!ELSEIF "$(CFG)" == "Consumer - Win32 Debug"
-
-# PROP Ignore_Default_Tool 1
-# Begin Custom Build - Invoking TAO_IDL Compiler
-InputPath=.\Event_Comm.idl
-InputName=Event_Comm
-
-BuildCmds= \
- tao_idl $(InputName).idl
-
-"$(InputName)C.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)C.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)C.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-# End Custom Build
-
-!ENDIF
-
-# End Source File
-# End Group
-# End Target
-# End Project
diff --git a/TAO/examples/Event_Comm/Consumer_Handler.cpp b/TAO/examples/Event_Comm/Consumer_Handler.cpp
deleted file mode 100644
index 215796c7dd7..00000000000
--- a/TAO/examples/Event_Comm/Consumer_Handler.cpp
+++ /dev/null
@@ -1,155 +0,0 @@
-// $Id$
-
-#include "Consumer_Handler.h"
-
-ACE_RCSID(Consumer, Consumer_Handler, "$Id$")
-
-Consumer_Handler::Consumer_Handler (void)
- : receiver_ (0),
- notifier_ (0),
- shutdowncallback (0)
-{
- // No-Op.
-}
-
-Consumer_Handler::~Consumer_Handler (void)
-{
- // No-Op.
-}
-
-int
-Consumer_Handler::init (int argc,
- char *argv[],
- ShutdownCallback *_shutdowncallback)
-{
- char *filtering_criteria = "";
-
- // First see if we have any environment variables.
- filtering_criteria =
- ACE_OS::getenv ("FILTERING_CRITERIA");
-
- // Then override these variables with command-line arguments if
- // necessary.
- filtering_criteria = argc > 1 ? argv[1] : "";
-
- ACE_TRY_NEW_ENV
- {
- // Retrieve the ORB.
- this->orb_ = CORBA::ORB_init (argc,
- argv,
- 0,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- // Save the Shutdown callback.
- this->shutdowncallback = _shutdowncallback;
- // Set the ShutdownCallback callback object
- // in the Consumer object implementation.
- this->receiver_i_.set (_shutdowncallback);
-
- // Start the servant.
- this->receiver_ =
- this->receiver_i_._this (ACE_TRY_ENV);
-
- ACE_TRY_CHECK;
-
- if (this->get_notifier () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- " (%P|%t) Unable to get the notifier "
- "the TAO_Naming_Client. \n"),
- -1);
-
- // Subscribe ourselves with the notifier's broker.
- this->notifier_->subscribe (this->receiver_,
- filtering_criteria,
- ACE_TRY_ENV);
- return 0;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Consumer_Handler::init\n");
- return -1;
- }
- ACE_ENDTRY;
- return 0;
-}
-
-int
-Consumer_Handler::get_notifier (void)
-{
- ACE_TRY_NEW_ENV
- {
- // Initialization of the naming service.
- if (naming_services_client_.init (orb_.in ()) != 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- " (%P|%t) Unable to initialize "
- "the TAO_Naming_Client. \n"),
- -1);
-
- CosNaming::Name notifier_ref_name (1);
- notifier_ref_name.length (1);
- notifier_ref_name[0].id = CORBA::string_dup (NOTIFIER_BIND_NAME);
-
- CORBA::Object_var notifier_obj =
- this->naming_services_client_->resolve (notifier_ref_name,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- // The CORBA::Object_var object is downcast to Notifier_var
- // using the <_narrow> method.
- this->notifier_ =
- Event_Comm::Notifier::_narrow (notifier_obj.in (),
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Consumer_Handler::get_notifier\n");
- return -1;
- }
- ACE_ENDTRY;
-
- return 0;
-}
-
-void
-Consumer_Handler::close (void)
-{
- this->orb_->shutdown ();
-}
-
-void
-Consumer_Handler::shutdown (void)
-{
- ACE_ASSERT (this->shutdowncallback != 0);
-
- this->shutdowncallback->close ();
-}
-
-int
-Consumer_Handler::run (void)
-{
- // Run the ORB.
- this->orb_->run ();
- return 0;
-}
-
-ACE_Reactor*
-Consumer_Handler::reactor(void)
-{
- // @@ Please see if there's a way to get to the Reactor without
- // using the TAO_ORB_Core_instance().
- return TAO_ORB_Core_instance ()->reactor ();
-}
-
-Event_Comm::Consumer *
-Consumer_Handler::receiver (void)
-{
- return this->receiver_;
-}
-
-Event_Comm::Notifier *
-Consumer_Handler::notifier (void)
-{
- return this->notifier_;
-}
diff --git a/TAO/examples/Event_Comm/Consumer_Handler.h b/TAO/examples/Event_Comm/Consumer_Handler.h
deleted file mode 100644
index 69219365550..00000000000
--- a/TAO/examples/Event_Comm/Consumer_Handler.h
+++ /dev/null
@@ -1,93 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Consumer_Handler.h
-//
-// = DESCRIPTION
-// Subclass of Corba_Handler that sets up the Consumer handler
-// for use with the ACE ACE_Reactor.
-//
-// = AUTHOR
-// Douglas C. Schmidt (schmidt@cs.wustl.edu) and Pradeep Gore
-// (pradeep@cs.wustl.edu)
-//
-// ============================================================================
-
-#ifndef _CONSUMER_HANDLER_H
-#define _CONSUMER_HANDLER_H
-
-#include "Event_Comm_i.h"
-#include "orbsvcs/Naming/Naming_Utils.h"
-#include "orbsvcs/CosNamingC.h"
-
-class Consumer_Handler
-{
- // = TITLE
- // The Consumer_Handler class.
- //
- // = DESCRIPTION
- // Starts up the ORB, registers the <Event_Comm::Consumer>
- // servant with the orb and gets a reference to a <Notifier>
- // from the Naming Service.
-public:
- // = Initialization and termination methods.
- Consumer_Handler (void);
- // Constructor.
-
- virtual ~Consumer_Handler (void);
- // Destructor.
-
- int init (int argc, char *argv[], ShutdownCallback *_shutdowncallback);
- // Initializes the ORB, gets the Notifier reference from the Naming
- // Service, and starts the servant for the Consumer object.
-
- int run (void);
- // runs the ORB.
-
- void close (void);
- // shutdown the orb.
-
- void shutdown (void);
- // called to shutdown the consumer application.
-
- // = Accessors
- Event_Comm::Consumer *receiver (void);
- Event_Comm::Notifier *notifier (void);
-
- ACE_Reactor *reactor (void);
- // returns the ORB's reactor.
-
-private:
- int get_notifier (void);
- // gets the notifier reference from the naming service.
- // returns 0 on success, -1 on error.
-
- Consumer_i receiver_i_;
- // The <Consumer> implementation.
-
- Event_Comm::Consumer_var receiver_;
- // Pointer to an IDL <Consumer> proxy object.
-
- Event_Comm::Notifier_var notifier_;
- // Pointer to an IDL <Notifier> proxy object.
-
- TAO_Naming_Client naming_services_client_;
- // An instance of the name client used for resolving the factory
- // objects.
-
- CORBA::ORB_var orb_;
- // Remember our orb.
-
- ShutdownCallback* shutdowncallback;
- // The Shutdown callback used to shutdown the consumer application.
-};
-
-#define NOTIFIER_BIND_NAME "Notifier"
-
-#endif /* _CONSUMER_HANDLER_H */
diff --git a/TAO/examples/Event_Comm/Consumer_Input_Handler.cpp b/TAO/examples/Event_Comm/Consumer_Input_Handler.cpp
deleted file mode 100644
index 94286df5850..00000000000
--- a/TAO/examples/Event_Comm/Consumer_Input_Handler.cpp
+++ /dev/null
@@ -1,150 +0,0 @@
-// $Id$
-
-#include "Consumer_Input_Handler.h"
-#include "Consumer_Handler.h"
-
-ACE_RCSID(Consumer, Consumer_Input_Handler, "$Id$")
-
-Consumer_Input_Handler::Consumer_Input_Handler (void)
- : receiver_handler_ (0),
- consumer_initiated_shutdown_ (0)
-{
- // No-Op.
-}
-
-Consumer_Input_Handler::~Consumer_Input_Handler (void)
-{
- // No-Op.
-}
-
-int
-Consumer_Input_Handler::consumer_initiated_shutdown (void)
-{
- return this->consumer_initiated_shutdown_;
-}
-
-void
-Consumer_Input_Handler::consumer_initiated_shutdown (int c)
-{
- this->consumer_initiated_shutdown_ = c;
-}
-
-int
-Consumer_Input_Handler::close (void)
-{
- ACE_DEBUG ((LM_DEBUG,
- "closing down Consumer::Input_Handler\n"));
-
- Event_Comm::Consumer *receiver =
- this->receiver_handler_->receiver ();
- Event_Comm::Notifier *notifier =
- this->receiver_handler_->notifier ();
-
- if (this->consumer_initiated_shutdown ())
- {
- // Only try to unsubscribe if the Consumer initiated the
- // shutdown. Otherwise, the Notifier initiated it and it has
- // probably gone away by now!
- ACE_TRY_NEW_ENV
- {
- // Gracefully shutdown the Receiver by removing it from the
- // Notifier's internal map.
-
- if (notifier != 0)
- notifier->unsubscribe (receiver,
- "",
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Consumer_Input_Handler::handle_close\n");
- }
- ACE_ENDTRY;
- }
-
- // Make sure to cleanup the STDIN handler.
- if (ACE_Event_Handler::remove_stdin_handler
- (TAO_ORB_Core_instance ()->reactor (),
- TAO_ORB_Core_instance ()->thr_mgr ()) == -1)
- ACE_ERROR ((LM_ERROR,
- "%p\n",
- "remove_stdin_handler"));
-
- return 0;
-}
-
-int Consumer_Input_Handler::initialize (Consumer_Handler *ch)
-{
- receiver_handler_ = ch;
-
- if (ACE_Event_Handler::register_stdin_handler
- (this,
- TAO_ORB_Core_instance ()->reactor (),
- TAO_ORB_Core_instance ()->thr_mgr ()) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_stdin_handler"),
- -1);
- return 0;
-}
-
-int
-Consumer_Input_Handler::handle_input (ACE_HANDLE h)
-{
- char buf[BUFSIZ];
-
- // Read up to BUFSIZ worth of data from ACE_HANDLE h.
- ssize_t n = ACE_OS::read (h, buf, sizeof buf - 1);
-
- if (n > 0)
- {
- // Null terminate the buffer, replacing the '\n' with '\0'.
- if (buf[n - 1] == '\n' || buf[n - 1] == EOF)
- buf[n - 1] = '\0';
- else
- buf[n] = '\0';
- ACE_DEBUG ((LM_DEBUG,
- "notifying for event %s\n",
- buf));
- }
- else
- {
- // If nothing is read, do nothing.
- return 0;
- }
-
- Event_Comm::Notifier *notifier =
- this->receiver_handler_->notifier ();
-
- ACE_ASSERT (notifier != 0);
-
- if (ACE_OS::strncmp (buf, "quit", 4) == 0)
- {
- // Consumer wants to shutdown.
- this->consumer_initiated_shutdown (1);
-
- // Tell the main event loop to shutdown.
- this->receiver_handler_->shutdown ();
- }
- else
- {
- ACE_TRY_NEW_ENV
- {
- Event_Comm::Event event;
-
- event.tag_ = ACE_OS::strdup (buf);
-
- notifier->push (event, ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception("Unexpected exception\n");
- }
- ACE_ENDTRY;
- }
-
- /* NOTREACHED */
- return 0;
-}
diff --git a/TAO/examples/Event_Comm/Consumer_Input_Handler.h b/TAO/examples/Event_Comm/Consumer_Input_Handler.h
deleted file mode 100644
index c4325081fbb..00000000000
--- a/TAO/examples/Event_Comm/Consumer_Input_Handler.h
+++ /dev/null
@@ -1,71 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Consumer_Input_Handler.h
-//
-// = AUTHOR
-// Douglas C. Schmidt (schmidt@cs.wustl.edu)
-//
-// ============================================================================
-
-#ifndef CONSUMER_INPUT_HANDLER_H
-#define CONSUMER_INPUT_HANDLER_
-
-#include "ace/Service_Config.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-// Forward declaration.
-class Consumer_Handler;
-
-class Consumer_Input_Handler : public ACE_Event_Handler
-{
- // = TITLE
- // Handles input events generated from a keyboard.
- //
- // = DESCRIPTION
- // This class holds a <Consumer_Handler> object. It accepts input
- // from the user and passes events to the <Notifier>. It also
- // initiates shutdown.
-public:
- // Initialization and termination methods.
- Consumer_Input_Handler(void);
- // Constructor.
-
- ~Consumer_Input_Handler (void);
- // Destructor.
-
- int initialize (Consumer_Handler *);
- // registers the input event handler.
- // returns 0 on success, -1 on error.
-
- virtual int handle_input (ACE_HANDLE);
- // Dispatch the callback when events occur.
-
- int close (void);
- // Close down the handler.
-
- int consumer_initiated_shutdown (void);
- // Report whether the Consumer initiated the shutdown.
-
- void consumer_initiated_shutdown (int);
- // Indicate that the Consumer initiated the shutdown.
-
-private:
- Consumer_Handler *receiver_handler_;
- // Pointer to the <Consumer_Handler> that receives notifications
- // from the <Event_Comm::Notifier>.
-
- int consumer_initiated_shutdown_;
- // Keep track of whether the Consumer initiated the shutdown.
-};
-
-#endif /* CONSUMER_INPUT_HANDLER_H */
diff --git a/TAO/examples/Event_Comm/Event_Comm.dsw b/TAO/examples/Event_Comm/Event_Comm.dsw
deleted file mode 100644
index 580d27aecee..00000000000
--- a/TAO/examples/Event_Comm/Event_Comm.dsw
+++ /dev/null
@@ -1,53 +0,0 @@
-Microsoft Developer Studio Workspace File, Format Version 5.00
-# WARNING: DO NOT EDIT OR DELETE THIS WORKSPACE FILE!
-
-###############################################################################
-
-Project: "Consumer"=.\Consumer.dsp - Package Owner=<4>
-
-Package=<5>
-{{{
-}}}
-
-Package=<4>
-{{{
-}}}
-
-###############################################################################
-
-Project: "Notifier"=.\Notifier.dsp - Package Owner=<4>
-
-Package=<5>
-{{{
-}}}
-
-Package=<4>
-{{{
-}}}
-
-###############################################################################
-
-Project: "Supplier"=.\Supplier.dsp - Package Owner=<4>
-
-Package=<5>
-{{{
-}}}
-
-Package=<4>
-{{{
-}}}
-
-###############################################################################
-
-Global:
-
-Package=<5>
-{{{
-}}}
-
-Package=<3>
-{{{
-}}}
-
-###############################################################################
-
diff --git a/TAO/examples/Event_Comm/Event_Comm.idl b/TAO/examples/Event_Comm/Event_Comm.idl
deleted file mode 100644
index 5c04344ea9a..00000000000
--- a/TAO/examples/Event_Comm/Event_Comm.idl
+++ /dev/null
@@ -1,110 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Event_Comm.idl
-//
-// = DESCRIPTION
-// The CORBA IDL module for distributed event notification.
-//
-// = AUTHOR
-// Douglas C. Schmidt (schmidt@cs.wustl.edu) and
-// Pradeep Gore (pradeep@cs.wustl.edu)
-//
-// ============================================================================
-
-#if !defined (_EVENT_COMM_IDL)
-#define _EVENT_COMM_IDL
-
-module Event_Comm
-{
- // = TITLE
- // The CORBA IDL module for distributed event notification.
-
- struct Event
- {
- // = TITLE
- // Defines the interface for an event <Event>.
- //
- // = DESCRIPTION
- // This is the type passed by the Notifier to the Consumer.
- // Since it contains an <any>, it can hold any type. Naturally,
- // the consumer must understand how to interpret this!
-
- string tag_;
- // Tag for the event. This is used by the <Notifier> to compare
- // with the <Consumer>s' filtering criteria.
-
- any value_;
- // An event can contain anything.
-
- Object object_ref_;
- // Object reference for callbacks.
- };
-
- interface Consumer
- {
- // = TITLE
- // Defines the interface for a <Consumer> of events.
-
- void push (in Event event);
- // Inform the <Consumer> that <event> has occurred.
-
- void disconnect (in string reason);
- // Disconnect the <Consumer> from the <Notifier>,
- // giving it the <reason>.
- };
-
- interface Notifier
- {
- // = TITLE
- // Defines the interface for a <Notifier> of events.
-
- exception CannotSubscribe
- {
- // = TITLE
- // This exception in thrown when a <subscribe> fails.
-
- string reason_;
- };
-
- exception CannotUnsubscribe
- {
- // = TITLE
- // This exception in thrown when a <unsubscribe> fails.
-
- string reason_;
- };
-
- // = The following operations are intended for Suppliers.
-
- void disconnect (in string reason);
- // Disconnect all the receivers, giving them the <reason>.
-
- void push (in Event event);
- // Send the <event> to all the consumers who have subscribed and
- // who match the filtering criteria.
-
- // = The following operations are intended for Consumers.
-
- void subscribe (in Consumer Consumer,
- in string filtering_criteria);
- // Subscribe the <Consumer> to receive events that match the
- // regular expresssion <filtering_criteria> applied by the
- // <Notifier>. If <filtering_criteria> is "" then all events are
- // matched.
-
- void unsubscribe (in Consumer Consumer,
- in string filtering_criteria);
- // Unsubscribe the <Consumer> that matches the filtering criteria.
- // If <filtering_criteria> is "" then all <Consumers> with the
- // matching object reference are removed.
- };
-};
-
-#endif /* _EVENT_COMM_IDL */
diff --git a/TAO/examples/Event_Comm/Event_Comm_i.cpp b/TAO/examples/Event_Comm/Event_Comm_i.cpp
deleted file mode 100644
index 6d6ebdf013c..00000000000
--- a/TAO/examples/Event_Comm/Event_Comm_i.cpp
+++ /dev/null
@@ -1,451 +0,0 @@
-// $Id$
-
-#include "Event_Comm_i.h"
-
-ACE_RCSID(Event_Comm, Event_Comm_i, "$Id$")
-
-class Consumer_Entry
-{
- // = TITLE
- // Keeps track of context information associated with
- // a <Event_Comm::Consumer> entry.
-public:
- // = Initialization and termination methods.
- Consumer_Entry (Event_Comm::Consumer *consumer,
- const char *filtering_criteria);
- // Constructor.
-
- ~Consumer_Entry (void);
- // Descriptor.
-
- // = Set/get filtering criteria.
- void criteria (const char *criteria);
- const char *criteria (void);
-
- // = Set/get Event_Comm::Consumer object reference.
- Event_Comm::Consumer *consumer (void);
- void consumer (Event_Comm::Consumer *);
-
- // = Set/get the compiled regular expression buffer.
- const char *regexp (void);
- void regexp (char *);
-
-private:
- const char *filtering_criteria_;
- // String containing the filtering criteria.
-
- char *compiled_regexp_;
- // Compiled representation of the regular expression (see
- // regexpr(3g)).
-
- Event_Comm::Consumer_ptr consumer_;
- // Object reference for the <Event_Comm::Consumer>.
-};
-
-// = Set/get filtering criteria.
-
-void
-Consumer_Entry::criteria (const char *criteria)
-{
- ACE_OS::free ((void *) this->filtering_criteria_);
- ACE_ALLOCATOR (this->filtering_criteria_,
- ACE_OS::strdup (criteria));
-}
-
-const char *
-Consumer_Entry::criteria (void)
-{
- return this->filtering_criteria_;
-}
-
-// = Set/get Event_Comm::Consumer object reference.
-
-Event_Comm::Consumer *
-Consumer_Entry::consumer (void)
-{
- return this->consumer_;
-}
-
-void
-Consumer_Entry::consumer (Event_Comm::Consumer *consumer)
-{
- this->consumer_ = consumer;
-}
-
-const char *
-Consumer_Entry::regexp (void)
-{
- return this->compiled_regexp_;
-}
-
-void
-Consumer_Entry::regexp (char *regexp)
-{
- ACE_OS::free ((void *) this->compiled_regexp_);
- this->compiled_regexp_ = regexp;
-}
-
-Consumer_Entry::Consumer_Entry (Event_Comm::Consumer *consumer,
- const char *filtering_criteria)
- : filtering_criteria_ (0),
- compiled_regexp_ (0),
- consumer_ (consumer)
-{
- char *compile_buffer = 0;
-
- this->criteria (filtering_criteria);
- ACE_ASSERT (this->criteria ());
-
- // Check for wildcard case first.
- if (ACE_OS::strcmp (filtering_criteria, "") == 0)
- ACE_ALLOCATOR (compile_buffer,
- ACE_OS::strdup (""));
- else
- {
-#if defined (ACE_HAS_REGEX)
- // Compile the regular expression (the 0's cause ACE_OS::compile
- // to allocate space).
- compile_buffer = ACE_OS::compile (filtering_criteria, 0, 0);
-#else
- // Win32 does not support regular expression functions such as compile.
- ACE_ALLOCATOR (compile_buffer,
- ACE_OS::strdup (""));
-#endif // #if defined (ACE_HAS_REGEX)
- }
-
- // Should throw an exception here!
- ACE_ASSERT (compile_buffer != 0);
-
- this->regexp (compile_buffer);
- ACE_ASSERT (this->regexp () != 0);
-
- // Increment the reference count since we are keeping a copy of
- // this...
- this->consumer_ = Event_Comm::Consumer::_duplicate (this->consumer_);
-}
-
-Consumer_Entry::~Consumer_Entry (void)
-{
- ACE_OS::free ((void *) this->filtering_criteria_);
- ACE_OS::free ((void *) this->compiled_regexp_);
- // Decrement the object reference count.
- CORBA::release (this->consumer_);
-}
-
-Notifier_i::Notifier_i (size_t size)
- : map_ (size)
-{
-// if platforms (such as win32) do not support the REGEXP functions
-// such as <compile> and <step> then warn the user that the regular
-// expression feature is not available.
-#ifndef ACE_HAS_REGEX
- ACE_DEBUG ((LM_DEBUG, "\n WARNING: This platform does not support \
-the functions for regular expressions.\n\
-The filtering criteria will not work.\n"));
-#endif //#ifndef ACE_HAS_REGEX
-}
-
-// Add a new consumer to the table, being careful to check for
-// duplicate entries. A consumer is considered a duplicate under the
-// following circumstances:
-//
-// 1. It has the same object reference and the same filtering
-// criteria.
-// 2. It has the same object reference and its filtering criteria is
-// "" (the wild card).
-
-void
-Notifier_i::subscribe (Event_Comm::Consumer_ptr consumer_ref,
- const char *filtering_criteria,
- CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_DEBUG ((LM_DEBUG,
- "in Notifier_i::subscribe for %x with filtering criteria \"%s\"\n",
- consumer_ref,
- filtering_criteria));
-
- MAP_ITERATOR mi (this->map_);
-
- // Try to locate an entry checking if the object references are
- // equivalent. If we don't find the entry, or if the filtering
- // criteria is different that is good news since we currently don't
- // allow duplicates... @@ Should duplicates be allowed?
-
- for (MAP_ENTRY *me = 0; mi.next (me) != 0; mi.advance ())
- {
- Consumer_Entry *nr_entry = me->int_id_;
-
- // The <_is_equivalent> function checks if objects are the same.
- // NOTE: this call might not behave well on other ORBs since
- // <_is_equivalent> isn't guaranteed to differentiate object
- // references.
-
- // Check for a duplicate entry.
- if (consumer_ref->_is_equivalent (me->ext_id_)
- && (ACE_OS::strcmp (filtering_criteria,
- "") == 0
- || ACE_OS::strcmp (filtering_criteria,
- nr_entry->criteria ()) == 0))
- {
- // Inform the caller that the <Event_Comm::Consumer> * is
- // already being used.
-
- ACE_TRY_ENV.exception (new Event_Comm::Notifier::CannotSubscribe
- ("Duplicate consumer and filtering criteria found.\n"));
- return;
- }
- }
-
- // If we get this far then we didn't find a duplicate, so add the
- // new entry!
- Consumer_Entry *nr_entry;
- ACE_NEW (nr_entry,
- Consumer_Entry (consumer_ref,
- filtering_criteria));
-
- // Try to add new <Consumer_Entry> to the map.
- if (this->map_.bind (nr_entry->consumer(), nr_entry) == -1)
- {
- // Prevent memory leaks.
- delete nr_entry;
- ACE_TRY_ENV.exception (new Event_Comm::Notifier::CannotSubscribe
- ("Failed to add Consumer to internal map\n"));
- }
-}
-
-// Remove a consumer from the table.
-
-void
-Notifier_i::unsubscribe (Event_Comm::Consumer_ptr consumer_ref,
- const char *filtering_criteria,
- CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_DEBUG ((LM_DEBUG,
- "in Notifier_i::unsubscribe for %x\n",
- consumer_ref));
-
- Consumer_Entry *nr_entry = 0;
- MAP_ITERATOR mi (this->map_);
- int found = 0;
-
- // Locate <Consumer_Entry> and free up resources. @@ Note, we don't
- // properly handle deallocation of KEYS!
-
- for (MAP_ENTRY *me = 0;
- mi.next (me) != 0;
- mi.advance ())
- {
- Consumer_Entry *nr_entry = me->int_id_;
-
- // The <_is_equivalent> function checks if objects are the same.
- // NOTE: this call might not behave well on other ORBs since
- // <_is_equivalent> isn't guaranteed to differentiate object
- // references.
-
- // Look for a match ..
- if (consumer_ref->_is_equivalent (me->ext_id_)
- && (ACE_OS::strcmp (filtering_criteria, "") == 0
- || ACE_OS::strcmp (filtering_criteria,
- nr_entry->criteria ()) == 0))
- {
- ACE_DEBUG ((LM_DEBUG,
- "removed entry %x with criteria \"%s\"\n",
- consumer_ref,
- filtering_criteria));
- found = 1;
- // @@ This is a hack, we need a better approach!
- if (this->map_.unbind (me->ext_id_,
- nr_entry) == -1)
- ACE_TRY_ENV.exception (new Event_Comm::Notifier::CannotUnsubscribe
- ("Internal map unbind failed."));
- else
- delete nr_entry;
- }
- }
-
- if (found == 0)
- ACE_TRY_ENV.exception (new Event_Comm::Notifier::CannotUnsubscribe
- ("The Consumer and filtering criteria were not found."));
-}
-
-// Disconnect all the consumers, giving them the <reason>.
-
-void
-Notifier_i::disconnect (const char *reason,
- CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_DEBUG ((LM_DEBUG,
- "in Notifier_i::send_disconnect = %s\n",
- reason));
-
- MAP_ITERATOR mi (this->map_);
- int count = 0;
-
- // Notify all the consumers, taking into account the filtering
- // criteria.
-
- for (MAP_ENTRY *me = 0;
- mi.next (me) != 0;
- mi.advance ())
- {
- Event_Comm::Consumer_ptr consumer_ref =
- me->ext_id_;
-
- ACE_ASSERT (consumer_ref != 0);
- ACE_DEBUG ((LM_DEBUG,
- "disconnecting client %x\n",
- consumer_ref));
- ACE_TRY
- {
- consumer_ref->disconnect (reason,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Unexpected exception\n");
- }
- ACE_ENDTRY;
-
- delete me->int_id_;
- count++;
- }
-
- this->map_.close ();
-
- if (count == 1)
- ACE_DEBUG ((LM_DEBUG,
- "there was 1 consumer\n"));
- else
- ACE_DEBUG ((LM_DEBUG,
- "there were %d consumers\n",
- count));
-}
-
-// Notify all consumers whose filtering criteria match the event.
-
-void
-Notifier_i::push (const Event_Comm::Event &event,
- CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_DEBUG ((LM_DEBUG,
- "in Notifier_i::send_notification = %s\n",
- (const char *) event.tag_));
- MAP_ITERATOR mi (this->map_);
- int count = 0;
-
- // Notify all the consumers.
-
- for (MAP_ENTRY *me = 0; mi.next (me) != 0; mi.advance ())
- {
- Event_Comm::Consumer_ptr consumer_ref = me->int_id_->consumer ();
- ACE_ASSERT (consumer_ref != 0);
- char *regexp = ACE_const_cast (char *, me->int_id_->regexp ());
- ACE_ASSERT (regexp);
- const char *criteria = me->int_id_->criteria ();
- ACE_ASSERT (criteria);
-
-#if defined (ACE_HAS_REGEX)
- // Do a regular expression comparison to determine matching.
- if (ACE_OS::strcmp ("", criteria) == 0 // Everything matches the wildcard.
- || ACE_OS::step (event.tag_, regexp) != 0)
-#endif // #if defined (ACE_HAS_REGEX)
- // if ACE_HAS_REGEX has not been defined,
- // let everything through.
- {
- ACE_DEBUG ((LM_DEBUG,
- "string %s matched regexp \"%s\" for client %x\n",
- (const char *) event.tag_,
- me->int_id_->criteria (),
- consumer_ref));
- ACE_TRY
- {
- consumer_ref->push (event,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Unexpected exception\n");
- continue;
- }
- ACE_ENDTRY;
- count++;
- }
- }
-
- if (count == 1)
- ACE_DEBUG ((LM_DEBUG,
- "there was 1 consumer\n"));
- else
- ACE_DEBUG ((LM_DEBUG,
- "there were %d consumers\n",
- count));
-}
-
-Consumer_i::Consumer_i (void)
- : shutdown (0)
-{
-}
-
-Consumer_i::~Consumer_i (void)
-{
-}
-
-// Inform the <Event_Comm::Consumer> that <event> has
-// occurred.
-
-void
-Consumer_i::push (const Event_Comm::Event &event,
- CORBA::Environment &ACE_TRY_ENV)
-{
- const char *tmpstr = event.tag_;
-
- ACE_DEBUG ((LM_DEBUG,
- "**** got notification = %s\n",
- tmpstr));
-}
-
-// Disconnect the <Event_Comm::Consumer> from the
-// <Event_Comm::Notifier>.
-
-void
-Consumer_i::disconnect (const char *reason,
- CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_DEBUG ((LM_DEBUG,
- "**** got disconnected due to %s\n",
- reason));
-
- ACE_ASSERT (shutdown != 0);
-
- shutdown->close ();
-}
-
-void
-Consumer_i::set (ShutdownCallback *_shutdown)
-{
- shutdown = _shutdown;
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-
-template class ACE_Map_Manager<Event_Comm::Consumer *,
- Consumer_Entry *, ACE_Null_Mutex>;
-template class ACE_Map_Iterator<Event_Comm::Consumer *, Consumer_Entry *,
- ACE_Null_Mutex>;
-template class ACE_Map_Entry<Event_Comm::Consumer *, Consumer_Entry *>;
-template class ACE_Map_Reverse_Iterator<Event_Comm::Consumer *,
- Consumer_Entry *, ACE_Null_Mutex>;
-template class ACE_Map_Iterator_Base<Event_Comm::Consumer *,
- Consumer_Entry *, ACE_Null_Mutex>;
-
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-
-#pragma instantiate ACE_Map_Manager<Event_Comm::Consumer *, Consumer_Entry *, ACE_Null_Mutex>
-#pragma instantiate ACE_Map_Iterator<Event_Comm::Consumer *, Consumer_Entry *, ACE_Null_Mutex>
-#pragma instantiate ACE_Map_Entry<Event_Comm::Consumer *, Consumer_Entry *>
-#pragma instantiate ACE_Map_Reverse_Iterator<Event_Comm::Consumer *, Consumer_Entry *, ACE_Null_Mutex>
-#pragma instantiate ACE_Map_Iterator_Base<Event_Comm::Consumer *, Consumer_Entry *, ACE_Null_Mutex>
-
-#endif /* ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA */
diff --git a/TAO/examples/Event_Comm/Event_Comm_i.h b/TAO/examples/Event_Comm/Event_Comm_i.h
deleted file mode 100644
index 9935711ba4f..00000000000
--- a/TAO/examples/Event_Comm/Event_Comm_i.h
+++ /dev/null
@@ -1,125 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Event_Comm_i.h
-//
-// = DESCRIPTION
-// Class interface for the implementation of the distributed
-// event notification mechanism.
-//
-// = AUTHOR
-// Douglas C. Schmidt (schmidt@cs.wustl.edu) and Pradeep Gore
-// <pradeep@cs.wustl.edu>
-//
-// ============================================================================
-
-#ifndef _EVENT_COMM_I_H
-#define _EVENT_COMM_I_H
-
-#include "ace/Map_Manager.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "ace/Synch.h"
-#include "ace/SString.h"
-#include "Event_CommS.h"
-
-class ShutdownCallback
-{
- // = TITLE
- // Helper callback class to shutdown the application.
-public:
- virtual void close (void) = 0;
- // This method is to be called to shutdown the application.
-};
-
-class Consumer_i : public POA_Event_Comm::Consumer
-{
- // = TITLE
- // Defines the implementation class for event <Consumers>.
-public:
- // = Initialization and termination methods.
- Consumer_i (void);
- // Constructor.
-
- ~Consumer_i (void);
- // Destructor.
-
- void set_reactor (ACE_Reactor *reactor);
- // set the <ACE_Reactor> to use when quitting.
-
- virtual void push (const Event_Comm::Event & event,
- CORBA::Environment &TAO_TRY_ENV);
- // Pass the <event> to the <Consumer>.
-
- virtual void disconnect (const char * reason,
- CORBA::Environment &TAO_TRY_ENV);
- // Disconnect the <Consumer> from the <Notifier>, giving it the
- // <reason>.
-
- void set (ShutdownCallback *_shutdown);
- // Set the Shutdown callback.
-
-private:
- ShutdownCallback *shutdown;
- // The callback to shutdown the consumer application.
-};
-
-// Forward reference.
-class Consumer_Entry;
-
-class Notifier_i : public POA_Event_Comm::Notifier
-{
- // = TITLE
- // Defines the implementation class for event <Notifiers>.
-public:
- enum
- {
- DEFAULT_SIZE = 1024
- // Default max number of Event_Comm::Consumers.
- };
-
- Notifier_i (size_t size_hint = Notifier_i::DEFAULT_SIZE);
- // Initialize a Notifier_i object with the specified size hint.
-
- virtual void disconnect (const char *reason,
- CORBA::Environment &TAO_TRY_ENV);
- // Disconnect all the receivers, giving them the <reason>.
-
- virtual void push (const Event_Comm::Event &event,
- CORBA::Environment &TAO_TRY_ENV);
- // Send the <event> to all the consumers who have subscribed and who
- // match the filtering criteria.
-
- virtual void subscribe (Event_Comm::Consumer_ptr Consumer,
- const char * filtering_criteria,
- CORBA::Environment &TAO_TRY_ENV);
- // Subscribe the <Consumer> to receive events that match
- // <filtering_criteria> applied by the <Notifier>.
-
- void unsubscribe (Event_Comm::Consumer *consumer,
- const char *filtering_criteria,
- CORBA::Environment &TAO_TRY_ENV);
- // Unsubscribe the <Consumer>.
-
-private:
- typedef ACE_Map_Manager <Event_Comm::Consumer_ptr, Consumer_Entry *, ACE_Null_Mutex>
- MAP_MANAGER;
- typedef ACE_Map_Iterator <Event_Comm::Consumer_ptr, Consumer_Entry *, ACE_Null_Mutex>
- MAP_ITERATOR;
- typedef ACE_Map_Entry <Event_Comm::Consumer_ptr, Consumer_Entry *>
- MAP_ENTRY;
-
- MAP_MANAGER map_;
- // Table that maps a <Event_Comm::Consumer *> to a <Consumer_Entry *>.
-};
-
-#endif /* _EVENT_COMM_I_H */
diff --git a/TAO/examples/Event_Comm/Makefile b/TAO/examples/Event_Comm/Makefile
deleted file mode 100644
index ebb7924422c..00000000000
--- a/TAO/examples/Event_Comm/Makefile
+++ /dev/null
@@ -1,966 +0,0 @@
-#----------------------------------------------------------------------------
-#
-# $Id$
-#
-#----------------------------------------------------------------------------
-
-#----------------------------------------------------------------------------
-# Local macros
-#----------------------------------------------------------------------------
-
-ifndef TAO_ROOT
- TAO_ROOT = $(ACE_ROOT)/TAO
-endif # ! TAO_ROOT
-
-LDLIBS = -lorbsvcs -lTAO
-PROG_SRCS = Consumer_Handler.cpp \
- Consumer_Input_Handler.cpp \
- Event_Comm_i.cpp \
- Notifier_Handler.cpp \
- Supplier_Input_Handler.cpp \
- consumer.cpp \
- notifier.cpp \
- supplier.cpp \
- Notifier_Server.cpp
-
-IDL_SRC = Event_CommS.cpp Event_CommC.cpp
-
-LSRC = $(IDL_SRC) $(PROG_SRCS)
-
-CONSUMER_OBJS = Event_CommC.o \
- Event_CommS.o \
- Consumer_Handler.o \
- Consumer_Input_Handler.o \
- Event_Comm_i.o \
- consumer.o
-
-SUPPLIER_OBJS = Event_CommC.o \
- Event_CommS.o \
- Supplier_Input_Handler.o \
- Event_Comm_i.o \
- Notifier_Handler.o \
- supplier.o
-
-NOTIFIER_OBJS = Event_CommC.o \
- Event_CommS.o \
- Notifier_Server.o \
- Event_Comm_i.o \
- notifier.o
-
-BIN = supplier \
- notifier \
- consumer
-
-BUILD = $(BIN)
-VLDLIBS = $(LDLIBS:%=%$(VAR))
-VBIN = $(BIN:%=%$(VAR))
-
-#----------------------------------------------------------------------------
-# Include macros and targets
-#----------------------------------------------------------------------------
-
-include $(ACE_ROOT)/include/makeinclude/wrapper_macros.GNU
-
-ifeq ($(ACE_HAS_GNUG_PRE_2_8),1)
-
- # Since older g++ cannot handle nested classes properly, this sample
- # will not build on g++ prior to 2.8.0.
- all clean realclean:
- @echo Event_Comm is not built with older versions of g++
-
-else # ! ACE_HAS_GNUG_PRE_2_8
-
-include $(ACE_ROOT)/include/makeinclude/macros.GNU
-include $(TAO_ROOT)/rules.tao.GNU
-include $(ACE_ROOT)/include/makeinclude/rules.common.GNU
-include $(ACE_ROOT)/include/makeinclude/rules.nonested.GNU
-include $(ACE_ROOT)/include/makeinclude/rules.local.GNU
-include $(TAO_ROOT)/taoconfig.mk
-
-#----------------------------------------------------------------------------
-# Local targets
-#----------------------------------------------------------------------------
-
-LDFLAGS += -L$(TAO_ROOT)/orbsvcs/orbsvcs -L$(TAO_ROOT)/tao -L$(TAO_ROOT)/orbsvcs/Naming_Service
-CPPFLAGS += -I$(TAO_ROOT)/orbsvcs
-
-.PRECIOUS: Event_CommC.cpp Event_CommS.cpp Event_CommC.h Event_CommS.h
-#$(IDL_SRC): event.idl
-# $(TAO_ROOT)/TAO_IDL/tao_idl cubit.idl
-
-supplier: $(addprefix $(VDIR),$(SUPPLIER_OBJS))
- $(LINK.cc) $(LDFLAGS) -o $@ $^ $(VLDLIBS) $(POSTLINK)
-
-consumer: $(addprefix $(VDIR),$(CONSUMER_OBJS))
- $(LINK.cc) $(LDFLAGS) -o $@ $^ $(VLDLIBS) $(POSTLINK)
-
-notifier: $(addprefix $(VDIR),$(NOTIFIER_OBJS))
- $(LINK.cc) $(LDFLAGS) -o $@ $^ $(VLDLIBS) $(POSTLINK)
-
-realclean: clean
- -/bin/rm -rf Event_CommS.* Event_CommC.* Event_CommS_T.*
-
-endif # ! ACE_HAS_GNUG_PRE_2_8
-
-# DO NOT DELETE THIS LINE -- g++dep uses it.
-# DO NOT PUT ANYTHING AFTER THIS LINE, IT WILL GO AWAY.
-
-.obj/Event_CommS.o .obj/Event_CommS.so .shobj/Event_CommS.o .shobj/Event_CommS.so: Event_CommS.cpp Event_CommS.h Event_CommC.h \
- Event_CommC.i Event_CommS_T.h Event_CommS_T.i Event_CommS_T.cpp \
- Event_CommS.i
-.obj/Event_CommC.o .obj/Event_CommC.so .shobj/Event_CommC.o .shobj/Event_CommC.so: Event_CommC.cpp Event_CommC.h Event_CommC.i \
- Event_CommS.h Event_CommS_T.h Event_CommS_T.i Event_CommS_T.cpp \
- Event_CommS.i
-.obj/Consumer_Handler.o .obj/Consumer_Handler.so .shobj/Consumer_Handler.o .shobj/Consumer_Handler.so: Consumer_Handler.cpp Consumer_Handler.h \
- Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(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/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h
-.obj/Consumer_Input_Handler.o .obj/Consumer_Input_Handler.so .shobj/Consumer_Input_Handler.o .shobj/Consumer_Input_Handler.so: Consumer_Input_Handler.cpp \
- Consumer_Input_Handler.h \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.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/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Consumer_Handler.h Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h
-.obj/Event_Comm_i.o .obj/Event_Comm_i.so .shobj/Event_Comm_i.o .shobj/Event_Comm_i.so: Event_Comm_i.cpp Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(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/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i
-.obj/Notifier_Handler.o .obj/Notifier_Handler.so .shobj/Notifier_Handler.o .shobj/Notifier_Handler.so: Notifier_Handler.cpp Notifier_Handler.h \
- $(ACE_ROOT)/ace/CORBA_Handler.h \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.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/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- $(ACE_ROOT)/ace/Pipe.h \
- $(ACE_ROOT)/ace/Pipe.i \
- Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h
-.obj/Supplier_Input_Handler.o .obj/Supplier_Input_Handler.so .shobj/Supplier_Input_Handler.o .shobj/Supplier_Input_Handler.so: Supplier_Input_Handler.cpp Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(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/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i Notifier_Handler.h \
- $(ACE_ROOT)/ace/CORBA_Handler.h \
- $(ACE_ROOT)/ace/Pipe.h \
- $(ACE_ROOT)/ace/Pipe.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h \
- Supplier_Input_Handler.h
-.obj/consumer.o .obj/consumer.so .shobj/consumer.o .shobj/consumer.so: consumer.cpp Consumer_Handler.h Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(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/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h \
- Consumer_Input_Handler.h
-.obj/notifier.o .obj/notifier.so .shobj/notifier.o .shobj/notifier.so: notifier.cpp Notifier_Server.h Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(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/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/tao/TAO.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h \
- notifier.h
-.obj/supplier.o .obj/supplier.so .shobj/supplier.o .shobj/supplier.so: supplier.cpp Notifier_Handler.h \
- $(ACE_ROOT)/ace/CORBA_Handler.h \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.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/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(ACE_ROOT)/ace/Trace.h \
- $(ACE_ROOT)/ace/Log_Msg.h \
- $(ACE_ROOT)/ace/Log_Record.h \
- $(ACE_ROOT)/ace/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.i \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- $(ACE_ROOT)/ace/Pipe.h \
- $(ACE_ROOT)/ace/Pipe.i \
- Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h \
- Supplier_Input_Handler.h supplier.h
-.obj/Notifier_Server.o .obj/Notifier_Server.so .shobj/Notifier_Server.o .shobj/Notifier_Server.so: Notifier_Server.cpp Notifier_Server.h \
- Event_Comm_i.h \
- $(ACE_ROOT)/ace/Map_Manager.h \
- $(ACE_ROOT)/ace/OS.h \
- $(ACE_ROOT)/ace/inc_user_config.h \
- $(ACE_ROOT)/ace/config.h \
- $(ACE_ROOT)/ace/config-g++-common.h \
- $(ACE_ROOT)/ace/streams.h \
- $(ACE_ROOT)/ace/Basic_Types.h \
- $(ACE_ROOT)/ace/Basic_Types.i \
- $(ACE_ROOT)/ace/OS.i \
- $(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/ACE.i \
- $(ACE_ROOT)/ace/Log_Priority.h \
- $(ACE_ROOT)/ace/SString.h \
- $(ACE_ROOT)/ace/SString.i \
- $(ACE_ROOT)/ace/Malloc_Base.h \
- $(ACE_ROOT)/ace/Log_Record.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.i \
- $(ACE_ROOT)/ace/Synch_T.h \
- $(ACE_ROOT)/ace/Event_Handler.h \
- $(ACE_ROOT)/ace/Event_Handler.i \
- $(ACE_ROOT)/ace/Synch_T.i \
- $(ACE_ROOT)/ace/Thread.h \
- $(ACE_ROOT)/ace/Thread.i \
- $(ACE_ROOT)/ace/Atomic_Op.i \
- $(ACE_ROOT)/ace/Synch_T.cpp \
- $(ACE_ROOT)/ace/Map_Manager.i \
- $(ACE_ROOT)/ace/Map_Manager.cpp \
- $(ACE_ROOT)/ace/Malloc.h \
- $(ACE_ROOT)/ace/Malloc.i \
- $(ACE_ROOT)/ace/Malloc_T.h \
- $(ACE_ROOT)/ace/Free_List.h \
- $(ACE_ROOT)/ace/Free_List.i \
- $(ACE_ROOT)/ace/Free_List.cpp \
- $(ACE_ROOT)/ace/Malloc_T.i \
- $(ACE_ROOT)/ace/Malloc_T.cpp \
- $(ACE_ROOT)/ace/Memory_Pool.h \
- $(ACE_ROOT)/ace/Signal.h \
- $(ACE_ROOT)/ace/Containers.h \
- $(ACE_ROOT)/ace/Containers.i \
- $(ACE_ROOT)/ace/Containers_T.h \
- $(ACE_ROOT)/ace/Containers_T.i \
- $(ACE_ROOT)/ace/Containers_T.cpp \
- $(ACE_ROOT)/ace/Signal.i \
- $(ACE_ROOT)/ace/Object_Manager.h \
- $(ACE_ROOT)/ace/Object_Manager.i \
- $(ACE_ROOT)/ace/Managed_Object.h \
- $(ACE_ROOT)/ace/Managed_Object.i \
- $(ACE_ROOT)/ace/Managed_Object.cpp \
- $(ACE_ROOT)/ace/Mem_Map.h \
- $(ACE_ROOT)/ace/Mem_Map.i \
- $(ACE_ROOT)/ace/Memory_Pool.i \
- $(ACE_ROOT)/ace/Service_Config.h \
- $(ACE_ROOT)/ace/Service_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.h \
- $(ACE_ROOT)/ace/Shared_Object.i \
- $(ACE_ROOT)/ace/Service_Object.i \
- $(ACE_ROOT)/ace/Service_Config.i \
- $(ACE_ROOT)/ace/Reactor.h \
- $(ACE_ROOT)/ace/Handle_Set.h \
- $(ACE_ROOT)/ace/Handle_Set.i \
- $(ACE_ROOT)/ace/Timer_Queue.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.h \
- $(ACE_ROOT)/ace/Timer_Queue_T.i \
- $(ACE_ROOT)/ace/Timer_Queue_T.cpp \
- $(ACE_ROOT)/ace/Reactor.i \
- $(ACE_ROOT)/ace/Reactor_Impl.h \
- $(ACE_ROOT)/ace/Svc_Conf_Tokens.h \
- Event_CommS.h Event_CommC.h Event_CommC.i Event_CommS_T.h \
- Event_CommS_T.i Event_CommS_T.cpp Event_CommS.i \
- $(TAO_ROOT)/tao/TAO.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/orbsvcs_export.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingC.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS_T.cpp \
- $(TAO_ROOT)/orbsvcs/orbsvcs/CosNamingS.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Naming_Utils.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/IOR_Multicast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.h \
- $(ACE_ROOT)/ace/SOCK_Dgram.i \
- $(ACE_ROOT)/ace/SOCK_Dgram_Mcast.i \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/CosNaming_i.h \
- $(TAO_ROOT)/orbsvcs/orbsvcs/Naming/Entries.h
-
-# IF YOU PUT ANYTHING HERE IT WILL GO AWAY
diff --git a/TAO/examples/Event_Comm/Notifier.dsp b/TAO/examples/Event_Comm/Notifier.dsp
deleted file mode 100644
index d52c617c2d8..00000000000
--- a/TAO/examples/Event_Comm/Notifier.dsp
+++ /dev/null
@@ -1,175 +0,0 @@
-# Microsoft Developer Studio Project File - Name="Notifier" - Package Owner=<4>
-# Microsoft Developer Studio Generated Build File, Format Version 5.00
-# ** DO NOT EDIT **
-
-# TARGTYPE "Win32 (x86) Console Application" 0x0103
-
-CFG=Notifier - 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 "Notifier.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 "Notifier.mak" CFG="Notifier - Win32 Debug"
-!MESSAGE
-!MESSAGE Possible choices for configuration are:
-!MESSAGE
-!MESSAGE "Notifier - Win32 Release" (based on\
- "Win32 (x86) Console Application")
-!MESSAGE "Notifier - Win32 Debug" (based on "Win32 (x86) Console Application")
-!MESSAGE
-
-# Begin Project
-# PROP Scc_ProjName ""
-# PROP Scc_LocalPath ""
-CPP=cl.exe
-RSC=rc.exe
-
-!IF "$(CFG)" == "Notifier - Win32 Release"
-
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 0
-# PROP BASE Output_Dir "Release"
-# PROP BASE Intermediate_Dir "Release"
-# PROP BASE Target_Dir ""
-# PROP Use_MFC 0
-# PROP Use_Debug_Libraries 0
-# PROP Output_Dir "Release"
-# PROP Intermediate_Dir "Release"
-# PROP Ignore_Export_Lib 0
-# PROP Target_Dir ""
-# ADD BASE CPP /nologo /W3 /GX /O2 /D "WIN32" /D "NDEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
-# ADD CPP /nologo /MD /W3 /GX /O2 /I "..\..\\" /I "..\..\..\\" /I "..\..\orbsvcs" /D "NDEBUG" /D "WIN32" /D "_CONSOLE" /FD /c
-# ADD BASE RSC /l 0x409 /d "NDEBUG"
-# ADD RSC /l 0x409 /d "NDEBUG"
-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 /machine:I386
-# ADD LINK32 ace.lib TAO.lib orbsvcs.lib /nologo /subsystem:console /pdb:"Release/client.pdb" /machine:I386 /libpath:"..\..\tao" /libpath:"..\..\..\ace" /libpath:"..\..\orbsvcs\orbsvcs"
-# SUBTRACT LINK32 /pdb:none
-
-!ELSEIF "$(CFG)" == "Notifier - Win32 Debug"
-
-# 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" /D "_MBCS" /YX /FD /c
-# ADD CPP /nologo /MDd /W3 /Gm /GX /Zi /Od /I "..\..\\" /I "..\..\..\\" /I "..\..\orbsvcs" /D "_DEBUG" /D "WIN32" /D "_CONSOLE" /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 /pdbtype:sept
-# ADD LINK32 aced.lib TAOd.lib orbsvcsd.lib /nologo /subsystem:console /pdb:"client.pdb" /debug /machine:I386 /libpath:"..\..\tao" /libpath:"..\..\..\ace" /libpath:"..\..\orbsvcs\orbsvcs"
-# SUBTRACT LINK32 /pdb:none
-
-!ENDIF
-
-# Begin Target
-
-# Name "Notifier - Win32 Release"
-# Name "Notifier - Win32 Debug"
-# Begin Group "Source"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm_i.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommC.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommS.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\notifier.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Notifier_Server.cpp
-# End Source File
-# End Group
-# Begin Group "Header"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm_i.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Notifier_Server.h
-# End Source File
-# End Group
-# Begin Group "IDL"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm.idl
-
-!IF "$(CFG)" == "Notifier - Win32 Release"
-
-!ELSEIF "$(CFG)" == "Notifier - Win32 Debug"
-
-# PROP Ignore_Default_Tool 1
-# Begin Custom Build - Invoking TAO_IDL Compiler
-InputPath=.\Event_Comm.idl
-InputName=Event_Comm
-
-BuildCmds= \
- tao_idl $(InputName).idl
-
-"$(InputName)C.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)C.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)C.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-# End Custom Build
-
-!ENDIF
-
-# End Source File
-# End Group
-# End Target
-# End Project
diff --git a/TAO/examples/Event_Comm/Notifier_Handler.cpp b/TAO/examples/Event_Comm/Notifier_Handler.cpp
deleted file mode 100644
index 322cb2c6128..00000000000
--- a/TAO/examples/Event_Comm/Notifier_Handler.cpp
+++ /dev/null
@@ -1,130 +0,0 @@
-// $Id$
-
-#include "Notifier_Handler.h"
-
-ACE_RCSID(Supplier, Notifier_Handler, "$Id$")
-
-Notifier_Handler::Notifier_Handler (void)
-{
- // No-Op.
-}
-
-// Destroy a Notifier target object.
-
-Notifier_Handler::~Notifier_Handler (void)
-{
- // No-Op.
-}
-
-int
-Notifier_Handler::close (void)
-{
- if (this->notifier_ != 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "closing down Notifier_Handler\n"));
- CORBA::release (this->notifier_);
- this->notifier_ = 0;
- }
-
- // shutdown the ORB.
- this->orb_->shutdown ();
- return 0;
-}
-
-void
-Notifier_Handler::shutdown (void)
-{
- ACE_ASSERT (this->shutdowncallback != 0);
-
- this->shutdowncallback->close ();
-}
-
-int
-Notifier_Handler::run (void)
-{
- // Run the ORB.
- this->orb_->run ();
- return 0;
-}
-
-ACE_Reactor*
-Notifier_Handler::reactor(void)
-{
- // @@ Please see if there's a way to get to the Reactor without
- // using the TAO_ORB_Core_instance().
- return TAO_ORB_Core_instance ()->reactor ();
-}
-
-Event_Comm::Notifier *
-Notifier_Handler::notifier (void)
-{
- return this->notifier_;
-}
-
-void
-Notifier_Handler::notifier (Event_Comm::Notifier *notifier)
-{
- if (this->notifier_ != notifier)
- {
- CORBA::release (this->notifier_);
- this->notifier_ = notifier;
- }
-}
-
-// Init function.
-
-int
-Notifier_Handler::init (int argc,
- char *argv[],
- ShutdownCallback* _shutdowncallback)
-{
- // set the callback
- shutdowncallback = _shutdowncallback;
-
- ACE_TRY_NEW_ENV
- {
- // Retrieve the ORB.
- this->orb_ = CORBA::ORB_init (argc,
- argv,
- 0,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- // Initialization of the naming service.
- if (this->naming_client_.init (orb_.in ()) != 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- "(%P|%t) Unable to initialize "
- "the TAO_Naming_Client. \n"),
- -1);
-
- CosNaming::Name notifier_ref_name (1);
- notifier_ref_name.length (1);
- notifier_ref_name[0].id =
- CORBA::string_dup (NOTIFIER_BIND_NAME);
-
- CORBA::Object_var notifier_obj =
- this->naming_client_->resolve (notifier_ref_name,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
-
- // The CORBA::Object_var object is downcast to Notifier_var
- // using the <_narrow> method.
- this->notifier_ =
- Event_Comm::Notifier::_narrow (notifier_obj.in (),
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- return 0;
-
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Notifier_Handler::init\n");
- return -1;
- }
- ACE_ENDTRY;
-
- return 0;
-}
diff --git a/TAO/examples/Event_Comm/Notifier_Handler.h b/TAO/examples/Event_Comm/Notifier_Handler.h
deleted file mode 100644
index cf83f94de6f..00000000000
--- a/TAO/examples/Event_Comm/Notifier_Handler.h
+++ /dev/null
@@ -1,81 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Notifier_Handler.h
-//
-// = AUTHOR
-// Douglas C. Schmidt (schmidt@cs.wustl.edu) and
-// Pradeep Gore (pradeep@cs.wustl.edu)
-//
-// ============================================================================
-
-#ifndef _NOTIFIER_HANDLER_H
-#define _NOTIFIER_HANDLER_H
-
-#include "ace/CORBA_Handler.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-#include "Event_Comm_i.h"
-#include "orbsvcs/Naming/Naming_Utils.h"
-#include "orbsvcs/CosNamingC.h"
-
-class Notifier_Handler
-{
- // = TITLE
- // Holds the <Event_Comm::Notifier> object which is obtained from
- // the naming service.
-public:
- // = Initialization and termination methods.
- Notifier_Handler (void);
- // This constructor gets the notifier object from the Naming
- // Service.
-
- virtual ~Notifier_Handler (void);
- // Destructor.
-
- int init (int argc, char *argv[], ShutdownCallback* _shutdowncallback);
- // Initialize the client communication endpoint with server.
-
- // = Accessors.
- Event_Comm::Notifier *notifier (void);
- void notifier (Event_Comm::Notifier *);
-
- int run (void);
- // runs the ORB.
-
- int close (void);
- // Close down the handler.
-
- void shutdown (void);
- // called to request application shutdown.
-
- ACE_Reactor *reactor (void);
- // returns the ORB's reactor.
-
-private:
- Event_Comm::Notifier *notifier_;
- // Pointer to an <Event_Comm::Notifier> object.
-
- TAO_Naming_Client naming_client_;
- // An instance of the name client used for resolving the factory
- // objects.
-
- CORBA::ORB_var orb_;
- // Remember our orb.
-
- ShutdownCallback *shutdowncallback;
- // The handler to shutdown the app.
-};
-
-#define NOTIFIER_BIND_NAME "Notifier"
-
-#endif /* _NOTIFIER_HANDLER_H */
diff --git a/TAO/examples/Event_Comm/Notifier_Server.cpp b/TAO/examples/Event_Comm/Notifier_Server.cpp
deleted file mode 100644
index eadbd0a8ede..00000000000
--- a/TAO/examples/Event_Comm/Notifier_Server.cpp
+++ /dev/null
@@ -1,146 +0,0 @@
-#include "Notifier_Server.h"
-#include "Event_CommC.h"
-
-ACE_RCSID(Echo, Server_i, "$Id$")
-
-// Constructor.
-
-Notifier_Server::Notifier_Server (void)
-{
- // no-op.
-}
-
-// Destructor.
-
-Notifier_Server::~Notifier_Server (void)
-{
- // no-op.
-}
-
-int
-Notifier_Server::close (void)
-{
- ACE_TRY_NEW_ENV
- {
- // disconnect all the consumers.
- this->servant_.disconnect ("notifier shutdown.",
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- // Name the object.
- CosNaming::Name notifier_obj_name (1);
- notifier_obj_name.length (1);
- notifier_obj_name[0].id =
- CORBA::string_dup (NOTIFIER_BIND_NAME);
-
- this->naming_server_->unbind (notifier_obj_name,
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- // Instruct the ORB to shutdown.
- this->orb_manager_.orb ()->shutdown ();
- }
- ACE_CATCHANY
- {
- return -1;
- }
- ACE_ENDTRY;
-
- return 0;
-}
-
-// The naming service is initialized and the naming context as well as
-// the object name is bound to the naming server.
-
-int
-Notifier_Server::init_naming_service (CORBA::Environment &ACE_TRY_ENV)
-{
- ACE_TRY
- {
- CORBA::ORB_var orb = this->orb_manager_.orb ();
-
- PortableServer::POA_var child_poa
- = this->orb_manager_.child_poa ();
-
- TAO_debug_level = 1;
-
- if (this->naming_server_.init (orb.in (),
- child_poa.in ()) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Failed to initialize TAO_Naming_Server\n"),
- -1);
-
- // Register the object implementation with the POA.
- Event_Comm::Notifier_var notifier_obj =
- this->servant_._this (ACE_TRY_ENV);
- ACE_TRY_CHECK;
-
- // Name the object.
- CosNaming::Name notifier_obj_name (1);
- notifier_obj_name.length (1);
- notifier_obj_name[0].id =
- CORBA::string_dup (NOTIFIER_BIND_NAME);
- ACE_TRY_CHECK;
-
- // Now, attach the object name to the context.
- this->naming_server_->bind (notifier_obj_name,
- notifier_obj.in (),
- ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Notifier_Server::init_naming_service\n");
- return -1;
- }
- ACE_ENDTRY;
-
- return 0;
-}
-
-
-// Initialize the server.
-int
-Notifier_Server::init (int argc,
- char *argv[],
- CORBA::Environment &ACE_TRY_ENV)
-{
- // Call the init of <TAO_ORB_Manager> to initialize the ORB and
- // create the child poa under the root POA.
-
- if (this->orb_manager_.init_child_poa (argc,
- argv,
- "child_poa",
- ACE_TRY_ENV) == -1)
-
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "init_child_poa"),
- -1);
- ACE_CHECK_RETURN (-1);
-
- // Activate the servant in the POA.
- CORBA::String_var str =
- this->orb_manager_.activate_under_child_poa (NOTIFIER_BIND_NAME,
- &this->servant_,
- ACE_TRY_ENV);
-
- return this->init_naming_service (ACE_TRY_ENV);
-}
-
-int
-Notifier_Server::run (CORBA::Environment &ACE_TRY_ENV)
-{
- // Run the main event loop for the ORB.
- if (this->orb_manager_.run (ACE_TRY_ENV) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "Notifier_Server::run"),
- -1);
- return 0;
-}
-
-ACE_Reactor *
-Notifier_Server::reactor (void)
-{
- return TAO_ORB_Core_instance ()->reactor ();
-}
diff --git a/TAO/examples/Event_Comm/Notifier_Server.h b/TAO/examples/Event_Comm/Notifier_Server.h
deleted file mode 100644
index 2439dfe53d9..00000000000
--- a/TAO/examples/Event_Comm/Notifier_Server.h
+++ /dev/null
@@ -1,71 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Notifier_Server.h
-//
-// = AUTHOR
-// Pradeep Gore <pradeep@cs.wustl.edu>
-//
-// ============================================================================
-
-#ifndef _NOTIFIER_SERVER_H
-#define _NOTIFIER_SERVER_H
-
-#include "Event_Comm_i.h"
-#include "tao/TAO.h"
-#include "orbsvcs/CosNamingS.h"
-#include "orbsvcs/Naming/Naming_Utils.h"
-
-class Notifier_Server
-{
- // = TITLE
- // The Notifier Server that handles CORBA operations from
- // Consumers and Suppliers.
-public:
- // = Initialization and termination methods.
- Notifier_Server (void);
- // Constructor.
-
- ~Notifier_Server (void);
- // Destructor.
-
- int init (int argc, char *argv[], CORBA::Environment &env);
- // Initialize the Server state.
-
- int run (CORBA::Environment &env);
- // Run the orb.
-
- int close (void);
- // Close the naming service.
-
- ACE_Reactor *reactor(void);
- // Reactor accessor.
-
-private:
- int init_naming_service (CORBA::Environment &env);
- // Initialises the name server and registers the Notifier server
- // object name with the name server.
-
- TAO_ORB_Manager orb_manager_;
- // The ORB manager.
-
- Notifier_i servant_;
- // Servant for the Notifier interface.
-
- CosNaming::NamingContext_var naming_context_;
- // Naming context for the naming service.
-
- TAO_Naming_Server naming_server_;
- // An instance of the name server, wherein the naming context
- // containing the factory of objects will be registered.
-};
-
-#define NOTIFIER_BIND_NAME "Notifier"
-
-#endif /* _NOTIFIER_SERVER_H */
diff --git a/TAO/examples/Event_Comm/README b/TAO/examples/Event_Comm/README
deleted file mode 100644
index 69075bef213..00000000000
--- a/TAO/examples/Event_Comm/README
+++ /dev/null
@@ -1,97 +0,0 @@
-OVERVIEW
-
-This directory contains source code for a prototype CORBA-based
-distributed notification mechanism. This mechanism implements a
-"publish/subscribe" communication protocol. It allows Suppliers to
-pass messages containing object references to a dynamically managed
-group of Consumers. This is similar to the OMG COSS Event Service,
-though not as sophisticated.
-
-DIRECTORY STRUCTURE
-
-There are 3 executables:
-
-Notifier
-
- -- The Notifier supplies events from Suppliers to Consumers
- It which must be started first.
- It has an instance of an IDL Notifier
- object. This object accepts subscriptions from Consumers
- and forwards events sent to it either via Consumers or
- Suppliers.
- The Notifier object is registered with a naming service
- so that it can be located by other objects.
- To run the Notifier, type:
- notifier
-
- To exit the Notifier press CTRL-C.
- All consumers registered with the Notifier will shutdown.
- Suppliers should however, be shutdown beforehand.
-Supplier:
- On startup the Supplier gets hold of the Notifier object from
- the naming service and registers itself with it.
- The Supplier accepts strings from the user and sends them to
- the Notifier.
- To run the supplier type:
- supplier
-
- To exit the supplier type CTRL-C or type "quit".
- To send strings to the Consumers, type the string on the prompt
- and press ENTER.
-
-Consumer:
- It has an instance of an IDL Consumer object.
- This object is used to receive notifications from the
- Notifier object.
- When the Consumer starts up, it gets an object reference to
- the Notifier.
- It then subscribes its Consumer object with
- the Notifier by passing an object reference.
-
- In addition to passing an object reference to a
- Notifier, the Consumer also may specify a
- filtering criteria, which is a regular expression. If
- the filtering criteria is the string "" then the Notifier
- will send all Notifications to the Consumer (i.e., "" is
- treated as a "wildcard"). Otherwise, the filtering
- criteria is considered to be a regular expression,
- and only those Notification tags that match the regular
- expression will be forwarded to the Consumer. The regular
- expressions are those used by ed(1) (see the regexp(5)
- manual page for more info).
-
- To run the Consumer, type:
- consumer <filtering_criteria>
-
- e.g. consumer a*b
- will accept the following strings: ab , b, aaaab.
-
- To send strings to other Consumers, type the string on the prompt
- and press ENTER.
-
-RUNNING THE SAMPLE:
-
-To run the tests do the following:
-
-1. Compile everything.
-
-2. Start the Notifier as described above.
-
-3. Start the Supplier executable.
-
-4. Start up as many copies of the Consumer as you'd like.
- Typically, I run each one in its own window.
-
-5. Once the Consumers have subscribed you can send them info by typing
- commands in the Supplier window. These will be sent to all the
- Consumers who have subscribed. Likewise, you can send messages
- from a Consumer to all other Consumers by typing messages in a
- Consumer window.
-
- Note that if you type "quit" or ^C in a Consumer window the
- Consumer will unsubscribe and shutdown its handlers and exit.
- Likewise, if you type ^C in the Notifier window
- the Notifier will disconnect all of its Consumers and exit.
-
-6. When you want to terminate a Consumer or a Supplier, just type ^C
- or "quit" and the process will shut down gracefully.
diff --git a/TAO/examples/Event_Comm/Supplier.dsp b/TAO/examples/Event_Comm/Supplier.dsp
deleted file mode 100644
index 0518d7132db..00000000000
--- a/TAO/examples/Event_Comm/Supplier.dsp
+++ /dev/null
@@ -1,191 +0,0 @@
-# Microsoft Developer Studio Project File - Name="Supplier" - Package Owner=<4>
-# Microsoft Developer Studio Generated Build File, Format Version 5.00
-# ** DO NOT EDIT **
-
-# TARGTYPE "Win32 (x86) Console Application" 0x0103
-
-CFG=Supplier - 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 "Supplier.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 "Supplier.mak" CFG="Supplier - Win32 Debug"
-!MESSAGE
-!MESSAGE Possible choices for configuration are:
-!MESSAGE
-!MESSAGE "Supplier - Win32 Release" (based on\
- "Win32 (x86) Console Application")
-!MESSAGE "Supplier - Win32 Debug" (based on "Win32 (x86) Console Application")
-!MESSAGE
-
-# Begin Project
-# PROP Scc_ProjName ""
-# PROP Scc_LocalPath ""
-CPP=cl.exe
-RSC=rc.exe
-
-!IF "$(CFG)" == "Supplier - Win32 Release"
-
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 0
-# PROP BASE Output_Dir "Supplier"
-# PROP BASE Intermediate_Dir "Supplier"
-# PROP BASE Target_Dir ""
-# PROP Use_MFC 0
-# PROP Use_Debug_Libraries 0
-# PROP Output_Dir "Supplier"
-# PROP Intermediate_Dir "Supplier"
-# PROP Ignore_Export_Lib 0
-# PROP Target_Dir ""
-# ADD BASE CPP /nologo /W3 /GX /O2 /D "WIN32" /D "NDEBUG" /D "_CONSOLE" /D "_MBCS" /YX /FD /c
-# ADD CPP /nologo /MD /W3 /GX /O2 /I "..\..\\" /I "..\..\..\\" /I "..\..\orbsvcs" /D "NDEBUG" /D "WIN32" /D "_CONSOLE" /Fo"Release/" /Fd"Release/" /FD /c
-# ADD BASE RSC /l 0x409 /d "NDEBUG"
-# ADD RSC /l 0x409 /d "NDEBUG"
-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 /machine:I386
-# ADD LINK32 ace.lib TAO.lib orbsvcs.lib /nologo /subsystem:console /pdb:"Release/client.pdb" /machine:I386 /out:"Release/Supplier.exe" /libpath:"..\..\tao" /libpath:"..\..\..\ace" /libpath:"..\..\orbsvcs\orbsvcs"
-# SUBTRACT LINK32 /pdb:none
-
-!ELSEIF "$(CFG)" == "Supplier - Win32 Debug"
-
-# PROP BASE Use_MFC 0
-# PROP BASE Use_Debug_Libraries 1
-# PROP BASE Output_Dir "Supplie0"
-# PROP BASE Intermediate_Dir "Supplie0"
-# 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" /D "_MBCS" /YX /FD /c
-# ADD CPP /nologo /MDd /W3 /Gm /GX /Zi /Od /I "..\..\\" /I "..\..\..\\" /I "..\..\orbsvcs" /D "_DEBUG" /D "WIN32" /D "_CONSOLE" /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 /pdbtype:sept
-# ADD LINK32 aced.lib TAOd.lib orbsvcsd.lib /nologo /subsystem:console /pdb:"client.pdb" /debug /machine:I386 /libpath:"..\..\tao" /libpath:"..\..\..\ace" /libpath:"..\..\orbsvcs\orbsvcs"
-# SUBTRACT LINK32 /pdb:none
-
-!ENDIF
-
-# Begin Target
-
-# Name "Supplier - Win32 Release"
-# Name "Supplier - Win32 Debug"
-# Begin Group "Source"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm_i.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommC.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommS.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Notifier_Handler.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\supplier.cpp
-# End Source File
-# Begin Source File
-
-SOURCE=.\Supplier_Input_Handler.cpp
-# End Source File
-# End Group
-# Begin Group "Header"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm_i.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommC.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Event_CommS.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Notifier_Handler.h
-# End Source File
-# Begin Source File
-
-SOURCE=.\Supplier_Input_Handler.h
-# End Source File
-# End Group
-# Begin Group "IDL"
-
-# PROP Default_Filter ""
-# Begin Source File
-
-SOURCE=.\Event_Comm.idl
-
-!IF "$(CFG)" == "Supplier - Win32 Release"
-
-!ELSEIF "$(CFG)" == "Supplier - Win32 Debug"
-
-# PROP Ignore_Default_Tool 1
-# Begin Custom Build - Invoking TAO_IDL Compiler
-InputPath=.\Event_Comm.idl
-InputName=Event_Comm
-
-BuildCmds= \
- tao_idl $(InputName).idl
-
-"$(InputName)C.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)C.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)C.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.h" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.i" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-
-"$(InputName)S_T.cpp" : $(SOURCE) "$(INTDIR)" "$(OUTDIR)"
- $(BuildCmds)
-# End Custom Build
-
-!ENDIF
-
-# End Source File
-# End Group
-# End Target
-# End Project
diff --git a/TAO/examples/Event_Comm/Supplier_Input_Handler.cpp b/TAO/examples/Event_Comm/Supplier_Input_Handler.cpp
deleted file mode 100644
index 2efd951efb9..00000000000
--- a/TAO/examples/Event_Comm/Supplier_Input_Handler.cpp
+++ /dev/null
@@ -1,121 +0,0 @@
-// $Id$
-
-#include "Event_Comm_i.h"
-#include "Notifier_Handler.h"
-#include "Supplier_Input_Handler.h"
-
-ACE_RCSID(Supplier, Supplier_Input_Handler, "$Id$")
-
-Supplier_Input_Handler::Supplier_Input_Handler ()
- : notifier_ (0)
-{
- // No-Op.
-}
-
-Supplier_Input_Handler::~Supplier_Input_Handler (void)
-{
- ACE_DEBUG ((LM_DEBUG,
- "closing down Supplier_Input_Handler::~Supplier_Input_Handler\n"));
-}
-
-int
-Supplier_Input_Handler::close (void)
-{
- ACE_DEBUG ((LM_DEBUG,
- "closing down Supplier::Supplier_Input_Handler\n"));
-
- // Make sure to cleanup the STDIN handler.
- if (ACE_Event_Handler::remove_stdin_handler
- (
- TAO_ORB_Core_instance ()->reactor (),
- TAO_ORB_Core_instance ()->thr_mgr ()) == -1)
- ACE_ERROR ((LM_ERROR,
- "%p\n",
- "remove_stdin_handler"));
- return 0;
-}
-
-int
-Supplier_Input_Handler::initialize (Notifier_Handler *notifier)
-{
- notifier_ = notifier;
- // Register our <Input_Handler> to handle STDIN events, which will
- // trigger the <handle_input> method to process these events.
-
- if (ACE_Event_Handler::register_stdin_handler
- (this,
- TAO_ORB_Core_instance ()->reactor (),
- TAO_ORB_Core_instance ()->thr_mgr ()) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_stdin_handler"),
- -1);
-
-
- return 0;
-}
-
-// Frame input events and notify <Consumers>.
-
-int
-Supplier_Input_Handler::handle_input (ACE_HANDLE h)
-{
- char buf[BUFSIZ];
-
- // Read up to BUFSIZ worth of data from ACE_HANDLE h.
-
- if (ACE_OS::fgets (buf,
- sizeof buf - 1,
- stdin) == 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- "shutting down Supplier_Input_Handler\n"));
- return 0;
- }
- else
- {
- size_t n = ACE_OS::strlen (buf);
-
- // Null terminate the buffer, replacing the '\n' with '\0'.
- if (buf[n - 1] == '\n' || buf[n - 1] == EOF)
- buf[n - 1] = '\0';
- else
- buf[n] = '\0';
- ACE_DEBUG ((LM_DEBUG,
- "notifying for event %s\n",
- buf));
- }
-
-
-
- if (ACE_OS::strncmp (buf, "quit", 4) == 0)
- // Tell the main event loop to shutdown.
- this->notifier_->shutdown ();
- else
- {
- Event_Comm::Notifier *notifier = this->notifier_->notifier ();
- ACE_ASSERT (notifier != 0);
-
- // Use the notifier to notify Consumers.
- ACE_TRY_NEW_ENV
- {
- Event_Comm::Event event;
-
- // Pass the buf over in the tag field.
- event.tag_ = ACE_OS::strdup (buf);
-
- // This is where the "any" value goes or the object
- // reference... event.value_ = ...
-
- // Forward <Event> to all <Consumers>.
- notifier->push (event, ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Unexpected Error\n");
- }
- ACE_ENDTRY;
- }
- return 0;
-}
diff --git a/TAO/examples/Event_Comm/Supplier_Input_Handler.h b/TAO/examples/Event_Comm/Supplier_Input_Handler.h
deleted file mode 100644
index 706e4bc77b7..00000000000
--- a/TAO/examples/Event_Comm/Supplier_Input_Handler.h
+++ /dev/null
@@ -1,65 +0,0 @@
-/* -*- C++ -*- */
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// EventComm
-//
-// = FILENAME
-// Supplier_Input_Handler.h
-//
-// = DESCRIPTION
-// Handle input from the keyboard.
-//
-// = AUTHOR
-// Douglas C. Schmidt (schmidt@cs.wustl.edu) and
-// Pradeep Gore (pradeep@cs.wustl.edu)
-//
-// ============================================================================
-
-#ifndef SUPPLIER_INPUT_HANDLER_H
-#define SUPPLIER_INPUT_HANDLER_H
-
-#include "ace/Service_Config.h"
-
-#if !defined (ACE_LACKS_PRAGMA_ONCE)
-# pragma once
-#endif /* ACE_LACKS_PRAGMA_ONCE */
-
-// Forward declaration.
-class Notifier_Handler;
-
-class Supplier_Input_Handler : public ACE_Event_Handler
-{
- // = TITLE
- // Handles input events generated from a keyboard.
- //
- // = DESCRIPTION
- // The events are currently framed and forwarded to all Consumers.
- // In the future, we will need to be more selective and only send
- // to those Consumers whose filtering criteria matches!
-public:
- // = Initialization and termination methods.
- Supplier_Input_Handler (void);
- // Constructor.
-
- ~Supplier_Input_Handler (void);
- // Destructor.
-
- int initialize (Notifier_Handler *);
- // Initialization.
-
- virtual int handle_input (ACE_HANDLE);
- // Frame input events and notify <Consumers>.
-
- int close (void);
- // Close down the handler.
-
-protected:
- Notifier_Handler *notifier_;
- // Pointer to a <Notifier_Handler> that's used to inform Consumers
- // that events of interest have occurred.
-};
-
-#endif /* SUPPLIER_INPUT_HANDLER_H */
diff --git a/TAO/examples/Event_Comm/consumer.cpp b/TAO/examples/Event_Comm/consumer.cpp
deleted file mode 100644
index 55b157feaf0..00000000000
--- a/TAO/examples/Event_Comm/consumer.cpp
+++ /dev/null
@@ -1,132 +0,0 @@
-// $Id$
-
-#include "Consumer_Handler.h"
-#include "Consumer_Input_Handler.h"
-
-ACE_RCSID(Consumer, consumer, "$Id$")
-
-class Consumer : public ACE_Event_Handler, public ShutdownCallback
-{
- // = TITLE
- // Consumer driver for the Publish/Subscribe example.
- //
- // = DESCRIPTION
- // The Consumer holds the <Consumer_Input_Handler> and
- // <Cosumer_Handler> objects.
-public:
- // = Initialization and termination methods.
- Consumer (void);
- // Constructor.
-
- ~Consumer (void);
- // Destructor.
-
- int initialize (int argc, char *argv[]);
- // Initialization method.
-
- int run (void);
- // Execute the consumer;
-
- virtual void close (void);
- // Shutdown the consumer.
-
-private:
- virtual int handle_signal (int signum, siginfo_t *, ucontext_t *);
- // Signal handler method.
-
- Consumer_Input_Handler ih_;
- // Handler for keyboard input.
-
- Consumer_Handler ch_;
- // Handler for CORBA Consumer.
-};
-
-Consumer::Consumer (void)
-{
- // No-Op.
-}
-
-Consumer::~Consumer (void)
-{
- // No-Op.
-}
-
-int
-Consumer::handle_signal (int signum,
- siginfo_t *,
- ucontext_t *)
-{
- ACE_DEBUG ((LM_DEBUG,
- "%S\n",
- signum));
-
- // Indicate that the consumer initiated the shutdown.
- this->ih_.consumer_initiated_shutdown (1);
-
- this->close ();
-
- return 0;
-}
-
-void
-Consumer::close (void)
-{
- // clean up the input handler.
- ih_.close ();
- // Shut down the ORB
- ch_.close ();
-}
-
-int
-Consumer::run (void)
-{
- // Run the <Consumer_Handler>'s ORB.
- return ch_.run ();
-}
-
-int
-Consumer::initialize (int argc, char *argv[])
-{
- // Initialize the <Consumer_Handler>.
- if (this->ch_.init (argc, argv, this) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "Consumer_Handler failed to initialize\n"),
- -1);
- // Initialize the <Consumer_Input_Handler>.
- else if (this->ih_.initialize (&this->ch_) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "Consumer_Input_Handler failed to initialize\n"),
- -1);
- else if (this->ch_.reactor ()->register_handler (SIGINT,
- this) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_handler"),
- -1);
- else
- return 0;
-}
-
-int
-main (int argc, char *argv[])
-{
- // Initialize the supplier and consumer object references.
- Consumer consumer;
-
- if (consumer.initialize (argc, argv) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "Consumer init failed\n"),
- 1);
-
- // Loop forever handling events.
- if (consumer.run () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "Consumer run failed\n"),
- 1);
-
- return 0;
-}
diff --git a/TAO/examples/Event_Comm/notifier.cpp b/TAO/examples/Event_Comm/notifier.cpp
deleted file mode 100644
index 213738cf943..00000000000
--- a/TAO/examples/Event_Comm/notifier.cpp
+++ /dev/null
@@ -1,71 +0,0 @@
-// $Id$
-
-#include "Notifier_Server.h"
-#include "notifier.h"
-ACE_RCSID(Notifier, notifier, "$Id$")
-
-
-int
-Notifier::handle_signal (int signum, siginfo_t *, ucontext_t *)
-{
- ACE_DEBUG ((LM_DEBUG,
- "got signal in handle_signal %S\n",
- signum));
-
- // Tell the <Notifier_Server> to shut down the ORB.
- ns_.close ();
- return 0;
-}
-
-void
-Notifier::run (void)
-{
- ACE_TRY_NEW_ENV
- {
- ns_.run (ACE_TRY_ENV);
- ACE_TRY_CHECK;
- }
- ACE_CATCHANY
- {
- return;
- }
- ACE_ENDTRY;
-}
-
-Notifier::Notifier (int argc, char *argv[])
-{
- ACE_TRY_NEW_ENV
- {
- ns_.init (argc, argv, ACE_TRY_ENV);
- }
- ACE_CATCHANY
- {
- ACE_TRY_ENV.print_exception ("Notifier_Server.init failed\n ");
- }
- ACE_ENDTRY;
-
- // Register with the ORB's Reactor to receive a signal to shut us
- // down.
- if (ns_.reactor ()->register_handler (SIGINT, this) == -1)
- ACE_ERROR ((LM_ERROR,
- "%p\n",
- "register_handler"));
-}
-
-Notifier::~Notifier (void)
-{
- // Cleanup.
- this->ns_.close ();
-}
-
-int
-main (int argc, char *argv[])
-{
- // Initialize server daemon.
- Notifier notifier (argc, argv);
-
- // Loop forever handling events.
- notifier.run ();
-
- return 0;
-}
diff --git a/TAO/examples/Event_Comm/notifier.h b/TAO/examples/Event_Comm/notifier.h
deleted file mode 100644
index be45a848ebf..00000000000
--- a/TAO/examples/Event_Comm/notifier.h
+++ /dev/null
@@ -1,46 +0,0 @@
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// TAO/example/Event_Comm
-//
-// = FILENAME
-// notifier.h
-//
-// = DESCRIPTION
-// This class implements notifier driver for the Publish/Subscribe example
-//
-// = AUTHOR
-//
-// ============================================================================
-
-
-
-class Notifier : public ACE_Event_Handler
-{
- // = TITLE
- // Notifier driver for the TAO Publish/Subscribe example.
- //
- // = DESCRIPTION
- // The driver class for the <Event_Comm::Notifier> object.
- public:
- // = Initialization and termination methods.
- Notifier (int argc, char *argv[]);
- // Constructor.
-
- ~Notifier (void);
- // Destructor.
-
- void run (void);
- // Execute the notifier.
-
- private:
- virtual int handle_signal (int signum,
- siginfo_t *,
- ucontext_t *);
- // Handle signals that shut us down.
-
- Notifier_Server ns_;
- // The notifier server.
-};
diff --git a/TAO/examples/Event_Comm/supplier.cpp b/TAO/examples/Event_Comm/supplier.cpp
deleted file mode 100644
index c44b6123b8d..00000000000
--- a/TAO/examples/Event_Comm/supplier.cpp
+++ /dev/null
@@ -1,85 +0,0 @@
-// $Id$
-
-#include "Notifier_Handler.h"
-#include "Supplier_Input_Handler.h"
-#include "supplier.h"
-
-ACE_RCSID(Supplier, supplier, "$Id$")
-Supplier::Supplier (void)
-{
- // No-Op.
-}
-
-Supplier::~Supplier (void)
-{
- // No-Op.
-}
-
-int
-Supplier::handle_signal (int signum, siginfo_t *, ucontext_t *)
-{
- ACE_DEBUG ((LM_DEBUG,
- "%S\n",
- signum));
-
- this->close ();
- return 0;
-}
-
-void
-Supplier::run (void)
-{
- if (nh_.run () == -1)
- ACE_ERROR ((LM_ERROR,
- "%p\n",
- "Notifier_Handler::run"));
-}
-
-void
-Supplier::close (void)
-{
- ih_.close ();
- nh_.close ();
-}
-
-int
-Supplier::init (int argc, char *argv[])
-{
- if (this->nh_.init (argc, argv, this) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "Notifier_Handler did not init\n"),
- -1);
- else if (this->ih_.initialize (&nh_) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "Supplier Input handler did not init\n"),
- -1);
- else if (nh_.reactor ()->register_handler (SIGINT,
- this) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_handler"),
- -1);
- ACE_DEBUG ((LM_DEBUG,
- "Supplier initialized.. \n"));
- return 0;
-}
-
-int
-main (int argc, char *argv[])
-{
- // Initialize server daemon.
- Supplier supplier;
-
- if (supplier.init (argc, argv) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "supplier init failed"),
- 1);
-
- // Loop forever handling events.
- supplier.run ();
-
- return 0;
-}
diff --git a/TAO/examples/Event_Comm/supplier.h b/TAO/examples/Event_Comm/supplier.h
deleted file mode 100644
index ee09719b593..00000000000
--- a/TAO/examples/Event_Comm/supplier.h
+++ /dev/null
@@ -1,56 +0,0 @@
-// -*- C++ -*-
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// TAO/example/Event_Comm
-//
-// = FILENAME
-// supplier.h
-//
-// = DESCRIPTION
-// This class implements driver for the Publish/Subscribe example
-//
-// = AUTHOR
-//
-// ============================================================================
-
-
-class Supplier : public ACE_Event_Handler, public ShutdownCallback
-{
- // = TITLE
- // Supplier driver for the TAO Publish/Subscribe example.
- //
- // = DESCRIPTION
- // This class starts up the <Supplier_Input_Handler> and
- // <Notifier_Handler> objects.
-public:
- // Initialization and Termination methods.
- Supplier (void);
- // Constructor.
-
- ~Supplier (void);
- // Destructor.
-
- int init (int argc, char *argv[]);
- // Initialization method. returns 0 on success, -1 on error.
-
- void run (void);
- // Execute the supplier.
-
- virtual void close (void);
- // Shutdown the application.
-
-private:
- virtual int handle_signal (int signum,
- siginfo_t *,
- ucontext_t *);
- // Handle shutdown signals.
-
- Supplier_Input_Handler ih_;
- // Handler for keyboard input.
-
- Notifier_Handler nh_;
- // The notifier handler.
-};