covid19/CovidBracelet
covid19/CovidBracelet
1
0
Fork 0
mirror of https://github.com/CovidBraceletPrj/CovidBracelet.git synced 2025-01-08 04:14:25 +01:00
Code Releases Activity

Correctly increase sequence number and save storage information to flash

Browse Source
This commit is contained in:
H1ghBre4k3r 2021-03-24 15:44:35 +01:00 committed by Patrick Rathje
parent de21af38f2
commit e74b58aab5
1 changed files with 23 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/storage.c
View File

@ -28,14 +28,9 @@ inline storage_id_t convert_sn_to_storage_id(record_sequence_number_t sn) {
return (storage_id_t)(sn % MAX_CONTACTS) + CONTACTS_OFFSET; return (storage_id_t)(sn % MAX_CONTACTS) + CONTACTS_OFFSET;
} }
void increment_storaed_contact_counter() {
if (contact_information.count >= MAX_CONTACTS) {
contact_information.oldest_contact = sequence_number_increment(contact_information.oldest_contact);
}
}
/** /**
* Load our initial storage information from storage. * Load our initial storage information from flash.
*/ */
int load_storage_information() { int load_storage_information() {
size_t size = sizeof(contact_information); size_t size = sizeof(contact_information);
@ -52,6 +47,26 @@ int load_storage_information() {
return 0; return 0;
} }
/**
* Save our current storage infromation to flash.
*/
int save_storage_information() {
int rc = nvs_write(&fs, STORED_CONTACTS_INFO_ID, &contact_information, sizeof(contact_information));
if(rc <= 0) {
printk("Something went wrong after saving storage information.\n");
}
}
void increment_stored_contact_counter() {
if (contact_information.count >= MAX_CONTACTS) {
contact_information.oldest_contact = sequence_number_increment(contact_information.oldest_contact);
} else {
contact_information.count++;
}
save_storage_information();
}
int init_contact_storage(void) { int init_contact_storage(void) {
int rc = 0; int rc = 0;
struct flash_pages_info info; struct flash_pages_info info;
@ -90,12 +105,12 @@ int load_contact(contact_t* dest, record_sequence_number_t sn) {
} }
int add_contact(contact_t* src) { int add_contact(contact_t* src) {
record_sequence_number_t curr_sn = get_latest_sequence_number() + 1; record_sequence_number_t curr_sn = sequence_number_increment(get_latest_sequence_number());
storage_id_t id = convert_sn_to_storage_id(curr_sn); storage_id_t id = convert_sn_to_storage_id(curr_sn);
int rc = nvs_write(&fs, id, src, sizeof(*src)); int rc = nvs_write(&fs, id, src, sizeof(*src));
if (rc > 0) { if (rc > 0) {
increment_storaed_contact_counter(); increment_stored_contact_counter();
return 0; return 0;
} }
return rc; return rc;