meshx_nvs.h File Reference

Header file for MeshX Non-Volatile Storage (NVS) operations. More...

#include <stdint.h>
#include "meshx_control_task.h"
#include "meshx_os_timer.h"

Include dependency graph for meshx_nvs.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	meshx_nvs
	Structure to hold the MeshX NVS data. More...

Macros
#define	MESHX_NVS_TIMER_PERIOD_DEF   1000
#define	MESHX_NVS_TIMER_PERIOD   MESHX_NVS_TIMER_PERIOD_DEF
#define	MESHX_NVS_AUTO_COMMIT   true
#define	MESHX_NVS_NO_AUTO_COMMIT   false

Typedefs
typedef struct meshx_nvs	meshx_nvs_t

Functions
meshx_err_t	meshx_nvs_init (void)
	MeshX NVS Initialisation.
meshx_err_t	meshx_nvs_erase (void)
	Erase all key-value pairs stored in the NVS.
meshx_err_t	meshx_nvs_commit (void)
	Commit changes to the NVS.
meshx_err_t	meshx_nvs_close (void)
	Close the NVS handle.
meshx_err_t	meshx_nvs_remove (char const *key)
	Remove a key-value pair from the NVS.
meshx_err_t	meshx_nvs_open (uint16_t cid, uint16_t pid, uint32_t commit_timeout_ms)
	Open the NVS with a timeout.
meshx_err_t	meshx_nvs_get (char const *key, void *blob, uint16_t blob_size)
	Get a value from the NVS.
meshx_err_t	meshx_nvs_set (char const *key, void const *blob, uint16_t blob_size, bool arm_timer)
	Set a value in the NVS.
meshx_err_t	meshx_nvs_element_ctx_get (uint16_t element_id, void *blob, size_t blob_size)
	Retrieve the context of a specific element from NVS.
meshx_err_t	meshx_nvs_element_ctx_set (uint16_t element_id, const void *blob, size_t blob_size)
	Store the context of a specific element to NVS.
meshx_err_t	meshx_nvs_element_ctx_remove (uint16_t element_id)
	Remove the context of a specific element from NVS.

Detailed Description

Header file for MeshX Non-Volatile Storage (NVS) operations.

This file provides APIs to manage the Non-Volatile Storage (NVS) used in the MeshX system. It includes functions to read, write, erase, and manage key-value pairs stored persistently.

Author

Pranjal Chanda

Definition in file meshx_nvs.h.

Macro Definition Documentation

MESHX_NVS_AUTO_COMMIT

#define MESHX_NVS_AUTO_COMMIT   true

Definition at line 25 of file meshx_nvs.h.

MESHX_NVS_NO_AUTO_COMMIT

#define MESHX_NVS_NO_AUTO_COMMIT   false

Definition at line 26 of file meshx_nvs.h.

MESHX_NVS_TIMER_PERIOD

#define MESHX_NVS_TIMER_PERIOD   MESHX_NVS_TIMER_PERIOD_DEF

Definition at line 22 of file meshx_nvs.h.

MESHX_NVS_TIMER_PERIOD_DEF

#define MESHX_NVS_TIMER_PERIOD_DEF   1000

Definition at line 19 of file meshx_nvs.h.

Typedef Documentation

meshx_nvs_t

typedef struct meshx_nvs meshx_nvs_t

Function Documentation

meshx_nvs_close()

meshx_err_t meshx_nvs_close

(

void

)

Close the NVS handle.

This function releases any resources associated with the NVS handle.

Returns

• MESHX_SUCCESS: Success.

Definition at line 297 of file meshx_nvs.c.

{
    meshx_err_t err = MESHX_SUCCESS;
    if (meshx_nvs_inst.init != MESHX_NVS_INIT_MAGIC)
        return MESHX_INVALID_STATE;
 
    err = meshx_nvs_plat_close(meshx_nvs_inst.meshx_nvs_handle);
    if (err)
    {
        MESHX_LOGE(MODULE_ID_COMPONENT_MESHX_NVS, "nvs_close %p", (void *)err);
    }
 
#if MESHX_NVS_TIMER_PERIOD
    err = meshx_os_timer_delete(&(meshx_nvs_inst.meshx_nvs_commit_tmr));
#endif /* MESHX_NVS_TIMER_PERIOD */
    meshx_nvs_inst.init = 0;
    return err;
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_commit()

meshx_err_t meshx_nvs_commit

(

void

)

Commit changes to the NVS.

This function ensures that any pending changes to the NVS are flushed to persistent storage.

Returns

• MESHX_SUCCESS: Success.

Definition at line 259 of file meshx_nvs.c.

{
    if (meshx_nvs_inst.init != MESHX_NVS_INIT_MAGIC)
        return MESHX_INVALID_STATE;
 
    meshx_err_t err = MESHX_SUCCESS;
    meshx_nvs_write_list_t *cur = meshx_nvs_write_list_head;
    meshx_nvs_write_list_t *prev;
 
    while (cur) {
        err = meshx_nvs_plat_write(meshx_nvs_inst.meshx_nvs_handle, cur->key, cur->data, cur->len);
        if (err) {
            MESHX_LOGE(MODULE_ID_COMPONENT_MESHX_NVS, "commit failed for key: %s", cur->key);
        }
        prev = cur;
        cur = cur->next;
        free(prev);
    }
 
    meshx_nvs_write_list_head = NULL;
 
    if (err == MESHX_SUCCESS) {
        // Only commit to platform once, after all writes
        err = meshx_nvs_plat_commit(meshx_nvs_inst.meshx_nvs_handle);
    }
 
    return err;
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_element_ctx_get()

meshx_err_t meshx_nvs_element_ctx_get	(	uint16_t	element_id,
		void *	blob,
		size_t	blob_size )

Retrieve the context of a specific element from NVS.

This function fetches the stored context of a given element identified by its ID from the Non-Volatile Storage (NVS).

Parameters

[in]	element_id	The ID of the element whose context is to be retrieved.
[out]	blob	Pointer to the buffer where the retrieved context will be stored.
[in]	blob_size	Size of the buffer provided to store the context.

Returns

• MESHX_SUCCESS: Successfully retrieved the context.

Definition at line 424 of file meshx_nvs.c.

{
    char key[MESHX_KEY_NAME_MAX_SIZE];
    snprintf(key, MESHX_KEY_NAME_MAX_SIZE, MESHX_NVS_ELEMENT_CTX, element_id);
    return meshx_nvs_get(key, blob, blob_size);
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_element_ctx_remove()

meshx_err_t meshx_nvs_element_ctx_remove

(

uint16_t

element_id

)

Remove the context of a specific element from NVS.

This function deletes the stored context of a given element identified by its ID from the Non-Volatile Storage (NVS).

Parameters

[in]

element_id

The ID of the element whose context is to be removed.

Returns

• MESHX_SUCCESS: Successfully removed the context.

Definition at line 462 of file meshx_nvs.c.

{
    char key[MESHX_KEY_NAME_MAX_SIZE];
    snprintf(key, MESHX_KEY_NAME_MAX_SIZE, MESHX_NVS_ELEMENT_CTX, element_id);
    return meshx_nvs_remove(key);
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_element_ctx_set()

meshx_err_t meshx_nvs_element_ctx_set	(	uint16_t	element_id,
		const void *	blob,
		size_t	blob_size )

Store the context of a specific element to NVS.

This function saves the context of a given element identified by its ID to the Non-Volatile Storage (NVS).

Parameters

[in]	element_id	The ID of the element whose context is to be stored.
[in]	blob	Pointer to the buffer containing the context to be stored.
[in]	blob_size	Size of the buffer containing the context.

Returns

• MESHX_SUCCESS: Successfully stored the context.

Definition at line 444 of file meshx_nvs.c.

{
    char key[MESHX_KEY_NAME_MAX_SIZE];
    snprintf(key, MESHX_KEY_NAME_MAX_SIZE, MESHX_NVS_ELEMENT_CTX, element_id);
    return meshx_nvs_set(key, blob, (uint16_t) blob_size, MESHX_NVS_AUTO_COMMIT);
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_erase()

meshx_err_t meshx_nvs_erase

(

void

)

Erase all key-value pairs stored in the NVS.

This function clears all data stored in the Non-Volatile Storage.

Returns

• MESHX_SUCCESS: Success.

Definition at line 243 of file meshx_nvs.c.

{
    if (meshx_nvs_inst.init != MESHX_NVS_INIT_MAGIC)
        return MESHX_INVALID_STATE;
 
    return meshx_nvs_plat_erase(meshx_nvs_inst.meshx_nvs_handle);
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_get()

meshx_err_t meshx_nvs_get	(	char const *	key,
		void *	blob,
		uint16_t	blob_size )

Get a value from the NVS.

This function retrieves a value associated with the given key from the NVS.

Parameters

[in]	key	The key identifying the value to be retrieved.
[out]	blob	Pointer to the buffer where the value will be stored.
[in]	blob_size	Size of the buffer in bytes.

Returns

• MESHX_SUCCESS: Success.

Definition at line 346 of file meshx_nvs.c.

{
    if (meshx_nvs_inst.init != MESHX_NVS_INIT_MAGIC)
        return MESHX_INVALID_STATE;
    return meshx_nvs_plat_read(meshx_nvs_inst.meshx_nvs_handle, key, blob, blob_size);
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_init()

meshx_err_t meshx_nvs_init

(

void

)

MeshX NVS Initialisation.

Returns

• MESHX_SUCCESS: Success.

Definition at line 135 of file meshx_nvs.c.

{
    meshx_err_t err = MESHX_SUCCESS;
#if CONFIG_ENABLE_UNIT_TEST
    err = register_unit_test(MODULE_ID_COMPONENT_MESHX_NVS, &meshx_nvs_unit_test_cb_handler);
    if (err)
    {
        MESHX_LOGE(MODULE_ID_COMPONENT_MESHX_NVS, "unit_test reg failed: (%d)", err);
        return err;
    }
#endif /* CONFIG_ENABLE_UNIT_TEST */
    return err;
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_open()

meshx_err_t meshx_nvs_open	(	uint16_t	cid,
		uint16_t	pid,
		uint32_t	commit_timeout_ms )

Open the NVS with a timeout.

This function initializes the NVS and sets a timeout for stability operations.

Note

NVS Namespace: MESHX_NVS_NAMESPACE

Parameters

[in]	cid	Company ID
[in]	pid	Product ID
[in]	commit_timeout_ms	Timeout for stability operations in milliseconds.

Note

commit_timeout_ms = 0 -> use MESHX_NVS_TIMER_PERIOD

Returns

• MESHX_SUCCESS: Success.

Definition at line 165 of file meshx_nvs.c.

{
    if (meshx_nvs_inst.init == MESHX_NVS_INIT_MAGIC)
    {
        return MESHX_INVALID_STATE;
    }
 
    meshx_err_t err;
 
    err = meshx_nvs_plat_open(&(meshx_nvs_inst.meshx_nvs_handle));
    if (err)
    {
        MESHX_LOGE(MODULE_ID_COMPONENT_MESHX_NVS, "nvs_open %p", (void *)err);
        return err;
    }
 
#if MESHX_NVS_TIMER_PERIOD
    if(commit_timeout_ms == 0)
    {
        commit_timeout_ms = MESHX_NVS_TIMER_PERIOD;
    }
    err = meshx_os_timer_create(
        MESHX_NVS_TIMER_NAME,
        commit_timeout_ms,
        MESHX_NVS_RELOAD_ONE_SHOT,
        &meshx_nvs_os_timer_cb,
        &(meshx_nvs_inst.meshx_nvs_commit_tmr));
    if (err)
    {
        MESHX_LOGE(MODULE_ID_COMPONENT_MESHX_NVS, "os_timer_create %p", (void *)err);
        return err;
    }
#else
    MESHX_UNUSED(commit_timeout_ms);
#endif /* MESHX_NVS_TIMER_PERIOD */
 
    meshx_nvs_inst.init = MESHX_NVS_INIT_MAGIC;
 
    err = meshx_nvs_get(
        MESHX_NVS_NAMESPACE_CID,
            &(meshx_nvs_inst.cid),
        sizeof(meshx_nvs_inst.cid));
 
    err += meshx_nvs_get(
        MESHX_NVS_NAMESPACE_PID,
            &(meshx_nvs_inst.pid),
        sizeof(meshx_nvs_inst.pid));
 
    if(err != MESHX_SUCCESS)
    {
        MESHX_LOGW(MODULE_ID_COMPONENT_MESHX_NVS, "Product ID not found in NVS reinitializing MeshX NVS");
        err = meshx_nvs_erase_prod_init(cid, pid);
    }
 
    else
    {
        if (meshx_nvs_inst.cid == cid && meshx_nvs_inst.pid == pid)
        {
            MESHX_LOGI(MODULE_ID_COMPONENT_MESHX_NVS, "Product ID match: %x|%x", meshx_nvs_inst.pid, meshx_nvs_inst.cid);
        }
        else
        {
            MESHX_LOGW(MODULE_ID_COMPONENT_MESHX_NVS, "Product ID mismatch: %x|%x", meshx_nvs_inst.pid, meshx_nvs_inst.cid);
            err = meshx_nvs_erase_prod_init(cid, pid);
        }
    }
 
    return err;
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_remove()

meshx_err_t meshx_nvs_remove

(

char const *

key

)

Remove a key-value pair from the NVS.

This function deletes a specific key-value pair from the NVS based on the provided key.

Parameters

[in]

key

The key identifying the value to be removed.

Returns

• MESHX_SUCCESS: Success.

Definition at line 326 of file meshx_nvs.c.

{
    if (meshx_nvs_inst.init != MESHX_NVS_INIT_MAGIC)
        return MESHX_INVALID_STATE;
 
    return meshx_nvs_plat_remove(meshx_nvs_inst.meshx_nvs_handle, key);
}

Here is the call graph for this function:

Here is the caller graph for this function:

meshx_nvs_set()

meshx_err_t meshx_nvs_set	(	char const *	key,
		void const *	blob,
		uint16_t	blob_size,
		bool	arm_timer )

Set a value in the NVS.

This function stores a value associated with the given key in the NVS.

Parameters

[in]	key	The key identifying the value to be stored.
[in]	blob	Pointer to the buffer containing the value.
[in]	blob_size	Size of the buffer in bytes.
[in]	arm_timer	Re-arm stability timer and auto commit

Returns

• MESHX_SUCCESS: Success.

Definition at line 366 of file meshx_nvs.c.

{
    if (meshx_nvs_inst.init != MESHX_NVS_INIT_MAGIC)
        return MESHX_INVALID_STATE;
 
    if (blob_size > MESHX_KEY_VALUE_MAX_SIZE)
        return MESHX_INVALID_ARG;
 
    // Check if key already exists in list → overwrite instead of duplicate
    meshx_nvs_write_list_t *cur = meshx_nvs_write_list_head;
    while (cur) {
        if (strncmp(cur->key, key, MESHX_KEY_NAME_MAX_SIZE-1) == 0)
        {
            cur->key[MESHX_KEY_NAME_MAX_SIZE - 1] = '\0';
            memcpy(cur->data, blob, blob_size);
            cur->len = blob_size;
            goto restart_timer;  // skip new node alloc
        }
        cur = cur->next;
    }
 
    // Allocate new node
    meshx_nvs_write_list_t *node = malloc(sizeof(meshx_nvs_write_list_t));
    if (!node) return MESHX_NO_MEM;
 
    strncpy(node->key, key, MESHX_KEY_NAME_MAX_SIZE);
    memcpy(node->data, blob, blob_size);
    node->len = blob_size;
    node->next = meshx_nvs_write_list_head;
    meshx_nvs_write_list_head = node;
 
restart_timer:
    if (arm_timer)
    {
#if MESHX_NVS_TIMER_PERIOD
        meshx_err_t err = meshx_os_timer_restart(meshx_nvs_inst.meshx_nvs_commit_tmr);
        if (err)
            MESHX_LOGE(MODULE_ID_COMPONENT_MESHX_NVS, "os_timer_restart err: %p", (void*)err);
#endif
    }
 
    return MESHX_SUCCESS;
}

Here is the call graph for this function:

Here is the caller graph for this function: