database.h

Go to the documentation of this file.

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
#ifndef TVM_S_TIR_META_SCHEDULE_DATABASE_H_
#define TVM_S_TIR_META_SCHEDULE_DATABASE_H_
 
#include <tvm/ffi/container/array.h>
#include <tvm/ffi/function.h>
#include <tvm/ffi/reflection/registry.h>
#include <tvm/ffi/string.h>
#include <tvm/ir/expr.h>
#include <tvm/ir/module.h>
#include <tvm/s_tir/meta_schedule/arg_info.h>
#include <tvm/s_tir/schedule/schedule.h>
#include <tvm/s_tir/schedule/trace.h>
#include <tvm/target/target.h>
 
#include <filesystem>
#include <memory>
 
namespace tvm {
namespace s_tir {
namespace meta_schedule {
 
class ModuleEquality;
 
class WorkloadNode : public ffi::Object {
 public:
  using THashCode = size_t;
  IRModule mod;
  THashCode shash;
 
  static void RegisterReflection() {
    namespace refl = tvm::ffi::reflection;
    refl::ObjectDef<WorkloadNode>().def_ro("mod", &WorkloadNode::mod);
  }
  TVM_FFI_DECLARE_OBJECT_INFO_FINAL("s_tir.meta_schedule.Workload", WorkloadNode, ffi::Object);
 
  ffi::ObjectRef AsJSON() const;
};
 
class Workload : public ffi::ObjectRef {
 public:
  using THashCode = WorkloadNode::THashCode;
  explicit Workload(ffi::ObjectPtr<WorkloadNode> data) : ffi::ObjectRef(data) {}
  TVM_DLL explicit Workload(IRModule mod);
  TVM_DLL explicit Workload(IRModule mod, THashCode shash);
  TVM_DLL static Workload FromJSON(const ffi::ObjectRef& json_obj);
 
  TVM_FFI_DEFINE_OBJECT_REF_METHODS_NOTNULLABLE(Workload, ffi::ObjectRef, WorkloadNode);
};
 
struct WorkloadHash {
  size_t operator()(const Workload& a) const { return a->shash; }
};
 
struct WorkloadEqual {
  explicit WorkloadEqual(const ModuleEquality& mod_eq) : mod_eq_(mod_eq) {}
 
  bool operator()(const Workload& a, const Workload& b) const;
 
 private:
  const ModuleEquality& mod_eq_;
};
 
class MeasureCandidate;
 
class TuningRecordNode : public ffi::Object {
 public:
  s_tir::Trace trace;
  Workload workload{ffi::UnsafeInit()};
  ffi::Optional<ffi::Array<FloatImm>> run_secs;
  ffi::Optional<Target> target;
  ffi::Optional<ffi::Array<ArgInfo>> args_info;
 
  static void RegisterReflection() {
    namespace refl = tvm::ffi::reflection;
    refl::ObjectDef<TuningRecordNode>()
        .def_ro("trace", &TuningRecordNode::trace)
        .def_ro("workload", &TuningRecordNode::workload)
        .def_ro("run_secs", &TuningRecordNode::run_secs)
        .def_ro("target", &TuningRecordNode::target)
        .def_ro("args_info", &TuningRecordNode::args_info);
  }
  TVM_FFI_DECLARE_OBJECT_INFO_FINAL("s_tir.meta_schedule.TuningRecord", TuningRecordNode,
                                    ffi::Object);
 
  MeasureCandidate AsMeasureCandidate() const;
  ffi::ObjectRef AsJSON() const;
  bool IsValid() const;
};
 
class TuningRecord : public ffi::ObjectRef {
 public:
  TVM_DLL explicit TuningRecord(s_tir::Trace trace, Workload workload,
                                ffi::Optional<ffi::Array<FloatImm>> run_secs,
                                ffi::Optional<Target> target,
                                ffi::Optional<ffi::Array<ArgInfo>> args_info);
  TVM_DLL static TuningRecord FromJSON(const ffi::ObjectRef& json_obj, const Workload& workload);
  TVM_FFI_DEFINE_OBJECT_REF_METHODS_NOTNULLABLE(TuningRecord, ffi::ObjectRef, TuningRecordNode);
};
 
class Database;
 
/* \brief The abstract interface of database. */
class DatabaseNode : public ffi::Object {
 public:
  explicit DatabaseNode(ffi::String mod_eq_name = "structural");
 
  virtual ~DatabaseNode();
  virtual bool HasWorkload(const IRModule& mod) = 0;
  virtual Workload CommitWorkload(const IRModule& mod) = 0;
  virtual void CommitTuningRecord(const TuningRecord& record) = 0;
  virtual ffi::Array<TuningRecord> GetTopK(const Workload& workload, int top_k) = 0;
  virtual ffi::Array<TuningRecord> GetAllTuningRecords() = 0;
  virtual int64_t Size() = 0;
  virtual ffi::Optional<TuningRecord> QueryTuningRecord(const IRModule& mod, const Target& target,
                                                        const ffi::String& workload_name);
  virtual ffi::Optional<s_tir::Schedule> QuerySchedule(const IRModule& mod, const Target& target,
                                                       const ffi::String& workload_name);
  virtual ffi::Optional<IRModule> QueryIRModule(const IRModule& mod, const Target& target,
                                                const ffi::String& workload_name);
  void DumpPruned(Database destination);
  const ModuleEquality& GetModuleEquality() const {
    TVM_FFI_ICHECK(mod_eq_);
    return *mod_eq_;
  }
 
  static constexpr const bool _type_mutable = true;
  TVM_FFI_DECLARE_OBJECT_INFO("s_tir.meta_schedule.Database", DatabaseNode, ffi::Object);
 
 private:
  std::unique_ptr<ModuleEquality> mod_eq_;
};
 
class PyDatabaseNode : public DatabaseNode {
 public:
  explicit PyDatabaseNode(ffi::String mod_eq_name = "structural");
 
  using FHasWorkload = ffi::TypedFunction<bool(const IRModule&)>;
  using FCommitWorkload = ffi::TypedFunction<Workload(const IRModule&)>;
  using FCommitTuningRecord = ffi::TypedFunction<void(const TuningRecord&)>;
  using FGetTopK = ffi::TypedFunction<ffi::Array<TuningRecord>(const Workload&, int)>;
  using FGetAllTuningRecords = ffi::TypedFunction<ffi::Array<TuningRecord>()>;
  using FQueryTuningRecord = ffi::TypedFunction<ffi::Optional<TuningRecord>(
      const IRModule&, const Target&, const ffi::String&)>;
  using FQuerySchedule = ffi::TypedFunction<ffi::Optional<s_tir::Schedule>(
      const IRModule&, const Target&, const ffi::String&)>;
  using FQueryIRModule = ffi::TypedFunction<ffi::Optional<IRModule>(const IRModule&, const Target&,
                                                                    const ffi::String&)>;
  using FSize = ffi::TypedFunction<int64_t()>;
 
  FHasWorkload f_has_workload;
  FCommitWorkload f_commit_workload;
  FCommitTuningRecord f_commit_tuning_record;
  FGetTopK f_get_top_k;
  FGetAllTuningRecords f_get_all_tuning_records;
  FQueryTuningRecord f_query_tuning_record;
  FQuerySchedule f_query_schedule;
  FQueryIRModule f_query_ir_module;
  FSize f_size;
 
  static void RegisterReflection() {
    // ffi::Functions are all not registered, because the reflection system doesn't take care of
    // them, so it cannot be accessible on the python side. If there is such need from the future,
    // we can then add corresponding accessor methods to help access on python.
    // `f_has_workload` is not registered
    // `f_commit_workload` is not registered
    // `f_commit_tuning_record` is not registered
    // `f_get_top_k` is not registered
    // `f_get_all_tuning_records` is not registered
    // `f_query_tuning_record` is not registered
    // `f_query_schedule` is not registered
    // `f_query_ir_module` is not registered
    // `f_size` is not registered
    namespace refl = tvm::ffi::reflection;
    refl::ObjectDef<PyDatabaseNode>();
  }
 
  bool HasWorkload(const IRModule& mod) final {
    TVM_FFI_ICHECK(f_has_workload != nullptr) << "PyDatabase's HasWorkload method not implemented!";
    return f_has_workload(mod);
  }
 
  Workload CommitWorkload(const IRModule& mod) final {
    TVM_FFI_ICHECK(f_commit_workload != nullptr)
        << "PyDatabase's CommitWorkload method not implemented!";
    return f_commit_workload(mod);
  }
 
  void CommitTuningRecord(const TuningRecord& record) final {
    TVM_FFI_ICHECK(f_commit_tuning_record != nullptr)
        << "PyDatabase's CommitTuningRecord method not implemented!";
    f_commit_tuning_record(record);
  }
 
  ffi::Array<TuningRecord> GetTopK(const Workload& workload, int top_k) final {
    TVM_FFI_ICHECK(f_get_top_k != nullptr) << "PyDatabase's GetTopK method not implemented!";
    return f_get_top_k(workload, top_k);
  }
 
  ffi::Array<TuningRecord> GetAllTuningRecords() final {
    TVM_FFI_ICHECK(f_get_all_tuning_records != nullptr)
        << "PyDatabase's GetAllTuningRecords method not implemented!";
    return f_get_all_tuning_records();
  }
 
  ffi::Optional<TuningRecord> QueryTuningRecord(const IRModule& mod, const Target& target,
                                                const ffi::String& workload_name) final {
    if (f_query_tuning_record == nullptr) {
      return DatabaseNode::QueryTuningRecord(mod, target, workload_name);
    } else {
      return f_query_tuning_record(mod, target, workload_name);
    }
  }
 
  ffi::Optional<s_tir::Schedule> QuerySchedule(const IRModule& mod, const Target& target,
                                               const ffi::String& workload_name) final {
    if (f_query_schedule == nullptr) {
      return DatabaseNode::QuerySchedule(mod, target, workload_name);
    } else {
      return f_query_schedule(mod, target, workload_name);
    }
  }
 
  ffi::Optional<IRModule> QueryIRModule(const IRModule& mod, const Target& target,
                                        const ffi::String& workload_name) final {
    if (f_query_ir_module == nullptr) {
      return DatabaseNode::QueryIRModule(mod, target, workload_name);
    } else {
      return f_query_ir_module(mod, target, workload_name);
    }
  }
 
  int64_t Size() final {
    TVM_FFI_ICHECK(f_size != nullptr) << "PyDatabase's Size method not implemented!";
    return f_size();
  }
 
  static constexpr const bool _type_mutable = true;
  TVM_FFI_DECLARE_OBJECT_INFO_FINAL("s_tir.meta_schedule.PyDatabase", PyDatabaseNode, DatabaseNode);
};
 
class Database : public ffi::ObjectRef {
 public:
  explicit Database(ffi::ObjectPtr<DatabaseNode> data) : ffi::ObjectRef(data) {
    TVM_FFI_ICHECK(data != nullptr);
  }
  TVM_DLL static Database MemoryDatabase(ffi::String mod_eq_name = "structural");
  TVM_DLL static Database ScheduleFnDatabase(ffi::TypedFunction<bool(s_tir::Schedule)> schedule_fn,
                                             ffi::String mod_eq_name = "structural");
  TVM_DLL static Database JSONDatabase(ffi::String path_workload, ffi::String path_tuning_record,
                                       bool allow_missing, ffi::String mod_eq_name = "structural");
  TVM_DLL static Database UnionDatabase(ffi::Array<Database, void> databases);
  TVM_DLL static Database OrderedUnionDatabase(ffi::Array<Database, void> databases);
  TVM_DLL static Database PyDatabase(PyDatabaseNode::FHasWorkload f_has_workload,
                                     PyDatabaseNode::FCommitWorkload f_commit_workload,
                                     PyDatabaseNode::FCommitTuningRecord f_commit_tuning_record,
                                     PyDatabaseNode::FGetTopK f_get_top_k,
                                     PyDatabaseNode::FGetAllTuningRecords f_get_all_tuning_records,
                                     PyDatabaseNode::FQueryTuningRecord f_query_tuning_record,
                                     PyDatabaseNode::FQuerySchedule f_query_schedule,
                                     PyDatabaseNode::FQueryIRModule f_query_ir_module,
                                     PyDatabaseNode::FSize f_size,
                                     ffi::String mod_eq_name = "structural");
  static ffi::Optional<Database> Current();
  void EnterWithScope();
  void ExitWithScope();
 
  TVM_FFI_DEFINE_OBJECT_REF_METHODS_NOTNULLABLE(Database, ffi::ObjectRef, DatabaseNode);
};
 
}  // namespace meta_schedule
}  // namespace s_tir
}  // namespace tvm
 
#endif  // TVM_S_TIR_META_SCHEDULE_DATABASE_H_