@@ -6628,14 +6628,18 @@ namespace hccl u8 HcclCommunicator::GetOrderLaunchMode (bool isCapture) { + bool isSupportHcomAttachedStream = !(attachedStreams_.empty() || attachedStreams_[0].ptr() == nullptr); // true 表示图模式下成功申请附属从流 + const u8 orderLaunchInvalidInHcom = 255; u8 orderLaunchMode = 0; HcclWorkflowMode mode = GetWorkflowMode(); if (isCapture) { orderLaunchMode = static_cast(AicpuNotifyMode::ACLGRAPH_MODE); } else if (mode == HcclWorkflowMode::HCCL_WORKFLOW_MODE_OP_BASE) { orderLaunchMode = static_cast(AicpuNotifyMode::OPBASE_MODE); - } else if (mode == HcclWorkflowMode::HCCL_WORKFLOW_MODE_OPS_KERNEL_INFO_LIB) { + } else if (mode == HcclWorkflowMode::HCCL_WORKFLOW_MODE_OPS_KERNEL_INFO_LIB && isSupportHcomAttachedStream) { orderLaunchMode = static_cast(AicpuNotifyMode::HCOM_MODE); + } else { + orderLaunchMode = orderLaunchInvalidInHcom; } return orderLaunchMode; @@ -6643,12 +6647,14 @@ namespace hccl HcclResult HcclCommunicator::InitAndCheckAicpuOrderNotify(u8 &orderLaunchMode) { + const u8 opbaseOrderLaunchMode = 0; + const u8 aclgraphOrderLaunchMode = 1; u32 idx0; u32 idx1; - if (orderLaunchMode == 0) { + if (orderLaunchMode == opbaseOrderLaunchMode) { idx0 = static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_OPBASE_0); idx1 = static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_OPBASE_1); - } else if (orderLaunchMode == 1) { + } else if (orderLaunchMode == aclgraphOrderLaunchMode) { idx0 = static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_ACLGRAPH_0); idx1 = static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_ACLGRAPH_1); } else { @@ -6695,15 +6701,18 @@ namespace hccl Stream kfcOpStream; HcclWorkflowMode mode = GetWorkflowMode(); + bool isSupportHcomAttachedStream = !(attachedStreams_.empty() || attachedStreams_[0].ptr() == nullptr); // true 表示图模式下成功申请附属从流 if (opParam.isCapture || mode == HcclWorkflowMode::HCCL_WORKFLOW_MODE_OP_BASE) { kfcOpStream = opStream_; } else { - // 如果是图模式，则尝试从附属从流中获取一下stream，如果能拿到则使用，否则报错 - if (attachedStreams_.empty() || attachedStreams_[0].ptr() == nullptr) { - HCCL_ERROR("[HcclCommunicator][AicpuKfcTilingDataLaunchIn] attachedStreams_ is invalid in graph mode"); - return HCCL_E_NOT_FOUND; + // 如果是图模式，则尝试从附属从流中获取一下stream，如果能拿到则使用，否则退化 + if (isSupportHcomAttachedStream) { + HCCL_INFO("[HcclCommunicator][AicpuKfcTilingDataLaunchIn] attachedStreams_ is valid in graph mode"); + kfcOpStream = attachedStreams_[0]; + } else { + HCCL_INFO("[HcclCommunicator][AicpuKfcTilingDataLaunchIn] attachedStreams_ is invalid in graph mode"); + kfcOpStream = opParam.stream; } - kfcOpStream = attachedStreams_[0]; } uint64_t beginTime = hrtMsprofSysCycleTime(); std::string profName = GetCMDTypeEnumStr(opParam.opType); @@ -6752,7 +6761,7 @@ namespace hccl notify0 = localAiCpuOpNotify_[static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_OPBASE_0)]; notify1 = localAiCpuOpNotify_[static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_OPBASE_1)]; CHK_RET(orderLaunch.OpbaseLaunchInOrder(identifier_, kfcOpStream, notify0, notify1, timeOut)); - } else if (mode == HcclWorkflowMode::HCCL_WORKFLOW_MODE_OPS_KERNEL_INFO_LIB) { + } else if (mode == HcclWorkflowMode::HCCL_WORKFLOW_MODE_OPS_KERNEL_INFO_LIB && isSupportHcomAttachedStream) { notify0 = localAiCpuOpNotify_[static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_HCOM_0)]; notify1 = localAiCpuOpNotify_[static_cast(AicpuLocalNotifyIdx::ORDER_INDEX_HCOM_1)]; CHK_RET(orderLaunch.HcomLaunchInOrder(identifier_, kfcOpStream, graphId_, notify0,

hcomm

hcomm