1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
/* Copyright (c) 2013, Linaro Limited
* Copyright (c) 2013, Nokia Solutions and Networks
* All rights reserved.
*
* SPDX-License-Identifier: BSD-3-Clause
*/
#ifndef ODP_PACKET_SOCKET_H
#define ODP_PACKET_SOCKET_H
#include <linux/if_packet.h>
#include <linux/if_ether.h>
#include <sys/socket.h>
#include <odp_align.h>
#include <odp_buffer.h>
#include <odp_debug.h>
#include <odp_pool.h>
#include <odp_packet.h>
#include <linux/version.h>
/*
* Packet socket config:
*/
/** Max receive (Rx) burst size*/
#define ODP_PACKET_SOCKET_MAX_BURST_RX 32
/** Max transmit (Tx) burst size*/
#define ODP_PACKET_SOCKET_MAX_BURST_TX 32
/*
* This makes sure that building for kernels older than 3.1 works
* and a fanout requests fails (for invalid packet socket option)
* in runtime if requested
*/
#ifndef PACKET_FANOUT
#define PACKET_FANOUT 18
#define PACKET_FANOUT_HASH 0
#endif /* PACKET_FANOUT */
typedef struct {
int sockfd; /**< socket descriptor */
odp_buffer_pool_t pool; /**< buffer pool to alloc packets from */
size_t buf_size; /**< size of buffer payload in 'pool' */
size_t max_frame_len; /**< max frame len = buf_size - sizeof(pkt_hdr) */
size_t frame_offset; /**< frame start offset from start of pkt buf */
unsigned char if_mac[ETH_ALEN]; /**< IF eth mac addr */
} pkt_sock_t;
/** packet mmap ring */
struct ring {
struct iovec *rd;
unsigned frame_num;
int rd_num;
int sock;
int type;
int version;
uint8_t *mm_space;
size_t mm_len;
size_t rd_len;
int flen;
struct tpacket_req req;
};
_ODP_STATIC_ASSERT(offsetof(struct ring, mm_space) <= ODP_CACHE_LINE_SIZE,
"ERR_STRUCT_RING");
/** Packet socket using mmap rings for both Rx and Tx */
typedef struct {
/** Packet mmap ring for Rx */
struct ring rx_ring ODP_ALIGNED_CACHE;
/** Packet mmap ring for Tx */
struct ring tx_ring ODP_ALIGNED_CACHE;
int sockfd ODP_ALIGNED_CACHE;
odp_buffer_pool_t pool;
size_t frame_offset; /**< frame start offset from start of pkt buf */
uint8_t *mmap_base;
unsigned mmap_len;
unsigned char if_mac[ETH_ALEN];
struct sockaddr_ll ll;
int fanout;
} pkt_sock_mmap_t;
/**
* Open & configure a raw packet socket
*/
int setup_pkt_sock(pkt_sock_t * const pkt_sock, const char *netdev,
odp_buffer_pool_t pool);
int setup_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock, const char *netdev,
odp_buffer_pool_t pool, int fanout);
/**
* Close a packet socket
*/
int close_pkt_sock(pkt_sock_t * const pkt_sock);
int close_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock);
/**
* Receive packets from the packet socket
*/
int recv_pkt_sock_basic(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
int recv_pkt_sock_mmsg(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
int recv_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock,
odp_packet_t pkt_table[], unsigned len);
/**
* Send packets through the packet socket
*/
int send_pkt_sock_basic(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
int send_pkt_sock_mmsg(pkt_sock_t * const pkt_sock, odp_packet_t pkt_table[],
unsigned len);
int send_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock,
odp_packet_t pkt_table[], unsigned len);
#endif
|
