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
|
/*
* Copyright (c) 2017 Cisco and/or its affiliates.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef SRC_VNET_SESSION_SEGMENT_MANAGER_H_
#define SRC_VNET_SESSION_SEGMENT_MANAGER_H_
#include <vnet/vnet.h>
#include <svm/svm_fifo_segment.h>
#include <vlibmemory/unix_shared_memory_queue.h>
#include <vlibmemory/api.h>
#include <vppinfra/lock.h>
typedef struct _segment_manager_properties
{
/** Session fifo sizes. */
u32 rx_fifo_size;
u32 tx_fifo_size;
/** Preallocated pool sizes */
u32 preallocated_fifo_pairs;
/** Configured additional segment size */
u32 add_segment_size;
/** Flag that indicates if additional segments should be created */
u8 add_segment;
/** Use private memory segment instead of shared memory */
u8 use_private_segment;
/** Use one or more private mheaps, instead of the global heap */
u32 private_segment_count;
} segment_manager_properties_t;
typedef struct _segment_manager
{
clib_spinlock_t lockp;
/** segments mapped by this manager */
u32 *segment_indices;
/** Owner app index */
u32 app_index;
/**
* Pointer to manager properties. Could be shared among all of
* an app's segment managers s
*/
u32 properties_index;
/**
* First segment should not be deleted unless segment manger is deleted.
* This also indicates that the segment manager is the first to have been
* allocated for the app.
*/
u8 first_is_protected;
} segment_manager_t;
#define SEGMENT_MANAGER_INVALID_APP_INDEX ((u32) ~0)
/** Pool of segment managers */
extern segment_manager_t *segment_managers;
always_inline segment_manager_t *
segment_manager_get (u32 index)
{
return pool_elt_at_index (segment_managers, index);
}
always_inline segment_manager_t *
segment_manager_get_if_valid (u32 index)
{
if (pool_is_free_index (segment_managers, index))
return 0;
return pool_elt_at_index (segment_managers, index);
}
always_inline u32
segment_manager_index (segment_manager_t * sm)
{
return sm - segment_managers;
}
segment_manager_t *segment_manager_new ();
int
segment_manager_init (segment_manager_t * sm, u32 props_index, u32 seg_size);
void segment_manager_get_segment_info (u32 index, u8 ** name, u32 * size);
int
session_manager_add_first_segment (segment_manager_t * sm, u32 segment_size);
int session_manager_add_segment (segment_manager_t * sm);
void segment_manager_del_sessions (segment_manager_t * sm);
void segment_manager_del (segment_manager_t * sm);
void segment_manager_init_del (segment_manager_t * sm);
u8 segment_manager_has_fifos (segment_manager_t * sm);
int
segment_manager_alloc_session_fifos (segment_manager_t * sm,
svm_fifo_t ** server_rx_fifo,
svm_fifo_t ** server_tx_fifo,
u32 * fifo_segment_index);
void
segment_manager_dealloc_fifos (u32 svm_segment_index, svm_fifo_t * rx_fifo,
svm_fifo_t * tx_fifo);
unix_shared_memory_queue_t *segment_manager_alloc_queue (segment_manager_t *
sm, u32 queue_size);
void segment_manager_dealloc_queue (segment_manager_t * sm,
unix_shared_memory_queue_t * q);
void segment_manager_app_detach (segment_manager_t * sm);
segment_manager_properties_t *segment_manager_properties_alloc (void);
void segment_manager_properties_free (segment_manager_properties_t * p);
segment_manager_properties_t *segment_manager_properties_get (u32 smp_index);
u32 segment_manager_properties_index (segment_manager_properties_t * p);
#endif /* SRC_VNET_SESSION_SEGMENT_MANAGER_H_ */
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
|
