//===- SCF.cpp - Structured Control Flow Operations -----------------------===// // // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions. // See https://llvm.org/LICENSE.txt for license information. // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception // //===----------------------------------------------------------------------===// #include "mlir/Dialect/SCF/SCF.h" #include "mlir/Dialect/StandardOps/IR/Ops.h" #include "mlir/IR/BlockAndValueMapping.h" #include "mlir/IR/PatternMatch.h" #include "mlir/Support/MathExtras.h" #include "mlir/Transforms/InliningUtils.h" using namespace mlir; using namespace mlir::scf; //===----------------------------------------------------------------------===// // SCFDialect Dialect Interfaces //===----------------------------------------------------------------------===// namespace { struct SCFInlinerInterface : public DialectInlinerInterface { using DialectInlinerInterface::DialectInlinerInterface; // We don't have any special restrictions on what can be inlined into // destination regions (e.g. while/conditional bodies). Always allow it. bool isLegalToInline(Region *dest, Region *src, bool wouldBeCloned, BlockAndValueMapping &valueMapping) const final { return true; } // Operations in scf dialect are always legal to inline since they are // pure. bool isLegalToInline(Operation *, Region *, bool, BlockAndValueMapping &) const final { return true; } // Handle the given inlined terminator by replacing it with a new operation // as necessary. Required when the region has only one block. void handleTerminator(Operation *op, ArrayRef valuesToRepl) const final { auto retValOp = dyn_cast(op); if (!retValOp) return; for (auto retValue : llvm::zip(valuesToRepl, retValOp.getOperands())) { std::get<0>(retValue).replaceAllUsesWith(std::get<1>(retValue)); } } }; } // end anonymous namespace //===----------------------------------------------------------------------===// // SCFDialect //===----------------------------------------------------------------------===// void SCFDialect::initialize() { addOperations< #define GET_OP_LIST #include "mlir/Dialect/SCF/SCFOps.cpp.inc" >(); addInterfaces(); } /// Default callback for IfOp builders. Inserts a yield without arguments. void mlir::scf::buildTerminatedBody(OpBuilder &builder, Location loc) { builder.create(loc); } //===----------------------------------------------------------------------===// // ForOp //===----------------------------------------------------------------------===// void ForOp::build(OpBuilder &builder, OperationState &result, Value lb, Value ub, Value step, ValueRange iterArgs, BodyBuilderFn bodyBuilder) { result.addOperands({lb, ub, step}); result.addOperands(iterArgs); for (Value v : iterArgs) result.addTypes(v.getType()); Region *bodyRegion = result.addRegion(); bodyRegion->push_back(new Block); Block &bodyBlock = bodyRegion->front(); bodyBlock.addArgument(builder.getIndexType()); for (Value v : iterArgs) bodyBlock.addArgument(v.getType()); // Create the default terminator if the builder is not provided and if the // iteration arguments are not provided. Otherwise, leave this to the caller // because we don't know which values to return from the loop. if (iterArgs.empty() && !bodyBuilder) { ForOp::ensureTerminator(*bodyRegion, builder, result.location); } else if (bodyBuilder) { OpBuilder::InsertionGuard guard(builder); builder.setInsertionPointToStart(&bodyBlock); bodyBuilder(builder, result.location, bodyBlock.getArgument(0), bodyBlock.getArguments().drop_front()); } } static LogicalResult verify(ForOp op) { if (auto cst = op.step().getDefiningOp()) if (cst.getValue() <= 0) return op.emitOpError("constant step operand must be positive"); // Check that the body defines as single block argument for the induction // variable. auto *body = op.getBody(); if (!body->getArgument(0).getType().isIndex()) return op.emitOpError( "expected body first argument to be an index argument for " "the induction variable"); auto opNumResults = op.getNumResults(); if (opNumResults == 0) return success(); // If ForOp defines values, check that the number and types of // the defined values match ForOp initial iter operands and backedge // basic block arguments. if (op.getNumIterOperands() != opNumResults) return op.emitOpError( "mismatch in number of loop-carried values and defined values"); if (op.getNumRegionIterArgs() != opNumResults) return op.emitOpError( "mismatch in number of basic block args and defined values"); auto iterOperands = op.getIterOperands(); auto iterArgs = op.getRegionIterArgs(); auto opResults = op.getResults(); unsigned i = 0; for (auto e : llvm::zip(iterOperands, iterArgs, opResults)) { if (std::get<0>(e).getType() != std::get<2>(e).getType()) return op.emitOpError() << "types mismatch between " << i << "th iter operand and defined value"; if (std::get<1>(e).getType() != std::get<2>(e).getType()) return op.emitOpError() << "types mismatch between " << i << "th iter region arg and defined value"; i++; } return RegionBranchOpInterface::verifyTypes(op); } /// Prints the initialization list in the form of /// (%inner = %outer, %inner2 = %outer2, <...>) /// where 'inner' values are assumed to be region arguments and 'outer' values /// are regular SSA values. static void printInitializationList(OpAsmPrinter &p, Block::BlockArgListType blocksArgs, ValueRange initializers, StringRef prefix = "") { assert(blocksArgs.size() == initializers.size() && "expected same length of arguments and initializers"); if (initializers.empty()) return; p << prefix << '('; llvm::interleaveComma(llvm::zip(blocksArgs, initializers), p, [&](auto it) { p << std::get<0>(it) << " = " << std::get<1>(it); }); p << ")"; } static void print(OpAsmPrinter &p, ForOp op) { p << op.getOperationName() << " " << op.getInductionVar() << " = " << op.lowerBound() << " to " << op.upperBound() << " step " << op.step(); printInitializationList(p, op.getRegionIterArgs(), op.getIterOperands(), " iter_args"); if (!op.getIterOperands().empty()) p << " -> (" << op.getIterOperands().getTypes() << ')'; p.printRegion(op.region(), /*printEntryBlockArgs=*/false, /*printBlockTerminators=*/op.hasIterOperands()); p.printOptionalAttrDict(op.getAttrs()); } static ParseResult parseForOp(OpAsmParser &parser, OperationState &result) { auto &builder = parser.getBuilder(); OpAsmParser::OperandType inductionVariable, lb, ub, step; // Parse the induction variable followed by '='. if (parser.parseRegionArgument(inductionVariable) || parser.parseEqual()) return failure(); // Parse loop bounds. Type indexType = builder.getIndexType(); if (parser.parseOperand(lb) || parser.resolveOperand(lb, indexType, result.operands) || parser.parseKeyword("to") || parser.parseOperand(ub) || parser.resolveOperand(ub, indexType, result.operands) || parser.parseKeyword("step") || parser.parseOperand(step) || parser.resolveOperand(step, indexType, result.operands)) return failure(); // Parse the optional initial iteration arguments. SmallVector regionArgs, operands; SmallVector argTypes; regionArgs.push_back(inductionVariable); if (succeeded(parser.parseOptionalKeyword("iter_args"))) { // Parse assignment list and results type list. if (parser.parseAssignmentList(regionArgs, operands) || parser.parseArrowTypeList(result.types)) return failure(); // Resolve input operands. for (auto operand_type : llvm::zip(operands, result.types)) if (parser.resolveOperand(std::get<0>(operand_type), std::get<1>(operand_type), result.operands)) return failure(); } // Induction variable. argTypes.push_back(indexType); // Loop carried variables argTypes.append(result.types.begin(), result.types.end()); // Parse the body region. Region *body = result.addRegion(); if (regionArgs.size() != argTypes.size()) return parser.emitError( parser.getNameLoc(), "mismatch in number of loop-carried values and defined values"); if (parser.parseRegion(*body, regionArgs, argTypes)) return failure(); ForOp::ensureTerminator(*body, builder, result.location); // Parse the optional attribute list. if (parser.parseOptionalAttrDict(result.attributes)) return failure(); return success(); } Region &ForOp::getLoopBody() { return region(); } bool ForOp::isDefinedOutsideOfLoop(Value value) { return !region().isAncestor(value.getParentRegion()); } LogicalResult ForOp::moveOutOfLoop(ArrayRef ops) { for (auto op : ops) op->moveBefore(*this); return success(); } ForOp mlir::scf::getForInductionVarOwner(Value val) { auto ivArg = val.dyn_cast(); if (!ivArg) return ForOp(); assert(ivArg.getOwner() && "unlinked block argument"); auto *containingOp = ivArg.getOwner()->getParentOp(); return dyn_cast_or_null(containingOp); } /// Return operands used when entering the region at 'index'. These operands /// correspond to the loop iterator operands, i.e., those exclusing the /// induction variable. LoopOp only has one region, so 0 is the only valid value /// for `index`. OperandRange ForOp::getSuccessorEntryOperands(unsigned index) { assert(index == 0 && "invalid region index"); // The initial operands map to the loop arguments after the induction // variable. return initArgs(); } /// Given the region at `index`, or the parent operation if `index` is None, /// return the successor regions. These are the regions that may be selected /// during the flow of control. `operands` is a set of optional attributes that /// correspond to a constant value for each operand, or null if that operand is /// not a constant. void ForOp::getSuccessorRegions(Optional index, ArrayRef operands, SmallVectorImpl ®ions) { // If the predecessor is the ForOp, branch into the body using the iterator // arguments. if (!index.hasValue()) { regions.push_back(RegionSuccessor(&getLoopBody(), getRegionIterArgs())); return; } // Otherwise, the loop may branch back to itself or the parent operation. assert(index.getValue() == 0 && "expected loop region"); regions.push_back(RegionSuccessor(&getLoopBody(), getRegionIterArgs())); regions.push_back(RegionSuccessor(getResults())); } void ForOp::getNumRegionInvocations(ArrayRef operands, SmallVectorImpl &countPerRegion) { assert(countPerRegion.empty()); countPerRegion.resize(1); auto lb = operands[0].dyn_cast_or_null(); auto ub = operands[1].dyn_cast_or_null(); auto step = operands[2].dyn_cast_or_null(); // Loop bounds are not known statically. if (!lb || !ub || !step || step.getValue().getSExtValue() == 0) { countPerRegion[0] = -1; return; } countPerRegion[0] = ceilDiv(ub.getValue().getSExtValue() - lb.getValue().getSExtValue(), step.getValue().getSExtValue()); } LoopNest mlir::scf::buildLoopNest( OpBuilder &builder, Location loc, ValueRange lbs, ValueRange ubs, ValueRange steps, ValueRange iterArgs, function_ref bodyBuilder) { assert(lbs.size() == ubs.size() && "expected the same number of lower and upper bounds"); assert(lbs.size() == steps.size() && "expected the same number of lower bounds and steps"); // If there are no bounds, call the body-building function and return early. if (lbs.empty()) { ValueVector results = bodyBuilder ? bodyBuilder(builder, loc, ValueRange(), iterArgs) : ValueVector(); assert(results.size() == iterArgs.size() && "loop nest body must return as many values as loop has iteration " "arguments"); return LoopNest(); } // First, create the loop structure iteratively using the body-builder // callback of `ForOp::build`. Do not create `YieldOp`s yet. OpBuilder::InsertionGuard guard(builder); SmallVector loops; SmallVector ivs; loops.reserve(lbs.size()); ivs.reserve(lbs.size()); ValueRange currentIterArgs = iterArgs; Location currentLoc = loc; for (unsigned i = 0, e = lbs.size(); i < e; ++i) { auto loop = builder.create( currentLoc, lbs[i], ubs[i], steps[i], currentIterArgs, [&](OpBuilder &nestedBuilder, Location nestedLoc, Value iv, ValueRange args) { ivs.push_back(iv); // It is safe to store ValueRange args because it points to block // arguments of a loop operation that we also own. currentIterArgs = args; currentLoc = nestedLoc; }); // Set the builder to point to the body of the newly created loop. We don't // do this in the callback because the builder is reset when the callback // returns. builder.setInsertionPointToStart(loop.getBody()); loops.push_back(loop); } // For all loops but the innermost, yield the results of the nested loop. for (unsigned i = 0, e = loops.size() - 1; i < e; ++i) { builder.setInsertionPointToEnd(loops[i].getBody()); builder.create(loc, loops[i + 1].getResults()); } // In the body of the innermost loop, call the body building function if any // and yield its results. builder.setInsertionPointToStart(loops.back().getBody()); ValueVector results = bodyBuilder ? bodyBuilder(builder, currentLoc, ivs, loops.back().getRegionIterArgs()) : ValueVector(); assert(results.size() == iterArgs.size() && "loop nest body must return as many values as loop has iteration " "arguments"); builder.setInsertionPointToEnd(loops.back().getBody()); builder.create(loc, results); // Return the loops. LoopNest res; res.loops.assign(loops.begin(), loops.end()); return res; } LoopNest mlir::scf::buildLoopNest( OpBuilder &builder, Location loc, ValueRange lbs, ValueRange ubs, ValueRange steps, function_ref bodyBuilder) { // Delegate to the main function by wrapping the body builder. return buildLoopNest(builder, loc, lbs, ubs, steps, llvm::None, [&bodyBuilder](OpBuilder &nestedBuilder, Location nestedLoc, ValueRange ivs, ValueRange) -> ValueVector { if (bodyBuilder) bodyBuilder(nestedBuilder, nestedLoc, ivs); return {}; }); } /// Replaces the given op with the contents of the given single-block region, /// using the operands of the block terminator to replace operation results. static void replaceOpWithRegion(PatternRewriter &rewriter, Operation *op, Region ®ion, ValueRange blockArgs = {}) { assert(llvm::hasSingleElement(region) && "expected single-region block"); Block *block = ®ion.front(); Operation *terminator = block->getTerminator(); ValueRange results = terminator->getOperands(); rewriter.mergeBlockBefore(block, op, blockArgs); rewriter.replaceOp(op, results); rewriter.eraseOp(terminator); } namespace { // Fold away ForOp iter arguments that are also yielded by the op. // These arguments must be defined outside of the ForOp region and can just be // forwarded after simplifying the op inits, yields and returns. // // The implementation uses `mergeBlockBefore` to steal the content of the // original ForOp and avoid cloning. struct ForOpIterArgsFolder : public OpRewritePattern { using OpRewritePattern::OpRewritePattern; LogicalResult matchAndRewrite(scf::ForOp forOp, PatternRewriter &rewriter) const final { bool canonicalize = false; Block &block = forOp.region().front(); auto yieldOp = cast(block.getTerminator()); // An internal flat vector of block transfer // arguments `newBlockTransferArgs` keeps the 1-1 mapping of original to // transformed block argument mappings. This plays the role of a // BlockAndValueMapping for the particular use case of calling into // `mergeBlockBefore`. SmallVector keepMask; keepMask.reserve(yieldOp.getNumOperands()); SmallVector newBlockTransferArgs, newIterArgs, newYieldValues, newResultValues; newBlockTransferArgs.reserve(1 + forOp.getNumIterOperands()); newBlockTransferArgs.push_back(Value()); // iv placeholder with null value newIterArgs.reserve(forOp.getNumIterOperands()); newYieldValues.reserve(yieldOp.getNumOperands()); newResultValues.reserve(forOp.getNumResults()); for (auto it : llvm::zip(forOp.getIterOperands(), // iter from outside forOp.getRegionIterArgs(), // iter inside region yieldOp.getOperands() // iter yield )) { // Forwarded is `true` when the region `iter` argument is yielded. bool forwarded = (std::get<1>(it) == std::get<2>(it)); keepMask.push_back(!forwarded); canonicalize |= forwarded; if (forwarded) { newBlockTransferArgs.push_back(std::get<0>(it)); newResultValues.push_back(std::get<0>(it)); continue; } newIterArgs.push_back(std::get<0>(it)); newYieldValues.push_back(std::get<2>(it)); newBlockTransferArgs.push_back(Value()); // placeholder with null value newResultValues.push_back(Value()); // placeholder with null value } if (!canonicalize) return failure(); scf::ForOp newForOp = rewriter.create( forOp.getLoc(), forOp.lowerBound(), forOp.upperBound(), forOp.step(), newIterArgs); Block &newBlock = newForOp.region().front(); // Replace the null placeholders with newly constructed values. newBlockTransferArgs[0] = newBlock.getArgument(0); // iv for (unsigned idx = 0, collapsedIdx = 0, e = newResultValues.size(); idx != e; ++idx) { Value &blockTransferArg = newBlockTransferArgs[1 + idx]; Value &newResultVal = newResultValues[idx]; assert((blockTransferArg && newResultVal) || (!blockTransferArg && !newResultVal)); if (!blockTransferArg) { blockTransferArg = newForOp.getRegionIterArgs()[collapsedIdx]; newResultVal = newForOp.getResult(collapsedIdx++); } } Block &oldBlock = forOp.region().front(); assert(oldBlock.getNumArguments() == newBlockTransferArgs.size() && "unexpected argument size mismatch"); // No results case: the scf::ForOp builder already created a zero // reult terminator. Merge before this terminator and just get rid of the // original terminator that has been merged in. if (newIterArgs.empty()) { auto newYieldOp = cast(newBlock.getTerminator()); rewriter.mergeBlockBefore(&oldBlock, newYieldOp, newBlockTransferArgs); rewriter.eraseOp(newBlock.getTerminator()->getPrevNode()); rewriter.replaceOp(forOp, newResultValues); return success(); } // No terminator case: merge and rewrite the merged terminator. auto cloneFilteredTerminator = [&](scf::YieldOp mergedTerminator) { OpBuilder::InsertionGuard g(rewriter); rewriter.setInsertionPoint(mergedTerminator); SmallVector filteredOperands; filteredOperands.reserve(newResultValues.size()); for (unsigned idx = 0, e = keepMask.size(); idx < e; ++idx) if (keepMask[idx]) filteredOperands.push_back(mergedTerminator.getOperand(idx)); rewriter.create(mergedTerminator.getLoc(), filteredOperands); }; rewriter.mergeBlocks(&oldBlock, &newBlock, newBlockTransferArgs); auto mergedYieldOp = cast(newBlock.getTerminator()); cloneFilteredTerminator(mergedYieldOp); rewriter.eraseOp(mergedYieldOp); rewriter.replaceOp(forOp, newResultValues); return success(); } }; /// Rewriting pattern that erases loops that are known not to iterate and /// replaces single-iteration loops with their bodies. struct SimplifyTrivialLoops : public OpRewritePattern { using OpRewritePattern::OpRewritePattern; LogicalResult matchAndRewrite(ForOp op, PatternRewriter &rewriter) const override { // If the upper bound is the same as the lower bound, the loop does not // iterate, just remove it. if (op.lowerBound() == op.upperBound()) { rewriter.replaceOp(op, op.getIterOperands()); return success(); } auto lb = op.lowerBound().getDefiningOp(); auto ub = op.upperBound().getDefiningOp(); if (!lb || !ub) return failure(); // If the loop is known to have 0 iterations, remove it. llvm::APInt lbValue = lb.getValue().cast().getValue(); llvm::APInt ubValue = ub.getValue().cast().getValue(); if (lbValue.sge(ubValue)) { rewriter.replaceOp(op, op.getIterOperands()); return success(); } auto step = op.step().getDefiningOp(); if (!step) return failure(); // If the loop is known to have 1 iteration, inline its body and remove the // loop. llvm::APInt stepValue = lb.getValue().cast().getValue(); if ((lbValue + stepValue).sge(ubValue)) { SmallVector blockArgs; blockArgs.reserve(op.getNumIterOperands() + 1); blockArgs.push_back(op.lowerBound()); llvm::append_range(blockArgs, op.getIterOperands()); replaceOpWithRegion(rewriter, op, op.getLoopBody(), blockArgs); return success(); } return failure(); } }; } // namespace void ForOp::getCanonicalizationPatterns(OwningRewritePatternList &results, MLIRContext *context) { results.insert(context); } //===----------------------------------------------------------------------===// // IfOp //===----------------------------------------------------------------------===// void IfOp::build(OpBuilder &builder, OperationState &result, Value cond, bool withElseRegion) { build(builder, result, /*resultTypes=*/llvm::None, cond, withElseRegion); } void IfOp::build(OpBuilder &builder, OperationState &result, TypeRange resultTypes, Value cond, bool withElseRegion) { auto addTerminator = [&](OpBuilder &nested, Location loc) { if (resultTypes.empty()) IfOp::ensureTerminator(*nested.getInsertionBlock()->getParent(), nested, loc); }; build(builder, result, resultTypes, cond, addTerminator, withElseRegion ? addTerminator : function_ref()); } void IfOp::build(OpBuilder &builder, OperationState &result, TypeRange resultTypes, Value cond, function_ref thenBuilder, function_ref elseBuilder) { assert(thenBuilder && "the builder callback for 'then' must be present"); result.addOperands(cond); result.addTypes(resultTypes); OpBuilder::InsertionGuard guard(builder); Region *thenRegion = result.addRegion(); builder.createBlock(thenRegion); thenBuilder(builder, result.location); Region *elseRegion = result.addRegion(); if (!elseBuilder) return; builder.createBlock(elseRegion); elseBuilder(builder, result.location); } void IfOp::build(OpBuilder &builder, OperationState &result, Value cond, function_ref thenBuilder, function_ref elseBuilder) { build(builder, result, TypeRange(), cond, thenBuilder, elseBuilder); } static LogicalResult verify(IfOp op) { if (op.getNumResults() != 0 && op.elseRegion().empty()) return op.emitOpError("must have an else block if defining values"); return RegionBranchOpInterface::verifyTypes(op); } static ParseResult parseIfOp(OpAsmParser &parser, OperationState &result) { // Create the regions for 'then'. result.regions.reserve(2); Region *thenRegion = result.addRegion(); Region *elseRegion = result.addRegion(); auto &builder = parser.getBuilder(); OpAsmParser::OperandType cond; Type i1Type = builder.getIntegerType(1); if (parser.parseOperand(cond) || parser.resolveOperand(cond, i1Type, result.operands)) return failure(); // Parse optional results type list. if (parser.parseOptionalArrowTypeList(result.types)) return failure(); // Parse the 'then' region. if (parser.parseRegion(*thenRegion, /*arguments=*/{}, /*argTypes=*/{})) return failure(); IfOp::ensureTerminator(*thenRegion, parser.getBuilder(), result.location); // If we find an 'else' keyword then parse the 'else' region. if (!parser.parseOptionalKeyword("else")) { if (parser.parseRegion(*elseRegion, /*arguments=*/{}, /*argTypes=*/{})) return failure(); IfOp::ensureTerminator(*elseRegion, parser.getBuilder(), result.location); } // Parse the optional attribute list. if (parser.parseOptionalAttrDict(result.attributes)) return failure(); return success(); } static void print(OpAsmPrinter &p, IfOp op) { bool printBlockTerminators = false; p << IfOp::getOperationName() << " " << op.condition(); if (!op.results().empty()) { p << " -> (" << op.getResultTypes() << ")"; // Print yield explicitly if the op defines values. printBlockTerminators = true; } p.printRegion(op.thenRegion(), /*printEntryBlockArgs=*/false, /*printBlockTerminators=*/printBlockTerminators); // Print the 'else' regions if it exists and has a block. auto &elseRegion = op.elseRegion(); if (!elseRegion.empty()) { p << " else"; p.printRegion(elseRegion, /*printEntryBlockArgs=*/false, /*printBlockTerminators=*/printBlockTerminators); } p.printOptionalAttrDict(op.getAttrs()); } /// Given the region at `index`, or the parent operation if `index` is None, /// return the successor regions. These are the regions that may be selected /// during the flow of control. `operands` is a set of optional attributes that /// correspond to a constant value for each operand, or null if that operand is /// not a constant. void IfOp::getSuccessorRegions(Optional index, ArrayRef operands, SmallVectorImpl ®ions) { // The `then` and the `else` region branch back to the parent operation. if (index.hasValue()) { regions.push_back(RegionSuccessor(getResults())); return; } // Don't consider the else region if it is empty. Region *elseRegion = &this->elseRegion(); if (elseRegion->empty()) elseRegion = nullptr; // Otherwise, the successor is dependent on the condition. bool condition; if (auto condAttr = operands.front().dyn_cast_or_null()) { condition = condAttr.getValue().isOneValue(); } else { // If the condition isn't constant, both regions may be executed. regions.push_back(RegionSuccessor(&thenRegion())); regions.push_back(RegionSuccessor(elseRegion)); return; } // Add the successor regions using the condition. regions.push_back(RegionSuccessor(condition ? &thenRegion() : elseRegion)); } namespace { // Pattern to remove unused IfOp results. struct RemoveUnusedResults : public OpRewritePattern { using OpRewritePattern::OpRewritePattern; void transferBody(Block *source, Block *dest, ArrayRef usedResults, PatternRewriter &rewriter) const { // Move all operations to the destination block. rewriter.mergeBlocks(source, dest); // Replace the yield op by one that returns only the used values. auto yieldOp = cast(dest->getTerminator()); SmallVector usedOperands; llvm::transform(usedResults, std::back_inserter(usedOperands), [&](OpResult result) { return yieldOp.getOperand(result.getResultNumber()); }); rewriter.updateRootInPlace(yieldOp, [&]() { yieldOp->setOperands(usedOperands); }); } LogicalResult matchAndRewrite(IfOp op, PatternRewriter &rewriter) const override { // Compute the list of used results. SmallVector usedResults; llvm::copy_if(op.getResults(), std::back_inserter(usedResults), [](OpResult result) { return !result.use_empty(); }); // Replace the operation if only a subset of its results have uses. if (usedResults.size() == op.getNumResults()) return failure(); // Compute the result types of the replacement operation. SmallVector newTypes; llvm::transform(usedResults, std::back_inserter(newTypes), [](OpResult result) { return result.getType(); }); // Create a replacement operation with empty then and else regions. auto emptyBuilder = [](OpBuilder &, Location) {}; auto newOp = rewriter.create(op.getLoc(), newTypes, op.condition(), emptyBuilder, emptyBuilder); // Move the bodies and replace the terminators (note there is a then and // an else region since the operation returns results). transferBody(op.getBody(0), newOp.getBody(0), usedResults, rewriter); transferBody(op.getBody(1), newOp.getBody(1), usedResults, rewriter); // Replace the operation by the new one. SmallVector repResults(op.getNumResults()); for (auto en : llvm::enumerate(usedResults)) repResults[en.value().getResultNumber()] = newOp.getResult(en.index()); rewriter.replaceOp(op, repResults); return success(); } }; struct RemoveStaticCondition : public OpRewritePattern { using OpRewritePattern::OpRewritePattern; LogicalResult matchAndRewrite(IfOp op, PatternRewriter &rewriter) const override { auto constant = op.condition().getDefiningOp(); if (!constant) return failure(); if (constant.getValue().cast().getValue()) replaceOpWithRegion(rewriter, op, op.thenRegion()); else if (!op.elseRegion().empty()) replaceOpWithRegion(rewriter, op, op.elseRegion()); else rewriter.eraseOp(op); return success(); } }; } // namespace void IfOp::getCanonicalizationPatterns(OwningRewritePatternList &results, MLIRContext *context) { results.insert(context); } //===----------------------------------------------------------------------===// // ParallelOp //===----------------------------------------------------------------------===// void ParallelOp::build( OpBuilder &builder, OperationState &result, ValueRange lowerBounds, ValueRange upperBounds, ValueRange steps, ValueRange initVals, function_ref bodyBuilderFn) { result.addOperands(lowerBounds); result.addOperands(upperBounds); result.addOperands(steps); result.addOperands(initVals); result.addAttribute( ParallelOp::getOperandSegmentSizeAttr(), builder.getI32VectorAttr({static_cast(lowerBounds.size()), static_cast(upperBounds.size()), static_cast(steps.size()), static_cast(initVals.size())})); result.addTypes(initVals.getTypes()); OpBuilder::InsertionGuard guard(builder); unsigned numIVs = steps.size(); SmallVector argTypes(numIVs, builder.getIndexType()); Region *bodyRegion = result.addRegion(); Block *bodyBlock = builder.createBlock(bodyRegion, {}, argTypes); if (bodyBuilderFn) { builder.setInsertionPointToStart(bodyBlock); bodyBuilderFn(builder, result.location, bodyBlock->getArguments().take_front(numIVs), bodyBlock->getArguments().drop_front(numIVs)); } ParallelOp::ensureTerminator(*bodyRegion, builder, result.location); } void ParallelOp::build( OpBuilder &builder, OperationState &result, ValueRange lowerBounds, ValueRange upperBounds, ValueRange steps, function_ref bodyBuilderFn) { // Only pass a non-null wrapper if bodyBuilderFn is non-null itself. Make sure // we don't capture a reference to a temporary by constructing the lambda at // function level. auto wrappedBuilderFn = [&bodyBuilderFn](OpBuilder &nestedBuilder, Location nestedLoc, ValueRange ivs, ValueRange) { bodyBuilderFn(nestedBuilder, nestedLoc, ivs); }; function_ref wrapper; if (bodyBuilderFn) wrapper = wrappedBuilderFn; build(builder, result, lowerBounds, upperBounds, steps, ValueRange(), wrapper); } static LogicalResult verify(ParallelOp op) { // Check that there is at least one value in lowerBound, upperBound and step. // It is sufficient to test only step, because it is ensured already that the // number of elements in lowerBound, upperBound and step are the same. Operation::operand_range stepValues = op.step(); if (stepValues.empty()) return op.emitOpError( "needs at least one tuple element for lowerBound, upperBound and step"); // Check whether all constant step values are positive. for (Value stepValue : stepValues) if (auto cst = stepValue.getDefiningOp()) if (cst.getValue() <= 0) return op.emitOpError("constant step operand must be positive"); // Check that the body defines the same number of block arguments as the // number of tuple elements in step. Block *body = op.getBody(); if (body->getNumArguments() != stepValues.size()) return op.emitOpError() << "expects the same number of induction variables: " << body->getNumArguments() << " as bound and step values: " << stepValues.size(); for (auto arg : body->getArguments()) if (!arg.getType().isIndex()) return op.emitOpError( "expects arguments for the induction variable to be of index type"); // Check that the yield has no results Operation *yield = body->getTerminator(); if (yield->getNumOperands() != 0) return yield->emitOpError() << "not allowed to have operands inside '" << ParallelOp::getOperationName() << "'"; // Check that the number of results is the same as the number of ReduceOps. SmallVector reductions(body->getOps()); auto resultsSize = op.results().size(); auto reductionsSize = reductions.size(); auto initValsSize = op.initVals().size(); if (resultsSize != reductionsSize) return op.emitOpError() << "expects number of results: " << resultsSize << " to be the same as number of reductions: " << reductionsSize; if (resultsSize != initValsSize) return op.emitOpError() << "expects number of results: " << resultsSize << " to be the same as number of initial values: " << initValsSize; // Check that the types of the results and reductions are the same. for (auto resultAndReduce : llvm::zip(op.results(), reductions)) { auto resultType = std::get<0>(resultAndReduce).getType(); auto reduceOp = std::get<1>(resultAndReduce); auto reduceType = reduceOp.operand().getType(); if (resultType != reduceType) return reduceOp.emitOpError() << "expects type of reduce: " << reduceType << " to be the same as result type: " << resultType; } return success(); } static ParseResult parseParallelOp(OpAsmParser &parser, OperationState &result) { auto &builder = parser.getBuilder(); // Parse an opening `(` followed by induction variables followed by `)` SmallVector ivs; if (parser.parseRegionArgumentList(ivs, /*requiredOperandCount=*/-1, OpAsmParser::Delimiter::Paren)) return failure(); // Parse loop bounds. SmallVector lower; if (parser.parseEqual() || parser.parseOperandList(lower, ivs.size(), OpAsmParser::Delimiter::Paren) || parser.resolveOperands(lower, builder.getIndexType(), result.operands)) return failure(); SmallVector upper; if (parser.parseKeyword("to") || parser.parseOperandList(upper, ivs.size(), OpAsmParser::Delimiter::Paren) || parser.resolveOperands(upper, builder.getIndexType(), result.operands)) return failure(); // Parse step values. SmallVector steps; if (parser.parseKeyword("step") || parser.parseOperandList(steps, ivs.size(), OpAsmParser::Delimiter::Paren) || parser.resolveOperands(steps, builder.getIndexType(), result.operands)) return failure(); // Parse init values. SmallVector initVals; if (succeeded(parser.parseOptionalKeyword("init"))) { if (parser.parseOperandList(initVals, /*requiredOperandCount=*/-1, OpAsmParser::Delimiter::Paren)) return failure(); } // Parse optional results in case there is a reduce. if (parser.parseOptionalArrowTypeList(result.types)) return failure(); // Now parse the body. Region *body = result.addRegion(); SmallVector types(ivs.size(), builder.getIndexType()); if (parser.parseRegion(*body, ivs, types)) return failure(); // Set `operand_segment_sizes` attribute. result.addAttribute( ParallelOp::getOperandSegmentSizeAttr(), builder.getI32VectorAttr({static_cast(lower.size()), static_cast(upper.size()), static_cast(steps.size()), static_cast(initVals.size())})); // Parse attributes. if (parser.parseOptionalAttrDict(result.attributes)) return failure(); if (!initVals.empty()) parser.resolveOperands(initVals, result.types, parser.getNameLoc(), result.operands); // Add a terminator if none was parsed. ForOp::ensureTerminator(*body, builder, result.location); return success(); } static void print(OpAsmPrinter &p, ParallelOp op) { p << op.getOperationName() << " (" << op.getBody()->getArguments() << ") = (" << op.lowerBound() << ") to (" << op.upperBound() << ") step (" << op.step() << ")"; if (!op.initVals().empty()) p << " init (" << op.initVals() << ")"; p.printOptionalArrowTypeList(op.getResultTypes()); p.printRegion(op.region(), /*printEntryBlockArgs=*/false); p.printOptionalAttrDict( op.getAttrs(), /*elidedAttrs=*/ParallelOp::getOperandSegmentSizeAttr()); } Region &ParallelOp::getLoopBody() { return region(); } bool ParallelOp::isDefinedOutsideOfLoop(Value value) { return !region().isAncestor(value.getParentRegion()); } LogicalResult ParallelOp::moveOutOfLoop(ArrayRef ops) { for (auto op : ops) op->moveBefore(*this); return success(); } ParallelOp mlir::scf::getParallelForInductionVarOwner(Value val) { auto ivArg = val.dyn_cast(); if (!ivArg) return ParallelOp(); assert(ivArg.getOwner() && "unlinked block argument"); auto *containingOp = ivArg.getOwner()->getParentOp(); return dyn_cast(containingOp); } namespace { // Collapse loop dimensions that perform a single iteration. struct CollapseSingleIterationLoops : public OpRewritePattern { using OpRewritePattern::OpRewritePattern; LogicalResult matchAndRewrite(ParallelOp op, PatternRewriter &rewriter) const override { BlockAndValueMapping mapping; // Compute new loop bounds that omit all single-iteration loop dimensions. SmallVector newLowerBounds; SmallVector newUpperBounds; SmallVector newSteps; newLowerBounds.reserve(op.lowerBound().size()); newUpperBounds.reserve(op.upperBound().size()); newSteps.reserve(op.step().size()); for (auto dim : llvm::zip(op.lowerBound(), op.upperBound(), op.step(), op.getInductionVars())) { Value lowerBound, upperBound, step, iv; std::tie(lowerBound, upperBound, step, iv) = dim; // Collect the statically known loop bounds. auto lowerBoundConstant = dyn_cast_or_null(lowerBound.getDefiningOp()); auto upperBoundConstant = dyn_cast_or_null(upperBound.getDefiningOp()); auto stepConstant = dyn_cast_or_null(step.getDefiningOp()); // Replace the loop induction variable by the lower bound if the loop // performs a single iteration. Otherwise, copy the loop bounds. if (lowerBoundConstant && upperBoundConstant && stepConstant && (upperBoundConstant.getValue() - lowerBoundConstant.getValue()) > 0 && (upperBoundConstant.getValue() - lowerBoundConstant.getValue()) <= stepConstant.getValue()) { mapping.map(iv, lowerBound); } else { newLowerBounds.push_back(lowerBound); newUpperBounds.push_back(upperBound); newSteps.push_back(step); } } // Exit if all or none of the loop dimensions perform a single iteration. if (newLowerBounds.size() == 0 || newLowerBounds.size() == op.lowerBound().size()) return failure(); // Replace the parallel loop by lower-dimensional parallel loop. auto newOp = rewriter.create(op.getLoc(), newLowerBounds, newUpperBounds, newSteps, op.initVals(), nullptr); // Clone the loop body and remap the block arguments of the collapsed loops // (inlining does not support a cancellable block argument mapping). rewriter.cloneRegionBefore(op.region(), newOp.region(), newOp.region().begin(), mapping); rewriter.replaceOp(op, newOp.getResults()); return success(); } }; /// Removes parallel loops in which at least one lower/upper bound pair consists /// of the same values - such loops have an empty iteration domain. struct RemoveEmptyParallelLoops : public OpRewritePattern { using OpRewritePattern::OpRewritePattern; LogicalResult matchAndRewrite(ParallelOp op, PatternRewriter &rewriter) const override { for (auto dim : llvm::zip(op.lowerBound(), op.upperBound())) { if (std::get<0>(dim) == std::get<1>(dim)) { rewriter.replaceOp(op, op.initVals()); return success(); } } return failure(); } }; } // namespace void ParallelOp::getCanonicalizationPatterns(OwningRewritePatternList &results, MLIRContext *context) { results.insert( context); } //===----------------------------------------------------------------------===// // ReduceOp //===----------------------------------------------------------------------===// void ReduceOp::build( OpBuilder &builder, OperationState &result, Value operand, function_ref bodyBuilderFn) { auto type = operand.getType(); result.addOperands(operand); OpBuilder::InsertionGuard guard(builder); Region *bodyRegion = result.addRegion(); Block *body = builder.createBlock(bodyRegion, {}, ArrayRef{type, type}); if (bodyBuilderFn) bodyBuilderFn(builder, result.location, body->getArgument(0), body->getArgument(1)); } static LogicalResult verify(ReduceOp op) { // The region of a ReduceOp has two arguments of the same type as its operand. auto type = op.operand().getType(); Block &block = op.reductionOperator().front(); if (block.empty()) return op.emitOpError("the block inside reduce should not be empty"); if (block.getNumArguments() != 2 || llvm::any_of(block.getArguments(), [&](const BlockArgument &arg) { return arg.getType() != type; })) return op.emitOpError() << "expects two arguments to reduce block of type " << type; // Check that the block is terminated by a ReduceReturnOp. if (!isa(block.getTerminator())) return op.emitOpError("the block inside reduce should be terminated with a " "'scf.reduce.return' op"); return success(); } static ParseResult parseReduceOp(OpAsmParser &parser, OperationState &result) { // Parse an opening `(` followed by the reduced value followed by `)` OpAsmParser::OperandType operand; if (parser.parseLParen() || parser.parseOperand(operand) || parser.parseRParen()) return failure(); Type resultType; // Parse the type of the operand (and also what reduce computes on). if (parser.parseColonType(resultType) || parser.resolveOperand(operand, resultType, result.operands)) return failure(); // Now parse the body. Region *body = result.addRegion(); if (parser.parseRegion(*body, /*arguments=*/{}, /*argTypes=*/{})) return failure(); return success(); } static void print(OpAsmPrinter &p, ReduceOp op) { p << op.getOperationName() << "(" << op.operand() << ") "; p << " : " << op.operand().getType(); p.printRegion(op.reductionOperator()); } //===----------------------------------------------------------------------===// // ReduceReturnOp //===----------------------------------------------------------------------===// static LogicalResult verify(ReduceReturnOp op) { // The type of the return value should be the same type as the type of the // operand of the enclosing ReduceOp. auto reduceOp = cast(op->getParentOp()); Type reduceType = reduceOp.operand().getType(); if (reduceType != op.result().getType()) return op.emitOpError() << "needs to have type " << reduceType << " (the type of the enclosing ReduceOp)"; return success(); } //===----------------------------------------------------------------------===// // WhileOp //===----------------------------------------------------------------------===// OperandRange WhileOp::getSuccessorEntryOperands(unsigned index) { assert(index == 0 && "WhileOp is expected to branch only to the first region"); return inits(); } void WhileOp::getSuccessorRegions(Optional index, ArrayRef operands, SmallVectorImpl ®ions) { (void)operands; if (!index.hasValue()) { regions.emplace_back(&before(), before().getArguments()); return; } assert(*index < 2 && "there are only two regions in a WhileOp"); if (*index == 0) { regions.emplace_back(&after(), after().getArguments()); regions.emplace_back(getResults()); return; } regions.emplace_back(&before(), before().getArguments()); } /// Parses a `while` op. /// /// op ::= `scf.while` assignments `:` function-type region `do` region /// `attributes` attribute-dict /// initializer ::= /* empty */ | `(` assignment-list `)` /// assignment-list ::= assignment | assignment `,` assignment-list /// assignment ::= ssa-value `=` ssa-value static ParseResult parseWhileOp(OpAsmParser &parser, OperationState &result) { SmallVector regionArgs, operands; Region *before = result.addRegion(); Region *after = result.addRegion(); OptionalParseResult listResult = parser.parseOptionalAssignmentList(regionArgs, operands); if (listResult.hasValue() && failed(listResult.getValue())) return failure(); FunctionType functionType; llvm::SMLoc typeLoc = parser.getCurrentLocation(); if (failed(parser.parseColonType(functionType))) return failure(); result.addTypes(functionType.getResults()); if (functionType.getNumInputs() != operands.size()) { return parser.emitError(typeLoc) << "expected as many input types as operands " << "(expected " << operands.size() << " got " << functionType.getNumInputs() << ")"; } // Resolve input operands. if (failed(parser.resolveOperands(operands, functionType.getInputs(), parser.getCurrentLocation(), result.operands))) return failure(); return failure( parser.parseRegion(*before, regionArgs, functionType.getInputs()) || parser.parseKeyword("do") || parser.parseRegion(*after) || parser.parseOptionalAttrDictWithKeyword(result.attributes)); } /// Prints a `while` op. static void print(OpAsmPrinter &p, scf::WhileOp op) { p << op.getOperationName(); printInitializationList(p, op.before().front().getArguments(), op.inits(), " "); p << " : "; p.printFunctionalType(op.inits().getTypes(), op.results().getTypes()); p.printRegion(op.before(), /*printEntryBlockArgs=*/false); p << " do"; p.printRegion(op.after()); p.printOptionalAttrDictWithKeyword(op.getAttrs()); } /// Verifies that two ranges of types match, i.e. have the same number of /// entries and that types are pairwise equals. Reports errors on the given /// operation in case of mismatch. template static LogicalResult verifyTypeRangesMatch(OpTy op, TypeRange left, TypeRange right, StringRef message) { if (left.size() != right.size()) return op.emitOpError("expects the same number of ") << message; for (unsigned i = 0, e = left.size(); i < e; ++i) { if (left[i] != right[i]) { InFlightDiagnostic diag = op.emitOpError("expects the same types for ") << message; diag.attachNote() << "for argument " << i << ", found " << left[i] << " and " << right[i]; return diag; } } return success(); } /// Verifies that the first block of the given `region` is terminated by a /// YieldOp. Reports errors on the given operation if it is not the case. template static TerminatorTy verifyAndGetTerminator(scf::WhileOp op, Region ®ion, StringRef errorMessage) { Operation *terminatorOperation = region.front().getTerminator(); if (auto yield = dyn_cast_or_null(terminatorOperation)) return yield; auto diag = op.emitOpError(errorMessage); if (terminatorOperation) diag.attachNote(terminatorOperation->getLoc()) << "terminator here"; return nullptr; } static LogicalResult verify(scf::WhileOp op) { if (failed(RegionBranchOpInterface::verifyTypes(op))) return failure(); auto beforeTerminator = verifyAndGetTerminator( op, op.before(), "expects the 'before' region to terminate with 'scf.condition'"); if (!beforeTerminator) return failure(); TypeRange trailingTerminatorOperands = beforeTerminator.args().getTypes(); if (failed(verifyTypeRangesMatch(op, trailingTerminatorOperands, op.after().getArgumentTypes(), "trailing operands of the 'before' block " "terminator and 'after' region arguments"))) return failure(); if (failed(verifyTypeRangesMatch( op, trailingTerminatorOperands, op.getResultTypes(), "trailing operands of the 'before' block terminator and op results"))) return failure(); auto afterTerminator = verifyAndGetTerminator( op, op.after(), "expects the 'after' region to terminate with 'scf.yield'"); return success(afterTerminator != nullptr); } //===----------------------------------------------------------------------===// // YieldOp //===----------------------------------------------------------------------===// static ParseResult parseYieldOp(OpAsmParser &parser, OperationState &result) { SmallVector operands; SmallVector types; llvm::SMLoc loc = parser.getCurrentLocation(); // Parse variadic operands list, their types, and resolve operands to SSA // values. if (parser.parseOperandList(operands) || parser.parseOptionalColonTypeList(types) || parser.resolveOperands(operands, types, loc, result.operands)) return failure(); return success(); } static void print(OpAsmPrinter &p, scf::YieldOp op) { p << op.getOperationName(); if (op.getNumOperands() != 0) p << ' ' << op.getOperands() << " : " << op.getOperandTypes(); } //===----------------------------------------------------------------------===// // TableGen'd op method definitions //===----------------------------------------------------------------------===// #define GET_OP_CLASSES #include "mlir/Dialect/SCF/SCFOps.cpp.inc"