PaddlePaddle
diff --git a/‎paddle/fluid/distributed/collective/CMakeLists.txt
Copy file name to clipboard
+60-1Lines changed: 60 additions & 1 deletion b/‎paddle/fluid/distributed/collective/CMakeLists.txt
Copy file name to clipboard
+60-1Lines changed: 60 additions & 1 deletion
diff --git a/‎paddle/phi/core/distributed/collective/async_load.cc renamed to ‎paddle/fluid/distributed/collective/async_load.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎paddle/phi/core/distributed/collective/async_load.cc renamed to ‎paddle/fluid/distributed/collective/async_load.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎paddle/phi/core/distributed/collective/async_load.h renamed to ‎paddle/fluid/distributed/collective/async_load.h
Copy file name to clipboard b/‎paddle/phi/core/distributed/collective/async_load.h renamed to ‎paddle/fluid/distributed/collective/async_load.h
Copy file name to clipboard
diff --git a/‎paddle/phi/core/distributed/collective/bkcl_tools.cc renamed to ‎paddle/fluid/distributed/collective/bkcl_tools.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎paddle/phi/core/distributed/collective/bkcl_tools.cc renamed to ‎paddle/fluid/distributed/collective/bkcl_tools.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎paddle/phi/core/distributed/collective/bkcl_tools.h renamed to ‎paddle/fluid/distributed/collective/bkcl_tools.h
Copy file name to clipboard b/‎paddle/phi/core/distributed/collective/bkcl_tools.h renamed to ‎paddle/fluid/distributed/collective/bkcl_tools.h
Copy file name to clipboard
diff --git a/‎paddle/phi/core/distributed/collective/common.cc renamed to ‎paddle/fluid/distributed/collective/common.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎paddle/phi/core/distributed/collective/common.cc renamed to ‎paddle/fluid/distributed/collective/common.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎paddle/phi/core/distributed/collective/common.h renamed to ‎paddle/fluid/distributed/collective/common.h
Copy file name to clipboard b/‎paddle/phi/core/distributed/collective/common.h renamed to ‎paddle/fluid/distributed/collective/common.h
Copy file name to clipboard
diff --git a/‎paddle/phi/core/distributed/collective/custom_ccl_tools.cc renamed to ‎paddle/fluid/distributed/collective/custom_ccl_tools.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎paddle/phi/core/distributed/collective/custom_ccl_tools.cc renamed to ‎paddle/fluid/distributed/collective/custom_ccl_tools.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
diff --git a/‎paddle/phi/core/distributed/collective/custom_ccl_tools.h renamed to ‎paddle/fluid/distributed/collective/custom_ccl_tools.h
Copy file name to clipboard b/‎paddle/phi/core/distributed/collective/custom_ccl_tools.h renamed to ‎paddle/fluid/distributed/collective/custom_ccl_tools.h
Copy file name to clipboard
diff --git a/‎paddle/phi/core/distributed/collective/gloo_send_recv.cc renamed to ‎paddle/fluid/distributed/collective/gloo_send_recv.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion b/‎paddle/phi/core/distributed/collective/gloo_send_recv.cc renamed to ‎paddle/fluid/distributed/collective/gloo_send_recv.cc
Copy file name to clipboard
+1-1Lines changed: 1 addition & 1 deletion
@@ -1,4 +1,63 @@
+cc_library(
+  process_group
+  SRCS process_group.cc
+  DEPS phi common xxhash)
+
 cc_library(
   eager_reducer
   SRCS reducer.cc
-  DEPS eager_api phi common string_helper)
+  DEPS eager_api process_group phi common string_helper)
+
+if(WITH_DISTRIBUTE)
+  cc_library(
+    process_group_gloo
+    SRCS process_group_gloo.cc gloo_send_recv.cc
+    DEPS phi common eager_api gloo_wrapper)
+endif()
+
+if(WITH_NCCL OR WITH_RCCL)
+  cc_library(
+    process_group_nccl
+    SRCS process_group_nccl.cc common.cc
+    DEPS process_group phi common collective_helper device_context
+         ${DEVICE_EVENT_LIBS})
+
+  cc_library(
+    async_load
+    SRCS async_load.cc
+    DEPS device_context phi common ${DEVICE_EVENT_LIBS})
+
+endif()
+
+if(WITH_XPU_BKCL)
+  cc_library(
+    process_group_bkcl
+    SRCS process_group_bkcl.cc bkcl_tools.cc common.cc
+    DEPS process_group phi common collective_helper device_context)
+endif()
+
+if(WITH_MPI)
+  cc_library(
+    process_group_mpi
+    SRCS process_group_mpi.cc mpi_tools.cc common.cc
+    DEPS collective_helper device_context)
+endif()
+
+if(WITH_CUSTOM_DEVICE)
+  cc_library(
+    process_group_custom
+    SRCS process_group_custom.cc custom_ccl_tools.cc common.cc
+    DEPS process_group phi common collective_helper device_context)
+endif()
+
+set(COMM_UTILS_DEPS process_group)
+if(WITH_NCCL OR WITH_RCCL)
+  set(COMM_UTILS_DEPS ${PROCESS_GROUP_UTILS_DEPS} process_group_nccl)
+endif()
+if(WITH_CUSTOM_DEVICE)
+  set(COMM_UTILS_DEPS ${PROCESS_GROUP_UTILS_DEPS} process_group_custom)
+endif()
+cc_library(
+  processgroup_comm_utils
+  SRCS processgroup_comm_utils.cc
+  DEPS ${COMM_UTILS_DEPS})
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#include "paddle/phi/core/distributed/collective/async_load.h"
+#include "paddle/fluid/distributed/collective/async_load.h"
 #include "paddle/phi/common/memory_utils.h"
 
 namespace paddle {
 
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#include "paddle/phi/core/distributed/collective/bkcl_tools.h"
+#include "paddle/fluid/distributed/collective/bkcl_tools.h"
 
 namespace paddle {
 namespace distributed {
 
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#include "paddle/phi/core/distributed/collective/common.h"
+#include "paddle/fluid/distributed/collective/common.h"
 
 namespace paddle::distributed {
 
 
@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#include "paddle/phi/core/distributed/collective/custom_ccl_tools.h"
+#include "paddle/fluid/distributed/collective/custom_ccl_tools.h"
 
 namespace paddle {
 namespace distributed {
 
@@ -18,7 +18,7 @@
 #include "gloo/common/logging.h"
 #include "gloo/math.h"
 #include "gloo/types.h"
-#include "paddle/phi/core/distributed/collective/gloo_send_recv.h"
+#include "paddle/fluid/distributed/collective/gloo_send_recv.h"
 
 namespace paddle::distributed {