ACE/protocols/ace/RMCast/Link.h

   1 // author    : Boris Kolpackov <boris@kolpackov.net>
   2
   3 #ifndef ACE_RMCAST_LINK_H
   4 #define ACE_RMCAST_LINK_H
   5
   6 #include "ace/SOCK_Dgram.h"
   7 #include "ace/SOCK_Dgram_Mcast.h"
   8
   9 #include "ace/Thread_Manager.h"
  10
  11 #include "Stack.h"
  12 #include "Protocol.h"
  13 #include "Parameters.h"
  14
  15 namespace ACE_RMCast
  16 {
  17   class Link : public Element
  18   {
  19   public:
  20     ~Link ();
  21
  22     Link (Address const& addr, Parameters const& params);
  23
  24     virtual void
  25     in_start (In_Element* in);
  26
  27     virtual void
  28     out_start (Out_Element* out);
  29
  30     virtual void
  31     in_stop ();
  32
  33   public:
  34     virtual void
  35     send (Message_ptr m);
  36
  37   private:
  38     virtual void
  39     send_ (Message_ptr m);
  40
  41   private:
  42     void
  43     recv ();
  44
  45     static ACE_THR_FUNC_RETURN
  46     recv_thunk (void* obj);
  47
  48   private:
  49     virtual void
  50     recv (Message_ptr);
  51
  52   private:
  53     Parameters const& params_;
  54
  55     Address addr_, self_;
  56     ACE_SOCK_Dgram_Mcast rsock_;
  57     ACE_SOCK_Dgram ssock_;
  58
  59     bool stop_;
  60     ACE_Thread_Manager recv_mgr_;
  61
  62     // Simulator.
  63     //
  64     Message_ptr hold_;
  65
  66     Mutex mutex_;
  67   };
  68 }
  69
  70
  71 #endif  // ACE_RMCAST_LINK_H