MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-12-26 15:33:54 +01:00
Code Issues Releases Wiki Activity

ircd::db::env: Add conversion for ioprio value; rename to ionice.

Browse source
This commit is contained in:
Jason Volk 2020-01-06 10:59:22 -08:00
parent 4ef3f6eab7
commit 214d955979
2 changed files with 22 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
ircd/db_env.cc
View file

@ -1217,6 +1217,17 @@ catch(const std::exception &e)
return 0;
}
int8_t
ircd::db::database::env::make_nice(const IOPriority &prio)
{
switch(prio)
{
case IOPriority::IO_HIGH: return -5;
case IOPriority::IO_LOW: return 5;
default: return 0;
}
}
//
// writable_file
//
@ -1580,7 +1591,7 @@ noexcept try
#endif
fs::write_opts wopts;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = this->nodelay;
fs::truncate(fd, size, wopts);
return Status::OK();
@ -1690,7 +1701,7 @@ noexcept try
#endif
fs::write_opts wopts;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = this->nodelay;
const const_buffer buf
{
@ -1754,7 +1765,7 @@ noexcept try
#endif
fs::write_opts wopts;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = this->nodelay;
wopts.offset = offset;
const const_buffer buf
@ -1924,7 +1935,7 @@ ircd::db::database::env::writable_file::_allocate(const size_t &offset,
fs::write_opts wopts;
wopts.offset = allocate_offset;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = this->nodelay;
wopts.keep_size = env_opts.fallocate_with_keep_size;
@ -2044,16 +2055,15 @@ noexcept
#endif
this->prio = prio;
this->ionice = make_nice(prio);
switch(this->prio)
{
case IOPriority::IO_HIGH:
prio_val = -5; //TODO: magic
nodelay = true;
break;
default:
case IOPriority::IO_LOW:
prio_val = 5; //TODO: magic
nodelay = false;
break;
}
@ -2213,7 +2223,7 @@ noexcept try
if(logical_offset > 0 && fs::size(fd) != logical_offset)
{
fs::write_opts wopts;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = true;
fs::truncate(fd, logical_offset, wopts);
}
@ -2265,7 +2275,7 @@ noexcept try
#endif
fs::write_opts wopts;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = true;
fs::truncate(fd, size, wopts);
logical_offset = size;
@ -2699,7 +2709,7 @@ ircd::db::database::env::writable_file_direct::_write__aligned(const const_buffe
assert(aligned(offset));
fs::write_opts wopts;
wopts.priority = this->prio_val;
wopts.priority = this->ionice;
wopts.nodelay = this->nodelay;
wopts.offset = offset;
fs::write(fd, buf, wopts);

4
ircd/db_env.h
View file

@ -34,6 +34,8 @@ struct ircd::db::database::env final
using ThreadStatus = rocksdb::ThreadStatus;
using ThreadStatusUpdater = rocksdb::ThreadStatusUpdater;
static int8_t make_nice(const IOPriority &prio);
static ircd::log::log log;
database &d;
@ -206,7 +208,7 @@ struct ircd::db::database::env::writable_file
rocksdb::EnvOptions env_opts;
fs::fd::opts opts;
IOPriority prio {IO_LOW};
int8_t prio_val {0};
int8_t ionice {0};
bool nodelay {false};
WriteLifeTimeHint hint {WriteLifeTimeHint::WLTH_NOT_SET};
fs::fd fd;