Skip to content

Commit

Permalink
Change witness schedule, remove randomization. Fix commits. Closes: #6
Browse files Browse the repository at this point in the history
  • Loading branch information
On1x committed Apr 25, 2018
1 parent 0c19619 commit c94146e
Show file tree
Hide file tree
Showing 2 changed files with 32 additions and 30 deletions.
18 changes: 8 additions & 10 deletions libraries/chain/database.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1824,7 +1824,6 @@ void database::process_comment_cashout()
void database::process_funds()
{
const auto& props = get_dynamic_global_properties();
const auto& wso = get_witness_schedule_object();

if( has_hardfork( STEEM_HARDFORK_0_16__551) )
{
Expand All @@ -1842,9 +1841,11 @@ void database::process_funds()
}
}
share_type inflation_per_block = inflation_per_year / int64_t( STEEM_BLOCKS_PER_YEAR );
elog( "Inflation status: props.head_block_number=${h1}, inflation_per_year=${h2}, new_supply=${h3}, inflation_per_block=${h4}",
/*
ilog( "Inflation status: props.head_block_number=${h1}, inflation_per_year=${h2}, new_supply=${h3}, inflation_per_block=${h4}",
("h1",props.head_block_number)("h2", inflation_per_year)("h3",new_supply)("h4",inflation_per_block)
);
*/
auto content_reward = ( inflation_per_block * STEEM_CONTENT_REWARD_PERCENT ) / STEEM_100_PERCENT;
if( has_hardfork( STEEM_HARDFORK_0_17__774 ) )
content_reward = pay_reward_funds( content_reward ); /// 75% to content creator
Expand All @@ -1853,19 +1854,16 @@ void database::process_funds()
auto witness_reward = inflation_per_block - content_reward - vesting_reward - committee_reward; /// Remaining 10% to witness pay

const auto& cwit = get_witness( props.current_witness );
witness_reward *= STEEM_MAX_WITNESSES;

/*
if( cwit.schedule == witness_object::timeshare )
witness_reward *= wso.timeshare_weight;
ilog( "Current witness: ${w}, support", ("w", cwit.owner) );
else if( cwit.schedule == witness_object::miner )
witness_reward *= wso.miner_weight;
ilog( "Current witness: ${w}, miner", ("w", cwit.owner) );
else if( cwit.schedule == witness_object::top )
witness_reward *= wso.top_weight;
ilog( "Current witness: ${w}, top", ("w", cwit.owner) );
else
wlog( "Encountered unknown witness type for witness: ${w}", ("w", cwit.owner) );

witness_reward /= wso.witness_pay_normalization_factor;

*/
inflation_per_block = content_reward + vesting_reward + committee_reward + witness_reward;
/*
elog( "Final inflation_per_block=${h1}, content_reward=${h2}, committee_reward=${h3}, witness_reward=${h4}, vesting_reward=${h5}",
Expand Down
44 changes: 24 additions & 20 deletions libraries/chain/witness_schedule.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,9 @@ void update_witness_schedule4( database& db )
vector< account_name_type > active_witnesses;
active_witnesses.reserve( STEEM_MAX_WITNESSES );

vector< account_name_type > support_witnesses;
support_witnesses.reserve( STEEM_MAX_WITNESSES );

/// Add the highest voted witnesses
flat_set< witness_id_type > selected_voted;
selected_voted.reserve( wso.max_voted_witnesses );
Expand All @@ -103,8 +106,6 @@ void update_witness_schedule4( database& db )
db.modify( *itr, [&]( witness_object& wo ) { wo.schedule = witness_object::top; } );
}

auto num_elected = active_witnesses.size();

/// Add miners from the top of the mining queue
flat_set< witness_id_type > selected_miners;
selected_miners.reserve( wso.max_miner_witnesses );
Expand Down Expand Up @@ -137,8 +138,6 @@ void update_witness_schedule4( database& db )
} );
}

auto num_miners = selected_miners.size();

/// Add the running witnesses in the lead
fc::uint128 new_virtual_time = wso.current_virtual_time;
const auto& schedule_idx = db.get_index<witness_index>().indices().get<by_schedule_time>();
Expand All @@ -157,14 +156,12 @@ void update_witness_schedule4( database& db )
if( selected_miners.find(sitr->id) == selected_miners.end()
&& selected_voted.find(sitr->id) == selected_voted.end() )
{
active_witnesses.push_back(sitr->owner);
support_witnesses.push_back(sitr->owner);
db.modify( *sitr, [&]( witness_object& wo ) { wo.schedule = witness_object::timeshare; } );
++witness_count;
}
}

auto num_timeshare = active_witnesses.size() - num_miners - num_elected;

/// Update virtual schedule of processed witnesses
bool reset_virtual_time = false;
for( auto itr = processed_witnesses.begin(); itr != processed_witnesses.end(); ++itr )
Expand All @@ -189,7 +186,7 @@ void update_witness_schedule4( database& db )
}

size_t expected_active_witnesses = std::min( size_t(STEEM_MAX_WITNESSES), widx.size() );
FC_ASSERT( active_witnesses.size() == expected_active_witnesses, "number of active witnesses does not equal expected_active_witnesses=${expected_active_witnesses}",
FC_ASSERT( ( active_witnesses.size() + support_witnesses.size() ) == expected_active_witnesses, "number of active witnesses does not equal expected_active_witnesses=${expected_active_witnesses}",
("active_witnesses.size()",active_witnesses.size()) ("STEEM_MAX_WITNESSES",STEEM_MAX_WITNESSES) ("expected_active_witnesses", expected_active_witnesses) );

auto majority_version = wso.majority_version;
Expand Down Expand Up @@ -263,26 +260,33 @@ void update_witness_schedule4( database& db )
}
}

assert( num_elected + num_miners + num_timeshare == active_witnesses.size() );

db.modify( wso, [&]( witness_schedule_object& _wso )
{
for( size_t i = 0; i < active_witnesses.size(); i++ )
size_t j = 0;
size_t support_witnesses_count = support_witnesses.size();
size_t active_witnesses_count = active_witnesses.size();
size_t sum_witnesses_count = support_witnesses_count+active_witnesses_count;
for( size_t i = 0; i < sum_witnesses_count; i++ )
{
_wso.current_shuffled_witnesses[i] = active_witnesses[i];
if(active_witnesses_count > 0){
_wso.current_shuffled_witnesses[j] = active_witnesses[i];
--active_witnesses_count;
++j;
}
if(support_witnesses_count > 0){
_wso.current_shuffled_witnesses[j] = support_witnesses[i];
--support_witnesses_count;
++j;
}
}

for( size_t i = active_witnesses.size(); i < STEEM_MAX_WITNESSES; i++ )
for( size_t i = sum_witnesses_count; i < STEEM_MAX_WITNESSES; i++ )
{
_wso.current_shuffled_witnesses[i] = account_name_type();
}

_wso.num_scheduled_witnesses = std::max< uint8_t >( active_witnesses.size(), 1 );
_wso.witness_pay_normalization_factor =
_wso.top_weight * num_elected
+ _wso.miner_weight * num_miners
+ _wso.timeshare_weight * num_timeshare;

_wso.num_scheduled_witnesses = std::max< uint8_t >( sum_witnesses_count , 1 );
/*
/// shuffle current shuffled witnesses
auto now_hi = uint64_t(db.head_block_time().sec_since_epoch()) << 32;
for( uint32_t i = 0; i < _wso.num_scheduled_witnesses; ++i )
Expand All @@ -300,7 +304,7 @@ void update_witness_schedule4( database& db )
std::swap( _wso.current_shuffled_witnesses[i],
_wso.current_shuffled_witnesses[j] );
}

*/
_wso.current_virtual_time = new_virtual_time;
_wso.next_shuffle_block_num = db.head_block_num() + _wso.num_scheduled_witnesses;
_wso.majority_version = majority_version;
Expand Down

0 comments on commit c94146e

Please sign in to comment.