udp_socket.h

Go to the documentation of this file.

/*
Copyright (C) 2004-2007  Anders Hedstrom
 
This library is made available under the terms of the GNU GPL.
 
If you would like to use this library in a closed-source application,
a separate license agreement is available. For information about
the closed-source license agreement for the C++ sockets library,
please visit http://www.alhem.net/Sockets/license.html and/or
email [email protected].
 
This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either version 2
of the License, or (at your option) any later version.
 
This program 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 program; if not, write to the Free Software
Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
*/
#pragma once
 
 
#include "socket.h"
 
 
namespace sockets
{

   class CLASS_DECL_APEX udp_socket :
      virtual public socket
   {
   public:
 
 
      char_pointer m_ibuf; 
      ::i32 m_ibufsz; 
      bool m_bind_ok; 
      ::networking::port_t m_port; 
      memsize m_last_size_written;
      ::i32 m_iConnectionRetryCount;
      bool m_b_read_ts;
 
 
      ::i32 m_iWriteFlags;

      udp_socket(::i32 ibufsz = 16384, bool ipv6 = false, ::i32 retries = 0);
      ~udp_socket();

      //\lparam buf Pointer to data
      //\lparam len Length of data
      //\lparam sa Pointer to sockaddr struct of sender
      //\lparam sa_len Length of sockaddr struct */
      //using socket::OnRawData;
      //virtual void OnRawData(char_pointer buf, memsize len, struct sockaddr * sa, socklen_t sa_len);

      //\lparam buf Pointer to data
      //\lparam len Length of data
      //\lparam sa Pointer to sockaddr struct of sender
      //\lparam sa_len Length of sockaddr struct
      //\lparam ts Timestamp from message */
      //virtual void OnRawData(char_pointer buf, memsize len, struct sockaddr * sa, socklen_t sa_len, struct timeval * ts);

      //\lparam port Incoming port number
      //\lparam range Port range to try if ports already in use
      //\return 0 if bind succeeded */
      //::i32 Bind(::networking::port_t & port, ::i32 range = 1);
      //\lparam intf Interface ip/hostname
      //\lparam port Port number
      //\lparam range Port range
      //\return 0 if bind succeeded */
      //::i32 Bind(const ::scoped_string & scopedstrHost, ::networking::port_t & port, ::i32 range = 1);
      //\lparam a Ip address
      //\lparam port Port number
      //\lparam range Port range
      //\return 0 if bind succeeded */
      //::i32 Bind(in_addr a, ::networking::port_t & port, ::i32 range = 1);
      //\lparam a Ipv6 address
      //\lparam port Port number
      //\lparam range Port range
      //\return 0 if bind succeeded */
      //::i32 Bind(in6_addr a, ::networking::port_t & port, ::i32 range = 1);
      //\lparam ad socket address
      //\lparam range Port range
      //\return 0 if bind succeeded */
      ::i32 Bind(::networking::address & address, ::i32 range = 1);

      //using ::sockets::socket::open;
      //bool open(in_addr l, ::networking::port_t port);
      //\lparam host Hostname
      //\lparam port Port number
      //\return true if successful */
      //bool open(const ::scoped_string & scopedstrHost, ::networking::port_t port);
      bool open(struct in6_addr & a, ::networking::port_t port);
      bool open(::networking::address * address);

      void SendToBuf(const ::scoped_string & scopedstr, ::networking::port_t, const_char_pointer data, ::i32 len, ::i32 flags = 0);
      //void SendToBuf(const in_addr & a, ::networking::port_t, const_char_pointer data, ::i32 len, ::i32 flags = 0);
      //void SendToBuf(const in6_addr & a, ::networking::port_t, const_char_pointer data, ::i32 len, ::i32 flags = 0);
      void SendToBuf(::networking::address * address, const_char_pointer data, ::i32 len, ::i32 flags = 0);

      //void SendTo(const ::scoped_string & scopedstr, ::networking::port_t, const ::scoped_string & scopedstr, ::i32 flags = 0);
      //void SendTo(in_addr, ::networking::port_t, const ::scoped_string & scopedstr, ::i32 flags = 0);
      //void SendTo(in6_addr, ::networking::port_t, const ::scoped_string & scopedstr, ::i32 flags = 0);
      void SendTo(::networking::address * address, const ::scoped_string & scopedstr, ::i32 flags = 0);

      //using ::file::file::write;
      //using ::object::write;
      void write(const void * data, memsize c);
      //void Send(const string &);

      void SetBroadcast(bool b = true);
      bool IsBroadcast();

      void SetMulticastTTL(::i32 ttl = 1);
      ::i32 GetMulticastTTL();
      bool SetMulticastLoop(bool = true);
      bool IsMulticastLoop();
      void AddMulticastMembership(const ::scoped_string & scopedstrGroup, const ::scoped_string & scopedstrInterface = "0.0.0.0", ::i32 if_index = 0);
      void DropMulticastMembership(const ::scoped_string & scopedstrGroup, const ::scoped_string & scopedstrInterface = "0.0.0.0", ::i32 if_index = 0);
      void SetMulticastHops(::i32 = -1);
      ::i32 GetMulticastHops();
      bool IsBound();
      //::networking::port_t GetPort();
      //void OnOptions(::i32, ::i32, ::i32, socket_id) {}
      memsize GetLastSizeWritten();

      void SetTimestamp(bool = true);
 
   protected:
      udp_socket(const udp_socket & s) : base_socket(s), socket(s) {}
      void OnRead();
#if defined(LINUX) || defined(MACOSX)
      ::i32 (char_pointer ioBuf, ::i32 inBufSize, struct sockaddr * from, ::i32 fromlen, struct timeval * ts);
#endif

      void CreateConnection();
 
 
   };
 
 
} // namespace sockets