adafruit-mirror/zephyr
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 9

modem: chat: implement buffer stats

Browse source 
implement buffer statistics for modem_chat module.

Signed-off-by: Bjarki Arge Andreasen <bjarki@arge-andreasen.me>
This commit is contained in:
Bjarki Arge Andreasen 2024-05-14 13:27:13 +02:00 committed by Johan Hedberg
parent 88bb45082a
commit 5e193edbc3
2 changed files with 71 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
include/zephyr/modem/chat.h
View file

@ -10,6 +10,7 @@
#include <zephyr/sys/ring_buffer.h>
#include <zephyr/modem/pipe.h>
#include <zephyr/modem/stats.h>
#ifndef ZEPHYR_MODEM_CHAT_
#define ZEPHYR_MODEM_CHAT_
@ -269,6 +270,12 @@ struct modem_chat {
/* Process received data */
struct k_work receive_work;
/* Statistics */
#if CONFIG_MODEM_STATS
struct modem_stats_buffer receive_buf_stats;
struct modem_stats_buffer work_buf_stats;
#endif
};
/**

64
subsys/modem/modem_chat.c
View file

@ -356,8 +356,27 @@ static void modem_chat_script_send_timeout_handler(struct k_work *item)
modem_chat_script_next(chat, false);
}
#if CONFIG_MODEM_STATS
static uint32_t get_receive_buf_length(struct modem_chat *chat)
{
return chat->receive_buf_len;
}
static void advertise_receive_buf_stats(struct modem_chat *chat)
{
uint32_t length;
length = get_receive_buf_length(chat);
modem_stats_buffer_advertise_length(&chat->receive_buf_stats, length);
}
#endif
static void modem_chat_parse_reset(struct modem_chat *chat)
{
#if CONFIG_MODEM_STATS
advertise_receive_buf_stats(chat);
#endif
/* Reset parameters used for parsing */
chat->receive_buf_len = 0;
chat->delimiter_match_len = 0;
@ -685,6 +704,21 @@ static void modem_chat_process_bytes(struct modem_chat *chat)
}
}
#if CONFIG_MODEM_STATS
static uint32_t get_work_buf_length(struct modem_chat *chat)
{
return chat->work_buf_len;
}
static void advertise_work_buf_stats(struct modem_chat *chat)
{
uint32_t length;
length = get_work_buf_length(chat);
modem_stats_buffer_advertise_length(&chat->work_buf_stats, length);
}
#endif
static void modem_chat_process_handler(struct k_work *item)
{
struct modem_chat *chat = CONTAINER_OF(item, struct modem_chat, receive_work);
@ -699,6 +733,10 @@ static void modem_chat_process_handler(struct k_work *item)
/* Save received data length */
chat->work_buf_len = (size_t)ret;
#if CONFIG_MODEM_STATS
advertise_work_buf_stats(chat);
#endif
/* Process data */
modem_chat_process_bytes(chat);
k_work_submit(&chat->receive_work);
@ -723,6 +761,28 @@ static void modem_chat_pipe_callback(struct modem_pipe *pipe, enum modem_pipe_ev
}
}
#if CONFIG_MODEM_STATS
static uint32_t get_receive_buf_size(struct modem_chat *chat)
{
return chat->receive_buf_size;
}
static uint32_t get_work_buf_size(struct modem_chat *chat)
{
return sizeof(chat->work_buf);
}
static void init_buf_stats(struct modem_chat *chat)
{
uint32_t size;
size = get_receive_buf_size(chat);
modem_stats_buffer_init(&chat->receive_buf_stats, "chat_rx", size);
size = get_work_buf_size(chat);
modem_stats_buffer_init(&chat->work_buf_stats, "chat_work", size);
}
#endif
int modem_chat_init(struct modem_chat *chat, const struct modem_chat_config *config)
{
__ASSERT_NO_MSG(chat != NULL);
@ -759,6 +819,10 @@ int modem_chat_init(struct modem_chat *chat, const struct modem_chat_config *con
k_work_init_delayable(&chat->script_send_timeout_work,
modem_chat_script_send_timeout_handler);
#if CONFIG_MODEM_STATS
init_buf_stats(chat);
#endif
return 0;
}