1f:{"diffs":[{"old_path":"src/legacy/common/ip_address.h","new_path":"src/legacy/common/ip_address.h","old_blob_id":"8a64d321764cf1ee56714d2e0b622f258d75b0dc","new_blob_id":"a32cd001e2356126d89d709fe5e58a3739fc5ea5","file_path":"src/legacy/common/ip_address.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -283,6 +283,11 @@ public:\n return eid_;\n }\n \n+ void SetEid(Eid eid)\n+ {\n+ eid_ = eid;\n+ }\n+\n Eid GetReverseEid() const\n {\n Eid eidOut;\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":5,"removed_lines":0,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/common/types/mc2_type.h","new_path":"src/legacy/common/types/mc2_type.h","old_blob_id":"08cf26d941117785425f6ba1af3c5ab22e7deb77","new_blob_id":"06ce2bb5b489439b6d9112e4ebacb24a27b10f07","file_path":"src/legacy/common/types/mc2_type.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -351,7 +351,7 @@ struct HcclOpArgs {\n DataType srcDataType;\n DataType dstDataType;\n ReduceOp reduceType;\n- uint64_t count;\n+ uint64_t count{0};\n char algConfig[ALG_CONFIG_SIZE];\n HcclAccelerator commEngine;\n uint64_t reverse;\n@@ -360,6 +360,7 @@ struct HcclOpArgs {\n srcDataType = DataType::FP16;\n dstDataType = DataType::FP16;\n reduceType = ReduceOp::SUM;\n+ count = 0;\n }\n };\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/legacy/framework/communicator/communicator_impl.cc","new_path":"src/legacy/framework/communicator/communicator_impl.cc","old_blob_id":"b23d2fe2a8ac2083eaa1e341a72a51d44db421cd","new_blob_id":"fdc05c0ccfce3619a31129d5dbfd9fea8ab8be53","file_path":"src/legacy/framework/communicator/communicator_impl.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":4,"removed_lines":4,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/buffer/local_rma_buf_manager.cc","new_path":"src/legacy/framework/resource_manager/buffer/local_rma_buf_manager.cc","old_blob_id":"a72d940d3dfc3fb577c0da27307f3391d3f4ec0f","new_blob_id":"b5522fe11722775ee5d791a66de7d95bdfd30c79","file_path":"src/legacy/framework/resource_manager/buffer/local_rma_buf_manager.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":3,"removed_lines":3,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/buffer/local_rma_buf_manager.h","new_path":"src/legacy/framework/resource_manager/buffer/local_rma_buf_manager.h","old_blob_id":"ec681fc0b64fd01c4795313add0076a8ee8b1f7b","new_blob_id":"97fee4504a4b7ffeeb3b01d8a7a23c2888486cab","file_path":"src/legacy/framework/resource_manager/buffer/local_rma_buf_manager.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -28,7 +28,7 @@ public:\n \n ~LocalRmaBufManager();\n \n- LocalRmaBuffer *Reg(const string &opTag, BufferType bufferType, std::shared_ptr buffer, const PortData &portData);\n+ LocalRmaBuffer *Reg(const string &opTag, BufferType bufferType, std::shared_ptr buffer, const PortData &portData, LinkProtocol linkProtocol);\n \n HcclResult Dereg(const string &opTag);\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/legacy/framework/resource_manager/buffer/remote_rma_buf_manager.cc","new_path":"src/legacy/framework/resource_manager/buffer/remote_rma_buf_manager.cc","old_blob_id":"e587c58874a9ac394f5226b7981d1676ac2e3b5f","new_blob_id":"7059b2d4402abd0177d47c43f0f33711aa60be13","file_path":"src/legacy/framework/resource_manager/buffer/remote_rma_buf_manager.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":4,"removed_lines":4,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.cc","new_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.cc","old_blob_id":"81f7ad4230ae5887f1a80cca74e4bbef2c241943","new_blob_id":"cf8fd1d97c1c3b2722c96cc3e2d5a0be1b86fa99","file_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.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":144,"removed_lines":9,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.h","new_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.h","old_blob_id":"92967e48e3d700d87371d9206bfc690eae9ac35f","new_blob_id":"ef4a0854e535f4318f2d5092f1607f7f313b15be","file_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$31","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":21,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/notify/conn_local_cnt_notify_manager.cc","new_path":"src/legacy/framework/resource_manager/notify/conn_local_cnt_notify_manager.cc","old_blob_id":"082b0b8f0df796969f6f599fa9ef8ff59e03ca1e","new_blob_id":"6e33dffcc51c70d71cd09691f71959c85a297e1d","file_path":"src/legacy/framework/resource_manager/notify/conn_local_cnt_notify_manager.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":6,"removed_lines":4,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/notify/conn_local_notify_manager.cc","new_path":"src/legacy/framework/resource_manager/notify/conn_local_notify_manager.cc","old_blob_id":"e23420492e17b1eac1b26a25db3433bceaa1f878","new_blob_id":"757352845f521fbb69b6693667e3f907511afc40","file_path":"src/legacy/framework/resource_manager/notify/conn_local_notify_manager.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":6,"removed_lines":5,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/resource_manager/transport/mem_transport_manager.cc","new_path":"src/legacy/framework/resource_manager/transport/mem_transport_manager.cc","old_blob_id":"e77f373d81535ae6806e350cee946106f6d07e41","new_blob_id":"07d979e6c54df3da1cfb7de0c8369210ea6043ca","file_path":"src/legacy/framework/resource_manager/transport/mem_transport_manager.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$34","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":14,"removed_lines":8,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/service/coll_service_base.cc","new_path":"src/legacy/framework/service/coll_service_base.cc","old_blob_id":"df5584853f6fea49e6808a4aeea74428d072c4f4","new_blob_id":"a76e3472c716c178f86f5b55afbb5eb1a24ed1a3","file_path":"src/legacy/framework/service/coll_service_base.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$35","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":6,"removed_lines":4,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/topo/new_topo_builder/common/topo_common_types.h","new_path":"src/legacy/framework/topo/new_topo_builder/common/topo_common_types.h","old_blob_id":"1f65a307d3125cba73bc8461f8eb4a8059edcce8","new_blob_id":"0af0c9524bd1a303a95b4f7d0b3a82c88a6574aa","file_path":"src/legacy/framework/topo/new_topo_builder/common/topo_common_types.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -28,7 +28,7 @@ using PlaneId = std::string;\n using FabricId = u32;\n \n MAKE_ENUM(LinkDirection, BOTH, SEND_ONLY, RECV_ONLY)\n-MAKE_ENUM(LinkProtocol, UB_CTP, UB_TP, ROCE, HCCS, TCP, UB_MEM, PCIE)\n+MAKE_ENUM(LinkProtocol, UB_CTP, UB_TP, ROCE, HCCS, TCP, UB_MEM, PCIE, UBOE)\n MAKE_ENUM(LinkPortType, PEER, BACKUP_PLANE, NET_PLANE)\n MAKE_ENUM(LinkType, PEER2PEER, PEER2NET, PEER2BACKUP)\n MAKE_ENUM(AddrPosition, HOST, DEVICE)\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/legacy/framework/topo/new_topo_builder/rank_table_info/address_info.cc","new_path":"src/legacy/framework/topo/new_topo_builder/rank_table_info/address_info.cc","old_blob_id":"f08acc29e834821bdb1cb152c42793041d524ea4","new_blob_id":"07e569d1aa8c52c3ecb0947839f93472d1ba8df3","file_path":"src/legacy/framework/topo/new_topo_builder/rank_table_info/address_info.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -50,6 +50,7 @@ void AddressInfo::Deserialize(const nlohmann::json &addressInfoJson)\n THROW(StringFormat(\"addr [%.*s] length is out of range [%u] to [%u]\", MAX_DISPLAY_LEN, address.c_str(), MIN_VALUE_ADDR_LENGRH, MAX_VALUE_ADDR_LENGRH));\n }\n \n+ HCCL_INFO(\"[AddressInfo::%s] addrTypeStr is[%s]\", __func__, addrTypeStr.c_str());\n if (addrTypeStr == \"IPV4\") {\n IPV4ToAddr(address);\n } else if (addrTypeStr == \"IPV6\") {\n@@ -101,6 +102,7 @@ void AddressInfo::IPV4ToAddr(std::string address)\n }\n IpAddress ipAddress0(address, ipFamily);\n addr=ipAddress0;\n+ HCCL_INFO(\"[AddressInfo::%s] IpAddress is[%s]\", __func__, ipAddress0.Describe().c_str());\n }\n \n void AddressInfo::IPV6ToAddr(std::string address)\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":2,"removed_lines":0,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/topo/new_topo_builder/topo_info/edge_info.cc","new_path":"src/legacy/framework/topo/new_topo_builder/topo_info/edge_info.cc","old_blob_id":"1f426e8b9b88a872149f85f09d19fd22507d97db","new_blob_id":"b4dd1cf14eef59f8ab70f7d2f4c03de4a233890e","file_path":"src/legacy/framework/topo/new_topo_builder/topo_info/edge_info.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -22,7 +22,9 @@ const unordered_map EdgeInfo::strToLinkProtocol =\n {\"HCCS\", LinkProtocol::HCCS},\n {\"PCIE\", LinkProtocol::PCIE},\n {\"TCP\", LinkProtocol::TCP},\n- {\"UB_MEM\", LinkProtocol::UB_MEM}});\n+ {\"UB_MEM\", LinkProtocol::UB_MEM},\n+ {\"UBOE\", LinkProtocol::UBOE}\n+ });\n \n const unordered_map EdgeInfo::strToTopoType =\n (unordered_map{{\"CLOS\", TopoType::CLOS},\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/legacy/framework/topo/port.h","new_path":"src/legacy/framework/topo/port.h","old_blob_id":"32802b52a6a6184f7b0325511c5ae41b5cf79369","new_blob_id":"d84e44781f0f91514f6ecae3274288e9d32b88d6","file_path":"src/legacy/framework/topo/port.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$36","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":8,"removed_lines":3,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/framework/topo/virtual_topo.cc","new_path":"src/legacy/framework/topo/virtual_topo.cc","old_blob_id":"e9f149421e2a9d014bc7ab66597d569ce70533b6","new_blob_id":"dd44706a5ab46a397d1de62a22c6afd0a1c83e69","file_path":"src/legacy/framework/topo/virtual_topo.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -87,6 +87,7 @@ std::vector LinkData::GetUniqueId() const\n \n auto loc = localAddr_.GetUniqueId();\n auto rmt = remoteAddr_.GetUniqueId();\n+ HCCL_INFO(\"[LinkData::%s] localAddr[%s], remoteAddr[%s].\", __func__, localAddr_.Describe().c_str(), remoteAddr_.Describe().c_str());\n \n u32 offset = result.size();\n u32 addrSize = loc.size();\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/legacy/service/collective/coll_operator.cc","new_path":"src/legacy/service/collective/coll_operator.cc","old_blob_id":"1db3ccfc26f421d0d83bf9d287cd03d91e835ca4","new_blob_id":"0505547888efe767f6dd254cb9db7953279b061e","file_path":"src/legacy/service/collective/coll_operator.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -225,6 +225,10 @@ std::string vectorToOpTag(const std::vector &opTagvector)\n \n std::vector CollOperator::GetUniqueId() const\n {\n+ HCCL_INFO(\"[CollOperator::%s] opMode[%s], opType[%s], reduceOp[%s], dataType[%s], dataCount[%llu], root[%u], \"\n+ \"myRank[%u], sendRecvRemoteRank[%u], opTag[%s], staticAddr[%d], staticShape[%d], outputDataType[%s], \",\n+ __func__, opMode.Describe().c_str(), opType.Describe().c_str(), reduceOp.Describe().c_str(), dataType.Describe().c_str(),\n+ dataCount, root, myRank, sendRecvRemoteRank, opTag.c_str(), staticAddr, staticShape, outputDataType.Describe().c_str());\n BinaryStream binaryStream;\n binaryStream << opMode;\n binaryStream << opType;\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":4,"removed_lines":0,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/service/collective/primitive/prim_rules.cc","new_path":"src/legacy/service/collective/primitive/prim_rules.cc","old_blob_id":"26394a74aa44fddc531a714fc043904c4428458c","new_blob_id":"35abacc72c660a7721936aae89f72622184c8689","file_path":"src/legacy/service/collective/primitive/prim_rules.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -54,8 +54,12 @@ inline void CheckLinkIsValid(const LinkData &link, const string &desc)\n return;\n } else if (link.GetType() == PortDeploymentType::DEV_NET) {\n auto linkProtocol = link.GetLinkProtocol();\n+ HCCL_INFO(\"[CheckLinkIsValid] linkProtocol is[%s]\", linkProtocol.Describe().c_str());\n if (linkProtocol == LinkProtocol::ROCE ||\n- linkProtocol == LinkProtocol::UB_CTP || linkProtocol == LinkProtocol::UB_TP) {\n+ linkProtocol == LinkProtocol::UB_CTP || \n+ linkProtocol == LinkProtocol::UB_TP ||\n+ linkProtocol == LinkProtocol::UBOE\n+ ) {\n return;\n }\n }\n","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":5,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null},{"old_path":"src/legacy/unified_platform/common/rdma_handle_manager.cc","new_path":"src/legacy/unified_platform/common/rdma_handle_manager.cc","old_blob_id":"6b8f6fce5b9b37de83a7a0a41bad390cb3fe48c2","new_blob_id":"3d8b74c75fd6309cc6d29f252a58284c112182f7","file_path":"src/legacy/unified_platform/common/rdma_handle_manager.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"$37","binary":false,"too_large":false,"collapsed":false,"line_count":[99999,99999],"added_lines":62,"removed_lines":1,"show_type":null,"audit_show_type":{"name":null,"desc":null,"title":null},"amode":null,"bmode":null}],"diff_refs":{"base_sha":"b5e216b43d9d471124f68b65d11c88adb8025671","head_sha":"99833653f6f662e60c2acb669bfa9b837af375cd","start_sha":"b5e216b43d9d471124f68b65d11c88adb8025671"},"added_lines":852,"removed_lines":123,"change_file_count":48,"change_line_count":975,"too_large":false,"total":48}

hcomm

hcomm