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
|
/* 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 */
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
*/
int 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);
#endif
|
