Fix several bugs and update v0.5 release notes (flagos-ai#264)

Author: MC952-arch

README.md

@@ -1,6 +1,12 @@
 [<img src="docs/images/flagopen.png">](https://flagopen.baai.ac.cn/)
 
 ## Latest News
+- **[2025/09]** Released [v0.5](https://github.com/FlagOpen/FlagCX/tree/release/v0.5):
+  - Adds AMD support (hipAdaptor and rcclAdaptor).
+  - Introduces flagcxNetAdaptor to unify network backends, currently supporting SOCKET, IBRC, UCX and IBUC (experimently).
+  - Enables zero-copy device-buffer RDMA (user-buffer RDMA) to boost small-message performance.
+  - Supports automatic tuning in homogeneous scenarios via flagcxTuner.
+  - Integrates automated PyTorch API tests into CI/CD.
 - **[2025/08]** Released [v0.4](https://github.com/FlagOpen/FlagCX/tree/release/v0.4):
   - Supports heterogeneous training of ERNIE4.5 on Nvidia and Iluvatar GPUs with Paddle + FlagCX.
   - Enables more robust and flexible deployments with full support of heterogeneous communication across arbitrary NIC configurations (bug fixes). 
@@ -92,7 +98,7 @@ FlagCX also integrates with upper-layer applications such as PyTorch and PaddleP
 2. Build the library with different flags targeting to different platforms:
     ```sh
     cd FlagCX
-    make [USE_NVIDIA/USE_ILUVATAR_COREX/USE_CAMBRICON/USE_GLOO/USE_MPI/USE_METAX/USE_MUSA/USE_KUNLUNXIN/USE_DU/USE_ASCEND]=1
+    make [USE_NVIDIA/USE_ILUVATAR_COREX/USE_CAMBRICON/USE_GLOO/USE_MPI/USE_METAX/USE_MUSA/USE_KUNLUNXIN/USE_DU/USE_ASCEND/USE_AMD]=1
     ```
     The default install path is set to `build/`, you can manually set `BUILDDIR` to specify the build path. You may also define `DEVICE_HOME` and `CCL_HOME` to indicate the install paths of device runtime and communication libraries.
 
@@ -117,6 +123,9 @@ All tests support the same set of arguments:
 * Performance
   * `-w, <warmup iteration count>` number of warmup iterations (not timed). Default: 5.
   * `-n, <iteration count>` number of iterations. Default: 20.
+* Test Operation
+  * `-R, <0/1>` enable local buffer registration on send/recv buffers. Default: 0.
+  * `-s, <OCT/DEC/HEX>` specify MPI communication split mode. Default: 0
 * Utils
   * `-p, <0/1>` print buffer info. Default: 0.
   * `-h` print help message. Default: disabled.

flagcx/core/flagcx_tuner.cc

@@ -114,20 +114,13 @@ struct flagcxTunerContext {
 };
 
 static struct flagcxEnvConfig config1 = {
-    .commTag = "defaultConfig1",
-    .envCount = 1,
-    .envs = {{.type = FLAGCX_ENV_TYPE_CREATION,
-              .name = "NCCL_P2P_NVL_CHUNKSIZE",
-              .value = "1024",
-              .defaultValue = "524288"}}};
-
+    "defaultConfig1",
+    1,
+    {FLAGCX_ENV_TYPE_COLL, "NCCL_P2P_NVL_CHUNKSIZE", "1024", "524288"}};
 static struct flagcxEnvConfig config2 = {
-    .commTag = "defaultConfig2",
-    .envCount = 1,
-    .envs = {{.type = FLAGCX_ENV_TYPE_CREATION,
-              .name = "NCCL_P2P_NVL_CHUNKSIZE",
-              .value = "524288",
-              .defaultValue = "524288"}}};
+    "defaultConfig2",
+    1,
+    {FLAGCX_ENV_TYPE_COLL, "NCCL_P2P_NVL_CHUNKSIZE", "524288", "524288"}};
 
 bool operator<(const struct flagcxCommTag &lhs,
                const struct flagcxCommTag &rhs) {

flagcx/core/flagcx_tuner.h

@@ -100,7 +100,7 @@ extern flagcxTuner_t internalTuner;
   do {                                                                         \
     comm->tunerInnerComm = nullptr;                                            \
     size_t nBytes = count * getFlagcxDataTypeSize(datatype);                   \
-    struct flagcxCommTag tag = {.tag = ""};                                    \
+    struct flagcxCommTag tag = {""};                                           \
     FLAGCXCHECK(comm->tuner->getCollInfo(comm->tunerContext, commOp, nBytes,   \
                                          0, NULL, 0, &tag));                   \
     const auto it = comm->homoCommMap.find(tag);                               \

flagcx/core/net.cc

@@ -344,10 +344,14 @@ flagcxResult_t flagcxSendProxyFree(sendNetResources *resources) {
     FLAGCXCHECK(deviceAdaptor->eventDestroy(resources->cpEvents[s]));
   }
   FLAGCXCHECK(deviceAdaptor->streamDestroy(resources->cpStream));
-  FLAGCXCHECK(resources->netAdaptor->deregMr(resources->netSendComm,
-                                             resources->mhandles[0]));
-  FLAGCXCHECK(resources->netAdaptor->closeSend(resources->netSendComm));
-  FLAGCXCHECK(deviceAdaptor->gdrMemFree(resources->buffers[0], NULL));
+  resources->netAdaptor->deregMr(resources->netSendComm,
+                                 resources->mhandles[0]);
+  resources->netAdaptor->closeSend(resources->netSendComm);
+  if (resources->netAdaptor == getUnifiedNetAdaptor(SOCKET)) {
+    free(resources->buffers[0]);
+  } else if (resources->netAdaptor == getUnifiedNetAdaptor(IBRC)) {
+    FLAGCXCHECK(deviceAdaptor->gdrMemFree(resources->buffers[0], NULL));
+  }
   return flagcxSuccess;
 }
 
@@ -356,11 +360,15 @@ flagcxResult_t flagcxRecvProxyFree(recvNetResources *resources) {
     FLAGCXCHECK(deviceAdaptor->eventDestroy(resources->cpEvents[s]));
   }
   FLAGCXCHECK(deviceAdaptor->streamDestroy(resources->cpStream));
-  FLAGCXCHECK(resources->netAdaptor->deregMr(resources->netRecvComm,
-                                             resources->mhandles[0]));
-  FLAGCXCHECK(resources->netAdaptor->closeRecv(resources->netRecvComm));
-  FLAGCXCHECK(resources->netAdaptor->closeListen(resources->netListenComm));
-  FLAGCXCHECK(deviceAdaptor->gdrMemFree(resources->buffers[0], NULL));
+  resources->netAdaptor->deregMr(resources->netRecvComm,
+                                 resources->mhandles[0]);
+  resources->netAdaptor->closeRecv(resources->netRecvComm);
+  resources->netAdaptor->closeListen(resources->netListenComm);
+  if (resources->netAdaptor == getUnifiedNetAdaptor(SOCKET)) {
+    free(resources->buffers[0]);
+  } else if (resources->netAdaptor == getUnifiedNetAdaptor(IBRC)) {
+    FLAGCXCHECK(deviceAdaptor->gdrMemFree(resources->buffers[0], NULL));
+  }
   return flagcxSuccess;
 }
 

flagcx/flagcx.cc

@@ -434,7 +434,7 @@ flagcxResult_t flagcxCommInitRank(flagcxComm_t *comm, int nranks,
     (*comm)->homoCommMap.clear();
     // Note: The tuner only support homo comm optimization for now
     for (uint32_t i = 0; i < nConfigs; ++i) {
-      struct flagcxCommTag tag = {.tag = ""};
+      struct flagcxCommTag tag = {""};
       FLAGCXCHECK((*comm)->tuner->setCandidate((*comm)->tunerContext, i, &tag));
       INFO(FLAGCX_INIT, "start to prepare communicator tag=%s(%u/%u)", tag.tag,
            i, nConfigs);

test/perf/tools.cc

@@ -98,7 +98,7 @@ parser::parser(int argc, char **argv) {
       {"iters", required_argument, 0, 'n'},
       {"print_buffer", required_argument, 0, 'p'},
       {"root", required_argument, 0, 'r'},
-      {"split_mask", required_argument, 0, 'm'},
+      {"split_mask", required_argument, 0, 's'},
       {"local_register", required_argument, 0, 'R'},
       // {"op", required_argument, 0, 'o'},
       // {"datatype", required_argument, 0, 'd'},
@@ -107,7 +107,7 @@ parser::parser(int argc, char **argv) {
 
   while (1) {
     int c;
-    c = getopt_long(argc, argv, "b:e:f:w:n:p:r:m:R:h", longOpts, &longIndex);
+    c = getopt_long(argc, argv, "b:e:f:w:n:p:r:s:R:h", longOpts, &longIndex);
 
     if (c == -1)
       break;
@@ -164,7 +164,7 @@ parser::parser(int argc, char **argv) {
           exit(1);
         }
         break;
-      case 'm':
+      case 's':
         splitMask = strtoul(optarg, NULL, 0);
         break;
       case 'R':
@@ -187,12 +187,12 @@ parser::parser(int argc, char **argv) {
                "[-n <iters>] \n\t"
                "[-p <printbuffer 0/1>] \n\t"
                "[-r <root>] \n\t"
-               "[-m <splitmask OCT/DEC/HEX>] \n\t"
+               "[-s <splitmask OCT/DEC/HEX>] \n\t"
                "[-R <localregister 0/1>] \n\t"
                "[-h\n",
                basename(argv[0]));
         printf("Use default values with -b 1M -e 1G -f 2 -w 5 -n 20 -p 0 -r 0 "
-               "-m 0 -R 0\n");
+               "-s 0 -R 0\n");
         break;
     }
   }