Method HandleMetaRsyncRequest

src/rsync_server.cc:114–157

}

void RsyncServerConn::HandleMetaRsyncRequest(void* arg) {
  std::unique_ptr<RsyncServerTaskArg> task_arg(static_cast<RsyncServerTaskArg*>(arg));
  const std::shared_ptr<RsyncService::RsyncRequest> req = task_arg->req;
  std::shared_ptr<net::PbConn> conn = task_arg->conn;
  std::string db_name = req->db_name();
  std::shared_ptr<DB> db = g_pika_server->GetDB(db_name);

  RsyncService::RsyncResponse response;
  response.set_reader_index(req->reader_index());
  response.set_code(RsyncService::kOk);
  response.set_type(RsyncService::kRsyncMeta);
  response.set_db_name(db_name);
  /*
   * Since the slot field is written in protobuffer,
   * slot_id is set to the default value 0 for compatibility
   * with older versions, but slot_id is not used
   */
  response.set_slot_id(0);

  std::string snapshot_uuid;
  if (!db || db->IsBgSaving()) {
    LOG(WARNING) << "waiting bgsave done...";
    response.set_snapshot_uuid(snapshot_uuid);
    response.set_code(RsyncService::kErr);
    RsyncWriteResp(response, conn);
    return;
  }

  std::vector<std::string> filenames;
  g_pika_server->GetDumpMeta(db_name, &filenames, &snapshot_uuid);
  response.set_snapshot_uuid(snapshot_uuid);

  LOG(INFO) << "Rsync Meta request, snapshot_uuid: " << snapshot_uuid
            << " files count: " << filenames.size() << " file list: ";
  std::for_each(filenames.begin(), filenames.end(), [](auto& file) {
    LOG(INFO) << "rsync snapshot file: " << file;
  });

  RsyncService::MetaResponse* meta_resp = response.mutable_meta_resp();
  for (const auto& filename : filenames) {
        meta_resp->add_filenames(filename);
  }
  RsyncWriteResp(response, conn);
}

void RsyncServerConn::HandleFileRsyncRequest(void* arg) {
  std::unique_ptr<RsyncServerTaskArg> task_arg(static_cast<RsyncServerTaskArg*>(arg));