数据库内核月报 － 2018 / 09

case SEQ_READ_APPEND:
    info->read_function = _my_b_seq_read;
    info->write_function = 0;			/* Force a core if used */
    break;
default:
    info->read_function = info->share ? _my_b_read_r : _my_b_read;
    info->write_function = _my_b_write;
  }

#define my_b_read(info,Buffer,Count) \
  ((info)->read_pos + (Count) <= (info)->read_end ?\
   (memcpy(Buffer,(info)->read_pos,(size_t) (Count)), \
    ((info)->read_pos+=(Count)),0) :\
   (*(info)->read_function)((info),Buffer,Count))

#define my_b_write(info,Buffer,Count) \
 ((info)->write_pos + (Count) <=(info)->write_end ?\
  (memcpy((info)->write_pos, (Buffer), (size_t)(Count)),\
   ((info)->write_pos+=(Count)),0) : \
   (*(info)->write_function)((info),(uchar *)(Buffer),(Count)))

// 先把 IO_CACHE 里剩下的数据读到 Buffer 里
if ((left_length=(size_t) (info->read_end-info->read_pos))
{
    memcpy(Buffer, info->read_pos, left_length);
    Buffer+=left_length;
    Count-=left_length;
}
//更新 pos_in_file, 如果更新之后超出了 end_of_file, 就去 append_buffer 中读取。
if (pos_in_file=info->pos_in_file +
    (size_t)(info->read_end - info->buffer)) > info->end_of_file)
    goto read_append_buffer;

// diff_length 为了对齐读
diff_length= (size_t)(pos_in_file &(IO_SIZE-1));

// 第二阶段，从文件里读数据
// 一般 IO_CACHE 默认初始化是 2*IO_CACHE，8KB，这个意思是 Count 的大小已经不能放在一个 IO_CACHE
// 的 Buffer 里
if (Count >= (size_t)(IO_SIZE + (IO_SIZE - diff_length)
{
    // 到这里面说明 Count 要读的数据超过了 IO_CACHE 中的 Buffer 大小，直接读到 Buffer
    // 那么读多少比较合适呢？
// 取出高阶的 IO_CACHE，整数个。(Count & (size_t)~(IO_SIZAE-1))
// 但是因为 pos_in_file 相对于 4K 对齐地址还有一定的偏移量，再减去这个偏移，保证整个读取是对齐的
    length=(Count & (size_t)~(IO_SIZE-1))-diff_Lenght;
    if (read_length=mysql_file_read(info->file, Buffer, length..){}
    // update after read
    Count -= read_lenght;
    Buffer += read_leagth;
    pos_in_file += read_length;
    if(read_length != length)
        goto read_append_buffer; // 没有读到想要的长度
    left_length += length;
    diff_length=0;  // no diff length now
}

// IO_CACHE buffer 中还可以读多少数据。
max_length= info->read_length-diff_length;
// 可能会超出文件结尾，需要到 append buffer 读取
if (max_length > (info->end_of_file - pos_in_file)
    max_length= (size_t)(info->end_of_file - pos_in_file)
if (!max_length) // 已经到了文件尾
{
    if (Count) // 如果还有东西要读
        goto read_append_buffer; 去 append buffer 读
}else // 还可以读一些东西
{
    // 读到 info->buffer 里，max_length 要么读到真实文件尾，要么读到 read buffer的尽头
    length= mysql_file_read(info->file, info->bufffer, max_length);
    if (lenth < Count) 还有东西要读
    {
        goto read_append_buffer;
    }
}     

return 0；

read_append_buffer:
{
    // 先看 append buffer 剩余多少空间
    size_t len_in_buffer = (size_t)(info->write_pos - info->append_read_pos);
    // 取其精华
    copy_len= MY_MIN(Count, len_in_buffer);
    memcpy 到 BUffer
    /* Fill read buffer with data from wirte buffer*/
}

if ((length=(size_t)(info->write_pos - info->write_buffer)))
{// length 是写缓冲区中数据的长度
    pos_in_file=info->pos_in_file;    // 保存一下，后面有用
    ...
    if (!append_cache)
        info->pos_in_file += length;
    // 这一步是 write_cache 的精华，获得总的 buffer 大小，然后减去当前文件 pos + length 
    // 之和，剩余部分就是文件中还没有对齐的地方，下一个写入这么大的数据，就可以满足一次对齐写
    // 所以当 buffer 比较小的时候，为了满足这种对齐的要求，可使用的 buffer 就会比较小，
	// 从而触发更多的文件 IO 操作
    info->write_end= (info->write_buffer + info->buffer_length - 
    (pos_in_file + length) & (IO_SIZE - 1)));

    if (mysql_file_wirte(info->file, info->write_buffer， length, info->myflags | 
        MY_NABP)
        info->error= -1;

    set_if_bigger(info->end_of_file, (pos_in_file+length));

    info->append_read_pos=info->write_pos=info->write_buffer;

    ....
    
}

// 和 _my_b_seq_read 互斥，保护 write buffer
lock_append_buffer(info);

rest_length= (size_t)(info->wirte_end - info->write_pos);
// 缓冲区够用
if (Count <= rest_length)
	goto end;
// 缓冲区不够用，把剩下的空间写满	
memcpy(info->write_pos, Buffer, reset_length);
Buffer += rest_length;
Count -= rest_length;
info->write_pos += rest_length;

// 写满了，刷到文件系统里去
if (my_b_flush_io_cache)
{
	...
}
// 如果要写入的太大，缓冲区可能放不下，要直接写到文件里去了。
if (Count >= IO_SIZE)
{
	// 写多少到文件里呢，IO_SIZE 以上对齐的部分。
	length= Count & (size_t)~(IO_SIZE - 1);
	mysql_file_write(info->file, Buffer, length, ..);
	
	Count-=length;
	Buffer+=length;
	info->end_of_file+=length;
	
}

end:
// 到这里要么是缓冲区够用，要么是剩下的数据页足够放到缓冲区里
memcpy(info->write_pos, Buffer, (size_t)Count);
info->write_pos += Count;
unlock_append_buffer(info);
return 0;