pkbuf.h

Go to the documentation of this file.

/*
** pkbuf.h for  in /home/anoman/work/lse/lseos/lseos-net/inet
** 
** Copyright (c)2004 Arthur Kopatsy
** Login   <kopats_a@epita.fr>
** 
** Started on  Thu Oct 14 09:41:40 2004 Arthur Kopatsy
** Last update Fri Dec 10 12:15:18 2004 Arthur Kopatsy
*/

#ifndef LIBINET_PKBUF_H_
#define LIBINET_PKBUF_H_

extern int              gl_buf_cpt;
extern int              gl_pkbuf_cpt;
extern int              gl_data_buf_cpt;

struct s_buf
{
  int                   bf_ref;         /* Reference counter */
};  

struct s_data_buf
{
  off_t                 data_off;       /* Offset inside s_buf */
  size_t                data_size;      /* Size of data inside s_buf */
  struct s_buf          *data_buf;

  /* For fragment management */
  struct s_data_buf     *data_fnext;    /* Next fragment of data */
  off_t                 data_foff;      /* Offset of the fragment */
};

#define BF_DATA(bf, off) ((char *)bf + sizeof (struct s_buf) + off)

struct s_pkbuf
{
  struct s_pkbuf                *pk_fnext;
  TAILQ_ENTRY(s_pkbuf)          pk_next;                /* Used for pkbuf queue */
  
  size_t                        pk_size;                /* Amount of data (header + data) */
  
#define PK_INPUT(pk)            (pk)->pk_info.pk_input_info
#define PK_OUTPUT(pk)           (pk)->pk_info.pk_output_info

#define PK_DA(pk)               (pk)->pk_info.pk_da
#define PK_SA(pk)               (pk)->pk_info.pk_sa

  int64_t                       pk_ar;                  /* Async report id */

  struct s_pk_info
  {
    struct sockaddr_in          pk_da;  
    struct sockaddr_in          pk_sa;

    struct s_input_info
    {
      struct s_iface            *pk_iface;              /* Incoming interface */
    } pk_input_info;

    struct s_output_info
    {
      struct s_route_entry      *pk_route;              /* Route for packet */
    } pk_output_info;
  } pk_info;

  struct s_buf                  *pk_lh_buf;
  size_t                        pk_lh_size;
  union {
    struct s_ethernet_hdr       *lh_ethernet;
    vaddr_t                     lh_addr;
  }                             pk_lh;                  /* Link layer header */  

  struct s_buf                  *pk_nh_buf;
  size_t                        pk_nh_size;
  int                           pk_nh_type;
  union {
    struct s_ip_hdr             *nh_ip;
    struct s_arp_hdr            *nh_arp;
    vaddr_t                     nh_addr;
  }                             pk_nh;                  /* Network layer header */

  struct s_buf                  *pk_ph_buf;
  size_t                        pk_ph_size;
  int                           pk_ph_type;
  union {
    struct s_udp_hdr            *ph_udp;
    struct s_icmp_hdr           *ph_icmp;
    struct s_tcp_hdr            *ph_tcp;
    vaddr_t                     ph_addr;
  }                             pk_ph;                  /* Protocol layer header */

  size_t                        pk_data_size;
  struct s_data_buf             *pk_data;
};

TAILQ_HEAD(s_pkq, s_pkbuf);

/* For pkbuf_extand and pkbuf_extract */
#define EXTRACT_LH      0
#define EXTRACT_NH      1
#define EXTRACT_PH      2

/* For pkbuf_write */
#define INCLUDE_DATA    (1<<0)
#define INCLUDE_PH      (1<<1)          
#define INCLUDE_NH      (1<<2)
#define INCLUDE_LH      (1<<3)
#define INCLUDE_HDRS    (INCLUDE_LH | INCLUDE_NH | INCLUDE_PH)
#define INCLUDE_ALL     (INCLUDE_DATA | INCLUDE_HDRS)

/* PROTO lib_pkbuf.c lib_pkbuf_cksum.c */
/* lib_pkbuf.c */
struct s_data_buf *data_buf_alloc2(size_t buf_size);
struct s_data_buf *data_buf_alloc(struct s_buf *buf, off_t buf_off, size_t buf_size);
struct s_data_buf *data_buf_clone(struct s_data_buf *data_buf);
void data_buf_free(struct s_data_buf *data_buf);
struct s_buf *buf_alloc(size_t size);
struct s_pkbuf *pkbuf_alloc(size_t size);
struct s_pkbuf *pkbuf_clone(struct s_pkbuf *pkbuf);
char *pkbuf_extract(struct s_pkbuf *pk, int type, size_t size);
char *pkbuf_extand(struct s_pkbuf *pk, int type, size_t extsize);
ssize_t data_buf_write(struct s_data_buf *data_buf, pid_t owner, off_t offset, vaddr_t ubuf, size_t usize);
ssize_t pkbuf_write(struct s_pkbuf *pkbuf, pid_t owner, off_t offset, int flags, vaddr_t ubuf, size_t usize);
void buf_free(struct s_buf *buf);
void pkbuf_free(struct s_pkbuf *pk);
/* lib_pkbuf_cksum.c */
u_int16_t pkbuf_cksum(struct s_pkbuf *pk, int flags, u_int8_t *phdr, size_t phdr_size);
#endif

---