nf7/nf7
nf7/nf7
1
0
Fork 0
Code Issues 9 Pull Requests Projects 3 Releases 5 Wiki Activity

fix error handling

Browse Source
This commit is contained in:
falsycat 2023-08-16 22:33:33 +09:00
parent 63c4aa078d
commit 1677f92a13
1 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
core/uv/parallelism.cc
View File

@ -56,11 +56,9 @@ try {
logger->Error("an async task threw an exception");
}
});
if (nullptr == work) {
logger_->Error("failed to create a work to be queued");
return;
}
work->queue();
} catch (const Exception&) {
logger_->Error("exception thrown");
} catch (const std::bad_alloc&) {
logger_->Error("memory shortage");
}
@ -69,16 +67,14 @@ void Parallelism::Impl::StartTimer(std::chrono::milliseconds wait, AsyncTask&& t
try {
auto self = shared_from_this();
auto timer = ctx_->Make<uvw::timer_handle>();
if (nullptr == timer) {
logger_->Error("failed to create a timer for delayed async task");
return;
}
timer->on<uvw::timer_event>([this, self, task](auto&, auto& timer) mutable {
timer.close();
QueueWork(std::move(task));
});
timer->start(wait, 0ms);
} catch (const std::bad_alloc&) {
} catch (const Exception&) {
logger_->Error("exception thrown");
} catch (...) {
logger_->Error("memory shortage");
}