boscore · vlbos · Jun 28, 2019 · Mar 19, 2019 · Mar 20, 2019 · Mar 20, 2019
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -33,9 +33,9 @@ set( CMAKE_CXX_STANDARD 14 )
 set( CMAKE_CXX_EXTENSIONS ON )
 set( CXX_STANDARD_REQUIRED ON)
 
-set(VERSION_MAJOR 2)
+set(VERSION_MAJOR 3)
 set(VERSION_MINOR 0)
-set(VERSION_PATCH 3)
+set(VERSION_PATCH 0)
 
 if(VERSION_SUFFIX)
     set(VERSION_FULL "${VERSION_MAJOR}.${VERSION_MINOR}.${VERSION_PATCH}-${VERSION_SUFFIX}")

diff --git a/Docker/README.md b/Docker/README.md
@@ -20,10 +20,10 @@ cd bos/Docker
 docker build . -t boscore/bos -s BOS
 ```
 
-The above will build off the most recent commit to the master branch by default. If you would like to target a specific branch/tag, you may use a build argument. For example, if you wished to generate a docker image based off of the v2.0.3 tag, you could do the following:
+The above will build off the most recent commit to the master branch by default. If you would like to target a specific branch/tag, you may use a build argument. For example, if you wished to generate a docker image based off of the v3.0.0 tag, you could do the following:
 
 ```bash
-docker build -t boscore/bos:v2.0.3 --build-arg branch=v2.0.3 .
+docker build -t boscore/bos:v3.0.0 --build-arg branch=v3.0.0 .
 
 ```
 

diff --git a/README.md b/README.md
@@ -1,6 +1,6 @@
 # BOSCore - Born for DApps. Born for Usability.
 
-## BOSCore Version: v2.0.3
+## BOSCore Version: v3.0.0
 ### Basic EOSIO Version: v1.6.4 (support REX)
 
 # Background
@@ -39,16 +39,6 @@ Attention:
 3. Treat update of eosio/eos code as new feature.
 4. Emergent issues must repaired by adopting hotfixes mode.
 
-## BOSCore Workflow
-BOSCore encourage community developer actively participate in contributing the code, members should follow the workflow below.
-![BOSCore Workflow](./images/bos-workflow.png)
-
-Attention: 
-1. Only allow Feature Branch or bug fix to submit PR to Develop Branch.
-2. Rebase is required before submitting PR to Develop Branch.
-3. Treat update of eosio/eos code as new feature.
-4. Emergent issues must repaired by adopting hotfixes mode.
-
 BOSCore bases on EOSIO, so you can also referer:
 
 [Getting Started](https://developers.eos.io/eosio-nodeos/docs/overview-1)  

diff --git a/README_CN.md b/README_CN.md
@@ -1,6 +1,6 @@
 # BOSCore - 更可用的链，为DApp而生。
 
-## BOSCore Version: v2.0.3
+## BOSCore Version: v3.0.0
 ### Basic EOSIO Version: v1.6.4 (support REX)
 
 # 背景
@@ -39,16 +39,6 @@ BOSCore 鼓励社区开发者参与代码贡献，社区成员应当遵循以下
 3. EOSIO 主网版本作为一个 Feature Branch 来对待
 4. 紧急问题修复采用 hotfixes 模式 
 
-## BOSCore 开发流程 
-BOSCore 鼓励社区开发者参与代码贡献，社区成员应当遵循以下工作流：
-![BOSCore Workflow](./images/bos-workflow.png)
-
-注意:
-1. 只有待发布的 Feature Branch 或者Bug修复才应该向 Develop Branch 提交
-2. 向 Develop Branch 提交 PR 之前需要现在本地执行 rebase 操作
-3. EOSIO 主网版本作为一个 Feature Branch 来对待
-4. 紧急问题修复采用 hotfixes 模式 
-
 BOSCore是基于EOSIO技术的扩展，所以EOSIO的相关资料也可以参考： 
 
 [EOSIO 开始](https://developers.eos.io/eosio-nodeos/docs/overview-1)  

diff --git a/contracts/eosio.system/delegate_bandwidth.cpp b/contracts/eosio.system/delegate_bandwidth.cpp
@@ -193,7 +193,7 @@ namespace eosiosystem {
 
       auto fee = ( tokens_out.amount + 199 ) / 200; /// .5% fee (round up)
       // since tokens_out.amount was asserted to be at least 2 earlier, fee.amount < tokens_out.amount
-      
+
       if( fee > 0 ) {
          INLINE_ACTION_SENDER(eosio::token, transfer)( N(eosio.token), {account,N(active)},
             { account, N(eosio.ramfee), asset(fee), std::string("sell ram fee") } );

diff --git a/contracts/eosio.system/eosio.system.abi b/contracts/eosio.system/eosio.system.abi
@@ -575,4 +575,4 @@
    ],
    "ricardian_clauses": [],
    "abi_extensions": []
-}
+}
diff --git a/contracts/eosio.system/exchange_state.hpp b/contracts/eosio.system/exchange_state.hpp
@@ -28,7 +28,7 @@ namespace eosiosystem {
 
       uint64_t primary_key()const { return supply.symbol; }
 
-      asset convert_to_exchange( connector& c, asset in ); 
+      asset convert_to_exchange( connector& c, asset in );
       asset convert_from_exchange( connector& c, asset in );
       asset convert( asset from, symbol_type to );
 

diff --git a/contracts/eosiolib/eosiolib.cpp b/contracts/eosiolib/eosiolib.cpp
@@ -55,6 +55,13 @@ namespace eosio {
       ds >> params;
    }
 
+   void set_upgrade_parameters(const eosio::upgrade_parameters& params) {
+      char buf[sizeof(eosio::upgrade_parameters)];
+      eosio::datastream<char *> ds( buf, sizeof(buf) );
+      ds << params;
+      set_upgrade_parameters_packed( buf, ds.tellp() );
+   }
+
    using ::memset;
    using ::memcpy;
 

diff --git a/contracts/eosiolib/privileged.h b/contracts/eosiolib/privileged.h
@@ -92,6 +92,7 @@ extern "C" {
     */
    uint32_t get_blockchain_parameters_packed(char* data, uint32_t datalen);
 
+   void set_upgrade_parameters_packed(char* data, uint32_t datalen);
    /**
     * @brief Activate new feature
     * Activate new feature

diff --git a/contracts/eosiolib/privileged.hpp b/contracts/eosiolib/privileged.hpp
@@ -108,6 +108,14 @@ namespace eosio {
       )
    };
 
+   struct upgrade_parameters {
+      uint32_t target_block_num;
+
+      EOSLIB_SERIALIZE(upgrade_parameters,
+              (target_block_num)
+      )
+   };
+
    /**
     * @brief Set the blockchain parameters
     * Set the blockchain parameters
@@ -122,6 +130,8 @@ namespace eosio {
     */
    void get_blockchain_parameters(eosio::blockchain_parameters& params);
 
+   void set_upgrade_parameters(const eosio::upgrade_parameters& params);
+
    ///@} priviledgedcppapi
 
    /**

diff --git a/libraries/chain/CMakeLists.txt b/libraries/chain/CMakeLists.txt
@@ -14,6 +14,8 @@ add_library( eosio_chain
              block_header_state.cpp
              block_state.cpp
              fork_database.cpp
+             pbft_database.cpp
+             pbft.cpp
              controller.cpp
              authorization_manager.cpp
              resource_limits.cpp

diff --git a/libraries/chain/block_header_state.cpp b/libraries/chain/block_header_state.cpp
@@ -33,7 +33,7 @@ namespace eosio { namespace chain {
    *  contain a transaction mroot, action mroot, or new_producers as those components
    *  are derived from chain state.
    */
-  block_header_state block_header_state::generate_next( block_timestamp_type when )const {
+  block_header_state block_header_state::generate_next( block_timestamp_type when, bool pbft_enabled )const {
     block_header_state result;
 
     if( when != block_timestamp_type() ) {
@@ -62,9 +62,17 @@ namespace eosio { namespace chain {
     result.pending_schedule                      = pending_schedule;
     result.dpos_proposed_irreversible_blocknum   = dpos_proposed_irreversible_blocknum;
     result.bft_irreversible_blocknum             = bft_irreversible_blocknum;
+    result.pbft_stable_checkpoint_blocknum       = pbft_stable_checkpoint_blocknum;
+
+
+    if (pbft_enabled) {
+        result.dpos_irreversible_blocknum = dpos_irreversible_blocknum;
+    } else {
+        result.producer_to_last_implied_irb[prokey.producer_name] = result.dpos_proposed_irreversible_blocknum;
+        result.dpos_irreversible_blocknum = result.calc_dpos_last_irreversible();
+    }
+
 
-    result.producer_to_last_implied_irb[prokey.producer_name] = result.dpos_proposed_irreversible_blocknum;
-    result.dpos_irreversible_blocknum                         = result.calc_dpos_last_irreversible(); 
 
     /// grow the confirmed count
     static_assert(std::numeric_limits<uint8_t>::max() >= (config::max_producers * 2 / 3) + 1, "8bit confirmations may not be able to hold all of the needed confirmations");
@@ -73,23 +81,30 @@ namespace eosio { namespace chain {
     auto num_active_producers = active_schedule.producers.size();
     uint32_t required_confs = (uint32_t)(num_active_producers * 2 / 3) + 1;
 
-    if( confirm_count.size() < config::maximum_tracked_dpos_confirmations ) {
-       result.confirm_count.reserve( confirm_count.size() + 1 );
-       result.confirm_count  = confirm_count;
-       result.confirm_count.resize( confirm_count.size() + 1 );
-       result.confirm_count.back() = (uint8_t)required_confs;
-    } else {
-       result.confirm_count.resize( confirm_count.size() );
-       memcpy( &result.confirm_count[0], &confirm_count[1], confirm_count.size() - 1 );
-       result.confirm_count.back() = (uint8_t)required_confs;
+    if (!pbft_enabled) {
+        if (confirm_count.size() < config::maximum_tracked_dpos_confirmations) {
+            result.confirm_count.reserve(confirm_count.size() + 1);
+            result.confirm_count = confirm_count;
+            result.confirm_count.resize(confirm_count.size() + 1);
+            result.confirm_count.back() = (uint8_t) required_confs;
+        } else {
+            result.confirm_count.resize(confirm_count.size());
+            memcpy(&result.confirm_count[0], &confirm_count[1], confirm_count.size() - 1);
+            result.confirm_count.back() = (uint8_t) required_confs;
+        }
     }
 
     return result;
   } /// generate_next
 
-   bool block_header_state::maybe_promote_pending() {
-      if( pending_schedule.producers.size() &&
-          dpos_irreversible_blocknum >= pending_schedule_lib_num )
+   bool block_header_state::maybe_promote_pending( bool pbft_enabled ) {
+
+      bool should_promote_pending = pending_schedule.producers.size();
+      if ( !pbft_enabled ) {
+          should_promote_pending = should_promote_pending && dpos_irreversible_blocknum >= pending_schedule_lib_num;
+      }
+
+      if (should_promote_pending)
       {
          active_schedule = move( pending_schedule );
 
@@ -99,7 +114,13 @@ namespace eosio { namespace chain {
             if( existing != producer_to_last_produced.end() ) {
                new_producer_to_last_produced[pro.producer_name] = existing->second;
             } else {
-               new_producer_to_last_produced[pro.producer_name] = dpos_irreversible_blocknum;
+               //TODO: max of bft and dpos lib
+               if (pbft_enabled) {
+                   new_producer_to_last_produced[pro.producer_name] = bft_irreversible_blocknum;
+               } else {
+                   new_producer_to_last_produced[pro.producer_name] = dpos_irreversible_blocknum;
+               }
+
             }
          }
 
@@ -109,7 +130,13 @@ namespace eosio { namespace chain {
             if( existing != producer_to_last_implied_irb.end() ) {
                new_producer_to_last_implied_irb[pro.producer_name] = existing->second;
             } else {
-               new_producer_to_last_implied_irb[pro.producer_name] = dpos_irreversible_blocknum;
+               //TODO: max of bft and dpos lib
+               if (pbft_enabled) {
+                   new_producer_to_last_implied_irb[pro.producer_name] = bft_irreversible_blocknum;
+               } else {
+                   new_producer_to_last_implied_irb[pro.producer_name] = dpos_irreversible_blocknum;
+               }
+
             }
          }
 
@@ -141,13 +168,13 @@ namespace eosio { namespace chain {
    *
    *  If the header specifies new_producers then apply them accordingly.
    */
-  block_header_state block_header_state::next( const signed_block_header& h, bool skip_validate_signee )const {
+  block_header_state block_header_state::next( const signed_block_header& h, bool skip_validate_signee, bool pbft_enabled  )const {
     EOS_ASSERT( h.timestamp != block_timestamp_type(), block_validate_exception, "", ("h",h) );
     //EOS_ASSERT( h.header_extensions.size() == 0, block_validate_exception, "no supported extensions" );
 
     EOS_ASSERT( h.timestamp > header.timestamp, block_validate_exception, "block must be later in time" );
     EOS_ASSERT( h.previous == id, unlinkable_block_exception, "block must link to current state" );
-    auto result = generate_next( h.timestamp );
+    auto result = generate_next( h.timestamp, pbft_enabled);
     EOS_ASSERT( result.header.producer == h.producer, wrong_producer, "wrong producer specified" );
     EOS_ASSERT( result.header.schedule_version == h.schedule_version, producer_schedule_exception, "schedule_version in signed block is corrupted" );
 
@@ -161,9 +188,11 @@ namespace eosio { namespace chain {
      /// below this point is state changes that cannot be validated with headers alone, but never-the-less,
      /// must result in header state changes
 
-    result.set_confirmed( h.confirmed );
 
-    auto was_pending_promoted = result.maybe_promote_pending();
+    result.set_confirmed(h.confirmed, pbft_enabled);
+
+
+    auto was_pending_promoted = result.maybe_promote_pending(pbft_enabled);
 
     if( h.new_producers ) {
       EOS_ASSERT( !was_pending_promoted, producer_schedule_exception, "cannot set pending producer schedule in the same block in which pending was promoted to active" );
@@ -185,14 +214,18 @@ namespace eosio { namespace chain {
     return result;
   } /// next
 
-  void block_header_state::set_confirmed( uint16_t num_prev_blocks ) {
+  void block_header_state::set_confirmed( uint16_t num_prev_blocks, bool pbft_enabled ) {
      /*
      idump((num_prev_blocks)(confirm_count.size()));
 
      for( uint32_t i = 0; i < confirm_count.size(); ++i ) {
         std::cerr << "confirm_count["<<i<<"] = " << int(confirm_count[i]) << "\n";
      }
      */
+     if (pbft_enabled) {
+         header.confirmed = 0;
+         return;
+     }
      header.confirmed = num_prev_blocks;
 
      int32_t i = (int32_t)(confirm_count.size() - 1);

diff --git a/libraries/chain/block_state.cpp b/libraries/chain/block_state.cpp
@@ -3,15 +3,15 @@
 
 namespace eosio { namespace chain {
 
-   block_state::block_state( const block_header_state& prev, block_timestamp_type when )
-   :block_header_state( prev.generate_next( when ) ), 
+   block_state::block_state( const block_header_state& prev, block_timestamp_type when, bool pbft_enabled )
+   :block_header_state( prev.generate_next( when, pbft_enabled) ),
     block( std::make_shared<signed_block>()  )
    {
       static_cast<block_header&>(*block) = header;
    }
 
-   block_state::block_state( const block_header_state& prev, signed_block_ptr b, bool skip_validate_signee )
-   :block_header_state( prev.next( *b, skip_validate_signee )), block( move(b) )
+   block_state::block_state( const block_header_state& prev, signed_block_ptr b, bool skip_validate_signee, bool pbft_enabled )
+   :block_header_state( prev.next( *b, skip_validate_signee, pbft_enabled)), block( move(b) )
    { }