// ============================================================================ // Copyright (C) 2001-2016 by Jozef Starosczyk // ixen@copyhandler.com // // This program is free software; you can redistribute it and/or modify // it under the terms of the GNU Library General Public License // (version 2) as published by the Free Software Foundation; // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU Library General Public // License along with this program; if not, write to the // Free Software Foundation, Inc., // 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. // ============================================================================ #include "stdafx.h" #include "TBufferList.h" #include "TCoreException.h" namespace chcore { TBufferList::TBufferList() : m_eventAllBuffersAccountedFor(true, true) { } void TBufferList::Push(TOverlappedDataBuffer* pBuffer) { if(!pBuffer) throw TCoreException(eErr_InvalidArgument, L"pBuffer", LOCATION); m_listBuffers.push_front(pBuffer); UpdateEvent(); m_notifier(true); } TOverlappedDataBuffer* TBufferList::Pop() { if(m_listBuffers.empty()) return nullptr; TOverlappedDataBuffer* pBuffer = m_listBuffers.front(); m_listBuffers.pop_front(); UpdateEvent(); m_notifier(false); return pBuffer; } void TBufferList::Clear() { bool bRemoved = !m_listBuffers.empty(); m_listBuffers.clear(); if (bRemoved) { UpdateEvent(); m_notifier(false); } } size_t TBufferList::GetCount() const { return m_listBuffers.size(); } bool TBufferList::IsEmpty() const { return m_listBuffers.empty(); } boost::signals2::signal& TBufferList::GetNotifier() { return m_notifier; } void TBufferList::UpdateEvent() { m_eventAllBuffersAccountedFor.SetEvent(m_listBuffers.size() == m_stExpectedBuffers); } }