My Groups
<|repo_name|>RobertoPetrignani/colaboration_platform<|file_sep(pDX::Message *message) {
if (message->get_type() == paxos::MessageType::PROMISE) {
// Promise message is received
auto promise = static_cast(message);
// Update current round number for this instance
current_round_[promise->instance_id_] = promise->round_number_;
// Check if there are enough promises
if (!promises_.count(promise->instance_id_) || promises_[promise->instance_id_].size() <= n_) {
promises_[promise->instance_id_].insert(promise->proposer_id_);
}
if (promises_[promise->instance_id_].size() > n_) {
// There are enough promises to choose the value
std::map(message);
accepted_proposals_[accepted->instance_id_].insert(accepted->proposer_id_);
if (accepted_proposals_[accepted->instance_id_].size() > n_) {
// This proposal is accepted by all instances
// TODO apply the chosen value here
// Reset data for this instance
accepted_proposals_.erase(accepted->instance_id_);
}
}
else if (message->get_type() == paxos::MessageType::PROPOSE) {
auto propose = static_cast(message);
auto it = proposals_.find(propose->instance_id_);
if (it == proposals_.end()) {
proposals_[propose->instance_id_] = std::make_pair(propose->round_number_, propose->value_);
promises_[propose->instance_id_] = std::set();
accepted_proposals_[propose->instance_id_] = std::set();
// Send promise message back to proposer
auto promise = new paxos::PromiseMessage(id_, propose->instance_id_,
propose->round_number_, propose->round_number_);
paxos_.send_message(promise);
}
else {
if (it->second.first >= propose->round_number_) {
// Already have a better or equal proposal for this instance
// Send promise message back to proposer
auto promise = new paxos::PromiseMessage(id_, propose->instance_id_,
propose->round_number_, it->second.first);
paxos_.send_message(promise);
}
else {
it->second.first = propose->round_number_;
it->second.second = propose->value_;
// Send promise message back to proposer
auto promise = new paxos::PromiseMessage(id_, propose->instance_id_,
propose->round_number_, propose->round_number_);
paxos_.send_message(promise);
}
}
}
}
<|repo_name|>RobertoPetrignani/colaboration_platform<|file_sep>#include "utils.h"
#include "common.pb.h"
#include "event_loop.h"
#include "logging.h"
#include "node.h"
#include "network.h"
#include "paxos.h"
#include "gtest/gtest.h