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

server: access callback lists solely under lock

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2022-06-01 11:00:49 +02:00 committed by Thomas Schoebel-Theuer
parent 5a659a0441
commit b395c4bdcc
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
kernel/mars_server.c
View File

@ -111,17 +111,20 @@ int cb_thread(void *data)
brick->cb_running = true;
wake_up_interruptible(&brick->startup_event);
while (!brick_thread_should_stop() || !list_empty(&brick->cb_read_list) || !list_empty(&brick->cb_write_list) || atomic_read(&brick->in_flight) > 0) {
while (!brick_thread_should_stop() ||
atomic_read(&brick->in_flight) > 0) {
struct server_mref_aspect *mref_a;
struct mref_object *mref;
struct list_head *tmp;
unsigned long wait_jiffies =
brick_thread_should_stop() ? 1 * HZ : 2;
bool cork;
wait_event_interruptible_timeout(
brick->cb_event,
!list_empty(&brick->cb_read_list) ||
!list_empty(&brick->cb_write_list),
1 * HZ);
atomic_read(&brick->in_flight) > 0,
wait_jiffies);
/* Try to get the next request for callback over
* the network.