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
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
|
/* Copyright (c) 2013-2018, Linaro Limited
* All rights reserved.
*
* SPDX-License-Identifier: BSD-3-Clause
*/
/**
* @file
*
* ODP packet IO - implementation internal
*/
#ifndef ODP_PACKET_IO_INTERNAL_H_
#define ODP_PACKET_IO_INTERNAL_H_
#ifdef __cplusplus
extern "C" {
#endif
#include <odp/api/packet_io.h>
#include <odp/api/plat/pktio_inlines.h>
#include <odp/api/spinlock.h>
#include <odp/api/ticketlock.h>
#include <odp_classification_datamodel.h>
#include <odp_align_internal.h>
#include <odp_debug_internal.h>
#include <odp_queue_if.h>
#include <odp_config_internal.h>
#include <odp/api/hints.h>
#define PKTIO_MAX_QUEUES 64
#include <linux/if_ether.h>
#define PKTIO_NAME_LEN 256
#define PKTIN_INVALID ((odp_pktin_queue_t) {ODP_PKTIO_INVALID, 0})
#define PKTOUT_INVALID ((odp_pktout_queue_t) {ODP_PKTIO_INVALID, 0})
/* Forward declaration */
struct pktio_if_ops;
struct pkt_dpdk_t;
typedef struct {
odp_queue_t loopq; /**< loopback queue for "loop" device */
odp_bool_t promisc; /**< promiscuous mode state */
uint8_t idx; /**< index of "loop" device */
} pkt_loop_t;
/** DPDK runtime configuration options */
typedef struct {
int num_rx_desc;
int num_tx_desc;
int rx_drop_en;
} dpdk_opt_t;
/** Packet socket using dpdk mmaped rings for both Rx and Tx */
typedef struct {
uint16_t port_id; /**< DPDK port identifier */
uint16_t mtu; /**< maximum transmission unit */
uint8_t lockless_rx; /**< no locking for rx */
uint8_t lockless_tx; /**< no locking for tx */
uint8_t min_rx_burst; /**< minimum RX burst size */
odp_pktin_hash_proto_t hash; /**< Packet input hash protocol */
char ifname[32];
odp_ticketlock_t rx_lock[PKTIO_MAX_QUEUES]; /**< RX queue locks */
odp_ticketlock_t tx_lock[PKTIO_MAX_QUEUES]; /**< TX queue locks */
uint8_t vdev_sysc_promisc; /**< promiscuous mode defined with
system call */
dpdk_opt_t opt;
} pkt_dpdk_t;
struct pktio_entry {
const struct pktio_if_ops *ops; /**< Implementation specific methods */
/* These two locks together lock the whole pktio device */
odp_ticketlock_t rxl; /**< RX ticketlock */
odp_ticketlock_t txl; /**< TX ticketlock */
uint8_t cls_enabled; /**< classifier enabled */
uint8_t chksum_insert_ena; /**< pktout checksum offload enabled */
odp_pktio_t handle; /**< pktio handle */
union {
pkt_loop_t pkt_loop; /**< Using loopback for IO */
pkt_dpdk_t pkt_dpdk; /**< using DPDK API for IO */
};
enum {
/* Not allocated */
PKTIO_STATE_FREE = 0,
/* Close pending on scheduler response. Next state after this
* is PKTIO_STATE_FREE. */
PKTIO_STATE_CLOSE_PENDING,
/* Open in progress.
Marker for all active states following under. */
PKTIO_STATE_ACTIVE,
/* Open completed */
PKTIO_STATE_OPENED,
/* Start completed */
PKTIO_STATE_STARTED,
/* Stop pending on scheduler response */
PKTIO_STATE_STOP_PENDING,
/* Stop completed */
PKTIO_STATE_STOPPED
} state;
odp_pktio_config_t config; /**< Device configuration */
classifier_t cls; /**< classifier linked with this pktio*/
odp_pktio_stats_t stats; /**< statistic counters for pktio */
odp_proto_chksums_t in_chksums; /**< Checksums validation settings */
char name[PKTIO_NAME_LEN]; /**< name of pktio provided to
pktio_open() */
odp_pool_t pool;
odp_pktio_param_t param;
odp_pktio_capability_t capa; /**< Packet IO capabilities */
/* Storage for queue handles
* Multi-queue support is pktio driver specific */
unsigned num_in_queue;
unsigned num_out_queue;
struct {
odp_queue_t queue;
queue_t queue_int;
odp_pktin_queue_t pktin;
} in_queue[PKTIO_MAX_QUEUES];
struct {
odp_queue_t queue;
odp_pktout_queue_t pktout;
} out_queue[PKTIO_MAX_QUEUES];
/* inotify instance for pcapng fifos */
struct {
enum {
PCAPNG_WR_STOP = 0,
PCAPNG_WR_PKT,
} state[PKTIO_MAX_QUEUES];
int fd[PKTIO_MAX_QUEUES];
} pcapng;
};
typedef union {
struct pktio_entry s;
uint8_t pad[ROUNDUP_CACHE_LINE(sizeof(struct pktio_entry))];
} pktio_entry_t;
typedef struct {
odp_spinlock_t lock;
pktio_entry_t entries[ODP_CONFIG_PKTIO_ENTRIES];
} pktio_table_t;
typedef struct pktio_if_ops {
const char *name;
void (*print)(pktio_entry_t *pktio_entry);
int (*init_global)(void);
int (*init_local)(void);
int (*term)(void);
int (*open)(odp_pktio_t pktio, pktio_entry_t *pktio_entry,
const char *devname, odp_pool_t pool);
int (*close)(pktio_entry_t *pktio_entry);
int (*start)(pktio_entry_t *pktio_entry);
int (*stop)(pktio_entry_t *pktio_entry);
int (*stats)(pktio_entry_t *pktio_entry, odp_pktio_stats_t *stats);
int (*stats_reset)(pktio_entry_t *pktio_entry);
uint64_t (*pktin_ts_res)(pktio_entry_t *pktio_entry);
odp_time_t (*pktin_ts_from_ns)(pktio_entry_t *pktio_entry, uint64_t ns);
int (*recv)(pktio_entry_t *entry, int index, odp_packet_t packets[],
int num);
int (*recv_tmo)(pktio_entry_t *entry, int index, odp_packet_t packets[],
int num, uint64_t wait_usecs);
int (*recv_mq_tmo)(pktio_entry_t *entry[], int index[], int num_q,
odp_packet_t packets[], int num, unsigned *from,
uint64_t wait_usecs);
int (*fd_set)(pktio_entry_t *entry, int index, fd_set *readfds);
int (*send)(pktio_entry_t *entry, int index,
const odp_packet_t packets[], int num);
uint32_t (*mtu_get)(pktio_entry_t *pktio_entry);
int (*promisc_mode_set)(pktio_entry_t *pktio_entry, int enable);
int (*promisc_mode_get)(pktio_entry_t *pktio_entry);
int (*mac_get)(pktio_entry_t *pktio_entry, void *mac_addr);
int (*mac_set)(pktio_entry_t *pktio_entry, const void *mac_addr);
int (*link_status)(pktio_entry_t *pktio_entry);
int (*capability)(pktio_entry_t *pktio_entry,
odp_pktio_capability_t *capa);
int (*config)(pktio_entry_t *pktio_entry,
const odp_pktio_config_t *config);
int (*input_queues_config)(pktio_entry_t *pktio_entry,
const odp_pktin_queue_param_t *param);
int (*output_queues_config)(pktio_entry_t *pktio_entry,
const odp_pktout_queue_param_t *p);
} pktio_if_ops_t;
extern void *pktio_entry_ptr[];
static inline pktio_entry_t *get_pktio_entry(odp_pktio_t pktio)
{
int idx;
if (odp_unlikely(pktio == ODP_PKTIO_INVALID))
return NULL;
if (odp_unlikely(_odp_typeval(pktio) > ODP_CONFIG_PKTIO_ENTRIES)) {
ODP_DBG("pktio limit %d/%d exceed\n",
_odp_typeval(pktio), ODP_CONFIG_PKTIO_ENTRIES);
return NULL;
}
idx = odp_pktio_index(pktio);
return pktio_entry_ptr[idx];
}
static inline int pktio_cls_enabled(pktio_entry_t *entry)
{
return entry->s.cls_enabled;
}
static inline void pktio_cls_enabled_set(pktio_entry_t *entry, int ena)
{
entry->s.cls_enabled = ena;
}
extern const pktio_if_ops_t loopback_pktio_ops;
extern const pktio_if_ops_t null_pktio_ops;
extern const pktio_if_ops_t dpdk_pktio_ops;
extern const pktio_if_ops_t * const pktio_if_ops[];
/* Dummy function required by odp_pktin_recv_mq_tmo() */
static inline int
sock_recv_mq_tmo_try_int_driven(const struct odp_pktin_queue_t queues[],
unsigned num_q ODP_UNUSED,
unsigned *from ODP_UNUSED,
odp_packet_t packets[] ODP_UNUSED,
int num ODP_UNUSED,
uint64_t usecs ODP_UNUSED,
int *trial_successful) {
(void)queues;
*trial_successful = 0;
return 0;
}
#ifdef __cplusplus
}
#endif
#endif
|
