tcp.h

Go to the documentation of this file.

/*
** tcp.h for  in /home/anoman/work/lse/lseos/lseos-net/inet
** 
** Copyright (c)2004 Arthur Kopatsy
** Login   <kopats_a@epita.fr>
** 
** Started on  Tue Nov  9 10:57:11 2004 Arthur Kopatsy
** Last update Tue Dec 14 09:58:55 2004 Arthur Kopatsy
*/

#ifndef TCP_H_
#define TCP_H_

#define TCP_FL_FIN      0x01
#define TCP_FL_SYN      0x02
#define TCP_FL_RST      0x04
#define TCP_FL_PSH      0x08
#define TCP_FL_ACK      0x10
#define TCP_FL_URG      0x20

struct s_tcp_hdr
{
  u_int16_t             tcp_sp;
  u_int16_t             tcp_dp;
  u_int32_t             tcp_seq;
  u_int32_t             tcp_ack;
#if 1                   /* Little indian */
  u_int8_t              tcp_u : 4;
  u_int8_t              tcp_hl : 4;
  u_int8_t              tcp_flg;
#else
  u_int8_t              tcp_flg;
  u_int8_t              tcp_hl : 4;
  u_int8_t              tcp_u : 4;
#endif
  u_int16_t             tcp_win;
  u_int16_t             tcp_sum;
  u_int16_t             tcp_urp;
} __attribute__ ((packed));

#define TCP_HEADER_LEN  sizeof (struct s_tcp_hdr)

#ifdef __INET__

#define TCP_WINDOW_SIZE         5840
#define TCP_DEFAULT_MSS         1460

/*
** TCP options
*/

#define TCPOPT_EOL              0x00
#define TCPOPT_NOP              0x01
#define TCPOPT_MSS              0x02
# define TCPOPT_LEN_MSS         0x04
#define TCPOPT_WSCALE           0x03
# define TCPOPT_LEN_WSCALE      0x03
#define TCPOPT_SACKOK           0x04
# define TCPOPT_LEN_SACKOK      0x02
#define TCPOPT_SACK             0x05
#define TCPOPT_TIMESTAMP        0x08
# define TCPOPT_LEN_TIMESTAMP   0x0a

struct s_tcp_option
{
  int8_t        opt;
  int8_t        optlen;
};

enum e_tcp_state
  {
    STATE_CLOSED, STATE_LISTEN, STATE_SYN_SENT, STATE_SYN_RCVD, STATE_ESTABLISHED,
    STATE_FIN_WAIT_1, STATE_FIN_WAIT_2, STATE_TIME_WAIT, STATE_CLOSE_WAIT,
    STATE_LAST_ACK
  };

struct s_tcp_segment
{
  TAILQ_ENTRY(s_tcp_segment)            seg_next;

  struct s_tcp_pcb                      *seg_pcb;

  u_int32_t                             seg_seq;
  struct s_data_buf                     *seg_data;
  size_t                                seg_size;

  int                                   seg_try;        /* Retry number */
  int                                   seg_timer_id;   /* Retransmission timer */
  int64_t                               seg_timeout;    /* Current timeout associated with timer*/
  int64_t                               seg_ar;         /* Async report associated with this emission */
};

TAILQ_HEAD(s_tcp_segment_tailq, s_tcp_segment);

struct s_tcp_pcb;
LIST_HEAD(s_tcp_pcb_list, s_tcp_pcb);

struct s_tcp_pcb
{
  LIST_ENTRY(s_tcp_pcb)         tcp_next;
  LIST_ENTRY(s_tcp_pcb)         tcp_next_con;
  int                           tcp_lock;
  enum e_tcp_state              tcp_state;

  /* Send */
  u_int32_t                     tcp_snd_iss;            /* Initial segment sequence */
  u_int32_t                     tcp_snd_una;            /* First not aknowleged segment sequence */
  u_int32_t                     tcp_snd_nxt;            /* Next segment sequence to send */
  u_int16_t                     tcp_snd_win;
  struct s_tcp_segment_tailq    tcp_sndq_una;

  /* Recv */
  u_int32_t                     tcp_rcv_iss;
  u_int16_t                     tcp_rcv_win;
  u_int32_t                     tcp_rcv_una;
  struct s_tcp_segment_tailq    tcp_rcvq_una;           /* Unaknowledged segment queue */
  struct s_tcp_segment_tailq    tcp_rcvq;               /* Aknowledged segment queue */

  struct s_tcp_pcb_list         tcp_con;                /* Connections established or not */

  struct s_in_pcb               *tcp_in_pcb;
  int64_t                       tcp_holders;

  struct s_entry                *tcp_entry;
};

typedef void (*t_tcp_state_fun)(struct s_tcp_pcb        *pcb,
                                struct s_pkbuf          *pk);

struct s_tcp_state
{
  enum e_tcp_state      state;
  t_tcp_state_fun       state_fun;
};

extern struct s_tcp_state tcp_states[];

struct s_tcp_proto_info
{
  struct s_tcp_pcb_list tcp_pcb;
  struct s_in_pcb_list  in_pcb;
  struct s_entry        *tcp_entry;
};

extern struct s_tcp_proto_info  tcp_proto_info;

#endif

/* PROTO tcp.c tcp_socket.c */
#ifdef __INET__
/* tcp.c */
void tcp_dump(struct s_pkbuf *pk);
void tcp_proto_init(void);
u_int32_t tcp_alloc_sequence(void);
int aa_tcp_input(struct s_pkbuf *pk);
int tcp_output(struct s_pkbuf *pk, struct s_tcp_pcb *pcb, int tcp_flags, u_int32_t tcp_seq);
void tcp_syn_sent_timeout(struct s_tcp_segment *segment);
int aa_tcp_connect(struct s_tcp_segment *segment);
void tcp_syn_sent_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
void tcp_send_timeout(struct s_tcp_segment *segment);
int aa_tcp_send(struct s_tcp_segment *segment);
int aa_tcp_ack(struct s_tcp_pcb *pcb);
int aa_tcp_close(struct s_tcp_pcb *pcb);
void tcp_established_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
void tcp_listen_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
int aa_tcp_accept(struct s_tcp_pcb *pcb);
void tcp_syn_rcvd_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
void tcp_last_ack_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
void tcp_fin_wait_1_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
void tcp_fin_wait_2_recv(struct s_tcp_pcb *pcb, struct s_pkbuf *pk);
/* tcp_socket.c */
int tcp_poll(struct s_socket *so, t_pollrec *pollrec);
int tcp_attach(struct s_socket *so);
int tcp_detach(struct s_socket *so);
int tcp_bind(struct s_socket *so, struct sockaddr *sa, socklen_t salen);
int tcp_getpeername(struct s_socket *so, struct sockaddr *sa, socklen_t *salen);
int tcp_getsockname(struct s_socket *so, struct sockaddr *sa, socklen_t *salen);
int tcp_connect(struct s_socket *so, struct sockaddr *sa, socklen_t salen);
size_t tcp_recv(struct s_socket *so, pid_t pid, struct sockaddr *sa, socklen_t *salen, vaddr_t uaddr, size_t usize);
int tcp_accept(struct s_socket *so, struct sockaddr *sa, socklen_t *salen, void **ret_pcb);
int tcp_listen(struct s_socket *so, int backlog);
int tcp_send(struct s_socket *so, struct s_data_buf *data, size_t data_size, struct sockaddr *sa, socklen_t salen);
int tcp_inetfs_read(pid_t pid, struct s_of *of, char *ubuf, size_t usize);
#endif /* __INET__ */
#endif

---