Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

3.0.x #9

Merged
merged 53 commits into from
Oct 17, 2019
Merged
Show file tree
Hide file tree
Changes from 12 commits
Commits
Show all changes
53 commits
Select commit Hold shift + click to select a range
1f3eaeb
update cleos to support eosio.msig new actions
maodaishan May 9, 2019
04f7f93
Merge pull request #110 from boscore/release/3.0.x
Thaipanda Jun 29, 2019
c1387e4
Merge pull request #109 from boscore/release/3.0.x
Thaipanda Jun 29, 2019
36006e9
valid new view before emit
Jul 8, 2019
019f595
add necessary validations before trying to relay new view msgs; optim…
VincentOCL Jul 9, 2019
20e08db
optimise transit_to_new_view; optimise handle pbft messages;
Jul 11, 2019
f4c83c2
net_plugin revert.
Jul 12, 2019
8916700
Add: switch fork reserve prepare and fetch branch from function test …
Frank-AFN Jul 15, 2019
0209353
Refactor reserve prepare testcase and Add two times maybe switch fork…
Frank-AFN Jul 16, 2019
fa2072c
Merge pull request #115 from eosiosg/feature/dpos-pbft-bos-upgrade
Thaipanda Jul 16, 2019
f47911c
optimise for return value.
Jul 22, 2019
f975445
add Tips section into Readme
EOSBIXIN Jul 22, 2019
f6aa4e6
Merge branch 'develop' into release/3.0.x
Thaipanda Jul 22, 2019
c94fa01
Merge branch 'master' into release/3.0.x
Thaipanda Jul 22, 2019
e424ec9
Merge pull request #118 from boscore/release/3.0.x
Thaipanda Jul 22, 2019
ca45e59
Merge pull request #119 from boscore/release/3.0.x
Thaipanda Jul 22, 2019
d47f250
reset timer upon state transition; refactor code;
Jul 25, 2019
99d2ed7
add global object to control pbft behavior; optimise checkpoint logic
Jul 30, 2019
239f484
refactor pbft db persistence
Jul 31, 2019
dac6102
fix tests
Aug 1, 2019
82f00a8
reset view change timer when global timeout is changed.
Aug 15, 2019
2840317
reserve prepare only if my_prepare is on forks
Aug 16, 2019
6efb1a9
reserve prepare only if my_prepare is on forks
Aug 16, 2019
6717cf2
Modify reserve prepare test case
Frank-AFN Aug 19, 2019
889161d
Modify reserve prepare test case
Frank-AFN Aug 19, 2019
a4e89a2
dpos pbft optimise (#121)
oldcold Aug 20, 2019
08ec703
update version info
EOSBIXIN Aug 21, 2019
2680d27
fix issues 111
EOSBIXIN Aug 21, 2019
06fa0e9
Merge pull request #93 from maodaishan/feature_msig_oppose_abstain
Thaipanda Aug 21, 2019
fc3ac9b
Merge pull request #122 from boscore/develop
Thaipanda Aug 21, 2019
22bbfa0
adjust the dockerfile
EOSBIXIN Aug 23, 2019
b097d3e
avoid sending last prepare.
Aug 26, 2019
1b15193
Merge branch 'release/3.0.x' into feature/dpos-pbft-bos-optimise
oldcold Aug 28, 2019
79bf108
Merge pull request #123 from eosiosg/feature/dpos-pbft-bos-optimise
Thaipanda Aug 29, 2019
b24a643
Merge pull request #124 from boscore/release/3.0.x
Thaipanda Aug 29, 2019
5e2cecc
fix pbft cert generation and validation
Sep 17, 2019
4304c51
attempt to fix bad prepared cert
Sep 10, 2019
3144c18
fix longest fork threshold
Sep 18, 2019
3971da5
redo cert validation
Sep 18, 2019
2ce70d7
refactor validation, add comments
Sep 18, 2019
b1ea9fd
clean up longest fork validation
Sep 20, 2019
783ceb7
add watermark check
Sep 20, 2019
144b4a9
Fix pbft certifications (#127)
oldcold Sep 22, 2019
9a09576
prepare 3.0.3-rc1
EOSBIXIN Sep 22, 2019
fbee034
further fix on commit certs generation and validation
Sep 23, 2019
f918d83
Merge branch 'release/3.0.x' into fix-cert-gen
oldcold Sep 24, 2019
2e09750
fix finding max committed certs block num
Sep 25, 2019
e73c333
highest committed cert block id should be strictly equal to the one f…
Sep 25, 2019
6c8470d
merge EOSIO ##7979
EOSBIXIN Sep 25, 2019
91ba180
add missing file
Sep 25, 2019
cad626a
Merge pull request #128 from eosiosg/fix-cert-gen
Thaipanda Oct 3, 2019
4dd9005
PBFT validation fixes
EOSBIXIN Oct 3, 2019
f117534
Merge pull request #129 from boscore/release/3.0.x
Thaipanda Oct 4, 2019
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,12 @@ As BOS continues to develop, developer rewards will be appropriately adjusted to
1. Build from code : `bash ./eosio_build.sh -s BOS`
2. Docker Style,check [Docker](./Docker/README.md)

## Tips:
- HTTP&P2P endpoints can be get from the [validator](https://validate.eosnation.io/bos/reports/endpoints.html) by EOS Nation
- BOS Mainnet [genesis.json](https://github.com/boscore/bosres/blob/master/genesis.json)
- BOS Mainnet [Genesis](https://github.com/boscore/bosres/blob/master/BOS_Genesis.md)
- EOS Mainnet [snapshot](https://github.com/boscore/bos-airdrop-snapshots/blob/master/README.md)

## BOSCore Workflow
BOSCore encourage community developer actively participate in contributing the code, members should follow the workflow below.
![BOSCore Workflow](./images/bos-workflow.png)
Expand Down
6 changes: 6 additions & 0 deletions README_CN.md
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,12 @@ BOS链的代码完全由社区贡献并维护,每个生态参与者都可以
1. 源码直接编译: `bash ./eosio_build.sh -s BOS`
2. Docker方式部署,参看 [Docker](./Docker/README.md)

## Tips:
- HTTP&P2P 列表可以从 EOS Nation 提供的[验证页面](https://validate.eosnation.io/bos/reports/endpoints.html)获取
- BOS Mainnet [genesis.json](https://github.com/boscore/bosres/blob/master/genesis.json)
- BOS Mainnet [创世纪](https://github.com/boscore/bosres/blob/master/BOS_Genesis.md)
- EOS Mainnet [账户空投信息](https://github.com/boscore/bos-airdrop-snapshots/blob/master/README.md)

## BOSCore 开发流程
BOSCore 鼓励社区开发者参与代码贡献,社区成员应当遵循以下工作流:
![BOSCore Workflow](./images/bos-workflow.png)
Expand Down
72 changes: 36 additions & 36 deletions libraries/chain/include/eosio/chain/pbft.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -37,18 +37,18 @@ namespace eosio {
return current;
}

void on_prepare(pbft_metadata_ptr<pbft_prepare> e);
void on_commit(pbft_metadata_ptr<pbft_commit> e);
void on_view_change(pbft_metadata_ptr<pbft_view_change> e);
void on_new_view(const pbft_metadata_ptr<pbft_new_view> &e);
void on_prepare(const pbft_metadata_ptr<pbft_prepare>& e);
void on_commit(const pbft_metadata_ptr<pbft_commit>& e);
void on_view_change(const pbft_metadata_ptr<pbft_view_change>& e);
void on_new_view(const pbft_metadata_ptr<pbft_new_view>& e);

void send_prepare();
void send_commit();
void send_view_change();

void transit_to_committed_state(psm_state_ptr s, bool to_new_view);
void transit_to_prepared_state(psm_state_ptr s);
void transit_to_view_change_state(psm_state_ptr s);
void transit_to_committed_state(const psm_state_ptr& s, bool to_new_view);
void transit_to_prepared_state(const psm_state_ptr& s);
void transit_to_view_change_state(const psm_state_ptr& s);
void transit_to_new_view(const pbft_metadata_ptr<pbft_new_view>& e, const psm_state_ptr& s);

void do_send_view_change();
Expand Down Expand Up @@ -106,13 +106,13 @@ namespace eosio {
psm_state();
~psm_state();

virtual void on_prepare(psm_machine_ptr m, pbft_metadata_ptr<pbft_prepare> e, pbft_database &pbft_db) = 0;
virtual void on_commit(psm_machine_ptr m, pbft_metadata_ptr<pbft_commit> e, pbft_database &pbft_db) = 0;
virtual void on_view_change(psm_machine_ptr m, pbft_metadata_ptr<pbft_view_change> e, pbft_database &pbft_db) = 0;
virtual void on_prepare(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_prepare>& e, pbft_database &pbft_db) = 0;
virtual void on_commit(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_commit>& e, pbft_database &pbft_db) = 0;
virtual void on_view_change(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_view_change>& e, pbft_database &pbft_db) = 0;

virtual void send_prepare(psm_machine_ptr m, pbft_database &pbft_db) = 0;
virtual void send_commit(psm_machine_ptr m, pbft_database &pbft_db) = 0;
virtual void send_view_change(psm_machine_ptr m, pbft_database &pbft_db) = 0;
virtual void send_prepare(const psm_machine_ptr& m, pbft_database &pbft_db) = 0;
virtual void send_commit(const psm_machine_ptr& m, pbft_database &pbft_db) = 0;
virtual void send_view_change(const psm_machine_ptr& m, pbft_database &pbft_db) = 0;

virtual const char* get_name() = 0;
std::shared_ptr<psm_state> get_self() { return shared_from_this(); };
Expand All @@ -124,13 +124,13 @@ namespace eosio {
psm_prepared_state();
~psm_prepared_state();

void on_prepare(psm_machine_ptr m, pbft_metadata_ptr<pbft_prepare> e, pbft_database &pbft_db) override;
void on_commit(psm_machine_ptr m, pbft_metadata_ptr<pbft_commit> e, pbft_database &pbft_db) override;
void on_view_change(psm_machine_ptr m, pbft_metadata_ptr<pbft_view_change> e, pbft_database &pbft_db) override;
void on_prepare(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_prepare>& e, pbft_database &pbft_db) override;
void on_commit(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_commit>& e, pbft_database &pbft_db) override;
void on_view_change(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_view_change>& e, pbft_database &pbft_db) override;

void send_prepare(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_commit(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_view_change(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_prepare(const psm_machine_ptr& m, pbft_database &pbft_db) override;
void send_commit(const psm_machine_ptr& m, pbft_database &pbft_db) override;
void send_view_change(const psm_machine_ptr& m, pbft_database &pbft_db) override;

bool pending_commit_local;

Expand All @@ -142,13 +142,13 @@ namespace eosio {
psm_committed_state();
~psm_committed_state();

void on_prepare(psm_machine_ptr m, pbft_metadata_ptr<pbft_prepare> e, pbft_database &pbft_db) override;
void on_commit(psm_machine_ptr m, pbft_metadata_ptr<pbft_commit> e, pbft_database &pbft_db) override;
void on_view_change(psm_machine_ptr m, pbft_metadata_ptr<pbft_view_change> e, pbft_database &pbft_db) override;
void on_prepare(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_prepare>& e, pbft_database &pbft_db) override;
void on_commit(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_commit>& e, pbft_database &pbft_db) override;
void on_view_change(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_view_change>& e, pbft_database &pbft_db) override;

void send_prepare(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_commit(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_view_change(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_prepare(const psm_machine_ptr& m, pbft_database &pbft_db) override;
void send_commit(const psm_machine_ptr& m, pbft_database &pbft_db) override;
void send_view_change(const psm_machine_ptr& m, pbft_database &pbft_db) override;

const char* get_name() override { return "{==== COMMITTED ====}"; }
};
Expand All @@ -158,13 +158,13 @@ namespace eosio {
psm_view_change_state();
~psm_view_change_state();

void on_prepare(psm_machine_ptr m, pbft_metadata_ptr<pbft_prepare> e, pbft_database &pbft_db) override;
void on_commit(psm_machine_ptr m, pbft_metadata_ptr<pbft_commit> e, pbft_database &pbft_db) override;
void on_view_change(psm_machine_ptr m, pbft_metadata_ptr<pbft_view_change> e, pbft_database &pbft_db) override;
void on_prepare(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_prepare>& e, pbft_database &pbft_db) override;
void on_commit(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_commit>& e, pbft_database &pbft_db) override;
void on_view_change(const psm_machine_ptr& m, const pbft_metadata_ptr<pbft_view_change>& e, pbft_database &pbft_db) override;

void send_prepare(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_commit(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_view_change(psm_machine_ptr m, pbft_database &pbft_db) override;
void send_prepare(const psm_machine_ptr& m, pbft_database &pbft_db) override;
void send_commit(const psm_machine_ptr& m, pbft_database &pbft_db) override;
void send_view_change(const psm_machine_ptr& m, pbft_database &pbft_db) override;

const char* get_name() override { return "{==== VIEW CHANGE ====}"; }
};
Expand All @@ -184,11 +184,11 @@ namespace eosio {
void maybe_pbft_view_change();
void maybe_pbft_checkpoint();

void on_pbft_prepare(pbft_metadata_ptr<pbft_prepare> p);
void on_pbft_commit(pbft_metadata_ptr<pbft_commit> c);
void on_pbft_view_change(pbft_metadata_ptr<pbft_view_change> vc);
void on_pbft_new_view(const pbft_metadata_ptr<pbft_new_view> &nv);
void on_pbft_checkpoint(const pbft_metadata_ptr<pbft_checkpoint> &cp);
void on_pbft_prepare(const pbft_metadata_ptr<pbft_prepare>& p);
void on_pbft_commit(const pbft_metadata_ptr<pbft_commit>& c);
void on_pbft_view_change(const pbft_metadata_ptr<pbft_view_change>& vc);
void on_pbft_new_view(const pbft_metadata_ptr<pbft_new_view>& nv);
void on_pbft_checkpoint(const pbft_metadata_ptr<pbft_checkpoint>& cp);

private:
fc::path datadir;
Expand Down
31 changes: 15 additions & 16 deletions libraries/chain/include/eosio/chain/pbft_database.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ namespace eosio {

template<typename pbft_message_body>
struct pbft_message_metadata {
explicit pbft_message_metadata(pbft_message_body m, chain_id_type chain_id): msg{m} {
explicit pbft_message_metadata(pbft_message_body m, chain_id_type& chain_id): msg{m} {
try {
sender_key = crypto::public_key(msg.sender_signature, msg.digest(chain_id), true);
} catch (fc::exception & /*e*/) {
Expand Down Expand Up @@ -110,6 +110,8 @@ namespace eosio {
}
};

using pbft_prepare_ptr = std::shared_ptr<pbft_prepare>;

struct pbft_commit {
explicit pbft_commit() = default;

Expand Down Expand Up @@ -166,6 +168,8 @@ namespace eosio {
}
};

using pbft_checkpoint_ptr = std::shared_ptr<pbft_checkpoint>;

struct pbft_stable_checkpoint {
explicit pbft_stable_checkpoint() = default;

Expand Down Expand Up @@ -252,6 +256,8 @@ namespace eosio {
}
};

using pbft_view_change_ptr = std::shared_ptr<pbft_view_change>;

struct pbft_view_changed_certificate {
explicit pbft_view_changed_certificate() = default;

Expand Down Expand Up @@ -301,6 +307,8 @@ namespace eosio {
}
};

using pbft_new_view_ptr = std::shared_ptr<pbft_new_view>;

struct pbft_state {
block_id_type block_id;
block_num_type block_num = 0;
Expand Down Expand Up @@ -465,7 +473,7 @@ namespace eosio {
bool should_recv_pbft_msg(const public_key_type &pub_key);

bool pending_pbft_lib();
chain_id_type get_chain_id() {return chain_id;}
chain_id_type& get_chain_id() {return chain_id;}
pbft_stable_checkpoint get_stable_checkpoint_by_id(const block_id_type &block_id, bool incl_blk_extn = true);
pbft_stable_checkpoint fetch_stable_checkpoint_from_blk_extn(const signed_block_ptr &b);
block_info_type cal_pending_stable_checkpoint() const;
Expand All @@ -481,20 +489,11 @@ namespace eosio {
flat_map<public_key_type, uint32_t> get_pbft_fork_schedules() const;


signal<void(const pbft_prepare &)> pbft_outgoing_prepare;
signal<void(const pbft_prepare &)> pbft_incoming_prepare;

signal<void(const pbft_commit &)> pbft_outgoing_commit;
signal<void(const pbft_commit &)> pbft_incoming_commit;

signal<void(const pbft_view_change &)> pbft_outgoing_view_change;
signal<void(const pbft_view_change &)> pbft_incoming_view_change;

signal<void(const pbft_new_view &)> pbft_outgoing_new_view;
signal<void(const pbft_new_view &)> pbft_incoming_new_view;

signal<void(const pbft_checkpoint &)> pbft_outgoing_checkpoint;
signal<void(const pbft_checkpoint &)> pbft_incoming_checkpoint;
signal<void(const pbft_prepare_ptr &)> pbft_outgoing_prepare;
signal<void(const pbft_commit_ptr &)> pbft_outgoing_commit;
signal<void(const pbft_view_change_ptr &)> pbft_outgoing_view_change;
signal<void(const pbft_new_view_ptr &)> pbft_outgoing_new_view;
signal<void(const pbft_checkpoint_ptr &)> pbft_outgoing_checkpoint;

private:
controller &ctrl;
Expand Down
Loading