Skip to content

Commit

Permalink
Permit builtin programs to be swapped out at epoch boundaries
Browse files Browse the repository at this point in the history
  • Loading branch information
mvines committed Jun 3, 2020
1 parent 1303c49 commit 4d31bc9
Show file tree
Hide file tree
Showing 2 changed files with 54 additions and 9 deletions.
16 changes: 14 additions & 2 deletions runtime/src/bank.rs
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ use crate::{
accounts_db::{ErrorCounters, SnapshotStorages},
accounts_index::Ancestors,
blockhash_queue::BlockhashQueue,
builtin_programs::get_builtin_programs,
builtin_programs::{get_builtin_programs, get_epoch_activated_builtin_programs},
epoch_stakes::{EpochStakes, NodeVoteAccounts},
message_processor::{MessageProcessor, ProcessInstruction},
nonce_utils,
Expand Down Expand Up @@ -456,6 +456,18 @@ impl Bank {
{
entered_epoch_callback(&mut new)
}

if let Some(builtin_programs) =
get_epoch_activated_builtin_programs(self.operating_mode(), self.epoch)
{
for program in builtin_programs.iter() {
self.add_builtin_program(
&program.name,
program.id,
program.process_instruction,
);
}
}
}

new.update_epoch_stakes(leader_schedule_epoch);
Expand Down Expand Up @@ -2048,7 +2060,7 @@ impl Bank {
}

pub fn finish_init(&mut self) {
let builtin_programs = get_builtin_programs();
let builtin_programs = get_builtin_programs(self.operating_mode(), self.epoch);
for program in builtin_programs.iter() {
self.add_builtin_program(&program.name, program.id, program.process_instruction);
}
Expand Down
47 changes: 40 additions & 7 deletions runtime/src/builtin_programs.rs
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
use crate::{message_processor::ProcessInstruction, system_instruction_processor};
use solana_sdk::{pubkey::Pubkey, system_program};
use solana_sdk::{clock::Epoch, genesis_config::OperatingMode, pubkey::Pubkey, system_program};

pub struct BuiltinProgram {
pub name: String,
Expand All @@ -16,13 +16,30 @@ impl BuiltinProgram {
}
}

pub fn get_builtin_programs() -> Vec<BuiltinProgram> {
fn new_system_program_activation_epoch(operating_mode: OperatingMode) -> Epoch {
match operating_mode {
OperatingMode::Development => 0,
OperatingMode::Preview => std::u64::MAX / 2,
OperatingMode::Stable => std::u64::MAX / 2,
}
}

/// All builtin programs that should be active at the given (operating_mode, epoch)
pub fn get_builtin_programs(operating_mode: OperatingMode, epoch: Epoch) -> Vec<BuiltinProgram> {
vec![
BuiltinProgram::new(
"system_program",
system_program::id(),
system_instruction_processor::process_instruction,
),
if epoch < new_system_program_activation_epoch(operating_mode) {
BuiltinProgram::new(
"system_program",
system_program::id(),
system_instruction_processor::process_instruction, // TODO: This is the OLD system instruction processor
)
} else {
BuiltinProgram::new(
"system_program",
system_program::id(),
system_instruction_processor::process_instruction, // TODO: This should be the NEW system instruction processor
)
},
BuiltinProgram::new(
"config_program",
solana_config_program::id(),
Expand All @@ -40,3 +57,19 @@ pub fn get_builtin_programs() -> Vec<BuiltinProgram> {
),
]
}

/// Builtin programs that activate at the given (operating_mode, epoch)
pub fn get_epoch_activated_builtin_programs(
operating_mode: OperatingMode,
epoch: Epoch,
) -> Option<Vec<BuiltinProgram>> {
if epoch == new_system_program_activation_epoch(operating_mode) {
Some(vec![BuiltinProgram::new(
"system_program",
system_program::id(),
system_instruction_processor::process_instruction, // TODO: This should be the NEW system instruction processor
)])
} else {
None
}
}

0 comments on commit 4d31bc9

Please sign in to comment.