Implement QAttention And Enable tests (#16837)

This commit is contained in:
Xiang Zhang 2023-07-24 18:12:20 -07:00 committed by Jeff Bloomfield
parent e9d330e489
commit c19e4c02e2
6 changed files with 712 additions and 9 deletions

View file

@ -0,0 +1,638 @@
// Copyright (c) Microsoft Corporation. All rights reserved.
// Licensed under the MIT License.
#include "precomp.h"
/*
Abbreviations: B is batch_size, S is sequence_length, W is hidden_size
N is number of attention heads, H is head size, and W=N*H
M is mask_index tensor
M A B C // M, A, B, and C are Inputs
| | | /
| Dequantize /
| \ | /
| Gemm
| / | \
| / | \
| / | \
| Slice Slice Slice
| | | |
| | | |
| Identity Identity Identity // The identities are used to transpose NCHW -> NHCW while
| | | | // keeping the GEMM strides as NCHW to better target metacommands
| | | |
----------------- MHA -----
|
|
Output // Final output
This kernel creates a DML_GRAPH, as mentioned above.
For reference, refer to this Doc:
https://github.com/microsoft/onnxruntime/blob/main/docs/ContribOperators.md#commicrosoftqattention
*/
namespace Dml
{
class DmlOperatorQAttention : public DmlOperator
{
public:
DmlOperatorQAttention(const MLOperatorKernelCreationContext& kernelCreationContext)
: DmlOperator(kernelCreationContext)
{
enum DmlInputIndex : uint32_t
{
mhaQueryIndex,
mhaKeyIndex,
mhaValueIndex,
mhaStackedQueryKeyIndex,
mhaStackedKeyValueIndex,
mhaStackedQueryKeyValueIndex,
mhaBiasIndex,
mhaMaskIndex,
mhaRelativePositionBiasIndex,
mhaPastKeyIndex,
mhaPastValueIndex,
mhaInputCount,
};
enum InputIndex : uint32_t
{
inputIndex,
weightsIndex,
biasIndex,
inputScaleIndex,
weightScaleIndex,
maskIndex,
inputZeroPointIndex,
weightZeroPointIndex,
pastIndex,
inputCount,
};
enum OutputIndex : uint32_t
{
outputIndex,
outputCount,
};
ML_CHECK_VALID_ARGUMENT(kernelCreationContext.GetInputCount() >= 2);
ML_CHECK_VALID_ARGUMENT(kernelCreationContext.GetOutputCount() >= 1);
const bool hasBias = kernelCreationContext.IsInputValid(biasIndex);
const bool hasMask = kernelCreationContext.IsInputValid(maskIndex);
const bool hasUnpaddedBounds = hasMask && kernelCreationContext.GetInputTensorDimensionCount(maskIndex) == 1;
DmlOperator::Initialize(kernelCreationContext, std::nullopt, std::nullopt, std::nullopt, std::nullopt, 1);
const uint32_t numHeads = gsl::narrow_cast<uint32_t>(kernelCreationContext.GetAttribute<int64_t>(AttrName::NumHeads));
ML_CHECK_VALID_ARGUMENT(numHeads > 0); // to avoid process crash because of division by zero.
auto inputTensorShape = m_inputTensorDescs[inputIndex].GetSizes();
ML_CHECK_VALID_ARGUMENT(inputTensorShape.size() == 3);
auto weightTensorShape = m_inputTensorDescs[weightsIndex].GetSizes();
ML_CHECK_VALID_ARGUMENT(weightTensorShape.size() == 2);
ML_CHECK_VALID_ARGUMENT(weightTensorShape[0] == inputTensorShape[2]);
const auto qkvHiddenSizes = kernelCreationContext.GetOptionalAttributeVectorInt32(AttrName::QkvHiddenSizes);
if (hasBias)
{
auto biasTensorShape = m_inputTensorDescs[biasIndex].GetSizes();
ML_CHECK_VALID_ARGUMENT(biasTensorShape.size() == 1);
ML_CHECK_VALID_ARGUMENT(weightTensorShape[1] == biasTensorShape[0]);
if (qkvHiddenSizes.empty())
{
ML_CHECK_VALID_ARGUMENT(biasTensorShape[0] % 3 == 0);
}
}
if (!qkvHiddenSizes.empty())
{
ML_CHECK_VALID_ARGUMENT(qkvHiddenSizes.size() == 3);
ML_CHECK_VALID_ARGUMENT(qkvHiddenSizes[0] == qkvHiddenSizes[1]);
}
else
{
ML_CHECK_VALID_ARGUMENT(weightTensorShape[1] % 3 == 0);
}
const uint32_t hiddenSize = qkvHiddenSizes.empty() ? weightTensorShape[1] / 3 : qkvHiddenSizes[0];
const uint32_t vHiddenSize = qkvHiddenSizes.empty() ? weightTensorShape[1] / 3 : qkvHiddenSizes[2];
const uint32_t headSize = hiddenSize / numHeads;
const uint32_t vHeadSize = vHiddenSize / numHeads;
const uint32_t batchSize = inputTensorShape[0];
const uint32_t sequenceLength = inputTensorShape[1];
uint32_t desiredWeightTensorShape[3] = {batchSize, weightTensorShape[0], hiddenSize + hiddenSize + vHiddenSize};
MLOperatorTensorDataType dataType = kernelCreationContext.GetOutputEdgeDescription(outputIndex).tensorDataType;
m_inputTensorDescs[weightsIndex] = TensorDesc::ConstructBroadcastedTensorDesc(
kernelCreationContext.GetInputEdgeDescription(weightsIndex).tensorDataType,
desiredWeightTensorShape,
weightTensorShape);
m_inputTensorDescs[inputScaleIndex] = TensorDesc::ConstructBroadcastedTensorDesc(
kernelCreationContext.GetInputEdgeDescription(inputScaleIndex).tensorDataType,
inputTensorShape,
m_inputTensorDescs[inputScaleIndex].GetSizes());
m_inputTensorDescs[inputZeroPointIndex] = TensorDesc::ConstructBroadcastedTensorDesc(
kernelCreationContext.GetInputEdgeDescription(inputZeroPointIndex).tensorDataType,
inputTensorShape,
m_inputTensorDescs[inputZeroPointIndex].GetSizes());
m_inputTensorDescs[weightScaleIndex] = TensorDesc::ConstructBroadcastedTensorDesc(
kernelCreationContext.GetInputEdgeDescription(weightScaleIndex).tensorDataType,
desiredWeightTensorShape,
m_inputTensorDescs[weightScaleIndex].GetSizes());
m_inputTensorDescs[weightZeroPointIndex] = TensorDesc::ConstructBroadcastedTensorDesc(
kernelCreationContext.GetInputEdgeDescription(weightZeroPointIndex).tensorDataType,
desiredWeightTensorShape,
m_inputTensorDescs[weightZeroPointIndex].GetSizes());
uint32_t desiredBiasTensorShape[3] = {batchSize, sequenceLength, hiddenSize + hiddenSize + vHiddenSize};
if (hasBias)
{
auto biasTensorShape = m_inputTensorDescs[biasIndex].GetSizes();
m_inputTensorDescs[biasIndex] = TensorDesc::ConstructBroadcastedTensorDesc(kernelCreationContext.GetInputEdgeDescription(biasIndex).tensorDataType, desiredBiasTensorShape, biasTensorShape);
}
MLOperatorTensorDataType maskTensorDataType = MLOperatorTensorDataType::Undefined;
bool hasMaxSequenceMask = false;
DML_MULTIHEAD_ATTENTION_MASK_TYPE maskType = DML_MULTIHEAD_ATTENTION_MASK_TYPE_NONE;
if (hasMask)
{
if (hasUnpaddedBounds)
{
auto unpaddedKeyBoundsShape = m_inputTensorDescs[maskIndex].GetSizes();
ML_CHECK_VALID_ARGUMENT(unpaddedKeyBoundsShape.size() == 1);
const uint32_t batchGroupCount = unpaddedKeyBoundsShape[0] / batchSize;
ML_CHECK_VALID_ARGUMENT(batchGroupCount == 1 || batchGroupCount == 2);
uint32_t desiredShape[2] = {batchGroupCount, batchSize};
m_inputTensorDescs[maskIndex] = TensorDesc(
m_inputTensorDescs[maskIndex].GetDmlDataType(),
desiredShape);
maskType = batchGroupCount == 1
? DML_MULTIHEAD_ATTENTION_MASK_TYPE_KEY_SEQUENCE_LENGTH
: DML_MULTIHEAD_ATTENTION_MASK_TYPE_KEY_SEQUENCE_END_START;
}
else
{
auto maskIndexTensorShape = m_inputTensorDescs[maskIndex].GetSizes();
ML_CHECK_VALID_ARGUMENT(maskIndexTensorShape.size() > 1 && maskIndexTensorShape.size() <= 4);
maskType = DML_MULTIHEAD_ATTENTION_MASK_TYPE_BOOLEAN;
std::vector<uint32_t> reshapedMaskIndexTensorShape(maskIndexTensorShape.begin(), maskIndexTensorShape.end());
if (maskIndexTensorShape.size() == 4 && maskIndexTensorShape[2] != sequenceLength)
{
hasMaxSequenceMask = true;
ML_CHECK_VALID_ARGUMENT(maskIndexTensorShape[2] == maskIndexTensorShape[3]);
const uint32_t maxSequenceLength = maskIndexTensorShape[2];
uint32_t desiredMaskIndexShape[4] {batchSize, numHeads, maxSequenceLength, maxSequenceLength};
maskTensorDataType = kernelCreationContext.GetInputEdgeDescription(maskIndex).tensorDataType;
m_inputTensorDescs[maskIndex] = TensorDesc::ConstructBroadcastedTensorDesc(maskTensorDataType, desiredMaskIndexShape, reshapedMaskIndexTensorShape);
}
else
{
uint32_t maskIndexDimensionCount = gsl::narrow_cast<uint32_t>(maskIndexTensorShape.size());
reshapedMaskIndexTensorShape.insert(reshapedMaskIndexTensorShape.begin() + 1, 4 - maskIndexDimensionCount, 1);
uint32_t desiredMaskIndexShape[4] {batchSize, numHeads, sequenceLength, sequenceLength};
maskTensorDataType = kernelCreationContext.GetInputEdgeDescription(maskIndex).tensorDataType;
m_inputTensorDescs[maskIndex] = TensorDesc::ConstructBroadcastedTensorDesc(maskTensorDataType, desiredMaskIndexShape, reshapedMaskIndexTensorShape);
}
}
}
TensorDesc firstGemmOutputTensorDesc = TensorDesc::ConstructDefaultTensorDesc(dataType, desiredBiasTensorShape);
DML_TENSOR_DESC namedFirstGemmOutputTensorDesc = firstGemmOutputTensorDesc.GetDmlDesc();
std::vector<DML_TENSOR_DESC> inputDescs = GetDmlInputDescs();
std::vector<DML_TENSOR_DESC> outputDescs = GetDmlOutputDescs();
// output edge between Dequantize and first GEMM node
TensorDesc intermediateInputTensorDesc = TensorDesc::ConstructDefaultTensorDesc(dataType, inputTensorShape);
TensorDesc intermediateWeightTensorDesc = TensorDesc::ConstructDefaultTensorDesc(dataType, desiredWeightTensorShape);
DML_TENSOR_DESC namedIntermediateInputTensorDesc = intermediateInputTensorDesc.GetDmlDesc();
DML_TENSOR_DESC namedIntermediateWeightTensorDesc = intermediateWeightTensorDesc.GetDmlDesc();
DML_ELEMENT_WISE_DEQUANTIZE_LINEAR_OPERATOR_DESC inputDequantizeOperatorDesc = {};
inputDequantizeOperatorDesc.InputTensor = &inputDescs[InputIndex::inputIndex];
inputDequantizeOperatorDesc.ScaleTensor = &inputDescs[InputIndex::inputScaleIndex];
inputDequantizeOperatorDesc.ZeroPointTensor = &inputDescs[InputIndex::inputZeroPointIndex];
inputDequantizeOperatorDesc.OutputTensor = &namedIntermediateInputTensorDesc;
const DML_OPERATOR_DESC inputDequantizeOpDesc{DML_OPERATOR_ELEMENT_WISE_DEQUANTIZE_LINEAR, &inputDequantizeOperatorDesc};
DML_ELEMENT_WISE_DEQUANTIZE_LINEAR_OPERATOR_DESC weightDequantizeOperatorDesc = {};
weightDequantizeOperatorDesc.InputTensor = &inputDescs[InputIndex::weightsIndex];
weightDequantizeOperatorDesc.ScaleTensor = &inputDescs[InputIndex::weightScaleIndex];
weightDequantizeOperatorDesc.ZeroPointTensor = &inputDescs[InputIndex::weightZeroPointIndex];
weightDequantizeOperatorDesc.OutputTensor = &namedIntermediateWeightTensorDesc;
const DML_OPERATOR_DESC weightDequantizeOpDesc{DML_OPERATOR_ELEMENT_WISE_DEQUANTIZE_LINEAR, &weightDequantizeOperatorDesc};
DML_GEMM_OPERATOR_DESC gemmOperatorDesc = {};
gemmOperatorDesc.ATensor = inputDequantizeOperatorDesc.OutputTensor;
gemmOperatorDesc.BTensor = weightDequantizeOperatorDesc.OutputTensor;
if (hasBias)
{
gemmOperatorDesc.CTensor = &inputDescs[2];
}
gemmOperatorDesc.OutputTensor = &namedFirstGemmOutputTensorDesc;
gemmOperatorDesc.TransA = DML_MATRIX_TRANSFORM_NONE;
gemmOperatorDesc.TransB = DML_MATRIX_TRANSFORM_NONE;
gemmOperatorDesc.Alpha = 1.0f;
gemmOperatorDesc.Beta = 1.0f;
gemmOperatorDesc.FusedActivation = nullptr;
const DML_OPERATOR_DESC gemmDesc {DML_OPERATOR_GEMM, &gemmOperatorDesc};
std::array<uint32_t, 3> queryKeySlicedTensorShape {batchSize, sequenceLength, hiddenSize + hiddenSize};
TensorDesc queryKeySlicedInputTensorDesc = TensorDesc::ConstructDefaultTensorDesc(dataType, queryKeySlicedTensorShape);
DML_TENSOR_DESC namedQueryKeySlicedInputTensorDesc = queryKeySlicedInputTensorDesc.GetDmlDesc();
std::array<uint32_t, 3> valueSlicedTensorShape {batchSize, sequenceLength, vHiddenSize};
TensorDesc valueSlicedInputTensorDesc = TensorDesc::ConstructDefaultTensorDesc(dataType, valueSlicedTensorShape);
DML_TENSOR_DESC namedValueSlicedInputTensorDesc = valueSlicedInputTensorDesc.GetDmlDesc();
// Transpose slice QK from [batchSize, sequenceLength, 2, numHeads, headSize] to [batchSize, sequenceLength, numHeads, 2, headSize]
std::array<uint32_t, 5> queryKeyTransposedTensorShape = {batchSize, sequenceLength, numHeads, 2, headSize};
std::array<uint32_t, 5> queryKeyTransposedStrides = {
sequenceLength * numHeads * 2 * headSize,
numHeads * 2 * headSize,
headSize,
numHeads * headSize,
1,
};
TensorDesc queryKeyTransposedInputTensorDesc = TensorDesc(
GetDmlDataTypeFromMlDataType(dataType),
queryKeyTransposedTensorShape,
queryKeyTransposedStrides);
DML_TENSOR_DESC namedQueryKeyTransposedInputTensorDesc = queryKeyTransposedInputTensorDesc.GetDmlDesc();
TensorDesc queryKeyTransposedOutputTensorDesc = TensorDesc(
GetDmlDataTypeFromMlDataType(dataType),
queryKeyTransposedTensorShape);
DML_TENSOR_DESC namedQueryKeyTransposedOutputTensorDesc = queryKeyTransposedOutputTensorDesc.GetDmlDesc();
// Transpose QKV from [batchSize, sequenceLength, 3, numHeads, headSize] to [batchSize, sequenceLength, numHeads, 3, headSize]
std::array<uint32_t, 5> queryKeyValueTransposedTensorShape {batchSize, sequenceLength, numHeads, 3, headSize};
std::array<uint32_t, 5> queryKeyValueTransposedStrides = {
sequenceLength * numHeads * 3 * headSize,
numHeads * 3 * headSize,
headSize,
numHeads * headSize,
1,
};
TensorDesc queryKeyValueTransposedInputTensorDesc = TensorDesc(
GetDmlDataTypeFromMlDataType(dataType),
queryKeyValueTransposedTensorShape,
queryKeyValueTransposedStrides);
DML_TENSOR_DESC namedQueryKeyValueTransposedInputTensorDesc = queryKeyValueTransposedInputTensorDesc.GetDmlDesc();
TensorDesc queryKeyValueTransposedOutputTensorDesc = TensorDesc(
GetDmlDataTypeFromMlDataType(dataType),
queryKeyValueTransposedTensorShape);
DML_TENSOR_DESC namedQueryKeyValueTransposedOutputTensorDesc = queryKeyValueTransposedOutputTensorDesc.GetDmlDesc();
std::array<uint32_t, 3> queryKeySliceOffset = {0, 0, 0};
std::array<uint32_t, 3> queryKeySliceSize = {batchSize, sequenceLength, hiddenSize + hiddenSize};
std::array<int32_t, 3> queryKeySliceStrides = {1, 1, 1};
std::array<uint32_t, 3> valueSliceOffset = {0, 0, 2 * hiddenSize};
std::array<uint32_t, 3> valueSliceSize = {batchSize, sequenceLength, vHiddenSize};
std::array<int32_t, 3> valueSliceStrides = {1, 1, 1};
const bool hasSlicedValue = hiddenSize != vHiddenSize;
// We need to slice the value tensor when its hidden size is different from the query and key
DML_SLICE1_OPERATOR_DESC queryKeySlicedOperatorDesc = {};
DML_SLICE1_OPERATOR_DESC valueSlicedOperatorDesc = {};
DML_ELEMENT_WISE_IDENTITY_OPERATOR_DESC transposeOperatorDesc = {};
if (hasSlicedValue)
{
queryKeySlicedOperatorDesc.InputTensor = &namedFirstGemmOutputTensorDesc;
queryKeySlicedOperatorDesc.OutputTensor = &namedQueryKeySlicedInputTensorDesc;
queryKeySlicedOperatorDesc.DimensionCount = gsl::narrow_cast<uint32_t>(queryKeySlicedTensorShape.size());
queryKeySlicedOperatorDesc.InputWindowOffsets = queryKeySliceOffset.data();
queryKeySlicedOperatorDesc.InputWindowSizes = queryKeySliceSize.data();
queryKeySlicedOperatorDesc.InputWindowStrides = queryKeySliceStrides.data();
valueSlicedOperatorDesc.InputTensor = &namedFirstGemmOutputTensorDesc;
valueSlicedOperatorDesc.OutputTensor = &namedValueSlicedInputTensorDesc;
valueSlicedOperatorDesc.DimensionCount = gsl::narrow_cast<uint32_t>(valueSlicedTensorShape.size());
valueSlicedOperatorDesc.InputWindowOffsets = valueSliceOffset.data();
valueSlicedOperatorDesc.InputWindowSizes = valueSliceSize.data();
valueSlicedOperatorDesc.InputWindowStrides = valueSliceStrides.data();
transposeOperatorDesc.InputTensor = &namedQueryKeyTransposedInputTensorDesc;
transposeOperatorDesc.OutputTensor = &namedQueryKeyTransposedOutputTensorDesc;
}
else
{
// When Q/K/V all have the same hidden size, we just have to transpose it before sending it to MHA
transposeOperatorDesc.InputTensor = &namedQueryKeyValueTransposedInputTensorDesc;
transposeOperatorDesc.OutputTensor = &namedQueryKeyValueTransposedOutputTensorDesc;
}
const DML_OPERATOR_DESC queryKeySlicedDesc = { DML_OPERATOR_SLICE1, &queryKeySlicedOperatorDesc};
const DML_OPERATOR_DESC valueSlicedDesc = { DML_OPERATOR_SLICE1, &valueSlicedOperatorDesc};
const DML_OPERATOR_DESC transposedDesc = { DML_OPERATOR_ELEMENT_WISE_IDENTITY, &transposeOperatorDesc};
std::array<uint32_t, 4> maskSliceOutputShape {batchSize, numHeads, sequenceLength, sequenceLength};
std::array<int32_t, 4> maskSliceStrides = {1, 1, 1, 1};
std::array<uint32_t, 4> maskSliceOffsets = {0, 0, 0, 0};
TensorDesc maskSliceOutputTensorDesc;
DML_TENSOR_DESC namedMaskSliceOutputTensorDesc;
DML_SLICE1_OPERATOR_DESC maskSlicedOperatorDesc = {};
if (hasMaxSequenceMask)
{
maskSliceOutputTensorDesc = TensorDesc::ConstructDefaultTensorDesc(maskTensorDataType, maskSliceOutputShape);
namedMaskSliceOutputTensorDesc = maskSliceOutputTensorDesc.GetDmlDesc();
maskSlicedOperatorDesc.InputTensor = &inputDescs[maskIndex];
maskSlicedOperatorDesc.OutputTensor = &namedMaskSliceOutputTensorDesc;
maskSlicedOperatorDesc.DimensionCount = gsl::narrow_cast<uint32_t>(maskSliceOutputShape.size());
maskSlicedOperatorDesc.InputWindowOffsets = maskSliceOffsets.data();
maskSlicedOperatorDesc.InputWindowSizes = maskSliceOutputShape.data();
maskSlicedOperatorDesc.InputWindowStrides = maskSliceStrides.data();
}
const DML_OPERATOR_DESC maskSlicedDesc = { DML_OPERATOR_SLICE1, &maskSlicedOperatorDesc};
DML_MULTIHEAD_ATTENTION_OPERATOR_DESC mhaOperatorDesc = {};
mhaOperatorDesc.ValueTensor = hasSlicedValue ? &namedValueSlicedInputTensorDesc : nullptr;
mhaOperatorDesc.StackedQueryKeyTensor = hasSlicedValue ? &namedQueryKeyTransposedOutputTensorDesc : nullptr;
mhaOperatorDesc.StackedQueryKeyValueTensor = hasSlicedValue ? nullptr : &namedQueryKeyValueTransposedOutputTensorDesc;
if (hasMaxSequenceMask)
{
mhaOperatorDesc.MaskTensor = &namedMaskSliceOutputTensorDesc;
}
else
{
mhaOperatorDesc.MaskTensor = hasMask ? &inputDescs[maskIndex] : nullptr;
}
// mhaOperatorDesc.RelativePositionBiasTensor = hasRelativePositionBias ? &inputDescs[dmlRelativePositionBiasIndex] : nullptr;
mhaOperatorDesc.RelativePositionBiasTensor = nullptr;
mhaOperatorDesc.OutputTensor = &outputDescs[outputIndex];
mhaOperatorDesc.Scale = kernelCreationContext.GetOptionalAttribute<float>(AttrName::Scale, gsl::narrow_cast<float>(1.0f / std::sqrt(headSize)));
mhaOperatorDesc.MaskFilterValue = kernelCreationContext.GetOptionalAttribute<float>(AttrName::MaskFilterValue, -10'000.0f);
mhaOperatorDesc.HeadCount = numHeads;
mhaOperatorDesc.MaskType = maskType;
const DML_OPERATOR_DESC mhaDesc = { DML_OPERATOR_MULTIHEAD_ATTENTION, &mhaOperatorDesc };
// Construct the graph
std::vector<DML_INPUT_GRAPH_EDGE_DESC> inputEdges;
std::vector<DML_INTERMEDIATE_GRAPH_EDGE_DESC> intermediateEdges;
std::vector<DML_OUTPUT_GRAPH_EDGE_DESC> outputEdges;
std::vector<const DML_OPERATOR_DESC*> opDescs = {
&inputDequantizeOpDesc,
&weightDequantizeOpDesc,
&gemmDesc,
&mhaDesc,
};
uint32_t currentNodeIndex = 0;
const uint32_t inputDequantizeNodeIndex = currentNodeIndex++;
const uint32_t weightDequantizeNodeIndex = currentNodeIndex++;
const uint32_t gemmNodeIndex = currentNodeIndex++;
const uint32_t mhaNodeIndex = currentNodeIndex++;
uint32_t valueSliceNodeIndex = 0;
uint32_t queryKeySliceNodeIndex = 0;
uint32_t queryKeyTransposedNodeIndex = 0;
uint32_t queryKeyValueTransposedNodeIndex = 0;
if (hasSlicedValue)
{
opDescs.push_back(&queryKeySlicedDesc);
queryKeySliceNodeIndex = currentNodeIndex++;
opDescs.push_back(&valueSlicedDesc);
valueSliceNodeIndex = currentNodeIndex++;
opDescs.push_back(&transposedDesc);
queryKeyTransposedNodeIndex = currentNodeIndex++;
}
else
{
opDescs.push_back(&transposedDesc);
queryKeyValueTransposedNodeIndex = currentNodeIndex++;
}
uint32_t maskSliceNodeIndex = 0;
if (hasMaxSequenceMask)
{
opDescs.push_back(&maskSlicedDesc);
maskSliceNodeIndex = currentNodeIndex++;
}
DML_INPUT_GRAPH_EDGE_DESC inputToDequantizeEdge = {};
inputToDequantizeEdge.GraphInputIndex = InputIndex::inputIndex;
inputToDequantizeEdge.ToNodeIndex = inputDequantizeNodeIndex;
inputToDequantizeEdge.ToNodeInputIndex = 0;
inputEdges.push_back(inputToDequantizeEdge);
DML_INPUT_GRAPH_EDGE_DESC inputScaleToDequantizeEdge = {};
inputScaleToDequantizeEdge.GraphInputIndex = InputIndex::inputScaleIndex;
inputScaleToDequantizeEdge.ToNodeIndex = inputDequantizeNodeIndex;
inputScaleToDequantizeEdge.ToNodeInputIndex = 1;
inputEdges.push_back(inputScaleToDequantizeEdge);
DML_INPUT_GRAPH_EDGE_DESC inputZeroPointToDequantizeEdge = {};
inputZeroPointToDequantizeEdge.GraphInputIndex = InputIndex::inputZeroPointIndex;
inputZeroPointToDequantizeEdge.ToNodeIndex = inputDequantizeNodeIndex;
inputZeroPointToDequantizeEdge.ToNodeInputIndex = 2;
inputEdges.push_back(inputZeroPointToDequantizeEdge);
DML_INPUT_GRAPH_EDGE_DESC weightToDequantizeEdge = {};
weightToDequantizeEdge.GraphInputIndex = InputIndex::weightsIndex;
weightToDequantizeEdge.ToNodeIndex = weightDequantizeNodeIndex;
weightToDequantizeEdge.ToNodeInputIndex = 0;
inputEdges.push_back(weightToDequantizeEdge);
DML_INPUT_GRAPH_EDGE_DESC weightScaleToDequantizeEdge = {};
weightScaleToDequantizeEdge.GraphInputIndex = InputIndex::weightScaleIndex;
weightScaleToDequantizeEdge.ToNodeIndex = weightDequantizeNodeIndex;
weightScaleToDequantizeEdge.ToNodeInputIndex = 1;
inputEdges.push_back(weightScaleToDequantizeEdge);
DML_INPUT_GRAPH_EDGE_DESC weightZeroPointToDequantizeEdge = {};
weightZeroPointToDequantizeEdge.GraphInputIndex = InputIndex::weightZeroPointIndex;
weightZeroPointToDequantizeEdge.ToNodeIndex = weightDequantizeNodeIndex;
weightZeroPointToDequantizeEdge.ToNodeInputIndex = 2;
inputEdges.push_back(weightZeroPointToDequantizeEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC inputQuantizeToGemmEdge = {};
inputQuantizeToGemmEdge.FromNodeIndex = inputDequantizeNodeIndex;
inputQuantizeToGemmEdge.FromNodeOutputIndex = 0;
inputQuantizeToGemmEdge.ToNodeIndex = gemmNodeIndex;
inputQuantizeToGemmEdge.ToNodeInputIndex = 0;
intermediateEdges.push_back(inputQuantizeToGemmEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC weightQuantizeToGemmEdge = {};
weightQuantizeToGemmEdge.FromNodeIndex = weightDequantizeNodeIndex;
weightQuantizeToGemmEdge.FromNodeOutputIndex = 0;
weightQuantizeToGemmEdge.ToNodeIndex = gemmNodeIndex;
weightQuantizeToGemmEdge.ToNodeInputIndex = 1;
intermediateEdges.push_back(weightQuantizeToGemmEdge);
if (hasBias)
{
DML_INPUT_GRAPH_EDGE_DESC biasToGemmEdge = {};
biasToGemmEdge.GraphInputIndex = biasIndex;
biasToGemmEdge.ToNodeIndex = gemmNodeIndex;
biasToGemmEdge.ToNodeInputIndex = 2;
inputEdges.push_back(biasToGemmEdge);
}
if (hasMask)
{
if (hasUnpaddedBounds)
{
DML_INPUT_GRAPH_EDGE_DESC maskToMhaEdge = {};
maskToMhaEdge.GraphInputIndex = maskIndex;
maskToMhaEdge.ToNodeIndex = mhaNodeIndex;
maskToMhaEdge.ToNodeInputIndex = mhaMaskIndex;
inputEdges.push_back(maskToMhaEdge);
}
else if (hasMaxSequenceMask)
{
DML_INPUT_GRAPH_EDGE_DESC maskToMaskSliceEdge = {};
maskToMaskSliceEdge.GraphInputIndex = maskIndex;
maskToMaskSliceEdge.ToNodeIndex = maskSliceNodeIndex;
maskToMaskSliceEdge.ToNodeInputIndex = 0;
inputEdges.push_back(maskToMaskSliceEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC maskSliceToMhaEdge = {};
maskSliceToMhaEdge.FromNodeIndex = maskSliceNodeIndex;
maskSliceToMhaEdge.FromNodeOutputIndex = 0;
maskSliceToMhaEdge.ToNodeIndex = mhaNodeIndex;
maskSliceToMhaEdge.ToNodeInputIndex = mhaMaskIndex;
intermediateEdges.push_back(maskSliceToMhaEdge);
}
else
{
DML_INPUT_GRAPH_EDGE_DESC maskToMhaEdge = {};
maskToMhaEdge.GraphInputIndex = maskIndex;
maskToMhaEdge.ToNodeIndex = mhaNodeIndex;
maskToMhaEdge.ToNodeInputIndex = mhaMaskIndex;
inputEdges.push_back(maskToMhaEdge);
}
}
if (hasSlicedValue)
{
// We need to slice QK and V, and transpose QK
DML_INTERMEDIATE_GRAPH_EDGE_DESC gemmToQueryKeySliceEdge = {};
gemmToQueryKeySliceEdge.FromNodeIndex = gemmNodeIndex;
gemmToQueryKeySliceEdge.FromNodeOutputIndex = 0;
gemmToQueryKeySliceEdge.ToNodeIndex = queryKeySliceNodeIndex;
gemmToQueryKeySliceEdge.ToNodeInputIndex = 0;
intermediateEdges.push_back(gemmToQueryKeySliceEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC queryKeySliceToTransposeEdge = {};
queryKeySliceToTransposeEdge.FromNodeIndex = queryKeySliceNodeIndex;
queryKeySliceToTransposeEdge.FromNodeOutputIndex = 0;
queryKeySliceToTransposeEdge.ToNodeIndex = queryKeyTransposedNodeIndex;
queryKeySliceToTransposeEdge.ToNodeInputIndex = 0;
intermediateEdges.push_back(queryKeySliceToTransposeEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC queryKeyTransposedToMhaEdge = {};
queryKeyTransposedToMhaEdge.FromNodeIndex = queryKeyTransposedNodeIndex;
queryKeyTransposedToMhaEdge.FromNodeOutputIndex = 0;
queryKeyTransposedToMhaEdge.ToNodeIndex = mhaNodeIndex;
queryKeyTransposedToMhaEdge.ToNodeInputIndex = mhaStackedQueryKeyIndex;
intermediateEdges.push_back(queryKeyTransposedToMhaEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC gemmToValueSliceEdge = {};
gemmToValueSliceEdge.FromNodeIndex = gemmNodeIndex;
gemmToValueSliceEdge.FromNodeOutputIndex = 0;
gemmToValueSliceEdge.ToNodeIndex = valueSliceNodeIndex;
gemmToValueSliceEdge.ToNodeInputIndex = 0;
intermediateEdges.push_back(gemmToValueSliceEdge);
DML_INTERMEDIATE_GRAPH_EDGE_DESC valueSliceToMhaEdge = {};
valueSliceToMhaEdge.FromNodeIndex = valueSliceNodeIndex;
valueSliceToMhaEdge.FromNodeOutputIndex = 0;
valueSliceToMhaEdge.ToNodeIndex = mhaNodeIndex;
valueSliceToMhaEdge.ToNodeInputIndex = mhaValueIndex;
intermediateEdges.push_back(valueSliceToMhaEdge);
}
else
{
DML_INTERMEDIATE_GRAPH_EDGE_DESC gemmToQueryKeyValueTransposeEdge = {};
gemmToQueryKeyValueTransposeEdge.FromNodeIndex = gemmNodeIndex;
gemmToQueryKeyValueTransposeEdge.FromNodeOutputIndex = 0;
gemmToQueryKeyValueTransposeEdge.ToNodeIndex = queryKeyValueTransposedNodeIndex;
gemmToQueryKeyValueTransposeEdge.ToNodeInputIndex = 0;
intermediateEdges.push_back(gemmToQueryKeyValueTransposeEdge);
// All we need to do here is transpose the stacked QKV tensor into something DML supports
DML_INTERMEDIATE_GRAPH_EDGE_DESC queryKeyValueTransposedToMhaEdge = {};
queryKeyValueTransposedToMhaEdge.FromNodeIndex = queryKeyValueTransposedNodeIndex;
queryKeyValueTransposedToMhaEdge.FromNodeOutputIndex = 0;
queryKeyValueTransposedToMhaEdge.ToNodeIndex = mhaNodeIndex;
queryKeyValueTransposedToMhaEdge.ToNodeInputIndex = mhaStackedQueryKeyValueIndex;
intermediateEdges.push_back(queryKeyValueTransposedToMhaEdge);
}
DML_OUTPUT_GRAPH_EDGE_DESC mhaToOutputEdge = {};
mhaToOutputEdge.FromNodeIndex = mhaNodeIndex;
mhaToOutputEdge.FromNodeOutputIndex = 0;
mhaToOutputEdge.GraphOutputIndex = 0;
outputEdges.push_back(mhaToOutputEdge);
MLOperatorGraphDesc operatorGraphDesc = {};
operatorGraphDesc.inputEdgeCount = gsl::narrow_cast<uint32_t>(inputEdges.size());
operatorGraphDesc.inputEdges = inputEdges.data();
operatorGraphDesc.intermediateEdgeCount = gsl::narrow_cast<uint32_t>(intermediateEdges.size());
operatorGraphDesc.intermediateEdges = intermediateEdges.data();
operatorGraphDesc.outputEdgeCount = gsl::narrow_cast<uint32_t>(outputEdges.size());
operatorGraphDesc.outputEdges = outputEdges.data();
operatorGraphDesc.nodeCount = gsl::narrow_cast<uint32_t>(opDescs.size());
operatorGraphDesc.nodesAsOpDesc = opDescs.data();
SetDmlOperatorGraphDesc(std::move(operatorGraphDesc), kernelCreationContext);
}
};
void CALLBACK QueryQAttention(IMLOperatorSupportQueryContextPrivate* context, /*out*/ bool* isSupported)
{
*isSupported = false;
// `past` input tensor is not supported yet
if (context->IsInputValid(8))
{
return;
}
// `present` output tensor is not supported yet
if (context->IsOutputValid(1))
{
return;
}
// `unidirectional == 1` is not supported yet
MLOperatorAttributes attributes(context);
if (attributes.GetOptionalAttribute<int32_t>(AttrName::Unidirectional, 0) != 0)
{
return;
}
// `do_rotary == 1` is not supported yet
if (attributes.GetOptionalAttribute<int32_t>(AttrName::DoRotary, 0) != 0)
{
return;
}
*isSupported = true;
}
DML_OP_DEFINE_CREATION_FUNCTION(QAttention, DmlOperatorQAttention);
} // namespace Dml

View file

@ -171,4 +171,4 @@ void CALLBACK QueryQLinearSigmoid(IMLOperatorSupportQueryContextPrivate* context
}
DML_OP_DEFINE_CREATION_FUNCTION(QLinearSigmoid, DmlOperatorQLinearSigmoid);
} // namespace Dml
} // namespace Dml

View file

@ -441,6 +441,7 @@ DML_OP_EXTERN_CREATION_FUNCTION(ConvInteger);
DML_OP_EXTERN_CREATION_FUNCTION(Trilu);
DML_OP_EXTERN_CREATION_FUNCTION(Shape);
DML_OP_EXTERN_CREATION_FUNCTION(Size);
DML_OP_EXTERN_CREATION_FUNCTION(QAttention);
DML_OP_EXTERN_CREATION_FUNCTION(Attention);
DML_OP_EXTERN_CREATION_FUNCTION(MultiHeadAttention);
DML_OP_EXTERN_CREATION_FUNCTION(NonZero);
@ -461,6 +462,7 @@ DML_OP_EXTERN_QUERY_FUNCTION(Pad);
DML_OP_EXTERN_QUERY_FUNCTION(LayerNormalization);
DML_OP_EXTERN_QUERY_FUNCTION(SkipLayerNormalization);
DML_OP_EXTERN_QUERY_FUNCTION(QLinearSigmoid);
DML_OP_EXTERN_QUERY_FUNCTION(QAttention);
DML_OP_EXTERN_QUERY_FUNCTION(Attention);
constexpr static std::array<const char*, 1> typeNameListDefault = {"T"};
@ -535,14 +537,22 @@ constexpr static std::array<SupportedTensorDataTypes, 2> supportedTypeListLayerN
constexpr static std::array<SupportedTensorDataTypes, 2> supportedTypeListShape = {SupportedTensorDataTypes::All, SupportedTensorDataTypes::Int64};
constexpr static std::array<SupportedTensorDataTypes, 2> supportedTypeListSize = {SupportedTensorDataTypes::All, SupportedTensorDataTypes::Int64};
constexpr static std::array<SupportedTensorDataTypes, 1> supportedTypeListQLinearSigmoid = {SupportedTensorDataTypes::UInt8 | SupportedTensorDataTypes::Int8};
constexpr static std::array<SupportedTensorDataTypes, 4> supportedTypeListQAttention = {
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Float16to32,
SupportedTensorDataTypes::Int32
};
constexpr static std::array<SupportedTensorDataTypes, 2> supportedTypeListAttention = {SupportedTensorDataTypes::Float16to32, SupportedTensorDataTypes::Int32};
constexpr static std::array<SupportedTensorDataTypes, 2> supportedTypeListGroupNorm = {SupportedTensorDataTypes::Float16to32, SupportedTensorDataTypes::Float16to32};
constexpr static std::array<SupportedTensorDataTypes, 1> supportedTypeListNonZero = {SupportedTensorDataTypes::Float16to32 | SupportedTensorDataTypes::Ints8Bit | SupportedTensorDataTypes::Ints16Bit | SupportedTensorDataTypes::Ints32Bit | SupportedTensorDataTypes::Bool};
constexpr static std::array<SupportedTensorDataTypes, 3> supportedTypeListQLinearMatMul = {
SupportedTensorDataTypes::Int8|SupportedTensorDataTypes::UInt8,
SupportedTensorDataTypes::Int8|SupportedTensorDataTypes::UInt8,
SupportedTensorDataTypes::Int8|SupportedTensorDataTypes::UInt8
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Ints8Bit
};
constexpr static std::array<SupportedTensorDataTypes, 3> supportedTypeListMatMulIntegerToFloat = {
@ -552,9 +562,9 @@ constexpr static std::array<SupportedTensorDataTypes, 3> supportedTypeListMatMul
};
constexpr static std::array<SupportedTensorDataTypes, 4> supportedTypeListQLinearConv = {
SupportedTensorDataTypes::Int8|SupportedTensorDataTypes::UInt8,
SupportedTensorDataTypes::Int8|SupportedTensorDataTypes::UInt8,
SupportedTensorDataTypes::Int8|SupportedTensorDataTypes::UInt8,
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Ints8Bit,
SupportedTensorDataTypes::Int32
};
@ -956,6 +966,7 @@ constexpr static OperatorRegistrationInformation operatorRegistrationInformation
{REG_INFO_MS( 1, DynamicQuantizeMatMul, typeNameListTwo, supportedTypeListDynamicQuantizeLinear, DmlGraphSupport::Supported)},
{REG_INFO_MS( 1, FusedMatMulActivation, typeNameListDefault, supportedTypeListFloat16to32, DmlGraphSupport::Supported)},
{REG_INFO_MS( 1, QLinearSigmoid, typeNameListDefault, supportedTypeListQLinearSigmoid, DmlGraphSupport::Supported, requiredConstantCpuInputs(), std::nullopt, QueryQLinearSigmoid)},
{REG_INFO_MS( 1, QAttention, typeNameListFour, supportedTypeListQAttention, DmlGraphSupport::Supported, requiredConstantCpuInputs(), std::nullopt, QueryQAttention)},
{REG_INFO_MS( 1, Attention, typeNameListAttention, supportedTypeListAttention, DmlGraphSupport::Supported, requiredConstantCpuInputs(), std::nullopt, QueryAttention)},
{REG_INFO_MS( 1, MultiHeadAttention, typeNameListAttention, supportedTypeListAttention, DmlGraphSupport::Supported)},

View file

@ -1589,6 +1589,7 @@ using ShapeInferenceHelper_Affine = GetOutputShapeAsInputShapeHelper;
using ShapeInferenceHelper_QuantizeLinear = GetOutputShapeAsInputShapeHelper;
using ShapeInferenceHelper_DequantizeLinear = GetOutputShapeAsInputShapeHelper;
using ShapeInferenceHelper_QLinearSigmoid = GetOutputShapeAsInputShapeHelper;
using ShapeInferenceHelper_QAttention = AttentionHelper;
using ShapeInferenceHelper_Attention = AttentionHelper;
using ShapeInferenceHelper_MultiHeadAttention = MultiHeadAttentionHelper;
using ShapeInferenceHelper_Sign = GetBroadcastedOutputShapeHelper;

View file

@ -428,6 +428,7 @@ namespace OperatorHelper
static const int sc_sinceVer_FusedMatMul = 1;
static const int sc_sinceVer_FusedMatMulActivation = 1;
static const int sc_sinceVer_QLinearSigmoid = 1;
static const int sc_sinceVer_QAttention = 1;
static const int sc_sinceVer_Attention = 1;
static const int sc_sinceVer_MatMulIntegerToFloat = 1;
static const int sc_sinceVer_MultiHeadAttention = 1;

View file

@ -20,7 +20,8 @@ namespace test {
enum class EP : char {
CPU,
CUDA,
DNNL
DNNL,
DML
};
// input: [batch_size, sequence_length, hidden_size]
@ -111,7 +112,9 @@ void RunQAttention(const std::vector<float>& input_data,
execution_providers.push_back(DefaultCudaExecutionProvider());
} else if constexpr (ep == EP::CPU) {
execution_providers.push_back(DefaultCpuExecutionProvider());
} else { // onednn ep
} else if constexpr (ep == EP::DML) {
execution_providers.push_back(DefaultDmlExecutionProvider());
} else{ // onednn ep
execution_providers.push_back(DefaultDnnlExecutionProvider());
}
@ -192,6 +195,52 @@ static void RunQAttentionDNNL(
#endif
}
static void RunQAttentionDML(
const std::vector<float>& input_data,
const std::vector<float>& weights_data,
const std::vector<float>& bias_data,
const std::vector<int32_t>& mask_index_data,
const std::vector<float>& output_data,
int batch_size,
int sequence_length,
int hidden_size,
int number_of_heads,
bool use_special_quantize_parameter = true,
bool is_unidirectional = false,
int input_hidden_size = 0) {
// Return without running code if USE_DML is not defined
#ifdef USE_DML
bool enable_dml = (nullptr != DefaultDmlExecutionProvider().get());
if (enable_dml) {
quantization::Params<uint8_t> input_quant_params(/*scale=*/0.0f, /*zero_point=*/0);
quantization::Params<int8_t> weights_quant_params(/*scale=*/0.0f, /*zero_point=*/0);
if (use_special_quantize_parameter) {
input_quant_params.scale = 0.1f;
weights_quant_params.scale = 0.1f;
input_quant_params.zero_point = 128;
weights_quant_params.zero_point = 1;
}
RunQAttention<uint8_t, int8_t, EP::DML>(
input_data, weights_data, bias_data, mask_index_data, output_data, input_quant_params, weights_quant_params,
batch_size, sequence_length, hidden_size, number_of_heads, is_unidirectional, false, input_hidden_size);
}
#else
ORT_UNUSED_PARAMETER(input_data);
ORT_UNUSED_PARAMETER(weights_data);
ORT_UNUSED_PARAMETER(bias_data);
ORT_UNUSED_PARAMETER(mask_index_data);
ORT_UNUSED_PARAMETER(output_data);
ORT_UNUSED_PARAMETER(batch_size);
ORT_UNUSED_PARAMETER(sequence_length);
ORT_UNUSED_PARAMETER(hidden_size);
ORT_UNUSED_PARAMETER(number_of_heads);
ORT_UNUSED_PARAMETER(use_special_quantize_parameter);
ORT_UNUSED_PARAMETER(is_unidirectional);
ORT_UNUSED_PARAMETER(input_hidden_size);
#endif
}
static void RunQAttentionU8U8(
const std::vector<float>& input_data,
const std::vector<float>& weights_data,
@ -272,6 +321,9 @@ static void RunQAttentionAll(
RunQAttentionDNNL(input_data, weight_data, bias_data, mask_index_data, output_data,
batch_size, sequence_length, hidden_size, number_of_heads,
use_special_quantize_parameter, is_unidirectional, input_hidden_size);
RunQAttentionDML(input_data, weight_data, bias_data, mask_index_data, output_data,
batch_size, sequence_length, hidden_size, number_of_heads,
use_special_quantize_parameter, is_unidirectional, input_hidden_size);
}
// ONEDNN EP only supports 2D raw mask