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
|
/*
* builtin_proxy.h - skeleton vpp engine plug-in header file
*
* Copyright (c) 2017-2019 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 __included_proxy_h__
#define __included_proxy_h__
#include <vnet/vnet.h>
#include <vnet/ip/ip.h>
#include <vppinfra/hash.h>
#include <vppinfra/error.h>
#include <vnet/session/session.h>
#include <vnet/session/application_interface.h>
#include <http/http.h>
#define foreach_proxy_session_side_state \
_ (CREATED, "created") \
_ (CONNECTING, "connecting") \
_ (ESTABLISHED, "establiehed") \
_ (CLOSED, "closed")
typedef enum proxy_session_side_state_
{
#define _(sym, str) PROXY_SC_S_##sym,
foreach_proxy_session_side_state
#undef _
} proxy_session_side_state_t;
typedef struct proxy_session_side_
{
session_handle_t session_handle;
svm_fifo_t *rx_fifo;
svm_fifo_t *tx_fifo;
u8 is_http;
} proxy_session_side_t;
typedef struct proxy_session_side_ctx_
{
proxy_session_side_t pair;
proxy_session_side_state_t state;
u32 sc_index;
u32 ps_index;
} proxy_session_side_ctx_t;
typedef struct
{
proxy_session_side_t po; /**< passive open side */
proxy_session_side_t ao; /**< active open side */
volatile int active_open_establishing;
volatile int po_disconnected;
volatile int ao_disconnected;
u32 ps_index;
} proxy_session_t;
typedef struct proxy_worker_
{
proxy_session_side_ctx_t *ctx_pool;
clib_spinlock_t pending_connects_lock;
vnet_connect_args_t *pending_connects;
vnet_connect_args_t *burst_connects;
} proxy_worker_t;
typedef struct
{
proxy_worker_t *workers; /**< per-thread data */
proxy_session_t *sessions; /**< session pool, shared */
clib_spinlock_t sessions_lock; /**< lock for session pool */
u8 **rx_buf; /**< intermediate rx buffers */
http_header_table_t *req_headers; /**< HTTP request headers */
u32 server_client_index; /**< server API client handle */
u32 server_app_index; /**< server app index */
u32 active_open_client_index; /**< active open API client handle */
u32 active_open_app_index; /**< active open index after attach */
u32 ckpair_index; /**< certkey pair index for tls */
u8 *capsule_proto_header;
/*
* Configuration params
*/
u32 fifo_size; /**< initial fifo size */
u32 max_fifo_size; /**< max fifo size */
u8 high_watermark; /**< high watermark (%) */
u8 low_watermark; /**< low watermark (%) */
u32 private_segment_count; /**< Number of private fifo segs */
u64 segment_size; /**< size of fifo segs */
u8 prealloc_fifos; /**< Request fifo preallocation */
u32 idle_timeout; /**< connect-proxy timeout for idle connections */
int rcv_buffer_size;
session_endpoint_cfg_t server_sep;
session_endpoint_cfg_t *client_sep;
/*
* Flags
*/
u8 is_init;
} proxy_main_t;
extern proxy_main_t proxy_main;
static inline proxy_worker_t *
proxy_worker_get (u32 thread_index)
{
proxy_main_t *pm = &proxy_main;
return vec_elt_at_index (pm->workers, thread_index);
}
#endif /* __included_proxy_h__ */
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
|
