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
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/* 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 <string.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_pool_t pool; /**< 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_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;
static inline void
ethaddr_copy(unsigned char mac_dst[], unsigned char mac_src[])
{
memcpy(mac_dst, mac_src, ETH_ALEN);
}
static inline int
ethaddrs_equal(unsigned char mac_a[], unsigned char mac_b[])
{
return !memcmp(mac_a, mac_b, ETH_ALEN);
}
/**
* Open & configure a raw packet socket
*/
int setup_pkt_sock(pkt_sock_t * const pkt_sock, const char *netdev,
odp_pool_t pool);
int setup_pkt_sock_mmap(pkt_sock_mmap_t * const pkt_sock, const char *netdev,
odp_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
|
