ACE/examples/Connection/blocking/SPIPE-connector.h

   1 /* -*- C++ -*- */
   2 #ifndef SP_CONNECTOR_H
   3 #define SP_CONNECTOR_H
   4
   5 #include "ace/Svc_Handler.h"
   6 #include "ace/Service_Config.h"
   7
   8 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   9 # pragma once
  10 #endif /* ACE_LACKS_PRAGMA_ONCE */
  11
  12 #include "ace/SPIPE_Stream.h"
  13 #include "ace/Connector.h"
  14 #include "ace/SPIPE_Connector.h"
  15 #include "ace/Sig_Adapter.h"
  16
  17 class Peer_Handler : public ACE_Svc_Handler<ACE_SPIPE_STREAM, ACE_NULL_SYNCH>
  18 {
  19 public:
  20   // = Initialization
  21
  22   Peer_Handler (int iterations = 0);
  23   // <iterations> is the number of buffers to send.  If <iterations>
  24   // == 0, then read from stdin.
  25
  26   ~Peer_Handler ();
  27
  28   virtual int open (void * = 0);
  29   // Activate the handler when connection is established.
  30
  31   // = Demultiplexing hooks.
  32   virtual int handle_input (ACE_HANDLE);
  33   virtual int handle_close (ACE_HANDLE handle = ACE_INVALID_HANDLE,
  34                             ACE_Reactor_Mask mask = ACE_Event_Handler::ALL_EVENTS_MASK);
  35
  36   virtual ACE_HANDLE get_handle () const;
  37
  38 private:
  39   void display_menu ();
  40
  41   int iterations_;
  42   // No. of buffers to send.
  43 };
  44
  45 class IPC_Client : public ACE_Connector<Peer_Handler, ACE_SPIPE_CONNECTOR>
  46 {
  47 public:
  48   // Initialization
  49   IPC_Client ();
  50   ~IPC_Client ();
  51
  52   // = Dynamic linking hooks.
  53   virtual int init (int argc, ACE_TCHAR *argv[]);
  54   // Initialize the IPC client.
  55
  56   virtual int fini ();
  57   // Destroy the IPC client.
  58
  59   virtual int svc ();
  60   // Run the svc.
  61
  62   virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);
  63   // Report connection errors.
  64
  65 private:
  66   int parse_args (int argc, ACE_TCHAR *argv[]);
  67   // Parse command-line arguments.
  68
  69   int iterations_;
  70   // Number of times to send a buffer.
  71
  72   ACE_TCHAR rendezvous_[MAXPATHLEN + 1];
  73   // Meeting place for pipe.
  74
  75   ACE_Sig_Adapter done_handler_;
  76   // Keeps track of when we shut down due to receipt of the SIGINT
  77   // signal.
  78 };
  79
  80 #endif /* SP_CONNECTOR_H */