File content as of revision 3:fd9d20c4d3f0:

/* SpwfSAInterface implementation of NetworkInterfaceAPI
 * Copyright (c) 2015 ARM Limited
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "SPWFInterface.h"
 
// Various timeouts for different SPWF operations
#define SPWF_CONNECT_TIMEOUT 20000
#define SPWF_SEND_TIMEOUT    500
#define SPWF_RECV_TIMEOUT    10000
#define SPWF_MISC_TIMEOUT    15000
 

// SpwfSAInterface implementation
SpwfSAInterface::SpwfSAInterface(PinName tx, PinName rx, PinName rst, PinName wkup, PinName rts, bool debug)
    : _spwf(tx, rx, rst, wkup, rts)
{
    memset(_ids, 0, sizeof(_ids));
    isInitialized = false;
}
 
SpwfSAInterface::~SpwfSAInterface()
{
}

int32_t SpwfSAInterface::init(void) 
{
    _spwf.setTimeout(SPWF_MISC_TIMEOUT);
    return (_spwf.init());
}

int32_t SpwfSAInterface::connect(
    const char *ap, 
    const char *pass_phrase, 
    ns_security_t security)
{
    //initialize the device before connecting
    if(!isInitialized)
    {
        if(init()==0)
            isInitialized=true;
        else return NS_ERROR_DEVICE_ERROR;
    }
    
    _spwf.setTimeout(SPWF_CONNECT_TIMEOUT);
    
    if(security == NS_SECURITY_WPA2) return NS_ERROR_DEVICE_ERROR;
    
    WiFi_Priv_Mode mode = (WiFi_Priv_Mode)security;
  
    return (_spwf.connect((char*)ap, (char*)pass_phrase, mode));//0 on success
}
 
int32_t SpwfSAInterface::disconnect()
{
    if(!isConnected()) return NS_ERROR_NO_CONNECTION;
    
    return (_spwf.disconnect());
}
 
const char *SpwfSAInterface::getIPAddress()
{
    return _spwf.getIPAddress();
}
 
const char *SpwfSAInterface::getMACAddress()
{
    return _spwf.getMACAddress();
}

void SpwfSAInterface::setid(bool set, int id)
{
    if(set)
        _ids[id] = true;
    else
        _ids[id] = false;
}
    
SocketInterface *SpwfSAInterface::createSocket(ns_protocol_t proto)
{
    return new SpwfSASocket(this, &_spwf, proto);
}
 
void SpwfSAInterface::destroySocket(SocketInterface *iface)
{
    SpwfSASocket *socket = (SpwfSASocket *)iface;
    _ids[socket->_id] = false;
    delete socket;
}
 
 
// SpwfSASocket implementation
int32_t SpwfSAInterface::SpwfSASocket::open(const char *ip, uint16_t port)
{
    uint8_t sock_id = 99;
    
    if(!_itf->isConnected()) return NS_ERROR_NO_CONNECTION;
 
    const char *proto = (_proto == NS_UDP) ? "u" : "t";//"s" for secure socket?
 
    __spwf->socket_client_open((uint8_t*)ip, (uint32_t)port, (uint8_t *)proto, &sock_id);
    
    //TODO: Maintain a socket table to map socket ID to host & port
    //TODO: lookup on client table to see if already socket is allocated to same host/port
    //multimap <char *, vector <uint16_t> > ::iterator i = c_table.find((char*)ip);
      
    if(sock_id <= SPWFSA_SOCKET_COUNT)
    {
        _id = sock_id;//the socket ID of this Socket instance
        _itf->setid(true, _id);
        //_itf->c_table.insert(pair <char *, vector <uint16_t> > ((char*)ip, port));
    }
    else 
        return NS_ERROR_NO_SOCKET;
    
    return 0;//0 means SUCCESS
}
 
int32_t SpwfSAInterface::SpwfSASocket::close()
{
    int32_t err;
    
    if(!_itf->isConnected()) return NS_ERROR_NO_CONNECTION;
    
    _itf->setid(false, _id);      
    //_itf->c_table.empty();
    
    err = __spwf->socket_client_close((uint8_t)_id);
    
    return err;
}
 
int32_t SpwfSAInterface::SpwfSASocket::send(const void *data, uint32_t size)
{
    int32_t err;

    if(!_itf->isConnected()) return NS_ERROR_NO_CONNECTION;
    
    err = __spwf->socket_client_write((uint8_t)_id, (uint16_t)size, (char*)data);
    
    return err;
}

//return no of bytes read
int32_t SpwfSAInterface::SpwfSASocket::recv(void *data, uint32_t size)
{
    int32_t recv;
    
    if(!_itf->isConnected()) return NS_ERROR_NO_CONNECTION;
    
    __spwf->setTimeout(SPWF_RECV_TIMEOUT);
    
    recv = __spwf->socket_client_recv((uint8_t)_id, (uint16_t)size, (char*)data);
    
    
    return recv;
    
}

void SpwfSAInterface::debug(const char * string)
{
    _spwf.debug_print(string);
}