michaelh/zephyr
1
0
Fork 0
Code Releases Activity

tests: coap_client: Add testcase for observation

Browse source 
Add test for ongoing observation and cancellation.

Signed-off-by: Seppo Takalo <seppo.takalo@nordicsemi.no>
This commit is contained in:
Seppo Takalo 2024-11-12 16:07:54 +02:00 • committed by Anas Nashif
commit 05a6ba678e
1 changed files with 52 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

52
tests/net/lib/coap_client/src/main.c
View file

@ -390,6 +390,18 @@ static ssize_t z_impl_zsock_recvfrom_custom_fake_duplicate_response(int sock, vo
return ret;
}
static ssize_t z_impl_zsock_recvfrom_custom_fake_observe(int sock, void *buf, size_t max_len,
int flags, struct sockaddr *src_addr,
socklen_t *addrlen)
{
int ret = z_impl_zsock_recvfrom_custom_fake_duplicate_response(sock, buf, max_len, flags,
src_addr, addrlen);
set_next_pending_message_id(get_next_pending_message_id() + 1);
z_impl_zsock_recvfrom_fake.custom_fake = z_impl_zsock_recvfrom_custom_fake_observe;
return ret;
}
extern void net_coap_init(void);
static void *suite_setup(void)
@ -1046,3 +1058,43 @@ ZTEST(coap_client, test_duplicate_response)
zassert_equal(k_sem_take(&sem, K_MSEC(MORE_THAN_EXCHANGE_LIFETIME_MS)), -EAGAIN, "");
}
ZTEST(coap_client, test_observe)
{
struct k_sem sem;
struct sockaddr address = {0};
struct coap_client_option options = {
.code = COAP_OPTION_OBSERVE,
.value[0] = 0,
.len = 1,
};
struct coap_client_request client_request = {
.method = COAP_METHOD_GET,
.confirmable = true,
.path = test_path,
.fmt = COAP_CONTENT_FORMAT_TEXT_PLAIN,
.cb = coap_callback,
.payload = short_payload,
.len = strlen(short_payload),
.options = &options,
.num_options = 1,
.user_data = &sem,
};
zassert_ok(k_sem_init(&sem, 0, 1));
z_impl_zsock_recvfrom_fake.custom_fake = z_impl_zsock_recvfrom_custom_fake_observe;
k_sleep(K_MSEC(1));
zassert_ok(coap_client_req(&client, 0, &address, &client_request, NULL));
zassert_ok(k_sem_take(&sem, K_MSEC(MORE_THAN_EXCHANGE_LIFETIME_MS)));
zassert_ok(k_sem_take(&sem, K_MSEC(MORE_THAN_EXCHANGE_LIFETIME_MS)));
zassert_ok(k_sem_take(&sem, K_MSEC(MORE_THAN_EXCHANGE_LIFETIME_MS)));
coap_client_cancel_requests(&client);
zassert_ok(k_sem_take(&sem, K_MSEC(MORE_THAN_EXCHANGE_LIFETIME_MS)));
zassert_equal(last_response_code, -ECANCELED, "");
zassert_not_ok(k_sem_take(&sem, K_MSEC(MORE_THAN_EXCHANGE_LIFETIME_MS)));
}