nspr/socket.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 CONEXUSNSPRSOCKET_H
#define CONEXUSNSPRSOCKET_H

#include <sys/types.h>

#include <iostream>

#include <utility>

#include <conexus-nspr/filedescriptor.h>
#include <conexus/ipv4_address.h>
#include <conexus/except.h>

namespace Conexus
{

  namespace NSS
  {
    class SSLSocket;
  }
  
  namespace NSPR
  {

    class Socket: public FileDescriptor
    {
      protected:

        Socket( ) throw ();

      public:
        
        typedef ConexusPointer<Socket> pointer;

        virtual ~Socket() throw ();

        virtual void close( bool force = false ) throw ( close_exception );

        virtual void bind() throw ( bind_exception );

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

        virtual void connect() throw ( connect_exception );

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

        virtual void listen( int backlog = 0 );

        virtual ssize_t writeto(Address& a, const Data data) throw (write_exception);

        virtual void set_option( PRSocketOptionData& option );

        virtual void change_state( long states ) throw ( state_exception );

        sigc::signal<void> signal_bound();

        sigc::signal<void> signal_connected();

        sigc::signal<void> signal_listening();

        bool is_bound();

        bool is_connected();

        bool is_listening();

        bool is_accepted();

        bool set_non_blocking(bool set=true);

        bool is_non_blocking();

        virtual Conexus::IPv4::Address& local_address();

        virtual Conexus::IPv4::Address& remote_address();

        virtual void set_remote_address( Conexus::IPv4::Address addr );

        virtual void unset_remote_address();

        virtual void set_local_address( Conexus::IPv4::Address addr );

      protected:
        friend class Conexus::NSS::SSLSocket;
        
        Conexus::IPv4::Address m_local_address;
        Conexus::IPv4::Address m_remote_address;
        bool m_remote_address_set;

        bool m_non_blocking;

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

        virtual Data read_data( size_t s, Timeout timeout ) throw ( read_exception );

        virtual void set_state_closed();
        virtual void set_state_bound();
        virtual void set_state_connected();
        virtual void set_state_listening();

        sigc::signal<void> m_signal_bound;
        sigc::signal<void> m_signal_connected;
        sigc::signal<void> m_signal_listening;

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

        void on_local_address_changed_proxy( );
        void on_remote_address_changed_proxy( );

    };

  }
}

#endif