[MySQL 5.6] double write buffer的几个关键函数

 938         if (!srv_use_doublewrite_buf || !buf_dblwr) {

1.

最大为单个page刷新预留的dblwr  page数为：

2 * TRX_SYS_DOUBLEWRITE_BLOCK_SIZE-srv_doublewrite_batch_size

默认为8个page

当s_reserved值等于最大page数量时，线程会去sleep后retry

2.从srv_doublewrite_batch_size开始，找到一个buf_dblwr->in_use[i] 不为TRUE的slot。分配给当前page

将in_use[i]设为TRUE，并递增s_reserved++

3.将单个page写入到double write buffer中。注意，这里已经释放了buf_dblwr->mutex

4.刷double write buffer (fil_flush(TRX_SYS_SPACE))，然后再将数据写入到磁盘中（buf_dblwr_write_block_to_datafile，buf_flush_sync_datafiles）

注意在函数buf_flush_sync_datafiles中会唤醒IO线程，等待写入完成，因此这是同步写操作

5.再次持有buf_dblwr->mutex，将s_reserved–， in_use[i]， buf_block_arr[i]置为NULL。

1.持有buf_dblwr->mutex

2.如果batch_running为TRUE，表示已经有人在开始做batch flush来刷dblwr，释放互斥锁，sleep一段时间后，回到1retry

3.如果batch满了（即buf_dblwr->first_free == srv_doublewrite_batch_size），则释放mutex， 主动调用buf_dblwr_flush_buffered_writes()把dblwr的写到磁盘，然后回到1   retry

4. 将page拷贝到第buf_dblwr->first_free个槽位，并设置：

buf_dblwr->buf_block_arr[buf_dblwr->first_free] = page;

buf_dblwr->first_free++;

buf_dblwr->b_reserved++;

5.再次检查batch flush的槽位是否已满(buf_dblwr->first_free == srv_doublewrite_batch_size) ，如果满了，则释放mutex，进行一次flush（buf_dblwr_flush_buffered_writes()），从函数返回

  

6.最后释放mutex.

1.持有buf_dblwr->mutex

2.如果fist_free为0，表示当前double write buffer为空，释放mutex,返回

3.如果batch_running为TRUE，表示正有线程在做batch flush，释放Mutex, sleep一段时间后回到1 retry

4.将batch_running设置为TRUE，避免并发写

5.释放buf_dblwr->mutex

6.检查每一个将要写dblwr的block以及write_buf中的page是否被损坏或者LSN值是否正确

buf_dblwr_check_block(block) 以及 buf_dblwr_check_page_lsn(write_buf + len2)

7.将write_buf中的page写入到文件中

先写第一个block(<=64个page)，再写第二个block(<=64个page)，

也就是说最多一次写入1M， 分两次写的原因是？？

8.将double write buffer刷到磁盘后（fil_flush(TRX_SYS_SPACE);），逐个开始写数据文件(OS_AIO_SIMULATED_WAKE_LATER)

 866                 buf_dblwr_write_block_to_datafile(

 867                         buf_dblwr->buf_block_arr[i]);

9.唤醒IO线程（os_aio_simulated_wake_handler_threads）

注意这里，在函数结束时并没有将batch_running设置为FALSE，因为这里对数据文件做的是异步写，设置标记位的工作留给了IO线程来完成