00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 namespace OpenDDS { 00009 namespace DCPS { 00010 00011 ACE_INLINE void 00012 UdpDataLink::configure(UdpInst* config, 00013 TransportReactorTask* reactor_task) 00014 { 00015 this->config_ = config; 00016 this->reactor_task_ = reactor_task; 00017 } 00018 00019 ACE_INLINE void 00020 UdpDataLink::send_strategy(UdpSendStrategy* send_strategy) 00021 { 00022 this->send_strategy_ = send_strategy; 00023 } 00024 00025 ACE_INLINE void 00026 UdpDataLink::receive_strategy(UdpReceiveStrategy* recv_strategy) 00027 { 00028 this->recv_strategy_ = recv_strategy; 00029 } 00030 00031 ACE_INLINE bool 00032 UdpDataLink::active() const 00033 { 00034 return this->active_; 00035 } 00036 00037 ACE_INLINE UdpInst* 00038 UdpDataLink::config() 00039 { 00040 return this->config_; 00041 } 00042 00043 ACE_INLINE TransportReactorTask* 00044 UdpDataLink::reactor_task() 00045 { 00046 return this->reactor_task_; 00047 } 00048 00049 ACE_INLINE ACE_Reactor* 00050 UdpDataLink::get_reactor() 00051 { 00052 if (this->reactor_task_ == 0) return 0; 00053 return this->reactor_task_->get_reactor(); 00054 } 00055 00056 ACE_INLINE ACE_INET_Addr& 00057 UdpDataLink::remote_address() 00058 { 00059 return this->remote_address_; 00060 } 00061 00062 ACE_INLINE ACE_SOCK_Dgram& 00063 UdpDataLink::socket() 00064 { 00065 return this->socket_; 00066 } 00067 00068 } // namespace DCPS 00069 } // namespace OpenDDS