#include <cassert>#include <cstdio>#include <cstring>#include <errno.h>#include <iostream>#include <cstdlib>#include <time.h>#include <arpa/inet.h>#include <stdlib.h>#include <unistd.h>#include <fcntl.h>#include <netinet/in.h>#include <sys/socket.h>#include <sys/types.h>#include <netdb.h>#include <string.h>#include "rutil/stun/Udp.hxx"
Include dependency graph for Udp.cxx:
Go to the source code of this file.
Functions | |
| resip::Socket | openPort (unsigned short port, unsigned int interfaceIp, bool verbose) |
| Open a UDP socket to receive on the given port - if port is 0, pick a a port, if interfaceIp!=0 then use ONLY the interface specified instead of all of them. | |
| bool | getMessage (resip::Socket fd, char *buf, int *len, UInt32 *srcIp, unsigned short *srcPort, bool verbose) |
| recive a UDP message | |
| bool | sendMessage (resip::Socket fd, char *buf, int l, unsigned int dstIp, unsigned short dstPort, bool verbose) |
| send a UDP message | |
Function Documentation
| bool getMessage | ( | resip::Socket | fd, |
| char * | buf, | ||
| int * | len, | ||
| UInt32 * | srcIp, | ||
| unsigned short * | srcPort, | ||
| bool | verbose | ||
| ) |
recive a UDP message
Definition at line 118 of file Udp.cxx.
References resip::getErrno(), INVALID_SOCKET, and SOCKET_ERROR.
Referenced by stunNatType(), stunOpenSocket(), stunOpenSocketPair(), stunServerProcess(), and stunTest().
{
assert( fd != INVALID_SOCKET );
int originalSize = *len;
assert( originalSize > 0 );
struct sockaddr_in from;
int fromLen = sizeof(from);
*len = recvfrom(fd,
buf,
originalSize,
0,
(struct sockaddr *)&from,
(socklen_t*)&fromLen);
if ( *len == SOCKET_ERROR )
{
int err = getErrno();
switch (err)
{
case ENOTSOCK:
cerr << "Error fd not a socket" << endl;
break;
case ECONNRESET:
cerr << "Error connection reset - host not reachable" << endl;
break;
default:
cerr << "Socket Error=" << err << endl;
}
return false;
}
if ( *len < 0 )
{
clog << "socket closed? negative len" << endl;
return false;
}
if ( *len == 0 )
{
clog << "socket closed? zero len" << endl;
return false;
}
*srcPort = ntohs(from.sin_port);
*srcIp = ntohl(from.sin_addr.s_addr);
if ( (*len)+1 >= originalSize )
{
if (verbose)
{
clog << "Received a message that was too large" << endl;
}
return false;
}
buf[*len]=0;
return true;
}
Here is the call graph for this function:
| resip::Socket openPort | ( | unsigned short | port, |
| unsigned int | interfaceIp, | ||
| bool | verbose | ||
| ) |
Open a UDP socket to receive on the given port - if port is 0, pick a a port, if interfaceIp!=0 then use ONLY the interface specified instead of all of them.
Definition at line 38 of file Udp.cxx.
References resip::closeSocket(), resip::getErrno(), INVALID_SOCKET, and strerror().
Referenced by stunInitServer(), stunNatType(), stunOpenSocket(), stunOpenSocketPair(), stunServerProcess(), and stunTest().
{
resip::Socket fd;
fd = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
if ( fd == INVALID_SOCKET )
{
int err = getErrno();
cerr << "Could not create a UDP socket:" << err << endl;
return INVALID_SOCKET;
}
struct sockaddr_in addr;
memset((char*) &(addr),0, sizeof((addr)));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = htonl(INADDR_ANY);
addr.sin_port = htons(port);
if ( (interfaceIp != 0) &&
( interfaceIp != 0x100007f ) )
{
addr.sin_addr.s_addr = htonl(interfaceIp);
if (verbose )
{
clog << "Binding to interface "
<< hex << "0x" << htonl(interfaceIp) << dec << endl;
}
}
if ( bind( fd,(struct sockaddr*)&addr, sizeof(addr)) != 0 )
{
int e = getErrno();
switch (e)
{
case 0:
{
cerr << "Could not bind socket" << endl;
closeSocket(fd);
return INVALID_SOCKET;
}
case EADDRINUSE:
{
cerr << "Port " << port << " for receiving UDP is in use" << endl;
closeSocket(fd);
return INVALID_SOCKET;
}
break;
case EADDRNOTAVAIL:
{
if ( verbose )
{
cerr << "Cannot assign requested address" << endl;
}
closeSocket(fd);
return INVALID_SOCKET;
}
break;
default:
{
cerr << "Could not bind UDP receive port"
<< "Error=" << e << " " << strerror(e) << endl;
closeSocket(fd);
return INVALID_SOCKET;
}
break;
}
}
if ( verbose )
{
clog << "Opened port " << port << " with fd " << fd << endl;
}
assert( fd != INVALID_SOCKET );
return fd;
}
Here is the call graph for this function:
| bool sendMessage | ( | resip::Socket | fd, |
| char * | buf, | ||
| int | l, | ||
| unsigned int | dstIp, | ||
| unsigned short | dstPort, | ||
| bool | verbose | ||
| ) |
send a UDP message
Definition at line 187 of file Udp.cxx.
References resip::getErrno(), INVALID_SOCKET, SOCKET_ERROR, and strerror().
Referenced by stunSendTest(), and stunServerProcess().
{
assert( fd != INVALID_SOCKET );
int s;
if ( dstPort == 0 )
{
// sending on a connected port
assert( dstIp == 0 );
s = send(fd,buf,l,0);
}
else
{
assert( dstIp != 0 );
assert( dstPort != 0 );
struct sockaddr_in to;
int toLen = sizeof(to);
memset(&to,0,toLen);
to.sin_family = AF_INET;
to.sin_port = htons(dstPort);
to.sin_addr.s_addr = htonl(dstIp);
s = sendto(fd, buf, l, 0,(sockaddr*)&to, toLen);
}
if ( s == SOCKET_ERROR )
{
int e = getErrno();
switch (e)
{
case ECONNREFUSED:
case EHOSTDOWN:
case EHOSTUNREACH:
{
// quietly ignore this
}
break;
case EAFNOSUPPORT:
{
cerr << "err EAFNOSUPPORT in send" << endl;
}
break;
default:
{
cerr << "err " << e << " " << strerror(e) << " in send" << endl;
}
}
return false;
}
if ( s == 0 )
{
cerr << "no data sent in send" << endl;
return false;
}
if ( s != l )
{
if (verbose)
{
cerr << "only " << s << " out of " << l << " bytes sent" << endl;
}
return false;
}
return true;
}
Here is the call graph for this function:
