Function DEV_WRITE_GUARDED

src/cpp-ethereum/libethereum/BlockQueue.cpp:436–455

{
	bool wasFull = false;
	DEV_WRITE_GUARDED(m_lock)
	{
		DEV_INVARIANT_CHECK;
		wasFull = knownFull();
		if (m_drainingSet.empty())
		{
			m_drainingDifficulty = 0;
			DEV_GUARDED(m_verification)
				o_out = m_verified.dequeueMultiple(min<unsigned>(_max, m_verified.count()));

			for (auto const& bs: o_out)
			{
				// TODO: @optimise use map<h256, bytes> rather than vector<bytes> & set<h256>.
				auto h = bs.verified.info.hash();
				m_drainingSet.insert(h);
				m_drainingDifficulty += bs.verified.info.difficulty();
				m_readySet.erase(h);
			}
		}
	}
	if (wasFull && !knownFull())
		m_onRoomAvailable();
}