Method UpdateWatchedKeysFromArgs

src/server/server.cc:2164–2170

}

void Server::UpdateWatchedKeysFromArgs(const std::vector<std::string> &args, const redis::CommandAttributes &attr) {
  if ((attr.GenerateFlags(args, *GetConfig()) & redis::kCmdWrite) && watched_key_size_ > 0) {
    attr.ForEachKeyRange([this](const std::vector<std::string> &args,
                                redis::CommandKeyRange range) { updateWatchedKeysFromRange(args, range); },
                         args, [this](const std::vector<std::string> &) { updateAllWatchedKeys(); });
  }
}

void Server::UpdateWatchedKeysManually(const std::vector<std::string> &keys) {
  std::shared_lock lock(watched_key_mutex_);