RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2025-01-12 18:01:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

client: fix list corruption

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2022-02-17 17:14:17 +01:00 committed by Thomas Schoebel-Theuer
parent d821ed0a37
commit b5e556e902
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
kernel/mars_client.c
View File

@ -564,7 +564,6 @@ int receiver_thread(void *data)
atomic_inc(&brick->receiver_count);
while (brick->power.button && !brick_thread_should_stop()) {
struct mars_cmd cmd = {};
struct list_head *tmp;
if (ch->recv_error) {
/* The protocol may be out of sync.
@ -606,6 +605,9 @@ int receiver_thread(void *data)
break;
case CMD_CB:
{
struct list_head *anchor;
struct list_head *tmp;
struct list_head *tmp_next;
struct mref_object *mref = NULL;
struct client_mref_aspect *mref_a = NULL;
unsigned long id = READ_ONCE(cmd.cmd_int1);
@ -613,7 +615,10 @@ int receiver_thread(void *data)
bool had_completed = false;
mutex_lock(&output->mutex);
for (tmp = output->hash_table[hash_index].next; tmp != &output->hash_table[hash_index]; tmp = tmp->next) {
anchor = &output->hash_table[hash_index];
for (tmp = READ_ONCE(anchor->next), tmp_next = READ_ONCE(tmp->next);
tmp != anchor;
tmp = tmp_next, tmp_next = READ_ONCE(tmp_next->next)) {
struct mref_object *tmp_mref;
struct client_mref_aspect *tmp_mref_a;