#include <vsnet_socketudp.h>

Inheritance diagram for VsnetUDPSocket:

Public Member Functions
	VsnetUDPSocket (int sock, const AddressIP &remote_ip, SocketSet &set)

	~VsnetUDPSocket ()

virtual bool	isTcp () const

virtual int	optPayloadSize () const

virtual int	queueLen (int pri)

virtual bool	isActive ()

virtual int	sendbuf (Packet packet, const AddressIP to, int pcktflags)

virtual int	recvbuf (Packet p, AddressIP ipadr)

virtual bool	lower_selected (int datalen=-1)

virtual void	dump (std::ostream &ostr) const

virtual bool	setRemoteAddress (const AddressIP &inp)

Public Member Functions inherited from VsnetSocket
	VsnetSocket (int sock, const AddressIP &remote_ip, const char *socktype, SocketSet &set)

virtual	~VsnetSocket ()

bool	eq (const VsnetSocket &r) const

bool	lt (const VsnetSocket &r) const

bool	sameAddress (const VsnetSocket &r) const

const AddressIP &	getRemoteAddress () const

const AddressIP &	getLocalAddress () const

bool	setLocalAddress (const AddressIP &lip)

Public Member Functions inherited from VsnetSocketBase
	VsnetSocketBase (int fd, const char *socktype, SocketSet &set)

virtual	~VsnetSocketBase ()

bool	valid () const

int	get_fd () const

int	close_fd ()

const char *	get_socktype () const

bool	set_block ()

bool	set_nonblock ()

bool	get_nonblock () const

void	disconnect (const char *s)

virtual bool	need_test_writable ()

virtual bool	write_on_negative ()

virtual int	get_write_fd () const

virtual int	lower_sendbuf ()

virtual void	lower_clean_sendbuf ()

virtual bool	isReadyToSend (fd_set *)

void	setSet (SocketSet *set)

Additional Inherited Members
Protected Member Functions inherited from VsnetSocketBase
virtual void	child_disconnect (const char *s)

Protected Attributes inherited from VsnetSocket
AddressIP	_remote_ip

AddressIP	_local_ip

Detailed Description

Definition at line 15 of file vsnet_socketudp.h.

Constructor & Destructor Documentation

VsnetUDPSocket::VsnetUDPSocket	(	int	sock,
		const AddressIP &	remote_ip,
		SocketSet &	set
	)

Definition at line 22 of file vsnet_socketudp.cpp.

References MAXBUFFER, and VsnetUDPSocket().

Referenced by VsnetUDPSocket().

                                                                                            :
     VsnetSocket( sock, remote_ip, "VsnetUDPSocket", socketset )
     , _mtu_size_estimation( 1024 )
 {
     _negotiated_max_size = MAXBUFFER;
     _recv_buf = new char[MAXBUFFER];
 }

VsnetUDPSocket::~VsnetUDPSocket ( )

Definition at line 30 of file vsnet_socketudp.cpp.

 {
     delete[] _recv_buf;
 }

Member Function Documentation

void VsnetUDPSocket::dump ( std::ostream & ostr) const

virtual

Implements VsnetSocket.

Definition at line 119 of file vsnet_socketudp.cpp.

References VsnetSocket::_remote_ip, and VsnetSocketBase::get_fd().

 {
     ostr<<"( s="<<get_fd()<<" UDP r="<<_remote_ip<<" )";
 }

bool VsnetUDPSocket::isActive ( )

virtual

Implements VsnetSocketBase.

Definition at line 124 of file vsnet_socketudp.cpp.

References VSMutex::lock(), and VSMutex::unlock().

 {
     _cpq_mx.lock();
     bool ret = (_cpq.empty() == false);
     _cpq_mx.unlock();
     return ret;
 }

virtual bool VsnetUDPSocket::isTcp ( ) const

inlinevirtual

Implements VsnetSocket.

Definition at line 20 of file vsnet_socketudp.h.

     {
         return false;
     }

bool VsnetUDPSocket::lower_selected ( int datalen = -1)

virtual

Implements VsnetSocketBase.

Definition at line 132 of file vsnet_socketudp.cpp.

References VsnetSocketBase::_set, SocketSet::add_pending(), COUT, VsnetSocketBase::get_fd(), VSMutex::lock(), VSMutex::unlock(), and vsnetLastError().

 {
     int       ret = 0;
     socklen_t len1;
     AddressIP from;
     size_t    lentoread = _negotiated_max_size;
     if (datalen != -1)
         lentoread = datalen;
     //In UDP mode, always receive data on sock
     len1 = sizeof (sockaddr_in);
     ret  = recvfrom( get_fd(), _recv_buf, lentoread,
                      0, (sockaddr*) (sockaddr_in*) &from, &len1 );
     if (ret < 0) {
         COUT<<" fd="<<get_fd()<<" error receiving: "
             <<vsnetLastError()<<endl;
     } else if (ret == 0) {
         COUT<<" Received "<<ret<<" bytes : "<<_recv_buf
             <<" (UDP socket closed, strange)"<<endl;
     } else {
 //COUT << "NETUI : Recvd " << ret << " bytes" << " <- " << from << endl;
         Pending mem( _recv_buf, ret, from );
         _cpq_mx.lock();
         _cpq.push( mem );
         _cpq_mx.unlock();
         if (_set) _set->add_pending( get_fd() );
         return true;
     }
     return false;
 }

int VsnetUDPSocket::optPayloadSize ( ) const

virtual

Implements VsnetSocket.

Definition at line 35 of file vsnet_socketudp.cpp.

 {
     return _mtu_size_estimation;
 }

int VsnetUDPSocket::queueLen ( int pri)

virtual

Implements VsnetSocket.

Definition at line 40 of file vsnet_socketudp.cpp.

 {
     return 0;
 }

int VsnetUDPSocket::recvbuf	(	Packet *	p,
		AddressIP *	from
	)

virtual

This function copies or moves data into the given PacketMem variable. It is preferred over the other recvbuf function because it may reduce the number of copy operations by at least one.

Implements VsnetSocket.

Definition at line 101 of file vsnet_socketudp.cpp.

References VsnetSocketBase::_set, buffer, VsnetSocketBase::get_fd(), PacketMem::len(), VSMutex::lock(), SocketSet::rem_pending(), and VSMutex::unlock().

 {
     _cpq_mx.lock();
     if ( _cpq.empty() ) {
         _cpq_mx.unlock();
         if (_set) _set->rem_pending( get_fd() );
         return -1;
     }
     PacketMem buffer = _cpq.front().mem;
     if (ipadr) *ipadr = _cpq.front().ip;
     _cpq.pop();
     _cpq_mx.unlock();
     int    len = buffer.len();
     Packet packet( buffer );
     *p = packet;
     return len;
 }

int VsnetUDPSocket::sendbuf	(	Packet *	packet,
		const AddressIP *	to,
		int	pcktflags
	)

virtual

Implements VsnetSocket.

Definition at line 69 of file vsnet_socketudp.cpp.

References VsnetSocket::_remote_ip, COUT, Packet::display(), VsnetSocketBase::get_fd(), Packet::getCommand(), Packet::getSendBuffer(), Packet::getSendBufferLength(), vsnetLastError(), and x.

 {
 //COUT << "enter " << __PRETTY_FUNCTION__ << endl;
     int numsent;
 
     //In UDP mode, always send on this->sock
     const sockaddr_in *dest = to;
     if (dest == NULL) dest = &_remote_ip;
     assert( dest != NULL );
     if (packet->getSendBufferLength() >= 512) {
         int *x = NULL;
         COUT<<"Trying to send UDP "<<packet->getCommand()<<" of invalid size "
             <<packet->getSendBufferLength()<<"(>=512)"<<endl;
         packet->display( __FILE__, __LINE__ );
         cout<<flush;
         cerr<<flush;
 #ifndef NO_CRASH_INVALID_UDP
         (*x) = 1;           //Cause crash.
 #endif
         return -1;
     }
     numsent = sendto( get_fd(),
                      packet->getSendBuffer(), packet->getSendBufferLength(),
                      0, (sockaddr*) dest, sizeof (struct sockaddr_in) );
     if (numsent < 0) {
         COUT<<"Error sending: "<<vsnetLastError()<<endl;
         return -1;
     }
 //cout<<"Sent "<<numsent<<" bytes"<<" -> "<<inet_ntoa( dest->sin_addr)<<":"<<ntohs(dest->sin_port)<<endl;
     return numsent;
 }

bool VsnetUDPSocket::setRemoteAddress ( const AddressIP & inp)

virtual

Reimplemented from VsnetSocket.

Definition at line 64 of file vsnet_socketudp.cpp.

References VsnetSocket::_remote_ip.

 {
     _remote_ip = to;
     return true;
 }

The documentation for this class was generated from the following files:

src/networking/lowlevel/vsnet_socketudp.h
src/networking/lowlevel/vsnet_socketudp.cpp

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation