#include <controller.hpp>

Collaboration diagram for sysio::chain::controller:

[legend]

Classes
struct	config

Public Types
enum class	block_status { irreversible = 0 , validated = 1 , complete = 2 , incomplete = 3 }

Public Member Functions
	controller (const config &cfg, const chain_id_type &chain_id)

	controller (const config &cfg, protocol_feature_set &&pfs, const chain_id_type &chain_id)

	~controller ()

void	add_indices ()

void	startup (std::function< void()> shutdown, std::function< bool()> check_shutdown, const snapshot_reader_ptr &snapshot)

void	startup (std::function< void()> shutdown, std::function< bool()> check_shutdown, const genesis_state &genesis)

void	startup (std::function< void()> shutdown, std::function< bool()> check_shutdown)

void	preactivate_feature (const digest_type &feature_digest)

vector< digest_type >	get_preactivated_protocol_features () const

void	validate_protocol_features (const vector< digest_type > &features_to_activate) const

void	start_block (block_timestamp_type time=block_timestamp_type(), uint16_t confirm_block_count=0)

void	start_block (block_timestamp_type time, uint16_t confirm_block_count, const vector< digest_type > &new_protocol_feature_activations, const fc::time_point &deadline=fc::time_point::maximum())

vector< transaction_metadata_ptr >	abort_block ()

transaction_trace_ptr	push_transaction (const transaction_metadata_ptr &trx, fc::time_point deadline, fc::microseconds max_transaction_time, uint32_t billed_cpu_time_us, bool explicit_billed_cpu_time, int64_t subjective_cpu_bill_us)

transaction_trace_ptr	push_scheduled_transaction (const transaction_id_type &scheduled, fc::time_point block_deadline, fc::microseconds max_transaction_time, uint32_t billed_cpu_time_us, bool explicit_billed_cpu_time)

block_state_ptr	finalize_block (const signer_callback_type &signer_callback)

void	sign_block (const signer_callback_type &signer_callback)

void	commit_block ()

std::future< block_state_ptr >	create_block_state_future (const block_id_type &id, const signed_block_ptr &b)

block_state_ptr	create_block_state (const block_id_type &id, const signed_block_ptr &b) const

void	push_block (const block_state_ptr &bsp, const forked_branch_callback &cb, const trx_meta_cache_lookup &trx_lookup)

boost::asio::io_context &	get_thread_pool ()

const chainbase::database &	db () const

const fork_database &	fork_db () const

const account_object &	get_account (account_name n) const

const global_property_object &	get_global_properties () const

const dynamic_global_property_object &	get_dynamic_global_properties () const

const resource_limits_manager &	get_resource_limits_manager () const
	controller_impl

resource_limits_manager &	get_mutable_resource_limits_manager ()

const authorization_manager &	get_authorization_manager () const

authorization_manager &	get_mutable_authorization_manager ()

const protocol_feature_manager &	get_protocol_feature_manager () const

uint32_t	get_max_nonprivileged_inline_action_size () const

const flat_set< account_name > &	get_actor_whitelist () const

const flat_set< account_name > &	get_actor_blacklist () const

const flat_set< account_name > &	get_contract_whitelist () const

const flat_set< account_name > &	get_contract_blacklist () const

const flat_set< pair< account_name, action_name > > &	get_action_blacklist () const

const flat_set< public_key_type > &	get_key_blacklist () const

void	set_actor_whitelist (const flat_set< account_name > &)

void	set_actor_blacklist (const flat_set< account_name > &)

void	set_contract_whitelist (const flat_set< account_name > &)

void	set_contract_blacklist (const flat_set< account_name > &)

void	set_action_blacklist (const flat_set< pair< account_name, action_name > > &)

void	set_key_blacklist (const flat_set< public_key_type > &)

void	set_s_header (const s_header &)

uint32_t	head_block_num () const

time_point	head_block_time () const

block_id_type	head_block_id () const

account_name	head_block_producer () const

const block_header &	head_block_header () const

block_state_ptr	head_block_state () const

uint32_t	fork_db_head_block_num () const

block_id_type	fork_db_head_block_id () const

time_point	fork_db_head_block_time () const

account_name	fork_db_head_block_producer () const

uint32_t	fork_db_pending_head_block_num () const

block_id_type	fork_db_pending_head_block_id () const

time_point	fork_db_pending_head_block_time () const

account_name	fork_db_pending_head_block_producer () const

time_point	pending_block_time () const

account_name	pending_block_producer () const

const block_signing_authority &	pending_block_signing_authority () const

std::optional< block_id_type >	pending_producer_block_id () const

uint32_t	pending_block_num () const

const vector< transaction_receipt > &	get_pending_trx_receipts () const

const producer_authority_schedule &	active_producers () const

const producer_authority_schedule &	pending_producers () const

std::optional< producer_authority_schedule >	proposed_producers () const

uint32_t	last_irreversible_block_num () const

block_id_type	last_irreversible_block_id () const

time_point	last_irreversible_block_time () const

signed_block_ptr	fetch_block_by_number (uint32_t block_num) const

signed_block_ptr	fetch_block_by_id (block_id_type id) const

block_state_ptr	fetch_block_state_by_number (uint32_t block_num) const

block_state_ptr	fetch_block_state_by_id (block_id_type id) const

block_id_type	get_block_id_for_num (uint32_t block_num) const

sha256	calculate_integrity_hash ()

void	write_snapshot (const snapshot_writer_ptr &snapshot)

bool	sender_avoids_whitelist_blacklist_enforcement (account_name sender) const

void	check_actor_list (const flat_set< account_name > &actors) const

void	check_contract_list (account_name code) const

void	check_action_list (account_name code, action_name action) const

void	check_key_list (const public_key_type &key) const

bool	is_building_block () const

bool	is_producing_block () const

bool	is_ram_billing_in_notify_allowed () const

uint32_t	configured_subjective_signature_length_limit () const

void	add_resource_greylist (const account_name &name)

void	remove_resource_greylist (const account_name &name)

bool	is_resource_greylisted (const account_name &name) const

const flat_set< account_name > &	get_resource_greylist () const

void	validate_expiration (const transaction &t) const

void	validate_tapos (const transaction &t) const

void	validate_db_available_size () const

bool	is_protocol_feature_activated (const digest_type &feature_digest) const

bool	is_builtin_activated (builtin_protocol_feature_t f) const

bool	is_known_unexpired_transaction (const transaction_id_type &id) const

int64_t	set_proposed_producers (vector< producer_authority > producers)

bool	light_validation_allowed () const

bool	skip_auth_check () const

bool	skip_trx_checks () const

bool	skip_db_sessions () const

bool	skip_db_sessions (block_status bs) const

bool	is_trusted_producer (const account_name &producer) const

bool	contracts_console () const

bool	is_profiling (account_name name) const

chain_id_type	get_chain_id () const

db_read_mode	get_read_mode () const

validation_mode	get_validation_mode () const

uint32_t	get_terminate_at_block () const

void	set_subjective_cpu_leeway (fc::microseconds leeway)

std::optional< fc::microseconds >	get_subjective_cpu_leeway () const

void	set_greylist_limit (uint32_t limit)

uint32_t	get_greylist_limit () const

void	add_to_ram_correction (account_name account, uint64_t ram_bytes)

bool	all_subjective_mitigations_disabled () const

deep_mind_handler *	get_deep_mind_logger () const

void	enable_deep_mind (deep_mind_handler *logger)

uint32_t	earliest_available_block_num () const

const apply_handler *	find_apply_handler (account_name contract, scope_name scope, action_name act) const

wasm_interface &	get_wasm_interface ()

std::optional< abi_serializer >	get_abi_serializer (account_name n, const abi_serializer::yield_function_t &yield) const

template<typename T >
fc::variant	to_variant_with_abi (const T &obj, const abi_serializer::yield_function_t &yield) const

void	replace_producer_keys (const public_key_type &key)

void	replace_account_keys (name account, name permission, const public_key_type &key)

Static Public Member Functions
static std::optional< uint64_t >	convert_exception_to_error_code (const fc::exception &e)

static chain_id_type	extract_chain_id (snapshot_reader &snapshot)

static std::optional< chain_id_type >	extract_chain_id_from_db (const path &state_dir)

Public Attributes
signal< void(uint32_t)>	block_start

signal< void(const signed_block_ptr &)>	pre_accepted_block

signal< void(const block_state_ptr &)>	accepted_block_header

signal< void(const block_state_ptr &)>	accepted_block

signal< void(const block_state_ptr &)>	irreversible_block

signal< void(const transaction_metadata_ptr &)>	accepted_transaction

signal< void(std::tuple< const transaction_trace_ptr &, const packed_transaction_ptr & >)>	applied_transaction

signal< void(const int &)>	bad_alloc

Friends
class	apply_context

class	transaction_context

Detailed Description

Definition at line 63 of file controller.hpp.

Member Enumeration Documentation

◆ block_status

enum class sysio::chain::controller::block_status

strong

Enumerator
irreversible	this block has already been applied before by this node and is considered irreversible
validated	this is a complete block signed by a valid producer and has been previously applied by this node and therefore validated but it is not yet irreversible
complete	this is a complete block signed by a valid producer but is not yet irreversible nor has it yet been applied by this node
incomplete	this is an incomplete block (either being produced by a producer or speculatively produced by a node)

Definition at line 106 of file controller.hpp.

                                 {
            irreversible = 0, 
            validated   = 1, 
            complete   = 2, 
            incomplete  = 3, 
         };

Constructor & Destructor Documentation

◆ controller() [1/2]

sysio::chain::controller::controller	(	const config &	cfg,
		const chain_id_type &	chain_id )

Definition at line 2610 of file controller.cpp.

:my( new controller_impl( cfg, *this, protocol_feature_set{}, chain_id ) )
{
}

◆ controller() [2/2]

sysio::chain::controller::controller	(	const config &	cfg,
		protocol_feature_set &&	pfs,
		const chain_id_type &	chain_id )

Definition at line 2615 of file controller.cpp.

:my( new controller_impl( cfg, *this, std::move(pfs), chain_id ) )
{
}

◆ ~controller()

sysio::chain::controller::~controller ( )

Definition at line 2620 of file controller.cpp.

                        {
   my->abort_block();
   /* Shouldn't be needed anymore.
   //close fork_db here, because it can generate "irreversible" signal to this controller,
   //in case if read-mode == IRREVERSIBLE, we will apply latest irreversible block
   //for that we need 'my' to be valid pointer pointing to valid controller_impl.
   my->fork_db.close();
   */
}

Member Function Documentation

◆ abort_block()

vector< transaction_metadata_ptr > sysio::chain::controller::abort_block ( )

Returns: transactions applied in aborted block

Definition at line 2847 of file controller.cpp.

                                                         {
   return my->abort_block();
}

Here is the caller graph for this function:

◆ active_producers()

const producer_authority_schedule & sysio::chain::controller::active_producers ( ) const

Definition at line 3179 of file controller.cpp.

                                                                        {
   if( !(my->pending) )
      return  my->head->active_schedule;
 
   if( std::holds_alternative<completed_block>(my->pending->_block_stage) )
      return std::get<completed_block>(my->pending->_block_stage)._block_state->active_schedule;
 
   return my->pending->get_pending_block_header_state().active_schedule;
}

Here is the caller graph for this function:

◆ add_indices()

void sysio::chain::controller::add_indices ( )

Definition at line 2630 of file controller.cpp.

                             {
   my->add_indices();
}

◆ add_resource_greylist()

void sysio::chain::controller::add_resource_greylist ( const account_name & name )

Definition at line 3421 of file controller.cpp.

                                                               {
   my->conf.resource_greylist.insert(name);
}

Here is the caller graph for this function:

◆ add_to_ram_correction()

void sysio::chain::controller::add_to_ram_correction	(	account_name	account,
		uint64_t	ram_bytes )

Definition at line 3438 of file controller.cpp.

                                                                                 {
   auto ptr = my->db.find<account_ram_correction_object, by_name>( account );
   if( ptr ) {
      my->db.modify<account_ram_correction_object>( *ptr, [&]( auto& rco ) {
         rco.ram_correction += ram_bytes;
      } );
   } else {
      ptr = &my->db.create<account_ram_correction_object>( [&]( auto& rco ) {
         rco.name = account;
         rco.ram_correction = ram_bytes;
      } );
   }
 
   if (auto dm_logger = get_deep_mind_logger()) {
      dm_logger->on_add_ram_correction(*ptr, ram_bytes);
   }
}

Here is the call graph for this function:

◆ all_subjective_mitigations_disabled()

bool sysio::chain::controller::all_subjective_mitigations_disabled ( ) const

Definition at line 3456 of file controller.cpp.

                                                          {
   return my->conf.disable_all_subjective_mitigations;
}

◆ calculate_integrity_hash()

sha256 sysio::chain::controller::calculate_integrity_hash ( )

Definition at line 3119 of file controller.cpp.

                                            { try {
   return my->calculate_integrity_hash();
} FC_LOG_AND_RETHROW() }

Here is the caller graph for this function:

◆ check_action_list()

void sysio::chain::controller::check_action_list	(	account_name	code,
		action_name	action ) const

Definition at line 3320 of file controller.cpp.

                                                                               {
   my->check_action_list( code, action );
}

Here is the caller graph for this function:

◆ check_actor_list()

void sysio::chain::controller::check_actor_list ( const flat_set< account_name > & actors ) const

Definition at line 3312 of file controller.cpp.

                                                                             {
   my->check_actor_list( actors );
}

Here is the caller graph for this function:

◆ check_contract_list()

void sysio::chain::controller::check_contract_list ( account_name code ) const

Definition at line 3316 of file controller.cpp.

                                                             {
   my->check_contract_list( code );
}

Here is the caller graph for this function:

◆ check_key_list()

void sysio::chain::controller::check_key_list ( const public_key_type & key ) const

Definition at line 3324 of file controller.cpp.

                                                                 {
   my->check_key_list( key );
}

◆ commit_block()

void sysio::chain::controller::commit_block ( )

Definition at line 2842 of file controller.cpp.

                              {
   validate_db_available_size();
   my->commit_block(true);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ configured_subjective_signature_length_limit()

uint32_t sysio::chain::controller::configured_subjective_signature_length_limit ( ) const

Definition at line 3342 of file controller.cpp.

                                                                       {
   return my->conf.maximum_variable_signature_length;
}

Here is the caller graph for this function:

◆ contracts_console()

bool sysio::chain::controller::contracts_console ( ) const

Definition at line 3265 of file controller.cpp.

                                        {
   return my->conf.contracts_console;
}

Here is the caller graph for this function:

◆ convert_exception_to_error_code()

std::optional< uint64_t > sysio::chain::controller::convert_exception_to_error_code ( const fc::exception & e )

static

Definition at line 3478 of file controller.cpp.

                                                                                        {
   const chain_exception* e_ptr = dynamic_cast<const chain_exception*>( &e );
 
   if( e_ptr == nullptr ) return {};
 
   if( !e_ptr->error_code ) return static_cast<uint64_t>(system_error_code::generic_system_error);
 
   return e_ptr->error_code;
}

Here is the caller graph for this function:

◆ create_block_state()

block_state_ptr sysio::chain::controller::create_block_state	(	const block_id_type &	id,
		const signed_block_ptr &	b ) const

Definition at line 2859 of file controller.cpp.

                                                                                                         {
   return my->create_block_state( id, b );
}

Here is the caller graph for this function:

◆ create_block_state_future()

std::future< block_state_ptr > sysio::chain::controller::create_block_state_future	(	const block_id_type &	id,
		const signed_block_ptr &	b )

Definition at line 2855 of file controller.cpp.

                                                                                                                     {
   return my->create_block_state_future( id, b );
}

◆ db()

const chainbase::database & sysio::chain::controller::db ( ) const

Definition at line 2646 of file controller.cpp.

2646{ return my->db; }

Here is the caller graph for this function:

◆ earliest_available_block_num()

uint32_t sysio::chain::controller::earliest_available_block_num ( ) const

Definition at line 3469 of file controller.cpp.

                                                       {
   return my->earliest_available_block_num();
}

◆ enable_deep_mind()

void sysio::chain::controller::enable_deep_mind ( deep_mind_handler * logger )

Definition at line 3464 of file controller.cpp.

                                                           {
   SYS_ASSERT( logger != nullptr, misc_exception, "Invalid logger passed into enable_deep_mind, must be set" );
   my->deep_mind_logger = logger;
}

◆ extract_chain_id()

chain_id_type sysio::chain::controller::extract_chain_id ( snapshot_reader & snapshot )

static

Definition at line 3488 of file controller.cpp.

                                                                    {
   chain_snapshot_header header;
   snapshot.read_section<chain_snapshot_header>([&header]( auto &section ){
      section.read_row(header);
      header.validate();
   });
 
   // check if this is a legacy version of the snapshot, which has a genesis state instead of chain id
   std::optional<genesis_state> genesis = controller_impl::extract_legacy_genesis_state(snapshot, header.version);
   if (genesis) {
      return genesis->compute_chain_id();
   }
 
   chain_id_type chain_id;
 
   using v4 = legacy::snapshot_global_property_object_v4;
   if (header.version <= v4::maximum_version) {
      snapshot.read_section<global_property_object>([&chain_id]( auto &section ){
         v4 global_properties;
         section.read_row(global_properties);
         chain_id = global_properties.chain_id;
      });
   }
   else {
      snapshot.read_section<global_property_object>([&chain_id]( auto &section ){
         snapshot_global_property_object global_properties;
         section.read_row(global_properties);
         chain_id = global_properties.chain_id;
      });
   }
 
   return chain_id;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ extract_chain_id_from_db()

std::optional< chain_id_type > sysio::chain::controller::extract_chain_id_from_db ( const path & state_dir )

static

Definition at line 3522 of file controller.cpp.

                                                                                       {
   try {
      chainbase::database db( state_dir, chainbase::database::read_only );
 
      db.add_index<database_header_multi_index>();
      db.add_index<global_property_multi_index>();
 
      controller_impl::validate_db_version( db );
 
      if( db.revision() < 1 ) return {};
 
      return db.get<global_property_object>().chain_id;
   } catch( const bad_database_version_exception& ) {
      throw;
   } catch( ... ) {
   }
 
   return {};
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fetch_block_by_id()

signed_block_ptr sysio::chain::controller::fetch_block_by_id ( block_id_type id ) const

Definition at line 3066 of file controller.cpp.

                                                                      {
   auto state = my->fork_db.get_block(id);
   if( state && state->block ) return state->block;
   auto bptr = my->blog.read_block_by_num( block_header::num_from_id(id) );
   if( bptr && bptr->calculate_id() == id ) return bptr;
   return signed_block_ptr();
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fetch_block_by_number()

signed_block_ptr sysio::chain::controller::fetch_block_by_number ( uint32_t block_num ) const

Definition at line 3074 of file controller.cpp.

                                                                             { try {
   auto blk_state = fetch_block_state_by_number( block_num );
   if( blk_state ) {
      return blk_state->block;
   }
 
   return my->blog.read_block_by_num(block_num);
} FC_CAPTURE_AND_RETHROW( (block_num) ) }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ fetch_block_state_by_id()

block_state_ptr sysio::chain::controller::fetch_block_state_by_id ( block_id_type id ) const

Definition at line 3083 of file controller.cpp.

                                                                           {
   auto state = my->fork_db.get_block(id);
   return state;
}

Here is the caller graph for this function:

◆ fetch_block_state_by_number()

block_state_ptr sysio::chain::controller::fetch_block_state_by_number ( uint32_t block_num ) const

Definition at line 3088 of file controller.cpp.

                                                                                  { try {
   if( my->read_mode == db_read_mode::IRREVERSIBLE ) {
      return my->fork_db.search_on_branch( my->fork_db.pending_head()->id, block_num );
   } else {
      return my->fork_db.search_on_branch( my->fork_db.head()->id, block_num );
   }
} FC_CAPTURE_AND_RETHROW( (block_num) ) }

Here is the caller graph for this function:

◆ finalize_block()

block_state_ptr sysio::chain::controller::finalize_block ( const signer_callback_type & signer_callback )

Definition at line 2818 of file controller.cpp.

                                                                                        {
   validate_db_available_size();
 
   my->finalize_block();
 
   auto& ab = std::get<assembled_block>(my->pending->_block_stage);
 
   auto bsp = std::make_shared<block_state>(
                  std::move( ab._pending_block_header_state ),
                  std::move( ab._unsigned_block ),
                  std::move( ab._trx_metas ),
                  my->protocol_features.get_protocol_feature_set(),
                  []( block_timestamp_type timestamp,
                      const flat_set<digest_type>& cur_features,
                      const vector<digest_type>& new_features )
                  {},
                  signer_callback
              );
 
   my->pending->_block_stage = completed_block{ bsp };
 
   return bsp;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ find_apply_handler()

const apply_handler * sysio::chain::controller::find_apply_handler	(	account_name	contract,
		scope_name	scope,
		action_name	act ) const

Definition at line 3289 of file controller.cpp.

{
   auto native_handler_scope = my->apply_handlers.find( receiver );
   if( native_handler_scope != my->apply_handlers.end() ) {
      auto handler = native_handler_scope->second.find( make_pair( scope, act ) );
      if( handler != native_handler_scope->second.end() )
         return &handler->second;
   }
   return nullptr;
}

Here is the caller graph for this function:

◆ fork_db()

const fork_database & sysio::chain::controller::fork_db ( ) const

Definition at line 2650 of file controller.cpp.

2650{ return my->fork_db; }

◆ fork_db_head_block_id()

block_id_type sysio::chain::controller::fork_db_head_block_id ( ) const

Definition at line 2972 of file controller.cpp.

                                                     {
   return my->fork_db.head()->id;
}

◆ fork_db_head_block_num()

uint32_t sysio::chain::controller::fork_db_head_block_num ( ) const

Definition at line 2968 of file controller.cpp.

                                                 {
   return my->fork_db.head()->block_num;
}

◆ fork_db_head_block_producer()

account_name sysio::chain::controller::fork_db_head_block_producer ( ) const

Definition at line 2980 of file controller.cpp.

                                                           {
   return my->fork_db.head()->header.producer;
}

◆ fork_db_head_block_time()

time_point sysio::chain::controller::fork_db_head_block_time ( ) const

Definition at line 2976 of file controller.cpp.

                                                    {
   return my->fork_db.head()->header.timestamp;
}

◆ fork_db_pending_head_block_id()

block_id_type sysio::chain::controller::fork_db_pending_head_block_id ( ) const

Definition at line 2988 of file controller.cpp.

                                                             {
   return my->fork_db.pending_head()->id;
}

Here is the caller graph for this function:

◆ fork_db_pending_head_block_num()

uint32_t sysio::chain::controller::fork_db_pending_head_block_num ( ) const

Definition at line 2984 of file controller.cpp.

                                                         {
   return my->fork_db.pending_head()->block_num;
}

Here is the caller graph for this function:

◆ fork_db_pending_head_block_producer()

account_name sysio::chain::controller::fork_db_pending_head_block_producer ( ) const

Definition at line 2996 of file controller.cpp.

                                                                   {
   return my->fork_db.pending_head()->header.producer;
}

◆ fork_db_pending_head_block_time()

time_point sysio::chain::controller::fork_db_pending_head_block_time ( ) const

Definition at line 2992 of file controller.cpp.

                                                            {
   return my->fork_db.pending_head()->header.timestamp;
}

◆ get_abi_serializer()

std::optional< abi_serializer > sysio::chain::controller::get_abi_serializer	(	account_name	n,
		const abi_serializer::yield_function_t &	yield ) const

inline

Definition at line 349 of file controller.hpp.

                                                                                                                            {
            if( n.good() ) {
               try {
                  const auto& a = get_account( n );
                  abi_def abi;
                  if( abi_serializer::to_abi( a.abi, abi ))
                     return abi_serializer( abi, yield );
               } FC_CAPTURE_AND_LOG((n))
            }
            return std::optional<abi_serializer>();
         }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_account()

const account_object & sysio::chain::controller::get_account ( account_name n ) const

Definition at line 3303 of file controller.cpp.

{ try {
   return my->db.get<account_object, by_name>(name);
} FC_CAPTURE_AND_RETHROW( (name) ) }

Here is the caller graph for this function:

◆ get_action_blacklist()

const flat_set< pair< account_name, action_name > > & sysio::chain::controller::get_action_blacklist ( ) const

Definition at line 2902 of file controller.cpp.

                                                                                          {
   return my->conf.action_blacklist;
}

Here is the caller graph for this function:

◆ get_actor_blacklist()

const flat_set< account_name > & sysio::chain::controller::get_actor_blacklist ( ) const

Definition at line 2893 of file controller.cpp.

                                                                    {
   return my->conf.actor_blacklist;
}

Here is the caller graph for this function:

◆ get_actor_whitelist()

const flat_set< account_name > & sysio::chain::controller::get_actor_whitelist ( ) const

Definition at line 2890 of file controller.cpp.

                                                                    {
   return my->conf.actor_whitelist;
}

Here is the caller graph for this function:

◆ get_authorization_manager()

const authorization_manager & sysio::chain::controller::get_authorization_manager ( ) const

Definition at line 2591 of file controller.cpp.

{
   return my->authorization;
}

Here is the caller graph for this function:

◆ get_block_id_for_num()

block_id_type sysio::chain::controller::get_block_id_for_num ( uint32_t block_num ) const

Definition at line 3096 of file controller.cpp.

                                                                        { try {
   const auto& tapos_block_summary = db().get<block_summary_object>((uint16_t)block_num);
 
   if( block_header::num_from_id(tapos_block_summary.block_id) == block_num )
      return tapos_block_summary.block_id;
 
   const auto& blog_head = my->blog.head();
 
   bool find_in_blog = (blog_head && block_num <= blog_head->block_num());
 
   if( !find_in_blog ) {
      auto bsp = fetch_block_state_by_number( block_num );
      if( bsp ) return bsp->id;
   }
 
   auto id = my->blog.read_block_id_by_num(block_num);
 
   SYS_ASSERT( BOOST_LIKELY( id != block_id_type() ), unknown_block_exception,
               "Could not find block: ${block}", ("block", block_num) );
 
   return id;
} FC_CAPTURE_AND_RETHROW( (block_num) ) }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ get_chain_id()

chain_id_type sysio::chain::controller::get_chain_id ( ) const

Definition at line 3273 of file controller.cpp.

                                            {
   return my->chain_id;
}

Here is the caller graph for this function:

◆ get_contract_blacklist()

const flat_set< account_name > & sysio::chain::controller::get_contract_blacklist ( ) const

Definition at line 2899 of file controller.cpp.

                                                                       {
   return my->conf.contract_blacklist;
}

Here is the caller graph for this function:

◆ get_contract_whitelist()

const flat_set< account_name > & sysio::chain::controller::get_contract_whitelist ( ) const

Definition at line 2896 of file controller.cpp.

                                                                       {
   return my->conf.contract_whitelist;
}

Here is the caller graph for this function:

◆ get_deep_mind_logger()

deep_mind_handler * sysio::chain::controller::get_deep_mind_logger ( ) const

Definition at line 3460 of file controller.cpp.

                                                         {
   return my->get_deep_mind_logger();
}

Here is the caller graph for this function:

◆ get_dynamic_global_properties()

const dynamic_global_property_object & sysio::chain::controller::get_dynamic_global_properties ( ) const

Definition at line 3059 of file controller.cpp.

                                                                                     {
  return my->db.get<dynamic_global_property_object>();
}

Here is the caller graph for this function:

◆ get_global_properties()

const global_property_object & sysio::chain::controller::get_global_properties ( ) const

Definition at line 3062 of file controller.cpp.

                                                                     {
  return my->db.get<global_property_object>();
}

Here is the caller graph for this function:

◆ get_greylist_limit()

uint32_t sysio::chain::controller::get_greylist_limit ( ) const

Definition at line 3417 of file controller.cpp.

                                             {
   return my->conf.greylist_limit;
}

Here is the caller graph for this function:

◆ get_key_blacklist()

const flat_set< public_key_type > & sysio::chain::controller::get_key_blacklist ( ) const

Definition at line 2905 of file controller.cpp.

                                                                     {
   return my->conf.key_blacklist;
}

Here is the caller graph for this function:

◆ get_max_nonprivileged_inline_action_size()

uint32_t sysio::chain::controller::get_max_nonprivileged_inline_action_size ( ) const

Definition at line 2605 of file controller.cpp.

{
   return my->conf.max_nonprivileged_inline_action_size;
}

Here is the caller graph for this function:

◆ get_mutable_authorization_manager()

authorization_manager & sysio::chain::controller::get_mutable_authorization_manager ( )

Definition at line 2595 of file controller.cpp.

{
   return my->authorization;
}

Here is the caller graph for this function:

◆ get_mutable_resource_limits_manager()

resource_limits_manager & sysio::chain::controller::get_mutable_resource_limits_manager ( )

Definition at line 2586 of file controller.cpp.

{
   return my->resource_limits;
}

Here is the caller graph for this function:

◆ get_pending_trx_receipts()

const vector< transaction_receipt > & sysio::chain::controller::get_pending_trx_receipts ( ) const

Definition at line 3041 of file controller.cpp.

                                                                             {
   SYS_ASSERT( my->pending, block_validate_exception, "no pending block" );
   return my->pending->get_trx_receipts();
}

Here is the caller graph for this function:

◆ get_preactivated_protocol_features()

vector< digest_type > sysio::chain::controller::get_preactivated_protocol_features ( ) const

Definition at line 2760 of file controller.cpp.

                                                                        {
   const auto& pso = my->db.get<protocol_state_object>();
 
   if( pso.preactivated_protocol_features.size() == 0 ) return {};
 
   vector<digest_type> preactivated_protocol_features;
 
   for( const auto& f : pso.preactivated_protocol_features ) {
      preactivated_protocol_features.emplace_back( f );
   }
 
   return preactivated_protocol_features;
}

Here is the caller graph for this function:

◆ get_protocol_feature_manager()

const protocol_feature_manager & sysio::chain::controller::get_protocol_feature_manager ( ) const

Definition at line 2600 of file controller.cpp.

{
   return my->protocol_features;
}

Here is the caller graph for this function:

◆ get_read_mode()

db_read_mode sysio::chain::controller::get_read_mode ( ) const

Definition at line 3277 of file controller.cpp.

                                            {
   return my->read_mode;
}

Here is the caller graph for this function:

◆ get_resource_greylist()

const flat_set< account_name > & sysio::chain::controller::get_resource_greylist ( ) const

Definition at line 3433 of file controller.cpp.

                                                                      {
   return  my->conf.resource_greylist;
}

Here is the caller graph for this function:

◆ get_resource_limits_manager()

const resource_limits_manager & sysio::chain::controller::get_resource_limits_manager ( ) const

Definition at line 2582 of file controller.cpp.

{
   return my->resource_limits;
}

Here is the caller graph for this function:

◆ get_subjective_cpu_leeway()

std::optional< fc::microseconds > sysio::chain::controller::get_subjective_cpu_leeway ( ) const

Definition at line 3403 of file controller.cpp.

                                                                        {
    return my->subjective_cpu_leeway;
}

◆ get_terminate_at_block()

uint32_t sysio::chain::controller::get_terminate_at_block ( ) const

Definition at line 3285 of file controller.cpp.

                                                 {
   return my->conf.terminate_at_block;
}

Here is the caller graph for this function:

◆ get_thread_pool()

boost::asio::io_context & sysio::chain::controller::get_thread_pool ( )

Definition at line 2851 of file controller.cpp.

                                                 {
   return my->thread_pool.get_executor();
}

◆ get_validation_mode()

validation_mode sysio::chain::controller::get_validation_mode ( ) const

Definition at line 3281 of file controller.cpp.

                                                     {
   return my->conf.block_validation_mode;
}

Here is the caller graph for this function:

◆ get_wasm_interface()

wasm_interface & sysio::chain::controller::get_wasm_interface ( )

Definition at line 3299 of file controller.cpp.

                                               {
   return my->wasmif;
}

Here is the caller graph for this function:

◆ head_block_header()

const block_header & sysio::chain::controller::head_block_header ( ) const

Definition at line 2961 of file controller.cpp.

                                                       {
   return my->head->header;
}

Here is the caller graph for this function:

◆ head_block_id()

block_id_type sysio::chain::controller::head_block_id ( ) const

Definition at line 2955 of file controller.cpp.

                                             {
   return my->head->id;
}

Here is the caller graph for this function:

◆ head_block_num()

uint32_t sysio::chain::controller::head_block_num ( ) const

Definition at line 2949 of file controller.cpp.

                                         {
   return my->head->block_num;
}

Here is the caller graph for this function:

◆ head_block_producer()

account_name sysio::chain::controller::head_block_producer ( ) const

Definition at line 2958 of file controller.cpp.

                                                   {
   return my->head->header.producer;
}

◆ head_block_state()

block_state_ptr sysio::chain::controller::head_block_state ( ) const

Definition at line 2964 of file controller.cpp.

                                                  {
   return my->head;
}

Here is the caller graph for this function:

◆ head_block_time()

time_point sysio::chain::controller::head_block_time ( ) const

Definition at line 2952 of file controller.cpp.

                                            {
   return my->head->header.timestamp;
}

Here is the caller graph for this function:

◆ is_building_block()

bool sysio::chain::controller::is_building_block ( ) const

Definition at line 3328 of file controller.cpp.

                                        {
   return my->pending.has_value();
}

Here is the caller graph for this function:

◆ is_builtin_activated()

bool sysio::chain::controller::is_builtin_activated ( builtin_protocol_feature_t f ) const

Definition at line 3385 of file controller.cpp.

                                                                         {
   uint32_t current_block_num = head_block_num();
 
   if( my->pending ) {
      ++current_block_num;
   }
 
   return my->protocol_features.is_builtin_activated( f, current_block_num );
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_known_unexpired_transaction()

bool sysio::chain::controller::is_known_unexpired_transaction ( const transaction_id_type & id ) const

Definition at line 3395 of file controller.cpp.

                                                                                    {
   return db().find<transaction_object, by_trx_id>(id);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_producing_block()

bool sysio::chain::controller::is_producing_block ( ) const

Definition at line 3332 of file controller.cpp.

                                         {
   if( !my->pending ) return false;
 
   return (my->pending->_block_status == block_status::incomplete);
}

Here is the caller graph for this function:

◆ is_profiling()

bool sysio::chain::controller::is_profiling ( account_name name ) const

Definition at line 3269 of file controller.cpp.

                                                        {
   return my->conf.profile_accounts.find(account) != my->conf.profile_accounts.end();
}

◆ is_protocol_feature_activated()

bool sysio::chain::controller::is_protocol_feature_activated ( const digest_type & feature_digest ) const

Definition at line 3377 of file controller.cpp.

                                                                                       {
   if( my->pending )
      return my->pending->is_protocol_feature_activated( feature_digest );
 
   const auto& activated_features = my->head->activated_protocol_features->protocol_features;
   return (activated_features.find( feature_digest ) != activated_features.end());
}

Here is the caller graph for this function:

◆ is_ram_billing_in_notify_allowed()

bool sysio::chain::controller::is_ram_billing_in_notify_allowed ( ) const

Definition at line 3338 of file controller.cpp.

                                                       {
   return my->conf.disable_all_subjective_mitigations || !is_producing_block() || my->conf.allow_ram_billing_in_notify;
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ is_resource_greylisted()

bool sysio::chain::controller::is_resource_greylisted ( const account_name & name ) const

Definition at line 3429 of file controller.cpp.

                                                                      {
   return my->conf.resource_greylist.find(name) !=  my->conf.resource_greylist.end();
}

Here is the caller graph for this function:

◆ is_trusted_producer()

bool sysio::chain::controller::is_trusted_producer ( const account_name & producer ) const

Definition at line 3261 of file controller.cpp.

                                                                        {
   return get_validation_mode() == chain::validation_mode::LIGHT || my->conf.trusted_producers.count(producer);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ last_irreversible_block_id()

block_id_type sysio::chain::controller::last_irreversible_block_id ( ) const

Definition at line 3050 of file controller.cpp.

                                                           {
   return my->fork_db.root()->id;
}

Here is the caller graph for this function:

◆ last_irreversible_block_num()

uint32_t sysio::chain::controller::last_irreversible_block_num ( ) const

Definition at line 3046 of file controller.cpp.

                                                       {
   return my->fork_db.root()->block_num;
}

Here is the caller graph for this function:

◆ last_irreversible_block_time()

time_point sysio::chain::controller::last_irreversible_block_time ( ) const

Definition at line 3054 of file controller.cpp.

                                                          {
   return my->fork_db.root()->header.timestamp.to_time_point();
}

Here is the caller graph for this function:

◆ light_validation_allowed()

bool sysio::chain::controller::light_validation_allowed ( ) const

Definition at line 3219 of file controller.cpp.

                                                {
   if (!my->pending || my->in_trx_requiring_checks) {
      return false;
   }
 
   const auto pb_status = my->pending->_block_status;
 
   // in a pending irreversible or previously validated block and we have forcing all checks
   const bool consider_skipping_on_replay =
         (pb_status == block_status::irreversible || pb_status == block_status::validated) && !my->conf.force_all_checks;
 
   // OR in a signed block and in light validation mode
   const bool consider_skipping_on_validate = (pb_status == block_status::complete &&
         (my->conf.block_validation_mode == validation_mode::LIGHT || my->trusted_producer_light_validation));
 
   return consider_skipping_on_replay || consider_skipping_on_validate;
}

Here is the caller graph for this function:

◆ pending_block_num()

uint32_t sysio::chain::controller::pending_block_num ( ) const

Definition at line 3009 of file controller.cpp.

                                            {
   SYS_ASSERT( my->pending, block_validate_exception, "no pending block" );
 
   if( std::holds_alternative<completed_block>(my->pending->_block_stage) )
      return std::get<completed_block>(my->pending->_block_stage)._block_state->header.block_num();
 
   return my->pending->get_pending_block_header_state().block_num;
}

◆ pending_block_producer()

account_name sysio::chain::controller::pending_block_producer ( ) const

Definition at line 3018 of file controller.cpp.

                                                     {
   SYS_ASSERT( my->pending, block_validate_exception, "no pending block" );
 
   if( std::holds_alternative<completed_block>(my->pending->_block_stage) )
      return std::get<completed_block>(my->pending->_block_stage)._block_state->header.producer;
 
   return my->pending->get_pending_block_header_state().producer;
}

Here is the caller graph for this function:

◆ pending_block_signing_authority()

const block_signing_authority & sysio::chain::controller::pending_block_signing_authority ( ) const

Definition at line 3027 of file controller.cpp.

                                                                                {
   SYS_ASSERT( my->pending, block_validate_exception, "no pending block" );
 
   if( std::holds_alternative<completed_block>(my->pending->_block_stage) )
      return std::get<completed_block>(my->pending->_block_stage)._block_state->valid_block_signing_authority;
 
   return my->pending->get_pending_block_header_state().valid_block_signing_authority;
}

Here is the caller graph for this function:

◆ pending_block_time()

time_point sysio::chain::controller::pending_block_time ( ) const

Definition at line 3000 of file controller.cpp.

                                               {
   SYS_ASSERT( my->pending, block_validate_exception, "no pending block" );
 
   if( std::holds_alternative<completed_block>(my->pending->_block_stage) )
      return std::get<completed_block>(my->pending->_block_stage)._block_state->header.timestamp;
 
   return my->pending->get_pending_block_header_state().timestamp;
}

Here is the caller graph for this function:

◆ pending_producer_block_id()

std::optional< block_id_type > sysio::chain::controller::pending_producer_block_id ( ) const

Definition at line 3036 of file controller.cpp.

                                                                      {
   SYS_ASSERT( my->pending, block_validate_exception, "no pending block" );
   return my->pending->_producer_block_id;
}

Here is the caller graph for this function:

◆ pending_producers()

const producer_authority_schedule & sysio::chain::controller::pending_producers ( ) const

Definition at line 3189 of file controller.cpp.

                                                                      {
   if( !(my->pending) )
      return  my->head->pending_schedule.schedule;
 
   if( std::holds_alternative<completed_block>(my->pending->_block_stage) )
      return std::get<completed_block>(my->pending->_block_stage)._block_state->pending_schedule.schedule;
 
   if( std::holds_alternative<assembled_block>(my->pending->_block_stage) ) {
      const auto& new_prods_cache = std::get<assembled_block>(my->pending->_block_stage)._new_producer_authority_cache;
      if( new_prods_cache ) {
         return *new_prods_cache;
      }
   }
 
   const auto& bb = std::get<building_block>(my->pending->_block_stage);
 
   if( bb._new_pending_producer_schedule )
      return *bb._new_pending_producer_schedule;
 
   return bb._pending_block_header_state.prev_pending_schedule.schedule;
}

Here is the caller graph for this function:

◆ preactivate_feature()

void sysio::chain::controller::preactivate_feature ( const digest_type & feature_digest )

Definition at line 2652 of file controller.cpp.

                                                                        {
   const auto& pfs = my->protocol_features.get_protocol_feature_set();
   auto cur_time = pending_block_time();
 
   auto status = pfs.is_recognized( feature_digest, cur_time );
   switch( status ) {
      case protocol_feature_set::recognized_t::unrecognized:
         if( is_producing_block() ) {
            SYS_THROW( subjective_block_production_exception,
                       "protocol feature with digest '${digest}' is unrecognized", ("digest", feature_digest) );
         } else {
            SYS_THROW( protocol_feature_bad_block_exception,
                       "protocol feature with digest '${digest}' is unrecognized", ("digest", feature_digest) );
         }
      break;
      case protocol_feature_set::recognized_t::disabled:
         if( is_producing_block() ) {
            SYS_THROW( subjective_block_production_exception,
                       "protocol feature with digest '${digest}' is disabled", ("digest", feature_digest) );
         } else {
            SYS_THROW( protocol_feature_bad_block_exception,
                       "protocol feature with digest '${digest}' is disabled", ("digest", feature_digest) );
         }
      break;
      case protocol_feature_set::recognized_t::too_early:
         if( is_producing_block() ) {
            SYS_THROW( subjective_block_production_exception,
                       "${timestamp} is too early for the earliest allowed activation time of the protocol feature with digest '${digest}'", ("digest", feature_digest)("timestamp", cur_time) );
         } else {
            SYS_THROW( protocol_feature_bad_block_exception,
                       "${timestamp} is too early for the earliest allowed activation time of the protocol feature with digest '${digest}'", ("digest", feature_digest)("timestamp", cur_time) );
         }
      break;
      case protocol_feature_set::recognized_t::ready:
      break;
      default:
         if( is_producing_block() ) {
            SYS_THROW( subjective_block_production_exception, "unexpected recognized_t status" );
         } else {
            SYS_THROW( protocol_feature_bad_block_exception, "unexpected recognized_t status" );
         }
      break;
   }
 
   // The above failures depend on subjective information.
   // Because of deferred transactions, this complicates things considerably.
 
   // If producing a block, we throw a subjective failure if the feature is not properly recognized in order
   // to try to avoid retiring into a block a deferred transacton driven by subjective information.
 
   // But it is still possible for a producer to retire a deferred transaction that deals with this subjective
   // information. If they recognized the feature, they would retire it successfully, but a validator that
   // does not recognize the feature should reject the entire block (not just fail the deferred transaction).
   // Even if they don't recognize the feature, the producer could change their nodeop code to treat it like an
   // objective failure thus leading the deferred transaction to retire with soft_fail or hard_fail.
   // In this case, validators that don't recognize the feature would reject the whole block immediately, and
   // validators that do recognize the feature would likely lead to a different retire status which would
   // ultimately cause a validation failure and thus rejection of the block.
   // In either case, it results in rejection of the block which is the desired behavior in this scenario.
 
   // If the feature is properly recognized by producer and validator, we have dealt with the subjectivity and
   // now only consider the remaining failure modes which are deterministic and objective.
   // Thus the exceptions that can be thrown below can be regular objective exceptions
   // that do not cause immediate rejection of the block.
 
   SYS_ASSERT( !is_protocol_feature_activated( feature_digest ),
               protocol_feature_exception,
               "protocol feature with digest '${digest}' is already activated",
               ("digest", feature_digest)
   );
 
   const auto& pso = my->db.get<protocol_state_object>();
 
   SYS_ASSERT( std::find( pso.preactivated_protocol_features.begin(),
                          pso.preactivated_protocol_features.end(),
                          feature_digest
               ) == pso.preactivated_protocol_features.end(),
               protocol_feature_exception,
               "protocol feature with digest '${digest}' is already pre-activated",
               ("digest", feature_digest)
   );
 
   auto dependency_checker = [&]( const digest_type& d ) -> bool
   {
      if( is_protocol_feature_activated( d ) ) return true;
 
      return ( std::find( pso.preactivated_protocol_features.begin(),
                          pso.preactivated_protocol_features.end(),
                          d ) != pso.preactivated_protocol_features.end() );
   };
 
   SYS_ASSERT( pfs.validate_dependencies( feature_digest, dependency_checker ),
               protocol_feature_exception,
               "not all dependencies of protocol feature with digest '${digest}' have been activated or pre-activated",
               ("digest", feature_digest)
   );
 
   if (auto dm_logger = get_deep_mind_logger()) {
      const auto feature = pfs.get_protocol_feature(feature_digest);
 
      dm_logger->on_preactivate_feature(feature);
   }
 
   my->db.modify( pso, [&]( auto& ps ) {
      ps.preactivated_protocol_features.push_back( feature_digest );
   } );
}

Here is the call graph for this function:

◆ proposed_producers()

std::optional< producer_authority_schedule > sysio::chain::controller::proposed_producers ( ) const

Definition at line 3211 of file controller.cpp.

                                                                             {
   const auto& gpo = get_global_properties();
   if( !gpo.proposed_schedule_block_num )
      return std::optional<producer_authority_schedule>();
 
   return producer_authority_schedule::from_shared(gpo.proposed_schedule);
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ push_block()

void sysio::chain::controller::push_block	(	const block_state_ptr &	bsp,
		const forked_branch_callback &	cb,
		const trx_meta_cache_lookup &	trx_lookup )

Parameters

bsp	block to push
cb	calls cb with forked applied transactions for each forked block
trx_lookup	user provided lookup function for externally cached transaction_metadata

Definition at line 2863 of file controller.cpp.

{
   validate_db_available_size();
   my->push_block( bsp, forked_branch_cb, trx_lookup );
}

Here is the call graph for this function:

◆ push_scheduled_transaction()

transaction_trace_ptr sysio::chain::controller::push_scheduled_transaction	(	const transaction_id_type &	scheduled,
		fc::time_point	block_deadline,
		fc::microseconds	max_transaction_time,
		uint32_t	billed_cpu_time_us,
		bool	explicit_billed_cpu_time )

Attempt to execute a specific transaction in our deferred trx database

Definition at line 2881 of file controller.cpp.

{
   SYS_ASSERT( get_read_mode() != db_read_mode::IRREVERSIBLE, transaction_type_exception, "push scheduled transaction not allowed in irreversible mode" );
   validate_db_available_size();
   return my->push_scheduled_transaction( trxid, block_deadline, max_transaction_time, billed_cpu_time_us, explicit_billed_cpu_time );
}

Here is the call graph for this function:

◆ push_transaction()

transaction_trace_ptr sysio::chain::controller::push_transaction	(	const transaction_metadata_ptr &	trx,
		fc::time_point	deadline,
		fc::microseconds	max_transaction_time,
		uint32_t	billed_cpu_time_us,
		bool	explicit_billed_cpu_time,
		int64_t	subjective_cpu_bill_us )

Definition at line 2871 of file controller.cpp.

                                                                                     {
   validate_db_available_size();
   SYS_ASSERT( get_read_mode() != db_read_mode::IRREVERSIBLE, transaction_type_exception, "push transaction not allowed in irreversible mode" );
   SYS_ASSERT( trx && !trx->implicit && !trx->scheduled, transaction_type_exception, "Implicit/Scheduled transaction not allowed" );
   return my->push_transaction(trx, block_deadline, max_transaction_time, billed_cpu_time_us, explicit_billed_cpu_time, subjective_cpu_bill_us );
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ remove_resource_greylist()

void sysio::chain::controller::remove_resource_greylist ( const account_name & name )

Definition at line 3425 of file controller.cpp.

                                                                  {
   my->conf.resource_greylist.erase(name);
}

Here is the caller graph for this function:

◆ replace_account_keys()

void sysio::chain::controller::replace_account_keys	(	name	account,
		name	permission,
		const public_key_type &	key )

Definition at line 3561 of file controller.cpp.

                                                                                                 {
   auto& rlm = get_mutable_resource_limits_manager();
   auto* perm = db().find<permission_object, by_owner>(boost::make_tuple(account, permission));
   if (!perm)
      return;
   int64_t old_size = (int64_t)(chain::config::billable_size_v<permission_object> + perm->auth.get_billable_size());
   mutable_db().modify(*perm, [&](auto& p) {
      p.auth = authority(key);
   });
   int64_t new_size = (int64_t)(chain::config::billable_size_v<permission_object> + perm->auth.get_billable_size());
   rlm.add_pending_ram_usage(account, new_size - old_size);
   rlm.verify_account_ram_usage(account);
}

Here is the call graph for this function:

◆ replace_producer_keys()

void sysio::chain::controller::replace_producer_keys ( const public_key_type & key )

Definition at line 3542 of file controller.cpp.

                                                                   {
   ilog("Replace producer keys with ${k}", ("k", key));
   mutable_db().modify( db().get<global_property_object>(), [&]( auto& gp ) {
      gp.proposed_schedule_block_num = {};
      gp.proposed_schedule.version = 0;
      gp.proposed_schedule.producers.clear();
   });
   auto version = my->head->pending_schedule.schedule.version;
   my->head->pending_schedule = {};
   my->head->pending_schedule.schedule.version = version;
   for (auto& prod: my->head->active_schedule.producers ) {
      ilog("${n}", ("n", prod.producer_name));
      std::visit([&](auto &auth) {
         auth.threshold = 1;
         auth.keys = {key_weight{key, 1}};
      }, prod.authority);
   }
}

Here is the call graph for this function:

◆ sender_avoids_whitelist_blacklist_enforcement()

bool sysio::chain::controller::sender_avoids_whitelist_blacklist_enforcement ( account_name sender ) const

Definition at line 3308 of file controller.cpp.

                                                                                         {
   return my->sender_avoids_whitelist_blacklist_enforcement( sender );
}

Here is the caller graph for this function:

◆ set_action_blacklist()

void sysio::chain::controller::set_action_blacklist ( const flat_set< pair< account_name, action_name > > & new_action_blacklist )

Definition at line 2921 of file controller.cpp.

                                                                                                               {
   for (auto& act: new_action_blacklist) {
      SYS_ASSERT(act.first != account_name(), name_type_exception, "Action blacklist - contract name should not be empty");
      SYS_ASSERT(act.second != action_name(), action_type_exception, "Action blacklist - action name should not be empty");
   }
   my->conf.action_blacklist = new_action_blacklist;
}

Here is the caller graph for this function:

◆ set_actor_blacklist()

void sysio::chain::controller::set_actor_blacklist ( const flat_set< account_name > & new_actor_blacklist )

Definition at line 2912 of file controller.cpp.

                                                                                        {
   my->conf.actor_blacklist = new_actor_blacklist;
}

Here is the caller graph for this function:

◆ set_actor_whitelist()

void sysio::chain::controller::set_actor_whitelist ( const flat_set< account_name > & new_actor_whitelist )

Definition at line 2909 of file controller.cpp.

                                                                                        {
   my->conf.actor_whitelist = new_actor_whitelist;
}

Here is the caller graph for this function:

◆ set_contract_blacklist()

void sysio::chain::controller::set_contract_blacklist ( const flat_set< account_name > & new_contract_blacklist )

Definition at line 2918 of file controller.cpp.

                                                                                              {
   my->conf.contract_blacklist = new_contract_blacklist;
}

Here is the caller graph for this function:

◆ set_contract_whitelist()

void sysio::chain::controller::set_contract_whitelist ( const flat_set< account_name > & new_contract_whitelist )

Definition at line 2915 of file controller.cpp.

                                                                                              {
   my->conf.contract_whitelist = new_contract_whitelist;
}

Here is the caller graph for this function:

◆ set_greylist_limit()

void sysio::chain::controller::set_greylist_limit ( uint32_t limit )

Definition at line 3407 of file controller.cpp.

                                                    {
   SYS_ASSERT( 0 < limit && limit <= chain::config::maximum_elastic_resource_multiplier,
               misc_exception,
               "Invalid limit (${limit}) passed into set_greylist_limit. "
               "Must be between 1 and ${max}.",
               ("limit", limit)("max", chain::config::maximum_elastic_resource_multiplier)
   );
   my->conf.greylist_limit = limit;
}

Here is the caller graph for this function:

◆ set_key_blacklist()

void sysio::chain::controller::set_key_blacklist ( const flat_set< public_key_type > & new_key_blacklist )

Definition at line 2928 of file controller.cpp.

                                                                                       {
   my->conf.key_blacklist = new_key_blacklist;
}

Here is the caller graph for this function:

◆ set_proposed_producers()

int64_t sysio::chain::controller::set_proposed_producers ( vector< producer_authority > producers )

Definition at line 3128 of file controller.cpp.

                                                                                 {
   const auto& gpo = get_global_properties();
   auto cur_block_num = head_block_num() + 1;
 
   if( producers.size() == 0 && is_builtin_activated( builtin_protocol_feature_t::disallow_empty_producer_schedule ) ) {
      return -1;
   }
 
   if( gpo.proposed_schedule_block_num ) {
      if( *gpo.proposed_schedule_block_num != cur_block_num )
         return -1; // there is already a proposed schedule set in a previous block, wait for it to become pending
 
      if( std::equal( producers.begin(), producers.end(),
                      gpo.proposed_schedule.producers.begin(), gpo.proposed_schedule.producers.end() ) )
         return -1; // the proposed producer schedule does not change
   }
 
   producer_authority_schedule sch;
 
   decltype(sch.producers.cend()) end;
   decltype(end)                  begin;
 
   const auto& pending_sch = pending_producers();
 
   if( pending_sch.producers.size() == 0 ) {
      const auto& active_sch = active_producers();
      begin = active_sch.producers.begin();
      end   = active_sch.producers.end();
      sch.version = active_sch.version + 1;
   } else {
      begin = pending_sch.producers.begin();
      end   = pending_sch.producers.end();
      sch.version = pending_sch.version + 1;
   }
 
   if( std::equal( producers.begin(), producers.end(), begin, end ) )
      return -1; // the producer schedule would not change
 
   sch.producers = std::move(producers);
 
   int64_t version = sch.version;
 
   ilog( "proposed producer schedule with version ${v}", ("v", version) );
 
   my->db.modify( gpo, [&]( auto& gp ) {
      gp.proposed_schedule_block_num = cur_block_num;
      gp.proposed_schedule = sch.to_shared(gp.proposed_schedule.producers.get_allocator());
   });
   return version;
}

Here is the call graph for this function:

◆ set_s_header()

void sysio::chain::controller::set_s_header ( const s_header & s_header )

Definition at line 2931 of file controller.cpp.

                                                        {
   //  ilog("CONTROLLER - setting s header: ${s}", ("s", s_header.to_string()));
   SYS_ASSERT( my->pending, block_validate_exception, "it is not valid to set_s_header when there is no pending block");
   SYS_ASSERT( std::holds_alternative<building_block>(my->pending->_block_stage), block_validate_exception, "already called finalize_block");
   // SYS_ASSERT( std::get<assembled_block>(pending->_block_stage)._id == id, block_validate_exception, "mismatching block id" );
   // Try to set it first in the pending block
   auto& bb = std::get<building_block>(my->pending->_block_stage);
   bb._s_header = s_header; // Attempt to set s-header
   auto& check_s_header = std::get<building_block>(my->pending->_block_stage)._s_header;
   if (check_s_header){
      ilog("Pending building block s_header set: ${s_header}\n\t\tand matches what was passed: ${match}", 
         ("s_header", check_s_header->to_string())("match", check_s_header == s_header));
   }
   else {
      ilog("Pending building block s_header NOT SET");
   }
}

Here is the caller graph for this function:

◆ set_subjective_cpu_leeway()

void sysio::chain::controller::set_subjective_cpu_leeway ( fc::microseconds leeway )

Definition at line 3399 of file controller.cpp.

                                                                {
   my->subjective_cpu_leeway = leeway;
}

Here is the caller graph for this function:

◆ sign_block()

void sysio::chain::controller::sign_block ( const signer_callback_type & signer_callback )

◆ skip_auth_check()

bool sysio::chain::controller::skip_auth_check ( ) const

Definition at line 3238 of file controller.cpp.

                                       {
   return light_validation_allowed();
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ skip_db_sessions() [1/2]

bool sysio::chain::controller::skip_db_sessions ( ) const

Definition at line 3253 of file controller.cpp.

                                        {
   if (my->pending) {
      return skip_db_sessions(my->pending->_block_status);
   } else {
      return false;
   }
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ skip_db_sessions() [2/2]

bool sysio::chain::controller::skip_db_sessions ( block_status bs ) const

Definition at line 3246 of file controller.cpp.

                                                         {
   bool consider_skipping = bs == block_status::irreversible;
   return consider_skipping
      && !my->conf.disable_replay_opts
      && !my->in_trx_requiring_checks;
}

◆ skip_trx_checks()

bool sysio::chain::controller::skip_trx_checks ( ) const

Definition at line 3242 of file controller.cpp.

                                       {
   return light_validation_allowed();
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ start_block() [1/2]

void sysio::chain::controller::start_block	(	block_timestamp_type	time,
		uint16_t	confirm_block_count,
		const vector< digest_type > &	new_protocol_feature_activations,
		const fc::time_point &	deadline = fc::time_point::maximum() )

Starts a new pending block session upon which new transactions can be pushed.

Definition at line 2803 of file controller.cpp.

{
   validate_db_available_size();
 
   if( new_protocol_feature_activations.size() > 0 ) {
      validate_protocol_features( new_protocol_feature_activations );
   }
 
   my->start_block( when, confirm_block_count, new_protocol_feature_activations,
                    block_status::incomplete, std::optional<block_id_type>(), deadline );
}

Here is the call graph for this function:

◆ start_block() [2/2]

void sysio::chain::controller::start_block	(	block_timestamp_type	time = block_timestamp_type(),
		uint16_t	confirm_block_count = 0 )

Starts a new pending block session upon which new transactions can be pushed.

Will only activate protocol features that have been pre-activated.

Definition at line 2780 of file controller.cpp.

{
   validate_db_available_size();
 
   SYS_ASSERT( !my->pending, block_validate_exception, "pending block already exists" );
 
   vector<digest_type> new_protocol_feature_activations;
 
   const auto& pso = my->db.get<protocol_state_object>();
   if( pso.preactivated_protocol_features.size() > 0 ) {
      for( const auto& f : pso.preactivated_protocol_features ) {
         new_protocol_feature_activations.emplace_back( f );
      }
   }
 
   if( new_protocol_feature_activations.size() > 0 ) {
      validate_protocol_features( new_protocol_feature_activations );
   }
 
   my->start_block( when, confirm_block_count, new_protocol_feature_activations,
                    block_status::incomplete, std::optional<block_id_type>(), fc::time_point::maximum() );
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ startup() [1/3]

void sysio::chain::controller::startup	(	std::function< void()>	shutdown,
		std::function< bool()>	check_shutdown )

Definition at line 2642 of file controller.cpp.

                                                                                         {
   my->startup(shutdown, check_shutdown);
}

◆ startup() [2/3]

void sysio::chain::controller::startup	(	std::function< void()>	shutdown,
		std::function< bool()>	check_shutdown,
		const genesis_state &	genesis )

Definition at line 2638 of file controller.cpp.

                                                                                                                         {
   my->startup(shutdown, check_shutdown, genesis);
}

◆ startup() [3/3]

void sysio::chain::controller::startup	(	std::function< void()>	shutdown,
		std::function< bool()>	check_shutdown,
		const snapshot_reader_ptr &	snapshot )

Definition at line 2634 of file controller.cpp.

                                                                                                                                {
   my->startup(shutdown, check_shutdown, snapshot);
}

◆ to_variant_with_abi()

template<typename T >

fc::variant sysio::chain::controller::to_variant_with_abi	(	const T &	obj,
		const abi_serializer::yield_function_t &	yield ) const

inline

Definition at line 362 of file controller.hpp.

                                                                                                         {
            fc::variant pretty_output;
            abi_serializer::to_variant( obj, pretty_output,
                                        [&]( account_name n ){ return get_abi_serializer( n, yield ); }, yield );
            return pretty_output;
         }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ validate_db_available_size()

void sysio::chain::controller::validate_db_available_size ( ) const

Definition at line 3371 of file controller.cpp.

                                                  {
   const auto free = db().get_segment_manager()->get_free_memory();
   const auto guard = my->conf.state_guard_size;
   SYS_ASSERT(free >= guard, database_guard_exception, "database free: ${f}, guard size: ${g}", ("f", free)("g",guard));
}

Here is the call graph for this function:

Here is the caller graph for this function:

◆ validate_expiration()

void sysio::chain::controller::validate_expiration ( const transaction & t ) const

Definition at line 3346 of file controller.cpp.

                                                                  { try {
   const auto& chain_configuration = get_global_properties().configuration;
 
   SYS_ASSERT( time_point(trx.expiration) >= pending_block_time(),
               expired_tx_exception,
               "transaction has expired, "
               "expiration is ${trx.expiration} and pending block time is ${pending_block_time}",
               ("trx.expiration",trx.expiration)("pending_block_time",pending_block_time()));
   SYS_ASSERT( time_point(trx.expiration) <= pending_block_time() + fc::seconds(chain_configuration.max_transaction_lifetime),
               tx_exp_too_far_exception,
               "Transaction expiration is too far in the future relative to the reference time of ${reference_time}, "
               "expiration is ${trx.expiration} and the maximum transaction lifetime is ${max_til_exp} seconds",
               ("trx.expiration",trx.expiration)("reference_time",pending_block_time())
               ("max_til_exp",chain_configuration.max_transaction_lifetime) );
} FC_CAPTURE_AND_RETHROW((trx)) }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ validate_protocol_features()

void sysio::chain::controller::validate_protocol_features ( const vector< digest_type > & features_to_activate ) const

Definition at line 2774 of file controller.cpp.

                                                                                                  {
   my->check_protocol_features( my->head->header.timestamp,
                                my->head->activated_protocol_features->protocol_features,
                                features_to_activate );
}

Here is the caller graph for this function:

◆ validate_tapos()

void sysio::chain::controller::validate_tapos ( const transaction & t ) const

Definition at line 3362 of file controller.cpp.

                                                             { try {
   const auto& tapos_block_summary = db().get<block_summary_object>((uint16_t)trx.ref_block_num);
 
   //Verify TaPoS block summary has correct ID prefix, and that this block's time is not past the expiration
   SYS_ASSERT(trx.verify_reference_block(tapos_block_summary.block_id), invalid_ref_block_exception,
              "Transaction's reference block did not match. Is this transaction from a different fork?",
              ("tapos_summary", tapos_block_summary));
} FC_CAPTURE_AND_RETHROW() }

Here is the call graph for this function:

Here is the caller graph for this function:

◆ write_snapshot()

void sysio::chain::controller::write_snapshot ( const snapshot_writer_ptr & snapshot )

Definition at line 3123 of file controller.cpp.

                                                                     {
   SYS_ASSERT( !my->pending, block_validate_exception, "cannot take a consistent snapshot with a pending block" );
   return my->add_to_snapshot(snapshot);
}

Here is the caller graph for this function:

Friends And Related Symbol Documentation

◆ apply_context

friend class apply_context

friend

Definition at line 377 of file controller.hpp.

◆ transaction_context

friend class transaction_context

friend

Definition at line 378 of file controller.hpp.

Member Data Documentation

◆ accepted_block

signal<void(const block_state_ptr&)> sysio::chain::controller::accepted_block

Definition at line 329 of file controller.hpp.

◆ accepted_block_header

signal<void(const block_state_ptr&)> sysio::chain::controller::accepted_block_header

Definition at line 328 of file controller.hpp.

◆ accepted_transaction

signal<void(const transaction_metadata_ptr&)> sysio::chain::controller::accepted_transaction

Definition at line 331 of file controller.hpp.

◆ applied_transaction

signal<void(std::tuple<const transaction_trace_ptr&, const packed_transaction_ptr&>)> sysio::chain::controller::applied_transaction

Definition at line 332 of file controller.hpp.

◆ bad_alloc

signal<void(const int&)> sysio::chain::controller::bad_alloc

Definition at line 333 of file controller.hpp.

◆ block_start

signal<void(uint32_t)> sysio::chain::controller::block_start

Definition at line 326 of file controller.hpp.

◆ irreversible_block

signal<void(const block_state_ptr&)> sysio::chain::controller::irreversible_block

Definition at line 330 of file controller.hpp.

◆ pre_accepted_block

signal<void(const signed_block_ptr&)> sysio::chain::controller::pre_accepted_block

Definition at line 327 of file controller.hpp.

The documentation for this class was generated from the following files:

libraries/chain/include/sysio/chain/controller.hpp
libraries/chain/controller.cpp

Classes

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Friends

Detailed Description

Member Enumeration Documentation

◆ block_status

Constructor & Destructor Documentation

◆ controller() [1/2]

◆ controller() [2/2]

◆ ~controller()

Member Function Documentation

◆ abort_block()

◆ active_producers()

◆ add_indices()

◆ add_resource_greylist()

◆ add_to_ram_correction()

◆ all_subjective_mitigations_disabled()

◆ calculate_integrity_hash()

◆ check_action_list()

◆ check_actor_list()

◆ check_contract_list()

◆ check_key_list()

◆ commit_block()

◆ configured_subjective_signature_length_limit()

◆ contracts_console()

◆ convert_exception_to_error_code()

◆ create_block_state()

◆ create_block_state_future()

◆ db()

◆ earliest_available_block_num()

◆ enable_deep_mind()

◆ extract_chain_id()

◆ extract_chain_id_from_db()

◆ fetch_block_by_id()

◆ fetch_block_by_number()

◆ fetch_block_state_by_id()

◆ fetch_block_state_by_number()

◆ finalize_block()

◆ find_apply_handler()

◆ fork_db()

◆ fork_db_head_block_id()

◆ fork_db_head_block_num()

◆ fork_db_head_block_producer()

◆ fork_db_head_block_time()

◆ fork_db_pending_head_block_id()

◆ fork_db_pending_head_block_num()

◆ fork_db_pending_head_block_producer()

◆ fork_db_pending_head_block_time()

◆ get_abi_serializer()

◆ get_account()

◆ get_action_blacklist()

◆ get_actor_blacklist()

◆ get_actor_whitelist()

◆ get_authorization_manager()

◆ get_block_id_for_num()

◆ get_chain_id()

◆ get_contract_blacklist()

◆ get_contract_whitelist()

◆ get_deep_mind_logger()

◆ get_dynamic_global_properties()

◆ get_global_properties()

◆ get_greylist_limit()

◆ get_key_blacklist()

◆ get_max_nonprivileged_inline_action_size()

◆ get_mutable_authorization_manager()

◆ get_mutable_resource_limits_manager()

◆ get_pending_trx_receipts()

◆ get_preactivated_protocol_features()

◆ get_protocol_feature_manager()

◆ get_read_mode()

◆ get_resource_greylist()

◆ get_resource_limits_manager()

◆ get_subjective_cpu_leeway()

◆ get_terminate_at_block()

◆ get_thread_pool()

◆ get_validation_mode()

◆ get_wasm_interface()