ACE/examples/ASX/UPIPE_Event_Server/Supplier_Router.h

   1 /* -*- C++ -*- */
   2 // The interface between a supplier and an Event Service ACE_Stream.
   3
   4 #ifndef _SUPPLIER_ROUTER_H
   5 #define _SUPPLIER_ROUTER_H
   6
   7 #include "ace/UPIPE_Addr.h"
   8
   9 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  10 # pragma once
  11 #endif /* ACE_LACKS_PRAGMA_ONCE */
  12
  13 #include "ace/UPIPE_Acceptor.h"
  14 #include "ace/Map_Manager.h"
  15 #include "ace/Svc_Handler.h"
  16 #include "Peer_Router.h"
  17
  18 #if defined (ACE_HAS_THREADS)
  19
  20 // Forward declaration.
  21 class Supplier_Handler;
  22
  23 // Type of search key for SUPPLIER_MAP.
  24 typedef ACE_HANDLE SUPPLIER_KEY;
  25
  26 // Instantiated type for routing messages to suppliers.
  27
  28 typedef Peer_Router<Supplier_Handler, SUPPLIER_KEY> SUPPLIER_ROUTER;
  29
  30 class Supplier_Handler
  31   : public Peer_Handler<SUPPLIER_ROUTER, SUPPLIER_KEY>
  32 {
  33 public:
  34   Supplier_Handler (ACE_Thread_Manager *tm = 0);
  35   virtual int open (void *);
  36 };
  37
  38 class Supplier_Router : public SUPPLIER_ROUTER
  39 {
  40 public:
  41   Supplier_Router (ACE_Thread_Manager *);
  42
  43 protected:
  44   // ACE_Task hooks..
  45   virtual int open (void *a = 0);
  46   virtual int close (u_long flags = 0);
  47   virtual int put (ACE_Message_Block *msg, ACE_Time_Value * = 0);
  48   virtual int svc ();
  49
  50   // Dynamic linking hooks inherited from Peer_Router.
  51   virtual int info (ACE_TCHAR **info_string, size_t length) const;
  52 };
  53
  54 #endif /* ACE_HAS_THREADS */
  55 #endif /* _SUPPLIER_ROUTER_H */