tcplib.h

tinyos-2.x.rar

/*
 * "Copyright (c) 2008, 2009 The Regents of the University  of California.
 * All rights reserved."
 *
 * Permission to use, copy, modify, and distribute this software and its
 * documentation for any purpose, without fee, and without written agreement is
 * hereby granted, provided that the above copyright notice, the following
 * two paragraphs and the author appear in all copies of this software.
 *
 * IN NO EVENT SHALL THE UNIVERSITY OF CALIFORNIA BE LIABLE TO ANY PARTY FOR
 * DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES ARISING OUT
 * OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF THE UNIVERSITY OF
 * CALIFORNIA HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * THE UNIVERSITY OF CALIFORNIA SPECIFICALLY DISCLAIMS ANY WARRANTIES,
 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
 * AND FITNESS FOR A PARTICULAR PURPOSE.  THE SOFTWARE PROVIDED HEREUNDER IS
 * ON AN "AS IS" BASIS, AND THE UNIVERSITY OF CALIFORNIA HAS NO OBLIGATION TO
 * PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS, OR MODIFICATIONS."
 *
 */
#ifndef TCPLIB_H_
#define TCPLIB_H_

/* 
 * tcplib: a simple tcp implemented in a library
 * @author Stephen Dawson-Haggerty <[e-mail]>
 *
 *
 */

// #include <netinet/in.h>
#include "ip.h"

#define min(X,Y) (((X) > (Y)) ? (Y) : (X))
#ifndef PC
#define printf(X, args ...) dbg("stdout", X, ## args)
#define fprintf(X, Y, args ...) dbg("fprintf", Y, ## args)
#endif

typedef enum {
  TCP_CLOSED = 0,
  TCP_LISTEN,
  TCP_SYN_RCVD,
  TCP_SYN_SENT,
  TCP_ESTABLISHED,
  TCP_CLOSE_WAIT,
  TCP_LAST_ACK,
  TCP_FIN_WAIT_1,
  TCP_FIN_WAIT_2,
  TCP_CLOSING,
  TCP_TIME_WAIT,
} tcplib_sock_state_t;

enum {
  TCP_ACKPENDING  = 0x3,
  TCP_DUPACKS     = 0x3c,
  TCP_DUPACKS_OFF = 2,
  TCP_ACKSENT     = 0x80,
};

enum {
  /* how many timer tics to stay in TIME_WAIT */
  TCPLIB_TIMEWAIT_LEN = 1,
  /* how many un-acked retransmissions before we give up the connection */
  TCPLIB_GIVEUP = 6,
};

#define GET_ACK_COUNT(X)    (((X) & TCP_DUPACKS) >> TCP_DUPACKS_OFF)
#define UNSET_ACK_COUNT(X)  ((X) &= ~TCP_DUPACKS)
#define INCR_ACK_COUNT(X)   ((X) += 1 << TCP_DUPACKS_OFF)

struct tcplib_sock {
  uint8_t flags;
  
  /* local and remote endpoints */
  struct sockaddr_in6 l_ep;
  struct sockaddr_in6 r_ep;

  /* current connection state */
  tcplib_sock_state_t state;

  void    *tx_buf;
  uint16_t tx_buf_len;

  /* max segment size, or default if
     we didn't bother to pull it out
     of the options field */
  uint16_t mss;

  uint16_t my_wind;
  /* the window the other end is
     reporting */
  uint16_t r_wind;
  uint16_t cwnd;
  uint16_t ssthresh;

  // the current next sequence number for ourgoing data.
  uint32_t seqno;
  // and the index of the last byte we've ACKed
  uint32_t ackno;

  struct {
    int8_t retx;
  } timer;

  /* retransmission counter */
  uint16_t retxcnt;

  /* callbacks for this connection */
/*   struct { */
/*     /\* a previous connection request has finished *\/ */
/*     void (*connect_done)(struct tcplib_sock *sock, int error); */

/*     /\* a callback to signal new data is ready *\/ */
/*     void (*recvfrom)(struct tcplib_sock *sock, void *data, int len); */

/*     /\* the connection was closed by the other party *\/ */
/*     void (*closed)(struct tcplib_sock *sock); */

/*     /\* you called close(); we've finished closing the socket. *\/ */
/*     void (*close_done)(struct tcplib_sock *sock); */
/*   } ops; */

  /* this needs to be at the end so
     we can call init() on a socket
     without blowing away the linked
     list */
  struct tcplib_sock *next;
};

/* EVENTS 
 * ------------------------------------------------------------ 
 *
 * calls generated by tcplib that must be dealt with elsewhere in the
 * program.
 */


/* called when a new connection request is recieved on a socket which
 * is LISTENing.
 *
 *
 * return 0 if it wants to accept the connection and allocated a
 * buffer for it; -1 otherwise.
 */
struct tcplib_sock *tcplib_accept(struct tcplib_sock *conn,
                                  struct sockaddr_in6 *from);

/* a call-out point for tcplib to send a message */
void tcplib_send_out(struct split_ip_msg *msg, struct tcp_hdr *tcph);

/* upcall for new data; may be dispatched all the way out to a
 * handler. 
 *
 * Returns: 0 on success,
 * -1 otherwise.  The error may be safely ignored.
 */
int tcplib_process(struct ip6_hdr *ip_packet, void *payload);  

/*
 * should be called every 500ms to increment all the tcp timers
 */
int tcplib_timer_process();

/* Just fill in the fields of the socket.
 *
 * If you perform a send on a socket in this state, an ephemeral port
 * will be allocated to it.
 *
 * This must be called once on any socket that might be sent on, or
 * might have bind() called.
 */
int tcplib_init_sock(struct tcplib_sock *sock);

/* bind the socket to a local address */
int tcplib_bind(struct tcplib_sock *sock,
                struct sockaddr_in6 *addr);

/* connect the socket to a remote endpoint */
int tcplib_connect(struct tcplib_sock *sock,
                   struct sockaddr_in6 *serv_addr);


/* send data on an open socket.
 *
 * returns: 0 on success
 *   other errors
 *     - no local buffer is available,
 *     
 */
int tcplib_send(struct tcplib_sock *sock,
                 void *data, int len);

int tcplib_close(struct tcplib_sock *sock);

/* abort a connection 
 *
 * This will send a RST segment if the connection has been opened and
 * immediately return the socket to the CLOSED, uninitialized state,
 * although buffer pointers are maintained.
 *
 */
int tcplib_abort(struct tcplib_sock *sock);
#endif