diff options
Diffstat (limited to 'examples/APG/Threads/Message_Receiver.h')
-rw-r--r-- | examples/APG/Threads/Message_Receiver.h | 90 |
1 files changed, 0 insertions, 90 deletions
diff --git a/examples/APG/Threads/Message_Receiver.h b/examples/APG/Threads/Message_Receiver.h deleted file mode 100644 index dee0731f007..00000000000 --- a/examples/APG/Threads/Message_Receiver.h +++ /dev/null @@ -1,90 +0,0 @@ -/** - * $Id$ - * - * Sample code from The ACE Programmer's Guide, - * copyright 2003 Addison-Wesley. All Rights Reserved. - */ - -#ifndef __MESSAGE_RECEIVER_H_ -#define __MESSAGE_RECEIVER_H_ - -#include "ace/Log_Msg.h" -#include "ace/Message_Block.h" -#include "ace/SOCK_Stream.h" -#include "ace/Svc_Handler.h" -#include "ace/Synch.h" -#include "ace/Task.h" - -// Listing 1 code/ch12 -struct DeviceCommandHeader -{ - int length_; - int deviceId_; -}; -// Listing 1 - -class HA_Device_Repository -{ -public: - HA_Device_Repository (); - - int update_device (int device_id, char *commands); - -private: - ACE_Task_Base *owner_; -}; - -HA_Device_Repository::HA_Device_Repository () -{ } - -int -HA_Device_Repository::update_device (int, char *) -{ - return 0; -} - -class HA_CommandHandler : public ACE_Task<ACE_MT_SYNCH> -{ -public: - HA_CommandHandler (HA_Device_Repository &rep) : rep_(rep) - { } - - virtual int svc(); - -private: - HA_Device_Repository &rep_; -}; - -class Message_Receiver : - public ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_MT_SYNCH> -{ -public: - Message_Receiver () : handler_(0) - { - ACE_ASSERT(0); - } - - Message_Receiver (HA_CommandHandler *ch) : handler_(ch) - { } - - ACE_Message_Block *shut_down_message (void); - - virtual int handle_input (ACE_HANDLE fd); - - virtual int handle_close (ACE_HANDLE = ACE_INVALID_HANDLE, - ACE_Reactor_Mask = ACE_Event_Handler::ALL_EVENTS_MASK) - { - this->peer ().close (); - delete this; - return 0; - } - -private: - int read_header (DeviceCommandHeader *dch); - int copy_payload (ACE_Message_Block *mb, int payload_length); - -private: - HA_CommandHandler *handler_; -}; - -#endif /* __MESSAGE_RECEIVER_H */ |