blob: 66006f37f79c475f64d1bf8e05831771abaf5c34 [file] [log] [blame]
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +02001/*
2 *------------------------------------------------------------------
3 * Copyright (c) 2017 Cisco and/or its affiliates.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at:
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 *------------------------------------------------------------------
16 */
17
Dave Wallace6cd396c2018-01-23 17:47:02 -050018/** @file
19 * @defgroup libmemif
20 */
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020021
22#ifndef _LIBMEMIF_H_
23#define _LIBMEMIF_H_
24
25/** Libmemif version. */
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +020026#define LIBMEMIF_VERSION "3.1"
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020027/** Default name of application using libmemif. */
28#define MEMIF_DEFAULT_APP_NAME "libmemif-app"
29
30#include <inttypes.h>
Jakub Grajciar84b83772019-03-04 12:42:19 +010031#include <sys/timerfd.h>
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020032
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020033/*! Error codes */
34typedef enum
35{
36 MEMIF_ERR_SUCCESS = 0, /*!< success */
37/* SYSCALL ERRORS */
38 MEMIF_ERR_SYSCALL, /*!< other syscall error */
Jakub Grajciar568cc462018-09-05 12:11:35 +020039 MEMIF_ERR_CONNREFUSED, /*!< connection refused */
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020040 MEMIF_ERR_ACCES, /*!< permission denied */
41 MEMIF_ERR_NO_FILE, /*!< file does not exist */
42 MEMIF_ERR_FILE_LIMIT, /*!< system open file limit */
43 MEMIF_ERR_PROC_FILE_LIMIT, /*!< process open file limit */
44 MEMIF_ERR_ALREADY, /*!< connection already requested */
45 MEMIF_ERR_AGAIN, /*!< fd is not socket, or operation would block */
46 MEMIF_ERR_BAD_FD, /*!< invalid fd */
47 MEMIF_ERR_NOMEM, /*!< out of memory */
48/* LIBMEMIF ERRORS */
49 MEMIF_ERR_INVAL_ARG, /*!< invalid argument */
50 MEMIF_ERR_NOCONN, /*!< handle points to no connection */
51 MEMIF_ERR_CONN, /*!< handle points to existing connection */
52 MEMIF_ERR_CB_FDUPDATE, /*!< user defined callback memif_control_fd_update_t error */
Jakub Grajciar84b83772019-03-04 12:42:19 +010053 MEMIF_ERR_FILE_NOT_SOCK, /*!< file specified by socket filename
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020054 exists, but it's not socket */
55 MEMIF_ERR_NO_SHMFD, /*!< missing shm fd */
56 MEMIF_ERR_COOKIE, /*!< wrong cookie on ring */
57 MEMIF_ERR_NOBUF_RING, /*!< ring buffer full */
58 MEMIF_ERR_NOBUF, /*!< not enough memif buffers */
59 MEMIF_ERR_NOBUF_DET, /*!< memif details needs larger buffer */
60 MEMIF_ERR_INT_WRITE, /*!< send interrupt error */
61 MEMIF_ERR_MFMSG, /*!< malformed msg received */
62 MEMIF_ERR_QID, /*!< invalid queue id */
63/* MEMIF PROTO ERRORS */
64 MEMIF_ERR_PROTO, /*!< incompatible protocol version */
65 MEMIF_ERR_ID, /*!< unmatched interface id */
66 MEMIF_ERR_ACCSLAVE, /*!< slave cannot accept connection requests */
67 MEMIF_ERR_ALRCONN, /*!< memif is already connected */
68 MEMIF_ERR_MODE, /*!< mode mismatch */
69 MEMIF_ERR_SECRET, /*!< secret mismatch */
70 MEMIF_ERR_NOSECRET, /*!< secret required */
71 MEMIF_ERR_MAXREG, /*!< max region limit reached */
72 MEMIF_ERR_MAXRING, /*!< max ring limit reached */
73 MEMIF_ERR_NO_INTFD, /*!< missing interrupt fd */
74 MEMIF_ERR_DISCONNECT, /*!< disconenct received */
75 MEMIF_ERR_DISCONNECTED, /*!< peer interface disconnected */
76 MEMIF_ERR_UNKNOWN_MSG, /*!< unknown message type */
Milan Lenco0a47c992017-10-12 14:19:31 +020077 MEMIF_ERR_POLL_CANCEL, /*!< memif_poll_event() was cancelled */
Damjan Marion6d56fa42017-11-03 12:24:37 +010078 MEMIF_ERR_MAX_RING, /*!< too large ring size */
Jakub Grajciarab7c2b02018-03-28 10:21:05 +020079 MEMIF_ERR_PRIVHDR, /*!< private hdrs not supported */
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020080} memif_err_t;
81
82/**
83 * @defgroup MEMIF_FD_EVENT Types of events that need to be watched for specific fd.
Dave Wallace6cd396c2018-01-23 17:47:02 -050084 * @ingroup libmemif
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +020085 * @{
86 */
87
88/** user needs to set events that occured on fd and pass them to memif_control_fd_handler */
89#define MEMIF_FD_EVENT_READ (1 << 0)
90#define MEMIF_FD_EVENT_WRITE (1 << 1)
91/** inform libmemif that error occured on fd */
92#define MEMIF_FD_EVENT_ERROR (1 << 2)
93/** if set, informs that fd is going to be closed (user may want to stop watching for events on this fd) */
94#define MEMIF_FD_EVENT_DEL (1 << 3)
95/** update events */
96#define MEMIF_FD_EVENT_MOD (1 << 4)
97/** @} */
98
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +020099/** \brief Memif per thread main handle
100 Pointer of type void, pointing to internal structure.
101 Used to identify internal per thread database.
102*/
103typedef void *memif_per_thread_main_handle_t;
104
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200105/** \brief Memif connection handle
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200106 pointer of type void, pointing to internal structure
107*/
108typedef void *memif_conn_handle_t;
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200109
Jakub Grajciar12df4972019-07-01 14:24:48 +0200110/** \brief Memif socket handle
111 pointer of type void, pointing to internal structure
112*/
113typedef void *memif_socket_handle_t;
114
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200115/** \brief Memif allocator alloc
116 @param size - requested allocation size
117
118 custom memory allocator: alloc function template
119*/
120typedef void *(memif_alloc_t) (size_t size);
121
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200122
123/** \brief Memif realloc
124 @param ptr - pointer to memory block
125 @param size - requested allocation size
126
127 custom memory reallocation
128*/
129typedef void *(memif_realloc_t) (void *ptr, size_t size);
130
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200131/** \brief Memif allocator free
132 @param size - requested allocation size
133
134 custom memory allocator: free function template
135*/
136typedef void (memif_free_t) (void *ptr);
137
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200138/**
139 * @defgroup CALLBACKS Callback functions definitions
Dave Wallace6cd396c2018-01-23 17:47:02 -0500140 * @ingroup libmemif
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200141 *
142 * @{
143 */
144
145/** \brief Memif control file descriptor update (callback function)
146 @param fd - new file descriptor to watch
147 @param events - event type(s) to watch for
Jakub Grajciar6f090fa2019-11-14 10:47:25 +0100148 @param private_ctx - libmemif main private context. Is NULL for
149 libmemif main created by memif_init()
150
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200151
152 This callback is called when there is new fd to watch for events on
153 or if fd is about to be closed (user mey want to stop watching for events on this fd).
Jakub Grajciar6f090fa2019-11-14 10:47:25 +0100154 Private context is taken from libmemif_main, 'private_ctx' passed to memif_per_thread_init()
155 or NULL in case of memif_init()
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200156*/
Jakub Grajciar12df4972019-07-01 14:24:48 +0200157typedef int (memif_control_fd_update_t) (int fd, uint8_t events,
158 void *private_ctx);
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200159
160/** \brief Memif connection status update (callback function)
161 @param conn - memif connection handle
162 @param private_ctx - private context
163
164 Informs user about connection status connected/disconnected.
165 On connected -> start watching for events on interrupt fd (optional).
166*/
167typedef int (memif_connection_update_t) (memif_conn_handle_t conn,
168 void *private_ctx);
169
170/** \brief Memif interrupt occured (callback function)
171 @param conn - memif connection handle
172 @param private_ctx - private context
173 @param qid - queue id on which interrupt occured
174
175 Called when event is received on interrupt fd.
176*/
177typedef int (memif_interrupt_t) (memif_conn_handle_t conn, void *private_ctx,
178 uint16_t qid);
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200179
180/** @} */
181
182/**
183 * @defgroup EXTERNAL_REGION External region APIs
184 * @ingroup libmemif
185 *
186 * @{
187 */
188
189/** \brief Get external buffer offset (optional)
190 @param private_ctx - private context
191
192 Find unallocated external buffer and return its offset.
193*/
194typedef uint32_t (memif_get_external_buffer_offset_t) (void *private_ctx);
195
196/** \brief Add external region
197 @param[out] addr - region address
198 @param size - requested region size
199 @param fd[out] - file descriptor
200 @param private_ctx - private context
201
202 Called by slave. Add external region created by client.
203*/
204typedef int (memif_add_external_region_t) (void * *addr, uint32_t size,
205 int *fd, void *private_ctx);
206
207/** \brief Get external region address
208 @param size - requested region size
209 @param fd - file descriptor
210 @param private_ctx - private context
211
212 Called by master. Get region address from client.
213
214 \return region address
215*/
216typedef void *(memif_get_external_region_addr_t) (uint32_t size, int fd,
217 void *private_ctx);
218
219/** \brief Delete external region
220 @param addr - region address
221 @param size - region size
222 @param fd - file descriptor
223 @param private_ctx - private context
224
225 Delete external region.
226*/
227typedef int (memif_del_external_region_t) (void *addr, uint32_t size, int fd,
228 void *private_ctx);
229
230/** \brief Register external region
231 @param ar - add external region callback
232 @param gr - get external region addr callback
233 @param dr - delete external region callback
234 @param go - get external buffer offset callback (optional)
235*/
236void memif_register_external_region (memif_add_external_region_t * ar,
237 memif_get_external_region_addr_t * gr,
238 memif_del_external_region_t * dr,
239 memif_get_external_buffer_offset_t * go);
240
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200241/** \brief Register external region
242 @param pt_main - per thread main handle
243 @param ar - add external region callback
244 @param gr - get external region addr callback
245 @param dr - delete external region callback
246 @param go - get external buffer offset callback (optional)
247*/
248void memif_per_thread_register_external_region (memif_per_thread_main_handle_t
249 pt_main,
250 memif_add_external_region_t *
251 ar,
252 memif_get_external_region_addr_t
253 * gr,
254 memif_del_external_region_t *
255 dr,
256 memif_get_external_buffer_offset_t
257 * go);
258
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200259/** @} */
260
261/**
262 * @defgroup ARGS_N_BUFS Connection arguments and buffers
Dave Wallace6cd396c2018-01-23 17:47:02 -0500263 * @ingroup libmemif
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200264 *
265 * @{
266 */
267
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200268#ifndef _MEMIF_H_
269typedef enum
270{
271 MEMIF_INTERFACE_MODE_ETHERNET = 0,
272 MEMIF_INTERFACE_MODE_IP = 1,
273 MEMIF_INTERFACE_MODE_PUNT_INJECT = 2,
274} memif_interface_mode_t;
275#endif /* _MEMIF_H_ */
276
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200277/** \brief Memif connection arguments
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200278 @param socket - Memif socket handle, if NULL default socket will be used.
279 Default socket is only supported in global database (see memif_init).
280 Custom database does not create a default socket
281 (see memif_per_thread_init).
282 Memif connection is stored in the same database as the socket.
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200283 @param secret - otional parameter used as interface autenthication
284 @param num_s2m_rings - number of slave to master rings
285 @param num_m2s_rings - number of master to slave rings
286 @param buffer_size - size of buffer in shared memory
287 @param log2_ring_size - logarithm base 2 of ring size
288 @param is_master - 0 == master, 1 == slave
289 @param interface_id - id used to identify peer connection
290 @param interface_name - interface name
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200291 @param mode - 0 == ethernet, 1 == ip , 2 == punt/inject
292*/
293typedef struct
294{
Jakub Grajciar12df4972019-07-01 14:24:48 +0200295 memif_socket_handle_t socket; /*!< default = /run/vpp/memif.sock */
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200296 uint8_t secret[24]; /*!< optional (interface authentication) */
297
298 uint8_t num_s2m_rings; /*!< default = 1 */
299 uint8_t num_m2s_rings; /*!< default = 1 */
300 uint16_t buffer_size; /*!< default = 2048 */
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200301 uint8_t log2_ring_size; /*!< default = 10 (1024) */
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200302 uint8_t is_master;
303
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200304 uint32_t interface_id;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200305 uint8_t interface_name[32];
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200306 memif_interface_mode_t mode:8;
307} memif_conn_args_t;
308
309/*! memif receive mode */
310typedef enum
311{
312 MEMIF_RX_MODE_INTERRUPT = 0, /*!< interrupt mode */
313 MEMIF_RX_MODE_POLLING /*!< polling mode */
314} memif_rx_mode_t;
315
316/** \brief Memif buffer
317 @param desc_index - ring descriptor index
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200318 @param ring - pointer to ring containing descriptor for this buffer
319 @param len - available length
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200320 @param flags - memif buffer flags
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200321 @param data - pointer to shared memory data
322*/
323typedef struct
324{
325 uint16_t desc_index;
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200326 void *ring;
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200327 uint32_t len;
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200328/** next buffer present (chained buffers) */
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200329#define MEMIF_BUFFER_FLAG_NEXT (1 << 0)
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200330/** states that buffer is from rx ring */
331#define MEMIF_BUFFER_FLAG_RX (1 << 1)
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200332 uint8_t flags;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200333 void *data;
334} memif_buffer_t;
335/** @} */
336
337/**
338 * @defgroup MEMIF_DETAILS Memif details structs
Dave Wallace6cd396c2018-01-23 17:47:02 -0500339 * @ingroup libmemif
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200340 *
341 * @{
342 */
343
344/** \brief Memif queue details
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200345 @param region - region index
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200346 @param qid - queue id
347 @param ring_size - size of ring buffer in sharem memory
Jakub Grajciar84197552017-11-16 14:02:49 +0100348 @param flags - ring flags
349 @param head - ring head pointer
350 @param tail - ring tail pointer
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200351 @param buffer_size - buffer size on sharem memory
352*/
353typedef struct
354{
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200355 uint8_t region;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200356 uint8_t qid;
357 uint32_t ring_size;
Jakub Grajciar84197552017-11-16 14:02:49 +0100358/** if set queue is in polling mode, else in interrupt mode */
359#define MEMIF_QUEUE_FLAG_POLLING 1
360 uint16_t flags;
361 uint16_t head;
362 uint16_t tail;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200363 uint16_t buffer_size;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200364} memif_queue_details_t;
365
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200366/** \brief Memif region details
367 @param index - region index
368 @param addr - region address
369 @param size - region size
370 @param fd - file descriptor
371 @param is_external - if not zero then region is defined by client
372*/
373typedef struct
374{
375 uint8_t index;
376 void *addr;
377 uint32_t size;
378 int fd;
379 uint8_t is_external;
380} memif_region_details_t;
381
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200382/** \brief Memif details
383 @param if_name - interface name
384 @param inst_name - application name
385 @param remote_if_name - peer interface name
386 @param remote_inst_name - peer application name
387 @param id - connection id
388 @param secret - secret
389 @param role - 0 = master, 1 = slave
390 @param mode - 0 = ethernet, 1 = ip , 2 = punt/inject
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200391 @param socket_filename - socket filename
392 @param regions_num - number of regions
393 @param regions - struct containing region details
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200394 @param rx_queues_num - number of receive queues
395 @param tx_queues_num - number of transmit queues
396 @param rx_queues - struct containing receive queue details
397 @param tx_queues - struct containing transmit queue details
Jakub Grajciar568cc462018-09-05 12:11:35 +0200398 @param error - error string
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200399 @param link_up_down - 1 = up (connected), 2 = down (disconnected)
400*/
401typedef struct
402{
403 uint8_t *if_name;
404 uint8_t *inst_name;
405 uint8_t *remote_if_name;
406 uint8_t *remote_inst_name;
407
408 uint32_t id;
409 uint8_t *secret; /* optional */
410 uint8_t role; /* 0 = master, 1 = slave */
411 uint8_t mode; /* 0 = ethernet, 1 = ip, 2 = punt/inject */
412 uint8_t *socket_filename;
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200413 uint8_t regions_num;
414 memif_region_details_t *regions;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200415 uint8_t rx_queues_num;
416 uint8_t tx_queues_num;
417 memif_queue_details_t *rx_queues;
418 memif_queue_details_t *tx_queues;
419
Jakub Grajciar568cc462018-09-05 12:11:35 +0200420 uint8_t *error;
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200421 uint8_t link_up_down; /* 1 = up, 0 = down */
422} memif_details_t;
423/** @} */
424
425/**
426 * @defgroup API_CALLS Api calls
Dave Wallace6cd396c2018-01-23 17:47:02 -0500427 * @ingroup libmemif
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200428 *
429 * @{
430 */
431
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200432/** \brief Memif get version
433
434 \return ((MEMIF_VERSION_MAJOR << 8) | MEMIF_VERSION_MINOR)
435*/
436uint16_t memif_get_version ();
437
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200438/** \biref Memif get queue event file descriptor
439 @param conn - memif connection handle
440 @param qid - queue id
441 @param[out] fd - returns event file descriptor
442
443 \return memif_err_t
444*/
445
446int memif_get_queue_efd (memif_conn_handle_t conn, uint16_t qid, int *fd);
447
448/** \brief Memif set rx mode
449 @param conn - memif connection handle
450 @param rx_mode - receive mode
451 @param qid - queue id
452
453 \return memif_err_t
454*/
455int memif_set_rx_mode (memif_conn_handle_t conn, memif_rx_mode_t rx_mode,
456 uint16_t qid);
457
458/** \brief Memif strerror
459 @param err_code - error code
460
461 Converts error code to error message.
Jakub Grajciar84b83772019-03-04 12:42:19 +0100462
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200463 \return Error string
464*/
465char *memif_strerror (int err_code);
466
467/** \brief Memif get details
468 @param conn - memif conenction handle
469 @param md - pointer to memif details struct
470 @param buf - buffer containing details strings
471 @param buflen - length of buffer
472
473 \return memif_err_t
474*/
475int memif_get_details (memif_conn_handle_t conn, memif_details_t * md,
476 char *buf, ssize_t buflen);
477
478/** \brief Memif initialization
479 @param on_control_fd_update - if control fd updates inform user to watch new fd
Jakub Grajciar19418712018-03-13 13:57:50 +0100480 @param app_name - application name (will be truncated to 32 chars)
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200481 @param memif_alloc - cutom memory allocator, NULL = default
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200482 @param memif_realloc - custom memory reallocation, NULL = default
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200483 @param memif_free - custom memory free, NULL = default
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200484
485 if param on_control_fd_update is set to NULL,
486 libmemif will handle file descriptor event polling
487 if a valid callback is set, file descriptor event polling needs to be done by
488 user application, all file descriptors and event types will be passed in
489 this callback to user application
490
491 Initialize internal libmemif structures. Create timerfd (used to periodically request connection by
492 disconnected memifs in slave mode, with no additional API call). This fd is passed to user with memif_control_fd_update_t
493 timer is inactive at this state. It activates with if there is at least one memif in slave mode.
494
495 \return memif_err_t
496*/
497int memif_init (memif_control_fd_update_t * on_control_fd_update,
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200498 char *app_name, memif_alloc_t * memif_alloc,
Jakub Grajciar93a5dd12018-08-20 14:26:32 +0200499 memif_realloc_t * memif_realloc, memif_free_t * memif_free);
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200500
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200501/** \brief Memif per thread initialization
502 @param pt_main - per thread main handle
503 @param private_ctx - private context
504 @param on_control_fd_update - if control fd updates inform user to watch new fd
505 @param app_name - application name (will be truncated to 32 chars)
506 @param memif_alloc - cutom memory allocator, NULL = default
507 @param memif_realloc - custom memory reallocation, NULL = default
508 @param memif_free - custom memory free, NULL = default
509
510 Per thread version of memif_init ().
511 Instead of using global database, creates and initializes unique database,
512 identified by 'memif_per_thread_main_handle_t'.
513
514 \return memif_err_t
515*/
516int memif_per_thread_init (memif_per_thread_main_handle_t * pt_main,
517 void *private_ctx,
518 memif_control_fd_update_t * on_control_fd_update,
519 char *app_name, memif_alloc_t * memif_alloc,
520 memif_realloc_t * memif_realloc,
521 memif_free_t * memif_free);
522
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200523/** \brief Memif cleanup
524
525 Free libmemif internal allocations.
526
527 \return 0
528*/
529int memif_cleanup ();
530
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200531/** \brief Memif per thread cleanup
532 @param pt_main - per thread main handle
533
534 Free libmemif internal allocations and sets the handle to NULL.
535
536 \return memif_err_t
537*/
538int memif_per_thread_cleanup (memif_per_thread_main_handle_t * pt_main);
539
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200540/** \brief Memory interface create function
Jakub Grajciar12df4972019-07-01 14:24:48 +0200541 @param conn - connection handle for client app
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200542 @param args - memory interface connection arguments
543 @param on_connect - inform user about connected status
544 @param on_disconnect - inform user about disconnected status
545 @param on_interrupt - informs user about interrupt, if set to null user will not be notified about interrupt, user can use memif_get_queue_efd call to get interrupt fd to poll for events
546 @param private_ctx - private contex passed back to user with callback
547
548 Creates memory interface.
Jakub Grajciar84b83772019-03-04 12:42:19 +0100549
550 SLAVE-MODE -
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200551 Start timer that will send events to timerfd. If this fd is passed to memif_control_fd_handler
552 every disconnected memif in slave mode will send connection request.
553 On success new fd is passed to user with memif_control_fd_update_t.
554
Jakub Grajciar84b83772019-03-04 12:42:19 +0100555 MASTER-MODE -
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200556 Create listener socket and pass fd to user with memif_cntrol_fd_update_t.
557 If this fd is passed to memif_control_fd_handler accept will be called and
558 new fd will be passed to user with memif_control_fd_update_t.
559
560
561 \return memif_err_t
562*/
563int memif_create (memif_conn_handle_t * conn, memif_conn_args_t * args,
564 memif_connection_update_t * on_connect,
565 memif_connection_update_t * on_disconnect,
566 memif_interrupt_t * on_interrupt, void *private_ctx);
567
568/** \brief Memif control file descriptor handler
569 @param fd - file descriptor on which the event occured
570 @param events - event type(s) that occured
571
572 If event occures on any control fd, call memif_control_fd_handler.
573 Internal - lib will "identify" fd (timerfd, lsitener, control) and handle event accordingly.
Jakub Grajciar84b83772019-03-04 12:42:19 +0100574
575 FD-TYPE -
576 TIMERFD -
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200577 Every disconnected memif in slave mode will request connection.
Jakub Grajciar84b83772019-03-04 12:42:19 +0100578 LISTENER or CONTROL -
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200579 Handle socket messaging (internal connection establishment).
Jakub Grajciar84b83772019-03-04 12:42:19 +0100580 INTERRUPT -
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200581 Call on_interrupt callback (if set).
Jakub Grajciar84b83772019-03-04 12:42:19 +0100582
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200583 \return memif_err_t
584
585*/
586int memif_control_fd_handler (int fd, uint8_t events);
587
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200588/** \brief Memif per thread control file descriptor handler
589 @param pt_main - per thread main handle
590 @param fd - file descriptor on which the event occured
591 @param events - event type(s) that occured
592
593 Per thread version of memif_control_fd_handler.
594
595 \return memif_err_t
596
597*/
598int memif_per_thread_control_fd_handler (memif_per_thread_main_handle_t
599 pt_main, int fd, uint8_t events);
600
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200601/** \brief Memif delete
602 @param conn - pointer to memif connection handle
603
604
605 disconnect session (free queues and regions, close file descriptors, unmap shared memory)
606 set connection handle to NULL, to avoid possible double free
607
608 \return memif_err_t
609*/
610int memif_delete (memif_conn_handle_t * conn);
611
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200612/** \brief Memif buffer enq tx
613 @param conn - memif conenction handle
614 @param qid - number indentifying queue
615 @param bufs - memif buffers
616 @param count - number of memif buffers to enque
617 @param count_out - returns number of allocated buffers
618
619 Slave is producer of buffers.
620 If connection handle points to master returns MEMIF_ERR_INVAL_ARG.
621
622 \return memif_err_t
623*/
624int memif_buffer_enq_tx (memif_conn_handle_t conn, uint16_t qid,
625 memif_buffer_t * bufs, uint16_t count,
626 uint16_t * count_out);
627
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200628/** \brief Memif buffer alloc
629 @param conn - memif conenction handle
630 @param qid - number indentifying queue
631 @param bufs - memif buffers
632 @param count - number of memif buffers to allocate
633 @param count_out - returns number of allocated buffers
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200634 @param size - buffer size, may return chained buffers if size > buffer_size
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200635
636 \return memif_err_t
637*/
638int memif_buffer_alloc (memif_conn_handle_t conn, uint16_t qid,
639 memif_buffer_t * bufs, uint16_t count,
Jakub Grajciarb467b2a2017-09-14 14:12:10 +0200640 uint16_t * count_out, uint16_t size);
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200641
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200642/** \brief Memif refill ring
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200643 @param conn - memif conenction handle
644 @param qid - number indentifying queue
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200645 @param count - number of buffers to be placed on ring
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200646 @param headroom - offset the buffer by headroom
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200647
648 \return memif_err_t
649*/
Jakub Grajciarecfa2aa2018-03-26 11:26:34 +0200650int memif_refill_queue (memif_conn_handle_t conn, uint16_t qid,
Jakub Grajciar3744fc72018-03-29 13:15:10 +0200651 uint16_t count, uint16_t headroom);
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200652
653/** \brief Memif transmit buffer burst
654 @param conn - memif conenction handle
655 @param qid - number indentifying queue
656 @param bufs - memif buffers
657 @param count - number of memif buffers to transmit
658 @param tx - returns number of transmitted buffers
659
660 \return memif_err_t
661*/
662int memif_tx_burst (memif_conn_handle_t conn, uint16_t qid,
663 memif_buffer_t * bufs, uint16_t count, uint16_t * tx);
664
665/** \brief Memif receive buffer burst
666 @param conn - memif conenction handle
667 @param qid - number indentifying queue
668 @param bufs - memif buffers
669 @param count - number of memif buffers to receive
670 @param rx - returns number of received buffers
671
Jan Cavojsky77a95cd2020-03-03 16:25:58 +0100672 Consume interrupt event for receive queue.
673 The event is not consumed, if memif_rx_burst fails.
674
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200675 \return memif_err_t
676*/
677int memif_rx_burst (memif_conn_handle_t conn, uint16_t qid,
678 memif_buffer_t * bufs, uint16_t count, uint16_t * rx);
679
680/** \brief Memif poll event
681 @param timeout - timeout in seconds
682
Jakub Grajciar84b83772019-03-04 12:42:19 +0100683 Passive event polling -
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200684 timeout = 0 - dont wait for event, check event queue if there is an event and return.
685 timeout = -1 - wait until event
686
687 \return memif_err_t
688*/
689int memif_poll_event (int timeout);
Milan Lenco0a47c992017-10-12 14:19:31 +0200690
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200691/** \brief Memif poll event
692 @param pt_main - per thread main handle
693 @param timeout - timeout in seconds
694
695 Per thread version of memif_poll_event.
696
697 \return memif_err_t
698*/
699int memif_per_thread_poll_event (memif_per_thread_main_handle_t pt_main,
700 int timeout);
701
Milan Lenco0a47c992017-10-12 14:19:31 +0200702/** \brief Send signal to stop concurrently running memif_poll_event().
703
704 The function, however, does not wait for memif_poll_event() to stop.
705 memif_poll_event() may still return simply because an event has occured
706 or the timeout has elapsed, but if called repeatedly in an infinite loop,
707 a canceled memif_poll_event() is guaranted to return MEMIF_ERR_POLL_CANCEL
708 in the shortest possible time.
709 This feature was not available in the first release.
710 Use macro MEMIF_HAVE_CANCEL_POLL_EVENT to check if the feature is present.
711
712 \return memif_err_t
713*/
714#define MEMIF_HAVE_CANCEL_POLL_EVENT 1
715int memif_cancel_poll_event ();
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200716/** \brief Send signal to stop concurrently running memif_poll_event().
717 @param pt_main - per thread main handle
718
719 Per thread version of memif_cancel_poll_event.
720
721 \return memif_err_t
722*/
723int memif_per_thread_cancel_poll_event (memif_per_thread_main_handle_t
724 pt_main);
Jakub Grajciar84b83772019-03-04 12:42:19 +0100725
726/** \brief Set connection request timer value
727 @param timer - new timer value
728
729 Timer on which all disconnected slaves request connection.
730 See system call 'timer_settime' man-page.
731
732 \return memif_err_t
733*/
Jakub Grajciar12df4972019-07-01 14:24:48 +0200734int memif_set_connection_request_timer (struct itimerspec timer);
Jakub Grajciar84b83772019-03-04 12:42:19 +0100735
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200736/** \brief Set connection request timer value
737 @param pt_main - per thread main handle
738 @param timer - new timer value
739
740 Per thread version of memif_set_connection_request_timer
741
742 \return memif_err_t
743*/
744int
745memif_per_thread_set_connection_request_timer (memif_per_thread_main_handle_t
746 pt_main,
747 struct itimerspec timer);
748
Jakub Grajciar84b83772019-03-04 12:42:19 +0100749/** \brief Send connection request
750 @param conn - memif connection handle
751
752 Only slave interface can request connection.
753
754 \return memif_err_t
755*/
Jakub Grajciar12df4972019-07-01 14:24:48 +0200756int memif_request_connection (memif_conn_handle_t conn);
757
758/** \brief Create memif socket
759 @param sock - socket handle for client app
760 @param filename - path to socket file
761 @param private_ctx - private context
762
763 The first time an interface is assigned a socket, its type is determined.
764 For master role it's 'listener', for slave role it's 'client'. Each interface
765 requires socket of its respective type. Default socket is creted if no
766 socket handle is passed to memif_create(). It's private context is NULL.
767 If all interfaces using this socket are deleted, the socket returns
768 to its default state.
769
770 \return memif_err_t
771*/
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200772int memif_create_socket (memif_socket_handle_t * sock, const char *filename,
773 void *private_ctx);
774
775/** \brief Create memif socket
776 @param pt_main - per thread main handle
777 @param sock - socket handle for client app
778 @param filename - path to socket file
779 @param private_ctx - private context
780
781 Per thread version of memif_create_sopcket.
782
783 \return memif_err_t
784*/
785int memif_per_thread_create_socket (memif_per_thread_main_handle_t pt_main,
786 memif_socket_handle_t * sock,
787 const char *filename, void *private_ctx);
Jakub Grajciar12df4972019-07-01 14:24:48 +0200788
789/** \brief Delete memif socket
790 @param sock - socket handle for client app
791
792 When trying to free socket in use, socket will not be freed and
793 MEMIF_ERR_INVAL_ARG is returned.
794
795 \return memif_err_t
796*/
797int memif_delete_socket (memif_socket_handle_t * sock);
798
Jakub Grajciar17f2a7b2019-07-31 14:40:52 +0200799/** \brief Get socket filename
800 @param sock - socket handle for client app
801
802 Return constant pointer to socket filename.
803
804 \return cosnt char *
805*/
806const char *memif_get_socket_filename (memif_socket_handle_t sock);
807
Jakub Grajciar7c5c40d2017-08-30 10:13:25 +0200808/** @} */
809
810#endif /* _LIBMEMIF_H_ */