From 5b331a9610d3a15ab12d6e3e9dbcf380ca2db5e6 Mon Sep 17 00:00:00 2001 From: yamuna Date: Sat, 4 Nov 2000 23:03:48 +0000 Subject: *** empty log message *** --- TAO/orbsvcs/orbsvcs/AV/QoS_MCast.h | 124 +++++++++++++++++++++++++++++++++++++ 1 file changed, 124 insertions(+) create mode 100644 TAO/orbsvcs/orbsvcs/AV/QoS_MCast.h diff --git a/TAO/orbsvcs/orbsvcs/AV/QoS_MCast.h b/TAO/orbsvcs/orbsvcs/AV/QoS_MCast.h new file mode 100644 index 00000000000..6f187505c45 --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/AV/QoS_MCast.h @@ -0,0 +1,124 @@ +//$Id$ + +#ifndef TAO_AV_QOS_MCAST_H +#define TAO_AV_QOS_MCAST_H + +// ============================================================================ +// +// = LIBRARY +// ORBSVCS AVStreams +// +// = FILENAME +// QoS_MCast.h +// +// = AUTHOR +// Yamuna Krishnamurthy +// +// +// ============================================================================ + +#include "ace/pre.h" + +#include "FlowSpec_Entry.h" +#include "Protocol_Factory.h" +#include "ace/INET_Addr.h" +#include "ace/SOCK_Dgram_Mcast_QoS.h" +#include "ace/QoS_Session.h" + +class TAO_AV_QoS_UDP_MCast_Flow_Handler; + +class TAO_AV_QoS_UDP_MCast_Transport + :public TAO_AV_Transport +{ + // = TITLE + // A transport abstraction for QoS enabled Multicast dgram sockets. + // + // = DESCRIPTION + // Uses the ACE_SOCK_Dgram_Mcast or ACE_SOCK_Dgram_Mcast_QoS to send the data. +public: + TAO_AV_QoS_UDP_MCast_Transport (void); + + TAO_AV_QoS_UDP_MCast_Transport (TAO_AV_QoS_UDP_MCast_Flow_Handler *handler); + + virtual ~TAO_AV_QoS_UDP_MCast_Transport (void); + + virtual int open (ACE_Addr *address); + + virtual int close (void); + + virtual int mtu (void); + + virtual ACE_Addr *get_peer_addr (void); + virtual ACE_Addr *get_local_addr (void); + + //virtual ssize_t send(); + + virtual ssize_t send (const ACE_Message_Block *mblk, + ACE_Time_Value *s = 0); + // Write the complete Message_Block chain to the connection. + + virtual ssize_t send (const char *buf, + size_t len, + ACE_Time_Value *s = 0); + // Write the contents of the buffer of length len to the connection. + + virtual ssize_t send (const iovec *iov, + int iovcnt, + ACE_Time_Value *s = 0); + // Write the contents of iovcnt iovec's to the connection. + + virtual ssize_t recv (char *buf, + size_t len, + ACE_Time_Value *s = 0); + // Read len bytes from into buf. + + virtual ssize_t recv (char *buf, + size_t len, + int flags, + ACE_Time_Value *s = 0); + // Read len bytes from into buf using flags. + + virtual ssize_t recv (iovec *iov, + int iovcnt, + ACE_Time_Value *s = 0); + // Read received data into the iovec buffers. +protected: + TAO_AV_QoS_UDP_MCast_Flow_Handler *handler_; + ACE_INET_Addr peer_addr_; + ACE_INET_Addr local_addr_; +}; + +class TAO_AV_QoS_UDP_MCast_Flow_Handler + :public virtual TAO_AV_Flow_Handler, + public virtual ACE_Event_Handler +{ +public: + TAO_AV_QoS_UDP_MCast_Flow_Handler (void); + // Ctor + TAO_AV_QoS_UDP_MCast_Flow_Handler (ACE_SOCK_Dgram_Mcast_QoS* dgram_mcast, + ACE_QoS_Session *qos_session); + // Ctor + ~TAO_AV_QoS_UDP_MCast_Flow_Handler (void); + // Dtor + virtual ACE_HANDLE get_handle (void) const; + virtual int handle_qos (ACE_HANDLE fd); + // Handles a QOS event. Right now, just + // prints a message. + virtual int handle_input (ACE_HANDLE fd); + virtual int handle_timeout (const ACE_Time_Value &tv, const void *arg = 0); + ACE_SOCK_Dgram_Mcast_QoS* get_mcast_socket (void) const; + virtual ACE_Event_Handler* event_handler (void){ return this; } + virtual ACE_QoS_Session* qos_session (void); + virtual void qos_session (ACE_QoS_Session& qos_session); +protected: + ACE_INET_Addr peer_addr_; + ACE_SOCK_Dgram_Mcast_QoS *dgram_mcast_qos_; + ACE_QoS_Session *mcast_qos_session_; +}; + +#if defined(__ACE_INLINE__) +#include "QoS_MCast.i" +#endif /* __ACE_INLINE__ */ + +#include "ace/post.h" +#endif /* TAO_AV_QOS_MCAST_H */ -- cgit v1.2.1