diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/AV/MCast.h')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/MCast.h | 117 |
1 files changed, 0 insertions, 117 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/MCast.h b/TAO/orbsvcs/orbsvcs/AV/MCast.h deleted file mode 100644 index fde288896ed..00000000000 --- a/TAO/orbsvcs/orbsvcs/AV/MCast.h +++ /dev/null @@ -1,117 +0,0 @@ -// -*- C++ -*- - -//============================================================================= -/** - * @file MCast.h - * - * $Id$ - * - * @author Nagarajan Surendran <naga@cs.wustl.edu> - */ -//============================================================================= - - -#ifndef TAO_AV_MCAST_H -#define TAO_AV_MCAST_H -#include /**/ "ace/pre.h" - -#include "orbsvcs/AV/FlowSpec_Entry.h" -#include "orbsvcs/AV/Protocol_Factory.h" -#include "ace/INET_Addr.h" -#include "ace/SOCK_Dgram_Mcast.h" - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -class TAO_AV_UDP_MCast_Flow_Handler; - -/** - * @class TAO_AV_UDP_MCast_Transport - * @brief A transport abstraction for Multicast dgram sockets. - * Uses the ACE_SOCK_Dgram_Mcast to send data. - */ -class TAO_AV_UDP_MCast_Transport - :public TAO_AV_Transport -{ - -public: - TAO_AV_UDP_MCast_Transport (void); - - TAO_AV_UDP_MCast_Transport (TAO_AV_UDP_MCast_Flow_Handler *handler); - - virtual ~TAO_AV_UDP_MCast_Transport (void); - - virtual int open (ACE_Addr *address); - - virtual int close (void); - - virtual int mtu (void); - - /// Write the complete Message_Block chain to the connection. - virtual ACE_Addr *get_peer_addr (void); - virtual ACE_Addr *get_local_addr (void); - virtual ssize_t send (const ACE_Message_Block *mblk, - ACE_Time_Value *s = 0); - - /// Write the contents of the buffer of length len to the connection. - virtual ssize_t send (const char *buf, - size_t len, - ACE_Time_Value *s = 0); - - /// Write the contents of iovcnt iovec's to the connection. - virtual ssize_t send (const iovec *iov, - int iovcnt, - ACE_Time_Value *s = 0); - - /// Read len bytes from into buf. - virtual ssize_t recv (char *buf, - size_t len, - ACE_Time_Value *s = 0); - - /// Read len bytes from into buf using flags. - virtual ssize_t recv (char *buf, - size_t len, - int flags, - ACE_Time_Value *s = 0); - - /// Read received data into the iovec buffers. - virtual ssize_t recv (iovec *iov, - int iovcnt, - ACE_Time_Value *s = 0); -protected: - TAO_AV_UDP_MCast_Flow_Handler *handler_; - ACE_INET_Addr peer_addr_; - ACE_INET_Addr local_addr_; -}; - -/** - * @class TAO_AV_UDP_MCast_Flow_Handler - * @brief Flow Handler for data sent over multicast sockets. - */ -class TAO_AV_UDP_MCast_Flow_Handler - :public virtual TAO_AV_Flow_Handler, - public virtual ACE_Event_Handler -{ -public: - /// Ctor - /// Dtor - TAO_AV_UDP_MCast_Flow_Handler (void); - virtual ~TAO_AV_UDP_MCast_Flow_Handler (void); - virtual ACE_HANDLE get_handle (void) const; - virtual int handle_input (ACE_HANDLE fd); - virtual int handle_timeout (const ACE_Time_Value &tv, const void *arg = 0); - ACE_SOCK_Dgram_Mcast *get_mcast_socket (void) const; - virtual ACE_Event_Handler* event_handler (void){ return this; } - void set_peer_addr (ACE_INET_Addr *peer_addr); -protected: - ACE_INET_Addr *peer_addr_; - ACE_SOCK_Dgram_Mcast *dgram_mcast_; -}; - -TAO_END_VERSIONED_NAMESPACE_DECL - -#if defined(__ACE_INLINE__) -#include "orbsvcs/AV/MCast.i" -#endif /* __ACE_INLINE__ */ - -#include /**/ "ace/post.h" -#endif /* TAO_AV_MCAST_H */ |