summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.i
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.i')
-rw-r--r--TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.i96
1 files changed, 96 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.i b/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.i
new file mode 100644
index 00000000000..c9c8279f64d
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Event/EC_Gateway_UDP.i
@@ -0,0 +1,96 @@
+//
+// $Id$
+//
+
+ACE_INLINE
+TAO_ECG_UDP_Out_Endpoint::TAO_ECG_UDP_Out_Endpoint (void)
+ : port_number_ (0),
+ if_count_ (0),
+ ifs_ (0)
+{
+}
+
+ACE_INLINE ACE_SOCK_Dgram&
+TAO_ECG_UDP_Out_Endpoint::dgram (void)
+{
+ return this->dgram_;
+}
+
+ACE_INLINE CORBA::ULong
+TAO_ECG_UDP_Out_Endpoint::next_request_id (void)
+{
+ return this->request_id_generator_++;
+}
+
+// ****************************************************************
+
+ACE_INLINE ACE_SOCK_Dgram&
+TAO_ECG_UDP_Sender::dgram (void)
+{
+ return this->endpoint_->dgram ();
+}
+
+ACE_INLINE CORBA::ULong
+TAO_ECG_UDP_Sender::mtu (void) const
+{
+ return this->mtu_;
+}
+
+// ****************************************************************
+
+ACE_INLINE
+TAO_ECG_UDP_Request_Index::TAO_ECG_UDP_Request_Index (void)
+ : request_id (0)
+{
+}
+
+ACE_INLINE
+TAO_ECG_UDP_Request_Index::TAO_ECG_UDP_Request_Index (const ACE_INET_Addr& from_,
+ CORBA::ULong request_id_)
+ : from (from_),
+ request_id (request_id_)
+{
+}
+
+ACE_INLINE u_long
+TAO_ECG_UDP_Request_Index::hash (void) const
+{
+ return ((from.get_ip_address() << 24)
+ | (from.get_port_number () << 8)
+ | (request_id & 0x000000ff));
+}
+
+ACE_INLINE int
+TAO_ECG_UDP_Request_Index::operator== (const TAO_ECG_UDP_Request_Index& rhs) const
+{
+ return (this->from == rhs.from &&
+ this->request_id == rhs.request_id);
+}
+
+ACE_INLINE int
+TAO_ECG_UDP_Request_Index::operator!= (const TAO_ECG_UDP_Request_Index& rhs) const
+{
+ return !(*this == rhs);
+}
+
+// ****************************************************************
+
+ACE_INLINE void
+TAO_ECG_UDP_Request_Entry::inc_timeout (void)
+{
+ this->timeout_counter_++;
+}
+
+ACE_INLINE int
+TAO_ECG_UDP_Request_Entry::get_timeout (void) const
+{
+ return this->timeout_counter_;
+}
+
+// ****************************************************************
+
+ACE_INLINE ACE_SOCK_Dgram&
+TAO_ECG_UDP_EH::dgram (void)
+{
+ return this->dgram_;
+}