RepoMirrors
/
mars
mirror of https://github.com/schoebel/mars
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

client: speedup hashing

This commit is contained in:
Thomas Schoebel-Theuer 2023-05-16 09:33:23 +02:00
parent ada1544100
commit f5fa4a19c1
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
kernel/mars_client.c
View File

@ -563,6 +563,9 @@ void __hash_insert(struct client_output *output,
int ref_id; int ref_id;
unsigned int hash_index; unsigned int hash_index;
if (mref_a->is_hashed)
return;
list_del(&mref_a->hash_head); list_del(&mref_a->hash_head);
ref_id = READ_ONCE(mref->ref_id); ref_id = READ_ONCE(mref->ref_id);
if (!ref_id) { if (!ref_id) {
@ -575,6 +578,7 @@ void __hash_insert(struct client_output *output,
} }
hash_index = CLIENT_HASH_FN(ref_id); hash_index = CLIENT_HASH_FN(ref_id);
list_add_tail(&mref_a->hash_head, &output->hash_table[hash_index]); list_add_tail(&mref_a->hash_head, &output->hash_table[hash_index]);
mref_a->is_hashed = true;
} }
static static
@ -729,6 +733,7 @@ int receiver_thread(void *data)
mref_a = tmp_mref_a; mref_a = tmp_mref_a;
mref = tmp_mref; mref = tmp_mref;
list_del_init(&mref_a->hash_head); list_del_init(&mref_a->hash_head);
mref_a->is_hashed = false;
list_del_init(&mref_a->io_head); list_del_init(&mref_a->io_head);
/* Networking produces inherent races between re-submission and /* Networking produces inherent races between re-submission and
* completion. Compensate them here. * completion. Compensate them here.
@ -890,6 +895,7 @@ void _do_timeout(struct client_output *output, struct list_head *anchor, int *ro
continue; continue;
list_del_init(&mref_a->hash_head); list_del_init(&mref_a->hash_head);
mref_a->is_hashed = false;
list_del_init(&mref_a->io_head); list_del_init(&mref_a->io_head);
mref_a->has_completed = true; mref_a->has_completed = true;

1
kernel/mars_client.h
View File

@ -48,6 +48,7 @@ struct client_mref_aspect {
int alloc_len; int alloc_len;
bool do_dealloc; bool do_dealloc;
bool has_completed; bool has_completed;
bool is_hashed;
}; };
struct client_brick { struct client_brick {