sysio::chain::unapplied_transaction_queue Class Reference

#include <unapplied_transaction_queue.hpp>

Public Types
using	iterator = unapplied_trx_queue_type::index<by_type>::type::iterator

Public Member Functions
void	set_max_transaction_queue_size (uint64_t v)
bool	empty () const
size_t	size () const
void	clear ()
size_t	incoming_size () const
transaction_metadata_ptr	get_trx (const transaction_id_type &id) const
template<typename Yield , typename Callback >
bool	clear_expired (const time_point &pending_block_time, Yield &&yield, Callback &&callback)
void	clear_applied (const block_state_ptr &bs)
void	add_forked (const branch_type &forked_branch)
void	add_aborted (std::vector< transaction_metadata_ptr > aborted_trxs)
void	add_persisted (const transaction_metadata_ptr &trx)
void	add_incoming (const transaction_metadata_ptr &trx, bool persist_until_expired, bool return_failure_trace, next_func_t next)
iterator	begin ()
iterator	end ()
iterator	unapplied_begin ()
iterator	unapplied_end ()
iterator	persisted_begin ()
iterator	persisted_end ()
iterator	incoming_begin ()
iterator	incoming_end ()
iterator	erase (iterator itr)
	caller's responsibility to call next() if applicable

Detailed Description

Track unapplied transactions for persisted, forked blocks, and aborted blocks. Persisted are first so that they can be applied in each block until expired.

Definition at line 52 of file unapplied_transaction_queue.hpp.

Member Typedef Documentation

iterator

using sysio::chain::unapplied_transaction_queue::iterator = unapplied_trx_queue_type::index<by_type>::type::iterator

Definition at line 195 of file unapplied_transaction_queue.hpp.

Member Function Documentation

add_aborted()

void sysio::chain::unapplied_transaction_queue::add_aborted ( std::vector< transaction_metadata_ptr > aborted_trxs )

inline

Definition at line 156 of file unapplied_transaction_queue.hpp.

                                                                        {
      for( auto& trx : aborted_trxs ) {
         fc::time_point expiry = trx->packed_trx()->expiration();
         auto insert_itr = queue.insert( { std::move( trx ), expiry, trx_enum_type::aborted } );
         if( insert_itr.second ) added( insert_itr.first );
      }
   }

Here is the caller graph for this function:

add_forked()

void sysio::chain::unapplied_transaction_queue::add_forked ( const branch_type & forked_branch )

inline

Definition at line 143 of file unapplied_transaction_queue.hpp.

                                                       {
      // forked_branch is in reverse order
      for( auto ritr = forked_branch.rbegin(), rend = forked_branch.rend(); ritr != rend; ++ritr ) {
         const block_state_ptr& bsptr = *ritr;
         for( auto itr = bsptr->trxs_metas().begin(), end = bsptr->trxs_metas().end(); itr != end; ++itr ) {
            const auto& trx = *itr;
            fc::time_point expiry = trx->packed_trx()->expiration();
            auto insert_itr = queue.insert( { trx, expiry, trx_enum_type::forked } );
            if( insert_itr.second ) added( insert_itr.first );
         }
      }
   }

Here is the caller graph for this function:

add_incoming()

void sysio::chain::unapplied_transaction_queue::add_incoming ( const transaction_metadata_ptr & trx, bool persist_until_expired, bool return_failure_trace, next_func_t next )

inline

Definition at line 179 of file unapplied_transaction_queue.hpp.

                                                                                                                                     {
      auto itr = queue.get<by_trx_id>().find( trx->id() );
      if( itr == queue.get<by_trx_id>().end() ) {
         fc::time_point expiry = trx->packed_trx()->expiration();
         auto insert_itr = queue.insert(
               { trx, expiry, persist_until_expired ? trx_enum_type::incoming_persisted : trx_enum_type::incoming, return_failure_trace, std::move( next ) } );
         if( insert_itr.second ) added( insert_itr.first );
      } else {
         if( itr->trx_meta == trx ) return; // same trx meta pointer
         if( next ) {
            next( std::static_pointer_cast<fc::exception>( std::make_shared<tx_duplicate>(
                  FC_LOG_MESSAGE( info, "duplicate transaction ${id}", ("id", trx->id()) ) ) ) );
         }
      }
   }

add_persisted()

void sysio::chain::unapplied_transaction_queue::add_persisted ( const transaction_metadata_ptr & trx )

inline

Definition at line 164 of file unapplied_transaction_queue.hpp.

                                                             {
      auto itr = queue.get<by_trx_id>().find( trx->id() );
      if( itr == queue.get<by_trx_id>().end() ) {
         fc::time_point expiry = trx->packed_trx()->expiration();
         auto insert_itr = queue.insert( { trx, expiry, trx_enum_type::persisted } );
         if( insert_itr.second ) added( insert_itr.first );
      } else if( itr->trx_type != trx_enum_type::persisted ) {
         if (itr->trx_type == trx_enum_type::incoming || itr->trx_type == trx_enum_type::incoming_persisted)
            --incoming_count;
         queue.get<by_trx_id>().modify( itr, [](auto& un){
            un.trx_type = trx_enum_type::persisted;
         } );
      }
   }

begin()

iterator sysio::chain::unapplied_transaction_queue::begin ( )

inline

Definition at line 197 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().begin(); }

Here is the call graph for this function:

Here is the caller graph for this function:

clear()

void sysio::chain::unapplied_transaction_queue::clear ( )

inline

Definition at line 85 of file unapplied_transaction_queue.hpp.

                {
      queue.clear();
   }

clear_applied()

void sysio::chain::unapplied_transaction_queue::clear_applied ( const block_state_ptr & bs )

inline

Definition at line 124 of file unapplied_transaction_queue.hpp.

                                                   {
      if( empty() ) return;
      auto& idx = queue.get<by_trx_id>();
      for( const auto& receipt : bs->block->transactions ) {
         if( std::holds_alternative<packed_transaction>(receipt.trx) ) {
            const auto& pt = std::get<packed_transaction>(receipt.trx);
            auto itr = idx.find( pt.id() );
            if( itr != idx.end() ) {
               if( itr->next ) {
                  itr->next( std::static_pointer_cast<fc::exception>( std::make_shared<tx_duplicate>(
                                FC_LOG_MESSAGE( info, "duplicate transaction ${id}", ("id", itr->trx_meta->id())))));
               }
               removed( itr );
               idx.erase( itr );
            }
         }
      }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

clear_expired()

template<typename Yield , typename Callback >

bool sysio::chain::unapplied_transaction_queue::clear_expired ( const time_point & pending_block_time, Yield && yield, Callback && callback )

inline

Definition at line 100 of file unapplied_transaction_queue.hpp.

                                                                                                  {
      auto& persisted_by_expiry = queue.get<by_expiry>();
      while( !persisted_by_expiry.empty() ) {
         const auto& itr = persisted_by_expiry.begin();
         if( itr->expiry > pending_block_time ) {
            break;
         }
         if( yield() ) {
            return false;
         }
         callback( itr->trx_meta->packed_trx(), itr->trx_type );
         if( itr->next ) {
            itr->next( std::static_pointer_cast<fc::exception>(
                  std::make_shared<expired_tx_exception>(
                        FC_LOG_MESSAGE( error, "expired transaction ${id}, expiration ${e}, block time ${bt}",
                                        ("id", itr->id())("e", itr->trx_meta->packed_trx()->expiration())
                                        ("bt", pending_block_time) ) ) ) );
         }
         removed( itr );
         persisted_by_expiry.erase( itr );
      }
      return true;
   }

Here is the caller graph for this function:

empty()

bool sysio::chain::unapplied_transaction_queue::empty ( ) const

inline

Definition at line 77 of file unapplied_transaction_queue.hpp.

                      {
      return queue.empty();
   }

Here is the caller graph for this function:

end()

iterator sysio::chain::unapplied_transaction_queue::end ( )

inline

Definition at line 198 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().end(); }

Here is the call graph for this function:

Here is the caller graph for this function:

erase()

iterator sysio::chain::unapplied_transaction_queue::erase ( iterator itr )

inline

Definition at line 211 of file unapplied_transaction_queue.hpp.

                                  {
      removed( itr );
      return queue.get<by_type>().erase( itr );
   }

Here is the call graph for this function:

Here is the caller graph for this function:

get_trx()

transaction_metadata_ptr sysio::chain::unapplied_transaction_queue::get_trx ( const transaction_id_type & id ) const

inline

Definition at line 93 of file unapplied_transaction_queue.hpp.

                                                                           {
      auto itr = queue.get<by_trx_id>().find( id );
      if( itr == queue.get<by_trx_id>().end() ) return {};
      return itr->trx_meta;
   }

Here is the caller graph for this function:

incoming_begin()

iterator sysio::chain::unapplied_transaction_queue::incoming_begin ( )

inline

Definition at line 207 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().lower_bound( trx_enum_type::incoming_persisted ); }

Here is the caller graph for this function:

incoming_end()

iterator sysio::chain::unapplied_transaction_queue::incoming_end ( )

inline

Definition at line 208 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().end(); } // if changed to upper_bound, verify usage performance

Here is the call graph for this function:

Here is the caller graph for this function:

incoming_size()

size_t sysio::chain::unapplied_transaction_queue::incoming_size ( ) const

inline

Definition at line 89 of file unapplied_transaction_queue.hpp.

                               {
      return incoming_count;
   }

Here is the caller graph for this function:

persisted_begin()

iterator sysio::chain::unapplied_transaction_queue::persisted_begin ( )

inline

Definition at line 204 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().lower_bound( trx_enum_type::persisted ); }

Here is the caller graph for this function:

persisted_end()

iterator sysio::chain::unapplied_transaction_queue::persisted_end ( )

inline

Definition at line 205 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().upper_bound( trx_enum_type::persisted ); }

Here is the caller graph for this function:

set_max_transaction_queue_size()

void sysio::chain::unapplied_transaction_queue::set_max_transaction_queue_size ( uint64_t v )

inline

Definition at line 75 of file unapplied_transaction_queue.hpp.

{ max_transaction_queue_size = v; }

size()

size_t sysio::chain::unapplied_transaction_queue::size ( ) const

inline

Definition at line 81 of file unapplied_transaction_queue.hpp.

                       {
      return queue.size();
   }

Here is the caller graph for this function:

unapplied_begin()

iterator sysio::chain::unapplied_transaction_queue::unapplied_begin ( )

inline

Definition at line 201 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().begin(); }

Here is the call graph for this function:

Here is the caller graph for this function:

unapplied_end()

iterator sysio::chain::unapplied_transaction_queue::unapplied_end ( )

inline

Definition at line 202 of file unapplied_transaction_queue.hpp.

{ return queue.get<by_type>().upper_bound( trx_enum_type::aborted ); }

Here is the caller graph for this function:

---

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

• libraries/chain/include/sysio/chain/unapplied_transaction_queue.hpp