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
|
/* Copyright (c) 2013, 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/spinlock.h>
#include <odp/api/ticketlock.h>
#include <odp_classification_datamodel.h>
#include <odp_align_internal.h>
#include <odp_debug_internal.h>
#include <odp_packet_io_ring_internal.h>
#include <odp_queue_if.h>
#include <odp_config_internal.h>
#include <odp/api/hints.h>
#include <net/if.h>
#define PKTIO_MAX_QUEUES 64
/* Forward declaration */
typedef union pktio_entry_u pktio_entry_t;
#include <odp_pktio_ops_subsystem.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})
/** Determine if a socket read/write error should be reported. Transient errors
* that simply require the caller to retry are ignored, the _send/_recv APIs
* are non-blocking and it is the caller's responsibility to retry if the
* requested number of packets were not handled. */
#define SOCK_ERR_REPORT(e) (e != EAGAIN && e != EWOULDBLOCK && e != EINTR)
struct pktio_entry {
const pktio_ops_module_t *ops; /**< Implementation specific methods */
pktio_ops_data_t ops_data; /**< IO operation specific data */
/* These two locks together lock the whole pktio device */
odp_ticketlock_t rxl; /**< RX ticketlock */
odp_ticketlock_t txl; /**< TX ticketlock */
int cls_enabled; /**< is classifier enabled */
odp_pktio_t handle; /**< pktio handle */
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 */
enum {
STATS_SYSFS = 0,
STATS_ETHTOOL,
STATS_UNSUPPORTED
} stats_type;
char name[PKTIO_NAME_LEN]; /**< name of pktio provided to
pktio_open() */
odp_pool_t pool;
odp_pktio_param_t param;
/* 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];
};
union pktio_entry_u {
struct pktio_entry s;
uint8_t pad[ROUNDUP_CACHE_LINE(sizeof(struct pktio_entry))];
};
typedef struct {
odp_spinlock_t lock;
pktio_entry_t entries[ODP_CONFIG_PKTIO_ENTRIES];
} pktio_table_t;
extern void *pktio_entry_ptr[];
static inline int pktio_to_id(odp_pktio_t pktio)
{
return _odp_typeval(pktio) - 1;
}
static inline pktio_entry_t *get_pktio_entry(odp_pktio_t pktio)
{
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;
}
return pktio_entry_ptr[pktio_to_id(pktio)];
}
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;
}
int sysfs_stats(pktio_entry_t *pktio_entry,
odp_pktio_stats_t *stats);
int sock_stats_fd(pktio_entry_t *pktio_entry,
odp_pktio_stats_t *stats,
int fd);
int sock_stats_reset_fd(pktio_entry_t *pktio_entry, int fd);
int pktin_poll(int pktio_index, int num_queue, int index[]);
void pktio_stop_finalize(int pktio_index);
#ifdef __cplusplus
}
#endif
#endif
|
