ipv4_udp.h

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2001,2002,2003,2004,2005,2006,2007,2008,2009            *
 *   by Rick L. Vinyard, Jr.                                               *
 *   rvinyard@cs.nmsu.edu                                                  *
 *                                                                         *
 *   This file is part of the conexus library.                             *
 *                                                                         *
 *   The conexus library is free software; you can redistribute it and/or  *
 *   modify it under the terms of the GNU General Public License           *
 *   version 3 as published by the Free Software Foundation.               *
 *                                                                         *
 *   The conexus library is distributed in the hope that it will be        *
 *   useful, but WITHOUT ANY WARRANTY; without even the implied warranty   *
 *   of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU   *
 *   General Public License for more details.                              *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this software. If not see <http://www.gnu.org/licenses/>.  *
 ***************************************************************************/
#ifndef CONEXUS_IPV4UDP_H
#define CONEXUS_IPV4UDP_H

#include <set>

#ifdef CONEXUS_HAVE_LINUX_UDP_H
#include <linux/udp.h>
#endif

#include <conexus/ipv4_ip.h>

namespace Conexus
{

  namespace IPv4
  {

    class UDP : public IP
    {
      protected:

        UDP( uint32_t local_if, uint16_t localport, uint16_t remoteport, int proto=IPPROTO_UDP );

        UDP( const std::string& local_if, uint16_t localport, uint16_t remoteport, int proto=IPPROTO_UDP );

      public:

        typedef ConexusPointer<UDP> pointer;

        CONEXUS_ENDPOINT_GENERIC_CREATE();

        static pointer create( uint16_t localport = 0, uint16_t remoteport = 0 );

        static pointer create( uint32_t local_if, uint16_t localport, uint16_t remoteport );

        static pointer create( const std::string& local_if, uint16_t localport = 0, uint16_t remoteport = 0 );

        virtual ~UDP() throw();

        virtual size_t input_available() throw();

        virtual void bind() throw ( bind_exception );

        virtual void bind( const Conexus::Address& a ) throw ( bind_exception );

        virtual void close() throw ( close_exception );

        virtual int output_pending();

        virtual void connect() throw ( connect_exception );

        virtual void connect( const Address& a ) throw ( connect_exception );

        virtual void set_write_without_connect( bool value = true );

        virtual bool write_without_connect() const;

        void add_multicast_interface( unsigned iface_index );

        void add_multicast_interface( const std::string& iface_name );

        void remove_multicast_interface( unsigned iface_index );

        void remove_multicast_interface( const std::string& iface_name );

        bool is_multicast_interface( unsigned iface_index );

        bool is_multicast_interface( const std::string& iface_name );

        virtual bool suppress_multicast_join() const;

        virtual void set_suppress_multicast_join( bool value = true );

        virtual unsigned multicast_hop_limit();

        virtual void set_multicast_hop_limit( unsigned hop_limit );

        static unsigned int default_multicast_hop_limit();

        static void set_default_multicast_hop_limit(unsigned int hop_limit);

        virtual bool is_multicast_loopback_enabled();

        virtual void enable_multicast_loopback( bool enable );

        static bool is_default_multicast_loopback_enabled();

        static void enable_default_multicast_loopback(bool loopback);

        #ifdef UDP_CORK

        void cork();

        void uncork();

        bool is_corked();
        #endif

      protected:

        static unsigned int m_default_hop_limit;
        static bool m_default_loopback_enabled;

        bool m_write_without_connect;
        bool m_suppress_multicast_join;
        std::set<unsigned> m_multicast_interfaces;
        unsigned m_multicast_hop_limit;
        bool m_multicast_loopback_enabled;

        virtual void on_local_address_changed( );
        virtual void on_remote_address_changed( );

        virtual void join();

        virtual void join(unsigned interface);

        virtual void leave();

        virtual void leave(unsigned interface);

        virtual size_t write_data( const Data data, Timeout timeout ) throw ( write_exception );

    };

  }

}

#endif