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
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
* Copyright (C) 2023 IBM, Inc.
*
* This is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License version 2.1, as published by the Free Software
* Foundation. See file COPYING.
*/
#ifndef MON_NVMEOFGWMAP_H_
#define MON_NVMEOFGWMAP_H_
#include <map>
#include <iostream>
#include "include/encoding.h"
#include "include/utime.h"
#include "common/Formatter.h"
#include "common/ceph_releases.h"
#include "common/version.h"
#include "common/options.h"
#include "common/Clock.h"
#include "msg/Message.h"
#include "common/ceph_time.h"
#include "NVMeofGwTypes.h"
using ceph::coarse_mono_clock;
class health_check_map_t;
class Monitor;
/*-------------------*/
class NVMeofGwMap
{
public:
Monitor *mon = NULL;
// epoch is for Paxos synchronization mechanizm
epoch_t epoch = 0;
bool delay_propose = false;
std::map<NvmeGroupKey, NvmeGwMonStates> created_gws;
// map that handles timers started by all Gateway FSMs
std::map<NvmeGroupKey, NvmeGwTimers> fsm_timers;
void to_gmap(std::map<NvmeGroupKey, NvmeGwMonClientStates>& Gmap) const;
void track_deleting_gws(const NvmeGroupKey& group_key,
const BeaconSubsystems& subs, bool &propose_pending);
int cfg_add_gw(const NvmeGwId &gw_id, const NvmeGroupKey& group_key);
int cfg_delete_gw(const NvmeGwId &gw_id, const NvmeGroupKey& group_key);
void process_gw_map_ka(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
epoch_t& last_osd_epoch, bool &propose_pending);
int process_gw_map_gw_down(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
bool &propose_pending);
int process_gw_map_gw_no_subsys_no_listeners(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
bool &propose_pending);
void update_active_timers(bool &propose_pending);
void handle_abandoned_ana_groups(bool &propose_pending);
void handle_removed_subsystems(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
const std::vector<NvmeNqnId> ¤t_subsystems, bool &propose_pending);
void start_timer(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeAnaGrpId anagrpid, uint8_t value);
void handle_gw_performing_fast_reboot(const NvmeGwId &gw_id,
const NvmeGroupKey& group_key, bool &map_modified);
private:
int do_delete_gw(const NvmeGwId &gw_id, const NvmeGroupKey& group_key);
int do_erase_gw_id(const NvmeGwId &gw_id,
const NvmeGroupKey& group_key);
void add_grp_id(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
const NvmeAnaGrpId grpid);
void remove_grp_id(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
const NvmeAnaGrpId grpid);
void fsm_handle_gw_down(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
gw_states_per_group_t state, NvmeAnaGrpId grpid, bool &map_modified);
void fsm_handle_gw_no_subsystems(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
gw_states_per_group_t state, NvmeAnaGrpId grpid, bool &map_modified);
void fsm_handle_gw_delete(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
gw_states_per_group_t state, NvmeAnaGrpId grpid, bool &map_modified);
void fsm_handle_gw_alive(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeGwMonState & gw_state, gw_states_per_group_t state,
NvmeAnaGrpId grpid, epoch_t& last_osd_epoch, bool &map_modified);
void fsm_handle_to_expired(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeAnaGrpId grpid, bool &map_modified);
void fsm_handle_gw_fast_reboot(const NvmeGwId &gw_id,
const NvmeGroupKey& group_key, NvmeAnaGrpId grpid,
bool &map_modified);
void find_failover_candidate(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeAnaGrpId grpid, bool &propose_pending);
void find_failback_gw(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
bool &propose_pending);
void set_failover_gw_for_ANA_group(
const NvmeGwId &failed_gw_id, const NvmeGroupKey& group_key,
const NvmeGwId &gw_id, NvmeAnaGrpId groupid);
int get_num_namespaces(const NvmeGwId &gw_id,
const NvmeGroupKey& group_key, const BeaconSubsystems& subs );
int get_timer(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeAnaGrpId anagrpid);
void cancel_timer(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeAnaGrpId anagrpid);
void validate_gw_map(
const NvmeGroupKey& group_key);
public:
int blocklist_gw(
const NvmeGwId &gw_id, const NvmeGroupKey& group_key,
NvmeAnaGrpId ANA_groupid, epoch_t &epoch, bool failover);
void encode(ceph::buffer::list &bl, uint64_t features) const {
using ceph::encode;
ENCODE_START(1, 1, bl);
encode(epoch, bl);// global map epoch
encode(created_gws, bl, features); //Encode created GWs
encode(fsm_timers, bl, features);
ENCODE_FINISH(bl);
}
void decode(ceph::buffer::list::const_iterator &bl) {
using ceph::decode;
DECODE_START(1, bl);
decode(epoch, bl);
decode(created_gws, bl);
decode(fsm_timers, bl);
DECODE_FINISH(bl);
}
void get_health_checks(health_check_map_t *checks);
};
#include "NVMeofGwSerialize.h"
#endif /* SRC_MON_NVMEOFGWMAP_H_ */
|
