InnoDB 的 Redo Log

constexpr inline lsn_t log_translate_sn_to_lsn(lsn_t sn) {
      return (sn / LOG_BLOCK_DATA_SIZE * OS_FILE_LOG_BLOCK_SIZE +
              sn % LOG_BLOCK_DATA_SIZE + LOG_BLOCK_HDR_SIZE);
    }

日志结构

事务流程

mtr.start()
	mlog_*()  //不同类型的日志
mtr.commit()

mini-transaction start

struct mtr_t {
  struct Impl {
    //事务锁
    mtr_buf_t m_memo;
    //事务的本地日志是一个动态分配的内存空间
    mtr_buf_t m_log;
    bool m_made_dirty;
    bool m_inside_ibuf;
    bool m_modifications;
    bool m_marked_nolog;
    size_t m_shard_index;
    uint32_t m_n_log_recs;
    mtr_state_t m_state;
    Flush_observer *m_flush_observer;
  };
}

mini-transaction 数据插入

//mtr_t.Impl.m_memo的结构
/** mini-transaction memo stack slot. */
struct mtr_memo_slot_t {
  void *object;  /* 加锁的对象. */
  ulint type;    /* 持有的锁类型，W or R. */
};

mlog_open

mlog_write_initial_log_record_fast

mach_write_compressed

mlog_close

//实际上是间接调用dyn的close()
//dyn0buf.h
/**
  Closes the buffer returned by open.
  @param ptr    end of used space */
  void close(const byte *ptr) {
    ut_ad(UT_LIST_GET_LEN(m_list) > 0);
    block_t *block = back();
    m_size -= block->used();
    block->close(ptr);
    m_size += block->used();  //统计整个dyn使用内存
  }

mini-transaction commit

1. 如果prepare_write(); 返回的的长度大于0接下来调用log_buffer_reserve() 获取handle 。
log_buffer_reserve() 首先提前计算插入redo buffer的start_sn 和 end_lsn 。（这是从MySQL 8.0开始，设计了一套无锁的写log机制。）

/* Reserve space in sequence of data bytes: */
const sn_t start_sn = log.sn.fetch_add(len); //原子增加

算完start_sn 和end_lsn 判断是否比buffer的limit大

if (unlikely(end_sn > log.buf_limit_sn.load())) {
    log_wait_for_space_after_reserving(log, handle);
  }

等待之前日志写入回收空间

static void log_wait_for_space_in_log_buf(log_t &log, sn_t end_sn) {
  lsn_t lsn;
  Wait_stats wait_stats;

  //当前已经写入文件的 sn
  const sn_t write_sn = log_translate_lsn_to_sn(log.write_lsn.load());

  log_sync_point("log_wait_for_space_in_buf_middle");

  const sn_t buf_size_sn = log.buf_size_sn.load();

  if (end_sn + OS_FILE_LOG_BLOCK_SIZE <= write_sn + buf_size_sn) {
    return;
  }

  /* We preserve this counter for backward compatibility with 5.7. */
  srv_stats.log_waits.inc();

  lsn = log_translate_sn_to_lsn(end_sn + OS_FILE_LOG_BLOCK_SIZE - buf_size_sn);
 //等待 lsn 之前的 redo log 被写入.
  wait_stats = log_write_up_to(log, lsn, false);

  MONITOR_INC_WAIT_STATS(MONITOR_LOG_ON_BUFFER_SPACE_, wait_stats);

  ut_a(end_sn + OS_FILE_LOG_BLOCK_SIZE <=
       log_translate_lsn_to_sn(log.write_lsn.load()) + buf_size_sn);
}

对于整个日志长度大于当前整个 redo log buffer 的 redo log 需要Resize 设置 redo log buffer

2. m_impl->m_log.for_each_block(write_log); 按块写入buffer
对m_log中的每一个 512 字节的 Block 调用mtr_write_log_t()（需要注意的是mtr_write_log_t()是运算符()的重载)
• log_buffer_write() 调用 std::memcpy(ptr, str, len) 进行写入redo buffer 。
• log_buffer_write_completed()更新log_t中的recent_written，即(start_lsnend_lsn)组成的list 。
• add_dirty_blocks_to_flush_list() 假如产生了 redo log，则将数据页的newest_modification修改为end_lsn 。
• 假如该 Block 是第一次被修改，就需要插入 Buffer Pool 的flush_list将涉及修改的数据页添加到 Buffer Pool 的flush_list(buf_flush_insert_into_flush_list()).(利用block->page.oldest_modification来判断是否为第一次修改)
 

log_flusher