handle_slave_io函式呼叫read_event函式讀取event後，然後呼叫queue_event將讀取的event寫入relay log檔案中。

程式碼如下：

static int queue_event(Master_info* mi,const char* buf, ulong event_len)
{
  int error= 0;
  String error_msg;
  ulong inc_pos= 0;
  Relay_log_info *rli= mi->rli;
  mysql_mutex_t *log_lock= rli->relay_log.get_log_lock();

  char rot_buf[LOG_EVENT_HEADER_LEN + ROTATE_HEADER_LEN + FN_REFLEN];
  Gtid gtid= { 0, 0 };
  Log_event_type event_type= (Log_event_type)buf[EVENT_TYPE_OFFSET];
  ...
  mysql_mutex_lock(&mi->data_lock);
  ...
  switch (event_type) {
  case STOP_EVENT:
    goto err;
  case ROTATE_EVENT:
    Rotate_log_event rev(buf, checksum_alg != BINLOG_CHECKSUM_ALG_OFF ?
                         event_len - BINLOG_CHECKSUM_LEN : event_len,
                         mi->get_mi_description_event());

    process_io_rotate(mi, &rev);
    break;
  case FORMAT_DESCRIPTION_EVENT:
    ...  
    break;
  case HEARTBEAT_LOG_EVENT:
    ...
    break;
  case PREVIOUS_GTIDS_LOG_EVENT:
    ...
    break;
  case GTID_LOG_EVENT:
    ...
    break;
  case ANONYMOUS_GTID_LOG_EVENT:
    
  default:
    inc_pos= event_len;
    break;
  }
  ...
  mysql_mutex_lock(log_lock);
  s_id= uint4korr(buf + SERVER_ID_OFFSET);
  s_id&= opt_server_id_mask;
  if ((s_id == ::server_id && !mi->rli->replicate_same_server_id) ||
      (mi->ignore_server_ids->dynamic_ids.elements > 0 && mi->shall_ignore_server_id(s_id) &&
         (s_id != mi->master_id ||(event_type != FORMAT_DESCRIPTION_EVENT && event_type != ROTATE_EVENT))))
  {
    if (!(s_id == ::server_id && !mi->rli->replicate_same_server_id) ||
        (event_type != FORMAT_DESCRIPTION_EVENT &&
         event_type != ROTATE_EVENT &&
         event_type != STOP_EVENT))
    {
      mi->set_master_log_pos(mi->get_master_log_pos() + inc_pos);
      memcpy(rli->ign_master_log_name_end, mi->get_master_log_name(), FN_REFLEN);
      rli->ign_master_log_pos_end= mi->get_master_log_pos();
    }
    rli->relay_log.signal_update(); // the slave SQL thread needs to re-check
  }
  else
  {
    /* write the event to the relay log */
    rli->relay_log.append_buffer(buf, event_len, mi);
    mi->set_master_log_pos(mi->get_master_log_pos() + inc_pos);//只是更新master的pos，檔名呢？
    rli->relay_log.harvest_bytes_written(&rli->log_space_total);
    ...
  }
  mysql_mutex_unlock(log_lock);

  if (unlock_data_lock)
    mysql_mutex_unlock(&mi->data_lock);

}

bool MYSQL_BIN_LOG::append_buffer(const char* buf, uint len, Master_info *mi)
{
  bool error= false;
  if (my_b_append(&log_file,(uchar*) buf,len) == 0)
  {
    bytes_written += len;
    error= after_append_to_relay_log(mi);
           ->flush_and_sync(0);//relay log滿會rotate
           ->signal_update();
  }
  else
    error= true;
  DBUG_RETURN(error);
}
 

1、根據事件的各種型別做不同的處理。當接收的是心跳事件時更新最近心跳時間，然後忽略該事件。
當接收到的是ROTATE_EVENT時，說明master的binlog發生變化，需要更新Master_info例項mi中master_log_file和master_log_pos資訊。
2、先獲取relay-log鎖，然後呼叫append_buffer將事件寫入relay-log中。append_buffer函式的功能：
  1）呼叫my_b_append函式將接收的事件寫入relay-log的快取中
  2）after_append_to_relay_log函式會呼叫flush_and_sync，將IO_CACHE內容刷到relay-log並持久化到磁碟
     將事件寫入到relay log後，判斷當前檔案是否達到max_relay_log_size指定大小，如果大就需要進行rotate
  3）呼叫signal_update通知slave sql執行緒relay-log有更新，可以繼續重放動作。

     如果slave也作為master，在其commit時，也是signal_update函式通知master dump函式傳送event；這裡會不會有衝突？

    relay_log類的函式。

  4）由於讀取了主庫的事件，所以要更新mi中的master_log_file和master_log_pos資訊。