1f:{"diffs":[{"old_path":"src/framework/communicator/impl/hccl_communicator.h","new_path":"src/framework/communicator/impl/hccl_communicator.h","old_blob_id":"7266fe5b7a9324aba9281ecc03b747ba2e76e284","new_blob_id":"f6cbfc53625d8ac157e74a6146f6c88dee4f9230","file_path":"src/framework/communicator/impl/hccl_communicator.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -651,6 +651,7 @@ private:\n bool interServer_;\n std::unique_ptr workSpaceRes_;\n std::vector enableP2PDevices_;\n+ std::unordered_set enableP2PRankIds_;\n bool isSingleMeshAggregation_;\n CCLBufferManager cclBufferManager_;\n bool isExecuteProfilingInit_;\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":1,"removed_lines":0,"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":"11562e4d0cd53c0501f93132f29a4ad460fd3549","new_blob_id":"436f35d11ce0b4aea2a9165b9f0b5541e0e46ce2","file_path":"src/framework/communicator/impl/hccl_communicator_host.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":15,"removed_lines":8,"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_conn.cc","new_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_conn.cc","old_blob_id":"028d2447b4b916c2845cc2c1ee0406bc6fb47954","new_blob_id":"65acc634b0c8ebaf2959fc0b6ec140accdbc493b","file_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_conn.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$2e","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":15,"removed_lines":7,"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_conn.h","new_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_conn.h","old_blob_id":"9de1e621b032d3a713f9dd23964cdbef8ad06d5d","new_blob_id":"194b495736be04e19d185e0e730dd0f8c0f11d73","file_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_conn.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -46,7 +46,8 @@ public:\n const HcclRankLinkInfo &remoteRankInfo, std::unique_ptr &socketManager,\n std::unique_ptr ¬ifyPool, const HcclDispatcher &dispatcher, const bool &useRdma, u32 sdid,\n u32 serverId, u32 trafficClass = HCCL_COMM_TRAFFIC_CLASS_CONFIG_NOT_SET,\n- u32 serviceLevel = HCCL_COMM_SERVICE_LEVEL_CONFIG_NOT_SET, bool aicpuUnfoldMode = false, bool isStandardCard = false);\n+ u32 serviceLevel = HCCL_COMM_SERVICE_LEVEL_CONFIG_NOT_SET, bool aicpuUnfoldMode = false,\n+ bool isStandardCard = false, bool isNeedEnableP2P = false);\n \n ~HcclOneSidedConn();\n \n@@ -103,6 +104,8 @@ private:\n TransportDeviceNormalData transportData_;\n DeviceMem transportDataDevice_;\n bool isStandardCard_{false};\n+ bool isNeedEnableP2P_{false};\n+ std::vector enableP2PDevices_;\n };\n }\n-#endif\n\\ No newline at end of file\n+#endif\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":5,"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.cc","new_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.cc","old_blob_id":"1e172885dc0e8dc6fb400ba14644f42382d25d6a","new_blob_id":"9507d77f0be3ce600d703ce015a21cef82bea9af","file_path":"src/framework/communicator/impl/one_sided_service/hccl_one_sided_service.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":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/i_hccl_one_sided_service.cc","new_path":"src/framework/communicator/impl/one_sided_service/i_hccl_one_sided_service.cc","old_blob_id":"913facf47e08547a50d482426f80a7a3efa4258c","new_blob_id":"09286bd35fe4e53aefc3cb62da2175386038914d","file_path":"src/framework/communicator/impl/one_sided_service/i_hccl_one_sided_service.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -21,7 +21,7 @@ IHcclOneSidedService::IHcclOneSidedService(unique_ptr &socket\n }\n \n HcclResult IHcclOneSidedService::Config(const HcclDispatcher &dispatcher, const HcclRankLinkInfo &localRankInfo,\n- const RankTable_t *rankTable, std::string identifier, bool isStandardCard)\n+ const RankTable_t *rankTable, std::string identifier, bool isStandardCard, const std::unordered_set& enableP2PRankIds)\n {\n CHK_PTR_NULL(dispatcher);\n CHK_PTR_NULL(rankTable);\n@@ -32,6 +32,7 @@ HcclResult IHcclOneSidedService::Config(const HcclDispatcher &dispatcher, const\n rankTable_ = rankTable;\n identifier_ = identifier;\n isStandardCard_ = isStandardCard;\n+ enableP2PRankIds_ = enableP2PRankIds;\n \n return HCCL_SUCCESS;\n }\n","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/impl/one_sided_service/i_hccl_one_sided_service.h","new_path":"src/framework/communicator/impl/one_sided_service/i_hccl_one_sided_service.h","old_blob_id":"369be8b6af81e278c98dec6177eac3383b82605a","new_blob_id":"d01f0c43485436be13a5dac496101bddfeb01cb6","file_path":"src/framework/communicator/impl/one_sided_service/i_hccl_one_sided_service.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -14,6 +14,7 @@\n #include \n #include \n #include \n+#include \n #include \"hccl_network_pub.h\"\n #include \"hccl_socket.h\"\n #include \"topoinfo_struct.h\"\n@@ -30,7 +31,8 @@ public:\n \n // 为了尽可能保障框架依赖兼容性，除了引用以外，参数不通过构造函数传递\n virtual HcclResult Config(const HcclDispatcher &dispatcher, const HcclRankLinkInfo &localRankInfo,\n- const RankTable_t *rankTable, std::string identifier = \"\", bool isStandardCard = false);\n+ const RankTable_t *rankTable, std::string identifier = \"\", bool isStandardCard = false,\n+ const std::unordered_set& enableP2PRankIds = {});\n \n // 析构时要处理的逻辑\n virtual HcclResult DeInit();\n@@ -53,6 +55,7 @@ protected:\n \n std::string identifier_;\n bool isStandardCard_{false};\n+ std::unordered_set enableP2PRankIds_;\n };\n }\n \n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":4,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null}],"diff_refs":{"base_sha":"3453c76874680963624e9afc7f91e833c30d5ed4","head_sha":"8bcde67a2635c4911e86f5178fae5579c128df1b","start_sha":"3453c76874680963624e9afc7f91e833c30d5ed4"},"added_lines":45,"removed_lines":20,"change_file_count":7,"change_line_count":65,"too_large":false,"total":7}

hcomm

hcomm