ipv4_udpposet.h

Go to the documentation of this file.

/***************************************************************************
 *   Copyright (C) 2001 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_IPV4UDPPOSET_H
#define CONEXUS_IPV4UDPPOSET_H

#include <conexus/ipv4_udp.h>

#include <map>
#include <set>

namespace Conexus
{

  namespace IPv4
  {

    class UDPPoset : public UDP
    {
      protected:

        UDPPoset( uint32_t local_if, uint16_t localport );

        UDPPoset( const std::string& local_if, uint16_t localport );

      public:
        // TODO Revisit and see if possible to add multicast support
        // TODO examine adding socket pools

        typedef std::multimap<int,Address> Destinations;

        typedef ConexusPointer<UDPPoset> pointer;

        CONEXUS_ENDPOINT_GENERIC_CREATE();

        static UDPPoset::pointer create( uint16_t localport = 0 );

        static UDPPoset::pointer create( uint32_t local_if, uint16_t localport = 0 );

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

        virtual ~UDPPoset() throw();

        virtual void bind() throw ( bind_exception );

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

        virtual void close() throw ( close_exception );

        virtual void connect() throw ( connect_exception );

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

        virtual void set_write_without_connect( bool value = true );

        bool add_destination( const Address& destination, int priority = 0, bool singleton = true );

        bool add_destination( uint32_t host, uint16_t port, int priority = 0, bool singleton = true );

        bool add_destination( std::string host, uint16_t port, int priority = 0, bool singleton = true );

        void remove_destination( const Address& destination, int priority );

        void remove_destination( const Address& destination );

        bool is_destination( const Address& destination );

        bool is_destination( const Address& destination, int priority );

        std::set<int> priorities( const Address& destination );

        const Destinations& destinations();

        sigc::signal<void,Address,int> signal_destination_added();

        sigc::signal<void,Address,int> signal_destination_removed();

      protected:
        Destinations m_addresses;

        sigc::signal<void,Address,int> m_signal_destination_added;

        sigc::signal<void,Address,int> m_signal_destination_removed;

        virtual void on_local_address_changed( unsigned which );

        virtual void on_remote_address_changed( unsigned which );

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

    };

  }

}

#endif