live_uni_pac_attr.cpp File Reference

#include <PfRingDeviceList.h>
#include <Packet.h>
#include <iostream>
#include <getopt.h>
#include "headers/packet_handler.h"
#include "headers/PacketStats.h"
#include <IPv4Layer.h>
#include <PcapFileDevice.h>
#include <chrono>
#include <signal.h>
#include <atomic>
#include <thread>
#include <clickhouse/client.h>
#include <csignal>
#include <pcap.h>

Include dependency graph for live_uni_pac_attr.cpp:

Macros
#define	EXIT_WITH_ERROR(reason)
#define	numOfCaptureThreads   12

Functions
void	onPacketArrives (pcpp::RawPacket *packet, uint32_t numOfPackets, uint8_t threadId, pcpp::PfRingDevice *dev, void *cookie)
pcpp::PfRingDevice *	init (std::string interfaceNameOrIP="enp7s0")
void	startCapture (pcpp::PfRingDevice *device, PacketStats *stats)
void	stopCapture (pcpp::PfRingDevice *device)
void	signal_handler (int signum)
int	main (int argc, char *argv[])

Variables
std::atomic< long long >	packet_count
pcpp::PfRingDevice *	dev
volatile sig_atomic_t	is_stop = 0

Macro Definition Documentation

EXIT_WITH_ERROR

#define EXIT_WITH_ERROR

(

reason

)

Value:

    do                                                \
    {                                                 \
        std::cout << std::endl                        \
                  << "ERROR: " << reason << std::endl \
                  << std::endl;                       \
        exit(1);                                      \
    } while (0)

numOfCaptureThreads

#define numOfCaptureThreads   12

Function Documentation

init()

pcpp::PfRingDevice * init

(

std::string

interfaceNameOrIP = "enp7s0"

)

如果不存在表,就创建表

main()

int main	(	int	argc,
		char *	argv[] )

onPacketArrives()

void onPacketArrives	(	pcpp::RawPacket *	packet,
		uint32_t	numOfPackets,
		uint8_t	threadId,
		pcpp::PfRingDevice *	dev,
		void *	cookie )

signal_handler()

void signal_handler

(

int

signum

)

startCapture()

void startCapture	(	pcpp::PfRingDevice *	device,
		PacketStats *	stats )

stopCapture()

void stopCapture

(

pcpp::PfRingDevice *

device

)

Variable Documentation

dev

pcpp::PfRingDevice* dev

is_stop

volatile sig_atomic_t is_stop = 0

packet_count

std::atomic<long long> packet_count