1f:{"diffs":[{"old_path":"src/algorithm/impl/operator/alltoall_operator.cc","new_path":"src/algorithm/impl/operator/alltoall_operator.cc","old_blob_id":"43c9efc5a537f42a6f925c785a8bce3939ee75b1","new_blob_id":"627793dbe5e8a3ec0936f5b400e70ba4d8ef5a89","file_path":"src/algorithm/impl/operator/alltoall_operator.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -410,7 +410,7 @@ HcclResult AlltoAllOperator::PreparePreOpParam(OpParam& preProcessOpParam,\n preProcessOpParam.DataDes.count = (preMetaInfo->outputSize / stepSize);\n preProcessOpParam.DataDes.dataType = HCCL_DATA_TYPE_UINT64;\n preProcessOpParam.stream = preProcessStream;\n- preProcessOpParam.aicpuUnfoldMode = deviceType_ == DevType::DEV_TYPE_910_93 && GetExternalInputHcclAicpuUnfold();\n+ preProcessOpParam.aicpuUnfoldMode = deviceType_ == DevType::DEV_TYPE_910_93 && topoMatcher_->GetAicpuUnfoldConfig();\n return HCCL_SUCCESS;\n }\n \n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":1,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/common/src/topo/topo_device/topoinfo_detect_device.cc","new_path":"src/framework/common/src/topo/topo_device/topoinfo_detect_device.cc","old_blob_id":"4474d1ac31d17da5cfac9c703be668b79042b2ca","new_blob_id":"cfe5226eb0a6e5deb594b5c62ad73650e818bf1b","file_path":"src/framework/common/src/topo/topo_device/topoinfo_detect_device.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -115,7 +115,7 @@ HcclResult TopoInfoDetect::PrepareHandle(HcclRankHandle &rankHandle, std::vector\n }\n \n HcclResult TopoInfoDetect::SetupAgent(u32 rankSize, u32 myrank, const HcclRootHandle &rootInfo,\n- const HcclRankHandle &rankHandle)\n+ const HcclRankHandle &rankHandle, const CommConfig &commConfig)\n {\n return HCCL_E_NOT_SUPPORT;\n }\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":1,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/common/src/topo/topoinfo_detect.cc","new_path":"src/framework/common/src/topo/topoinfo_detect.cc","old_blob_id":"68adf427f65a4efa7703329556577598e23c24e3","new_blob_id":"bd2ed741934306ea98ce0a895bfb291f48f0cb0b","file_path":"src/framework/common/src/topo/topoinfo_detect.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$2d","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":3,"removed_lines":2,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/common/src/topo/topoinfo_detect.h","new_path":"src/framework/common/src/topo/topoinfo_detect.h","old_blob_id":"ef760cb9b837692a652e8c0eda7c222fafe01459","new_blob_id":"d42f0346859ad8731ecea5e2db5a02edc7f5559d","file_path":"src/framework/common/src/topo/topoinfo_detect.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$2e","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":2,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/communicator/comm_config.cc","new_path":"src/framework/communicator/comm_config.cc","old_blob_id":"508b6d30a13d5e07b7e1616666f50590c6b3db32","new_blob_id":"e7b94e64922de2bdf50f739ebf95171a04033d61","file_path":"src/framework/communicator/comm_config.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -350,7 +350,15 @@ HcclResult CommConfig::SetConfigOpExpansionMode(const CommConfigHandle &config)\n break;\n case COMM_CONFIG_OPEXPANSION_AICPU:\n // 目前只有A3和300I支持Aicpu展开\n- HCCL_WARNING(\"Only A3 and 300I support aicpu unfold, set aicpuUnfold_ to [%d] and aivMode_ to [%d].\", aicpuUnfold_, aivMode_);\n+ DevType deviceType;\n+ CHK_RET(hrtGetDeviceType(deviceType));\n+ if (deviceType == DevType::DEV_TYPE_910_93) {\n+ aicpuUnfold_ = true;\n+ aivMode_ = false;\n+ HCCL_INFO(\"CommConfig is set to 2(aicpuUnfold_), aicpuUnfold_ is [%d] and aivMode_ is [%d].\", aicpuUnfold_, aivMode_);\n+ } else {\n+ HCCL_WARNING(\"Only A3 and 300I support aicpu unfold, set aicpuUnfold_ to [%d] and aivMode_ to [%d].\", aicpuUnfold_, aivMode_);\n+ } \n break;\n case COMM_CONFIG_OPEXPANSION_AIV:\n aivMode_ = true;\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":9,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/communicator/impl/hccl_communicator.cc","new_path":"src/framework/communicator/impl/hccl_communicator.cc","old_blob_id":"35c032df1899bd8548542ca0c8d5fbd233139f15","new_blob_id":"677fd6055a45911d6602fd17e13591f190240122","file_path":"src/framework/communicator/impl/hccl_communicator.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$2f","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":3,"removed_lines":3,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/communicator/impl/hccl_communicator_host.cc","new_path":"src/framework/communicator/impl/hccl_communicator_host.cc","old_blob_id":"104447d27c76ce44d1857429189ab1b64d44f1d1","new_blob_id":"8c4418e7cb232c549f0f0e15aa79432401afb0dd","file_path":"src/framework/communicator/impl/hccl_communicator_host.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$30","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":29,"removed_lines":29,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.cc","new_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.cc","old_blob_id":"d32a36a46c26acd3d57569bad966bfe88890b007","new_blob_id":"f162540de2c3648a0c24202f36d695cadadabe6f","file_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -34,9 +34,10 @@ std::unique_ptr g_launchStream = nullptr;\n std::mutex g_launchMutex;\n \n HcclOneSidedService::HcclOneSidedService(unique_ptr &socketManager,\n- unique_ptr ¬ifyPool)\n+ unique_ptr ¬ifyPool, const CommConfig &commConfig)\n : IHcclOneSidedService(socketManager, notifyPool)\n {\n+ commConfig_ = commConfig;\n }\n \n HcclOneSidedService::~HcclOneSidedService()\n@@ -332,7 +333,7 @@ HcclResult HcclOneSidedService::InitAicpuUnfoldMode()\n DevType deviceType;\n CHK_RET(hrtGetDeviceType(deviceType));\n aicpuUnfoldMode_ = (deviceType == DevType::DEV_TYPE_910_93) &&\n- GetExternalInputHcclAicpuUnfold(); // keep env flag for perf test\n+ commConfig_.GetConfigAicpuUnfold(); // keep env flag for perf test\n HCCL_INFO(\"[InitAicpuUnfoldMode] A3[%u] rdma[%u] aicpu[%u]\", (deviceType == DevType::DEV_TYPE_910_93),\n (netDevRdmaCtx_ != nullptr), aicpuUnfoldMode_);\n if (aicpuUnfoldMode_) {\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":3,"removed_lines":2,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.h","new_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.h","old_blob_id":"accc5447ed7730ce769be6ed2cdbf5947efccab8","new_blob_id":"575b7cfe7c0a1bbe97a3e29ae197c5540eb7a039","file_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -22,6 +22,7 @@\n #include \"hccl_mem.h\"\n #include \"global_mem_record.h\"\n #include \"aicpu_operator_pub.h\"\n+#include \"comm_config_pub.h\"\n \n using HcclBatchData = struct HcclBatchDataDef {\n HcclComm comm;\n@@ -65,7 +66,7 @@ public:\n };\n \n HcclOneSidedService(std::unique_ptr &socketManager,\n- std::unique_ptr ¬ifyPool);\n+ std::unique_ptr ¬ifyPool, const CommConfig &commConfig);\n \n // 父类Config()等已经完成必要参数的配置\n HcclOneSidedService() = default;\n@@ -179,6 +180,7 @@ private:\n DeviceMem commResParaDevice_;\n DeviceMem execStreamContext_;\n aclrtBinHandle binHandle_ = nullptr;\n+ CommConfig commConfig_;\n };\n }\n \n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":3,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/communicator/impl/one_sided_service/one_sided_service_adapt.cc","new_path":"src/framework/communicator/impl/one_sided_service/one_sided_service_adapt.cc","old_blob_id":"6d7baec8b7ee1f37e70e987b771a07639a004507","new_blob_id":"a7521e1e281181a6ed51ff6dd6ada49c99d48528","file_path":"src/framework/communicator/impl/one_sided_service/one_sided_service_adapt.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -487,10 +487,10 @@ inline static HcclResult HcclMemHandleParamCheck(void *memHandle, const std::str\n \n // 通信域创建OneSidedService对象的回调函数\n HcclResult HcclBuildOneSidedService(std::unique_ptr &service, std::unique_ptr &socketManager,\n- std::unique_ptr ¬ifyPool)\n+ std::unique_ptr ¬ifyPool, const CommConfig &commConfig)\n {\n EXCEPTION_HANDLE_BEGIN\n- service = std::make_unique(socketManager, notifyPool);\n+ service = std::make_unique(socketManager, notifyPool, commConfig);\n EXCEPTION_HANDLE_END\n return HCCL_SUCCESS;\n }\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":2,"removed_lines":2,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/framework/op_base/src/op_base.cc","new_path":"src/framework/op_base/src/op_base.cc","old_blob_id":"d5e5cef775f6914a520a1d5bdd1a25bf51ffd486","new_blob_id":"12670e249ec161f965e3e51452e0a68cc3f5748f","file_path":"src/framework/op_base/src/op_base.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$31","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":3,"removed_lines":2,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"test/ut/misc/ut_onesided_service.cc","new_path":"test/ut/misc/ut_onesided_service.cc","old_blob_id":"9a75c402fb474126c0b6650e6d7c2faf7794ef54","new_blob_id":"4abfdf2b5bf7d16be559cc915eeb36be2630f104","file_path":"test/ut/misc/ut_onesided_service.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$32","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":9,"removed_lines":5,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"test/ut/platform/hcom/ut_comm_config.cc","new_path":"test/ut/platform/hcom/ut_comm_config.cc","old_blob_id":"84dfeb6e0b357fa863a4a43c45a67fbf0c60f9d2","new_blob_id":"57c636e27aa5ec5331e498357399837e8b2a733d","file_path":"test/ut/platform/hcom/ut_comm_config.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$33","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":44,"removed_lines":0,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null}],"diff_refs":{"base_sha":"32f4d02b5334f050a8f533e588a551729797c0c9","head_sha":"63b9e506da003b031eeb40fb29d389ad8b67c0c1","start_sha":"32f4d02b5334f050a8f533e588a551729797c0c9"},"added_lines":112,"removed_lines":50,"change_file_count":13,"change_line_count":162,"too_large":false,"total":13}

hcomm

hcomm