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

Merge pull request #477 from mmkayPL/per-queue-seq-cutoff-locks

Browse Source 
Use read/write locks in queue sequential cutoffs
This commit is contained in:
Robert Baldyga 2021-03-23 13:54:27 +01:00 committed by GitHub
commit b12e124954
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/ocf_seq_cutoff.c
View File

@ -204,9 +204,11 @@ bool ocf_core_seq_cutoff_check(ocf_core_t core, struct ocf_request *req)
return false; return false;
} }
env_rwlock_read_lock(&req->io_queue->seq_cutoff->lock);
result = ocf_core_seq_cutoff_base_check(req->io_queue->seq_cutoff, result = ocf_core_seq_cutoff_base_check(req->io_queue->seq_cutoff,
req->byte_position, req->byte_length, req->rw, req->byte_position, req->byte_length, req->rw,
threshold, &queue_stream); threshold, &queue_stream);
env_rwlock_read_unlock(&req->io_queue->seq_cutoff->lock);
if (queue_stream) if (queue_stream)
return result; return result;
@ -319,8 +321,10 @@ void ocf_core_seq_cutoff_update(ocf_core_t core, struct ocf_request *req)
return; return;
} }
env_rwlock_write_lock(&req->io_queue->seq_cutoff->lock);
stream = ocf_core_seq_cutoff_base_update(req->io_queue->seq_cutoff, stream = ocf_core_seq_cutoff_base_update(req->io_queue->seq_cutoff,
req->byte_position, req->byte_length, req->rw, true); req->byte_position, req->byte_length, req->rw, true);
env_rwlock_write_unlock(&req->io_queue->seq_cutoff->lock);
if (stream->bytes >= threshold) if (stream->bytes >= threshold)
promote = true; promote = true;
@ -330,8 +334,10 @@ void ocf_core_seq_cutoff_update(ocf_core_t core, struct ocf_request *req)
if (promote) { if (promote) {
env_rwlock_write_lock(&core->seq_cutoff->lock); env_rwlock_write_lock(&core->seq_cutoff->lock);
env_rwlock_write_lock(&req->io_queue->seq_cutoff->lock);
ocf_core_seq_cutoff_base_promote(core->seq_cutoff, ocf_core_seq_cutoff_base_promote(core->seq_cutoff,
req->io_queue->seq_cutoff, stream); req->io_queue->seq_cutoff, stream);
env_rwlock_write_unlock(&req->io_queue->seq_cutoff->lock);
env_rwlock_write_unlock(&core->seq_cutoff->lock); env_rwlock_write_unlock(&core->seq_cutoff->lock);
} }
} }