Merge pull request PaddlePaddle#8 from Fridge003/cinn_tmp

fix
Fridge003 · Mar 20, 2024 · 45cfe69 · 45cfe69
2 parents 277b202 + c02814b
commit 45cfe69
Showing 1 changed file with 77 additions and 0 deletions.
diff --git a/paddle/cinn/frontend/cluster_ops/fusion_helper.cc b/paddle/cinn/frontend/cluster_ops/fusion_helper.cc
@@ -110,6 +110,83 @@ std::optional<ErrorGroupPattern> StmtFusionHelper::Fuse_PS_x_R_2_R(
   return FuseFilteredStmtPatterns<FusePolicy_PS_x_R_2_R>(stmt_patterns);
 }
 
+bool StmtFusionHelper::FusePolicy_IS_x_PS_2_PS::FuseCondition(const StmtPattern& upstream,
+                          const StmtPattern& downstream) {
+  return IsISPattern(upstream) && IsPSPattern(downstream);
+}
+std::variant<StmtPattern, ErrorGroupPattern> StmtFusionHelper::FusePolicy_IS_x_PS_2_PS::MergePattern(
+    const StmtPattern& upstream, const StmtPattern& downstream) {
+  return MergePatternImpl(std::get<IS>(upstream), std::get<PS>(downstream));
+}
+std::variant<StmtPattern, ErrorGroupPattern> StmtFusionHelper::FusePolicy_IS_x_PS_2_PS::MergePatternImpl(
+    const IS& upstream, const PS& downstream) {
+  const auto& ops = [&] {
+    std::vector<const pir::Operation*> ops(upstream.ops.begin(),
+                                            upstream.ops.end());
+    for (const auto* downstream_op : downstream.ops) {
+      if (std::find(ops.begin(), ops.end(), downstream_op) == ops.end()) {
+        ops.push_back(downstream_op);
+      }
+    }
+    return ops;
+  }();
+  const auto& shardable_axes_signature =
+      MergeShardableAxesSignature(upstream, downstream);
+  return StmtPattern(PS{
+      .ops = ops,
+      .sole_sink = downstream.sole_sink,
+      .shardable_axes_signature = shardable_axes_signature,
+  });
+}
+
+ShardableAxesSignature StmtFusionHelper::FusePolicy_IS_x_PS_2_PS::MergeShardableAxesSignature(
+    const IS& upstream, const PS& downstream) {
+  LOG(FATAL) << "TODO(tianchao)";
+}
+
+
+bool StmtFusionHelper::FusePolicy_IS_x_R_2_R::FuseCondition(const StmtPattern& upstream,
+                          const StmtPattern& downstream) {
+  return IsISPattern(upstream) && IsRPattern(downstream);
+}
+std::variant<StmtPattern, ErrorGroupPattern> StmtFusionHelper::FusePolicy_IS_x_R_2_R::MergePattern(
+    const StmtPattern& upstream, const StmtPattern& downstream) {
+  return MergePatternImpl(std::get<IS>(upstream), std::get<R>(downstream));
+}
+std::variant<StmtPattern, ErrorGroupPattern> StmtFusionHelper::FusePolicy_IS_x_R_2_R::MergePatternImpl(
+    const IS& upstream, const R& downstream) {
+  if (downstream.HasFusedInput()) {
+    return ErrorGroupPattern{
+        .ops = {downstream.reduce_op_pattern.reduce_op},
+        .error_string = "The input of reduce has been fused.",
+    };
+  }
+  R new_pattern = R(downstream);
+  new_pattern.input = upstream;
+  return StmtPattern(std::move(new_pattern));
+}
+
+bool StmtFusionHelper::FusePolicy_PS_x_R_2_R::FuseCondition(const StmtPattern& upstream,
+                          const StmtPattern& downstream) {
+  return IsISPattern(upstream) && IsRPattern(downstream);
+}
+std::variant<StmtPattern, ErrorGroupPattern> StmtFusionHelper::FusePolicy_PS_x_R_2_R::MergePattern(
+    const StmtPattern& upstream, const StmtPattern& downstream) {
+  return MergePatternImpl(std::get<PS>(upstream), std::get<R>(downstream));
+}
+std::variant<StmtPattern, ErrorGroupPattern> StmtFusionHelper::FusePolicy_PS_x_R_2_R::MergePatternImpl(
+    const PS& upstream, const R& downstream) {
+  if (downstream.HasFusedInput()) {
+    return ErrorGroupPattern{
+        .ops = {downstream.reduce_op_pattern.reduce_op},
+        .error_string = "The input of reduce has been fused.",
+    };
+  }
+  R new_pattern = R(downstream);
+  new_pattern.input = upstream;
+  return StmtPattern(new_pattern);
+}
+
 StmtPattern StmtFusionHelper::ConvertToStmtPattern(const pir::Operation* op) {
   const hlir::framework::OpPatternKind kind = GetOpPatternKind(op);
   if (IsInjectiveSource(op)) {