DAOS-16971 cart: fix style

fix style Run-GHA: true Allow-unstable-test: true Signed-off-by: Di Wang <[email protected]>
daos-stack · Feb 1, 2025 · 584f8b1 · 584f8b1
1 parent ee2ba3f
commit 584f8b1
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 12 deletions.
diff --git a/src/cart/crt_bulk.c b/src/cart/crt_bulk.c
@@ -185,7 +185,7 @@ crt_bulk_transfer(struct crt_bulk_desc *bulk_desc, crt_bulk_cb_t complete_cb,
 	rc = crt_hg_bulk_transfer(bulk_desc, complete_cb, arg, opid, false);
 	if (rc != 0)
 		DL_ERROR(rc, "%p:%s crt_hg_bulk_transfer() failed", bulk_desc->bd_rpc,
-			 crt_rpc_get_origin_addr(bulk_desc->bd_rpc));
+			 crt_req_origin_addr_get(bulk_desc->bd_rpc));
 
 out:
 	return rc;
@@ -205,8 +205,8 @@ crt_bulk_bind_transfer(struct crt_bulk_desc *bulk_desc,
 
 	rc = crt_hg_bulk_transfer(bulk_desc, complete_cb, arg, opid, true);
 	if (rc != 0)
-		DL_ERROR(rc, "%p:%s crt_hg_bulk_transfer() failed.\n", bulk_desc->bd_rpc,
-			 crt_rpc_get_origin_addr(bulk_desc->bd_rpc));
+		DL_ERROR(rc, "%p:%s crt_hg_bulk_transfer() failed.", bulk_desc->bd_rpc,
+			 crt_req_origin_addr_get(bulk_desc->bd_rpc));
 
 out:
 	return rc;

diff --git a/src/cart/crt_hg.c b/src/cart/crt_hg.c
@@ -1870,7 +1870,7 @@ crt_hg_bulk_transfer(struct crt_bulk_desc *bulk_desc, crt_bulk_cb_t complete_cb,
 }
 
 char *
-crt_rpc_get_origin_addr(crt_rpc_t *rpc_pub)
+crt_req_origin_addr_get(crt_rpc_t *rpc_pub)
 {
 	struct crt_rpc_priv *rpc_priv;
 

diff --git a/src/cart/crt_internal.h b/src/cart/crt_internal.h
@@ -40,15 +40,15 @@ crt_rpc_priv_get_origin_addr(struct crt_rpc_priv *rpc_priv)
 
 	hg_info = HG_Get_info(rpc_priv->crp_hg_hdl);
 	if (hg_info == NULL)
-		return "None";
+		return "NOINFO";
 
 	rc = HG_Addr_to_string(hg_info->hg_class, addr, (hg_size_t *)&addr_size, hg_info->addr);
 	if (rc != 0)
-		return "None";
+		return "NONE";
 
 	D_ALLOC(rpc_priv->crp_orig_uri, addr_size);
 	if (rpc_priv->crp_orig_uri == NULL)
-		return "None";
+		return "NOMEM";
 
 	memcpy(rpc_priv->crp_orig_uri, addr, addr_size);
 

diff --git a/src/cart/crt_rpc.c b/src/cart/crt_rpc.c
@@ -1601,7 +1601,7 @@ crt_reply_send(crt_rpc_t *req)
 		rc = crt_hg_reply_send(rpc_priv);
 		if (rc != 0)
 			D_ERROR("crt_hg_reply_send failed, rc: %d,opc: %#x.: %s\n", rc,
-				rpc_priv->crp_pub.cr_opc, crt_rpc_get_origin_addr(req));
+				rpc_priv->crp_pub.cr_opc, crt_req_origin_addr_get(req));
 	}
 
 	rpc_priv->crp_reply_pending = 0;

diff --git a/src/include/cart/api.h b/src/include/cart/api.h
@@ -2383,7 +2383,7 @@ crt_req_get_proto_ver(crt_rpc_t *req);
  * \return			the origin address of the RPC
  */
 char *
-crt_rpc_get_origin_addr(crt_rpc_t *rpc);
+crt_req_origin_addr_get(crt_rpc_t *rpc);
 
 /** @}
  */

diff --git a/src/object/srv_obj.c b/src/object/srv_obj.c
@@ -245,7 +245,7 @@ obj_bulk_comp_cb(const struct crt_bulk_cb_info *cb_info)
 	rpc = bulk_desc->bd_rpc;
 
 	if (cb_info->bci_rc != 0)
-		D_ERROR("rpc: %p:%s bulk transfer failed: %d\n", rpc, crt_rpc_get_origin_addr(rpc),
+		D_ERROR("rpc: %p:%s bulk transfer failed: %d\n", rpc, crt_req_origin_addr_get(rpc),
 			cb_info->bci_rc);
 
 	arg = (struct obj_bulk_args *)cb_info->bci_arg;
@@ -5785,7 +5785,7 @@ ds_obj_coll_punch_handler(crt_rpc_t *rpc)
 		  (ocpi->ocpi_flags & ORF_LEADER)
 		      ? "leader"
 		      : (ocpi->ocpi_tgts.ca_count == 1 ? "non-leader" : "relay-engine"),
-		  rpc, crt_rpc_get_origin_addr(rpc), DP_UOID(ocpi->ocpi_oid), dmi->dmi_xs_id,
+		  rpc, crt_req_origin_addr_get(rpc), DP_UOID(ocpi->ocpi_oid), dmi->dmi_xs_id,
 		  dmi->dmi_tgt_id, DP_UUID(ocpi->ocpi_po_uuid), DP_UUID(ocpi->ocpi_co_hdl),
 		  DP_UUID(ocpi->ocpi_co_uuid), ocpi->ocpi_epoch, ocpi->ocpi_map_ver, max_ver,
 		  DP_DTI(&ocpi->ocpi_xid), ocpi->ocpi_bulk_tgt_sz, ocpi->ocpi_bulk_tgt_nr,
@@ -5926,7 +5926,7 @@ ds_obj_coll_query_handler(crt_rpc_t *rpc)
 		"Handled collective query RPC %p:%s %s forwarding for obj " DF_UOID
 		" on rank %u XS %u/%u epc " DF_X64 " pmv %u, with dti " DF_DTI ", dct_nr %u, "
 		"forward width %u, forward depth %u\n: " DF_RC "\n",
-		rpc, crt_rpc_get_origin_addr(rpc),
+		rpc, crt_req_origin_addr_get(rpc),
 		ocqi->ocqi_tgts.ca_count <= 1 ? "without" : "with", DP_UOID(ocqi->ocqi_oid), myrank,
 		dmi->dmi_xs_id, tgt_id, ocqi->ocqi_epoch, ocqi->ocqi_map_ver,
 		DP_DTI(&ocqi->ocqi_xid), (unsigned int)ocqi->ocqi_tgts.ca_count,
-Original file line number
+Diff line change
@@ Expand Up @@
     }
     char *
-    crt_rpc_get_origin_addr(crt_rpc_t *rpc_pub)
+    crt_req_origin_addr_get(crt_rpc_t *rpc_pub)
     {
     	struct crt_rpc_priv *rpc_priv;
@@ Expand Down @@