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
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
|
/* SPDX-License-Identifier: BSD-3-Clause
* Copyright(c) 2017-2018 Intel Corporation
*/
#ifndef RTE_FBARRAY_H
#define RTE_FBARRAY_H
/**
* @file
*
* File-backed shared indexed array for DPDK.
*
* Basic workflow is expected to be the following:
* 1) Allocate array either using ``rte_fbarray_init()`` or
* ``rte_fbarray_attach()`` (depending on whether it's shared between
* multiple DPDK processes)
* 2) find free spots using ``rte_fbarray_find_next_free()``
* 3) get pointer to data in the free spot using ``rte_fbarray_get()``, and
* copy data into the pointer (element size is fixed)
* 4) mark entry as used using ``rte_fbarray_set_used()``
*
* Calls to ``rte_fbarray_init()`` and ``rte_fbarray_destroy()`` will have
* consequences for all processes, while calls to ``rte_fbarray_attach()`` and
* ``rte_fbarray_detach()`` will only have consequences within a single process.
* Therefore, it is safe to call ``rte_fbarray_attach()`` or
* ``rte_fbarray_detach()`` while another process is using ``rte_fbarray``,
* provided no other thread within the same process will try to use
* ``rte_fbarray`` before attaching or after detaching. It is not safe to call
* ``rte_fbarray_init()`` or ``rte_fbarray_destroy()`` while another thread or
* another process is using ``rte_fbarray``.
*/
#ifdef __cplusplus
extern "C" {
#endif
#include <stdbool.h>
#include <stdio.h>
#include <rte_compat.h>
#include <rte_rwlock.h>
#define RTE_FBARRAY_NAME_LEN 64
struct rte_fbarray {
char name[RTE_FBARRAY_NAME_LEN]; /**< name associated with an array */
unsigned int count; /**< number of entries stored */
unsigned int len; /**< current length of the array */
unsigned int elt_sz; /**< size of each element */
void *data; /**< data pointer */
rte_rwlock_t rwlock; /**< multiprocess lock */
};
/**
* Set up ``rte_fbarray`` structure and allocate underlying resources.
*
* Call this function to correctly set up ``rte_fbarray`` and allocate
* underlying files that will be backing the data in the current process. Note
* that in order to use and share ``rte_fbarray`` between multiple processes,
* data pointed to by ``arr`` pointer must itself be allocated in shared memory.
*
* @param arr
* Valid pointer to allocated ``rte_fbarray`` structure.
*
* @param name
* Unique name to be assigned to this array.
*
* @param len
* Number of elements initially available in the array.
*
* @param elt_sz
* Size of each element.
*
* @return
* - 0 on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_init(struct rte_fbarray *arr, const char *name, unsigned int len,
unsigned int elt_sz);
/**
* Attach to a file backing an already allocated and correctly set up
* ``rte_fbarray`` structure.
*
* Call this function to attach to file that will be backing the data in the
* current process. The structure must have been previously correctly set up
* with a call to ``rte_fbarray_init()``. Calls to ``rte_fbarray_attach()`` are
* usually meant to be performed in a multiprocessing scenario, with data
* pointed to by ``arr`` pointer allocated in shared memory.
*
* @param arr
* Valid pointer to allocated and correctly set up rte_fbarray structure.
*
* @return
* - 0 on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_attach(struct rte_fbarray *arr);
/**
* Deallocate resources for an already allocated and correctly set up
* ``rte_fbarray`` structure, and remove the underlying file.
*
* Call this function to deallocate all resources associated with an
* ``rte_fbarray`` structure within the current process. This will also
* zero-fill data pointed to by ``arr`` pointer and remove the underlying file
* backing the data, so it is expected that by the time this function is called,
* all other processes have detached from this ``rte_fbarray``.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @return
* - 0 on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_destroy(struct rte_fbarray *arr);
/**
* Deallocate resources for an already allocated and correctly set up
* ``rte_fbarray`` structure.
*
* Call this function to deallocate all resources associated with an
* ``rte_fbarray`` structure within current process.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @return
* - 0 on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_detach(struct rte_fbarray *arr);
/**
* Get pointer to element residing at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param idx
* Index of an element to get a pointer to.
*
* @return
* - non-NULL pointer on success.
* - NULL on failure, with ``rte_errno`` indicating reason for failure.
*/
void * __rte_experimental
rte_fbarray_get(const struct rte_fbarray *arr, unsigned int idx);
/**
* Find index of a specified element within the array.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param elt
* Pointer to element to find index to.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_idx(const struct rte_fbarray *arr, const void *elt);
/**
* Mark specified element as used.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param idx
* Element index to mark as used.
*
* @return
* - 0 on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_set_used(struct rte_fbarray *arr, unsigned int idx);
/**
* Mark specified element as free.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param idx
* Element index to mark as free.
*
* @return
* - 0 on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_set_free(struct rte_fbarray *arr, unsigned int idx);
/**
* Check whether element at specified index is marked as used.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param idx
* Element index to check as used.
*
* @return
* - 1 if element is used.
* - 0 if element is unused.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_is_used(struct rte_fbarray *arr, unsigned int idx);
/**
* Find index of next free element, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_next_free(struct rte_fbarray *arr, unsigned int start);
/**
* Find index of next used element, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_next_used(struct rte_fbarray *arr, unsigned int start);
/**
* Find index of next chunk of ``n`` free elements, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @param n
* Number of free elements to look for.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_next_n_free(struct rte_fbarray *arr, unsigned int start,
unsigned int n);
/**
* Find index of next chunk of ``n`` used elements, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @param n
* Number of used elements to look for.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_next_n_used(struct rte_fbarray *arr, unsigned int start,
unsigned int n);
/**
* Find how many more free entries there are, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_contig_free(struct rte_fbarray *arr,
unsigned int start);
/**
* Find how many more used entries there are, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_contig_used(struct rte_fbarray *arr, unsigned int start);
/**
* Find index of previous free element, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_prev_free(struct rte_fbarray *arr, unsigned int start);
/**
* Find index of previous used element, starting at specified index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_prev_used(struct rte_fbarray *arr, unsigned int start);
/**
* Find lowest start index of chunk of ``n`` free elements, down from specified
* index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @param n
* Number of free elements to look for.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_prev_n_free(struct rte_fbarray *arr, unsigned int start,
unsigned int n);
/**
* Find lowest start index of chunk of ``n`` used elements, down from specified
* index.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @param n
* Number of used elements to look for.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_prev_n_used(struct rte_fbarray *arr, unsigned int start,
unsigned int n);
/**
* Find how many more free entries there are before specified index (like
* ``rte_fbarray_find_contig_free`` but going in reverse).
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_rev_contig_free(struct rte_fbarray *arr,
unsigned int start);
/**
* Find how many more used entries there are before specified index (like
* ``rte_fbarray_find_contig_used`` but going in reverse).
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param start
* Element index to start search from.
*
* @return
* - non-negative integer on success.
* - -1 on failure, with ``rte_errno`` indicating reason for failure.
*/
int __rte_experimental
rte_fbarray_find_rev_contig_used(struct rte_fbarray *arr, unsigned int start);
/**
* Dump ``rte_fbarray`` metadata.
*
* @param arr
* Valid pointer to allocated and correctly set up ``rte_fbarray`` structure.
*
* @param f
* File object to dump information into.
*/
void __rte_experimental
rte_fbarray_dump_metadata(struct rte_fbarray *arr, FILE *f);
#ifdef __cplusplus
}
#endif
#endif /* RTE_FBARRAY_H */
|