sqlite_pcap.h

Go to the documentation of this file.

 
#ifndef SQLITE_PCAP_H
#define SQLITE_PCAP_H
 
#include <stdint.h>
#include <sqlite3.h>
 
#include "../../../utils/allocs.h"
#include "../../../utils/os.h"
#include "../../../utils/squeue.h"
 
#define PCAP_TABLE_NAME "pcap"
#define PCAP_CREATE_TABLE                                                      \
  "CREATE TABLE IF NOT EXISTS " PCAP_TABLE_NAME                                \
  " (timestamp INTEGER NOT NULL, name TEXT NOT NULL, "                         \
  "caplen INTEGER, length INTEGER, "                                           \
  "PRIMARY KEY (name));"
#define PCAP_INSERT_INTO                                                       \
  "INSERT INTO " PCAP_TABLE_NAME " VALUES(@timestamp, @name, @caplen, "        \
  "@length);"
#define PCAP_SELECT_FIRST_ENTRY                                                \
  "SELECT timestamp,caplen FROM " PCAP_TABLE_NAME                              \
  " ORDER BY timestamp ASC LIMIT 1;"
#define PCAP_SUM_GROUP                                                         \
  "SELECT timestamp,caplen FROM " PCAP_TABLE_NAME                              \
  " WHERE timestamp > @lt ORDER BY timestamp ASC LIMIT @lim;"
#define PCAP_SELECT_GROUP                                                      \
  "SELECT timestamp,name FROM " PCAP_TABLE_NAME                                \
  " WHERE timestamp >= @lt ORDER BY timestamp ASC LIMIT @lim;"
#define PCAP_DELETE_GROUP                                                      \
  "DELETE FROM " PCAP_TABLE_NAME " WHERE timestamp >= @lt AND timestamp <= "   \
  "@ht;"
 
struct pcap_file_meta {
  uint64_t timestamp;
  char *name;
};
 
int init_sqlite_pcap_db(sqlite3 *db);
 
int save_sqlite_pcap_entry(sqlite3 *db, char *name, uint64_t timestamp,
                           uint32_t caplen, uint32_t length);
 
int get_first_pcap_entry(sqlite3 *db, uint64_t *timestamp, uint64_t *caplen);
 
int get_pcap_meta_array(sqlite3 *db, uint64_t lt, uint32_t lim,
                        UT_array *pcap_meta_arr);
 
int delete_pcap_entries(sqlite3 *db, uint64_t lt, uint64_t ht);
 
int sum_pcap_group(sqlite3 *db, uint64_t lt, uint32_t lim, uint64_t *ht,
                   uint64_t *sum);
 
#endif