net: openthread: rpc: add otLinkRawGetRadioTime()

Add serialization of otLinkRawGetRadioTime() API.

Signed-off-by: Damian Krolik <[email protected]>

Author: Damian-Nordic

doc/nrf/libraries/networking/ot_rpc.rst

@@ -123,6 +123,7 @@ OpenThread RPC currently supports the serialization of the following OpenThread
 * :c:func:`otLinkGetFactoryAssignedIeeeEui64`
 * :c:func:`otLinkGetPanId`
 * :c:func:`otLinkGetPollPeriod`
+* :c:func:`otLinkRawGetRadioTime`
 * :c:func:`otLinkSetEnabled`
 * :c:func:`otLinkSetMaxFrameRetriesDirect`
 * :c:func:`otLinkSetMaxFrameRetriesIndirect`

samples/nrf_rpc/protocols_serialization/client/src/ot_shell.c

@@ -13,6 +13,7 @@
 #include <openthread/coap.h>
 #include <openthread/ip6.h>
 #include <openthread/link.h>
+#include <openthread/link_raw.h>
 #include <openthread/thread.h>
 #include <openthread/udp.h>
 #include <openthread/netdata.h>
@@ -235,6 +236,26 @@ static int cmd_discover(const struct shell *sh, size_t argc, char *argv[])
 	return ot_cli_command_invoke(ot_cli_command_discover, sh, argc, argv);
 }
 
+static otError ot_cli_command_radio(const struct shell *sh, size_t argc, char *argv[])
+{
+	if (argc != 2 || strcmp(argv[1], "time") != 0) {
+		return OT_ERROR_INVALID_COMMAND;
+	}
+
+	shell_print(sh, "%" PRIu64, otLinkRawGetRadioTime(NULL));
+
+	return OT_ERROR_NONE;
+}
+
+static int cmd_radio(const struct shell *sh, size_t argc, char *argv[])
+{
+	if (argc == 2 && strcmp(argv[1], "time") == 0) {
+		return ot_cli_command_invoke(ot_cli_command_radio, sh, argc, argv);
+	}
+
+	return ot_cli_command_send(sh, argc + 1, argv - 1);
+}
+
 static otError ot_cli_command_ifconfig(const struct shell *sh, size_t argc, char *argv[])
 {
 	if (argc <= 1) {
@@ -1783,6 +1804,7 @@ SHELL_STATIC_SUBCMD_SET_CREATE(
 	SHELL_CMD_ARG(state, NULL, "Current role", cmd_state, 1, 1),
 	SHELL_CMD_ARG(thread, NULL, "Role management", cmd_thread, 2, 0),
 	SHELL_CMD_ARG(discover, NULL, "Thread discovery scan", cmd_discover, 1, 4),
+	SHELL_CMD_ARG(radio, NULL, "Radio configuration", cmd_radio, 1, 1),
 	SHELL_CMD_ARG(test_message, NULL, "Test message API", cmd_test_message, 1, 0),
 	SHELL_CMD_ARG(test_udp_init, NULL, "Test udp init API", cmd_test_udp_init, 1, 0),
 	SHELL_CMD_ARG(test_udp_send, NULL, "Test udp send API", cmd_test_udp_send, 1, 0),
@@ -1827,8 +1849,8 @@ SHELL_STATIC_SUBCMD_SET_CREATE(
 	SHELL_CMD_ARG(cmd_test_srp_client_service_clear, NULL, "Test SRP client service clear API",
 		      cmd_test_srp_client_service_clear, 2, 0),
 	SHELL_CMD_ARG(test_srp_client_add_service_remove, NULL,
-		      "Test SRP client service remove API",
-		      cmd_test_srp_client_service_remove, 2, 0),
+		      "Test SRP client service remove API", cmd_test_srp_client_service_remove, 2,
+		      0),
 	SHELL_CMD_ARG(test_srp_client_host_address_auto, NULL,
 		      "Test SRP client host address auto API",
 		      cmd_test_srp_client_host_address_auto, 1, 0),
@@ -1845,19 +1867,23 @@ SHELL_STATIC_SUBCMD_SET_CREATE(
 		      cmd_dns_client_resolve, 3, 0),
 	SHELL_CMD_ARG(test_dns_client_resolve4, NULL, "Resolve IPv4 address, args: <name> <server>",
 		      cmd_dns_client_resolve, 3, 0),
-	SHELL_CMD_ARG(test_dns_client_service, NULL, "Service instance resolution, args: <instance>"
-						     "<service> <server>",
+	SHELL_CMD_ARG(test_dns_client_service, NULL,
+		      "Service instance resolution, args: <instance>"
+		      "<service> <server>",
 		      cmd_dns_client_service, 4, 0),
-	SHELL_CMD_ARG(test_dns_client_servicehost, NULL, "Service instance resolution, args:"
-							 " <instance> <service> <server>",
+	SHELL_CMD_ARG(test_dns_client_servicehost, NULL,
+		      "Service instance resolution, args:"
+		      " <instance> <service> <server>",
 		      cmd_dns_client_service, 4, 0),
 	SHELL_CMD_ARG(test_dns_client_browse, NULL, "Service browsing, args <service> <server>",
 		      cmd_dns_client_browse, 3, 0),
-	SHELL_CMD_ARG(test_vendor_data, NULL, "Vendor data, args: <vendor-name> <vendor-model>"
-					      " <vendor-sw-version>",
+	SHELL_CMD_ARG(test_vendor_data, NULL,
+		      "Vendor data, args: <vendor-name> <vendor-model>"
+		      " <vendor-sw-version>",
 		      cmd_test_vendor_data, 4, 0),
-	SHELL_CMD_ARG(test_net_diag, NULL, "Network diag, args: <get|reset> <IPv6-address>"
-					   " <tlv-type ...>",
+	SHELL_CMD_ARG(test_net_diag, NULL,
+		      "Network diag, args: <get|reset> <IPv6-address>"
+		      " <tlv-type ...>",
 		      cmd_test_net_diag, 4, 255),
 	SHELL_SUBCMD_SET_END);
 

subsys/net/openthread/rpc/client/CMakeLists.txt

@@ -15,6 +15,7 @@ zephyr_library_sources(
   ot_rpc_instance.c
   ot_rpc_ip6.c
   ot_rpc_link.c
+  ot_rpc_link_raw.c
   ot_rpc_message.c
   ot_rpc_netdata.c
   ot_rpc_netdiag.c

subsys/net/openthread/rpc/client/ot_rpc_link_raw.c

@@ -0,0 +1,32 @@
+/*
+ * Copyright (c) 2025 Nordic Semiconductor ASA
+ *
+ * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
+ */
+
+#include <ot_rpc_ids.h>
+#include <ot_rpc_common.h>
+#include <nrf_rpc/nrf_rpc_serialize.h>
+
+#include <nrf_rpc_cbor.h>
+
+#include <openthread/link_raw.h>
+
+uint64_t otLinkRawGetRadioTime(otInstance *aInstance)
+{
+	struct nrf_rpc_cbor_ctx ctx;
+	uint64_t time;
+
+	ARG_UNUSED(aInstance);
+
+	NRF_RPC_CBOR_ALLOC(&ot_group, ctx, 0);
+	nrf_rpc_cbor_cmd_rsp_no_err(&ot_group, OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME, &ctx);
+
+	time = nrf_rpc_decode_uint64(&ctx);
+
+	if (!nrf_rpc_decoding_done_and_check(&ot_group, &ctx)) {
+		ot_rpc_report_rsp_decoding_error(OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME);
+	}
+
+	return time;
+}

subsys/net/openthread/rpc/common/ot_rpc_ids.h

@@ -163,6 +163,7 @@ enum ot_rpc_cmd_server {
 	OT_RPC_CMD_DNS_SERVICE_RESP_GET_SERVICE_NAME,
 	OT_RPC_CMD_DNS_SERVICE_RESP_GET_SERVICE_INFO,
 	OT_RPC_CMD_DNS_SERVICE_RESP_GET_HOST_ADDRESS,
+	OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME,
 };
 
 #endif /* OT_RPC_IDS_H_ */

subsys/net/openthread/rpc/server/CMakeLists.txt

@@ -15,6 +15,7 @@ zephyr_library_sources(
   ot_rpc_instance.c
   ot_rpc_ip6.c
   ot_rpc_link.c
+  ot_rpc_link_raw.c
   ot_rpc_message.c
   ot_rpc_netdata.c
   ot_rpc_netdiag.c

subsys/net/openthread/rpc/server/ot_rpc_link_raw.c

@@ -0,0 +1,39 @@
+/*
+ * Copyright (c) 2025 Nordic Semiconductor ASA
+ *
+ * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
+ */
+
+#include <nrf_rpc/nrf_rpc_serialize.h>
+#include <ot_rpc_ids.h>
+#include <ot_rpc_types.h>
+#include <ot_rpc_common.h>
+
+#include <nrf_rpc_cbor.h>
+
+#include <zephyr/net/openthread.h>
+
+#include <openthread/link_raw.h>
+
+static void ot_rpc_cmd_get_radio_time(const struct nrf_rpc_group *group,
+				      struct nrf_rpc_cbor_ctx *ctx, void *handler_data)
+{
+	uint64_t time;
+	struct nrf_rpc_cbor_ctx rsp_ctx;
+
+	if (!nrf_rpc_decoding_done_and_check(group, ctx)) {
+		ot_rpc_report_cmd_decoding_error(OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME);
+		return;
+	}
+
+	openthread_api_mutex_lock(openthread_get_default_context());
+	time = otLinkRawGetRadioTime(openthread_get_default_instance());
+	openthread_api_mutex_unlock(openthread_get_default_context());
+
+	NRF_RPC_CBOR_ALLOC(group, rsp_ctx, 1 + sizeof(time));
+	nrf_rpc_encode_uint64(&rsp_ctx, time);
+	nrf_rpc_cbor_rsp_no_err(group, &rsp_ctx);
+}
+
+NRF_RPC_CBOR_CMD_DECODER(ot_group, ot_rpc_cmd_get_radio_time, OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME,
+			 ot_rpc_cmd_get_radio_time, NULL);

tests/subsys/net/openthread/rpc/client/src/link_raw_suite.c

@@ -0,0 +1,53 @@
+/*
+ * Copyright (c) 2024 Nordic Semiconductor ASA
+ *
+ * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
+ */
+
+#include <mock_nrf_rpc_transport.h>
+#include <ot_rpc_ids.h>
+#include <test_rpc_env.h>
+
+#include <zephyr/ztest.h>
+#include <zephyr/kernel.h>
+
+#include <openthread/link_raw.h>
+
+static void nrf_rpc_err_handler(const struct nrf_rpc_err_report *report)
+{
+	zassert_ok(report->code);
+}
+
+static void tc_setup(void *f)
+{
+	mock_nrf_rpc_tr_expect_add(RPC_INIT_REQ, RPC_INIT_RSP);
+	zassert_ok(nrf_rpc_init(nrf_rpc_err_handler));
+	mock_nrf_rpc_tr_expect_reset();
+}
+
+/* Test serialization of otLinkRawGetRadioTime() which returns 0 */
+ZTEST(ot_rpc_link_raw, test_otLinkRawGetRadioTime_0)
+{
+	uint64_t time;
+
+	mock_nrf_rpc_tr_expect_add(RPC_CMD(OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME), RPC_RSP(0));
+	time = otLinkRawGetRadioTime(NULL);
+	mock_nrf_rpc_tr_expect_done();
+
+	zassert_equal(time, 0);
+}
+
+/* Test serialization of otLinkRawGetRadioTime() which returns UINT64_MAX */
+ZTEST(ot_rpc_link_raw, test_otLinkRawGetRadioTime_max)
+{
+	uint64_t time;
+
+	mock_nrf_rpc_tr_expect_add(RPC_CMD(OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME),
+				   RPC_RSP(CBOR_UINT64(UINT64_MAX)));
+	time = otLinkRawGetRadioTime(NULL);
+	mock_nrf_rpc_tr_expect_done();
+
+	zassert_equal(time, UINT64_MAX);
+}
+
+ZTEST_SUITE(ot_rpc_link_raw, NULL, NULL, tc_setup, NULL, NULL);

tests/subsys/net/openthread/rpc/server/src/link_raw_suite.c

@@ -0,0 +1,68 @@
+/*
+ * Copyright (c) 2025 Nordic Semiconductor ASA
+ *
+ * SPDX-License-Identifier: LicenseRef-Nordic-5-Clause
+ */
+
+#include <mock_nrf_rpc_transport.h>
+#include <ot_rpc_ids.h>
+#include <test_rpc_env.h>
+
+#include <zephyr/fff.h>
+#include <zephyr/ztest.h>
+#include <zephyr/kernel.h>
+
+#include <openthread/link_raw.h>
+
+/* Fake functions */
+
+FAKE_VALUE_FUNC(uint64_t, otLinkRawGetRadioTime, otInstance *);
+
+#define FOREACH_FAKE(f) f(otLinkRawGetRadioTime);
+
+static void nrf_rpc_err_handler(const struct nrf_rpc_err_report *report)
+{
+	zassert_ok(report->code);
+}
+
+static void tc_setup(void *f)
+{
+	mock_nrf_rpc_tr_expect_add(RPC_INIT_REQ, RPC_INIT_RSP);
+	zassert_ok(nrf_rpc_init(nrf_rpc_err_handler));
+	mock_nrf_rpc_tr_expect_reset();
+
+	FOREACH_FAKE(RESET_FAKE);
+	FFF_RESET_HISTORY();
+}
+
+/*
+ * Test reception of otLinkRawGetRadioTime() command.
+ * Test serialization of the result: 0.
+ */
+ZTEST(ot_rpc_link_raw, test_otLinkRawGetRadioTime_0)
+{
+	otLinkRawGetRadioTime_fake.return_val = 0;
+
+	mock_nrf_rpc_tr_expect_add(RPC_RSP(0), NO_RSP);
+	mock_nrf_rpc_tr_receive(RPC_CMD(OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME));
+	mock_nrf_rpc_tr_expect_done();
+
+	zassert_equal(otLinkRawGetRadioTime_fake.call_count, 1);
+}
+
+/*
+ * Test reception of otLinkRawGetRadioTime() command.
+ * Test serialization of the result: UINT64_MAX.
+ */
+ZTEST(ot_rpc_link_raw, test_otLinkRawGetRadioTime_max)
+{
+	otLinkRawGetRadioTime_fake.return_val = UINT64_MAX;
+
+	mock_nrf_rpc_tr_expect_add(RPC_RSP(CBOR_UINT64(UINT64_MAX)), NO_RSP);
+	mock_nrf_rpc_tr_receive(RPC_CMD(OT_RPC_CMD_LINK_RAW_GET_RADIO_TIME));
+	mock_nrf_rpc_tr_expect_done();
+
+	zassert_equal(otLinkRawGetRadioTime_fake.call_count, 1);
+}
+
+ZTEST_SUITE(ot_rpc_link_raw, NULL, NULL, tc_setup, NULL, NULL);