miruo.h

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#define _GNU_SOURCE
#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
#include<ctype.h>
#include<stdint.h>
#include<string.h>
#include<limits.h>
#include<getopt.h>
#include<signal.h>
#include<errno.h>
#include<fcntl.h>
#include<time.h>
#include<sys/time.h>
#include<sys/resource.h>
#include<sys/types.h>
#include<sys/stat.h>
#include<sys/socket.h>
#ifdef HAVE_SYS_EPOLL_H
#include<sys/epoll.h>
#else
#include<poll.h>
#endif
#include<netinet/in.h>
#include<arpa/inet.h>
#include<pcap.h>
#include"lnklist.h"

/****** COLOR CODE *****/
#define COLOR_RED     1
#define COLOR_GREEN   2
#define COLOR_YELLOW  3
#define COLOR_BLUE    4
#define COLOR_MAGENTA 5
#define COLOR_CYAN    6
#define COLOR_WHITE   7

/***** MIRUO MODE *****/
#define MIRUO_MODE_TCP   1
#define MIRUO_MODE_HTTP  2
#define MIRUO_MODE_MYSQL 3

/***** TCP STATUS *****/
#define MIRUO_STATE_TCP_LISTEN     1
#define MIRUO_STATE_TCP_SYN_SENT   2
#define MIRUO_STATE_TCP_SYN_RECV   3
#define MIRUO_STATE_TCP_EST        4
#define MIRUO_STATE_TCP_FIN_WAIT1  5
#define MIRUO_STATE_TCP_FIN_WAIT2  6
#define MIRUO_STATE_TCP_CLOSE_WAIT 7
#define MIRUO_STATE_TCP_LAST_ACK   8
#define MIRUO_STATE_TCP_CLOSED     9
#define MIRUO_STATE_TCP_TIME_WAIT  10

/*************************************
* Header
*************************************/
typedef struct ethhdr{
  uint8_t  smac[6];
  uint8_t  dmac[6];
  uint16_t type;
} ethhdr;

typedef struct sllhdr{
  uint8_t d[14];
  uint16_t type;
} sllhdr;

typedef struct l2hdr{
  union{
    ethhdr eth;
    sllhdr sll;
  } hdr;
} l2hdr;

typedef struct iprawhdr
{
  uint8_t  vih;
  uint8_t  tos;
  uint16_t len;
  uint16_t id;
  uint16_t ffo;
  uint8_t  ttl;
  uint8_t  protocol;
  uint16_t checksum;
  uint32_t src;
  uint32_t dst;
} iphdraw;

typedef struct iphdr
{
  l2hdr    l2;
  uint8_t  ver;
  uint8_t  ihl;
  uint8_t  tos;
  uint16_t len;
  uint16_t id;
  uint8_t  flags;
  uint16_t offset;
  uint8_t  ttl;
  uint8_t  protocol;
  uint16_t checksum;
  struct in_addr src;
  struct in_addr dst;
  uint8_t option[40];
} iphdr;

typedef struct tcprawhdr
{
  uint16_t sport;
  uint16_t dport;
  uint32_t seqno;
  uint32_t ackno;
  uint8_t  offset;
  uint8_t  flags;
  uint16_t window;
  uint16_t checksum;
  uint16_t urgent;
  uint8_t opt[40];
} tcphdraw;

typedef struct tcphdr
{
  iphdr    ip;
  uint16_t sport;
  uint16_t dport;
  uint32_t seqno;
  uint32_t ackno;
  uint8_t  offset;
  uint8_t  flags;
  uint16_t window;
  uint16_t checksum;
  uint16_t urgent;
  uint8_t opt[40];
} tcphdr;

typedef struct tcpsegment
{
  uint8_t  color;          // 表示色
  uint8_t  view;           // 表示済なら1になる
  uint8_t  sno;            //
  uint8_t  rno;            //
  uint8_t  st[2];          // ステータス
  uint8_t  flags;          // TCPフラグ
  uint8_t  fragment;       // IPフラグメントの状態
  uint16_t segsz;          // セグメントサイズ
  uint16_t segno;          // セグメント番号
  uint32_t seqno;          // シーケンス番号
  uint32_t ackno;          // 応答番号
  uint8_t  optsize;        // TCPオプションのサイズ
  uint8_t  opt[40];        // TCPヘッダからコピーしたオプションデータ
  uint16_t plen;
  uint8_t  *payload;
  struct lnklist *dpimsg;  // DPIメッセージ
  struct timeval ts;       // パケットをキャプチャした時間
  struct tcpsegment *prev; // 前のセグメント
  struct tcpsegment *next; // 次のセグメント
} tcpsegment;

typedef struct tcpsession
{
  uint16_t   sid;            // セッションID
  uint8_t   view;            // このセッションを表示する場合は1
  uint8_t  zview;            // ついでに表示するセグメントの残数
  uint32_t pkcnt;            // 現在保持しているパケット数
  uint32_t pkall;            // このセッションで飛び交った総パケット数
  uint32_t szall;            // このセッションで飛び交った総データサイズ(L2/L3ヘッダも含む)
  uint8_t  st[2];            // 現在のステータス
  uint32_t sq[2];            // シーケンス番号の初期値
  struct sockaddr_in ip[2];  // 0=接続元 1=接続先
  struct tcpsegment segment; // 先頭のセグメント
  struct tcpsegment *last;   // 最後のセグメント
  struct tcpsession *prev;   // 前のセッション
  struct tcpsession *next;   // 次のセッション
} tcpsession;

typedef struct tcpsegpool
{
  uint32_t   block;
  uint32_t   count;
  tcpsegment  *free;
  tcpsegment **pool;
} tcpsegpool;

typedef struct tcpsespool
{
  uint32_t   count;
  tcpsession *free;
} tcpsespool;

typedef struct meminfo
{
  uint64_t   vsz;
  uint64_t   res;
  uint64_t share;
  uint64_t  text;
  uint64_t  data;
  long page_size;
} meminfo;

typedef union miruopt_dpi
{
  struct
  {
    struct lnklist *reqhdr;
    struct lnklist *reshdr;
  } http;
} miruopt_dpi;

typedef struct miruopt
{
  pcap_t *p;                  //
  int  loop;                  // SININT/SIGTERMが発生したら0になる
  int  mode;                  // 動作モード。mオプションの値で決定
  int  all;                   // 1なら全セッション表示する
  int  live;                  // 1ならリアルタイム表示する
  int  quiet;                 // 疑わしきは罰しないモード
  int  color;                 // カラー表示を有効にするかどうか
  int  lktype;                // データリンク層の種別
  int  pksize;                // キャプチャサイズ
  int  promisc;               // NICをpromiscにするか
  int  rstmode;               // Rオプションの数
  int  fragment;              // IPのフラグメントを検出するかどうか
  int  viewdata;              // ついでに表示しとくデータの数
  int  rsynfind;              // SYNの再送を必ず検出するフラグ
  int  stattime;              // 統計情報を表示する間隔
  int  rt_limit;              // 再送許容間隔(ms)
  int  ct_limit;              // これ以上時間がかかったコネクションを表示
  int  st_limit;              // 次のパケットの到着がこれ以上かかったら表示
  int  ts_limit;              // 最大同時接続数
  int  sg_limit;              // 保持するセグメントの最大数
  char dev[32];               // デバイス名(eth0とかbond0とか)
  char exp[1024];             // フィルタ文字列
  char lkname[256];           // データリンク層の名前?
  char lkdesc[256];           // データリンク層の説明?
  char file[PATH_MAX];        // オフラインモードで読み込むファイル名
  uint32_t err_l2;            //
  uint32_t err_ip;            //
  uint32_t err_tcp;           //
  uint32_t count_ts;          // tcpsessionオブジェクト数(未使用分も含む)
  uint32_t count_ts_act;      // 現在の接続数
  uint32_t count_ts_max;      // 瞬間最大接続数
  uint64_t count_ts_error;    // 
  uint64_t count_ts_long;     // 
  uint64_t count_ts_total;    //
  uint64_t count_ts_view;     //
  uint64_t count_ts_drop;     // TCPセッションの確保ができなかった数
  uint64_t count_ts_timeout;  //
  uint32_t count_sg_act;      // 使用中のtcpsegmentオブジェクト数
  uint32_t count_sg_max;      // tcpsegmentオブジェクトの最大利用数
  uint64_t count_sg_delay;    // 
  uint64_t count_sg_drop;     // TCPセグメントを保持できなかった数
  uint64_t count_sg_retrans;  // 再送回数
  uint64_t count_ip_fragment; //
  uint64_t count_rstbreak;    //
  uint64_t count_rstclose;    //
  tcpsession *tsact;          //
  tcpsespool tsespool;        //
  tcpsegpool tsegpool;        //
  struct timeval stv;         // 開始時刻
  struct timeval ntv;         // 現在時刻
} miruopt;

extern miruopt opt;
extern miruopt_dpi dpi;