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

ircd::db: Give some env callbacks handlers.

Browse source
This commit is contained in:
Jason Volk 2018-08-23 18:57:24 -07:00
parent bbcddbcf5b
commit ec0670262e
1 changed files with 18 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
ircd/db.cc
View file

@ -1873,7 +1873,7 @@ rocksdb::Status
ircd::db::database::env::NewSequentialFile(const std::string& name, ircd::db::database::env::NewSequentialFile(const std::string& name,
std::unique_ptr<SequentialFile> *const r, std::unique_ptr<SequentialFile> *const r,
const EnvOptions &options) const EnvOptions &options)
noexcept noexcept try
{ {
#ifdef RB_DEBUG_DB_ENV #ifdef RB_DEBUG_DB_ENV
log::debug log::debug
@ -1888,12 +1888,20 @@ noexcept
*r = std::make_unique<sequential_file>(&d, name, options); *r = std::make_unique<sequential_file>(&d, name, options);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e)
{
return error_to_status{e};
}
catch(const std::exception &e)
{
return error_to_status{e};
}
rocksdb::Status rocksdb::Status
ircd::db::database::env::NewRandomAccessFile(const std::string& name, ircd::db::database::env::NewRandomAccessFile(const std::string& name,
std::unique_ptr<RandomAccessFile> *const r, std::unique_ptr<RandomAccessFile> *const r,
const EnvOptions &options) const EnvOptions &options)
noexcept noexcept try
{ {
ctx::uninterruptible::nothrow ui; ctx::uninterruptible::nothrow ui;
@ -1910,6 +1918,14 @@ noexcept
*r = std::make_unique<random_access_file>(&d, name, options); *r = std::make_unique<random_access_file>(&d, name, options);
return Status::OK(); return Status::OK();
} }
catch(const fs::error &e)
{
return error_to_status{e};
}
catch(const std::exception &e)
{
return error_to_status{e};
}
rocksdb::Status rocksdb::Status
ircd::db::database::env::NewWritableFile(const std::string& name, ircd::db::database::env::NewWritableFile(const std::string& name,