WiFi UDP
#include <WiFiUDP.h>
/*H*******************************************************
WiFiUdp.cpp - Library for Arduino WiFi shield.
Copyright ( c) 2011-2014 Arduino LLC. All right reserved.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or ( at your option) any later version.
This 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
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
********************************************************/
extern "C" {
#include "utility/debug.h"
#include "utility/wifi_spi.h"
}
#include <string.h>
#include "utility/server_drv.h"
#include "utility/wifi_drv.h"
#include "WiFi.h"
#include "WiFiUdp.h"
#include "WiFiClient.h"
#include "WiFiServer.h"
/* Constructor */
WiFiUDP::WiFiUDP() : _sock( NO_SOCKET_AVAIL) {}
/*F********************************************************************
* START WiFiUDP SOCKET, LISTENING AT LOCAL PORT PORT
**********************************************************************/
uint8_t WiFiUDP::
begin( uint16_t port )
{
uint8_t sock = WiFiClass::getSocket();
if( sock != NO_SOCKET_AVAIL )
{
ServerDrv::startServer( port, sock, UDP_MODE );
WiFiClass::_server_port[sock] = port;
_sock = sock;
_port = port;
return( 1 );
}
return( 0 );
}
/*F********************************************************************
* RETURN NUMBER OF BYTES AVAILABLE IN THE CURRENT PACKET,
WILL RETURN ZERO IF PARSEpACKET HASN'T BEEN CALLED YET
**********************************************************************/
int WiFiUDP::
available()
{
if( _sock != NO_SOCKET_AVAIL )
return( ServerDrv::availData( _sock ) );
return( 0 );
}
/*F********************************************************************
* RELEASE ANY RESOURCES BEING USED BY THIS WiFiUDP INSTANCE
**********************************************************************/
void WiFiUDP::
stop()
{
if( _sock == NO_SOCKET_AVAIL)
return;
ServerDrv::stopClient( _sock);
_sock = NO_SOCKET_AVAIL;
}
/*F********************************************************************
* LOOK UP THE HOST FIRST
**********************************************************************/
int WiFiUDP::
beginPacket( const char *host, uint16_t port )
{
int ret = 0;
IPAddress remote_addr;
if( WiFi.hostByName( host, remote_addr))
return( beginPacket( remote_addr, port) );
return( ret );
}
/*F********************************************************************
*
**********************************************************************/
int WiFiUDP::
beginPacket( IPAddress ip, uint16_t port )
{
if( _sock == NO_SOCKET_AVAIL)
_sock = WiFiClass::getSocket();
if( _sock != NO_SOCKET_AVAIL)
{
ServerDrv::startClient( uint32_t( ip), port, _sock, UDP_MODE);
WiFiClass::_state[_sock] = _sock;
return( 1 );
}
return( 0 );
}
/*F********************************************************************
*
**********************************************************************/
int WiFiUDP::
endPacket()
{
return( ServerDrv::sendUdpData( _sock) );
}
/*F********************************************************************
*
**********************************************************************/
size_t WiFiUDP::
write( uint8_t byte )
{
return( write( &byte, 1) );
}
/*F********************************************************************
*
**********************************************************************/
size_t WiFiUDP::
write( const uint8_t *buffer, size_t size)
{
ServerDrv::insertDataBuf( _sock, buffer, size);
return( size );
}
/*F********************************************************************
*
**********************************************************************/
int WiFiUDP::
parsePacket()
{
return( available() );
}
/*F********************************************************************
*
**********************************************************************/
int WiFiUDP::
read()
{
uint8_t b;
if( available())
{
ServerDrv::getData( _sock, &b );
return( b );
}
else
return( -1 );
}
/*F********************************************************************
*
**********************************************************************/
int WiFiUDP::
read( unsigned char *buffer, size_t len )
{
if( available())
{
uint16_t size = 0;
if( !ServerDrv::getDataBuf( _sock, buffer, &size))
return( -1 );
// TODO check if the buffer is too small in respect to buffer size
return( size );
}
else
return( -1 );
}
/*F********************************************************************
*
**********************************************************************/
int WiFiUDP::
peek()
{
uint8_t b;
if( !available())
return( -1 );
ServerDrv::getData( _sock, &b, 1);
return( b );
}
/*F********************************************************************
*
**********************************************************************/
void WiFiUDP::
flush()
{
// TODO: a real check to ensure transmission has been completed
}
/*F********************************************************************
*
**********************************************************************/
IPAddress WiFiUDP::
remoteIP()
{
uint8_t _remoteIp[4] = { 0 };
uint8_t _remotePort[2] = { 0 };
WiFiDrv::getRemoteData( _sock, _remoteIp, _remotePort );
IPAddress ip( _remoteIp );
return( ip );
}
/*F********************************************************************
*
**********************************************************************/
uint16_t WiFiUDP::
remotePort()
{
uint8_t _remoteIp[4] = { 0 };
uint8_t _remotePort[2] = { 0 };
WiFiDrv::getRemoteData( _sock, _remoteIp, _remotePort );
uint16_t port = ( _remotePort[0] << 8 ) + _remotePort[1];
return( port );
}