1f:{"diffs":[{"old_path":"src/algorithm/base/inc/alltoallv_continuous_pipeline_pub.h","new_path":"src/algorithm/base/inc/alltoallv_continuous_pipeline_pub.h","old_blob_id":"1e3b3a1d2dcd447fe0e5fbd9c128d935b1559c99","new_blob_id":"25d57976c27ca5ef0ee75dbf0b44738d1888224d","file_path":"src/algorithm/base/inc/alltoallv_continuous_pipeline_pub.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -96,10 +96,10 @@ private:\n // 本地将info和flag写到buffer对应位置，同时做一次level1的同步\n HcclResult DoLocalWriteInfoAndFlagAndInterSync();\n \n- // 轮询等待某个rank的flag，阻塞函数!!\n+ // 轮询等待某个rank的flag，阻塞函数\n HcclResult WaitFlagOfRank(const u32 rank);\n \n- // 等待counts信息并刷新recive info，阻塞函数!!\n+ // 等待counts信息并刷新recive info，阻塞函数\n HcclResult WaitAndCalReceiveInfo();\n \n // 获取module内某个rank对应的Sdma从流idx\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/common/src/topo/topoinfo_exchange_base.cc","new_path":"src/framework/common/src/topo/topoinfo_exchange_base.cc","old_blob_id":"015b935adc8eab7484ce137af387c35f2cfde7fc","new_blob_id":"e5c33e791c039015339247d5884371cb97e2389d","file_path":"src/framework/common/src/topo/topoinfo_exchange_base.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -138,7 +138,7 @@ HcclResult TopoInfoExchangeBase::RecvClusterInfoMsg(std::shared_ptr\n \"EI0015\",\n std::vector({\"error_reason\"}),\n std::vector({RANKTABLE_DETECT_RECV_FAULT_REASON}));\n- HCCL_ERROR(\"[%s][%s] TopoDetect ERROR occur !!! fault_type[%s], fault_info[%s]\",\n+ HCCL_ERROR(\"[%s][%s] TopoDetect ERROR occur fault_type[%s], fault_info[%s]\",\n LOG_KEYWORDS_INIT_GROUP.c_str(),\n LOG_KEYWORDS_RANKTABLE_DETECT.c_str(),\n jClusterJson[\"fault_type\"].dump().c_str(),\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/ccu/ccu_ins_preprocessor.cpp","new_path":"src/legacy/framework/ccu/ccu_ins_preprocessor.cpp","old_blob_id":"c318b41704e8a39978d6a742c5aa7e5309a188dc","new_blob_id":"ac58435463cd73822b19283f2c19dc88ed60b5d0","file_path":"src/legacy/framework/ccu/ccu_ins_preprocessor.cpp","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -331,7 +331,7 @@ void CcuInsPreprocessor::Preprocess(std::shared_ptr &insQueue, bool is\n \n HCCL_INFO(\"[CcuInsPreprocessor::%s] resAllocSuccess is[%d]\", __func__, resAllocSuccess);\n if (!resAllocSuccess) {\n- HCCL_INFO(\"[CcuInsPreprocessor::%s] ResAlloc failed, accelerator fall back.\", __func__);\n+ HCCL_INFO(\"[CcuInsPreprocessor::%s] ResAlloc unsuccessful, accelerator fall back.\", __func__);\n if (isMc2) {\n // mc2场景，CCU资源不足时不支持回退\n THROW(StringFormat(\"[CcuInsPreprocessor::%s] Alloc local resource failed\", __func__));\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/ccu/ccu_mc2/mc2_compont.cpp","new_path":"src/legacy/framework/ccu/ccu_mc2/mc2_compont.cpp","old_blob_id":"33136857074c1c362bfa6d3f2162fdfba75272e9","new_blob_id":"1d105ece48618f72b355a747e91660fe358def51","file_path":"src/legacy/framework/ccu/ccu_mc2/mc2_compont.cpp","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -262,7 +262,7 @@ void Mc2Compont::MC2AllocCommRes(const CollAlgParams ¶ms, std::shared_ptrGetCcuInsPreprocessor()->Preprocess(insQueue, true);\n if (collService->GetCcuInsPreprocessor()->IsRollback()) { // mc2暂不能回退到aicpu\n- THROW(\"[Mc2Compont][%s]ResAlloc failed.\", __func__);\n+ THROW(\"[Mc2Compont][%s]ResAlloc unsuccessful.\", __func__);\n }\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/legacy/framework/entrance/hcom_comm/comm_manager.cc","new_path":"src/legacy/framework/entrance/hcom_comm/comm_manager.cc","old_blob_id":"ba3f9c05e6c2728d9c26029d71be90384c44f526","new_blob_id":"442b2b5627001cc759d54cddbca20584ab398865","file_path":"src/legacy/framework/entrance/hcom_comm/comm_manager.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -698,7 +698,7 @@ HcclResult CommManager::SetCommAcceleratorV2(Hccl::HcclCommunicator *communicato\n {\n CHK_PTR_NULL(communicator);\n if (accelerator < static_cast(HcclAccelerator::DEFAULT) || accelerator > static_cast(HcclAccelerator::AICPU)) {\n- HCCL_ERROR(\"[SetCommAcceleratorV2] Invalid accelerator value [%d]\", accelerator);\n+ HCCL_ERROR(\"[SetCommAcceleratorV2] Invalid accelerator value [%d], valid range is [0,7]\", accelerator);\n return HCCL_E_NOT_SUPPORT;\n }\n HcclAccelerator hcclAccelerator = static_cast(accelerator);\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/entrance/op_base/op_base_v2.cc","new_path":"src/legacy/framework/entrance/op_base/op_base_v2.cc","old_blob_id":"856e0997054da742d82cab8d3f0cd129678f72a6","new_blob_id":"6b9c60240e42d9396e5fa19e1444d77d60a260f5","file_path":"src/legacy/framework/entrance/op_base/op_base_v2.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/connection/rma_conn_manager.cc","new_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.cc","old_blob_id":"f9ac0afa75763b981bdc025094c90087a66f0f1e","new_blob_id":"50765df563cf9cb0bee9a1ebce790ab181b4a6d7","file_path":"src/legacy/framework/resource_manager/connection/rma_conn_manager.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -92,7 +92,7 @@ RmaConnection *RmaConnManager::Create(const std::string &tag, const LinkData &li\n linkData.Describe().c_str());\n RmaConnection *rmaConnPtr = Get(tag, linkData);\n if (rmaConnPtr != nullptr) {\n- HCCL_INFO(\"has inited!!\");\n+ HCCL_INFO(\"has inited\");\n return rmaConnPtr;\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/legacy/service/collective/alg/coll_alg_factory/alg_template/prim_alg_template/temp_all_gather_mesh.cc","new_path":"src/legacy/service/collective/alg/coll_alg_factory/alg_template/prim_alg_template/temp_all_gather_mesh.cc","old_blob_id":"fa1245a2b98372b4e8f13f44d8d172cecd1b2cad","new_blob_id":"48e62cf43adeedc5b0fc5add783e63b4699c2423","file_path":"src/legacy/service/collective/alg/coll_alg_factory/alg_template/prim_alg_template/temp_all_gather_mesh.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -40,7 +40,7 @@ HcclResult TempAllGatherMesh::CalcResDetour(const RankGraph *rankGraph, AlgTempR\n linkNumBtwPeers_ = GetLinkNum(rankGraph, myRank_, tempVTopo_[0][(myAlgRank + 1) % tempRankSize_]);\n if (linkNumBtwPeers_ == 1) {\n HCCL_INFO(\"[CollAlgFactory] [TempAllGatherMesh] [WARNING] Rank [%d], linkNum between rank [%d] and rank [%d] \"\n- \"equals 1, not able to detour!!!\",\n+ \"equals 1, not able to detour\",\n myRank_, myRank_, tempVTopo_[0][(myAlgRank + 1) % tempRankSize_]);\n enableDetour_ = false;\n } else {\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/service/collective/alg/coll_alg_factory/alg_template/prim_alg_template/temp_reduce_scatter_mesh.cc","new_path":"src/legacy/service/collective/alg/coll_alg_factory/alg_template/prim_alg_template/temp_reduce_scatter_mesh.cc","old_blob_id":"1013933a6a0c570444d6869f0c83cde09544198f","new_blob_id":"a4c0d81a696109d5a0f312d91e5122a6e030407b","file_path":"src/legacy/service/collective/alg/coll_alg_factory/alg_template/prim_alg_template/temp_reduce_scatter_mesh.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -49,7 +49,7 @@ HcclResult TempReduceScatterMesh::CalcResDetour(const bool forAllReduce, const R\n if (linkNumBtwPeers_ == 1) {\n HCCL_INFO(\n \"[CollAlgFactory] [TempReduceScatterMesh] [WARNING] Rank [%d], linkNum between rank [%d] and rank [%d] \"\n- \"equals 1, not able to detour!!!\",\n+ \"equals 1, not able to detour\",\n myRank_, myRank_, tempVTopo_[0][(myAlgRank + 1) % tempRankSize_]);\n enableDetour_ = false;\n } else {\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/platform/common/mr_manager.cc","new_path":"src/platform/common/mr_manager.cc","old_blob_id":"9d5441ac51a2a8641823abe887c67da4e89236a2","new_blob_id":"51300a285cf4654016aab06d4faa0ade75dde194","file_path":"src/platform/common/mr_manager.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -564,7 +564,7 @@ HcclResult MrManager::ReleaseKey(void *addr, u64 size) // 释放临时MR\n \n HcclResult MrManager::GetMrInfo(MrInfo &mrInfo, bool &isInfoNotFound)\n {\n- CHK_PRT_RET(regedMrMap_.empty(), HCCL_ERROR(\"[MrManager][GetMrInfo]get mr info failed, mr map is empty!!!\"),\n+ CHK_PRT_RET(regedMrMap_.empty(), HCCL_ERROR(\"[MrManager][GetMrInfo]get mr info failed, mr map is empty\"),\n HCCL_E_PARA);\n \n isInfoNotFound = false;\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/platform/hccp/rdma_service/rs_epoll.c","new_path":"src/platform/hccp/rdma_service/rs_epoll.c","old_blob_id":"a99f0dec22d9a390bd72648569aba639566b247a","new_blob_id":"9018dd9780498e0122047ac962a953999ee2f04f","file_path":"src/platform/hccp/rdma_service/rs_epoll.c","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -551,7 +551,7 @@ STATIC void *RsEpollHandle(void *arg)\n \n /* eventfd is for wake up epoll wait, value is ignored */\n if (events[0].data.fd == connCb->eventfd) {\n- hccp_warn(\" SHUT DOWN event!!! eventfd:%d\", connCb->eventfd);\n+ hccp_warn(\" SHUT DOWN event eventfd:%d\", connCb->eventfd);\n do {\n num = read(connCb->eventfd, &val, sizeof(eventfd_t));\n } while ((num < 0) && (errno == EINTR));\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/platform/hccp/rdma_service/rs_rdma.c","new_path":"src/platform/hccp/rdma_service/rs_rdma.c","old_blob_id":"8e4c3d6ec4e3e707474aacedb94f5c1f12cca2d2","new_blob_id":"e6d48db8ca70b3da06ea14282114c7298a2e599c","file_path":"src/platform/hccp/rdma_service/rs_rdma.c","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -457,7 +457,7 @@ STATIC int RsMrInfoSync(struct RsMrCb *mrCb)\n \n /*\n * no socket available for MR_INFO exchange if allowed\n- * need exchange when socket available!!!\n+ * need exchange when socket available\n */\n CHK_PRT_RETURN(mrCb->qpCb->connInfo == NULL, hccp_warn(\"no conn available !\"), 0);\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/platform/resource/transport/heterog/transport_heterog_event_tcp.cc","new_path":"src/platform/resource/transport/heterog/transport_heterog_event_tcp.cc","old_blob_id":"ef4edd0209bed08f527107a8364978718ec03785","new_blob_id":"38cfefd3db48327fdcf98fb78d0292c68f254ab5","file_path":"src/platform/resource/transport/heterog/transport_heterog_event_tcp.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/platform/resource/transport/heterog/transport_heterog_roce.cc","new_path":"src/platform/resource/transport/heterog/transport_heterog_roce.cc","old_blob_id":"98175dcc3f8fd131505465c9d5ca41bc5f944c4a","new_blob_id":"1202a7da64a373c8d1d0d4db766eaf1afa412b4f","file_path":"src/platform/resource/transport/heterog/transport_heterog_roce.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -317,7 +317,7 @@ HcclResult TransportHeterogRoce::Imrecv(const TransData &recvData, HcclMessageIn\n dataReadWr_.next = nullptr;\n \n if (!(remoteIsHdc_ && (deviceLogicId_ == HOST_DEVICE_ID))) {\n- HCCL_INFO(\"general server not load ack !!!\");\n+ HCCL_INFO(\"general server not load ack \");\n dataReadWr_.next = &dataAckWr_;\n dataAckSge_.addr = reinterpret_cast(&envelope.msn);\n dataAckSge_.length = sizeof(uint64_t);\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/platform/resource/transport/tcp_recv_task.cc","new_path":"src/platform/resource/transport/tcp_recv_task.cc","old_blob_id":"522eb6b69c70374ed5cb2a72e2bfa7bd1dda539f","new_blob_id":"00b192489a879ab565769b38ac8c31c860962b24","file_path":"src/platform/resource/transport/tcp_recv_task.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -31,7 +31,7 @@ void TcpRecvTask::RecvDataCb(const FdHandle fdHandle)\n return;\n }\n if (fdHandle == nullptr) {\n- HCCL_ERROR(\"[RecvTask][RecvDataCb]fdHandle is nullptr!!!!\");\n+ HCCL_ERROR(\"[RecvTask][RecvDataCb]fdHandle is nullptr\");\n } else {\n GetRecvTaskInstance()->RecvData(fdHandle);\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/platform/resource/transport/tcp_send_thread_pool.cc","new_path":"src/platform/resource/transport/tcp_send_thread_pool.cc","old_blob_id":"5f5a8ea96a0cc3a7a60591460e25a351f8604b8b","new_blob_id":"aeef8f24be18cbf8a01f4bf777ab1ac1f75867e3","file_path":"src/platform/resource/transport/tcp_send_thread_pool.cc","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -210,7 +210,7 @@ HcclResult TcpSendThreadPool::AddSendTask(HcclRequestInfo *request)\n HcclResult TcpSendThreadPool::RunTask(u32 serialNum)\n {\n if (BindDataCpu(devId_) != HCCL_SUCCESS) {\n- HCCL_WARNING(\"send thread bind cpu failed!!!\");\n+ HCCL_WARNING(\"send thread bind cpu failed\");\n }\n \n HCCL_DEBUG(\"threadSerial[%u]\", serialNum);\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/pub_inc/memory_alloc_ring.h","new_path":"src/pub_inc/memory_alloc_ring.h","old_blob_id":"4d1b974cf3faf25b8dc0e3176d91b4fcdca83eb4","new_blob_id":"9cd17c8d90caf940b55097a1feccb1518d8ef3a3","file_path":"src/pub_inc/memory_alloc_ring.h","new_file":false,"renamed_file":false,"deleted_file":false,"diff":"@@ -105,7 +105,7 @@ public:\n HCCL_ERROR(\"Init fail.\");\n return nullptr;\n }\n- HCCL_DEBUG(\"LocklessRingMemoryAllocate::Alloc Start!!!\");\n+ HCCL_DEBUG(\"LocklessRingMemoryAllocate::Alloc Start\");\n while (sem_trywait(&allocAvailable_) != 0) {\n HCCL_INFO(\"Alloc limited! head_[%u] tail_[%u]\", head_ - 0, tail_ - 0);\n std::unique_lock lock(expansionMutex_);\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}],"diff_refs":{"base_sha":"a6700dde374d7bbc9d970f72615ff7c56d6a6c64","head_sha":"3606dfc318f7f754275a525307467734b2ba80f5","start_sha":"a6700dde374d7bbc9d970f72615ff7c56d6a6c64"},"added_lines":23,"removed_lines":23,"change_file_count":17,"change_line_count":46,"too_large":false,"total":17}

hcomm

hcomm