From 3cb93361f24bdf20686f6a72c2c34951bdccfde6 Mon Sep 17 00:00:00 2001 From: Julien Clement Date: Tue, 5 May 2020 23:57:16 +0200 Subject: [PATCH] Add send_voted --- src/legislator/legislator.cc | 11 ++++++++++- src/legislator/legislator.hh | 2 ++ 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/src/legislator/legislator.cc b/src/legislator/legislator.cc index ad38803..eea7767 100644 --- a/src/legislator/legislator.cc +++ b/src/legislator/legislator.cc @@ -182,7 +182,16 @@ namespace paxos vote.decree = decree; ledger.set_prev_vote(vote); - sender = sender; + send_voted(ballot, sender); + } + + void Legislator::send_voted(int ballot, std::string receiver) + { + Message message; + message.set_method("Voted"); + message.add_header("ballot", std::to_string(ballot)); + message.add_header("sender", self->config_.name); + SendEW::send_message(message, legislators[receiver]); } void Legislator::handle_message(Message message) diff --git a/src/legislator/legislator.hh b/src/legislator/legislator.hh index b232352..dc35729 100644 --- a/src/legislator/legislator.hh +++ b/src/legislator/legislator.hh @@ -29,6 +29,8 @@ namespace paxos void receive_begin_ballot(Message message); void receive_begin_ballot(int ballot, int decree, std::string sender); + void send_voted(int ballot, std::string receiver); + void handle_message(Message message); Ledger ledger;