sr_lwtcp_glue.c

/*-----------------------------------------------------------------------------
 * file:   sr_lwtcp_glue.c
 * date:   Thu Nov 20 14:34:07 PST 2003
 * Author: Martin Casado
 *
 * Description:
 *
 * Interface methods for handling packets crossing between lwip and sr.
 *
 *---------------------------------------------------------------------------*/

#include <stdio.h>
#include <assert.h>

#ifdef _SOLARIS_
#include <inttypes.h>
#endif /* _SOLARIS_ */

#define  __USE_BSD 1
#include <sys/socket.h>
#include <netinet/in_systm.h>
#include <netinet/ip.h>

#include "lwip/ip_addr.h"
#include "lwip/ip.h"
#include "lwip/netif.h"
#include "lwip/pbuf.h"
#include "lwip/transport_subsys.h"

#include "sr_base_internal.h"
#include "sr_lwtcp_glue.h"


/*-----------------------------------------------------------------------------
 * Method: sr_transport_input(..)
 * Scope:  Global
 *
 * Called by sr to send a packet to the transport layer.  Packet is assumed
 * to have a header with a correct ip length.  The memory holding packet is
 * left untouched.
 *
 *---------------------------------------------------------------------------*/

void sr_transport_input(uint8_t* packet /* borrowed */)
{
    struct pbuf* pb;
    struct netif inp;

    /* -- this is sort of a hack for now, in the future we should
     *    initialize netif's with the hw information and pass handles
     *    to them around with the packets
     *                                                            -- */
    memset(&inp, sizeof(struct netif), 0);

    struct ip* header = (struct ip*)packet;

    pb = pbuf_alloc(PBUF_RAW, ntohs(header->ip_len), PBUF_RAM);

    pb->len = pb->tot_len = ntohs(header->ip_len);

    memcpy(pb->payload,packet,pb->tot_len);

    tcp_msg_input(pb, &inp);
} /* -- sr_transport_input -- */

/*-----------------------------------------------------------------------------
 * Method: ip_route(..)
 * Scope:  Global
 *
 * Called by lwip to pair a destination with the correct source (based on
 * the routing table.  ip_integ_route(..) must be implemented by the network
 * level implementation
 *
 *---------------------------------------------------------------------------*/

uint32_t /*nbo*/ ip_route(struct ip_addr *dest)
{
    return  sr_integ_findsrcip(dest->addr);
} /* -- ip_route -- */

/*-----------------------------------------------------------------------------
 * Method: sr_lwip_output(..)
 * Scope: Global
 *
 * Called by the lwip transport layer to pass packets to the lower level
 * network stack.  If the header is included the packet simply needs to
 * be routed:
 *
 *  sr_integ_ip_route(..)
 *
 * otherwise an IP header must be added
 *
 *  sr_integ_ip_output(..)
 *
 *---------------------------------------------------------------------------*/

err_t sr_lwip_output(struct pbuf *p, struct ip_addr *src, struct ip_addr *dst, uint8_t proto )
{
    struct pbuf *q;
    uint8_t* payload;
    int offset = 0;

    /* initiate transfer(); */


    payload = (uint8_t*)malloc(p->tot_len);

    memcpy(payload + offset, p->payload, p->len);
    offset += p->len;

    for(q = p->next; q != NULL; q = q->next)
    {
        memcpy(payload + offset, q->payload, q->len);
        offset += q->len;
    }

    sr_integ_ip_output(
            payload, /*disown*/
            proto,
            src->addr,
            dst->addr,
            p->tot_len);

    return 0;
} /* -- sr_lwip_output -- */