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
|
// SPDX-License-Identifier: GPL-2.0-or-later
/*
* MGMTD Transactions
*
* Copyright (C) 2021 Vmware, Inc.
* Pushpasis Sarkar <spushpasis@vmware.com>
*/
#ifndef _FRR_MGMTD_TXN_H_
#define _FRR_MGMTD_TXN_H_
#include "mgmtd/mgmt_be_adapter.h"
#include "mgmtd/mgmt.h"
#include "mgmtd/mgmt_ds.h"
#define MGMTD_TXN_PROC_DELAY_MSEC 5
#define MGMTD_TXN_PROC_DELAY_USEC 10
#define MGMTD_TXN_MAX_NUM_SETCFG_PROC 128
#define MGMTD_TXN_MAX_NUM_GETCFG_PROC 128
#define MGMTD_TXN_MAX_NUM_GETDATA_PROC 128
#define MGMTD_TXN_SEND_CFGVALIDATE_DELAY_MSEC 100
#define MGMTD_TXN_SEND_CFGAPPLY_DELAY_MSEC 100
#define MGMTD_TXN_CFG_COMMIT_MAX_DELAY_MSEC 30000 /* 30 seconds */
#define MGMTD_TXN_CLEANUP_DELAY_MSEC 100
#define MGMTD_TXN_CLEANUP_DELAY_USEC 10
/*
* The following definition enables local validation of config
* on the MGMTD process by loading client-defined NB callbacks
* and calling them locally before sening CNFG_APPLY_REQ to
* backend for actual apply of configuration on internal state
* of the backend application.
*
* #define MGMTD_LOCAL_VALIDATIONS_ENABLED
*
* Note: Enabled by default in configure.ac, if this needs to be
* disabled then pass --enable-mgmtd-local-validations=no to
* the list of arguments passed to ./configure
*/
PREDECL_LIST(mgmt_txns);
struct mgmt_master;
enum mgmt_txn_type {
MGMTD_TXN_TYPE_NONE = 0,
MGMTD_TXN_TYPE_CONFIG,
MGMTD_TXN_TYPE_SHOW
};
static inline const char *mgmt_txn_type2str(enum mgmt_txn_type type)
{
switch (type) {
case MGMTD_TXN_TYPE_NONE:
return "None";
case MGMTD_TXN_TYPE_CONFIG:
return "CONFIG";
case MGMTD_TXN_TYPE_SHOW:
return "SHOW";
}
return "Unknown";
}
/* Initialise transaction module. */
extern int mgmt_txn_init(struct mgmt_master *cm, struct event_loop *tm);
/* Destroy the transaction module. */
extern void mgmt_txn_destroy(void);
/*
* Check if transaction is in progress.
*
* Returns:
* session ID if in-progress, MGMTD_SESSION_ID_NONE otherwise.
*/
extern uint64_t mgmt_config_txn_in_progress(void);
/*
* Create transaction.
*
* session_id
* Session ID.
*
* type
* Transaction type (CONFIG/SHOW/NONE)
*
* Returns:
* transaction ID.
*/
extern uint64_t mgmt_create_txn(uint64_t session_id, enum mgmt_txn_type type);
/*
* Destroy transaction.
*
* txn_id
* Unique transaction identifier.
*/
extern void mgmt_destroy_txn(uint64_t *txn_id);
/*
* Send set-config request to be processed later in transaction.
*
* txn_id
* Unique transaction identifier.
*
* req_id
* Unique transaction request identifier.
*
* ds_id
* Datastore ID.
*
* ds_hndl
* Datastore handle.
*
* cfg_req
* Config requests.
*
* num_req
* Number of config requests.
*
* implicit_commit
* TRUE if the commit is implicit, FALSE otherwise.
*
* dst_ds_id
* Destination datastore ID.
*
* dst_ds_handle
* Destination datastore handle.
*
* Returns:
* 0 on success, -1 on failures.
*/
extern int mgmt_txn_send_set_config_req(uint64_t txn_id, uint64_t req_id,
Mgmtd__DatastoreId ds_id,
struct mgmt_ds_ctx *ds_ctx,
Mgmtd__YangCfgDataReq **cfg_req,
size_t num_req, bool implicit_commit,
Mgmtd__DatastoreId dst_ds_id,
struct mgmt_ds_ctx *dst_ds_ctx);
/*
* Send commit-config request to be processed later in transaction.
*
* txn_id
* Unique transaction identifier.
*
* req_id
* Unique transaction request identifier.
*
* src_ds_id
* Source datastore ID.
*
* src_ds_hndl
* Source Datastore handle.
*
* validate_only
* TRUE if commit request needs to be validated only, FALSE otherwise.
*
* abort
* TRUE if need to restore Src DS back to Dest DS, FALSE otherwise.
*
* implicit
* TRUE if the commit is implicit, FALSE otherwise.
*
* Returns:
* 0 on success, -1 on failures.
*/
extern int mgmt_txn_send_commit_config_req(uint64_t txn_id, uint64_t req_id,
Mgmtd__DatastoreId src_ds_id,
struct mgmt_ds_ctx *dst_ds_ctx,
Mgmtd__DatastoreId dst_ds_id,
struct mgmt_ds_ctx *src_ds_ctx,
bool validate_only, bool abort,
bool implicit);
/*
* Send get-{cfg,data} request to be processed later in transaction.
*
* Is get-config if cfg_root is provided and the config is gathered locally,
* otherwise it's get-data and data is fetched from backedn clients.
*/
extern int mgmt_txn_send_get_req(uint64_t txn_id, uint64_t req_id,
Mgmtd__DatastoreId ds_id,
struct nb_config *cfg_root,
Mgmtd__YangGetDataReq **data_req,
size_t num_reqs);
/*
* Notifiy backend adapter on connection.
*/
extern int
mgmt_txn_notify_be_adapter_conn(struct mgmt_be_client_adapter *adapter,
bool connect);
/*
* Reply to backend adapter about transaction create/delete.
*/
extern int
mgmt_txn_notify_be_txn_reply(uint64_t txn_id, bool create, bool success,
struct mgmt_be_client_adapter *adapter);
/*
* Reply to backend adapater with config data create request.
*/
extern int
mgmt_txn_notify_be_cfgdata_reply(uint64_t txn_id, uint64_t batch_id,
bool success, char *error_if_any,
struct mgmt_be_client_adapter *adapter);
/*
* Reply to backend adapater with config data validate request.
*/
extern int mgmt_txn_notify_be_cfg_validate_reply(
uint64_t txn_id, bool success, uint64_t batch_ids[],
size_t num_batch_ids, char *error_if_any,
struct mgmt_be_client_adapter *adapter);
/*
* Reply to backend adapater with config data apply request.
*/
extern int
mgmt_txn_notify_be_cfg_apply_reply(uint64_t txn_id, bool success,
uint64_t batch_ids[],
size_t num_batch_ids, char *error_if_any,
struct mgmt_be_client_adapter *adapter);
/*
* Dump transaction status to vty.
*/
extern void mgmt_txn_status_write(struct vty *vty);
/*
* Trigger rollback config apply.
*
* Creates a new transaction and commit request for rollback.
*/
extern int
mgmt_txn_rollback_trigger_cfg_apply(struct mgmt_ds_ctx *src_ds_ctx,
struct mgmt_ds_ctx *dst_ds_ctx);
#endif /* _FRR_MGMTD_TXN_H_ */
|
