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

copy: make fly limitation global

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2017-04-11 08:27:24 +02:00
parent b7a770c91f
commit 71bc90cc71
2 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
kernel/mars_copy.c
View File

@ -71,11 +71,14 @@ EXPORT_SYMBOL_GPL(mars_copy_read_max_fly);
int mars_copy_write_max_fly = 0;
EXPORT_SYMBOL_GPL(mars_copy_write_max_fly);
atomic_t global_copy_read_flight;
atomic_t global_copy_write_flight;
#define is_read_limited(brick) \
(mars_copy_read_max_fly > 0 && atomic_read(&(brick)->copy_read_flight) >= mars_copy_read_max_fly)
(mars_copy_read_max_fly > 0 && atomic_read(&global_copy_read_flight) >= mars_copy_read_max_fly)
#define is_write_limited(brick) \
(mars_copy_write_max_fly > 0 && atomic_read(&(brick)->copy_write_flight) >= mars_copy_write_max_fly)
(mars_copy_write_max_fly > 0 && atomic_read(&global_copy_write_flight) >= mars_copy_write_max_fly)
///////////////////////// own helper functions ////////////////////////
@ -260,8 +263,10 @@ exit:
}
if (mref->ref_rw) {
atomic_dec(&brick->copy_write_flight);
atomic_dec(&global_copy_write_flight);
} else {
atomic_dec(&brick->copy_read_flight);
atomic_dec(&global_copy_read_flight);
}
brick->trigger = true;
wake_up_interruptible(&brick->event);
@ -338,8 +343,10 @@ int _make_mref(struct copy_brick *brick, int index, int queue, void *data, loff_
GET_STATE(brick, index).active[queue] = true;
if (rw) {
atomic_inc(&brick->copy_write_flight);
atomic_inc(&global_copy_write_flight);
} else {
atomic_inc(&brick->copy_read_flight);
atomic_inc(&global_copy_read_flight);
}
GENERIC_INPUT_CALL(input, mref_io, mref);

3
kernel/mars_copy.h
View File

@ -39,6 +39,9 @@ extern int mars_copy_write_prio;
extern int mars_copy_read_max_fly;
extern int mars_copy_write_max_fly;
extern atomic_t global_copy_read_flight;
extern atomic_t global_copy_write_flight;
enum {
COPY_STATE_RESET = -1,
COPY_STATE_START = 0, // don't change this, it _must_ be zero