eos源码解析(五):区块的分叉与回退

谢谢可爱的小哥哥小姐姐的支持,不知不觉来到了第五节,看完点个赞呗,不然度娘都搜不到,不方便大家查找O(∩_∩)O
惊闻以太坊暴跌如雷,慌乱中瞄了瞄钱包的柚子,还好,没跌破30。如果说个人是被时代的洪流裹挟前进,那么币圈则被资本的洪流包围。资本现在流向哪里,相信善搭梯子各位,心中已有答案。郑重声明:以上纯属虚构,言归正传,继续第五节

image

1,收到一个区块

2,把自己的pending放弃

4,将区块信息加入fork_db中,先在fork_db中查找引用区块的id,没有找到就算成是unlink的区块,直接放弃。然后更新fork_db的head,这个指向可逆区块高度最高同时序号最大的一个区块。然后选出fork_db中current链最小的区块,把它以及与低于它的所有区块信息从fork_db中擦除。然后将db的相应内存退栈丢弃(4.4)。

      my->head = *my->index.get<by_lib_block_num>().begin();
      auto lib    = my->head->dpos_irreversible_blocknum;
      auto oldest = *my->index.get<by_block_num>().begin();
      if( oldest->block_num < lib ) {
         prune( oldest );
      }

5,如果当前fork_db中的head大于chain中的head,则考虑是不是应该换链,如果fork_db中head指向的是chain中的head则不换链,只是在当前链上加一个区块,如果fork_db中的head指向的不是当前链的head则要换链。

6,将旧链的内存栈丢弃。

9,创建新的可撤销内存栈

内存栈的结构:

eos存放于内存数据又是以一张张表存进去的,eos把当前的“状态”都存放在内存里面,这点与以太坊不一样,比如账户数据存放在内存的account_index表中。

void add_indices() {
      reversible_blocks.add_index<reversible_block_index>();

      db.add_index<account_index>();
      db.add_index<account_sequence_index>();

      db.add_index<table_id_multi_index>();
      db.add_index<key_value_index>();
      db.add_index<index64_index>();
      db.add_index<index128_index>();
      db.add_index<index256_index>();
      db.add_index<index_double_index>();
      db.add_index<index_long_double_index>();

      db.add_index<global_property_multi_index>();
      db.add_index<dynamic_global_property_multi_index>();
      db.add_index<block_summary_multi_index>();
      db.add_index<transaction_multi_index>();
      db.add_index<generated_transaction_multi_index>();

      authorization.add_indices();
      resource_limits.add_indices();
   }

比如account_index表,这个表会经过generic_index封装,然后赋值给:

_index_map[ type_id ].reset( new_index );_index_list.push_back( new_index );

_index_map和_index_list就是db中存放这些表的地方,里面存放的是被generic_index封装的一张张表。这里,可以看到,_index_map和_index_list里面存的内容是一致的,之所以使用map是为了更好搜索,接下来看generic_index数据结构:

.......
boost::interprocess::deque< undo_state_type, allocator<undo_state_type> > _stack;
........
typedef MultiIndexType        index_type; //account_index
index_type                      _indices;
.......
session start_undo_session( bool enabled ) {
   if( enabled ) {
      _stack.emplace_back( _indices.get_allocator() );
      _stack.back().old_next_id = _next_id;
      _stack.back().revision = ++_revision;
      return session( *this, _revision );
   } else {
      return session( *this, -1 );
   }
}
.......
void undo() {
   if( !enabled() ) return;

   const auto& head = _stack.back();

   for( auto& item : head.old_values ) {
      auto ok = _indices.modify( _indices.find( item.second.id ), [&]( value_type& v ) {
         v = std::move( item.second );
      });
      if( !ok ) BOOST_THROW_EXCEPTION( std::logic_error( "Could not modify object, most likely a uniqueness constraint was violated" ) );
   }

   for( auto id : head.new_ids )
   {
      _indices.erase( _indices.find( id ) );
   }
   _next_id = head.old_next_id;

   for( auto& item : head.removed_values ) {
      bool ok = _indices.emplace( std::move( item.second ) ).second;
      if( !ok ) BOOST_THROW_EXCEPTION( std::logic_error( "Could not restore object, most likely a uniqueness constraint was violated" ) );
   }

   _stack.pop_back();
   --_revision;
}
.......

可以发现,新建一个段就是在_stack末尾压入一个表,删除一个段就是去掉末尾的那个表。

在第8步的start_block中有:

pending = db.start_undo_session(true);

这个函数在的实现如下:

database::session database::start_undo_session( bool enabled )
{
   if( enabled ) {
      vector< std::unique_ptr<abstract_session> > _sub_sessions;
      _sub_sessions.reserve( _index_list.size() );
      for( auto& item : _index_list ) {
         _sub_sessions.push_back( item->start_undo_session( enabled ) );
      }
      return session( std::move( _sub_sessions ) );
   } else {
      return session();
   }
}

可以这样粗鲁的理解,db中存放的是一个map和数组,它们是一样的东东,map只是为了搜索方便。这个数组的元素是一个封装了某种表的对象,这个对象里面是用队列存了好多张表,是按块序号存放的,只有最后一张是现在用的,撤销或者增加只要对队列进行相应操作就行,比如增加一个新区块,就是在数组中的每个元素上新增一张表。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 217,734评论 6 505
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 92,931评论 3 394
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 164,133评论 0 354
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 58,532评论 1 293
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 67,585评论 6 392
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 51,462评论 1 302
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,262评论 3 418
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,153评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 45,587评论 1 314
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,792评论 3 336
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,919评论 1 348
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,635评论 5 345
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,237评论 3 329
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,855评论 0 22
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,983评论 1 269
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,048评论 3 370
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,864评论 2 354

推荐阅读更多精彩内容