*** empty log message ***AV

1 files changed, 124 insertions, 0 deletions

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 <yamuna@cs.wustl.edu>
+//
+//
+// ============================================================================
+
+#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 */