sysio::chain_apis::trx_retry_db_impl Struct Reference

Public Member Functions
	trx_retry_db_impl (const chain::controller &controller, size_t max_mem_usage_size, fc::microseconds retry_interval, fc::microseconds max_expiration_time, fc::microseconds abi_serializer_max_time)
const fc::microseconds &	get_max_expiration () const
size_t	size () const
void	track_transaction (packed_transaction_ptr ptrx, std::optional< uint16_t > num_blocks, next_function< std::unique_ptr< fc::variant > > next)
void	on_applied_transaction (const chain::transaction_trace_ptr &trace, const chain::packed_transaction_ptr &ptrx)
void	on_block_start (uint32_t block_num)
void	on_accepted_block (const chain::block_state_ptr &bsp)
void	on_irreversible_block (const chain::block_state_ptr &bsp)

Detailed Description

Definition at line 92 of file trx_retry_db.cpp.

Constructor & Destructor Documentation

trx_retry_db_impl()

sysio::chain_apis::trx_retry_db_impl::trx_retry_db_impl ( const chain::controller & controller, size_t max_mem_usage_size, fc::microseconds retry_interval, fc::microseconds max_expiration_time, fc::microseconds abi_serializer_max_time )

inlineexplicit

Definition at line 93 of file trx_retry_db.cpp.

   : _controller(controller)
   , _transaction_ack_channel(appbase::app().get_channel<chain::plugin_interface::compat::channels::transaction_ack>())
   , _abi_serializer_max_time(abi_serializer_max_time)
   , _max_mem_usage_size(max_mem_usage_size)
   , _retry_interval(retry_interval)
   , _max_expiration_time(max_expiration_time)
   {}

Member Function Documentation

get_max_expiration()

const fc::microseconds & sysio::chain_apis::trx_retry_db_impl::get_max_expiration ( ) const

inline

Definition at line 104 of file trx_retry_db.cpp.

                                                   {
      return _max_expiration_time;
   }

on_accepted_block()

void sysio::chain_apis::trx_retry_db_impl::on_accepted_block ( const chain::block_state_ptr & bsp )

inline

Definition at line 166 of file trx_retry_db.cpp.

                                                            {
      // good time to perform processing
      ack_ready_trxs_by_block_num( bsp->block_num );
      retry_trxs();
   }

on_applied_transaction()

void sysio::chain_apis::trx_retry_db_impl::on_applied_transaction ( const chain::transaction_trace_ptr & trace, const chain::packed_transaction_ptr & ptrx )

inline

Definition at line 128 of file trx_retry_db.cpp.

                                                                                                                   {
      if( !trace->receipt ) return;
      // include only executed incoming transactions.
      // soft_fail not included as only interested in incoming
      if(trace->receipt->status != chain::transaction_receipt_header::executed) {
         return;
      }
      // only incoming
      if( trace->scheduled ) return;
      // Only want transactions in a block, if no producer id then not in a block
      if( !trace->producer_block_id ) return;
      // Don't care about implicit
      if( chain::is_onblock( *trace ) ) return;
 
      // Is this a transaction we are tracking
      auto& idx = _tracked_trxs.index().get<by_trx_id>();
      auto itr = idx.find(trace->id);
      if( itr != idx.end() ) {
         _tracked_trxs.modify( itr, [&trace, &control=_controller, &abi_max_time=_abi_serializer_max_time]( tracked_transaction& tt ) {
            tt.block_num = trace->block_num;
            try {
               // send_transaction trace output format.
               // Convert to variant with abi here and now because abi could change in very next transaction.
               // Alternatively, we could store off all the abis needed and do the conversion later, but as this is designed
               // to run on an API node, probably the best trade off to perform the abi serialization during block processing.
               tt.trx_trace_v = control.to_variant_with_abi( *trace, abi_serializer::create_yield_function( abi_max_time ) );
            } catch( chain::abi_exception& ) {
               tt.trx_trace_v = *trace;
            }
         } );
      }
   }

Here is the call graph for this function:

on_block_start()

void sysio::chain_apis::trx_retry_db_impl::on_block_start ( uint32_t block_num )

inline

Definition at line 161 of file trx_retry_db.cpp.

                                             {
      // on forks rollback any accepted block transactions
      rollback_to( block_num );
   }

on_irreversible_block()

void sysio::chain_apis::trx_retry_db_impl::on_irreversible_block ( const chain::block_state_ptr & bsp )

inline

Definition at line 172 of file trx_retry_db.cpp.

                                                                {
      ack_ready_trxs_by_lib( bsp->block_num );
      clear_expired( bsp->block->timestamp );
   }

size()

size_t sysio::chain_apis::trx_retry_db_impl::size ( ) const

inline

Definition at line 108 of file trx_retry_db.cpp.

                      {
      return _tracked_trxs.index().size();
   }

Here is the call graph for this function:

track_transaction()

void sysio::chain_apis::trx_retry_db_impl::track_transaction ( packed_transaction_ptr ptrx, std::optional< uint16_t > num_blocks, next_function< std::unique_ptr< fc::variant > > next )

inline

Definition at line 112 of file trx_retry_db.cpp.

                                                                                                                                         {
      SYS_ASSERT( _tracked_trxs.memory_size() < _max_mem_usage_size, tx_resource_exhaustion,
                  "Transaction exceeded  transaction-retry-max-storage-size-gb limit: ${m} bytes", ("m", _tracked_trxs.memory_size()) );
      auto i = _tracked_trxs.index().get<by_trx_id>().find( ptrx->id() );
      if( i == _tracked_trxs.index().end() ) {
         _tracked_trxs.insert( {std::move(ptrx),
                                !num_blocks.has_value() ? lib_totem : *num_blocks,
                                0,
                                {},
                                fc::time_point::now(),
                                std::move(next)} );
      } else {
         // already tracking transaction
      }
   }

Here is the call graph for this function:

---

The documentation for this struct was generated from the following file:

• plugins/chain_plugin/trx_retry_db.cpp