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
|
// SPDX-License-Identifier: GPL-2.0-or-later
/*
* MGMTD Frontend Client Connection Adapter
*
* Copyright (C) 2021 Vmware, Inc.
* Pushpasis Sarkar <spushpasis@vmware.com>
*/
#ifndef _FRR_MGMTD_FE_ADAPTER_H_
#define _FRR_MGMTD_FE_ADAPTER_H_
#include "mgmt_fe_client.h"
#include "mgmt_msg.h"
#include "mgmtd/mgmt_defines.h"
struct mgmt_fe_client_adapter;
struct mgmt_master;
struct mgmt_commit_stats {
struct timeval last_start;
#ifdef MGMTD_LOCAL_VALIDATIONS_ENABLED
struct timeval validate_start;
#endif
struct timeval prep_cfg_start;
struct timeval txn_create_start;
struct timeval send_cfg_start;
struct timeval apply_cfg_start;
struct timeval apply_cfg_end;
struct timeval txn_del_start;
struct timeval last_end;
unsigned long last_exec_tm;
unsigned long max_tm;
unsigned long min_tm;
unsigned long last_batch_cnt;
unsigned long last_num_cfgdata_reqs;
unsigned long last_num_apply_reqs;
unsigned long max_batch_cnt;
unsigned long min_batch_cnt;
unsigned long commit_cnt;
};
struct mgmt_setcfg_stats {
struct timeval last_start;
struct timeval last_end;
unsigned long last_exec_tm;
unsigned long max_tm;
unsigned long min_tm;
unsigned long avg_tm;
unsigned long set_cfg_count;
};
PREDECL_LIST(mgmt_fe_sessions);
PREDECL_LIST(mgmt_fe_adapters);
struct mgmt_fe_client_adapter {
int conn_fd;
union sockunion conn_su;
struct event *conn_read_ev;
struct event *conn_write_ev;
struct event *conn_writes_on;
struct event *proc_msg_ev;
uint32_t flags;
char name[MGMTD_CLIENT_NAME_MAX_LEN];
/* List of sessions created and being maintained for this client. */
struct mgmt_fe_sessions_head fe_sessions;
/* IO streams for read and write */
struct mgmt_msg_state mstate;
int refcount;
struct mgmt_commit_stats cmt_stats;
struct mgmt_setcfg_stats setcfg_stats;
struct mgmt_fe_adapters_item list_linkage;
};
#define MGMTD_FE_ADAPTER_FLAGS_WRITES_OFF (1U << 0)
DECLARE_LIST(mgmt_fe_adapters, struct mgmt_fe_client_adapter, list_linkage);
/* Initialise frontend adapter module */
extern int mgmt_fe_adapter_init(struct event_loop *tm, struct mgmt_master *cm);
/* Destroy frontend adapter module */
extern void mgmt_fe_adapter_destroy(void);
/* Acquire lock for frontend adapter */
extern void mgmt_fe_adapter_lock(struct mgmt_fe_client_adapter *adapter);
/* Remove lock from frontend adapter */
extern void
mgmt_fe_adapter_unlock(struct mgmt_fe_client_adapter **adapter);
/* Create frontend adapter */
extern struct mgmt_fe_client_adapter *
mgmt_fe_create_adapter(int conn_fd, union sockunion *su);
/* Fetch frontend adapter given a name */
extern struct mgmt_fe_client_adapter *
mgmt_fe_get_adapter(const char *name);
/*
* Send set-config reply to the frontend client.
*
* session
* Unique session identifier.
*
* txn_id
* Unique transaction identifier.
*
* ds_id
* Datastore ID.
*
* req_id
* Config request ID.
*
* result
* Config request result (MGMT_*).
*
* error_if_any
* Buffer to store human-readable error message in case of error.
*
* implicit_commit
* TRUE if the commit is implicit, FALSE otherwise.
*
* Returns:
* 0 on success, -1 on failures.
*/
extern int mgmt_fe_send_set_cfg_reply(uint64_t session_id, uint64_t txn_id,
Mgmtd__DatastoreId ds_id,
uint64_t req_id,
enum mgmt_result result,
const char *error_if_any,
bool implcit_commit);
/*
* Send commit-config reply to the frontend client.
*/
extern int mgmt_fe_send_commit_cfg_reply(
uint64_t session_id, uint64_t txn_id, Mgmtd__DatastoreId src_ds_id,
Mgmtd__DatastoreId dst_ds_id, uint64_t req_id, bool validate_only,
enum mgmt_result result, const char *error_if_any);
/*
* Send get-config reply to the frontend client.
*/
extern int mgmt_fe_send_get_cfg_reply(uint64_t session_id, uint64_t txn_id,
Mgmtd__DatastoreId ds_id,
uint64_t req_id,
enum mgmt_result result,
Mgmtd__YangDataReply *data_resp,
const char *error_if_any);
/*
* Send get-data reply to the frontend client.
*/
extern int mgmt_fe_send_get_data_reply(
uint64_t session_id, uint64_t txn_id, Mgmtd__DatastoreId ds_id,
uint64_t req_id, enum mgmt_result result,
Mgmtd__YangDataReply *data_resp, const char *error_if_any);
/*
* Send data notify to the frontend client.
*/
extern int mgmt_fe_send_data_notify(Mgmtd__DatastoreId ds_id,
Mgmtd__YangData * data_resp[],
int num_data);
/* Fetch frontend client session set-config stats */
extern struct mgmt_setcfg_stats *
mgmt_fe_get_session_setcfg_stats(uint64_t session_id);
/* Fetch frontend client session commit stats */
extern struct mgmt_commit_stats *
mgmt_fe_get_session_commit_stats(uint64_t session_id);
extern void mgmt_fe_adapter_status_write(struct vty *vty, bool detail);
extern void mgmt_fe_adapter_perf_measurement(struct vty *vty, bool config);
extern void mgmt_fe_adapter_reset_perf_stats(struct vty *vty);
#endif /* _FRR_MGMTD_FE_ADAPTER_H_ */
|
