diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-02-15 19:18:27 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1999-02-15 19:18:27 +0000 |
commit | 8c3acf83c6ebdb83436580b7ce4d30b9bb067e9d (patch) | |
tree | d2e6d4a4a12a28acc83417dd1e1f99258656a90a /TAO/examples/Event_Comm | |
parent | f0c2268cbafbbb544c3f29529f8f87a56d230287 (diff) | |
download | ATCD-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')
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. -}; |