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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
|
/* 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 <stddef.h>
#include <odp/api/align.h>
#include <odp/api/buffer.h>
#include <odp/api/debug.h>
#include <odp/api/pool.h>
#include <odp/api/packet.h>
#include <odp/api/packet_io.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 */
uint32_t mtu; /**< maximum transmission unit */
unsigned char if_mac[ETH_ALEN]; /**< IF eth mac addr */
uint8_t *cache_ptr[ODP_PACKET_SOCKET_MAX_BURST_RX];
odp_shm_t shm;
} 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);
}
/**
* Read the MAC address from a packet socket
*/
int mac_addr_get_fd(int fd, const char *name, unsigned char mac_dst[]);
/**
* Read the MTU from a packet socket
*/
uint32_t mtu_get_fd(int fd, const char *name);
/**
* Enable/Disable promisc mode for a packet socket
*/
int promisc_mode_set_fd(int fd, const char *name, int enable);
/**
* Return promisc mode of a packet socket
*/
int promisc_mode_get_fd(int fd, const char *name);
/**
* Return link status of a packet socket (up/down)
*/
int link_status_fd(int fd, const char *name);
/**
* Get enabled RSS hash protocols of a packet socket
*
* @param fd Socket file descriptor
* @param name Interface name
* @param hash_proto[out] Hash protocols
*
* @returns Number enabled hash protocols
*/
int rss_conf_get_fd(int fd, const char *name,
odp_pktin_hash_proto_t *hash_proto);
/**
* Get supported RSS hash protocols of a packet socket
*
* Can be both read and modified.
*
* @param fd Socket file descriptor
* @param name Interface name
* @param hash_proto[out] Hash protocols
*
* @returns Number of supported hash protocols
*/
int rss_conf_get_supported_fd(int fd, const char *name,
odp_pktin_hash_proto_t *hash_proto);
/**
* Set RSS hash protocols of a packet socket
*
* @param fd Socket file descriptor
* @param name Interface name
* @param hash_proto Hash protocols
*
* @retval 0 on success
* @retval <0 on failure
*/
int rss_conf_set_fd(int fd, const char *name,
const odp_pktin_hash_proto_t *proto);
/**
* Print enabled RSS hash protocols
*
* @param hash_proto Hash protocols
*/
void rss_conf_print(const odp_pktin_hash_proto_t *hash_proto);
/**
* Get ethtool statistics of a packet socket
*/
int ethtool_stats_get_fd(int fd, const char *name, odp_pktio_stats_t *stats);
#endif
|
