tyler.durden/icinga2
1
0
Fork 0
mirror of https://github.com/Icinga/icinga2.git synced 2025-07-23 13:45:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove unused IoBoundWorkSlot

Browse Source
This commit is contained in:
Alexander A. Klimov 2024-02-07 10:59:49 +01:00
parent 3d5e031adf
commit eb4e601eaf
2 changed files with 0 additions and 43 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
lib/base/io-engine.cpp
View File

@ -50,29 +50,6 @@ void CpuBoundWork::Done()
} }
} }
IoBoundWorkSlot::IoBoundWorkSlot(boost::asio::yield_context yc)
: yc(yc)
{
IoEngine::Get().m_CpuBoundSemaphore.fetch_add(1);
}
IoBoundWorkSlot::~IoBoundWorkSlot()
{
auto& ioEngine (IoEngine::Get());
for (;;) {
auto availableSlots (ioEngine.m_CpuBoundSemaphore.fetch_sub(1));
if (availableSlots < 1) {
ioEngine.m_CpuBoundSemaphore.fetch_add(1);
IoEngine::YieldCurrentCoroutine(yc);
continue;
}
break;
}
}
LazyInit<std::unique_ptr<IoEngine>> IoEngine::m_Instance ([]() { return std::unique_ptr<IoEngine>(new IoEngine()); }); LazyInit<std::unique_ptr<IoEngine>> IoEngine::m_Instance ([]() { return std::unique_ptr<IoEngine>(new IoEngine()); });
IoEngine& IoEngine::Get() IoEngine& IoEngine::Get()

20
lib/base/io-engine.hpp
View File

@ -50,25 +50,6 @@ private:
bool m_Done; bool m_Done;
}; };
/**
* Scope break for CPU-bound work done in an I/O thread
*
* @ingroup base
*/
class IoBoundWorkSlot
{
public:
IoBoundWorkSlot(boost::asio::yield_context yc);
IoBoundWorkSlot(const IoBoundWorkSlot&) = delete;
IoBoundWorkSlot(IoBoundWorkSlot&&) = delete;
IoBoundWorkSlot& operator=(const IoBoundWorkSlot&) = delete;
IoBoundWorkSlot& operator=(IoBoundWorkSlot&&) = delete;
~IoBoundWorkSlot();
private:
boost::asio::yield_context yc;
};
/** /**
* Async I/O engine * Async I/O engine
* *
@ -77,7 +58,6 @@ private:
class IoEngine class IoEngine
{ {
friend CpuBoundWork; friend CpuBoundWork;
friend IoBoundWorkSlot;
public: public:
IoEngine(const IoEngine&) = delete; IoEngine(const IoEngine&) = delete;