diff options
Diffstat (limited to 'TAO/examples/Event_Comm/consumer.cpp')
-rw-r--r-- | TAO/examples/Event_Comm/consumer.cpp | 111 |
1 files changed, 0 insertions, 111 deletions
diff --git a/TAO/examples/Event_Comm/consumer.cpp b/TAO/examples/Event_Comm/consumer.cpp deleted file mode 100644 index e0145302aa8..00000000000 --- a/TAO/examples/Event_Comm/consumer.cpp +++ /dev/null @@ -1,111 +0,0 @@ -// $Id$ - -#include "Consumer_Handler.h" -#include "Consumer_Input_Handler.h" - -ACE_RCSID(Consumer, consumer, "$Id$") - -class Consumer : public ACE_Event_Handler -{ - // = 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 (); - ~Consumer (void); - - int initialize (int argc, char *argv[]); - // initialization method. - - void run (void); - // Execute 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) - : ih_ (), - ch_ () -{ - // No-Op. -} - -Consumer::~Consumer (void) -{ - // Allow the handlers to clean up. - this->ih_.handle_close(); - this->ch_.handle_close(); -} - -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); - - // Shut down the ORB - ch_.close(); - return 0; -} - -void -Consumer::run (void) -{ - // run the <Consumer_Handler>'s ORB - ch_.run(); -} - -int Consumer::initialize (int argc, char *argv[]) -{ - // initialize the <Consumer_Handler>. - if (this->ch_.init (argc, argv) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "Consumer_Handler failed to initialize\n"), -1); - - // initialize the <Consumer_Input_Handler>. - if (this->ih_.initialize (&this->ch_) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "Consumer_Input_Handler failed to initialize\n"), -1); - - if (this->ch_.reactor()->register_handler (SIGINT, this) == -1) - ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "register_handler"), -1); - 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. - consumer.run (); - - return 0; -} |