diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/AV/MCast.h')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/AV/MCast.h | 110 |
1 files changed, 0 insertions, 110 deletions
diff --git a/TAO/orbsvcs/orbsvcs/AV/MCast.h b/TAO/orbsvcs/orbsvcs/AV/MCast.h deleted file mode 100644 index 530163eaa49..00000000000 --- a/TAO/orbsvcs/orbsvcs/AV/MCast.h +++ /dev/null @@ -1,110 +0,0 @@ -/* -*- C++ -*- */ - -// $Id$ - -// ============================================================================ -// -// = LIBRARY -// ORBSVCS AVStreams -// -// = FILENAME -// MCast.h -// -// = AUTHOR -// Nagarajan Surendran <naga@cs.wustl.edu> -// -// -// ============================================================================ - -#ifndef TAO_AV_MCAST_H -#define TAO_AV_MCAST_H - -#include "FlowSpec_Entry.h" -#include "Protocol_Factory.h" -#include "ace/INET_Addr.h" -#include "ace/SOCK_Dgram_Mcast.h" - -class TAO_AV_UDP_MCast_Flow_Handler; - -class TAO_AV_UDP_MCast_Transport - :public TAO_AV_Transport -{ - // = TITLE - // A transport abstraction for Multicast dgram sockets. - // - // = DESCRIPTION - // Uses the ACE_SOCK_Dgram_Mcast to send the data. -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); - - 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 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_UDP_MCast_Flow_Handler *handler_; - ACE_INET_Addr peer_addr_; - ACE_INET_Addr local_addr_; -}; - -class TAO_AV_UDP_MCast_Flow_Handler - :public virtual TAO_AV_Flow_Handler, - public virtual ACE_Event_Handler -{ -public: - TAO_AV_UDP_MCast_Flow_Handler (void); - // Ctor - ~TAO_AV_UDP_MCast_Flow_Handler (void); - // Dtor - 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; } -protected: - ACE_INET_Addr peer_addr_; - ACE_SOCK_Dgram_Mcast *dgram_mcast_; -}; - -#if defined(__ACE_INLINE__) -#include "MCast.i" -#endif /* __ACE_INLINE__ */ - -#endif /* TAO_AV_MCAST_H */ |