github/ocf
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

seq_cutoff: Ignore invalid streams

Browse Source 
Signed-off-by: Robert Baldyga <robert.baldyga@intel.com>
This commit is contained in:
Robert Baldyga 2021-04-01 18:46:28 +02:00
parent 6603e958bf
commit 9a3f64df28
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/ocf_seq_cutoff.c
View File

@ -31,6 +31,12 @@ static int ocf_seq_cutoff_stream_cmp(struct ocf_rb_node *n1,
struct ocf_seq_cutoff_stream *stream2 = container_of(n2, struct ocf_seq_cutoff_stream *stream2 = container_of(n2,
struct ocf_seq_cutoff_stream, node); struct ocf_seq_cutoff_stream, node);
if (stream1->valid < stream2->valid)
return -1;
if (stream1->valid > stream2->valid)
return 1;
if (stream1->rw < stream2->rw) if (stream1->rw < stream2->rw)
return -1; return -1;
@ -54,12 +60,8 @@ static struct ocf_rb_node *ocf_seq_cutoff_stream_list_find(
node = list_entry(node_list, struct ocf_rb_node, list); node = list_entry(node_list, struct ocf_rb_node, list);
stream = container_of(node, struct ocf_seq_cutoff_stream, node); stream = container_of(node, struct ocf_seq_cutoff_stream, node);
if (stream->valid)
max_stream = stream;
list_for_each_entry(node, node_list, list) { list_for_each_entry(node, node_list, list) {
stream = container_of(node, struct ocf_seq_cutoff_stream, node); stream = container_of(node, struct ocf_seq_cutoff_stream, node);
if (!stream->valid)
continue;
if (!max_stream) if (!max_stream)
max_stream = stream; max_stream = stream;
if (stream->bytes > max_stream->bytes) if (stream->bytes > max_stream->bytes)
@ -161,7 +163,7 @@ static bool ocf_core_seq_cutoff_base_check(struct ocf_seq_cutoff *seq_cutoff,
struct ocf_seq_cutoff_stream **out_stream) struct ocf_seq_cutoff_stream **out_stream)
{ {
struct ocf_seq_cutoff_stream item = { struct ocf_seq_cutoff_stream item = {
.last = addr, .rw = rw .last = addr, .rw = rw, .valid = true
}; };
struct ocf_seq_cutoff_stream *stream; struct ocf_seq_cutoff_stream *stream;
struct ocf_rb_node *node; struct ocf_rb_node *node;
@ -229,7 +231,7 @@ static struct ocf_seq_cutoff_stream *ocf_core_seq_cutoff_base_update(
uint64_t addr, uint32_t len, int rw, bool insert) uint64_t addr, uint32_t len, int rw, bool insert)
{ {
struct ocf_seq_cutoff_stream item = { struct ocf_seq_cutoff_stream item = {
.last = addr, .rw = rw .last = addr, .rw = rw, .valid = true
}; };
struct ocf_seq_cutoff_stream *stream; struct ocf_seq_cutoff_stream *stream;
struct ocf_rb_node *node; struct ocf_rb_node *node;