thebestvibedev/tromcho.net
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove unused SUBMIT_SCRUB_READ

Browse Source
This commit is contained in:
Vitaliy Filippov
2025-08-30 16:30:52 +03:00
parent 9f2dc48d0f
commit 47c7aa62de
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/osd/osd_primary.h
-1
View File
@@ -9,7 +9,6 @@
#define SUBMIT_READ 0 #define SUBMIT_READ 0
#define SUBMIT_RMW_READ 1 #define SUBMIT_RMW_READ 1
#define SUBMIT_WRITE 2 #define SUBMIT_WRITE 2
#define SUBMIT_SCRUB_READ 3
struct unstable_osd_num_t struct unstable_osd_num_t
{ {
src/osd/osd_primary_subops.cpp
+2 -2
View File
@@ -153,13 +153,13 @@ int osd_t::submit_primary_subop_batch(int submit_type, inode_t inode, uint64_t o
for (int role = 0; role < (op_data->pg ? op_data->pg->pg_size : 1); role++) for (int role = 0; role < (op_data->pg ? op_data->pg->pg_size : 1); role++)
{ {
// We always submit zero-length writes to all replicas, even if the stripe is not modified // We always submit zero-length writes to all replicas, even if the stripe is not modified
if (!(wr || !rep && stripes[role].read_end != 0 || zero_read == role || submit_type == SUBMIT_SCRUB_READ)) if (!(wr || !rep && stripes[role].read_end != 0 || zero_read == role))
{ {
continue; continue;
} }
osd_num_t role_osd_num = osd_set[role]; osd_num_t role_osd_num = osd_set[role];
int stripe_num = rep ? 0 : role; int stripe_num = rep ? 0 : role;
osd_rmw_stripe_t *si = stripes + (submit_type == SUBMIT_SCRUB_READ ? role : stripe_num); osd_rmw_stripe_t *si = stripes + stripe_num;
if (role_osd_num != 0) if (role_osd_num != 0)
{ {
si->osd_num = role_osd_num; si->osd_num = role_osd_num;