MvccTrxLogReplayer类 参考

事务日志回放器 更多...

#include <mvcc_trx_log.h>

类 MvccTrxLogReplayer 继承关系图:

Public 成员函数
	MvccTrxLogReplayer (Db &db, MvccTrxKit &trx_kit, LogHandler &log_handler)
RC	replay (const LogEntry &entry) override
	回放一条日志 更多...
RC	on_done () override
	当所有日志回放完成时的回调函数 更多...
virtual RC	replay (const LogEntry &entry)=0
	回放一条日志 更多...
virtual RC	on_done ()
	当所有日志回放完成时的回调函数 更多...

Private 属性
Db &	db_
	所属数据库
MvccTrxKit &	trx_kit_
	事务管理器
LogHandler &	log_handler_
	日志处理器 更多...
unordered_map< int32_t, MvccTrx * >	trx_map_

详细描述

事务日志回放器

成员函数说明

on_done()

RC MvccTrxLogReplayer::on_done ( )

overridevirtual

当所有日志回放完成时的回调函数

日志回放已经完成，需要把没有提交的事务，回滚掉

重载 LogReplayer .

replay()

RC MvccTrxLogReplayer::replay ( const LogEntry &  entry )

overridevirtual

回放一条日志

参数

entry

日志

直接调用事务代码自己的重放函数

如果事务结束了，需要从内存中把它删除

实现了 LogReplayer.

类成员变量说明

log_handler_

LogHandler& MvccTrxLogReplayer::log_handler_

private

日志处理器

事务ID到事务的映射。在重做结束后，如果还有未提交的事务，需要回滚。

---

该类的文档由以下文件生成:

• src/observer/storage/trx/mvcc_trx_log.h
• src/observer/storage/trx/mvcc_trx_log.cpp