/* Copyright 2019 The TensorFlow Authors. All Rights Reserved. Licensed 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. ==============================================================================*/ // This file implements logic for lowering HLO/LHLO dialect to Linalg dialect. #include #include "llvm/ADT/STLExtras.h" #include "llvm/ADT/SetVector.h" #include "mlir-hlo/Dialect/mhlo/IR/hlo_ops.h" #include "mlir-hlo/Dialect/mhlo/IR/lhlo_ops.h" #include "mlir-hlo/Dialect/mhlo/transforms/map_lmhlo_to_scalar_op.h" #include "mlir-hlo/Dialect/mhlo/transforms/rewriters.h" #include "mlir/Dialect/Affine/IR/AffineOps.h" #include "mlir/Dialect/Linalg/IR/LinalgOps.h" #include "mlir/Dialect/Linalg/IR/LinalgTypes.h" #include "mlir/Dialect/Math/IR/Math.h" #include "mlir/Dialect/SCF/SCF.h" #include "mlir/Dialect/StandardOps/IR/Ops.h" #include "mlir/Dialect/Tensor/IR/Tensor.h" #include "mlir/IR/AffineExpr.h" #include "mlir/IR/Attributes.h" #include "mlir/IR/Builders.h" #include "mlir/IR/BuiltinOps.h" #include "mlir/IR/BuiltinTypes.h" #include "mlir/IR/Location.h" #include "mlir/IR/MLIRContext.h" #include "mlir/IR/Matchers.h" #include "mlir/IR/Operation.h" #include "mlir/IR/OperationSupport.h" #include "mlir/IR/PatternMatch.h" #include "mlir/IR/TypeUtilities.h" #include "mlir/Pass/Pass.h" #include "mlir/Pass/PassManager.h" #include "mlir/Support/LogicalResult.h" #include "mlir/Transforms/DialectConversion.h" namespace mlir { namespace { /// Returns an ArrayAttr that contains `nLoops` attributes. All the attributes /// are "parallel" except the last `nReduction` elements, where are "reduction" /// attributes. SmallVector GetParallelAndReductionIterators( unsigned nLoops, unsigned nReduction) { SmallVector res(nLoops - nReduction, getParallelIteratorTypeName()); res.append(nReduction, getReductionIteratorTypeName()); return res; } SmallVector GetNParallelLoopsAttrs(unsigned nParallelLoops) { return GetParallelAndReductionIterators(nParallelLoops, 0); } template Value GetResultValue(Operation* op) { return isLHLO ? op->getOperand(op->getNumOperands() - 1) : op->getResult(0); } template ShapedType GetHloOpResultType(Operation* op) { return GetResultValue(op).getType().template cast(); } template bool VerifyHloOpBufferOrTensorSemantics(Operation* op) { auto verify_type = [&](Value val) -> bool { return (isLHLO && val.getType().isa()) || (!isLHLO && val.getType().isa()); }; if (!llvm::all_of(op->getOperands(), verify_type)) return false; return isLHLO ? op->getResults().empty() : llvm::all_of(op->getResults(), verify_type); } Value GetInitTensor(OpBuilder& b, Location loc, ShapedType type, ArrayRef dyn_sizes) { return b.create(loc, dyn_sizes, type.getShape(), type.getElementType()); } SmallVector ExtractDynamicSizes(OpBuilder& b, Location loc, Value tensor) { auto tensor_type = tensor.getType().dyn_cast(); if (!tensor_type) return {}; SmallVector dyn_sizes; for (auto& en : llvm::enumerate(tensor_type.getShape())) { if (en.value() != ShapedType::kDynamicSize) continue; dyn_sizes.push_back(b.create(loc, tensor, en.index())); } return dyn_sizes; } SmallVector Extract1DVector(DenseIntElementsAttr elements) { SmallVector ret; for (const APInt& element : elements) { ret.push_back(element.getLimitedValue()); } return ret; } /// Returns the constant value associated with the init value if the defining /// operation is a constant. Attribute GetInitValueAsConst(Value init) { DenseElementsAttr attr; if (!matchPattern(init, m_Constant(&attr))) return {}; auto type = attr.getType().dyn_cast(); if (!type || type.getRank() != 0) return {}; return attr.getValue({}); } /// Returns a permutation AffineMap that puts all reduction dimensions to the /// last. The order of parallel loops and reduction loops are all sorted. E.g., /// if `rank` is 4 and `reductionDims` is {1, 3}, then /// "(d0, d1, d2, d3) -> (d0, d2, d1, d3)" is used. The inverse permutation of /// the AffineMap is returned. AffineMap GetTransposeMapForReduction(MLIRContext* context, int rank, ArrayRef reduction_dims) { llvm::SmallSetVector s; for (auto dim : reduction_dims) s.insert(dim); SmallVector permutation; for (int i = 0; i < rank; ++i) if (!s.count(i)) permutation.push_back(i); for (auto dim : reduction_dims) permutation.push_back(dim); auto map = AffineMap::getPermutationMap(permutation, context); return inversePermutation(map); } template class PointwiseToLinalgConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { auto loc = op.getLoc(); ShapedType t0 = args[0].getType().template dyn_cast(); if (!t0) return failure(); unsigned nloops = t0.getRank(); auto fail = [&](ShapedType t) { return !t || !t.hasRank() || t.getRank() != nloops || !(t.getElementType().isSignlessIntOrFloat() || t.getElementType().isa()); }; if (llvm::any_of(args, [&](Value v) { return fail(v.getType().dyn_cast()); }) || llvm::any_of(op.getOperation()->getResultTypes(), [&](Type t) { return fail(t.dyn_cast()); })) return emitError(loc, "lhlo to linalg conversion expects ranked args of " "signless int, float or complex element type with ") << nloops << " parallel iterators: " << *(op.getOperation()); // Construct the indexing maps needed for linalg.generic ops. SmallVector body_arg_types, body_result_types, op_result_types; // This doesnt account for implicit broadcast, but the working assumption // in HLO/LHLO is that are broadcasts are made explicit. if (isLHLO && !nloops) return failure(); int num_inputs = (isLHLO ? args.size() - 1 : args.size()); ValueRange inputs(args.take_front(num_inputs)); for (Value in : inputs) body_arg_types.emplace_back(getElementTypeOrSelf(in.getType())); SmallVector output_buffers; if (isLHLO) { output_buffers.append(args.begin() + num_inputs, args.end()); } else { Value result = op.getOperation()->getResult(0); ShapedType result_type = result.getType().template cast(); auto dyn_sizes = ExtractDynamicSizes(rewriter, loc, args[0]); output_buffers.push_back( GetInitTensor(rewriter, loc, result_type, dyn_sizes)); op_result_types.push_back(result.getType()); } body_result_types = llvm::to_vector<4>(llvm::map_range( output_buffers, [](Value v) { return getElementTypeOrSelf(v); })); AffineMap common_indexing_map = nloops ? rewriter.getMultiDimIdentityMap(nloops) : AffineMap::get(nloops, 0, rewriter.getContext()); SmallVector indexing_maps(args.size() + (isLHLO ? 0 : 1), common_indexing_map); bool failed = false; auto linalg_op = rewriter.create( loc, op_result_types, inputs, output_buffers, indexing_maps, GetNParallelLoopsAttrs(nloops), [&](OpBuilder& nested_builder, Location nested_loc, ValueRange args) { // TODO(ravishankarm) : For now use the method in lmhlo namespace. // That method needs to be moved out of there. Value op_result = lmhlo::HloOpToStdScalarOp::map( op, body_result_types, llvm::to_vector<2>(args.take_front(inputs.size())), &rewriter); if (op_result == nullptr) { failed = true; } else { nested_builder.create(loc, op_result); } }); if (failed) return failure(); rewriter.replaceOp(op, linalg_op.getOperation()->getResults()); return success(); } }; template class ScalarPointwiseToStandardConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( LhloOp lhlo_op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { auto loc = lhlo_op.getLoc(); auto arg_type = lhlo_op.getOperand(0).getType().template dyn_cast(); if (!arg_type || !arg_type.getElementType().isSignlessIntOrFloat() || (arg_type.getRank() != 0)) { return failure(); } // Create two loads from the input. auto lhs = rewriter.create(loc, lhlo_op.lhs()); auto rhs = rewriter.create(loc, lhlo_op.rhs()); // TODO(ravishankarm) : Move this method out of lmhlo namespace. Value op_result = lmhlo::HloOpToStdScalarOp::map( lhlo_op, arg_type.getElementType(), llvm::ArrayRef{lhs, rhs}, &rewriter); rewriter.create(loc, op_result, lhlo_op.out()); rewriter.eraseOp(lhlo_op); return success(); } }; //===----------------------------------------------------------------------===// // lmhlo.convolution conversion pattern. //===----------------------------------------------------------------------===// /// Converts lmhlo.convolution operation to a linalg.conv op. struct ConvToLinalgConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; // This code has been adapted from IREE's // (https://github.com/google/iree/) mhlo -> linalg conversion. LogicalResult matchAndRewrite( lmhlo::ConvOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { // Check validity of dimension information. if (const mhlo::ConvDimensionNumbers& dimension_numbers = op.dimension_numbers()) { const int input_spatial_rank = llvm::size(dimension_numbers.input_spatial_dimensions()); // The dimensions for input should follow the order of // batch_count, spatial_dims..., input_feature_count. if (dimension_numbers.input_batch_dimension().getInt() != 0 || dimension_numbers.input_feature_dimension().getInt() != (input_spatial_rank + 1)) return failure(); const int kernel_spatial_rank = llvm::size(dimension_numbers.kernel_spatial_dimensions()); // The dimensions for filter should follow the order of // spatial_dims..., input_feature_count, num_output_feature_count. if (dimension_numbers.kernel_input_feature_dimension().getInt() != kernel_spatial_rank || dimension_numbers.kernel_output_feature_dimension().getInt() != (kernel_spatial_rank + 1)) return failure(); const int output_spatial_rank = llvm::size(dimension_numbers.output_spatial_dimensions()); // The dimensions for output should follow the order of // batch_count, spatial_dims.., output_feature_count. if (dimension_numbers.output_batch_dimension().getInt() != 0 || dimension_numbers.output_feature_dimension().getInt() != (output_spatial_rank + 1)) return failure(); if (input_spatial_rank != output_spatial_rank || input_spatial_rank != kernel_spatial_rank) return failure(); auto input_spatial_dim = dimension_numbers.input_spatial_dimensions().begin(); auto kernel_spatial_dim = dimension_numbers.kernel_spatial_dimensions().begin(); auto output_spatial_dim = dimension_numbers.output_spatial_dimensions().begin(); // Check if spatial dims are ordered correctly. for (int i = 0; i < input_spatial_rank; ++i) { const int dim = i + 1; if ((*input_spatial_dim++).getZExtValue() != dim || (*output_spatial_dim++).getZExtValue() != dim || (*kernel_spatial_dim++).getZExtValue() != i) return failure(); } } // TODO: LHS dilation for deconvolution not supported yet. // TODO(jurahul): Window reversal is not supported yet. if (op.lhs_dilation() || op.hasWindowReversal()) { return failure(); } llvm::SmallVector strides; if (auto window_strides = op.window_strides()) { auto range = window_strides->getAttributeValues(); strides.assign(range.begin(), range.end()); } auto strides_arg = ArrayAttr::get(op.getContext(), strides); llvm::SmallVector dilation; if (auto rhs_dilation = op.rhs_dilation()) { auto range = rhs_dilation->getAttributeValues(); dilation.assign(range.begin(), range.end()); } else { // Default dilation of 1. dilation.resize(2, IntegerAttr::get(rewriter.getIntegerType(64), 1)); } auto dilation_arg = ArrayAttr::get(op.getContext(), dilation); // Set padding only if it is non-zero. DenseIntElementsAttr padding = op.paddingAttr(); if (!padding || !llvm::any_of(padding.getValues(), [](APInt int_val) { return !int_val.isNullValue(); })) { padding = nullptr; } // The order of input and filter are switched with linalg.conv. rewriter.replaceOpWithNewOp( op, args[1], args[0], args[2], strides_arg, dilation_arg, padding); return success(); } }; /// Base class for lowering HLO operations that have one operand and one result, /// and are semantically equivalent to a copy of the input to the output (like /// transpose, some reshape, etc.). The derived classes need to provide a method /// `getIndexingMaps` that returns AffineMaps for the index maps of the input /// and the output. template class DataMovementOpConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { if (!VerifyHloOpBufferOrTensorSemantics(op)) return failure(); auto result_type = GetHloOpResultType(op); SmallVector indexing_maps = Derived::getIndexingMaps(op, &rewriter); if (indexing_maps.empty()) return failure(); auto nloops = result_type.getRank(); auto loc = op.getLoc(); // TODO(pifon): technically, the op itself could have size operands (e.g. // broadcast into a dynamic dimension).Handle this case. auto dyn_sizes = isLHLO ? SmallVector() : ExtractDynamicSizes(rewriter, loc, args[0]); auto linalg_op = rewriter.create( loc, /*resultTensorTypes=*/isLHLO ? ArrayRef{} : result_type, /*inputs=*/args.front(), /*outputBuffers=*/ isLHLO ? ValueRange{args.back()} : ValueRange{GetInitTensor(rewriter, loc, result_type, dyn_sizes)}, indexing_maps, GetNParallelLoopsAttrs(nloops), [&](OpBuilder& nested_builder, Location nested_loc, ValueRange args) { nested_builder.create(loc, *args.begin()); }); rewriter.replaceOp(op, linalg_op.getOperation()->getResults()); return success(); } }; /// Pattern to convert BroadcastOp to Linalg ops. template class BroadcastConverter : public DataMovementOpConverter, OpTy, isLHLO> { public: using DataMovementOpConverter::DataMovementOpConverter; static SmallVector getIndexingMaps(OpTy broadcast_op, Builder* b) { ShapedType input_type = broadcast_op.operand().getType().template cast(); unsigned input_rank = input_type.getRank(); unsigned nloops = GetHloOpResultType(broadcast_op).getRank(); // BroadcastOp prepends the dimensions in the `broadcast_sizes` attribute to // the input's dimensions. unsigned num_prepended_dims = llvm::size(broadcast_op.broadcast_sizes()); SmallVector input_dim_exprs; input_dim_exprs.reserve(input_rank); for (int i = 0; i < input_rank; ++i) { input_dim_exprs.push_back(b->getAffineDimExpr(num_prepended_dims + i)); } AffineMap input_map; MLIRContext* context = b->getContext(); if (input_dim_exprs.empty()) { // The input is a scalar, i.e. this is a scalar broadcast op. input_map = AffineMap::get(nloops, /*symbolCount=*/0, context); } else { input_map = AffineMap::get(nloops, /*symbolCount=*/0, input_dim_exprs, context); } return {input_map, b->getMultiDimIdentityMap(nloops)}; } }; class HloBroadcastInDimConverter : public DataMovementOpConverter { public: using DataMovementOpConverter::DataMovementOpConverter; static SmallVector getIndexingMaps( mhlo::BroadcastInDimOp broadcast_op, Builder* b) { auto result_type = GetHloOpResultType(broadcast_op); auto operand_type = broadcast_op.operand().getType().template cast(); unsigned nloops = result_type.getRank(); // The input is a scalar, i.e. this is a scalar broadcast op. if (operand_type.getRank() == 0) { return {AffineMap::get(nloops, /*symbolCount=*/0, b->getContext()), b->getMultiDimIdentityMap(nloops)}; } auto operand_shape = operand_type.getShape(); SmallVector dim_exprs; dim_exprs.reserve(nloops); if (broadcast_op.broadcast_dimensions()) { for (const auto& broadcastDim : enumerate(broadcast_op.broadcast_dimensions().getIntValues())) { int size = broadcastDim.value().getSExtValue(); bool expansion_needed = operand_shape[broadcastDim.index()] == 1 && result_type.getShape()[size] != 1; dim_exprs.push_back(expansion_needed ? b->getAffineConstantExpr(0) : b->getAffineDimExpr(size)); } } return { AffineMap::get(nloops, /*symbolCount=*/0, dim_exprs, b->getContext()), b->getMultiDimIdentityMap(nloops)}; } }; class HloDynamicBroadcastInDimConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( mhlo::DynamicBroadcastInDimOp op, ArrayRef operands, ConversionPatternRewriter& rewriter) const final { // Convert only if the producer is an HLO constant. Ideally the pattern // (`mhlo.constant` -> `mhlo.dynamic_broadcast_in_dim`) should be converted // to an Tensor-dialect op similar to TF ConstantLikeOp. if (!op.operand().getDefiningOp()) return failure(); mhlo::DynamicBroadcastInDimOp::Adaptor adaptor(op); Value operand = adaptor.operand(); auto operand_type = operand.getType().dyn_cast(); if (!operand_type || operand_type.getRank() != 0) return failure(); Value shape = adaptor.output_dimensions(); auto shape_type = shape.getType().cast(); int64_t result_rank = shape_type.getDimSize(0); SmallVector dyn_dims; Location loc = op.getLoc(); for (int i = 0; i < result_rank; ++i) { Value index = rewriter.create(loc, i); dyn_dims.push_back(rewriter.create(loc, shape, index)); } auto result_type = op.getType().dyn_cast(); if (!result_type) return failure(); int64_t nloops = result_type.getRank(); Value init = rewriter.create( loc, dyn_dims, result_type.getShape(), result_type.getElementType()); Operation* generic = rewriter.create( loc, TypeRange{init.getType()}, ValueRange{operand}, /*outputBuffers=*/ValueRange{init}, llvm::makeArrayRef( {AffineMap::get(/*dimCount=*/nloops, /*symbolCount=*/0, {}, rewriter.getContext()), rewriter.getMultiDimIdentityMap(nloops)}), GetNParallelLoopsAttrs(nloops), [&](OpBuilder& nested_builder, Location nested_loc, ValueRange args) { nested_builder.create(loc, *args.begin()); }); rewriter.replaceOp(op, generic->getResults()); return success(); } }; class LhloBroadcastInDimConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( lmhlo::BroadcastInDimOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { lmhlo::BroadcastInDimOp::Adaptor operand_adaptor(args); auto result_type = operand_adaptor.output().getType().cast(); auto result_shape = result_type.getShape(); auto operand_and_dims = InsertReshapeIfNecessary(op, args, rewriter); Value operand = std::get<0>(operand_and_dims); auto broadcast_dims = std::get<1>(operand_and_dims); auto loc = op.getLoc(); auto nloops = result_type.getRank(); auto operand_type = operand.getType().cast(); // For a degenerate case, i.e. broadcasting with expansion of // memref<1xELEMENT_TYPE>, the operand is not passed to `linalg.generic`. // Instead the value is loaded and used directly in `linalg.yield`. if (operand_type.getRank() == 1 && operand_type.getDimSize(0) < result_type.getDimSize(broadcast_dims.front())) { Value zero = rewriter.create(loc, 0); Value val = rewriter.create(loc, operand, llvm::makeArrayRef({zero})); rewriter.create( loc, /*inputs=*/ValueRange{}, /*outputBuffers=*/ValueRange{operand_adaptor.output()}, llvm::makeArrayRef(rewriter.getMultiDimIdentityMap(nloops)), GetNParallelLoopsAttrs(nloops), [&](OpBuilder& nested_builder, Location nested_loc, ValueRange args) { nested_builder.create(loc, val); }); } else { auto indexing_maps = getIndexingMaps(op, broadcast_dims, result_shape, operand_type, &rewriter); rewriter.create( loc, /*inputs=*/ValueRange{operand}, /*outputBuffers=*/ValueRange{operand_adaptor.output()}, indexing_maps, GetNParallelLoopsAttrs(nloops), [&](OpBuilder& nested_builder, Location nested_loc, ValueRange args) { nested_builder.create(loc, *args.begin()); }); } rewriter.replaceOp(op, llvm::None); return success(); } // Inserts 'linalg.reshape' if there is a size-1 dim expansion. std::pair> InsertReshapeIfNecessary( lmhlo::BroadcastInDimOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const { lmhlo::BroadcastInDimOp::Adaptor operand_adaptor(args); Value operand = operand_adaptor.operand(); auto operand_type = operand_adaptor.operand().getType().cast(); auto operand_shape = operand_type.getShape(); Value result = operand_adaptor.output(); auto result_type = result.getType().cast(); auto result_shape = result_type.getShape(); SmallVector operand_strides; int64_t operand_offset; if (failed(getStridesAndOffset(operand_type, operand_strides, operand_offset))) { op.emitOpError() << "Failed to get offset and strides."; } SmallVector new_shape, new_strides, broadcast_dims; SmallVector collapsed_dims_list; linalg::ReassociationIndices collapsed_dims; for (const auto& item : enumerate(op.broadcast_dimensions().getIntValues())) { size_t index = item.index(); int dim = item.value().getSExtValue(); collapsed_dims.push_back(index); bool expansion_needed = operand_shape[index] == 1 && result_shape[dim] != 1; if (expansion_needed) { continue; } new_shape.push_back(operand_shape[index]); new_strides.push_back(operand_strides[index]); broadcast_dims.push_back(dim); collapsed_dims_list.push_back(collapsed_dims); collapsed_dims.clear(); } // If `collapsed_dims_list` is empty, then the memref has shape [1, ..., 1] // and all dimensions need expansion. Such memref will be reshaped to a 1D // memref with a single element. New shape and strides needs to be updated // accordingly. if (collapsed_dims_list.empty()) { collapsed_dims_list.push_back({}); new_shape.push_back(1); new_strides.push_back(1); broadcast_dims.push_back(0); } for (const auto& dims : collapsed_dims) { collapsed_dims_list.back().push_back(dims); } // `linalg.reshape` is inserted only if necessary, i.e. when the rank can be // reduced. if (new_shape.size() < operand_shape.size()) { auto new_memref_type = MemRefType::get( new_shape, operand_type.getElementType(), makeStridedLinearLayoutMap(new_strides, operand_offset, rewriter.getContext())); operand = rewriter.create(op.getLoc(), new_memref_type, operand_adaptor.operand(), collapsed_dims_list); } return std::make_pair(operand, broadcast_dims); } SmallVector getIndexingMaps(lmhlo::BroadcastInDimOp op, ArrayRef broadcast_dims, ArrayRef result_shape, MemRefType operand_type, Builder* b) const { unsigned nloops = result_shape.size(); // The input is a scalar, i.e. this is a scalar broadcast op. if (operand_type.getRank() == 0) { return {AffineMap::get(nloops, /*symbolCount=*/0, b->getContext()), b->getMultiDimIdentityMap(nloops)}; } auto operand_shape = operand_type.getShape(); SmallVector dim_exprs; dim_exprs.reserve(nloops); for (const auto& broadcast_dim : llvm::enumerate(broadcast_dims)) { int size = broadcast_dim.value(); bool expansion_needed = operand_shape[broadcast_dim.index()] == 1 && result_shape[size] != 1; if (expansion_needed) { op.emitOpError( "BroadcastInDimOp lowering to Linalg does not support size-1 " "dimensions expansion."); } dim_exprs.push_back(b->getAffineDimExpr(size)); } return { AffineMap::get(nloops, /*symbolCount=*/0, dim_exprs, b->getContext()), b->getMultiDimIdentityMap(nloops)}; } }; template class TransposeConverter : public DataMovementOpConverter, OpTy, isLHLO> { public: using DataMovementOpConverter, OpTy, isLHLO>::DataMovementOpConverter; static SmallVector getIndexingMaps(OpTy op, Builder* b) { auto result_type = GetHloOpResultType(op).template cast(); auto nloops = result_type.getRank(); SmallVector input_exprs; input_exprs.resize(result_type.getRank()); for (auto permutation : llvm::enumerate(op.permutation())) { input_exprs[permutation.value().getZExtValue()] = b->getAffineDimExpr(permutation.index()); } return { AffineMap::get(nloops, /*symbolCount=*/0, input_exprs, b->getContext()), b->getMultiDimIdentityMap(nloops)}; } }; // Converts reshape ops that can be proven to be either a collapse of dimensions // or expansion of dimensions of the operand. template class ReshapeOpConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy reshape_op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { if (!VerifyHloOpBufferOrTensorSemantics(reshape_op)) return failure(); typename OpTy::Adaptor operands(args); ShapedType operand_type = operands.operand().getType().template cast(); ShapedType result_type = GetHloOpResultType(reshape_op); if (!operand_type.hasStaticShape() || !result_type.hasStaticShape()) return failure(); // Compute the reassociation maps for the linalg operation. ArrayRef src_shape = (operand_type.getRank() > result_type.getRank() ? operand_type.getShape() : result_type.getShape()); ArrayRef dst_shape = (operand_type.getRank() > result_type.getRank() ? result_type.getShape() : operand_type.getShape()); unsigned curr_src_dim = 0, curr_dst_dim = 0; SmallVector reassociation_map( dst_shape.size()); // First scan all dimensions in the source shapes to see whether we have a // perfect case where consecutive dimensions in source are collapsed. For // such case we can just generate one single linalg.reshape. bool is_collapsing_source = true; while (curr_src_dim < src_shape.size() && curr_dst_dim < dst_shape.size()) { int64_t dst_size = dst_shape[curr_dst_dim]; int64_t src_size = src_shape[curr_src_dim]; while (src_size < dst_size && curr_src_dim < src_shape.size()) { reassociation_map[curr_dst_dim].push_back( rewriter.getAffineDimExpr(curr_src_dim++)); src_size *= src_shape[curr_src_dim]; } if (src_size == dst_size) { reassociation_map[curr_dst_dim].push_back( rewriter.getAffineDimExpr(curr_src_dim++)); // If the next dim in dst_shape is not 1, treat subsequent dims in // src_shape which are 1 to be collapsed. if (curr_dst_dim == dst_shape.size() - 1 || dst_shape[curr_dst_dim + 1] != 1) { while (curr_src_dim < src_shape.size() && src_shape[curr_src_dim] == 1) { reassociation_map[curr_dst_dim].push_back( rewriter.getAffineDimExpr(curr_src_dim++)); } } } else { is_collapsing_source = false; break; } curr_dst_dim++; } if (curr_src_dim != src_shape.size() || curr_dst_dim != dst_shape.size()) is_collapsing_source = false; // Otherwise, we need to first reduce all source dimensions into one and // then expand to the destination dimensions. if (!is_collapsing_source) { auto get_identity_exprs = [&rewriter](int n) { SmallVector exprs; for (int i = 0; i < n; ++i) exprs.push_back(rewriter.getAffineDimExpr(i)); return exprs; }; Location loc = reshape_op.getLoc(); int64_t total_elems = std::accumulate(src_shape.begin(), src_shape.end(), 1, std::multiplies()); auto elem_type = operand_type.getElementType(); SmallVector collapsing_map = { // Use operand_type here because we need to collapse all operands // dimensions. get_identity_exprs(operand_type.getShape().size())}; SmallVector expanding_map = { // Use result_type here because we need to expand to all result // dimensions. get_identity_exprs(result_type.getShape().size())}; if (isLHLO) { auto collapsed_type = MemRefType::get({total_elems}, elem_type); Value collapsed_op = rewriter.create( loc, collapsed_type, args[0], collapsing_map); Value reshape_buffer = rewriter.create( loc, result_type, collapsed_op, expanding_map); rewriter.replaceOpWithNewOp(reshape_op, reshape_buffer, args[1]); } else { auto collapsed_type = RankedTensorType::get({total_elems}, elem_type); Value collapsed_op = rewriter.create( loc, collapsed_type, args[0], collapsing_map); rewriter.replaceOpWithNewOp( reshape_op, result_type, collapsed_op, expanding_map); } return success(); } if (isLHLO) { Value reshape_buffer = rewriter.create( reshape_op.getLoc(), result_type, args[0], reassociation_map); rewriter.replaceOpWithNewOp(reshape_op, reshape_buffer, args[1]); } else { rewriter.replaceOpWithNewOp( reshape_op, result_type, args[0], reassociation_map); } return success(); } }; template class IotaConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy iota_op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { ShapedType result_shaped_type = GetHloOpResultType(iota_op); if (!result_shaped_type) return failure(); auto result_element_type = result_shaped_type.getElementType(); if (!result_element_type.isSignlessIntOrFloat()) return failure(); // Construct the indexing maps needed for linalg.generic ops. unsigned nloops = result_shaped_type.getRank(); Location loc = iota_op.getLoc(); auto dyn_sizes = isLHLO ? SmallVector() : ExtractDynamicSizes(rewriter, loc, GetResultValue(iota_op)); auto linalg_op = rewriter.create( loc, /*resultTensorTypes=*/ isLHLO ? ArrayRef{} : ArrayRef{result_shaped_type}, /*inputs=*/ValueRange{}, /*outputBuffers=*/ isLHLO ? ValueRange{args} : ValueRange{GetInitTensor(rewriter, loc, result_shaped_type, dyn_sizes)}, llvm::makeArrayRef(rewriter.getMultiDimIdentityMap(nloops)), GetNParallelLoopsAttrs(nloops), [&](OpBuilder& nested_builder, Location nested_loc, ValueRange ivs, ValueRange args) { Value cast_op = nested_builder.create( nested_loc, ivs[iota_op.iota_dimension()], nested_builder.getIntegerType( result_element_type.getIntOrFloatBitWidth())); if (result_element_type.template isa()) { cast_op = nested_builder.create(nested_loc, cast_op, result_element_type); } nested_builder.create(nested_loc, cast_op); }); if (isLHLO) rewriter.replaceOp(iota_op, llvm::None); else rewriter.replaceOp(iota_op, linalg_op.result_tensors()); return success(); } }; template class ConstConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy const_op, ArrayRef /*args*/, ConversionPatternRewriter& rewriter) const final { Location loc = const_op.getLoc(); auto value_attr = const_op.value().template cast(); if (value_attr.getType().getRank() != 0) return failure(); ReplaceConstOp(loc, const_op, value_attr, rewriter); return success(); } private: void ReplaceConstOp(Location loc, mhlo::ConstOp op, DenseElementsAttr value_attr, ConversionPatternRewriter& rewriter) const { Value std_tensor_const = rewriter.create(loc, value_attr); rewriter.replaceOp(op, {std_tensor_const}); } void ReplaceConstOp(Location loc, lmhlo::ConstOp op, DenseElementsAttr value_attr, ConversionPatternRewriter& rewriter) const { Value std_scalar_const = rewriter.create(loc, value_attr.getValue({})); rewriter.create(loc, std_scalar_const, op.getOperand(), llvm::None); rewriter.eraseOp(op); } }; class ReduceConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( lmhlo::ReduceOp reduce_op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { auto loc = reduce_op.getLoc(); lmhlo::ReduceOp::Adaptor adaptor(args); auto operand_shape = adaptor.operands()[0].getType().template dyn_cast(); if (!operand_shape || !operand_shape.hasRank()) { emitError(loc, "lhlo to linalg conversion expects known-rank args"); return failure(); } // First fill the output buffer with the init value. Value init_value = rewriter.create(loc, adaptor.init_values()[0]); rewriter.create(loc, adaptor.out()[0], init_value); DenseIntElementsAttr dimensions_attr = reduce_op.dimensions(); SmallVector reduction_dims; for (const auto& dim : dimensions_attr.getIntValues()) { reduction_dims.push_back(dim.getSExtValue()); } SmallVector src_exprs; SmallVector dst_exprs; SmallVector types; for (int i = 0, rank = operand_shape.getRank(); i != rank; ++i) { bool is_reduced = llvm::is_contained(reduction_dims, i); types.push_back(is_reduced ? getReductionIteratorTypeName() : getParallelIteratorTypeName()); src_exprs.push_back(mlir::getAffineDimExpr(i, rewriter.getContext())); if (!is_reduced) { dst_exprs.push_back(mlir::getAffineDimExpr(i, rewriter.getContext())); } } auto maps = AffineMap::inferFromExprList({src_exprs, dst_exprs}); auto linalg_op = rewriter.create( loc, /*resultTensorTypes=*/ArrayRef{}, /*inputs=*/adaptor.operands(), /*outputBuffers=*/adaptor.out(), maps, types); rewriter.inlineRegionBefore(reduce_op.body(), linalg_op.region(), linalg_op.region().end()); { OpBuilder::InsertionGuard region_guard(rewriter); Block* block = linalg_op.getBody(); rewriter.setInsertionPoint(&block->front()); // The incoming region is operating on buffers, while linalg.generic // expects scalar SSA values. Add some allocs around the original op to // make it compatible. auto arg_type = block->getArgument(0).getType().cast(); Value alloc_a = rewriter.create(loc, arg_type); Value alloc_b = rewriter.create(loc, arg_type); Value alloc_res = rewriter.create(loc, arg_type); // Now turn the existing signature // (memref, memref, memref) -> () // into // (X, X) -> X TypeConverter::SignatureConversion signature_converter(3); signature_converter.remapInput(0, alloc_a); signature_converter.remapInput(1, alloc_b); signature_converter.remapInput(2, alloc_res); signature_converter.addInputs( {arg_type.getElementType(), arg_type.getElementType()}); Block* entry_block = rewriter.applySignatureConversion( &linalg_op.region(), signature_converter); // Store the arguments into the newly allocated buffers. rewriter.setInsertionPointAfter(alloc_res.getDefiningOp()); rewriter.create(loc, entry_block->getArgument(0), alloc_a); rewriter.create(loc, entry_block->getArgument(1), alloc_b); rewriter.replaceOp(entry_block->getTerminator(), {}); // Load & yield the result. rewriter.setInsertionPointToEnd(entry_block); auto load_res = rewriter.create(loc, alloc_res); rewriter.create(loc, ValueRange{load_res}); } rewriter.replaceOp(reduce_op, linalg_op.getOperation()->getResults()); return success(); } }; // TODO(b/156787842): Support the lowering for dynamic shapes. template class ReverseConverter : public DataMovementOpConverter, OpTy, isLHLO> { public: using DataMovementOpConverter, OpTy, isLHLO>::DataMovementOpConverter; static SmallVector getIndexingMaps(OpTy op, Builder* b) { auto result_type = GetHloOpResultType(op).template cast(); auto nloops = result_type.getRank(); SmallVector input_exprs; input_exprs.reserve(nloops); for (int i = 0; i < nloops; ++i) input_exprs.push_back(b->getAffineDimExpr(i)); for (auto dim : op.dimensions()) { int i = dim.getZExtValue(); if (result_type.isDynamicDim(i)) return {}; int n = result_type.getShape()[i]; input_exprs[i] = b->getAffineConstantExpr(n - 1) - input_exprs[i]; } return { AffineMap::get(nloops, /*symbolCount=*/0, input_exprs, b->getContext()), b->getMultiDimIdentityMap(nloops)}; } }; template class SliceConverter : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy slice_op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { auto loc = slice_op.getLoc(); auto arg_type = args[0].getType().template dyn_cast(); if (!arg_type || !arg_type.hasRank()) { emitError(loc, "lhlo to linalg conversion expects known-rank args"); return failure(); } SmallVector offsets, sizes, strides; for (int i = 0, e = arg_type.getRank(); i < e; ++i) { offsets.push_back(rewriter.getI64IntegerAttr( slice_op.start_indices().template getValue(i))); sizes.push_back(rewriter.getI64IntegerAttr( slice_op.limit_indices().template getValue(i) - slice_op.start_indices().template getValue(i))); strides.push_back(rewriter.getI64IntegerAttr( slice_op.strides().template getValue(i))); } if (isLHLO) { auto linalg_op = rewriter.create(loc, args[0], offsets, sizes, strides); rewriter.create(loc, linalg_op, args[1]); rewriter.eraseOp(slice_op); } else { rewriter.replaceOpWithNewOp(slice_op, args[0], offsets, sizes, strides); } return success(); } }; enum class DotOperationType { kVectorDot = 0, kMatrixVector = 1, kMatrixMatrix = 2, kUnsupported = 3 }; DotOperationType GetDotOperationType(mhlo::DotOp dot_op) { ArrayRef lhs_shape = dot_op.lhs().getType().cast().getShape(); ArrayRef rhs_shape = dot_op.rhs().getType().cast().getShape(); auto shape_matches = [](int64_t a, int64_t b) { return a == ShapedType::kDynamicSize || b == ShapedType::kDynamicSize || a == b; }; if (lhs_shape.size() == 1 && rhs_shape.size() == 1 && shape_matches(lhs_shape[0], rhs_shape[0])) { return DotOperationType::kVectorDot; } if (lhs_shape.size() == 2 && rhs_shape.size() == 1 && shape_matches(lhs_shape[1], rhs_shape[0])) { return DotOperationType::kMatrixVector; } if (rhs_shape.size() == 2 && rhs_shape.size() == 2 && shape_matches(lhs_shape[1], rhs_shape[0])) { return DotOperationType::kMatrixMatrix; } return DotOperationType::kUnsupported; } SmallVector GetDotOpInitTensorDynSizes(OpBuilder& b, Location loc, Value lhs, Value rhs, DotOperationType type) { SmallVector dyn_shape; switch (type) { case DotOperationType::kMatrixMatrix: { if (lhs.getType().cast().isDynamicDim(0)) dyn_shape.push_back(b.create(loc, lhs, 0)); if (rhs.getType().cast().isDynamicDim(1)) dyn_shape.push_back(b.create(loc, rhs, 1)); break; } case DotOperationType::kMatrixVector: { if (lhs.getType().cast().isDynamicDim(0)) dyn_shape.push_back(b.create(loc, lhs, 0)); break; } case DotOperationType::kVectorDot: case DotOperationType::kUnsupported: default: { break; } } return dyn_shape; } template class DotOpOnTensorsConversion : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( mhlo::DotOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { if (!VerifyHloOpBufferOrTensorSemantics(op)) { return failure(); } mhlo::DotOp::Adaptor adaptor(args); auto lhs_el_type = adaptor.lhs().getType().cast().getElementType(); auto rhs_el_type = adaptor.lhs().getType().cast().getElementType(); if (lhs_el_type != rhs_el_type || !lhs_el_type.isa() || lhs_el_type.getIntOrFloatBitWidth() != input_bit_width) { return failure(); } auto output_type = op.getType().cast(); auto output_el_type = output_type.getElementType(); if (!output_el_type.isa() || output_el_type.getIntOrFloatBitWidth() != output_bit_width) { return failure(); } if (GetDotOperationType(op) != op_type) return failure(); Location loc = op.getLoc(); auto zero_attr = rewriter.getZeroAttr(output_el_type); Value zero = rewriter.create(loc, zero_attr); SmallVector dyn_shape = GetDotOpInitTensorDynSizes( rewriter, loc, adaptor.lhs(), adaptor.rhs(), op_type); auto init_tensor = GetInitTensor(rewriter, loc, output_type, dyn_shape); Value zero_tensor = rewriter.create(loc, init_tensor, zero).getResult(0); rewriter.replaceOpWithNewOp( op, TypeRange{op.getType()}, ValueRange{adaptor.lhs(), adaptor.rhs()}, ValueRange{zero_tensor}); return success(); } }; SmallVector GetDotGeneralOpInitTensorDynSizes( OpBuilder& b, Location loc, Value lhs, Value rhs, ShapedType result_type) { SmallVector dyn_shape; if (result_type.isDynamicDim(0)) dyn_shape.push_back(b.create(loc, lhs, 0)); if (result_type.isDynamicDim(1)) dyn_shape.push_back(b.create(loc, lhs, 1)); if (result_type.isDynamicDim(2)) dyn_shape.push_back(b.create(loc, rhs, 2)); return dyn_shape; } template class DotGeneralOpOnTensorsConversion : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( mhlo::DotGeneralOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { if (!VerifyHloOpBufferOrTensorSemantics(op)) { return failure(); } mhlo::DotDimensionNumbers dim_numbers = op.dot_dimension_numbers(); auto lhs_bathcing_dims = Extract1DVector(dim_numbers.lhs_batching_dimensions()); auto rhs_bathcing_dims = Extract1DVector(dim_numbers.rhs_batching_dimensions()); auto lhs_contracting_dims = Extract1DVector(dim_numbers.lhs_contracting_dimensions()); auto rhs_contracting_dims = Extract1DVector(dim_numbers.rhs_contracting_dimensions()); if (lhs_bathcing_dims.size() != 1 || lhs_bathcing_dims[0] != 0) { return rewriter.notifyMatchFailure( op, "expected lhs batching dimensions exactly {0}"); } if (rhs_bathcing_dims.size() != 1 || rhs_bathcing_dims[0] != 0) { return rewriter.notifyMatchFailure( op, "expected rhs batching dimensions exactly {0}"); } if (lhs_contracting_dims.size() != 1 || lhs_contracting_dims[0] != 2) { return rewriter.notifyMatchFailure( op, "expected lhs contracting dimensions exactly {2}"); } if (rhs_contracting_dims.size() != 1 || rhs_contracting_dims[0] != 1) { return rewriter.notifyMatchFailure( op, "expected rhs contracting dimensions exactly {1}"); } mhlo::DotGeneralOp::Adaptor adaptor(args); auto lhs_el_type = adaptor.lhs().getType().cast().getElementType(); auto rhs_el_type = adaptor.lhs().getType().cast().getElementType(); if (lhs_el_type != rhs_el_type || !lhs_el_type.isa() || lhs_el_type.getIntOrFloatBitWidth() != input_bit_width) { return failure(); } auto output_type = op.getType().cast(); auto output_el_type = output_type.getElementType(); if (!output_el_type.isa() || output_el_type.getIntOrFloatBitWidth() != output_bit_width) { return failure(); } Location loc = op.getLoc(); SmallVector dyn_shape = GetDotGeneralOpInitTensorDynSizes( rewriter, loc, adaptor.lhs(), adaptor.rhs(), output_type); auto zero_attr = rewriter.getZeroAttr(output_el_type); Value zero = rewriter.create(loc, zero_attr); auto init_tensor = GetInitTensor(rewriter, loc, output_type, dyn_shape); Value zero_tensor = rewriter.create(loc, init_tensor, zero).getResult(0); Operation* linalg_op = rewriter.create( loc, /*resultTensorTypes=*/TypeRange{op.getType()}, /*inputs=*/ValueRange{adaptor.lhs(), adaptor.rhs()}, /*outputBuffers=*/ValueRange{zero_tensor}); rewriter.replaceOp(op, linalg_op->getResults()); return success(); } }; template struct ReduceRegionXLAOpConversion : public OpConversionPattern { using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( OpTy op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { // Only convert the body of reduction ops to std ops. auto parent_op = op.getOperation()->getParentRegion()->getParentOp(); if (!isa( parent_op)) { return failure(); } if (!op.getResult().getType().template isa()) return failure(); if (llvm::all_of(args, [](Value arg) { return arg.getType().template isa(); })) { return failure(); } Value result = lmhlo::HloOpToStdScalarOp::map(op, args[0].getType(), args, &rewriter); rewriter.replaceOp(op, result); return success(); } }; SmallVector GetReduceOpInitTensorDynSizes( OpBuilder& b, Location loc, Value arg, ShapedType result_type, ArrayRef reduction_dims) { llvm::SmallSetVector s; for (auto dim : reduction_dims) s.insert(dim); SmallVector parallel_dims; SmallVector dyn_shape; int rank = arg.getType().cast().getRank(); for (int i = 0, j = 0; i < rank; ++i) { if (s.count(i)) continue; if (!result_type.isDynamicDim(j++)) continue; dyn_shape.push_back(b.create(loc, arg, i)); } return dyn_shape; } class ReduceRegionReturnOpConversion : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( mhlo::ReturnOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { rewriter.replaceOpWithNewOp(op, args); return success(); } }; class ReduceOnTensorsConversion : public OpConversionPattern { public: using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( mhlo::ReduceOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const final { Location loc = op.getLoc(); mhlo::ReduceOp::Adaptor adaptor(args); if (op.getNumOperands() != 2) { return op.emitError("expects exactly two operands"); } Value src = adaptor.operands()[0]; auto src_type = src.getType().cast(); int src_rank = src_type.getRank(); if (!src_rank) { return rewriter.notifyMatchFailure(op, "expects known-rank args"); } // Check if init_value is constant. If so, inline the value into the region. Value init_value = adaptor.init_values()[0]; Attribute init_const_val = GetInitValueAsConst(init_value); if (init_const_val) { init_value = rewriter.create( init_value.getDefiningOp()->getLoc(), init_const_val); } else { init_value = rewriter.create(loc, init_value); } // Prepare indexing maps for linalg generic op. The elements are for src and // dst. Transpose `src` to make the reduction loops be the innermost, // because it's easier to fully utilize processors. SmallVector indexing_maps; SmallVector reduction_dims = Extract1DVector(op.dimensions()); indexing_maps.emplace_back(GetTransposeMapForReduction( rewriter.getContext(), src_rank, reduction_dims)); // The indexing map of `dst` should drop the reduction loops. Since the // reduction loops now are all in the innermost, drops // `reduction_dims.size()` dimensions. We don't need an inverse permutation // here because they are the same. SmallVector exprs; for (int i = 0, e = src_rank - reduction_dims.size(); i < e; ++i) exprs.push_back(rewriter.getAffineDimExpr(i)); indexing_maps.emplace_back(AffineMap::get(src_rank, /*symbolCount=*/0, exprs, rewriter.getContext())); SmallVector inputs = {adaptor.operands()[0]}; Type result_type = op.getResult(0).getType(); auto shaped_type = result_type.cast(); SmallVector dyn_shape = GetReduceOpInitTensorDynSizes( rewriter, loc, adaptor.operands()[0], result_type.cast(), reduction_dims); auto init_tensor = GetInitTensor(rewriter, loc, shaped_type, dyn_shape); Value filled_tensor = rewriter.create(loc, init_tensor, init_value) .getResult(0); auto linalg_op = rewriter.create( loc, /*resultTensorTypes=*/op.getResultTypes(), inputs, /*outputBuffers=*/ValueRange{filled_tensor}, indexing_maps, GetParallelAndReductionIterators(src_rank, reduction_dims.size())); // Convert the signature of the body. The reduce op region apply function // has a signature (lhs, rhs) -> output, all of the same tensor type t. // This is converted to a function with the same signature but with // element types. E.g., "(tensor, tensor) -> tensor" will // be converted to "(f32, f32, f32)". Region& region = linalg_op.region(); rewriter.inlineRegionBefore(op.body(), region, region.end()); TypeConverter::SignatureConversion signatureConverter(2); signatureConverter.addInputs(0, src_type.getElementType()); signatureConverter.addInputs(1, src_type.getElementType()); rewriter.applySignatureConversion(®ion, signatureConverter); rewriter.replaceOp(op, linalg_op.getResults()); return success(); } }; /// Converts mhlo.pad operation to linalg.pad_tensor op. struct PadOpOnTensorsConversion : public OpConversionPattern { using OpConversionPattern::OpConversionPattern; LogicalResult matchAndRewrite( mhlo::PadOp op, ArrayRef args, ConversionPatternRewriter& rewriter) const override { mhlo::PadOp::Adaptor adaptor(args); if (llvm::any_of( op.interior_padding().getValues(), [](const APInt& int_val) { return int_val.getZExtValue() != 0; })) { return rewriter.notifyMatchFailure(op, "expected no interior padding"); } auto loc = op.getLoc(); Value padding_val = rewriter.createOrFold(loc, adaptor.padding_value()); const auto& edge_padding_low = op.edge_padding_low(); const auto& edge_padding_high = op.edge_padding_high(); SmallVector low, high; for (auto it : llvm::zip(edge_padding_low, edge_padding_high)) { low.push_back(rewriter.createOrFold( loc, std::get<0>(it).getZExtValue())); high.push_back(rewriter.createOrFold( loc, std::get<1>(it).getZExtValue())); } Type result_type = op.getResult().getType(); auto pad_tensor_op = linalg::PadTensorOp::createPadScalarOp( result_type, adaptor.operand(), padding_val, low, high, loc, rewriter); rewriter.replaceOp(op, pad_tensor_op.getResult()); return success(); } }; void populateLHLOToLinalgConversionPattern(MLIRContext* context, OwningRewritePatternList* patterns) { // clang-format off patterns->insert, ConstConverter, ConvToLinalgConverter, IotaConverter, LhloBroadcastInDimConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, // TODO(ataei): Remove this pattern, CopyOp is folded away. PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, ReduceConverter, ReshapeOpConverter, ReverseConverter, ScalarPointwiseToStandardConverter, ScalarPointwiseToStandardConverter, SliceConverter, TransposeConverter >(context); // clang-format on } // Converts LHLO ops to Linalg generic. // Sample result for lmhlo::AddOp. // // "lmhlo.add"(%arg1, %arg2, %out) : // (memref<2x2xf32>, memref<2x2xf32>, memref<2x2xf32>) -> () // // will be converted to // // #map0 = (d0, d1) -> (d0, d1) // "linalg.generic"(%arg1, %arg2, %out) ( { // ^bb0(%arg4: f32, %arg5: f32): // %0 = addf %arg4, %arg5 : f32 // "linalg.yield"(%0) : (f32) -> () // }) { // indexing_maps = [#map0, #map0, #map0], // iterator_types = ["parallel", "parallel"], // } : (memref<2x2xf32>, memref<2x2xf32>, memref<2x2xf32>) -> () struct LhloLegalizeToLinalgPass : public PassWrapper { void getDependentDialects(DialectRegistry& registry) const override { registry.insert(); } void runOnFunction() override { OwningRewritePatternList patterns; ConversionTarget target(getContext()); target.addLegalDialect(); auto func = getFunction(); populateLHLOToLinalgConversionPattern(func.getContext(), &patterns); if (failed(applyPartialConversion(func, target, std::move(patterns)))) { signalPassFailure(); } } }; struct HloLegalizeToLinalgPass : public PassWrapper { void getDependentDialects(DialectRegistry& registry) const override { registry.insert(); } void runOnFunction() override { OwningRewritePatternList patterns; ConversionTarget target(getContext()); target.addLegalDialect(); auto func = getFunction(); mhlo::populateHLOToLinalgConversionPattern(func.getContext(), &patterns); if (failed(applyPartialConversion(func, target, std::move(patterns)))) { signalPassFailure(); } } }; } // namespace namespace lmhlo { std::unique_ptr> createLegalizeLhloToLinalgPass() { return std::make_unique(); } } // namespace lmhlo namespace mhlo { void populateHLOToLinalgConversionPattern(MLIRContext* context, OwningRewritePatternList* patterns) { // clang-format off patterns->insert< BroadcastConverter, ConstConverter, HloDynamicBroadcastInDimConverter, HloBroadcastInDimConverter, IotaConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, PointwiseToLinalgConverter, ReshapeOpConverter, ReverseConverter, SliceConverter, TransposeConverter, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotOpOnTensorsConversion, DotGeneralOpOnTensorsConversion, DotGeneralOpOnTensorsConversion, DotGeneralOpOnTensorsConversion, DotGeneralOpOnTensorsConversion, ReduceOnTensorsConversion, PadOpOnTensorsConversion>(context); // clang-format on patterns->insert, ReduceRegionXLAOpConversion, ReduceRegionXLAOpConversion, ReduceRegionReturnOpConversion>(context); } std::unique_ptr> createLegalizeHloToLinalgPass() { return std::make_unique(); } } // namespace mhlo } // namespace mlir