2022-08-09 15:58:46 +08:00
|
|
|
/*
|
|
|
|
|
**********************************************************************************************
|
|
|
|
|
* File: pio_packet_queue.h
|
|
|
|
|
* Description: pio packet queue structure and api
|
|
|
|
|
* Authors: Liu WenTan <liuwentan@geedgenetworks.com>
|
|
|
|
|
* Date: 2022-07-15
|
|
|
|
|
* Copyright: (c) 2018-2022 Geedge Networks, Inc. All rights reserved.
|
|
|
|
|
***********************************************************************************************
|
|
|
|
|
*/
|
|
|
|
|
|
2022-08-11 10:50:41 +08:00
|
|
|
#ifndef _PIO_PACKET_QUEUE_H_
|
|
|
|
|
#define _PIO_PACKET_QUEUE_H_
|
|
|
|
|
|
|
|
|
|
#ifdef __cpluscplus
|
|
|
|
|
extern "C"
|
|
|
|
|
{
|
|
|
|
|
#endif
|
2022-08-09 15:58:46 +08:00
|
|
|
|
|
|
|
|
#include <stdint.h>
|
|
|
|
|
|
|
|
|
|
#define PKT_QUEUE_MAX_NUM 256
|
|
|
|
|
|
|
|
|
|
#define CUSTOM_ZONE_LEN 64
|
|
|
|
|
#define ETHERNET_HEADER_LEN 14
|
|
|
|
|
#define DEFAULT_MTU 1500
|
|
|
|
|
#define DEFAULT_PACKET_SIZE (CUSTOM_ZONE_LEN + DEFAULT_MTU + ETHERNET_HEADER_LEN)
|
|
|
|
|
|
|
|
|
|
#define SIZE_OF_PIO_PACKET (DEFAULT_PACKET_SIZE + sizeof(struct pio_packet))
|
|
|
|
|
|
2022-08-09 18:32:25 +08:00
|
|
|
/**
|
2022-08-09 15:58:46 +08:00
|
|
|
* @brief pcap_live/pcap_file mode packet structure
|
|
|
|
|
*
|
|
|
|
|
* |<-pkt_hdr |<-pkt_payload
|
|
|
|
|
* | |
|
|
|
|
|
* | struct pio_packet | custom zone | L2 header | ...... |
|
|
|
|
|
* 64bytes 14bytes 1500bytes
|
|
|
|
|
*
|
|
|
|
|
* custom zone: user can set custom field
|
|
|
|
|
* pkt_payload: received packet data
|
2022-08-10 10:21:07 +08:00
|
|
|
*/
|
2022-08-09 15:58:46 +08:00
|
|
|
struct pio_packet {
|
|
|
|
|
/* pkt header pointer */
|
|
|
|
|
void *pkt_hdr;
|
|
|
|
|
|
|
|
|
|
/* pkt length */
|
2022-08-09 18:32:25 +08:00
|
|
|
uint32_t pkt_len;
|
2022-08-09 15:58:46 +08:00
|
|
|
|
|
|
|
|
/* pkt payload pointer */
|
|
|
|
|
void *pkt_payload;
|
|
|
|
|
|
|
|
|
|
/* reference counts */
|
2022-08-09 18:32:25 +08:00
|
|
|
uint32_t ref_cnt;
|
2022-08-09 15:58:46 +08:00
|
|
|
|
|
|
|
|
struct pio_packet *prev;
|
|
|
|
|
|
|
|
|
|
struct pio_packet *next;
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
struct pio_packet_queue {
|
|
|
|
|
struct pio_packet *top;
|
|
|
|
|
struct pio_packet *bot;
|
|
|
|
|
uint32_t len;
|
|
|
|
|
pthread_mutex_t mutex_q;
|
|
|
|
|
};
|
|
|
|
|
|
2022-08-09 18:32:25 +08:00
|
|
|
int packet_copy_data(uint8_t *ptr, const uint8_t *pkt_data, uint32_t pkt_len);
|
|
|
|
|
|
2022-08-09 15:58:46 +08:00
|
|
|
void pio_packet_enqueue(struct pio_packet_queue *, struct pio_packet *);
|
|
|
|
|
struct pio_packet *pio_packet_dequeue(struct pio_packet_queue *);
|
2022-08-11 10:50:41 +08:00
|
|
|
void release_pio_packet_queue(struct pio_packet_queue *);
|
|
|
|
|
|
|
|
|
|
#ifdef __cpluscplus
|
|
|
|
|
}
|
|
|
|
|
#endif
|
|
|
|
|
|
|
|
|
|
#endif /* _PIO_PACKET_QUEUE_H_ */
|