corsaro_int.h

Go to the documentation of this file.

/* 
 * corsaro
 *
 * Alistair King, CAIDA, UC San Diego
 * corsaro-info@caida.org
 * 
 * Copyright (C) 2012 The Regents of the University of California.
 * 
 * This file is part of corsaro.
 *
 * corsaro is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * corsaro is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with corsaro.  If not, see <http://www.gnu.org/licenses/>.
 *
 */

#ifndef __CORSARO_INT_H
#define __CORSARO_INT_H

#include "libtrace.h"

#include "config.h"

#include "corsaro.h"

#include "corsaro_file.h"
#include "corsaro_geo.h"
#include "corsaro_plugin.h"

/* GCC optimizations */
#if __GNUC__ >= 3 
#  define DEPRECATED __attribute__((deprecated))
#  define SIMPLE_FUNCTION __attribute__((pure))
#  define UNUSED __attribute__((unused))
#  define PACKED __attribute__((packed))
#  define PRINTF(formatpos,argpos) __attribute__((format(printf,formatpos,argpos)))
#else
#  define DEPRECATED
#  define SIMPLE_FUNCTION
#  define UNUSED
#  define PACKED 
#  define PRINTF(formatpos,argpos) 
#endif

typedef enum corsaro_magic
  { 
    CORSARO_MAGIC          = 0x45444752,
    CORSARO_MAGIC_HEADER   = 0x48454144,
    CORSARO_MAGIC_INTERVAL = 0x494E5452,
    /* corsaro data block magic number - "DATA" */
    CORSARO_MAGIC_DATA     = 0x44415441,
    /* corsaro trailer magic number - "FOOT" */
    CORSARO_MAGIC_TRAILER  = 0x464F4F54
  } corsaro_magic_t;

struct corsaro_header
{
  uint32_t corsaro_magic;
  uint32_t magic;
  uint8_t version_major;
  uint8_t version_minor;
  uint32_t local_init_time;
  uint16_t interval_length;
  uint16_t traceuri_len;
  uint8_t *traceuri;
  uint16_t plugin_cnt;
  uint32_t *plugin_magics;
} PACKED;

struct corsaro_trailer
{
  uint32_t corsaro_magic;
  uint32_t magic;
  uint64_t packet_cnt;
  uint64_t accepted_cnt;
  uint64_t dropped_cnt;
  uint32_t first_packet_time;
  uint32_t last_packet_time;
  uint32_t local_final_time;
  uint32_t runtime;
} PACKED;

struct corsaro_interval
{
  uint32_t corsaro_magic;
  uint32_t magic;
  uint16_t         number;
  uint32_t         time;
} PACKED;

struct corsaro_plugin_data
{
  uint32_t corsaro_magic;
  uint32_t magic;
  uint32_t plugin_magic;
} PACKED;

#define CORSARO_INTERVAL_DEFAULT 60

struct corsaro_packet_state
{
  uint8_t flags;
};

enum
  {
    CORSARO_PACKET_STATE_FLAG_BACKSCATTER    = 0x01,

    CORSARO_PACKET_STATE_IGNORE              = 0x02,
  };

struct corsaro_packet
{
  corsaro_packet_state_t  state;

  corsaro_geo_provider_t *geo_providers[CORSARO_GEO_PROVIDER_MAX];

  corsaro_geo_provider_t *geo_provider_default;

  libtrace_packet_t    *ltpacket;
};

#define LT_PKT(corsaro_packet)   (corsaro_packet->ltpacket) 

struct corsaro
{
  struct timeval init_time;

  libtrace_t *trace;

  char *uridata;

  char *monitorname;

  char *template;

  corsaro_file_mode_t output_mode;

  corsaro_file_compress_t compress;

  int compress_level;

  corsaro_file_t *global_file;

  int global_file_disabled;

  corsaro_file_t *logfile;

  int logfile_disabled;

  corsaro_packet_t *packet;

  /* this is what gets passed to any function relating to plugin management */
  corsaro_plugin_manager_t *plugin_manager;

  corsaro_interval_align_t interval_align;

  int interval;

  int output_rotate;

  int meta_output_rotate;

  corsaro_interval_t interval_start;

  uint32_t next_report;

  struct timeval first_ts;

  struct timeval last_ts;

  int interval_end_needed;

  uint64_t packet_cnt;

  uint64_t accepted_pkts;

  uint64_t dropped_pkts;

  int started;

};

struct corsaro_in
{
  char *uridata;

  corsaro_file_in_t *file;

  corsaro_in_record_type_t expected_type;

  /* this is what gets passed to any function relating to plugin management */
  corsaro_plugin_manager_t *plugin_manager;

  corsaro_plugin_t *plugin;

  int started;

};

#define CORSARO_IN_RECORD_DEFAULT_BUFFER_LEN     LIBTRACE_PACKET_BUFSIZE+1024

struct corsaro_in_record
{
  corsaro_in_t *corsaro;

  uint8_t *buffer;

  size_t buffer_len;

  corsaro_in_record_type_t type;

};

#endif /* __CORSARO_INT_H */