DatagramSocket.h

Go to the documentation of this file.

/* Copyright (C) 2000 KOM/Darmstadt University of Technology
 *
 * You are allowed to use all other parts of the code under the following terms:
 *
 * For non-commercial use, code may be used in unmodified form provided
 * that this copyright notice and this permission notice appear in
 * supporting documentation.
 *
 * This software is provided "as is" and without any express or implied
 * warranties, including, without limitation, the implied warranty of
 * fitness for a particular purpose.
 *
 * The code may be subjected to the GNU General Public License, Version 2,
 * and re-distributed under the terms of this license.
 * As a special exception, permission is granted to link this code
 * with the Qt library and distribute executables, as long as you
 * follow the requirements of the GNU GPL in regard to all of the
 * software in the executable aside from Qt.
 *
 * Commercial use other than under the terms of the GNU General Public
 * License is allowed only after express negotiation of conditions
 * with the authors.
 */
#ifndef MN_OS_NET_DATAGRAMSOCKET_H
#define MN_OS_NET_DATAGRAMSOCKET_H

/*************************************************************
 * Classes defined in this header file:
 * DatagramSocket
 */

#include "MNSocket.h"
#include "MNRope.h"
#include "MNUDPServerSocket.h"
#include "RefCountedSocketFactory.h"
#include <sys/uio.h>
#include <assert.h>

class MNSelector;
class MNRope;

/* The Linux netinet header files are a shame, because they're completely
 * inconsitant compared to what the standards define.
 * Better check if this is defined in the 2.2.2 Kernel
 */

#define IP_RECVDSTADDR  7       /* bool; receive IP dst addr w/datagram */ 

class DatagramSocket : public MNUDPServerSocket
{
private:
  void get_size_packet( );
 
public:
  DatagramSocket( RefCountedSocketFactory* factory,
                      MNSelector&        sel,
                      MNSocket&          sock );

  DatagramSocket( RefCountedSocketFactory* factory,
                      MNSelector&        sel,
                      int                port );

  MNSocketBaseT<DatagramSocket> _callmeplease;  
  MNSocketBaseT<DatagramSocket> _callmepleasewrite;
  virtual ~DatagramSocket ( );
 
  virtual void activate ( bool sender );
  
  virtual void tcp_callback ( MNSelector* select, int fd );

  virtual void write_enabled ( );

  struct iovec* set_buffers_tcp ( int& iovlen, int& buffersize );
 
  void buffers_to_rope_tcp ( struct iovec* iov, int& iovlen, size_t bytesused );

private:
  int _packet_size;
  bool _size_packet;
  bool _data_packet;
  int _left_to_read;
  char* _size_packet_buffer;
  MNRope* _rope;
};

#endif /* MN_OS_NET_DATAGRAMSOCKET_H */

---