Signed-off-by: leonidc <leonidc@il.ibm.com>
bool apply_ack_logic = true;
bool send_ack = false;
+ check_beacon_timeout(now, gw_propose);
if (avail == gw_availability_t::GW_CREATED) {
- if (gw == group_gws.end()) {
+ if (!gw_exists) {
gw_created = false;
dout(10) << "Warning: GW " << gw_id << " group_key " << group_key
<< " was not found in the map.created_gws "
void do_send_map_ack(MonOpRequestRef op, bool gw_created, bool gw_propose,
uint64_t stored_sequence, bool is_correct_sequence,
const NvmeGroupKey& group_key, const NvmeGwId &gw_id);
+ void check_beacon_timeout(ceph::coarse_mono_clock::time_point now,
+ bool &propose_pending);
++
};
#endif /* MON_NVMEGWMONITOR_H_ */